Changeset b72caac

Timestamp:

2006-06-21T16:34:33Z (19 years ago)

Author:

Wilmer van der Gaast <wilmer@…>

Branches:

master

Children:

59f5c42a

Parents:

3af70b0 (diff), df417ca (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merging libevent branch: Events can now be handles by both glib and libevent.

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

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_INSTEAD__
+#define free            __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM__
 #undef malloc
-#define malloc          __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM_INSTEAD__
+#define malloc          __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM__
 #undef calloc
-#define calloc          __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM_INSTEAD__
+#define calloc          __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM__
 #undef realloc
-#define realloc         __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM_INSTEAD__
+#define realloc         __PLEASE_USE_THE_GLIB_MEMORY_ALLOCATION_SYSTEM__
 #undef strdup
-#define strdup          __PLEASE_USE_THE_GLIB_STRDUP_FUNCTIONS_SYSTEM_INSTEAD__
+#define strdup          __PLEASE_USE_THE_GLIB_STRDUP_FUNCTIONS_SYSTEM__
 #undef strndup
-#define strndup         __PLEASE_USE_THE_GLIB_STRDUP_FUNCTIONS_SYSTEM_INSTEAD__
+#define strndup         __PLEASE_USE_THE_GLIB_STRDUP_FUNCTIONS_SYSTEM__
 #undef snprintf
-#define snprintf        __PLEASE_USE_G_SNPRINTF_INSTEAD__
+#define snprintf        __PLEASE_USE_G_SNPRINTF__
 #undef strcasecmp
-#define strcasecmp      __PLEASE_USE_G_STRCASECMP_INSTEAD__
+#define strcasecmp      __PLEASE_USE_G_STRCASECMP__
 #undef strncasecmp
-#define strncasecmp     __PLEASE_USE_G_STRNCASECMP_INSTEAD__
+#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__
 
 #ifndef F_OK
@@ -112 +131 @@
 #include "sock.h"
 #include "util.h"
+#include "proxy.h"
 
 typedef struct global {
@@ -121 +141 @@
         GList *storage; /* The first backend in the list will be used for saving */
         char *helpfile;
-        GMainLoop *loop;
         int restart;
 } global_t;
@@ -128 +147 @@
 int bitlbee_inetd_init( void );
 
-gboolean bitlbee_io_current_client_read( GIOChannel *source, GIOCondition condition, gpointer data );
-gboolean bitlbee_io_current_client_write( GIOChannel *source, GIOCondition condition, gpointer data );
+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 );
 
 void root_command_string( irc_t *irc, user_t *u, char *command, int flags );
 void root_command( irc_t *irc, char *command[] );
-void bitlbee_shutdown( gpointer data );
+gboolean bitlbee_shutdown( gpointer data, gint fd, b_input_condition cond );
 
 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
@@ -28 +29 @@
 strip=1
 ipv6=1
+
+events=glib
 ssl=auto
 
@@ -64 +67 @@
 --ipv6=0/1      IPv6 socket support                     $ipv6
 
+--events=...    Event handler (glib, libevent)          $events
 --ssl=...       SSL library to use (gnutls, nss, openssl, bogus, auto)
                                                         $ssl
@@ -80 +84 @@
 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'`
 
@@ -173 +179 @@
 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()
 {
@@ -401 +430 @@
 fi
 
-if [ "$msn" = "1" ]; then
-        echo '  Using SSL library: '$ssl;
-fi
+echo '  Using event handler: '$events;
+echo '  Using SSL library: '$ssl;
 
 #if [ "$flood" = "0" ]; then

ipc.c

@@ -60 +60 @@
                 ipc_to_children_str( "DIE\r\n" );
         
-        bitlbee_shutdown( NULL );
+        bitlbee_shutdown( NULL, -1, 0 );
 }
 
@@ -91 +91 @@
         
         global.restart = -1;
-        bitlbee_shutdown( NULL );
+        bitlbee_shutdown( NULL, -1, 0 );
 }
 
@@ -246 +246 @@
 }
 
-void ipc_master_read( gpointer data, gint source, GaimInputCondition cond )
+gboolean ipc_master_read( gpointer data, gint source, b_input_condition cond )
 {
         char *buf, **cmd;
@@ -272 +272 @@
                 }
         }
-}
-
-void ipc_child_read( gpointer data, gint source, GaimInputCondition cond )
+        
+        return TRUE;
+}
+
+gboolean ipc_child_read( gpointer data, gint source, b_input_condition cond )
 {
         char *buf, **cmd;
@@ -286 +288 @@
         else
         {
-                gaim_input_remove( global.listen_watch_source_id );
+                b_event_remove( global.listen_watch_source_id );
                 close( global.listen_socket );
                 
                 global.listen_socket = -1;
         }
+        
+        return TRUE;
 }
 
