renatofilho@320: /**
renatofilho@320:  * GMyth Library
renatofilho@320:  *
renatofilho@320:  * @file gmyth/gmyth_monitor_handler.c
renatofilho@320:  * 
renatofilho@320:  * @brief <p> GMythMonitorHandler deals with the streaming media events remote/local
renatofilho@320:  * that are sent to the MythTV frontend.
renatofilho@320:  *
renatofilho@320:  * Copyright (C) 2006 INdT - Instituto Nokia de Tecnologia.
renatofilho@320:  * @author Rosfran Lins Borges <rosfran.borges@indt.org.br>
renatofilho@320:  *
renatofilho@320:  *//*
renatofilho@320:  * 
renatofilho@320:  * This program is free software; you can redistribute it and/or modify
renatofilho@320:  * it under the terms of the GNU Lesser General Public License as published by
renatofilho@320:  * the Free Software Foundation; either version 2 of the License, or
renatofilho@320:  * (at your option) any later version.
renatofilho@320:  *
renatofilho@320:  * This program is distributed in the hope that it will be useful,
renatofilho@320:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
renatofilho@320:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
renatofilho@320:  * GNU General Public License for more details.
renatofilho@320:  *
renatofilho@320:  * You should have received a copy of the GNU Lesser General Public License
renatofilho@320:  * along with this program; if not, write to the Free Software
renatofilho@320:  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
renatofilho@320:  *
renatofilho@320:  * GStreamer MythTV plug-in properties:
renatofilho@320:  * - location (backend server hostname/URL) [ex.: myth://192.168.1.73:28722/1000_1092091.nuv]
renatofilho@320:  * - path (qurl - remote file to be opened)
renatofilho@320:  * - port number *   
renatofilho@320:  */
renatofilho@320: 
renatofilho@320: #ifdef HAVE_CONFIG_H
renatofilho@320: #include "config.h"
renatofilho@320: #endif
renatofilho@320: 
renatofilho@320: #include <unistd.h>
renatofilho@320: #include <glib.h>
renatofilho@320: #include <arpa/inet.h>
renatofilho@320: #include <sys/types.h>
renatofilho@320: #include <sys/socket.h>
renatofilho@320: #include <netdb.h>
renatofilho@320: #include <errno.h>
renatofilho@320: #include <stdlib.h>
renatofilho@320: #include <assert.h>
renatofilho@320: 
renatofilho@320: #include "gmyth_marshal.h"
renatofilho@320: 
renatofilho@320: #include "gmyth_monitor_handler.h"
renatofilho@320: 
renatofilho@320: #include "gmyth.h"
renatofilho@320:  
renatofilho@320: #define GMYTHTV_QUERY_HEADER		"QUERY_FILETRANSFER "
renatofilho@320: 
renatofilho@320: #define GMYTHTV_VERSION							30
renatofilho@320: 
renatofilho@320: #define GMYTHTV_TRANSFER_MAX_WAITS	700
renatofilho@320: 
renatofilho@320: #define GMYTHTV_BUFFER_SIZE					8*1024
renatofilho@320: 
renatofilho@320: #ifdef GMYTHTV_ENABLE_DEBUG
renatofilho@320: #define GMYTHTV_ENABLE_DEBUG				1
renatofilho@320: #else
renatofilho@320: #undef GMYTHTV_ENABLE_DEBUG
renatofilho@320: #endif
renatofilho@320: 
renatofilho@320: /* this NDEBUG is to maintain compatibility with GMyth library */
renatofilho@320: #ifndef NDEBUG
renatofilho@320: #define GMYTHTV_ENABLE_DEBUG				1
renatofilho@320: #endif
renatofilho@320: 
renatofilho@320: //GMainContext *io_watcher_context = NULL;
renatofilho@320: 
renatofilho@320: //GThread *monitor_th = NULL;
renatofilho@320: 
renatofilho@320: //static gboolean* myth_control_sock_listener( GIOChannel *io_channel );
renatofilho@320: //static gboolean gmyth_monitor_handler_listener( GIOChannel *io_channel, 
renatofilho@320: //						GIOCondition condition, gpointer data );
renatofilho@320: 
renatofilho@320: //gboolean* gmyth_monitor_handler_listener( GMythMonitorHandler *monitor );
renatofilho@320: 
renatofilho@320: void gmyth_monitor_handler_listener( GMythMonitorHandler *monitor, gpointer user_data );
renatofilho@320: 
renatofilho@320: static void gmyth_monitor_handler_default_listener( GMythMonitorHandler *monitor, gint msg_code, gchar* message );
renatofilho@320: 
renatofilho@320: static GMutex*				mutex 					 = NULL;
renatofilho@320: 
renatofilho@320: //static GCond*					io_watcher_cond  = NULL;
renatofilho@320: 
renatofilho@320: static void gmyth_monitor_handler_class_init          (GMythMonitorHandlerClass *klass);
renatofilho@320: static void gmyth_monitor_handler_init                (GMythMonitorHandler *object);
renatofilho@320: 
renatofilho@320: static void gmyth_monitor_handler_dispose  (GObject *object);
renatofilho@320: static void gmyth_monitor_handler_finalize (GObject *object);
renatofilho@320: 
renatofilho@320: static gboolean gmyth_connect_to_backend_monitor (GMythMonitorHandler *monitor);
renatofilho@320: 
renatofilho@320: void gmyth_monitor_handler_close( GMythMonitorHandler *monitor );
renatofilho@320: 
renatofilho@320: G_DEFINE_TYPE(GMythMonitorHandler, gmyth_monitor_handler, G_TYPE_OBJECT)
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_monitor_handler_class_init (GMythMonitorHandlerClass *klass)
renatofilho@320: {
renatofilho@320:   GObjectClass *gobject_class;
renatofilho@320:   GMythMonitorHandlerClass *gmonitor_class;
renatofilho@320: 
renatofilho@320:   gobject_class = (GObjectClass *) klass;
renatofilho@320:   gmonitor_class = (GMythMonitorHandlerClass *) gobject_class;
renatofilho@320: 
renatofilho@320:   gobject_class->dispose  = gmyth_monitor_handler_dispose;
renatofilho@320:   gobject_class->finalize = gmyth_monitor_handler_finalize;
renatofilho@320:   
renatofilho@320: 	gmonitor_class->backend_events_handler_signal_id = 
renatofilho@320: 		  g_signal_new ("backend-events-handler",
renatofilho@320: 		                 G_TYPE_FROM_CLASS (gmonitor_class),
renatofilho@320: 		                 G_SIGNAL_RUN_LAST | G_SIGNAL_NO_RECURSE | G_SIGNAL_NO_HOOKS,
renatofilho@320: 		                 0,
renatofilho@320: 										 NULL,
renatofilho@320: 										 NULL,
renatofilho@320: 										 gmyth_marshal_VOID__INT_STRING,
renatofilho@320: 										 G_TYPE_NONE,
renatofilho@320: 										 2,
renatofilho@320: 										 G_TYPE_INT,
renatofilho@320: 										 G_TYPE_STRING);
renatofilho@320: 										 
renatofilho@320: 	gmonitor_class->backend_events_handler = gmyth_monitor_handler_default_listener;
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_monitor_handler_init (GMythMonitorHandler *monitor)
renatofilho@320: { 
renatofilho@320:   g_return_if_fail( monitor != NULL );
renatofilho@320: 
renatofilho@320:   monitor->event_sock = NULL;
renatofilho@320:   monitor->hostname = NULL;
renatofilho@320:   monitor->port = 0;
renatofilho@320:   monitor->actual_index = 0;
renatofilho@320:   
renatofilho@320:   monitor->allow_msgs_listener = TRUE;
renatofilho@320:   
renatofilho@320:   //monitor->backend_msgs = g_hash_table_new( g_int_hash, g_int_equal );
renatofilho@320:     
renatofilho@320:   /* it is used for signalizing the event socket consumer thread */
renatofilho@320:   //io_watcher_cond = g_cond_new();
renatofilho@320:   
renatofilho@320:   /* mutex to control access to the event socket consumer thread */
renatofilho@320:   //mutex = g_mutex_new();
renatofilho@320:   
renatofilho@320:   monitor->monitor_th = NULL;
renatofilho@320:   
renatofilho@320:   monitor->gmyth_monitor_handler_listener = gmyth_monitor_handler_listener;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_monitor_handler_dispose  (GObject *object)
renatofilho@320: {
renatofilho@320: 	
renatofilho@320: 	GMythMonitorHandler *monitor = GMYTH_MONITOR_HANDLER (object);
renatofilho@320: 	
renatofilho@320: 	monitor->allow_msgs_listener = FALSE;
renatofilho@320: 	
renatofilho@320: 	if ( monitor->monitor_th != NULL )  
renatofilho@320:   {
renatofilho@320:   	g_thread_pool_free( monitor->monitor_th, TRUE, FALSE );
renatofilho@320:   	//g_thread_exit( monitor->monitor_th );
renatofilho@320:   	if ( monitor->monitor_th != NULL )
renatofilho@320:   		g_object_unref( monitor->monitor_th );
renatofilho@320:   	monitor->monitor_th = NULL;
renatofilho@320:   }
renatofilho@320: 	
renatofilho@320:   if ( monitor->event_sock != NULL )  
renatofilho@320:   {
renatofilho@320:   	g_object_unref( monitor->event_sock );
renatofilho@320:   	monitor->event_sock = NULL;
renatofilho@320:   }
renatofilho@320:   
renatofilho@320:   if ( monitor->hostname != NULL )  
renatofilho@320:   {
renatofilho@320:   	g_free( monitor->hostname );
renatofilho@320:   	monitor->hostname = NULL;
renatofilho@320:   }
renatofilho@320: 
renatofilho@320:   if ( monitor->backend_msgs != NULL )
renatofilho@320:   {
renatofilho@320:   	g_hash_table_destroy ( monitor->backend_msgs );
renatofilho@320:   	monitor->backend_msgs = NULL;
renatofilho@320:   }
renatofilho@320:   
renatofilho@320:   if ( mutex != NULL )  
renatofilho@320:   {
renatofilho@320:   	g_mutex_free( mutex );
renatofilho@320:   	mutex = NULL;
renatofilho@320:   }
renatofilho@320:   
renatofilho@320:   /*
renatofilho@320:   if ( io_watcher_cond != NULL )  
renatofilho@320:   {
renatofilho@320:   	g_cond_free( io_watcher_cond );
renatofilho@320:   	io_watcher_cond = NULL;
renatofilho@320:   }
renatofilho@320:   */
renatofilho@320:   
renatofilho@320:   G_OBJECT_CLASS (gmyth_monitor_handler_parent_class)->dispose (object);
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_monitor_handler_finalize (GObject *object)
renatofilho@320: {
renatofilho@320:   g_signal_handlers_destroy (object);
renatofilho@320: 
renatofilho@320:   G_OBJECT_CLASS (gmyth_monitor_handler_parent_class)->finalize (object);
renatofilho@320: }
renatofilho@320: 
renatofilho@320: // fixme: do we need the card_id????
renatofilho@320: GMythMonitorHandler*
renatofilho@320: gmyth_monitor_handler_new ( void )
renatofilho@320: {
renatofilho@320:   GMythMonitorHandler *monitor = GMYTH_MONITOR_HANDLER ( g_object_new ( GMYTH_MONITOR_HANDLER_TYPE, 
renatofilho@320:   					FALSE ) );
renatofilho@320: 				
renatofilho@320:   return monitor;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static gboolean 
renatofilho@320: myth_control_acquire_context( gboolean do_wait ) 
renatofilho@320: {
renatofilho@320: 	
renatofilho@320: 	gboolean ret = TRUE;	
renatofilho@320: 	//guint max_iter = 50;
renatofilho@320: 	
renatofilho@320: 	//g_mutex_lock( mutex );
renatofilho@320: 	
renatofilho@320:   //while ( !has_io_access ) 
renatofilho@320:   //	g_cond_wait( io_watcher_cond, mutex );
renatofilho@320:   	
renatofilho@320:   //has_io_access = FALSE;
renatofilho@320:   /*
renatofilho@320:   if ( do_wait ) {
renatofilho@320:   	while ( --max_iter > 0 && !g_main_context_wait( io_watcher_context, io_watcher_cond, mutex ) )
renatofilho@320:   		ret = FALSE;
renatofilho@320:   } else if ( !g_main_context_acquire( io_watcher_context ) )
renatofilho@320:   	ret = FALSE;
renatofilho@320:   */
renatofilho@320:   	
renatofilho@320:   //g_static_mutex_lock( &st_mutex );
renatofilho@320:   
renatofilho@320:   return ret;
renatofilho@320:   
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static gboolean 
renatofilho@320: myth_control_release_context( ) 
renatofilho@320: {
renatofilho@320: 	
renatofilho@320: 	gboolean ret = TRUE;
renatofilho@320:     
renatofilho@320:   //g_static_mutex_unlock( &st_mutex );
renatofilho@320:   
renatofilho@320: 	//g_main_context_release( io_watcher_context );
renatofilho@320:   
renatofilho@320:   //g_main_context_wakeup( io_watcher_context );
renatofilho@320:   
renatofilho@320:   //has_io_access = TRUE;
renatofilho@320: 
renatofilho@320:   //g_cond_broadcast( io_watcher_cond );
renatofilho@320:   
renatofilho@320:   //g_mutex_unlock( mutex );  
renatofilho@320:  
renatofilho@320:   return ret;
renatofilho@320:   
renatofilho@320: }
renatofilho@320: 
renatofilho@320: gboolean
renatofilho@320: gmyth_monitor_handler_open (GMythMonitorHandler *monitor, const gchar *hostname, gint port)
renatofilho@320: {
renatofilho@320:   gboolean ret = TRUE;
renatofilho@320:   
renatofilho@320:   g_return_val_if_fail( hostname != NULL, FALSE );
renatofilho@320: 
renatofilho@320:   if (monitor->hostname != NULL) {
renatofilho@320:     g_free (monitor->hostname);
renatofilho@320:     monitor->hostname = NULL;
renatofilho@320:   }
renatofilho@320: 
renatofilho@320:   monitor->hostname = g_strdup( hostname );
renatofilho@320:   monitor->port = port;
renatofilho@320: 
renatofilho@320:   gmyth_debug ("Monitor event socket --- hostname: %s, port %d\n", monitor->hostname, monitor->port);
renatofilho@320:   
renatofilho@320:   /* configure the event socket */
renatofilho@320:   if ( NULL == monitor->event_sock ) { 
renatofilho@320:     if (!gmyth_connect_to_backend_monitor (monitor)) {
renatofilho@320:       g_printerr( "Connection to backend failed (Event Socket).\n" );
renatofilho@320:       ret = FALSE;
renatofilho@320:     }
renatofilho@320:   } else {
renatofilho@320:     g_warning("Remote monitor event socket already created.\n");
renatofilho@320:   }
renatofilho@320: 
renatofilho@320:   return ret;
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static gint
renatofilho@320: gmyth_monitor_handler_is_backend_message( GMythMonitorHandler *monitor,
renatofilho@320:                         GMythStringList* strlist, gchar **back_msg_action )
renatofilho@320: {
renatofilho@320: 	gint msg_type = GMYTH_BACKEND_NO_MESSAGE;
renatofilho@320: 	GString *back_msg = NULL;
renatofilho@320: 	
renatofilho@320: 	back_msg = gmyth_string_list_get_string( strlist, 0 );
renatofilho@320: 	if ( back_msg != NULL && back_msg->str != NULL &&
renatofilho@320: 	                                strstr( back_msg->str, "BACKEND" ) != NULL )
renatofilho@320: 	{
renatofilho@320: 		gmyth_debug( "MONITOR HANDLER - Received backend message = %s", back_msg->str );
renatofilho@320:   	*back_msg_action = gmyth_string_list_get_char_array( strlist, 1 );
renatofilho@320:   	
renatofilho@320:   	if ( back_msg_action != NULL )
renatofilho@320:   	{	        	
renatofilho@320:   	
renatofilho@320:     	if ( g_strstr_len( *back_msg_action, strlen( *back_msg_action ), "LIVETV_CHAIN" ) ||
renatofilho@320:     			g_strstr_len( *back_msg_action, strlen( *back_msg_action ), "RECORDING_LIST_CHANGE" ) || 
renatofilho@320:     			g_strstr_len( *back_msg_action, strlen( *back_msg_action ), "SCHEDULE_CHANGE" ) ||
renatofilho@320:     			g_strstr_len( *back_msg_action, strlen( *back_msg_action ), "LIVETV_WATCH" ) )
renatofilho@320:     	{
renatofilho@320:     		gmyth_debug( "MONITOR: message type == GMYTH_BACKEND_PROGRAM_INFO_CHANGED, msg = %s", *back_msg_action );
renatofilho@320:     		msg_type = GMYTH_BACKEND_PROGRAM_INFO_CHANGED;
renatofilho@320:     	} else if ( g_strstr_len( *back_msg_action, strlen( *back_msg_action ), "DONE_RECORDING" ) ) {
renatofilho@320:     		gmyth_debug( "MONITOR: message type == GMYTH_BACKEND_DONE_RECORDING, msg = %s", *back_msg_action );
renatofilho@320:     		msg_type = GMYTH_BACKEND_DONE_RECORDING;
renatofilho@320:     	}    	  	
renatofilho@320: 
renatofilho@320:       //g_hash_table_insert ( monitor->backend_msgs,
renatofilho@320:       //                       &(monitor->actual_index), *back_msg_action );
renatofilho@320: 	    
renatofilho@320: 	  } // if
renatofilho@320: 	}
renatofilho@320: 	
renatofilho@320: 	if ( back_msg != NULL )
renatofilho@320: 	{
renatofilho@320: 		g_string_free( back_msg, TRUE );
renatofilho@320: 		back_msg = NULL;        	
renatofilho@320: 	}
renatofilho@320: 	
renatofilho@320: 	return msg_type;
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_monitor_handler_default_listener( GMythMonitorHandler *monitor, gint msg_code, gchar* message )
renatofilho@320: {
renatofilho@320: 	//assert( message!= NULL );  
renatofilho@320: 	gmyth_debug( "DEFAULT Signal handler ( msg = %s, code = %d )\n", 
renatofilho@320: 				message, msg_code );
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_monitor_handler_print( GString *str, gpointer ptr )
renatofilho@320: {
renatofilho@320: 	gmyth_debug( "Backend message event: %s --- ", str->str );
renatofilho@320: }
renatofilho@320: 
renatofilho@320: //static void
renatofilho@320: //gmyth_monitor_handler_listener (GMythMonitorHandler *monitor, gpointer user_data)
renatofilho@320: //static gboolean
renatofilho@320: //gmyth_monitor_handler_listener( GIOChannel *io_channel, GIOCondition condition, gpointer data )
renatofilho@320: //gboolean* gmyth_monitor_handler_listener( GMythMonitorHandler *monitor )
renatofilho@320: void
renatofilho@320: gmyth_monitor_handler_listener (GMythMonitorHandler *monitor, gpointer user_data)
renatofilho@320: {
renatofilho@320: 	//GMythMonitorHandler *monitor = (GMythMonitorHandler*)data; 
renatofilho@320:   GIOStatus io_status;
renatofilho@320:   GIOCondition io_cond;  
renatofilho@320:   guint recv = 0;
renatofilho@320:   gboolean *ret = g_new0( gboolean, 1 );
renatofilho@320:   *ret = TRUE;
renatofilho@320:   //gboolean ret = TRUE;
renatofilho@320:   gsize len = 0;
renatofilho@320:   
renatofilho@320:   static guint count = 0;
renatofilho@320:   
renatofilho@320:   GIOChannel *io_channel = monitor->event_sock->sd_io_ch;
renatofilho@320:   //GIOCondition condition = g_io_channel_get_buffer_condition( io_channel );
renatofilho@320:   
renatofilho@320:   GMythStringList *strlist = NULL;
renatofilho@320:   
renatofilho@320:   //GMythMonitorHandler *monitor = (GMythMonitorHandler*)data;
renatofilho@320:   
renatofilho@320:   myth_control_acquire_context (TRUE);
renatofilho@320:   
renatofilho@320:   if ( io_channel == NULL ) {
renatofilho@320:   	g_debug ("Monitor socket is NULL!\n");
renatofilho@320:   	*ret = FALSE;
renatofilho@320:   	goto clean_up;
renatofilho@320:   }
renatofilho@320:     
renatofilho@320:   while (monitor->allow_msgs_listener) {
renatofilho@320:   	++count;
renatofilho@320:   	
renatofilho@320:   	gmyth_debug ("%d - Listening on Monitor socket...!\n", count);
renatofilho@320: 	
renatofilho@320:     do 
renatofilho@320:     {
renatofilho@320:     	
renatofilho@320:     	gint bytes_sent = 0;
renatofilho@320:     	
renatofilho@320:     	strlist = gmyth_string_list_new();
renatofilho@320:     	
renatofilho@320:     	if ( monitor->event_sock != NULL )
renatofilho@320:     	{
renatofilho@320:     		
renatofilho@320: 	      len = gmyth_socket_read_stringlist( monitor->event_sock, strlist );
renatofilho@320: 	      
renatofilho@320: 		    if ( strlist != NULL && gmyth_string_list_length( strlist ) > 0 ) 
renatofilho@320: 		    { 
renatofilho@320: 			    bytes_sent = gmyth_string_list_get_int( strlist,  0 ); // -1 on backend error
renatofilho@320: 	
renatofilho@320: 		      gmyth_debug ( "[%s] MONITOR: received data buffer from IO event channel... %d strings gone!\n", 
renatofilho@320: 		      		__FUNCTION__, len );
renatofilho@320: 		      		
renatofilho@320: 		      recv += len;
renatofilho@320: 		      
renatofilho@320: 		      /* debug purpose: prints out all the string list elements */
renatofilho@320: 		      g_list_foreach( strlist->glist, (GFunc)gmyth_monitor_handler_print, NULL );
renatofilho@320: 		      
renatofilho@320: 		      gchar *back_msg_action = g_new0( gchar, 1 );
renatofilho@320: 		      gint msg_type = gmyth_monitor_handler_is_backend_message( monitor, strlist, 
renatofilho@320: 		      		&back_msg_action );
renatofilho@320: 		      
renatofilho@320: 	        g_signal_emit ( monitor,
renatofilho@320: 	               GMYTH_MONITOR_HANDLER_GET_CLASS (monitor)->backend_events_handler_signal_id,
renatofilho@320: 	               0, /* details */
renatofilho@320: 	               msg_type, back_msg_action );
renatofilho@320: 	               
renatofilho@320: 	        if (back_msg_action!= NULL)
renatofilho@320: 	        	g_free( back_msg_action );
renatofilho@320: 		      
renatofilho@320: 		    }
renatofilho@320: 		    
renatofilho@320:     	}
renatofilho@320: 	    
renatofilho@320: 	    if (strlist!=NULL)
renatofilho@320: 	    	g_object_unref( strlist );
renatofilho@320:       	
renatofilho@320:       io_cond = g_io_channel_get_buffer_condition( io_channel );
renatofilho@320: 
renatofilho@320:     } while ( recv <= 0 && ( io_cond & G_IO_IN ) != 0 );
renatofilho@320:     
renatofilho@320:     gmyth_debug ("[%s]\tMONITOR EVENT: Read %d bytes\n", __FUNCTION__, recv );
renatofilho@320: 
renatofilho@320: 	  g_usleep( 300 );
renatofilho@320: 	  
renatofilho@320:   } /* main GThread while */
renatofilho@320:   
renatofilho@320:   myth_control_release_context ();
renatofilho@320:   
renatofilho@320:   if ( io_status == G_IO_STATUS_ERROR ) {
renatofilho@320:     //gmyth_debug ("[%s] Error reading: %s\n", __FUNCTION__, error != NULL ? error->message : "" );
renatofilho@320:     gmyth_debug ("Error reading MONITOR event socket.\n");
renatofilho@320:    	*ret = FALSE;
renatofilho@320:    	goto clean_up;   	
renatofilho@320:   }
renatofilho@320:   
renatofilho@320: clean_up:
renatofilho@320: 
renatofilho@320:   if (strlist!=NULL)
renatofilho@320:   	g_object_unref( strlist );
renatofilho@320:   	
renatofilho@320:  	return;
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static gboolean
renatofilho@320: gmyth_connect_to_backend_monitor (GMythMonitorHandler *monitor)
renatofilho@320: {
renatofilho@320:   gboolean ret = TRUE;
renatofilho@320: 
renatofilho@320:   monitor->event_sock = gmyth_socket_new();
renatofilho@320: 
renatofilho@320:   /* Connects the socket, send Mythtv ANN Monitor and verify Mythtv protocol version */ 
renatofilho@320:   if (!gmyth_socket_connect_to_backend_events ( monitor->event_sock,
renatofilho@320:           monitor->hostname, monitor->port, FALSE ) ) 
renatofilho@320:   {
renatofilho@320:     g_object_unref (monitor->event_sock);
renatofilho@320:     monitor->event_sock = NULL;
renatofilho@320:     ret = FALSE;
renatofilho@320:   }
renatofilho@320:   
renatofilho@320:   return ret;
renatofilho@320: }    
renatofilho@320: 
renatofilho@320: static gboolean*
renatofilho@320: gmyth_monitor_handler_setup( GMythMonitorHandler *monitor, GIOChannel *channel )
renatofilho@320: {
renatofilho@320: 	gboolean *ret = g_new0( gboolean, 1 );
renatofilho@320: 	guint src_id = 0;
renatofilho@320: 	
renatofilho@320: 	*ret = TRUE;
renatofilho@320: 	
renatofilho@320:   //io_watcher_context = g_main_context_default();
renatofilho@320:   //GMainLoop *loop = g_main_loop_new( io_watcher_context, TRUE );
renatofilho@320: 
renatofilho@320:   //GSource *source;
renatofilho@320: 
renatofilho@320:   if ( channel != NULL ) {
renatofilho@320:     //source = g_io_create_watch( channel, G_IO_IN | G_IO_HUP );
renatofilho@320:     src_id = g_io_add_watch( channel, G_IO_IN, 
renatofilho@320:     					(GIOFunc)gmyth_monitor_handler_listener, monitor );
renatofilho@320:   } else {
renatofilho@320:   	*ret = FALSE;
renatofilho@320:   	goto cleanup;
renatofilho@320:   }
renatofilho@320: 
renatofilho@320:   //g_source_set_callback ( source, (GSourceFunc)gmyth_monitor_handler_listener, NULL, NULL );
renatofilho@320: 
renatofilho@320:   //g_source_attach( source, io_watcher_context );
renatofilho@320:   
renatofilho@320:   //if (NULL == source){
renatofilho@320:   if (src_id < 0){
renatofilho@320:     gmyth_debug( "[%s] Error adding watch listener function to the IO control channel!\n", __FUNCTION__ );
renatofilho@320:     *ret = FALSE;
renatofilho@320:     goto cleanup;
renatofilho@320:   }
renatofilho@320:   
renatofilho@320:   //g_main_loop_run( loop );
renatofilho@320:   
renatofilho@320: cleanup:
renatofilho@320:   //if ( source != NULL )
renatofilho@320:   //  g_source_unref( source );
renatofilho@320:     
renatofilho@320:   //if ( io_watcher_context != NULL )
renatofilho@320:   //  g_main_context_unref( io_watcher_context );
renatofilho@320: 
renatofilho@320:   //if ( loop != NULL )
renatofilho@320:   //  g_main_loop_unref( loop );
renatofilho@320:     
renatofilho@320:   return ret;
renatofilho@320:   
renatofilho@320: }
renatofilho@320: 
renatofilho@320: gboolean 
renatofilho@320: gmyth_monitor_handler_start (GMythMonitorHandler *monitor)
renatofilho@320: {
renatofilho@320: 	gboolean *ret = g_new0( gboolean, 1 ); 
renatofilho@320: 	*ret = TRUE;	
renatofilho@320: 	
renatofilho@320: 	/*if (!g_thread_supported () ) 	g_thread_init (NULL);*/
renatofilho@320: 	/*
renatofilho@320:   monitor->monitor_th = g_thread_pool_new( (GThreadFunc)gmyth_monitor_handler_listener, 
renatofilho@320:   					monitor, TRUE, NULL );
renatofilho@320:  */				
renatofilho@320:   monitor->monitor_th = g_thread_pool_new( (GFunc)gmyth_monitor_handler_listener, 
renatofilho@320:   					monitor, 3, TRUE, NULL );
renatofilho@320:   g_thread_pool_push( monitor->monitor_th, monitor, NULL ); 
renatofilho@320:   					
renatofilho@320:   //if ( ( ret = g_thread_join( monitor_th ) ) == FALSE )
renatofilho@320:   if ( monitor->monitor_th != NULL )
renatofilho@320:   //if ( gmyth_monitor_handler_setup( monitor, monitor->event_sock->sd_io_ch ) )
renatofilho@320:   {
renatofilho@320:   	gmyth_debug ( "\n[%s]\tOK! Starting listener on the MONITOR event socket...[thread location = %p]\n", 
renatofilho@320:   				__FUNCTION__, g_thread_self( ) );
renatofilho@320:   	*ret = TRUE;  	  	
renatofilho@320:   } else {
renatofilho@320:   	gmyth_debug ( "\n[%s]\tERROR! Coudn't start listener on the MONITOR event socket...[thread location = %p]\n", 
renatofilho@320:   				__FUNCTION__, g_thread_self( ) );
renatofilho@320:   	*ret = FALSE;
renatofilho@320:   }
renatofilho@320: 
renatofilho@320: //cleanup:
renatofilho@320:     
renatofilho@320:   gmyth_debug( "[%s] Watch listener function over the IO control channel? %s!!!\n", 
renatofilho@320:   			__FUNCTION__, ( *ret == TRUE ? "YES" : "NO" ) );
renatofilho@320:     
renatofilho@320:     return *ret;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: void
renatofilho@320: gmyth_monitor_handler_close( GMythMonitorHandler *monitor )
renatofilho@320: {
renatofilho@320: 	
renatofilho@320:   if (monitor->event_sock) {
renatofilho@320:     g_object_unref( monitor->event_sock );
renatofilho@320:     monitor->event_sock = NULL;
renatofilho@320:   }
renatofilho@320: 
renatofilho@320:   if (monitor->hostname) {
renatofilho@320:     g_free( monitor->hostname );
renatofilho@320:     monitor->hostname = NULL;
renatofilho@320:   }
renatofilho@320:   
renatofilho@320: }
renatofilho@320: