Changes in / [125b35d:1fc2958]

Files:

• bitlbee.c (modified) (15 diffs)
• bitlbee.h (modified) (4 diffs)
• configure (modified) (6 diffs)
• ipc.c (modified) (10 diffs)
• ipc.h (modified) (1 diff)
• irc.c (modified) (14 diffs)
• irc.h (modified) (2 diffs)
• protocols/Makefile (modified) (1 diff)
• protocols/events.h (deleted)
• protocols/events_glib.c (deleted)
• protocols/events_libevent.c (deleted)
• protocols/http_client.c (modified) (10 diffs)
• protocols/jabber/jabber.c (modified) (9 diffs)
• protocols/msn/msn.c (modified) (1 diff)
• protocols/msn/msn.h (modified) (2 diffs)
• protocols/msn/ns.c (modified) (7 diffs)
• protocols/msn/sb.c (modified) (7 diffs)
• protocols/nogaim.c (modified) (9 diffs)
• protocols/nogaim.h (modified) (1 diff)
• protocols/oscar/oscar.c (modified) (27 diffs)
• protocols/proxy.c (modified) (40 diffs)
• protocols/proxy.h (modified) (3 diffs)
• protocols/ssl_bogus.c (modified) (1 diff)
• protocols/ssl_client.h (modified) (2 diffs)
• protocols/ssl_gnutls.c (modified) (7 diffs)
• protocols/ssl_nss.c (modified) (5 diffs)
• protocols/ssl_openssl.c (modified) (9 diffs)
• protocols/yahoo/yahoo.c (modified) (7 diffs)
• sock.h (modified) (1 diff)
• unix.c (modified) (3 diffs)
• user.c (modified) (1 diff)

bitlbee.c

@@ -34 +34 @@
 #include <errno.h>
 
-static gboolean bitlbee_io_new_client( gpointer data, gint fd, b_input_condition condition );
+gboolean bitlbee_io_new_client( GIOChannel *source, GIOCondition condition, gpointer data );
 
 int bitlbee_daemon_init()
@@ -44 +44 @@
 #endif
         int i;
+        GIOChannel *ch;
         FILE *fp;
         
@@ -90 +91 @@
         }
         
-        global.listen_watch_source_id = b_input_add( global.listen_socket, GAIM_INPUT_READ, bitlbee_io_new_client, NULL );
+        ch = g_io_channel_unix_new( global.listen_socket );
+        global.listen_watch_source_id = g_io_add_watch( ch, G_IO_IN, bitlbee_io_new_client, NULL );
         
 #ifndef _WIN32
@@ -145 +147 @@
 }
 
-gboolean bitlbee_io_current_client_read( gpointer data, gint fd, b_input_condition cond )
+gboolean bitlbee_io_current_client_read( GIOChannel *source, GIOCondition condition, gpointer data )
 {
         irc_t *irc = data;
@@ -151 +153 @@
         int st;
         
+        if( condition & G_IO_ERR || condition & G_IO_HUP )
+        {
+                irc_abort( irc, 1, "Read error" );
+                return FALSE;
+        }
+        
         st = read( irc->fd, line, sizeof( line ) - 1 );
         if( st == 0 )
@@ -186 +194 @@
         if( !g_slist_find( irc_connection_list, irc ) )
         {
-                log_message( LOGLVL_WARNING, "Abnormal termination of connection with fd %d.", fd );
+                log_message( LOGLVL_WARNING, "Abnormal termination of connection with fd %d.", irc->fd );
                 return FALSE;
         } 
@@ -200 +208 @@
 }
 
-gboolean bitlbee_io_current_client_write( gpointer data, gint fd, b_input_condition cond )
+gboolean bitlbee_io_current_client_write( GIOChannel *source, GIOCondition condition, gpointer data )
 {
         irc_t *irc = data;
@@ -207 +215 @@
 
         if( irc->sendbuffer == NULL )
-                return FALSE;
+                return( FALSE );
         
         size = strlen( irc->sendbuffer );
@@ -231 +239 @@
                         irc_free( irc );
                 
-                return FALSE;
+                return( FALSE );
         }
         else
@@ -239 +247 @@
                 irc->sendbuffer = temp;
                 
-                return TRUE;
-        }
-}
-
-static gboolean bitlbee_io_new_client( gpointer data, gint fd, b_input_condition condition )
-{
-        socklen_t size = sizeof( struct sockaddr_in );
+                return( TRUE );
+        }
+}
+
+gboolean bitlbee_io_new_client( GIOChannel *source, GIOCondition condition, gpointer data )
+{
+        size_t size = sizeof( struct sockaddr_in );
         struct sockaddr_in conn_info;
         int new_socket = accept( global.listen_socket, (struct sockaddr *) &conn_info, &size );
@@ -278 +286 @@
                         child->pid = client_pid;
                         child->ipc_fd = fds[0];
-                        child->ipc_inpa = b_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
+                        child->ipc_inpa = gaim_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
                         child_list = g_slist_append( child_list, child );
                         
@@ -293 +301 @@
                         /* Close the listening socket, we're a client. */
                         close( global.listen_socket );
-                        b_event_remove( global.listen_watch_source_id );
+                        g_source_remove( global.listen_watch_source_id );
                         
                         /* Make the connection. */
@@ -300 +308 @@
                         /* We can store the IPC fd there now. */
                         global.listen_socket = fds[1];
-                        global.listen_watch_source_id = b_input_add( fds[1], GAIM_INPUT_READ, ipc_child_read, irc );
+                        global.listen_watch_source_id = gaim_input_add( fds[1], GAIM_INPUT_READ, ipc_child_read, irc );
                         
                         close( fds[0] );
@@ -316 +324 @@
 }
 
-gboolean bitlbee_shutdown( gpointer data, gint fd, b_input_condition cond )
+void bitlbee_shutdown( gpointer data )
 {
         /* Try to save data for all active connections (if desired). */
@@ -323 +331 @@
         
         /* We'll only reach this point when not running in inetd mode: */
-        b_main_quit();
-        
-        return FALSE;
-}
+        g_main_quit( global.loop );
+}

bitlbee.h

@@ -58 +58 @@
 /* The following functions should not be used if we want to maintain Windows compatibility... */
 #undef free
-#define free            __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM__
+#define free            __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM_INSTEAD__
 #undef malloc
-#define malloc          __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM__
+#define malloc          __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM_INSTEAD__
 #undef calloc
-#define calloc          __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM__
+#define calloc          __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM_INSTEAD__
 #undef realloc
-#define realloc         __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM__
+#define realloc         __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM_INSTEAD__
 #undef strdup
-#define strdup          __PLEASE_USE_THE_GLIB_STRDUP_FUNCTIONS_SYSTEM__
+#define strdup          __PLEASE_USE_THE_GLIB_STRDUP_FUNCTIONS_SYSTEM_INSTEAD__
 #undef strndup
-#define strndup         __PLEASE_USE_THE_GLIB_STRDUP_FUNCTIONS_SYSTEM__
+#define strndup         __PLEASE_USE_THE_GLIB_STRDUP_FUNCTIONS_SYSTEM_INSTEAD__
 #undef snprintf
-#define snprintf        __PLEASE_USE_G_SNPRINTF__
+#define snprintf        __PLEASE_USE_G_SNPRINTF_INSTEAD__
 #undef strcasecmp
-#define strcasecmp      __PLEASE_USE_G_STRCASECMP__
+#define strcasecmp      __PLEASE_USE_G_STRCASECMP_INSTEAD__
 #undef strncasecmp
-#define strncasecmp     __PLEASE_USE_G_STRNCASECMP__
-
-/* And the following functions shouldn't be used anymore to keep compatibility
-   with other event handling libs than GLib. */
-#undef g_timeout_add
-#define g_timeout_add           __PLEASE_USE_B_TIMEOUT_ADD__
-#undef g_timeout_add_full
-#define g_timeout_add_full      __PLEASE_USE_B_TIMEOUT_ADD__
-#undef g_io_add_watch
-#define g_io_add_watch          __PLEASE_USE_B_INPUT_ADD__
-#undef g_io_add_watch_full
-#define g_io_add_watch_full     __PLEASE_USE_B_INPUT_ADD__
-#undef g_source_remove
-#define g_source_remove         __PLEASE_USE_B_EVENT_REMOVE__
-#undef g_source_remove_by_user_data
-#define g_source_remove_by_user_data    __PLEASE_USE_B_SOURCE_REMOVE_BY_USER_DATA__
-#undef g_main_run
-#define g_main_run              __PLEASE_USE_B_MAIN_RUN__
-#undef g_main_quit
-#define g_main_quit             __PLEASE_USE_B_MAIN_QUIT__
+#define strncasecmp     __PLEASE_USE_G_STRNCASECMP_INSTEAD__
 
 #ifndef F_OK