@@ -397 +401 @@
 void ipc_master_free_one( struct bitlbee_child *c )
 {
-        gaim_input_remove( c->ipc_inpa );
+        b_event_remove( c->ipc_inpa );
         closesocket( c->ipc_fd );
         
@@ -463 +467 @@
 
 
-static gboolean new_ipc_client (GIOChannel *gio, GIOCondition cond, gpointer data)
+static gboolean new_ipc_client( gpointer data, gint serversock, b_input_condition cond )
 {
         struct bitlbee_child *child = g_new0( struct bitlbee_child, 1 );
-        int serversock;
-
-        serversock = g_io_channel_unix_get_fd(gio);
-
-        child->ipc_fd = accept(serversock, NULL, 0);
-
-        if (child->ipc_fd == -1) {
+        
+        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 = gaim_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
-                
+        child->ipc_inpa = b_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
+        
         child_list = g_slist_append( child_list, child );
-
+        
         return TRUE;
 }
@@ -489 +491 @@
         struct sockaddr_un un_addr;
         int serversock;
-        GIOChannel *gio;
 
         /* Clean up old socket files that were hanging around.. */
@@ -517 +518 @@
         }
         
-        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);
+        b_input_add( serversock, GAIM_INPUT_READ, new_ipc_client, NULL );
+        
         return 1;
 }
@@ -563 +558 @@
                         return 0;
                 }
-                child->ipc_inpa = gaim_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
+                child->ipc_inpa = b_input_add( child->ipc_fd, GAIM_INPUT_READ, ipc_master_read, child );
                 
                 child_list = g_slist_append( child_list, child );

ipc.h

@@ -40 +40 @@
 
 
-void ipc_master_read( gpointer data, gint source, GaimInputCondition cond );
-void ipc_child_read( gpointer data, gint source, GaimInputCondition cond );
+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_free_one( struct bitlbee_child *child );

irc.c

@@ -29 +29 @@
 #include "ipc.h"
 
-static gboolean irc_userping( gpointer _irc );
+static gboolean irc_userping( gpointer _irc, int fd, b_input_condition cond );
 
 GSList *irc_connection_list = NULL;
@@ -54 +54 @@
         
         irc->fd = fd;
-        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 );
+        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->status = USTATUS_OFFLINE;
@@ -116 +114 @@
 
         if( global.conf->ping_interval > 0 && global.conf->ping_timeout > 0 )
-                irc->ping_source_id = g_timeout_add( global.conf->ping_interval * 1000, irc_userping, irc );
+                irc->ping_source_id = b_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" );
@@ -186 +184 @@
                    bitlbee_.._write doesn't do it first. */
                 
-                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 );
+                b_event_remove( irc->r_watch_source_id );
+                irc->r_watch_source_id = b_timeout_add( 1000, (b_event_handler) irc_free, irc );
         }
         else
@@ -220 +218 @@
         
         if( irc->ping_source_id > 0 )
-                g_source_remove( irc->ping_source_id );
-        g_source_remove( irc->r_watch_source_id );
+                b_event_remove( irc->ping_source_id );
+        b_event_remove( irc->r_watch_source_id );
         if( irc->w_watch_source_id > 0 )
-                g_source_remove( irc->w_watch_source_id );
-        
-        g_io_channel_unref( irc->io_channel );
+                b_event_remove( irc->w_watch_source_id );
+        
         irc_connection_list = g_slist_remove( irc_connection_list, irc );
         
@@ -275 +272 @@
                         if(user->host!=user->nick) g_free(user->host);
                         if(user->realname!=user->nick) g_free(user->realname);
-                        gaim_input_remove(user->sendbuf_timer);
+                        b_event_remove(user->sendbuf_timer);
                                         
                         usertmp = user;
@@ -325 +322 @@
         
         if( global.conf->runmode == RUNMODE_INETD || global.conf->runmode == RUNMODE_FORKDAEMON )
-                g_main_quit( global.loop );
+                b_main_quit();
 }
 
@@ -579 +576 @@
         char line[IRC_MAX_LINE+1], *cs;
                 
-        if( irc->quit )
+        /* Don't try to write anything new anymore when shutting down. */
+        if( irc->status == USTATUS_SHUTDOWN )
                 return;
         
@@ -596 +594 @@
         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 )
         {
-                irc->w_watch_source_id = g_io_add_watch( irc->io_channel, G_IO_OUT, bitlbee_io_current_client_write, irc );
+                /* 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 );
         }
         
@@ -632 +638 @@
                 if( now )
                 {
-                        bitlbee_io_current_client_write( irc->io_channel, G_IO_OUT, irc );
+                        bitlbee_io_current_client_write( irc, irc->fd, GAIM_INPUT_WRITE );
                 }
                 temp = temp->next;
@@ -1035 +1041 @@
 }
 
-gboolean buddy_send_handler_delayed( gpointer data )
+static gboolean buddy_send_handler_delayed( gpointer data, gint fd, b_input_condition cond )
 {
         user_t *u = data;
@@ -1066 +1072 @@
                 {
                         /* Flush the buffer */
-                        g_source_remove( u->sendbuf_timer );
-                        buddy_send_handler_delayed( u );
+                        b_event_remove( u->sendbuf_timer );
+                        buddy_send_handler_delayed( u, -1, 0 );
                 }
 
@@ -1091 +1097 @@
                 
                 if( u->sendbuf_timer > 0 )
