Changeset 59f527b6

Timestamp:

2008-01-12T17:24:38Z (17 years ago)

Author:

Wilmer van der Gaast <wilmer@…>

Branches:

master

Children:

fc0cf92

Parents:

e64de00

Message:

When a switchboard connection dies (at the TCP level) and there are still
queued messages, they will now be moved back to the main queue and a new
sb will be created to try to send the messages again. I hope this will
solve some/most/all of the "Closing switchboard with unsent messages"
problems, but can't be sure since this problem isn't very easy to reproduce.
At least it should solve the ones caused by keeping spare switchboards
around. Also enabling switchboard debugging output if configured with
--debug=1, at least for now this will be useful.

Location:

protocols/msn

Files:

• msn.h (modified) (2 diffs)
• sb.c (modified) (2 diffs)

protocols/msn/msn.h

@@ -29 +29 @@
 #define GROUPCHAT_SWITCHBOARD_MESSAGE "\r\r\rME WANT TALK TO MANY PEOPLE\r\r\r"
 
-#ifdef _WIN32
-#define debug 
+#ifdef DEBUG
+#define debug( text... ) imcb_log( ic, text );
 #else
-#define debug( text... ) irc_usermsg( IRC, text );
-#undef debug
 #define debug( text... )
 #endif
@@ -66 +64 @@
         GSList *msgq;
         GSList *switchboards;
+        int sb_failures;
+        time_t first_sb_failure;
+        
         const struct msn_away_state *away_state;
-        
         int buddycount;
         int groupcount;

protocols/msn/sb.c

@@ -277 +277 @@
 {
         struct msn_switchboard *sb = data;
+        struct im_connection *ic = sb->ic;
+        struct msn_data *md = ic->proto_data;
         
         if( msn_handler( sb->handler ) == -1 )
         {
+                time_t now = time( NULL );
+                
+                if( now - md->first_sb_failure > 600 )
+                {
+                        /* It's not really the first one, but the start of this "series".
+                           With this, the warning below will be shown only if this happens
+                           at least three times in ten minutes. This algorithm isn't
+                           perfect, but for this purpose it will do. */
+                        md->first_sb_failure = now;
+                        md->sb_failures = 0;
+                }
+                
                 debug( "Error: Switchboard died" );
+                if( ++ md->sb_failures >= 3 )
+                        imcb_log( ic, "Warning: Many switchboard failures on MSN connection. "
+                                      "There might be problems delivering your messages." );
+                
+                if( sb->msgq != NULL )
+                {
+                        char buf[1024];
+                        
+                        if( md->msgq == NULL )
+                        {
+                                md->msgq = sb->msgq;
+                        }
+                        else
+                        {
+                                GSList *l;
+                                
+                                for( l = md->msgq; l->next; l = l->next );
+                                l->next = sb->msgq;
+                        }
+                        sb->msgq = NULL;
+                        
+                        debug( "Moved queued messages back to the main queue, creating a new switchboard to retry." );
+                        g_snprintf( buf, sizeof( buf ), "XFR %d SB\r\n", ++md->trId );
+                        if( !msn_write( ic, buf, strlen( buf ) ) )
+                                return FALSE;
+                }
+                
                 msn_sb_destroy( sb );
                 
@@ -286 +327 @@
         }
         else
+        {
                 return TRUE;
+        }
 }