@@ -131 +112 @@
 #include "sock.h"
 #include "util.h"
-#include "proxy.h"
 
 typedef struct global {
@@ -141 +121 @@
         GList *storage; /* The first backend in the list will be used for saving */
         char *helpfile;
+        GMainLoop *loop;
         int restart;
 } global_t;
@@ -147 +128 @@
 int bitlbee_inetd_init( void );
 
-gboolean bitlbee_io_current_client_read( gpointer data, gint source, b_input_condition cond );
-gboolean bitlbee_io_current_client_write( gpointer data, gint source, b_input_condition cond );
+gboolean bitlbee_io_current_client_read( GIOChannel *source, GIOCondition condition, gpointer data );
+gboolean bitlbee_io_current_client_write( GIOChannel *source, GIOCondition condition, gpointer data );
 
 void root_command_string( irc_t *irc, user_t *u, char *command, int flags );
 void root_command( irc_t *irc, char *command[] );
-gboolean bitlbee_shutdown( gpointer data, gint fd, b_input_condition cond );
+void bitlbee_shutdown( gpointer data );
 
 extern global_t global;

configure

@@ -14 +14 @@
 datadir='$prefix/share/bitlbee/'
 config='/var/lib/bitlbee/'
-plugindir='$prefix/lib/bitlbee/'
-includedir='$prefix/include/bitlbee/'
-libevent='/usr/'
 pidfile='/var/run/bitlbee.pid'
 ipcsocket='/var/run/bitlbee'
+plugindir='$prefix/lib/bitlbee'
 pcdir='$prefix/lib/pkgconfig'
+includedir='$prefix/include/bitlbee'
 
 msn=1
@@ -29 +28 @@
 strip=1
 ipv6=1
-
-events=glib
 ssl=auto
 
@@ -67 +64 @@
 --ipv6=0/1      IPv6 socket support                     $ipv6
 
---events=...    Event handler (glib, libevent)          $events
 --ssl=...       SSL library to use (gnutls, nss, openssl, bogus, auto)
                                                         $ssl
@@ -84 +80 @@
 config=`eval echo "$config/" | sed 's/\/\{1,\}/\//g'`
 plugindir=`eval echo "$plugindir/" | sed 's/\/\{1,\}/\//g'`
-includedir=`eval echo "$includedir"/ | sed 's/\/\{1,\}/\//g'`
-libevent=`eval echo "$libevent"/ | sed 's/\/\{1,\}/\//g'`
-
 pidfile=`eval echo "$pidfile" | sed 's/\/\{1,\}/\//g'`
 ipcsocket=`eval echo "$ipcsocket" | sed 's/\/\{1,\}/\//g'`
+includedir=`eval echo "$includedir" | sed 's/\/\{1,\}/\//g'`
 pcdir=`eval echo "$pcdir" | sed 's/\/\{1,\}/\//g'`
 
@@ -179 +173 @@
 fi
 
-if [ "$events" = "libevent" ]; then
-        if ! [ -e "${libevent}include/event.h" ]; then
-                echo
-                echo 'Warning: Could not find event.h, you might have to install it and/or specify'
-                echo 'its location using the --libevent= argument. (Example: If event.h is in'
-                echo '/usr/local/include and binaries are in /usr/local/lib: --libevent=/usr/local)'
-        fi
-        
-        echo '#define EVENTS_LIBEVENT' >> config.h
-        cat <<EOF>>Makefile.settings
-EFLAGS+=-levent -L${libevent}lib
-CFLAGS+=-I${libevent}include
-EOF
-elif [ "$events" = "glib" ]; then
-        ## We already use glib anyway, so this is all we need (and in fact not even this, but just to be sure...):
-        echo '#define EVENTS_GLIB' >> config.h
-else
-        echo
-        echo 'ERROR: Unknown event handler specified.'
-        exit 1
-fi
-echo 'EVENT_HANDLER=events_'$events'.o' >> Makefile.settings
-
 detect_gnutls()
 {
@@ -430 +401 @@
 fi
 
-echo '  Using event handler: '$events;
-echo '  Using SSL library: '$ssl;
+if [ "$msn" = "1" ]; then
+        echo '  Using SSL library: '$ssl;
+fi
 
 #if [ "$flood" = "0" ]; then

ipc.c

@@ -60 +60 @@
                 ipc_to_children_str( "DIE\r\n" );
         
-        bitlbee_shutdown( NULL, -1, 0 );
+        bitlbee_shutdown( NULL );
 }
 
@@ -91 +91 @@
         
         global.restart = -1;
-        bitlbee_shutdown( NULL, -1, 0 );
+        bitlbee_shutdown( NULL );
 }
 
@@ -246 +246 @@
 }
 
-gboolean ipc_master_read( gpointer data, gint source, b_input_condition cond )
+void ipc_master_read( gpointer data, gint source, GaimInputCondition cond )
 {
         char *buf, **cmd;
@@ -272 +272 @@
                 }
         }
-        
-        return TRUE;
-}
-
-gboolean ipc_child_read( gpointer data, gint source, b_input_condition cond )
+}
+
+void ipc_child_read( gpointer data, gint source, GaimInputCondition cond )
 {
         char *buf, **cmd;
@@ -288 +286 @@
         else
         {
-                b_event_remove( global.listen_watch_source_id );
+                gaim_input_remove( global.listen_watch_source_id );
                 close( global.listen_socket );
                 
                 global.listen_socket = -1;
         }
-        
-        return TRUE;
 }
 
@@ -401 +397 @@
 void ipc_master_free_one( struct bitlbee_child *c )
 {
-        b_event_remove( c->ipc_inpa );
+        gaim_input_remove( c->ipc_inpa );
         closesocket( c->ipc_fd );
         
@@ -467 +463 @@
 
 
-static gboolean new_ipc_client( gpointer data, gint serversock, b_input_condition cond )
+static gboolean new_ipc_client (GIOChannel *gio, GIOCondition cond, gpointer data)
 {
         struct bitlbee_child *child = g_new0( struct bitlbee_child, 1 );
-        
-        child->ipc_fd = accept( serversock, NULL, 0 );
-        
-        if( child->ipc_fd == -1 )
-        {
+        int serversock;
+
+        serversock = g_io_channel_unix_get_fd(gio);
+
+        child->ipc_fd = accept(serversock, NULL, 0);
+
+        if (child->ipc_fd == -1) {
                 log_message( LOGLVL_WARNING, "Unable to accept connection on UNIX domain socket: %s", strerror(errno) );
                 return TRUE;
         }
                 
-        child->ipc_inpa = b_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
-        
+        child->ipc_inpa = gaim_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
+                
         child_list = g_slist_append( child_list, child );
-        
+
         return TRUE;
 }
@@ -491 +489 @@
         struct sockaddr_un un_addr;
         int serversock;
+        GIOChannel *gio;
 
         /* Clean up old socket files that were hanging around.. */
@@ -518 +517 @@
         }
         
-        b_input_add( serversock, GAIM_INPUT_READ, new_ipc_client, NULL );
-        
+        gio = g_io_channel_unix_new(serversock);
+        
+        if (gio == NULL) {
+                log_message( LOGLVL_WARNING, "Unable to create IO channel for unix socket" );
+                return 0;
+        }
+
+        g_io_add_watch(gio, G_IO_IN, new_ipc_client, NULL);
         return 1;
 }
@@ -558 +563 @@
                         return 0;
                 }
-                child->ipc_inpa = b_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
+                child->ipc_inpa = gaim_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
                 
                 child_list = g_slist_append( child_list, child );