-                        g_source_remove( u->sendbuf_timer );
-                u->sendbuf_timer = g_timeout_add( delay, buddy_send_handler_delayed, u );
+                        b_event_remove( u->sendbuf_timer );
+                u->sendbuf_timer = b_timeout_add( delay, buddy_send_handler_delayed, u );
         }
         else
@@ -1176 +1182 @@
    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 )
+static gboolean irc_userping( gpointer _irc, gint fd, b_input_condition cond )
 {
         irc_t *irc = _irc;

irc.h

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

protocols/Makefile

@@ -10 +10 @@
 
 # [SH] Program variables
-objects = http_client.o md5.o nogaim.o proxy.o sha.o $(SSL_CLIENT)
+objects = $(EVENT_HANDLER) 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 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 );
+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 );
 
 
@@ -104 +104 @@
 /* This one is actually pretty simple... Might get more calls if we can't write 
    the whole request at once. */
-static void http_connected( gpointer data, int source, GaimInputCondition cond )
+static gboolean http_connected( gpointer data, int source, b_input_condition cond )
 {
         struct http_request *req = data;
@@ -113 +113 @@
         
         if( req->inpa > 0 )
-                gaim_input_remove( req->inpa );
+                b_event_remove( req->inpa );
         
         sock_make_nonblocking( req->fd );
@@ -148 +148 @@
         
         if( req->bytes_written < req->request_length )
-                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;
+                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;
         
 error:
@@ -164 +164 @@
         g_free( req );
         
-        return;
+        return FALSE;
 }
 
-static void http_ssl_connected( gpointer data, void *source, GaimInputCondition cond )
+static gboolean http_ssl_connected( gpointer data, void *source, b_input_condition cond )
 {
         struct http_request *req = data;
@@ -179 +179 @@
 }
 
-static void http_incoming_data( gpointer data, int source, GaimInputCondition cond )
+static gboolean http_incoming_data( gpointer data, int source, b_input_condition cond )
 {
         struct http_request *req = data;
@@ -188 +188 @@
         
         if( req->inpa > 0 )
-                gaim_input_remove( req->inpa );
+                b_event_remove( req->inpa );
         
         if( req->ssl )
@@ -236 +236 @@
         
         /* There will be more! */
-        req->inpa = gaim_input_add( req->fd,
-                                    req->ssl ? ssl_getdirection( req->ssl ) : GAIM_INPUT_READ,
-                                    http_incoming_data, req );
-        
-        return;
+        req->inpa = b_input_add( req->fd,
+                                 req->ssl ? ssl_getdirection( req->ssl ) : GAIM_INPUT_READ,
+                                 http_incoming_data, req );
+        
+        return FALSE;
 
 got_reply:
@@ -430 +430 @@
                 req->reply_headers = req->reply_body = NULL;
                 
-                return;
+                return FALSE;
         }
         
@@ -449 +449 @@
         g_free( req->status_string );
         g_free( req );
+        
+        return FALSE;
 }

protocols/jabber/jabber.c

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

protocols/msn/msn.h

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

protocols/msn/ns.c

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

protocols/msn/sb.c

@@ -30 +30 @@
 #include "md5.h"
 
-static void msn_sb_callback( gpointer data, gint source, GaimInputCondition cond );
+static gboolean msn_sb_callback( gpointer data, gint source, b_input_condition 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 ) gaim_input_remove( sb->inp );
+        if( sb->inp ) b_event_remove( sb->inp );
         closesocket( sb->fd );
         
@@ -245 +245 @@
 }
 
-void msn_sb_connected( gpointer data, gint source, GaimInputCondition cond )
+gboolean msn_sb_connected( gpointer data, gint source, b_input_condition cond )
 {
         struct msn_switchboard *sb = data;
@@ -254 +254 @@
         /* Are we still alive? */
         if( !g_slist_find( msn_switchboards, sb ) )
-                return;
+                return FALSE;
         
         gc = sb->gc;
@@ -263 +263 @@
                 debug( "ERROR %d while connecting to switchboard server", 1 );
                 msn_sb_destroy( sb );
-                return;
+                return FALSE;
         }
         
@@ -280 +280 @@
         
         if( msn_sb_write( sb, buf, strlen( buf ) ) )
-                sb->inp = gaim_input_add( sb->fd, GAIM_INPUT_READ, msn_sb_callback, sb );
+                sb->inp = b_input_add( sb->fd, GAIM_INPUT_READ, msn_sb_callback, sb );
         else
                 debug( "ERROR %d while connecting to switchboard server", 2 );
-}
-
-static void msn_sb_callback( gpointer data, gint source, GaimInputCondition cond )
+        
+        return FALSE;
+}
+
+static gboolean msn_sb_callback( gpointer data, gint source, b_input_condition cond )
 {
         struct msn_switchboard *sb = data;
@@ -293 +295 @@
                 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-2004 Wilmer van der Gaast and others                *
+  * Copyright 2002-2006 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
  */
 
@@ -160 +158 @@
          * 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 );
@@ -240 +238 @@
 }
 
