Changes in irc.c [0356ae3:dd89a55]

File:

• irc.c (modified) (16 diffs)

irc.c

@@ -29 +29 @@
 #include "ipc.h"
 
-static gboolean irc_userping( gpointer _irc, int fd, b_input_condition cond );
+static gboolean irc_userping( gpointer _irc );
 
 GSList *irc_connection_list = NULL;
@@ -54 +54 @@
         
         irc->fd = fd;
-        sock_make_nonblocking( irc->fd );
-        
-        irc->r_watch_source_id = b_input_add( irc->fd, GAIM_INPUT_READ, bitlbee_io_current_client_read, irc );
+        irc->io_channel = g_io_channel_unix_new( fd );
+#ifdef GLIB2
+        g_io_channel_set_encoding (irc->io_channel, NULL, NULL);
+        g_io_channel_set_buffered (irc->io_channel, FALSE);
+        g_io_channel_set_flags( irc->io_channel, G_IO_FLAG_NONBLOCK, NULL );
+#else
+        fcntl( irc->fd, F_SETFL, O_NONBLOCK);
+#endif
+        irc->r_watch_source_id = g_io_add_watch( irc->io_channel, G_IO_IN | G_IO_ERR | G_IO_HUP, bitlbee_io_current_client_read, irc );
         
         irc->status = USTATUS_OFFLINE;
@@ -114 +120 @@
 
         if( global.conf->ping_interval > 0 && global.conf->ping_timeout > 0 )
-                irc->ping_source_id = b_timeout_add( global.conf->ping_interval * 1000, irc_userping, irc );
+                irc->ping_source_id = g_timeout_add( global.conf->ping_interval * 1000, irc_userping, irc );
         
         irc_write( irc, ":%s NOTICE AUTH :%s", irc->myhost, "BitlBee-IRCd initialized, please go on" );
@@ -184 +190 @@
                    bitlbee_.._write doesn't do it first. */
                 
-                b_event_remove( irc->r_watch_source_id );
-                irc->r_watch_source_id = b_timeout_add( 1000, (b_event_handler) irc_free, irc );
+                g_source_remove( irc->r_watch_source_id );
+                irc->r_watch_source_id = g_timeout_add_full( G_PRIORITY_HIGH, 1000, (GSourceFunc) irc_free, irc, NULL );
         }
         else
@@ -218 +224 @@
         
         if( irc->ping_source_id > 0 )
-                b_event_remove( irc->ping_source_id );
-        b_event_remove( irc->r_watch_source_id );
+                g_source_remove( irc->ping_source_id );
+        g_source_remove( irc->r_watch_source_id );
         if( irc->w_watch_source_id > 0 )
-                b_event_remove( irc->w_watch_source_id );
-        
+                g_source_remove( irc->w_watch_source_id );
+        
+        g_io_channel_unref( irc->io_channel );
         irc_connection_list = g_slist_remove( irc_connection_list, irc );
         
@@ -272 +279 @@
                         if(user->host!=user->nick) g_free(user->host);
                         if(user->realname!=user->nick) g_free(user->realname);
-                        b_event_remove(user->sendbuf_timer);
+                        gaim_input_remove(user->sendbuf_timer);
                                         
                         usertmp = user;
@@ -322 +329 @@
         
         if( global.conf->runmode == RUNMODE_INETD || global.conf->runmode == RUNMODE_FORKDAEMON )
-                b_main_quit();
+                g_main_quit( global.loop );
 }
 
@@ -550 +557 @@
         
         u = user_find( irc, irc->mynick );
-        if( u ) is_private = u->is_private;
+        is_private = u->is_private;
         
         va_start( params, format );
@@ -576 +583 @@
         char line[IRC_MAX_LINE+1], *cs;
                 
-        /* Don't try to write anything new anymore when shutting down. */
-        if( irc->status == USTATUS_SHUTDOWN )
+        if( irc->quit )
                 return;
         
@@ -594 +600 @@
         strcat( line, "\r\n" );
         
-        if( irc->sendbuffer != NULL )
-        {
+        if( irc->sendbuffer != NULL ) {
                 size = strlen( irc->sendbuffer ) + strlen( line );
                 irc->sendbuffer = g_renew ( char, irc->sendbuffer, size + 1 );
                 strcpy( ( irc->sendbuffer + strlen( irc->sendbuffer ) ), line );
         }
-        else
-        {
-                irc->sendbuffer = g_strdup(line);
-        }
+        else 
+                irc->sendbuffer = g_strdup(line);       
         
         if( irc->w_watch_source_id == 0 )
         {
-                /* If the buffer is empty we can probably write, so call the write event handler
-                   immediately. If it returns TRUE, it should be called again, so add the event to
-                   the queue. If it's FALSE, we emptied the buffer and saved ourselves some work
-                   in the event queue. */
-                if( bitlbee_io_current_client_write( irc, irc->fd, GAIM_INPUT_WRITE ) )
-                        irc->w_watch_source_id = b_input_add( irc->fd, GAIM_INPUT_WRITE, bitlbee_io_current_client_write, irc );
+                irc->w_watch_source_id = g_io_add_watch( irc->io_channel, G_IO_OUT, bitlbee_io_current_client_write, irc );
         }
         
@@ -638 +636 @@
                 if( now )
                 {
-                        bitlbee_io_current_client_write( irc, irc->fd, GAIM_INPUT_WRITE );
+                        bitlbee_io_current_client_write( irc->io_channel, G_IO_OUT, irc );
                 }
                 temp = temp->next;
@@ -1019 +1017 @@
 }
 
-static gboolean buddy_send_handler_delayed( gpointer data, gint fd, b_input_condition cond )
+gboolean buddy_send_handler_delayed( gpointer data )
 {
         user_t *u = data;
@@ -1032 +1030 @@
         u->sendbuf_flags = 0;
         
-        return FALSE;
+        return( FALSE );
 }
 
@@ -1046 +1044 @@
                 {
                         //Flush the buffer
-                        b_event_remove( u->sendbuf_timer );
-                        buddy_send_handler_delayed( u, -1, 0 );
+                        g_source_remove( u->sendbuf_timer );
+                        buddy_send_handler_delayed( u );
                 }
 
@@ -1071 +1069 @@
                 
                 if( u->sendbuf_timer > 0 )
-                        b_event_remove( u->sendbuf_timer );
-                u->sendbuf_timer = b_timeout_add( delay, buddy_send_handler_delayed, u );
+                        g_source_remove( u->sendbuf_timer );
+                u->sendbuf_timer = g_timeout_add( delay, buddy_send_handler_delayed, u );
         }
         else
@@ -1156 +1154 @@
    pongs from the user. When not connected yet, we don't ping but drop the
    connection when the user fails to connect in IRC_LOGIN_TIMEOUT secs. */
-static gboolean irc_userping( gpointer _irc, gint fd, b_input_condition cond )
+static gboolean irc_userping( gpointer _irc )
 {
         irc_t *irc = _irc;