ipc.h

@@ -40 +40 @@
 
 
-gboolean ipc_master_read( gpointer data, gint source, b_input_condition cond );
-gboolean ipc_child_read( gpointer data, gint source, b_input_condition cond );
+void ipc_master_read( gpointer data, gint source, GaimInputCondition cond );
+void ipc_child_read( gpointer data, gint source, GaimInputCondition cond );
 
 void ipc_master_free_one( struct bitlbee_child *child );

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 );
+        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 );
+        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 +116 @@
 
         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 +186 @@
                    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 +220 @@
         
         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 +275 @@
                         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 +325 @@
         
         if( global.conf->runmode == RUNMODE_INETD || global.conf->runmode == RUNMODE_FORKDAEMON )
-                b_main_quit();
+                g_main_quit( global.loop );
 }
 
@@ -576 +579 @@
         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 +596 @@
         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 +632 @@
                 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;
@@ -1041 +1035 @@
 }
 
-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;
@@ -1072 +1066 @@
                 {
                         /* 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 );
                 }
 
@@ -1097 +1091 @@
                 
                 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
@@ -1182 +1176 @@
    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;

irc.h

@@ -61 +61 @@
         char *sendbuffer;
         char *readbuffer;
+        int quit;
 
         int sentbytes;
@@ -92 +93 @@
         struct set *set;
 
+        GIOChannel *io_channel;
         gint r_watch_source_id;
         gint w_watch_source_id;

protocols/Makefile

@@ -10 +10 @@
 
 # [SH] Program variables
-objects = $(EVENT_HANDLER) http_client.o md5.o nogaim.o proxy.o sha.o $(SSL_CLIENT)
+objects = http_client.o md5.o nogaim.o proxy.o sha.o $(SSL_CLIENT)
 
 # [SH] The next two lines should contain the directory name (in $(subdirs))

protocols/http_client.c

@@ -32 +32 @@
 
 
-static gboolean http_connected( gpointer data, int source, b_input_condition cond );
-static gboolean http_ssl_connected( gpointer data, void *source, b_input_condition cond );
-static gboolean http_incoming_data( gpointer data, int source, b_input_condition cond );
+static void http_connected( gpointer data, int source, GaimInputCondition cond );
+static void http_ssl_connected( gpointer data, void *source, GaimInputCondition cond );
+static void http_incoming_data( gpointer data, int source, GaimInputCondition cond );
 
 
@@ -104 +104 @@
 /* This one is actually pretty simple... Might get more calls if we can't write 
    the whole request at once. */
-static gboolean http_connected( gpointer data, int source, b_input_condition cond )
+static void http_connected( gpointer data, int source, GaimInputCondition cond )
 {
         struct http_request *req = data;
@@ -113 +113 @@
         
         if( req->inpa > 0 )
-                b_event_remove( req->inpa );
+                gaim_input_remove( req->inpa );
         
         sock_make_nonblocking( req->fd );
@@ -148 +148 @@
         
         if( req->bytes_written < req->request_length )
-                req->inpa = b_input_add( source,
-                                         req->ssl ? ssl_getdirection( req->ssl ) : GAIM_INPUT_WRITE,
-                                         http_connected, req );
-        else
-                req->inpa = b_input_add( source, GAIM_INPUT_READ, http_incoming_data, req );
-        
-        return FALSE;
+                req->inpa = gaim_input_add( source,
+                                            req->ssl ? ssl_getdirection( req->ssl ) : GAIM_INPUT_WRITE,
+                                            http_connected, req );
+        else
+                req->inpa = gaim_input_add( source, GAIM_INPUT_READ, http_incoming_data, req );
+        
+        return;
         
 error:
@@ -164 +164 @@
         g_free( req );
         
-        return FALSE;
+        return;
 }
 
-static gboolean http_ssl_connected( gpointer data, void *source, b_input_condition cond )
+static void http_ssl_connected( gpointer data, void *source, GaimInputCondition cond )
 {
         struct http_request *req = data;
@@ -179 +179 @@
 }
 
-static gboolean http_incoming_data( gpointer data, int source, b_input_condition cond )
+static void http_incoming_data( gpointer data, int source, GaimInputCondition cond )
 {
         struct http_request *req = data;
@@ -188 +188 @@
         
         if( req->inpa > 0 )
-                b_event_remove( req->inpa );
+                gaim_input_remove( req->inpa );
         
         if( req->ssl )
@@ -236 +236 @@
         
         /* There will be more! */
-        req->inpa = b_input_add( req->fd,
-                                 req->ssl ? ssl_getdirection( req->ssl ) : GAIM_INPUT_READ,
-                                 http_incoming_data, req );
-        
-        return FALSE;
+        req->inpa = gaim_input_add( req->fd,
+                                    req->ssl ? ssl_getdirection( req->ssl ) : GAIM_INPUT_READ,
+                                    http_incoming_data, req );
+        
+        return;
 
 got_reply:
@@ -430 +430 @@
                 req->reply_headers = req->reply_body = NULL;
                 
-                return FALSE;
+                return;
         }
         
@@ -449 +449 @@
         g_free( req->status_string );
         g_free( req );
-        
-        return FALSE;
 }

protocols/jabber/jabber.c

@@ -471 +471 @@
 }
 
-static gboolean jabber_callback(gpointer data, gint source, b_input_condition condition)
+static void jabber_callback(gpointer data, gint source, GaimInputCondition condition)
 {
         struct gaim_connection *gc = (struct gaim_connection *)data;
@@ -477 +477 @@
 
         gjab_recv(jd->gjc);
-        
-        return TRUE;
 }
 
@@ -489 +487 @@
 }
 
-static gboolean gjab_connected(gpointer data, gint source, b_input_condition cond)
+static void gjab_connected(gpointer data, gint source, GaimInputCondition cond)
 {
         xmlnode x;
@@ -499 +497 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return FALSE;
+                return;
         }
 
@@ -510 +508 @@
         if (source == -1) {
                 STATE_EVT(JCONN_STATE_OFF)
-                return FALSE;
+                return;
         }
 
@@ -532 +530 @@
 
         gc = GJ_GC(gjc);
-        gc->inpa = b_input_add(gjc->fd, GAIM_INPUT_READ, jabber_callback, gc);
-        
-        return FALSE;
-}
-
-static gboolean gjab_connected_ssl(gpointer data, void *source, b_input_condition cond)
+        gc->inpa = gaim_input_add(gjc->fd, GAIM_INPUT_READ, jabber_callback, gc);
+}
+
+static void gjab_connected_ssl(gpointer data, void *source, GaimInputCondition cond)
 {
         struct gaim_connection *gc = data;
@@ -548 +544 @@
         if (source == NULL) {
                 STATE_EVT(JCONN_STATE_OFF)
-                return FALSE;
+                return;
         }
         
         if (!g_slist_find(get_connections(), gc)) {
                 ssl_disconnect(source);
-                return FALSE;
+                return;
         }
         
-        return gjab_connected(data, gjc->fd, cond);
+        gjab_connected(data, gjc->fd, cond);
 }
 
@@ -1547 +1543 @@
 }
 
-static gboolean jabber_free(gpointer data, gint fd, b_input_condition cond)
+static gboolean jabber_free(gpointer data)
 {
         struct jabber_data *jd = data;
@@ -1592 +1588 @@
         }
         if (gc->inpa)
-                b_event_remove(gc->inpa);
+                gaim_input_remove(gc->inpa);
 
         if(jd) {
-                b_timeout_add(50, jabber_free, jd);
+                g_timeout_add(50, jabber_free, jd);
                 if(jd->gjc != NULL)
                         xmlnode_free(jd->gjc->current);

protocols/msn/msn.c

@@ -94 +94 @@
                         g_slist_free( md->msgq );
                 }
-                
-                g_free( md->grouplist );
                 
                 g_free( md );

protocols/msn/msn.h

@@ -146 +146 @@
 
 /* ns.c */
-gboolean msn_ns_connected( gpointer data, gint source, b_input_condition cond );
+void msn_ns_connected( gpointer data, gint source, GaimInputCondition cond );
 
 /* msn_util.c */