-static gboolean send_keepalive( gpointer d )
+static gboolean send_keepalive( gpointer d, gint fd, b_input_condition cond )
 {
         struct gaim_connection *gc = d;
@@ -264 +262 @@
         serv_got_crap( gc, "Logged in" );
         
-        gc->keepalive = g_timeout_add( 60000, send_keepalive, gc );
+        gc->keepalive = b_timeout_add( 60000, send_keepalive, gc );
         gc->flags |= OPT_LOGGED_IN;
         
@@ -272 +270 @@
 }
 
-gboolean auto_reconnect( gpointer data )
+gboolean auto_reconnect( gpointer data, gint fd, b_input_condition cond )
 {
         account_t *a = data;
@@ -284 +282 @@
 void cancel_auto_reconnect( account_t *a )
 {
-        while( g_source_remove_by_user_data( (gpointer) a ) );
+        /* while( b_event_remove_by_data( (gpointer) a ) ); */
+        b_event_remove( a->reconnect );
         a->reconnect = 0;
 }
@@ -295 +294 @@
         
         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 );
-        gaim_input_remove( gc->inpa );
+        b_event_remove( gc->inpa );
         
         while( u )
@@ -327 +326 @@
         {
                 int delay = set_getint( irc, "auto_reconnect_delay" );
+                
                 serv_got_crap( gc, "Reconnecting in %d seconds..", delay );
-                
-                a->reconnect = 1;
-                g_timeout_add( delay * 1000, auto_reconnect, a );
+                a->reconnect = b_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 );
+gboolean auto_reconnect( gpointer data, gint fd, b_input_condition cond );
 void cancel_auto_reconnect( struct account *a );
 

protocols/oscar/oscar.c

@@ -255 +255 @@
 static int msgerrreasonlen = 25;
 
-static void oscar_callback(gpointer data, gint source,
-                                GaimInputCondition condition) {
+static gboolean oscar_callback(gpointer data, gint source,
+                                b_input_condition 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;
+                return FALSE;
         }
       
@@ -270 +270 @@
                 /* oh boy. this is probably bad. i guess the only thing we 
                  * can really do is return? */
-                return;
+                return FALSE;
         }
 
@@ -290 +290 @@
                                 c->conn = NULL;
                                 if (c->inpa > 0)
-                                        gaim_input_remove(c->inpa);
+                                        b_event_remove(c->inpa);
                                 c->inpa = 0;
                                 c->fd = -1;
@@ -298 +298 @@
                         } else if (conn->type == AIM_CONN_TYPE_CHATNAV) {
                                 if (odata->cnpa > 0)
-                                        gaim_input_remove(odata->cnpa);
+                                        b_event_remove(odata->cnpa);
                                 odata->cnpa = 0;
                                 while (odata->create_rooms) {
@@ -312 +312 @@
                         } else if (conn->type == AIM_CONN_TYPE_AUTH) {
                                 if (odata->paspa > 0)
-                                        gaim_input_remove(odata->paspa);
+                                        b_event_remove(odata->paspa);
                                 odata->paspa = 0;
                                 aim_conn_kill(odata->sess, &conn);
@@ -319 +319 @@
                         }
                 }
-        }
-}
-
-static void oscar_login_connect(gpointer data, gint source, GaimInputCondition cond)
+        } else {
+                /* WTF??? */
+                return FALSE;
+        }
+                
+        return TRUE;
+}
+
+static gboolean oscar_login_connect(gpointer data, gint source, b_input_condition cond)
 {
         struct gaim_connection *gc = data;
@@ -331 +336 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return;
+                return FALSE;
         }
 
@@ -341 +346 @@
                 hide_login_progress(gc, _("Couldn't connect to host"));
                 signoff(gc);
-                return;
+                return FALSE;
         }
 
         aim_conn_completeconnect(sess, conn);
-        gc->inpa = gaim_input_add(conn->fd, GAIM_INPUT_READ,
+        gc->inpa = b_input_add(conn->fd, GAIM_INPUT_READ,
                         oscar_callback, conn);
+        
+        return FALSE;
 }
 
@@ -414 +421 @@
                 struct chat_connection *n = odata->oscar_chats->data;
                 if (n->inpa > 0)
-                        gaim_input_remove(n->inpa);
+                        b_event_remove(n->inpa);
                 g_free(n->name);
                 g_free(n->show);
@@ -433 +440 @@
                 g_free(odata->oldp);
         if (gc->inpa > 0)
-                gaim_input_remove(gc->inpa);
+                b_event_remove(gc->inpa);
         if (odata->cnpa > 0)
-                gaim_input_remove(odata->cnpa);
+                b_event_remove(odata->cnpa);
         if (odata->paspa > 0)
-                gaim_input_remove(odata->paspa);
+                b_event_remove(odata->paspa);
         aim_session_kill(odata->sess);
         g_free(odata->sess);
@@ -445 +452 @@
 }
 
-static void oscar_bos_connect(gpointer data, gint source, GaimInputCondition cond) {
+static gboolean oscar_bos_connect(gpointer data, gint source, b_input_condition cond) {
         struct gaim_connection *gc = data;
         struct oscar_data *odata;
@@ -453 +460 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return;
+                return FALSE;
         }
 
@@ -463 +470 @@
                 hide_login_progress(gc, _("Could Not Connect"));
                 signoff(gc);
-                return;
+                return FALSE;
         }
 
         aim_conn_completeconnect(sess, bosconn);
