/**

  * $Id$

  *

  * Glib-based networking support functions. Currently this is just for activity callbacks.

  *

  * Copyright (c) 2009 Nathan Keynes.

  *

  * This program is free software; you can redistribute it and/or modify

  * it under the terms of the GNU General Public License as published by

  * the Free Software Foundation; either version 2 of the License, or

  * (at your option) any later version.

  *

  * This program is distributed in the hope that it will be useful,

  * but WITHOUT ANY WARRANTY; without even the implied warranty of

  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

  * GNU General Public License for more details.

  */

 #include <assert.h>

 #include <glib.h>

 #include <stdlib.h>

 #include "netutil.h"

 struct net_glib_cbinfo {

     net_callback_t callback;

     void * cbdata;

     void (*cbdealloc)(void *);

 };

 static gboolean net_glib_callback( GIOChannel *source, GIOCondition cond, gpointer data )

 {

     struct net_glib_cbinfo *cbinfo = (struct net_glib_cbinfo *)data;

     return cbinfo->callback( g_io_channel_unix_get_fd(source), cbinfo->cbdata);

 }

 static void net_glib_release( void *data )

 {

     struct net_glib_cbinfo *cbinfo = (struct net_glib_cbinfo *)data;

     if( cbinfo->cbdealloc ) {

         cbinfo->cbdealloc( cbinfo->cbdata );

     }

     free(cbinfo);

 }

 /**

  * Register a TCP server socket listener on an already open (and listening) 

  * socket. The socket must not have been previously registered.

  * @return TRUE on success, FALSE on failure.

  * 

  * Defined in netutil.h

  */ 

 gboolean net_register_tcp_listener( int fd, net_callback_t callback, void *data, void (*dealloc)(void*) )

 {

     struct net_glib_cbinfo *cbinfo = malloc( sizeof(struct net_glib_cbinfo) );

     assert(cbinfo != NULL);

     cbinfo->callback = callback;

     cbinfo->cbdata = data;

     cbinfo->cbdealloc = dealloc;

     /**

      * Note magic here: the watch creates an event source which holds a 

      * reference to the channel. We unref the channel so that the channel then

      * is automatically released when the event source goes away.

      */

     GIOChannel *chan = g_io_channel_unix_new(fd);

     g_io_channel_set_encoding( chan, NULL, NULL );

     g_io_channel_set_buffered(chan, FALSE);

     g_io_add_watch_full( chan, 0, G_IO_IN, net_glib_callback, cbinfo, net_glib_release );

     g_io_channel_unref( chan );

     return TRUE;

 }