@@ -173 +173 @@
 void msn_sb_to_chat( struct msn_switchboard *sb );
 void msn_sb_destroy( struct msn_switchboard *sb );
-gboolean msn_sb_connected( gpointer data, gint source, b_input_condition cond );
+void msn_sb_connected( gpointer data, gint source, GaimInputCondition cond );

protocols/msn/ns.c

@@ -30 +30 @@
 #include "md5.h"
 
-static gboolean msn_ns_callback( gpointer data, gint source, b_input_condition cond );
+static void msn_ns_callback( gpointer data, gint source, GaimInputCondition cond );
 static int msn_ns_command( gpointer data, char **cmd, int num_parts );
 static int msn_ns_message( gpointer data, char *msg, int msglen, char **cmd, int num_parts );
@@ -36 +36 @@
 static void msn_auth_got_passport_id( struct passport_reply *rep );
 
-gboolean msn_ns_connected( gpointer data, gint source, b_input_condition cond )
+void msn_ns_connected( gpointer data, gint source, GaimInputCondition cond )
 {
         struct gaim_connection *gc = data;
@@ -43 +43 @@
         
         if( !g_slist_find( msn_connections, gc ) )
-                return FALSE;
+                return;
         
         if( source == -1 )
@@ -49 +49 @@
                 hide_login_progress( gc, "Could not connect to server" );
                 signoff( gc );
-                return FALSE;
+                return;
         }
         
@@ -75 +75 @@
         if( msn_write( gc, s, strlen( s ) ) )
         {
-                gc->inpa = b_input_add( md->fd, GAIM_INPUT_READ, msn_ns_callback, gc );
+                gc->inpa = gaim_input_add( md->fd, GAIM_INPUT_READ, msn_ns_callback, gc );
                 set_login_progress( gc, 1, "Connected to server, waiting for reply" );
         }
-        
-        return FALSE;
 }
 
-static gboolean msn_ns_callback( gpointer data, gint source, b_input_condition cond )
+void msn_ns_callback( gpointer data, gint source, GaimInputCondition cond )
 {
         struct gaim_connection *gc = data;
@@ -91 +89 @@
                 hide_login_progress( gc, "Error while reading from server" );
                 signoff( gc );
-                
-                return FALSE;
-        }
-        else
-                return TRUE;
+        }
 }
 
@@ -136 +130 @@
                 if( num_parts == 6 && strcmp( cmd[2], "NS" ) == 0 )
                 {
-                        b_event_remove( gc->inpa );
+                        gaim_input_remove( gc->inpa );
                         gc->inpa = 0;
                         closesocket( md->fd );

protocols/msn/sb.c

@@ -30 +30 @@
 #include "md5.h"
 
-static gboolean msn_sb_callback( gpointer data, gint source, b_input_condition cond );
+static void msn_sb_callback( gpointer data, gint source, GaimInputCondition cond );
 static int msn_sb_command( gpointer data, char **cmd, int num_parts );
 static int msn_sb_message( gpointer data, char *msg, int msglen, char **cmd, int num_parts );
@@ -237 +237 @@
         }
         
-        if( sb->inp ) b_event_remove( sb->inp );
+        if( sb->inp ) gaim_input_remove( sb->inp );
         closesocket( sb->fd );
         
@@ -245 +245 @@
 }
 
-gboolean msn_sb_connected( gpointer data, gint source, b_input_condition cond )
+void msn_sb_connected( gpointer data, gint source, GaimInputCondition cond )
 {
         struct msn_switchboard *sb = data;
@@ -254 +254 @@
         /* Are we still alive? */
         if( !g_slist_find( msn_switchboards, sb ) )
-                return FALSE;
+                return;
         
         gc = sb->gc;
@@ -263 +263 @@
                 debug( "ERROR %d while connecting to switchboard server", 1 );
                 msn_sb_destroy( sb );
-                return FALSE;
+                return;
         }
         
@@ -280 +280 @@
         
         if( msn_sb_write( sb, buf, strlen( buf ) ) )
-                sb->inp = b_input_add( sb->fd, GAIM_INPUT_READ, msn_sb_callback, sb );
+                sb->inp = gaim_input_add( sb->fd, GAIM_INPUT_READ, msn_sb_callback, sb );
         else
                 debug( "ERROR %d while connecting to switchboard server", 2 );
-        
-        return FALSE;
-}
-
-static gboolean msn_sb_callback( gpointer data, gint source, b_input_condition cond )
+}
+
+static void msn_sb_callback( gpointer data, gint source, GaimInputCondition cond )
 {
         struct msn_switchboard *sb = data;
@@ -295 +293 @@
                 debug( "ERROR: Switchboard died" );
                 msn_sb_destroy( sb );
-                
-                return FALSE;
-        }
-        else
-                return TRUE;
+        }
 }
 

protocols/nogaim.c

@@ -2 +2 @@
   * BitlBee -- An IRC to other IM-networks gateway                     *
   *                                                                    *
-  * Copyright 2002-2006 Wilmer van der Gaast and others                *
+  * Copyright 2002-2004 Wilmer van der Gaast and others                *
   \********************************************************************/
 
@@ -13 +13 @@
  * from scratch for BitlBee and doesn't contain any code from Gaim anymore
  * (except for the function names).
+ *
+ * Copyright 2002-2006 Wilmer van der Gaast <wilmer@gaast.net> and others
  */
 
@@ -158 +160 @@
          * This fixes daemon mode breakage where IRC doesn't point to the currently active connection.
          */
-        gc->irc = user->irc;
+        gc->irc=user->irc;
         
         connections = g_slist_append( connections, gc );
@@ -238 +240 @@
 }
 
-static gboolean send_keepalive( gpointer d, gint fd, b_input_condition cond )
+static gboolean send_keepalive( gpointer d )
 {
         struct gaim_connection *gc = d;
@@ -262 +264 @@
         serv_got_crap( gc, "Logged in" );
         
-        gc->keepalive = b_timeout_add( 60000, send_keepalive, gc );
+        gc->keepalive = g_timeout_add( 60000, send_keepalive, gc );
         gc->flags |= OPT_LOGGED_IN;
         
@@ -270 +272 @@
 }
 
-gboolean auto_reconnect( gpointer data, gint fd, b_input_condition cond )
+gboolean auto_reconnect( gpointer data )
 {
         account_t *a = data;
@@ -282 +284 @@
 void cancel_auto_reconnect( account_t *a )
 {
-        /* while( b_event_remove_by_data( (gpointer) a ) ); */
-        b_event_remove( a->reconnect );
+        while( g_source_remove_by_user_data( (gpointer) a ) );
         a->reconnect = 0;
 }
@@ -294 +295 @@
         
         serv_got_crap( gc, "Signing off.." );
-        
-        b_event_remove( gc->keepalive );
         gc->flags |= OPT_LOGGING_OUT;
+        
+        gaim_input_remove( gc->keepalive );
         gc->keepalive = 0;
         gc->prpl->close( gc );
-        b_event_remove( gc->inpa );
+        gaim_input_remove( gc->inpa );
         
         while( u )
@@ -326 +327 @@
         {
                 int delay = set_getint( irc, "auto_reconnect_delay" );
-                
                 serv_got_crap( gc, "Reconnecting in %d seconds..", delay );
-                a->reconnect = b_timeout_add( delay * 1000, auto_reconnect, a );
+                
+                a->reconnect = 1;
+                g_timeout_add( delay * 1000, auto_reconnect, a );
         }
         

protocols/nogaim.h

@@ -208 +208 @@
 char *set_eval_away_devoice( irc_t *irc, set_t *set, char *value );
 
-gboolean auto_reconnect( gpointer data, gint fd, b_input_condition cond );
+gboolean auto_reconnect( gpointer data );
 void cancel_auto_reconnect( struct account *a );
 

protocols/oscar/oscar.c

@@ -255 +255 @@
 static int msgerrreasonlen = 25;
 
-static gboolean oscar_callback(gpointer data, gint source,
-                                b_input_condition condition) {
+static void oscar_callback(gpointer data, gint source,
+                                GaimInputCondition condition) {
         aim_conn_t *conn = (aim_conn_t *)data;
         aim_session_t *sess = aim_conn_getsess(conn);
@@ -264 +264 @@
         if (!gc) {
                 /* gc is null. we return, else we seg SIGSEG on next line. */
-                return FALSE;
+                return;
         }
       
@@ -270 +270 @@
                 /* oh boy. this is probably bad. i guess the only thing we 
                  * can really do is return? */
-                return FALSE;
+                return;
         }
 
@@ -290 +290 @@
                                 c->conn = NULL;
                                 if (c->inpa > 0)
-                                        b_event_remove(c->inpa);
+                                        gaim_input_remove(c->inpa);
                                 c->inpa = 0;
                                 c->fd = -1;
@@ -298 +298 @@
                         } else if (conn->type == AIM_CONN_TYPE_CHATNAV) {
                                 if (odata->cnpa > 0)
-                                        b_event_remove(odata->cnpa);
+                                        gaim_input_remove(odata->cnpa);
                                 odata->cnpa = 0;
                                 while (odata->create_rooms) {
@@ -312 +312 @@
                         } else if (conn->type == AIM_CONN_TYPE_AUTH) {
                                 if (odata->paspa > 0)
-                                        b_event_remove(odata->paspa);
+                                        gaim_input_remove(odata->paspa);
                                 odata->paspa = 0;
                                 aim_conn_kill(odata->sess, &conn);
@@ -319 +319 @@
                         }
                 }
-        } else {
-                /* WTF??? */
-                return FALSE;
-        }
-                
-        return TRUE;
-}
-
-static gboolean oscar_login_connect(gpointer data, gint source, b_input_condition cond)
+        }
+}
+
+static void oscar_login_connect(gpointer data, gint source, GaimInputCondition cond)
 {
         struct gaim_connection *gc = data;
@@ -336 +331 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return FALSE;
+                return;
         }
 
@@ -346 +341 @@
                 hide_login_progress(gc, _("Couldn't connect to host"));
                 signoff(gc);
-                return FALSE;
+                return;
         }
 
         aim_conn_completeconnect(sess, conn);
-        gc->inpa = b_input_add(conn->fd, GAIM_INPUT_READ,
+        gc->inpa = gaim_input_add(conn->fd, GAIM_INPUT_READ,
                         oscar_callback, conn);
-        
-        return FALSE;
 }
 
@@ -421 +414 @@
                 struct chat_connection *n = odata->oscar_chats->data;
                 if (n->inpa > 0)
-                        b_event_remove(n->inpa);
+                        gaim_input_remove(n->inpa);
                 g_free(n->name);
                 g_free(n->show);
@@ -440 +433 @@
                 g_free(odata->oldp);
         if (gc->inpa > 0)
-                b_event_remove(gc->inpa);
+                gaim_input_remove(gc->inpa);
         if (odata->cnpa > 0)
-                b_event_remove(odata->cnpa);
+                gaim_input_remove(odata->cnpa);
         if (odata->paspa > 0)
-                b_event_remove(odata->paspa);
+                gaim_input_remove(odata->paspa);
         aim_session_kill(odata->sess);
         g_free(odata->sess);
@@ -452 +445 @@
 }
 
-static gboolean oscar_bos_connect(gpointer data, gint source, b_input_condition cond) {
+static void oscar_bos_connect(gpointer data, gint source, GaimInputCondition cond) {
         struct gaim_connection *gc = data;
         struct oscar_data *odata;
@@ -460 +453 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return FALSE;
+                return;
         }
 
@@ -470 +463 @@
                 hide_login_progress(gc, _("Could Not Connect"));
                 signoff(gc);
-                return FALSE;
+                return;
         }
 
         aim_conn_completeconnect(sess, bosconn);
-        gc->inpa = b_input_add(bosconn->fd, GAIM_INPUT_READ,
+        gc->inpa = gaim_input_add(bosconn->fd, GAIM_INPUT_READ,
                         oscar_callback, bosconn);
         set_login_progress(gc, 4, _("Connection established, cookie sent"));
-        
-        return FALSE;
 }
 
@@ -581 +572 @@
         }
         aim_sendcookie(sess, bosconn, info->cookie);
-        b_event_remove(gc->inpa);
+        gaim_input_remove(gc->inpa);
 
         return 1;
@@ -596 +587 @@
 };
 
-static gboolean damn_you(gpointer data, gint source, b_input_condition c)
+static void damn_you(gpointer data, gint source, GaimInputCondition c)
 {
         struct pieceofcrap *pos = data;
@@ -616 +607 @@
                 do_error_dialog(pos->gc, "Gaim was unable to get a valid hash for logging into AIM."
                                 " You may be disconnected shortly.", "Login Error");
-                b_event_remove(pos->inpa);
+                gaim_input_remove(pos->inpa);
                 closesocket(pos->fd);
                 g_free(pos);
-                return FALSE;
+                return;
         }
         /* [WvG] Wheeeee! Who needs error checking anyway? ;-) */
         read(pos->fd, m, 16);
         m[16] = '\0';
-        b_event_remove(pos->inpa);
+        gaim_input_remove(pos->inpa);
         closesocket(pos->fd);
         aim_sendmemblock(od->sess, pos->conn, 0, 16, m, AIM_SENDMEMBLOCK_FLAG_ISHASH);
         g_free(pos);
-        
-        return FALSE;
-}
-
-static gboolean straight_to_hell(gpointer data, gint source, b_input_condition cond) {
+}
+
+static void straight_to_hell(gpointer data, gint source, GaimInputCondition cond) {
         struct pieceofcrap *pos = data;
         char buf[BUF_LONG];
@@ -642 +631 @@
                         g_free(pos->modname);
                 g_free(pos);
-                return FALSE;
+                return;
         }
 
@@ -651 +640 @@
         if (pos->modname)
                 g_free(pos->modname);
-        pos->inpa = b_input_add(pos->fd, GAIM_INPUT_READ, damn_you, pos);
-        return FALSE;
+        pos->inpa = gaim_input_add(pos->fd, GAIM_INPUT_READ, damn_you, pos);
+        return;
 }
 
@@ -774 +763 @@
 }
 
-static gboolean oscar_chatnav_connect(gpointer data, gint source, b_input_condition cond) {
+static void oscar_chatnav_connect(gpointer data, gint source, GaimInputCondition cond) {
         struct gaim_connection *gc = data;
         struct oscar_data *odata;
@@ -782 +771 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return FALSE;
+                return;
         }
 
@@ -791 +780 @@
         if (source < 0) {
                 aim_conn_kill(sess, &tstconn);
-                return FALSE;
+                return;
         }
 
         aim_conn_completeconnect(sess, tstconn);
-        odata->cnpa = b_input_add(tstconn->fd, GAIM_INPUT_READ,
+        odata->cnpa = gaim_input_add(tstconn->fd, GAIM_INPUT_READ,
                                         oscar_callback, tstconn);
-        
-        return FALSE;
-}
-
-static gboolean oscar_auth_connect(gpointer data, gint source, b_input_condition cond)
+}
+
+static void oscar_auth_connect(gpointer data, gint source, GaimInputCondition cond)
 {
         struct gaim_connection *gc = data;
@@ -810 +797 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return FALSE;
+                return;
         }
 
@@ -819 +806 @@
         if (source < 0) {
                 aim_conn_kill(sess, &tstconn);
-                return FALSE;
+                return;
         }
 
         aim_conn_completeconnect(sess, tstconn);
-        odata->paspa = b_input_add(tstconn->fd, GAIM_INPUT_READ,
+        odata->paspa = gaim_input_add(tstconn->fd, GAIM_INPUT_READ,
                                 oscar_callback, tstconn);
-        
-        return FALSE;
-}
-
-static gboolean oscar_chat_connect(gpointer data, gint source, b_input_condition cond)
+}
+
+static void oscar_chat_connect(gpointer data, gint source, GaimInputCondition cond)
 {
         struct chat_connection *ccon = data;
@@ -842 +827 @@
                 g_free(ccon->name);
                 g_free(ccon);
-                return FALSE;
+                return;
         }
 
@@ -854 +839 @@
                 g_free(ccon->name);
                 g_free(ccon);
-                return FALSE;
+                return;
         }
 
         aim_conn_completeconnect(sess, ccon->conn);
-        ccon->inpa = b_input_add(tstconn->fd,
+        ccon->inpa = gaim_input_add(tstconn->fd,
                         GAIM_INPUT_READ,
                         oscar_callback, tstconn);
         odata->oscar_chats = g_slist_append(odata->oscar_chats, ccon);
-        
-        return FALSE;
 }
 
@@ -2582 +2565 @@
         od->oscar_chats = g_slist_remove(od->oscar_chats, cc);
         if (cc->inpa > 0)
-                b_event_remove(cc->inpa);
+                gaim_input_remove(cc->inpa);
         aim_conn_kill(od->sess, &cc->conn);
         g_free(cc->name);

protocols/proxy.c

@@ -21 +21 @@
  */
 
+/* this is a little piece of code to handle proxy connection */
+/* it is intended to : 1st handle http proxy, using the CONNECT command
+ , 2nd provide an easy way to add socks support */
+
 #define BITLBEE_CORE
 #include <stdio.h>
@@ -42 +46 @@
 #include "proxy.h"
 
+#define GAIM_READ_COND  (G_IO_IN | G_IO_HUP | G_IO_ERR)
+#define GAIM_WRITE_COND (G_IO_OUT | G_IO_HUP | G_IO_ERR | G_IO_NVAL)
+#define GAIM_ERR_COND   (G_IO_HUP | G_IO_ERR | G_IO_NVAL)
+
 char proxyhost[128] = "";
 int proxyport = 0;
@@ -49 +57 @@
 
 struct PHB {
-        b_event_handler func, proxy_func;
+        GaimInputFunction func, proxy_func;
         gpointer data, proxy_data;
         char *host;
@@ -56 +64 @@
         gint inpa;
 };
+
+typedef struct _GaimIOClosure {
+        GaimInputFunction function;
+        guint result;
+        gpointer data;
+} GaimIOClosure;
 
 
@@ -78 +92 @@
 }
 
-static gboolean gaim_io_connected(gpointer data, gint source, b_input_condition cond)
+static void gaim_io_destroy(gpointer data)
+{
+        g_free(data);
+}
+
+static gboolean gaim_io_invoke(GIOChannel *source, GIOCondition condition, gpointer data)
+{
+        GaimIOClosure *closure = data;
+        GaimInputCondition gaim_cond = 0;
+
+        if (condition & GAIM_READ_COND)
+                gaim_cond |= GAIM_INPUT_READ;
+        if (condition & GAIM_WRITE_COND)
+                gaim_cond |= GAIM_INPUT_WRITE;
+
+        closure->function(closure->data, g_io_channel_unix_get_fd(source), gaim_cond);
+
+        return TRUE;
+}
+
+static void gaim_io_connected(gpointer data, gint source, GaimInputCondition cond)
 {
         struct PHB *phb = data;
@@ -88 +122 @@
         if (getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
                 closesocket(source);
-                b_event_remove(phb->inpa);
+                gaim_input_remove(phb->inpa);
                 if( phb->proxy_func )
                         phb->proxy_func(phb->proxy_data, -1, GAIM_INPUT_READ);
@@ -95 +129 @@
                         g_free(phb);
                 }
-                return FALSE;
+                return;
         }
 #endif
         sock_make_blocking(source);
-        b_event_remove(phb->inpa);
+        gaim_input_remove(phb->inpa);
         if( phb->proxy_func )
                 phb->proxy_func(phb->proxy_data, source, GAIM_INPUT_READ);
@@ -106 +140 @@
                 g_free(phb);
         }
-        
-        return FALSE;
 }
 
@@ -126 +158 @@
 
         sock_make_nonblocking(fd);
-        
-        event_debug("proxy_connect_none( \"%s\", %d ) = %d\n", host, port, fd);
-        
+
         if (connect(fd, (struct sockaddr *)sin, sizeof(*sin)) < 0) {
                 if (sockerr_again()) {
-                        phb->inpa = b_input_add(fd, GAIM_INPUT_WRITE, gaim_io_connected, phb);
+                        phb->inpa = gaim_input_add(fd, GAIM_INPUT_WRITE, gaim_io_connected, phb);
                         phb->fd = fd;
                 } else {
@@ -149 +179 @@
 #define HTTP_GOODSTRING2 "HTTP/1.1 200 Connection established"
 
-static gboolean http_canread(gpointer data, gint source, b_input_condition cond)
+static void http_canread(gpointer data, gint source, GaimInputCondition cond)
 {
         int nlc = 0;
@@ -156 +186 @@
         char inputline[8192];
 
-        b_event_remove(phb->inpa);
+        gaim_input_remove(phb->inpa);
 
         while ((pos < sizeof(inputline)-1) && (nlc != 2) && (read(source, &inputline[pos++], 1) == 1)) {
@@ -171 +201 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
@@ -178 +208 @@
         g_free(phb->host);
         g_free(phb);
-        
-        return FALSE;
-}
-
-static gboolean http_canwrite(gpointer data, gint source, b_input_condition cond)
+        return;
+}
+
+static void http_canwrite(gpointer data, gint source, GaimInputCondition cond)
 {
         char cmd[384];
@@ -189 +218 @@
         int error = ETIMEDOUT;
         if (phb->inpa > 0)
-                b_event_remove(phb->inpa);
+                gaim_input_remove(phb->inpa);
         len = sizeof(error);
         if (getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
@@ -196 +225 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
         sock_make_blocking(source);
@@ -207 +236 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
@@ -222 +251 @@
                         g_free(phb->host);
                         g_free(phb);
-                        return FALSE;
+                        return;
                 }
         }
@@ -232 +261 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
-        }
-
-        phb->inpa = b_input_add(source, GAIM_INPUT_READ, http_canread, phb);
-        
-        return FALSE;
+                return;
+        }
+
+        phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, http_canread, phb);
 }
 
@@ -253 +280 @@
 /* Connecting to SOCKS4 proxies */
 
-static gboolean s4_canread(gpointer data, gint source, b_input_condition cond)
+static void s4_canread(gpointer data, gint source, GaimInputCondition cond)
 {
         unsigned char packet[12];
         struct PHB *phb = data;
 
-        b_event_remove(phb->inpa);
+        gaim_input_remove(phb->inpa);
 
         memset(packet, 0, sizeof(packet));
@@ -265 +292 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
@@ -272 +299 @@
         g_free(phb->host);
         g_free(phb);
-        
-        return FALSE;
-}
-
-static gboolean s4_canwrite(gpointer data, gint source, b_input_condition cond)
+}
+
+static void s4_canwrite(gpointer data, gint source, GaimInputCondition cond)
 {
         unsigned char packet[12];
@@ -284 +309 @@
         int error = ETIMEDOUT;
         if (phb->inpa > 0)
-                b_event_remove(phb->inpa);
+                gaim_input_remove(phb->inpa);
         len = sizeof(error);
         if (getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
@@ -291 +316 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
         sock_make_blocking(source);
@@ -301 +326 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
@@ -318 +343 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
-        }
-
-        phb->inpa = b_input_add(source, GAIM_INPUT_READ, s4_canread, phb);
-        
-        return FALSE;
+                return;
+        }
+
+        phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, s4_canread, phb);
 }
 
@@ -339 +362 @@
 /* Connecting to SOCKS5 proxies */
 