-        gc->inpa = gaim_input_add(bosconn->fd, GAIM_INPUT_READ,
+        gc->inpa = b_input_add(bosconn->fd, GAIM_INPUT_READ,
                         oscar_callback, bosconn);
         set_login_progress(gc, 4, _("Connection established, cookie sent"));
+        
+        return FALSE;
 }
 
@@ -572 +581 @@
         }
         aim_sendcookie(sess, bosconn, info->cookie);
-        gaim_input_remove(gc->inpa);
+        b_event_remove(gc->inpa);
 
         return 1;
@@ -587 +596 @@
 };
 
-static void damn_you(gpointer data, gint source, GaimInputCondition c)
+static gboolean damn_you(gpointer data, gint source, b_input_condition c)
 {
         struct pieceofcrap *pos = data;
@@ -607 +616 @@
                 do_error_dialog(pos->gc, "Gaim was unable to get a valid hash for logging into AIM."
                                 " You may be disconnected shortly.", "Login Error");
-                gaim_input_remove(pos->inpa);
+                b_event_remove(pos->inpa);
                 closesocket(pos->fd);
                 g_free(pos);
-                return;
+                return FALSE;
         }
         /* [WvG] Wheeeee! Who needs error checking anyway? ;-) */
         read(pos->fd, m, 16);
         m[16] = '\0';
-        gaim_input_remove(pos->inpa);
+        b_event_remove(pos->inpa);
         closesocket(pos->fd);
         aim_sendmemblock(od->sess, pos->conn, 0, 16, m, AIM_SENDMEMBLOCK_FLAG_ISHASH);
         g_free(pos);
-}
-
-static void straight_to_hell(gpointer data, gint source, GaimInputCondition cond) {
+        
+        return FALSE;
+}
+
+static gboolean straight_to_hell(gpointer data, gint source, b_input_condition cond) {
         struct pieceofcrap *pos = data;
         char buf[BUF_LONG];
@@ -631 +642 @@
                         g_free(pos->modname);
                 g_free(pos);
-                return;
+                return FALSE;
         }
 
@@ -640 +651 @@
         if (pos->modname)
                 g_free(pos->modname);
-        pos->inpa = gaim_input_add(pos->fd, GAIM_INPUT_READ, damn_you, pos);
-        return;
+        pos->inpa = b_input_add(pos->fd, GAIM_INPUT_READ, damn_you, pos);
+        return FALSE;
 }
 
@@ -763 +774 @@
 }
 
-static void oscar_chatnav_connect(gpointer data, gint source, GaimInputCondition cond) {
+static gboolean oscar_chatnav_connect(gpointer data, gint source, b_input_condition cond) {
         struct gaim_connection *gc = data;
         struct oscar_data *odata;
@@ -771 +782 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return;
+                return FALSE;
         }
 
@@ -780 +791 @@
         if (source < 0) {
                 aim_conn_kill(sess, &tstconn);
-                return;
+                return FALSE;
         }
 
         aim_conn_completeconnect(sess, tstconn);
-        odata->cnpa = gaim_input_add(tstconn->fd, GAIM_INPUT_READ,
+        odata->cnpa = b_input_add(tstconn->fd, GAIM_INPUT_READ,
                                         oscar_callback, tstconn);
-}
-
-static void oscar_auth_connect(gpointer data, gint source, GaimInputCondition cond)
+        
+        return FALSE;
+}
+
+static gboolean oscar_auth_connect(gpointer data, gint source, b_input_condition cond)
 {
         struct gaim_connection *gc = data;
@@ -797 +810 @@
         if (!g_slist_find(get_connections(), gc)) {
                 closesocket(source);
-                return;
+                return FALSE;
         }
 
@@ -806 +819 @@
         if (source < 0) {
                 aim_conn_kill(sess, &tstconn);
-                return;
+                return FALSE;
         }
 
         aim_conn_completeconnect(sess, tstconn);
-        odata->paspa = gaim_input_add(tstconn->fd, GAIM_INPUT_READ,
+        odata->paspa = b_input_add(tstconn->fd, GAIM_INPUT_READ,
                                 oscar_callback, tstconn);
-}
-
-static void oscar_chat_connect(gpointer data, gint source, GaimInputCondition cond)
+        
+        return FALSE;
+}
+
+static gboolean oscar_chat_connect(gpointer data, gint source, b_input_condition cond)
 {
         struct chat_connection *ccon = data;
@@ -827 +842 @@
                 g_free(ccon->name);
                 g_free(ccon);
-                return;
+                return FALSE;
         }
 
@@ -839 +854 @@
                 g_free(ccon->name);
                 g_free(ccon);
-                return;
+                return FALSE;
         }
 
         aim_conn_completeconnect(sess, ccon->conn);
-        ccon->inpa = gaim_input_add(tstconn->fd,
+        ccon->inpa = b_input_add(tstconn->fd,
                         GAIM_INPUT_READ,
                         oscar_callback, tstconn);
         odata->oscar_chats = g_slist_append(odata->oscar_chats, ccon);
+        
+        return FALSE;
 }
 
