Changes in / [5e713f6:9a1555d]

Files:

• bitlbee.c (modified) (1 diff)
• configure (modified) (5 diffs)
• ipc.c (modified) (2 diffs)
• ipc.h (modified) (1 diff)
• utils/bitlbee-ctl.pl (added)

bitlbee.c

@@ -118 +118 @@
         if( global.conf->runmode == RUNMODE_FORKDAEMON )
                 ipc_master_load_state();
+
+        if( global.conf->runmode == RUNMODE_DAEMON || 
+                global.conf->runmode == RUNMODE_FORKDAEMON )
+                ipc_master_listen_socket();
         
         if( ( fp = fopen( global.conf->pidfile, "w" ) ) )

configure

@@ -15 +15 @@
 config='/var/lib/bitlbee/'
 pidfile='/var/run/bitlbee.pid'
+ipcsocket='/var/run/bitlbee'
 plugindir='$prefix/lib/bitlbee'
 
@@ -49 +50 @@
 --pidfile=...                                           $pidfile
 --config=...                                            $config
+--ipcsocket=...                                         $ipcsocket
 
 --msn=0/1       Disable/enable MSN part                 $msn
@@ -76 +78 @@
 config=`eval echo "$config/" | sed 's/\/\{1,\}/\//g'`
 plugindir=`eval echo "$plugindir/" | sed 's/\/\{1,\}/\//g'`
-pidfile=`eval echo "$pidfile/" | sed 's/\/\{1,\}/\//g'`
+pidfile=`eval echo "$pidfile" | sed 's/\/\{1,\}/\//g'`
+ipcsocket=`eval echo "$ipcsocket" | sed 's/\/\{1,\}/\//g'`
 
 cat<<EOF>Makefile.settings
@@ -86 +89 @@
 DATADIR=$datadir
 PLUGINDIR=$plugindir
-PIDFILE=$pidfile
 CONFIG=$config
+IPCSOCKET=$ipcsocket
 
 ARCH=$arch
@@ -109 +112 @@
 #define PLUGINDIR "$plugindir"
 #define PIDFILE "$pidfile"
+#define IPCSOCKET "$ipcsocket"
 #define ARCH "$arch"
 #define CPU "$cpu"

ipc.c

@@ -28 +28 @@
 #include "ipc.h"
 #include "commands.h"
+#ifndef _WIN32
+#include <sys/un.h>
+#endif
 
 GSList *child_list = NULL;
@@ -461 +464 @@
 }
 
+
+static gboolean new_ipc_client (GIOChannel *gio, GIOCondition cond, gpointer data)
+{
+        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) {
+                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_list = g_slist_append( child_list, child );
+
+        return TRUE;
+}
+
+#ifndef _WIN32
+int ipc_master_listen_socket()
+{
+        struct sockaddr_un un_addr;
+        int serversock;
+        GIOChannel *gio;
+
+        /* Clean up old socket files that were hanging around.. */
+        if (unlink(IPCSOCKET) == -1 && errno != ENOENT) {
+                log_message( LOGLVL_ERROR, "Could not remove old IPC socket at %s: %s", IPCSOCKET, strerror(errno) );
+                return 0;
+        }
+
+        un_addr.sun_family = AF_UNIX;
+        strcpy(un_addr.sun_path, IPCSOCKET);
+
+        serversock = socket(AF_UNIX, SOCK_STREAM, PF_UNIX);
+
+        if (serversock == -1) {
+                log_message( LOGLVL_WARNING, "Unable to create UNIX socket: %s", strerror(errno) );
+                return 0;
+        }
+
+        if (bind(serversock, &un_addr, sizeof(un_addr)) == -1) {
+                log_message( LOGLVL_WARNING, "Unable to bind UNIX socket to %s: %s", IPCSOCKET, strerror(errno) );
+                return 0;
+        }
+
+        if (listen(serversock, 5) == -1) {
+                log_message( LOGLVL_WARNING, "Unable to listen on UNIX socket: %s", strerror(errno) );
+                return 0;
+        }
+        
+        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;
+}
+#else
+        /* FIXME: Open named pipe \\.\BITLBEE */
+#endif
+
 int ipc_master_load_state()
 {

ipc.h

@@ -57 +57 @@
 void ipc_master_set_statefile( char *fn );
 int ipc_master_load_state();
-
+int ipc_master_listen_socket();
 
 extern GSList *child_list;