-static gboolean s5_canread_again(gpointer data, gint source, b_input_condition cond)
+static void s5_canread_again(gpointer data, gint source, GaimInputCondition cond)
 {
         unsigned char buf[512];
         struct PHB *phb = data;
 
-        b_event_remove(phb->inpa);
+        gaim_input_remove(phb->inpa);
 
         if (read(source, buf, 10) < 10) {
@@ -351 +374 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
         if ((buf[0] != 0x05) || (buf[1] != 0x00)) {
@@ -358 +381 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
@@ -364 +387 @@
         g_free(phb->host);
         g_free(phb);
-        
-        return FALSE;
+        return;
 }
 
@@ -373 +395 @@
         struct PHB *phb = data;
         int hlen = strlen(phb->host);
-        
+
         buf[0] = 0x05;
         buf[1] = 0x01;          /* CONNECT */
@@ -391 +413 @@
         }
 
-        phb->inpa = b_input_add(source, GAIM_INPUT_READ, s5_canread_again, phb);
-}
-
-static gboolean s5_readauth(gpointer data, gint source, b_input_condition cond)
+        phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, s5_canread_again, phb);
+}
+
+static void s5_readauth(gpointer data, gint source, GaimInputCondition cond)
 {
         unsigned char buf[512];
         struct PHB *phb = data;
 
-        b_event_remove(phb->inpa);
+        gaim_input_remove(phb->inpa);
 
         if (read(source, buf, 2) < 2) {
@@ -406 +428 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
@@ -414 +436 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
         s5_sendconnect(phb, source);
-        
-        return FALSE;
-}
-
-static gboolean s5_canread(gpointer data, gint source, b_input_condition cond)
+}
+
+static void s5_canread(gpointer data, gint source, GaimInputCondition cond)
 {
         unsigned char buf[512];
         struct PHB *phb = data;
 
-        b_event_remove(phb->inpa);
+        gaim_input_remove(phb->inpa);
 
         if (read(source, buf, 2) < 2) {
@@ -434 +454 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
@@ -442 +462 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
 
@@ -457 +477 @@
                         g_free(phb->host);
                         g_free(phb);
-                        return FALSE;
+                        return;
                 }
 
-                phb->inpa = b_input_add(source, GAIM_INPUT_READ, s5_readauth, phb);
+                phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, s5_readauth, phb);
         } else {
                 s5_sendconnect(phb, source);
         }
-        
-        return FALSE;
-}
-
-static gboolean s5_canwrite(gpointer data, gint source, b_input_condition cond)
+}
+
+static void s5_canwrite(gpointer data, gint source, GaimInputCondition cond)
 {
         unsigned char buf[512];
@@ -476 +494 @@
         int error = ETIMEDOUT;
         if (phb->inpa > 0)
-                b_event_remove(phb->inpa);
+                gaim_input_remove(phb->inpa);
         len = sizeof(error);
         if (getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
@@ -483 +501 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
+                return;
         }
         sock_make_blocking(source);
@@ -505 +523 @@
                 g_free(phb->host);
                 g_free(phb);
-                return FALSE;
-        }
-
-        phb->inpa = b_input_add(source, GAIM_INPUT_READ, s5_canread, phb);
-        
-        return FALSE;
+                return;
+        }
+
+        phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, s5_canread, phb);
 }
 
@@ -526 +542 @@
 /* Export functions */
 
-int proxy_connect(const char *host, int port, b_event_handler func, gpointer data)
+gint gaim_input_add(gint source, GaimInputCondition condition, GaimInputFunction function, gpointer data)
+{
+        GaimIOClosure *closure = g_new0(GaimIOClosure, 1);
+        GIOChannel *channel;
+        GIOCondition cond = 0;
+        
+        closure->function = function;
+        closure->data = data;
+        
+        if (condition & GAIM_INPUT_READ)
+                cond |= GAIM_READ_COND;
+        if (condition & GAIM_INPUT_WRITE)
+                cond |= GAIM_WRITE_COND;
+        
+        channel = g_io_channel_unix_new(source);
+        closure->result = g_io_add_watch_full(channel, G_PRIORITY_DEFAULT, cond,
+                                              gaim_io_invoke, closure, gaim_io_destroy);
+        
+        g_io_channel_unref(channel);
+        return closure->result;
+}
+
+void gaim_input_remove(gint tag)
+{
+        if (tag > 0)
+                g_source_remove(tag);
+}
+
+int proxy_connect(const char *host, int port, GaimInputFunction func, gpointer data)
 {
         struct PHB *phb;

protocols/proxy.h

@@ -1 +1 @@
 /*
- * nogaim
+ * gaim
  *
  * Copyright (C) 1998-1999, Mark Spencer <markster@marko.net>
@@ -36 +36 @@
 #include <gmodule.h>
 
-#include "events.h"
-
 #define PROXY_NONE 0
 #define PROXY_HTTP 1
@@ -49 +47 @@
 extern char proxypass[128];
 
-G_MODULE_EXPORT int proxy_connect(const char *host, int port, b_event_handler func, gpointer data);
+typedef enum {
+        GAIM_INPUT_READ = 1 << 0,
+        GAIM_INPUT_WRITE = 1 << 1
+} GaimInputCondition;
+typedef void (*GaimInputFunction)(gpointer, gint, GaimInputCondition);
+
+G_MODULE_EXPORT gint gaim_input_add(int, GaimInputCondition, GaimInputFunction, gpointer);
+G_MODULE_EXPORT void gaim_input_remove(gint);
+
+G_MODULE_EXPORT int proxy_connect(const char *host, int port, GaimInputFunction func, gpointer data);
 
 #endif /* _PROXY_H_ */

protocols/ssl_bogus.c

@@ -52 +52 @@
 }
 
-b_input_condition ssl_getdirection( void *conn )
+GaimInputCondition ssl_getdirection( void *conn )
 {
         return GAIM_INPUT_READ;

protocols/ssl_client.h

@@ -33 +33 @@
 extern int ssl_errno;
 
-typedef gboolean (*ssl_input_function)(gpointer, void*, b_input_condition);
+typedef void (*ssl_input_function)(gpointer, void*, GaimInputCondition);
 
 G_MODULE_EXPORT void *ssl_connect( char *host, int port, ssl_input_function func, gpointer data );
@@ -40 +40 @@
 G_MODULE_EXPORT void ssl_disconnect( void *conn_ );
 G_MODULE_EXPORT int ssl_getfd( void *conn );
-G_MODULE_EXPORT b_input_condition ssl_getdirection( void *conn );
+G_MODULE_EXPORT GaimInputCondition ssl_getdirection( void *conn );

protocols/ssl_gnutls.c

@@ -48 +48 @@
 };
 
-static gboolean ssl_connected( gpointer data, gint source, b_input_condition cond );
+static void ssl_connected( gpointer data, gint source, GaimInputCondition cond );
 
 
@@ -81 +81 @@
 }
 
-static gboolean ssl_handshake( gpointer data, gint source, b_input_condition cond );
-
-static gboolean ssl_connected( gpointer data, gint source, b_input_condition cond )
+static void ssl_handshake( gpointer data, gint source, GaimInputCondition cond );
+
+static void ssl_connected( gpointer data, gint source, GaimInputCondition cond )
 {
         struct scd *conn = data;
@@ -96 +96 @@
                 g_free( conn );
                 
-                return FALSE;
+                return;
         }
         
@@ -102 +102 @@
         gnutls_transport_set_ptr( conn->session, (gnutls_transport_ptr) conn->fd );
         
-        return ssl_handshake( data, source, cond );
-}
-
-static gboolean ssl_handshake( gpointer data, gint source, b_input_condition cond )
+        ssl_handshake( data, source, cond );
+}
+
+static void ssl_handshake( gpointer data, gint source, GaimInputCondition cond )
 {
         struct scd *conn = data;
         int st;
         
+        if( conn->inpa != -1 )
+        {
+                gaim_input_remove( conn->inpa );
+                conn->inpa = -1;
+        }
+        
         if( ( st = gnutls_handshake( conn->session ) ) < 0 )
         {
                 if( st == GNUTLS_E_AGAIN || st == GNUTLS_E_INTERRUPTED )
                 {
-                        conn->inpa = b_input_add( conn->fd, ssl_getdirection( conn ),
-                                                  ssl_handshake, data );
+                        conn->inpa = gaim_input_add( conn->fd, ssl_getdirection( conn ),
+                                                     ssl_handshake, data );
                 }
                 else
@@ -136 +142 @@
                 conn->func( conn->data, conn, cond );
         }
-        
-        return FALSE;
 }
 
@@ -183 +187 @@
         
         if( conn->inpa != -1 )
-                b_event_remove( conn->inpa );
+                gaim_input_remove( conn->inpa );
         
         if( conn->established )
@@ -200 +204 @@
 }
 