@@ -2565 +2582 @@
         od->oscar_chats = g_slist_remove(od->oscar_chats, cc);
         if (cc->inpa > 0)
-                gaim_input_remove(cc->inpa);
+                b_event_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>
@@ -46 +42 @@
 #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;
@@ -57 +49 @@
 
 struct PHB {
-        GaimInputFunction func, proxy_func;
+        b_event_handler func, proxy_func;
         gpointer data, proxy_data;
         char *host;
@@ -64 +56 @@
         gint inpa;
 };
-
-typedef struct _GaimIOClosure {
-        GaimInputFunction function;
-        guint result;
-        gpointer data;
-} GaimIOClosure;
 
 
@@ -92 +78 @@
 }
 
-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)
+static gboolean gaim_io_connected(gpointer data, gint source, b_input_condition cond)
 {
         struct PHB *phb = data;
@@ -122 +88 @@
         if (getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
                 closesocket(source);
-                gaim_input_remove(phb->inpa);
+                b_event_remove(phb->inpa);
                 if( phb->proxy_func )
                         phb->proxy_func(phb->proxy_data, -1, GAIM_INPUT_READ);
@@ -129 +95 @@
                         g_free(phb);
                 }
-                return;
+                return FALSE;
         }
 #endif
         sock_make_blocking(source);
-        gaim_input_remove(phb->inpa);
+        b_event_remove(phb->inpa);
         if( phb->proxy_func )
                 phb->proxy_func(phb->proxy_data, source, GAIM_INPUT_READ);
@@ -140 +106 @@
                 g_free(phb);
         }
+        
+        return FALSE;
 }
 
@@ -158 +126 @@
 
         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 = gaim_input_add(fd, GAIM_INPUT_WRITE, gaim_io_connected, phb);
+                        phb->inpa = b_input_add(fd, GAIM_INPUT_WRITE, gaim_io_connected, phb);
                         phb->fd = fd;
                 } else {
@@ -179 +149 @@
 #define HTTP_GOODSTRING2 "HTTP/1.1 200 Connection established"
 
-static void http_canread(gpointer data, gint source, GaimInputCondition cond)
+static gboolean http_canread(gpointer data, gint source, b_input_condition cond)
 {
         int nlc = 0;
@@ -186 +156 @@
         char inputline[8192];
 
-        gaim_input_remove(phb->inpa);
+        b_event_remove(phb->inpa);
 
         while ((pos < sizeof(inputline)-1) && (nlc != 2) && (read(source, &inputline[pos++], 1) == 1)) {
@@ -201 +171 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
@@ -208 +178 @@
         g_free(phb->host);
         g_free(phb);
-        return;
-}
-
-static void http_canwrite(gpointer data, gint source, GaimInputCondition cond)
+        
+        return FALSE;
+}
+
+static gboolean http_canwrite(gpointer data, gint source, b_input_condition cond)
 {
         char cmd[384];
@@ -218 +189 @@
         int error = ETIMEDOUT;
         if (phb->inpa > 0)
-                gaim_input_remove(phb->inpa);
+                b_event_remove(phb->inpa);
         len = sizeof(error);
         if (getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
@@ -225 +196 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
         sock_make_blocking(source);
@@ -236 +207 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
@@ -251 +222 @@
                         g_free(phb->host);
                         g_free(phb);
-                        return;
+                        return FALSE;
                 }
         }
@@ -261 +232 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
-        }
-
-        phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, http_canread, phb);
+                return FALSE;
+        }
+
+        phb->inpa = b_input_add(source, GAIM_INPUT_READ, http_canread, phb);
+        
+        return FALSE;
 }
 
@@ -280 +253 @@
 /* Connecting to SOCKS4 proxies */
 
-static void s4_canread(gpointer data, gint source, GaimInputCondition cond)
+static gboolean s4_canread(gpointer data, gint source, b_input_condition cond)
 {
         unsigned char packet[12];
         struct PHB *phb = data;
 
-        gaim_input_remove(phb->inpa);
+        b_event_remove(phb->inpa);
 
         memset(packet, 0, sizeof(packet));
@@ -292 +265 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
@@ -299 +272 @@
         g_free(phb->host);
         g_free(phb);
-}
-
-static void s4_canwrite(gpointer data, gint source, GaimInputCondition cond)
+        
+        return FALSE;
+}
+
+static gboolean s4_canwrite(gpointer data, gint source, b_input_condition cond)
 {
         unsigned char packet[12];
@@ -309 +284 @@
         int error = ETIMEDOUT;
         if (phb->inpa > 0)
-                gaim_input_remove(phb->inpa);
+                b_event_remove(phb->inpa);
         len = sizeof(error);
         if (getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
@@ -316 +291 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
         sock_make_blocking(source);
@@ -326 +301 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
@@ -343 +318 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
-        }
-
-        phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, s4_canread, phb);
+                return FALSE;
+        }
+
+        phb->inpa = b_input_add(source, GAIM_INPUT_READ, s4_canread, phb);
+        
+        return FALSE;
 }
 
@@ -362 +339 @@
 /* Connecting to SOCKS5 proxies */
 
-static void s5_canread_again(gpointer data, gint source, GaimInputCondition cond)
+static gboolean s5_canread_again(gpointer data, gint source, b_input_condition cond)
 {
         unsigned char buf[512];
         struct PHB *phb = data;
 
-        gaim_input_remove(phb->inpa);
+        b_event_remove(phb->inpa);
 
         if (read(source, buf, 10) < 10) {
@@ -374 +351 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
         if ((buf[0] != 0x05) || (buf[1] != 0x00)) {
@@ -381 +358 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
@@ -387 +364 @@
         g_free(phb->host);
         g_free(phb);
-        return;
+        
+        return FALSE;
 }
 
@@ -395 +373 @@
         struct PHB *phb = data;
         int hlen = strlen(phb->host);
-
+        
         buf[0] = 0x05;
         buf[1] = 0x01;          /* CONNECT */
@@ -413 +391 @@
         }
 
-        phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, s5_canread_again, phb);
-}
-
-static void s5_readauth(gpointer data, gint source, GaimInputCondition cond)
+        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)
 {
         unsigned char buf[512];
         struct PHB *phb = data;
 
-        gaim_input_remove(phb->inpa);
+        b_event_remove(phb->inpa);
 
         if (read(source, buf, 2) < 2) {
@@ -428 +406 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
@@ -436 +414 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
         s5_sendconnect(phb, source);
-}
-
-static void s5_canread(gpointer data, gint source, GaimInputCondition cond)
+        
+        return FALSE;
+}
+
+static gboolean s5_canread(gpointer data, gint source, b_input_condition cond)
 {
         unsigned char buf[512];
         struct PHB *phb = data;
 
-        gaim_input_remove(phb->inpa);
+        b_event_remove(phb->inpa);
 
         if (read(source, buf, 2) < 2) {
@@ -454 +434 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
@@ -462 +442 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
 
@@ -477 +457 @@
                         g_free(phb->host);
                         g_free(phb);
-                        return;
+                        return FALSE;
                 }
 
-                phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, s5_readauth, phb);
+                phb->inpa = b_input_add(source, GAIM_INPUT_READ, s5_readauth, phb);
         } else {
                 s5_sendconnect(phb, source);
         }
-}
-
-static void s5_canwrite(gpointer data, gint source, GaimInputCondition cond)
+        
+        return FALSE;
+}
+
+static gboolean s5_canwrite(gpointer data, gint source, b_input_condition cond)
 {
         unsigned char buf[512];
@@ -494 +476 @@
         int error = ETIMEDOUT;
         if (phb->inpa > 0)
-                gaim_input_remove(phb->inpa);
+                b_event_remove(phb->inpa);
         len = sizeof(error);
         if (getsockopt(source, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {
@@ -501 +483 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
+                return FALSE;
         }
         sock_make_blocking(source);
@@ -523 +505 @@
                 g_free(phb->host);
                 g_free(phb);
-                return;
-        }
-
-        phb->inpa = gaim_input_add(source, GAIM_INPUT_READ, s5_canread, phb);
+                return FALSE;
+        }
+
+        phb->inpa = b_input_add(source, GAIM_INPUT_READ, s5_canread, phb);
+        
+        return FALSE;
 }
 
@@ -542 +526 @@
 /* Export functions */
 
-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)
+int proxy_connect(const char *host, int port, b_event_handler func, gpointer data)
 {
         struct PHB *phb;

protocols/proxy.h

@@ -1 +1 @@
 /*
- * gaim
+ * nogaim
  *
  * 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
@@ -47 +49 @@
 extern char proxypass[128];
 
-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);
+G_MODULE_EXPORT int proxy_connect(const char *host, int port, b_event_handler func, gpointer data);
 
 #endif /* _PROXY_H_ */

protocols/ssl_bogus.c

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

protocols/ssl_client.h

@@ -33 +33 @@
 extern int ssl_errno;
 
-typedef void (*ssl_input_function)(gpointer, void*, GaimInputCondition);
+typedef gboolean (*ssl_input_function)(gpointer, void*, b_input_condition);
 
 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 GaimInputCondition ssl_getdirection( void *conn );
+G_MODULE_EXPORT b_input_condition ssl_getdirection( void *conn );

protocols/ssl_gnutls.c

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

protocols/ssl_nss.c

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

protocols/ssl_openssl.c

@@ -52 +52 @@
 };
 
-static void ssl_connected( gpointer data, gint source, GaimInputCondition cond );
-
+static gboolean ssl_connected( gpointer data, gint source, b_input_condition cond );
 
 
@@ -95 +94 @@
 }
 
-static void ssl_handshake( gpointer data, gint source, GaimInputCondition cond );
-
-static void ssl_connected( gpointer data, gint source, GaimInputCondition cond )
+static gboolean ssl_handshake( gpointer data, gint source, b_input_condition cond );
+
+static gboolean ssl_connected( gpointer data, gint source, b_input_condition cond )
 {
         struct scd *conn = data;
@@ -104 +103 @@
                 return ssl_handshake( data, -1, cond );
         
-        /* Make it non-blocking at least during the handshake... */
+        /* We can do at least the handshake with non-blocking I/O */
         sock_make_nonblocking( conn->fd );
         SSL_set_fd( conn->ssl, conn->fd );
@@ -111 +110 @@
 }       
 