-b_input_condition ssl_getdirection( void *conn )
+GaimInputCondition ssl_getdirection( void *conn )
 {
         return( gnutls_record_get_direction( ((struct scd*)conn)->session ) ?

protocols/ssl_nss.c

@@ -52 +52 @@
 };
 
-static gboolean ssl_connected( gpointer data, gint source, b_input_condition cond );
+static void ssl_connected( gpointer data, gint source, GaimInputCondition cond );
 
 
@@ -116 +116 @@
 }
 
-static gboolean ssl_connected( gpointer data, gint source, b_input_condition cond )
+static void ssl_connected( gpointer data, gint source, GaimInputCondition cond )
 {
         struct scd *conn = data;
@@ -140 +140 @@
         conn->established = TRUE;
         conn->func( conn->data, conn, cond );
-        return FALSE;
+        return;
         
         ssl_connected_failure:
@@ -149 +149 @@
         if( source >= 0 ) closesocket( source );
         g_free( conn );
-        
-        return FALSE;
 }
 
@@ -184 +182 @@
 }
 
-b_input_condition ssl_getdirection( void *conn )
+GaimInputCondition ssl_getdirection( void *conn )
 {
         /* Just in case someone calls us, let's return the most likely case: */

protocols/ssl_openssl.c

@@ -52 +52 @@
 };
 
-static gboolean ssl_connected( gpointer data, gint source, b_input_condition cond );
+static void ssl_connected( gpointer data, gint source, GaimInputCondition cond );
+
 
 
@@ -94 +95 @@
 }
 
-static gboolean ssl_handshake( gpointer data, gint source, b_input_condition cond );
-
-static gboolean ssl_connected( gpointer data, gint source, b_input_condition cond )
+static void ssl_handshake( gpointer data, gint source, GaimInputCondition cond );
+
+static void ssl_connected( gpointer data, gint source, GaimInputCondition cond )
 {
         struct scd *conn = data;
@@ -103 +104 @@
                 return ssl_handshake( data, -1, cond );
         
-        /* We can do at least the handshake with non-blocking I/O */
+        /* Make it non-blocking at least during the handshake... */
         sock_make_nonblocking( conn->fd );
         SSL_set_fd( conn->ssl, conn->fd );
@@ -110 +111 @@
 }       
 
-static gboolean ssl_handshake( gpointer data, gint source, b_input_condition cond )
+static void ssl_handshake( gpointer data, gint source, GaimInputCondition cond )
 {
         struct scd *conn = data;
         int st;
+        
+        if( conn->inpa != -1 )
+        {
+                gaim_input_remove( conn->inpa );
+                conn->inpa = -1;
+        }
         
         if( ( st = SSL_connect( conn->ssl ) ) < 0 )
@@ -121 +128 @@
                         goto ssl_connected_failure;
                 
-                conn->inpa = b_input_add( conn->fd, ssl_getdirection( conn ), ssl_handshake, data );
-                return FALSE;
+                conn->inpa = gaim_input_add( conn->fd, ssl_getdirection( conn ), ssl_handshake, data );
+                return;
         }
         
@@ -128 +135 @@
         sock_make_blocking( conn->fd );         /* For now... */
         conn->func( conn->data, conn, cond );
-        return FALSE;
+        return;
         
 ssl_connected_failure:
@@ -144 +151 @@
         if( source >= 0 ) closesocket( source );
         g_free( conn );
-        
-        return FALSE;
 }
 
@@ -199 +204 @@
         
         if( conn->inpa != -1 )
-                b_event_remove( conn->inpa );
+                gaim_input_remove( conn->inpa );
         
         if( conn->established )
@@ -216 +221 @@
 }
 
-b_input_condition ssl_getdirection( void *conn )
+GaimInputCondition ssl_getdirection( void *conn )
 {
         return( ((struct scd*)conn)->lasterr == SSL_ERROR_WANT_WRITE ? GAIM_INPUT_WRITE : GAIM_INPUT_READ );

protocols/yahoo/yahoo.c

@@ -443 +443 @@
 };
 
-void byahoo_connect_callback( gpointer data, gint source, b_input_condition cond )
+void byahoo_connect_callback( gpointer data, gint source, GaimInputCondition cond )
 {
         struct byahoo_connect_callback_data *d = data;
@@ -465 +465 @@
 };
 
-gboolean byahoo_read_ready_callback( gpointer data, gint source, b_input_condition cond )
+void byahoo_read_ready_callback( gpointer data, gint source, GaimInputCondition cond )
 {
         struct byahoo_read_ready_data *d = data;
         
         if( !byahoo_get_gc_by_id( d->id ) )
+        {
                 /* WTF doesn't libyahoo clean this up? */
-                return FALSE;
+                ext_yahoo_remove_handler( d->id, d->tag );
+                return;
+        }
         
         yahoo_read_ready( d->id, d->fd, d->data );
-        
-        return TRUE;
 }
 
@@ -486 +487 @@
 };
 
-gboolean byahoo_write_ready_callback( gpointer data, gint source, b_input_condition cond )
+void byahoo_write_ready_callback( gpointer data, gint source, GaimInputCondition cond )
 {
         struct byahoo_write_ready_data *d = data;
         
         if( !byahoo_get_gc_by_id( d->id ) )
+        {
                 /* WTF doesn't libyahoo clean this up? */
-                return FALSE;
+                ext_yahoo_remove_handler( d->id, d->tag );
+                return;
+        }
         
         yahoo_write_ready( d->id, d->fd, d->data );
-        
-        return FALSE;
 }
 
@@ -685 +687 @@
                 
                 inp->d = d;
-                d->tag = inp->h = b_input_add( fd, GAIM_INPUT_READ, (b_event_handler) byahoo_read_ready_callback, (gpointer) d );
+                d->tag = inp->h = gaim_input_add( fd, GAIM_INPUT_READ, (GaimInputFunction) byahoo_read_ready_callback, (gpointer) d );
         }
         else if( cond == YAHOO_INPUT_WRITE )
@@ -696 +698 @@
                 
                 inp->d = d;
-                d->tag = inp->h = b_input_add( fd, GAIM_INPUT_WRITE, (b_event_handler) byahoo_write_ready_callback, (gpointer) d );
+                d->tag = inp->h = gaim_input_add( fd, GAIM_INPUT_WRITE, (GaimInputFunction) byahoo_write_ready_callback, (gpointer) d );
         }
         else
@@ -727 +729 @@
         }
         
-        b_event_remove( tag );
+        gaim_input_remove( tag );
 }
 
@@ -736 +738 @@
         
         d = g_new0( struct byahoo_connect_callback_data, 1 );
-        if( ( fd = proxy_connect( host, port, (b_event_handler) byahoo_connect_callback, (gpointer) d ) ) < 0 )
+        if( ( fd = proxy_connect( host, port, (GaimInputFunction) byahoo_connect_callback, (gpointer) d ) ) < 0 )
         {
                 g_free( d );

sock.h

@@ -18 +18 @@
 #define sock_make_blocking(fd) fcntl(fd, F_SETFL, 0)
 #define sockerr_again() (errno == EINPROGRESS || errno == EINTR)
-#ifndef EVENTS_LIBEVENT
 #define closesocket(a) close(a)
-#endif
 #else
 # include <winsock2.h>

unix.c

@@ -47 +47 @@
         memset( &global, 0, sizeof( global_t ) );
         
-        b_main_init();
+        global.loop = g_main_new( FALSE );
         
         log_init();
@@ -117 +117 @@
                 log_message( LOGLVL_WARNING, "Error opening helpfile %s.", HELP_FILE );
         
-        b_main_run();
+        g_main_run( global.loop );
         
         if( global.restart )
@@ -165 +165 @@
                         
                         log_message( LOGLVL_ERROR, "SIGTERM received, cleaning up process." );
-                        b_timeout_add( 1, (b_event_handler) bitlbee_shutdown, NULL );
+                        g_timeout_add_full( G_PRIORITY_LOW, 1, (GSourceFunc) bitlbee_shutdown, NULL, NULL );
                         
                         first = 0;

user.c

@@ -109 +109 @@
                         if( u->handle ) g_free( u->handle );
                         if( u->sendbuf ) g_free( u->sendbuf );
-                        if( u->sendbuf_timer ) b_event_remove( u->sendbuf_timer );
+                        if( u->sendbuf_timer ) g_source_remove( u->sendbuf_timer );
                         g_free( u );