-static void ssl_handshake( gpointer data, gint source, GaimInputCondition cond )
+static gboolean ssl_handshake( gpointer data, gint source, b_input_condition 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 )
@@ -128 +121 @@
                         goto ssl_connected_failure;
                 
-                conn->inpa = gaim_input_add( conn->fd, ssl_getdirection( conn ), ssl_handshake, data );
-                return;
+                conn->inpa = b_input_add( conn->fd, ssl_getdirection( conn ), ssl_handshake, data );
+                return FALSE;
         }
         
@@ -135 +128 @@
         sock_make_blocking( conn->fd );         /* For now... */
         conn->func( conn->data, conn, cond );
-        return;
+        return FALSE;
         
 ssl_connected_failure:
@@ -151 +144 @@
         if( source >= 0 ) closesocket( source );
         g_free( conn );
+        
+        return FALSE;
 }
 
@@ -204 +199 @@
         
         if( conn->inpa != -1 )
-                gaim_input_remove( conn->inpa );
+                b_event_remove( conn->inpa );
         
         if( conn->established )
@@ -221 +216 @@
 }
 
-GaimInputCondition ssl_getdirection( void *conn )
+b_input_condition 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, GaimInputCondition cond )
+void byahoo_connect_callback( gpointer data, gint source, b_input_condition cond )
 {
         struct byahoo_connect_callback_data *d = data;
@@ -465 +465 @@
 };
 
-void byahoo_read_ready_callback( gpointer data, gint source, GaimInputCondition cond )
+gboolean byahoo_read_ready_callback( gpointer data, gint source, b_input_condition cond )
 {
         struct byahoo_read_ready_data *d = data;
         
         if( !byahoo_get_gc_by_id( d->id ) )
-        {
                 /* WTF doesn't libyahoo clean this up? */
-                ext_yahoo_remove_handler( d->id, d->tag );
-                return;
-        }
+                return FALSE;
         
         yahoo_read_ready( d->id, d->fd, d->data );
+        
+        return TRUE;
 }
 
@@ -487 +486 @@
 };
 
-void byahoo_write_ready_callback( gpointer data, gint source, GaimInputCondition cond )
+gboolean byahoo_write_ready_callback( gpointer data, gint source, b_input_condition cond )
 {
         struct byahoo_write_ready_data *d = data;
         
         if( !byahoo_get_gc_by_id( d->id ) )
-        {
                 /* WTF doesn't libyahoo clean this up? */
-                ext_yahoo_remove_handler( d->id, d->tag );
-                return;
-        }
+                return FALSE;
         
         yahoo_write_ready( d->id, d->fd, d->data );
+        
+        return FALSE;
 }
 
@@ -687 +685 @@
                 
                 inp->d = d;
-                d->tag = inp->h = gaim_input_add( fd, GAIM_INPUT_READ, (GaimInputFunction) byahoo_read_ready_callback, (gpointer) d );
+                d->tag = inp->h = b_input_add( fd, GAIM_INPUT_READ, (b_event_handler) byahoo_read_ready_callback, (gpointer) d );
         }
         else if( cond == YAHOO_INPUT_WRITE )
@@ -698 +696 @@
                 
                 inp->d = d;
-                d->tag = inp->h = gaim_input_add( fd, GAIM_INPUT_WRITE, (GaimInputFunction) byahoo_write_ready_callback, (gpointer) d );
+                d->tag = inp->h = b_input_add( fd, GAIM_INPUT_WRITE, (b_event_handler) byahoo_write_ready_callback, (gpointer) d );
         }
         else
@@ -729 +727 @@
         }
         
-        gaim_input_remove( tag );
+        b_event_remove( tag );
 }
 
@@ -738 +736 @@
         
         d = g_new0( struct byahoo_connect_callback_data, 1 );
-        if( ( fd = proxy_connect( host, port, (GaimInputFunction) byahoo_connect_callback, (gpointer) d ) ) < 0 )
+        if( ( fd = proxy_connect( host, port, (b_event_handler) 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 ) );
         
-        global.loop = g_main_new( FALSE );
+        b_main_init();
         
         log_init();
@@ -117 +117 @@
                 log_message( LOGLVL_WARNING, "Error opening helpfile %s.", HELP_FILE );
         
-        g_main_run( global.loop );
+        b_main_run();
         
         if( global.restart )
@@ -165 +165 @@
                         
                         log_message( LOGLVL_ERROR, "SIGTERM received, cleaning up process." );
-                        g_timeout_add_full( G_PRIORITY_LOW, 1, (GSourceFunc) bitlbee_shutdown, NULL, NULL );
+                        b_timeout_add( 1, (b_event_handler) bitlbee_shutdown, 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 ) g_source_remove( u->sendbuf_timer );
+                        if( u->sendbuf_timer ) b_event_remove( u->sendbuf_timer );
                         g_free( u );