renatofilho@320: /**
renatofilho@320:  * GMyth Library
renatofilho@320:  *
renatofilho@320:  * @file gmyth/gmyth_socket.c
renatofilho@320:  * 
renatofilho@320:  * @brief <p> MythTV socket implementation, according to the MythTV Project
renatofilho@320:  * (www.mythtv.org). 
renatofilho@320:  * 
renatofilho@320:  * This component provides basic socket functionalities to interact with
renatofilho@320:  * the Mythtv backend.
renatofilho@320:  * <p>
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: 
renatofilho@320: #ifdef HAVE_CONFIG_H
renatofilho@320: #include "config.h"
renatofilho@320: #endif
renatofilho@320: 
renatofilho@320: #include "gmyth_socket.h"
renatofilho@320: 
renatofilho@320: #include <glib.h> 
renatofilho@320: #include <glib/gprintf.h>
renatofilho@320: 
renatofilho@320: #include <arpa/inet.h>
renatofilho@320: #include <sys/types.h>
renatofilho@320: #include <sys/socket.h>
renatofilho@320: #include <sys/param.h>
renatofilho@320: #include <netdb.h>
renatofilho@320: #include <net/if.h>
renatofilho@320: #include <errno.h>
renatofilho@320: #include <stdlib.h>
renatofilho@320: 
renatofilho@320: #include <unistd.h>
renatofilho@320: #include <netinet/in.h>
renatofilho@320: #include <fcntl.h>
renatofilho@320: #include <signal.h>
renatofilho@320: 
renatofilho@320: #include <sys/ioctl.h>
renatofilho@320: 
renatofilho@320: #include "gmyth_stringlist.h"
renatofilho@320: #include "gmyth_uri.h"
renatofilho@320: #include "gmyth_debug.h"
renatofilho@320: 
renatofilho@320: #define BUFLEN 				   	512
renatofilho@320: #define MYTH_SEPARATOR 			    	"[]:[]"
renatofilho@320: #define MYTH_PROTOCOL_FIELD_SIZE		8
renatofilho@320: 
renatofilho@320: /* max number of iterations */
renatofilho@320: #define MYTHTV_MAX_VERSION_CHECKS		40
renatofilho@320: 
renatofilho@320: // FIXME: put this in the right place
renatofilho@320: #define  MYTHTV_VERSION_DEFAULT			30
renatofilho@320: 
renatofilho@320: static GStaticMutex mutex = G_STATIC_MUTEX_INIT;
renatofilho@320: 
renatofilho@320: static gchar* local_hostname = NULL;
renatofilho@320: 
renatofilho@320: static void gmyth_socket_class_init          (GMythSocketClass *klass);
renatofilho@320: static void gmyth_socket_init                (GMythSocket *object);
renatofilho@320: 
renatofilho@320: static void gmyth_socket_dispose  (GObject *object);
renatofilho@320: static void gmyth_socket_finalize (GObject *object);
renatofilho@320: 
renatofilho@320: G_DEFINE_TYPE(GMythSocket, gmyth_socket, G_TYPE_OBJECT)
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_socket_class_init (GMythSocketClass *klass)
renatofilho@320: {
renatofilho@320:     GObjectClass *gobject_class;
renatofilho@320: 
renatofilho@320:     gobject_class = (GObjectClass *) klass;
renatofilho@320: 
renatofilho@320:     gobject_class->dispose  = gmyth_socket_dispose;
renatofilho@320:     gobject_class->finalize = gmyth_socket_finalize;	
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_socket_init (GMythSocket *gmyth_socket)
renatofilho@320: {
renatofilho@320: 	
renatofilho@320: 	/* gmyth_socket->local_hostname = NULL; */
renatofilho@320: 	
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Gets the some important address translation info, from the client socket
renatofilho@320:  * that will open a connection.
renatofilho@320:  * 
renatofilho@320:  * @return gint that represents the error number from getaddrinfo(). 
renatofilho@320:  */
renatofilho@320: static gint
renatofilho@320: gmyth_socket_toaddrinfo (const gchar *addr, gint port, struct addrinfo **addrInfo )
renatofilho@320: {
renatofilho@320:     struct addrinfo hints;
renatofilho@320:     gchar *portStr = NULL;
renatofilho@320:     gint errorn = EADDRNOTAVAIL;
renatofilho@320:  
renatofilho@320:     g_return_val_if_fail ( addr != NULL, -1 );
renatofilho@320:     g_debug ("Calling %s\n", __FUNCTION__);
renatofilho@320: 
renatofilho@320:     /* hints = g_malloc0 ( sizeof(struct addrinfo) ); */
renatofilho@320:     memset ( &hints, 0, sizeof(struct addrinfo) );
renatofilho@320:     hints.ai_family = AF_INET;
renatofilho@320:     hints.ai_socktype = SOCK_STREAM;
renatofilho@320:     /* hints.ai_flags = AI_NUMERICHOST; */
renatofilho@320:     
renatofilho@320:     if ( port != -1 )	
renatofilho@320:         portStr = g_strdup_printf ( "%d", port );
renatofilho@320:     else
renatofilho@320: 	portStr = NULL;
renatofilho@320: 
renatofilho@320:     gmyth_debug ("Getting name resolution for: %s, %d\n", addr, port);
renatofilho@320: 
renatofilho@320:     if ( ( errorn = getaddrinfo(addr, portStr, &hints, addrInfo) ) != 0 ) {
renatofilho@320: 		g_printerr( "[%s] Socket ERROR: %s\n", __FUNCTION__, gai_strerror(errorn) );
renatofilho@320:     }
renatofilho@320:     g_free (portStr);
renatofilho@320:     /* g_free (hints); */
renatofilho@320:     return errorn;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static gint
renatofilho@320: gmyth_socket_find_match_address_uri( GMythURI* uri, gchar *address ) {
renatofilho@320: 
renatofilho@320:         if ( g_ascii_strcasecmp( gmyth_uri_get_host( uri ), address ) == 0 ) {
renatofilho@320:                 //g_printerr( "Found URI: %s !!!\n", rui_uri_getvalue(uri) );
renatofilho@320:                 return 0;
renatofilho@320:         } else {
renatofilho@320:                 return -1;
renatofilho@320:         }
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static const gchar *PATH_PROC_NET_DEV = "/proc/net/dev";
renatofilho@320: 
renatofilho@320: /** Gets the list of all local network interfaces (using the /proc/net/dev directory).
renatofilho@320:  * 
renatofilho@320:  * @param current_connections	A list with all the network interfaces are valid, 
renatofilho@320:  * 		to be applied just like a filter.
renatofilho@320:  * @return List with all the local net interfaces. 
renatofilho@320:  */
renatofilho@320: static GList *
renatofilho@320: gmyth_socket_get_local_addrs( GList *current_connections )
renatofilho@320: {
renatofilho@320: 
renatofilho@320: 	GList *local_addrs = NULL;
renatofilho@320: 	FILE *fd;
renatofilho@320: 	gint s;
renatofilho@320: 	gchar buffer[256+1];
renatofilho@320: 	gchar ifaddr[20+1];
renatofilho@320: 	gchar *ifname;
renatofilho@320: 	gchar *sep;
renatofilho@320: 	
renatofilho@320: 	s = socket(AF_INET, SOCK_DGRAM, 0);
renatofilho@320: 	if (s < 0)
renatofilho@320: 		return 0;
renatofilho@320: 	fd = fopen(PATH_PROC_NET_DEV, "r");
renatofilho@320: 	fgets(buffer, sizeof(buffer)-1, fd);
renatofilho@320: 	fgets(buffer, sizeof(buffer)-1, fd);
renatofilho@320: 	while (!feof(fd)) {
renatofilho@320: 		ifname = buffer;
renatofilho@320: 		sep;
renatofilho@320: 		if (fgets(buffer, sizeof(buffer)-1, fd) == NULL)
renatofilho@320: 			break;
renatofilho@320: 		sep = strrchr(buffer, ':');
renatofilho@320: 		if (sep)
renatofilho@320: 			*sep = 0;
renatofilho@320: 		while (*ifname == ' ')
renatofilho@320: 			ifname++;
renatofilho@320: 		struct ifreq req;
renatofilho@320: 		strcpy(req.ifr_name, ifname);
renatofilho@320: 		if (ioctl(s, SIOCGIFFLAGS, &req) < 0)
renatofilho@320: 			continue;
renatofilho@320: 		if (!(req.ifr_flags & IFF_UP))
renatofilho@320: 			continue;
renatofilho@320: 		if (req.ifr_flags & IFF_LOOPBACK)
renatofilho@320: 			continue;
renatofilho@320: 		if (ioctl(s, SIOCGIFADDR, &req) < 0)
renatofilho@320: 			continue;
renatofilho@320: 		g_strlcpy( ifaddr, inet_ntoa(((struct sockaddr_in*)&req.ifr_addr)->sin_addr), sizeof(struct ifaddr)-1 );
renatofilho@320: 		local_addrs = g_list_append( local_addrs, g_strdup( ifaddr ) );
renatofilho@320: 
renatofilho@320: 		gmyth_debug( "( from the /proc/net/dev) Interface name: %s, address: %s\n", 
renatofilho@320: 								ifname, ifaddr );
renatofilho@320: 	}
renatofilho@320: 	fclose(fd);
renatofilho@320: 	close(s);
renatofilho@320: 	return local_addrs;
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: 
renatofilho@320: /**
renatofilho@320:  * Get only the local addresses from the primary interface
renatofilho@320:  */
renatofilho@320: static gchar *
renatofilho@320: gmyth_socket_get_primary_addr()
renatofilho@320: {
renatofilho@320: 	
renatofilho@320: 	gchar *if_eth0 = g_new0( gchar, sizeof(struct ifaddr)-1 );
renatofilho@320: 	GList *if_tmp = NULL;
renatofilho@320: 	
renatofilho@320: 	GList *interfs = gmyth_socket_get_local_addrs( NULL );
renatofilho@320: 	
renatofilho@320: 	if ( interfs != NULL && ( g_list_length( interfs ) > 0 ) ) 
renatofilho@320: 	{
renatofilho@320: 		/* get the first occurrence (primary interface) */
renatofilho@320: 		if_tmp = g_list_first( interfs );
renatofilho@320: 		
renatofilho@320: 		if ( if_tmp != NULL )
renatofilho@320: 			g_strlcpy (if_eth0, (gchar *)if_tmp->data, sizeof(struct ifaddr)-1 );
renatofilho@320: 
renatofilho@320: 	}
renatofilho@320: 	
renatofilho@320: 	if ( interfs != NULL )
renatofilho@320: 		g_list_free( interfs );
renatofilho@320: 	
renatofilho@320: 	return if_eth0;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** This function retrieves the local hostname of the 
renatofilho@320:  * client machine.
renatofilho@320:  *
renatofilho@320:  * @return GString* get local hostname.
renatofilho@320:  */
renatofilho@320: GString *
renatofilho@320: gmyth_socket_get_local_hostname  ()
renatofilho@320: {
renatofilho@320: 
renatofilho@320:     char hname[50];
renatofilho@320:     gint res = gethostname (hname, 50);
renatofilho@320: 
renatofilho@320:     if (res == -1) {
renatofilho@320: 	g_debug ("Error while getting hostname");
renatofilho@320: 	return NULL;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     return g_string_new (hname);
renatofilho@320:     
renatofilho@320: #if 0	
renatofilho@320:     GString *str = NULL;
renatofilho@320:     
renatofilho@320:     if ( local_hostname != NULL && strlen(local_hostname) > 0 )
renatofilho@320:     	return g_string_new( local_hostname );
renatofilho@320: 
renatofilho@320:     gchar *localaddr = NULL; 
renatofilho@320:     gboolean found_addr = FALSE;
renatofilho@320:     struct addrinfo* addr_info_data = NULL, *addr_info0 = NULL;
renatofilho@320:     struct sockaddr_in* sa = NULL;
renatofilho@320:     gchar localhostname[MAXHOSTNAMELEN];
renatofilho@320: 
renatofilho@320: 
renatofilho@320:     if (gethostname (localhostname, MAXHOSTNAMELEN) != 0 ) {
renatofilho@320:     	gmyth_debug ( "Error on gethostname" );
renatofilho@320:     }
renatofilho@320:     localhostname[MAXHOSTNAMELEN-1] = 0;
renatofilho@320: 
renatofilho@320:     gint err = gmyth_socket_toaddrinfo (localhostname, -1,  &addr_info_data );
renatofilho@320:     
renatofilho@320:     if ( err == EADDRNOTAVAIL )
renatofilho@320:     {
renatofilho@320:     	g_warning( "[%s] Address (%s) not available. (reason = %d)\n", __FUNCTION__, localhostname, err );
renatofilho@320:     	return str;
renatofilho@320:     }
renatofilho@320:     
renatofilho@320:     g_static_mutex_lock( &mutex );    	
renatofilho@320: 
renatofilho@320:     addr_info0 = addr_info_data;
renatofilho@320: 
renatofilho@320:     while( addr_info0 != NULL && addr_info0->ai_addr != NULL && 
renatofilho@320: 	    ( sa = (struct sockaddr_in*)addr_info0->ai_addr ) != NULL && !found_addr ) {
renatofilho@320:     	localaddr = inet_ntoa( sa->sin_addr );
renatofilho@320: 
renatofilho@320: 	    if ( localaddr != NULL && ( g_strrstr( localaddr, "127" ) == NULL ) ) {
renatofilho@320: 	        str = g_string_new (localaddr);
renatofilho@320: 	        found_addr = TRUE;
renatofilho@320: 		g_free (localaddr);
renatofilho@320: 	        break;
renatofilho@320: 	    }
renatofilho@320: /*
renatofilho@320: 	    if (localaddr != NULL) {
renatofilho@320: 		g_free (localaddr);
renatofilho@320: 		localaddr = NULL;
renatofilho@320: 	    }
renatofilho@320: 	    */
renatofilho@320: 
renatofilho@320: 	    addr_info0 = addr_info0->ai_next;
renatofilho@320:     };
renatofilho@320:     
renatofilho@320:     freeaddrinfo (addr_info_data);
renatofilho@320:     addr_info_data = NULL;
renatofilho@320:     
renatofilho@320:     if ( found_addr == FALSE ) {
renatofilho@320:         gchar *prim_addr = gmyth_socket_get_primary_addr();
renatofilho@320: 
renatofilho@320:     	if ( prim_addr != NULL ) {
renatofilho@320: 		g_warning("[%s] Could not determine the local alphanumerical hostname. Setting to %s\n",
renatofilho@320:     	        __FUNCTION__, prim_addr );
renatofilho@320:       
renatofilho@320: 	        str = g_string_new (prim_addr);
renatofilho@320: 	        g_free (prim_addr);
renatofilho@320:     	} else {
renatofilho@320:         	str = g_string_new (localhostname);
renatofilho@320:     	}
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     g_static_mutex_unlock (&mutex);
renatofilho@320:     
renatofilho@320:     if ( str != NULL && str->str != NULL )
renatofilho@320:     	local_hostname = g_strdup( str->str );
renatofilho@320: 
renatofilho@320:     return str;
renatofilho@320: #endif    
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_socket_dispose  (GObject *object)
renatofilho@320: {
renatofilho@320:     GMythSocket *gmyth_socket = GMYTH_SOCKET(object);
renatofilho@320: 
renatofilho@320:     /* disconnect socket */
renatofilho@320:     gmyth_socket_close_connection (gmyth_socket);
renatofilho@320: 
renatofilho@320:     g_free (gmyth_socket->hostname);
renatofilho@320:     gmyth_socket->hostname = NULL;
renatofilho@320:     
renatofilho@320:     g_free (local_hostname);
renatofilho@320:     
renatofilho@320:     local_hostname = NULL;
renatofilho@320: 
renatofilho@320:     G_OBJECT_CLASS (gmyth_socket_parent_class)->dispose (object);
renatofilho@320: }
renatofilho@320: 
renatofilho@320: static void
renatofilho@320: gmyth_socket_finalize (GObject *object)
renatofilho@320: {
renatofilho@320:     g_signal_handlers_destroy (object);
renatofilho@320: 
renatofilho@320:     G_OBJECT_CLASS (gmyth_socket_parent_class)->finalize (object);
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Creates a new instance of GMythSocket.
renatofilho@320:  * 
renatofilho@320:  * @return a new instance of GMythSocket.
renatofilho@320:  */
renatofilho@320: GMythSocket*
renatofilho@320: gmyth_socket_new ()
renatofilho@320: {
renatofilho@320:     GMythSocket *gmyth_socket = GMYTH_SOCKET (g_object_new(GMYTH_SOCKET_TYPE, NULL));
renatofilho@320: 
renatofilho@320:     gmyth_socket->mythtv_version = MYTHTV_VERSION_DEFAULT;
renatofilho@320: 
renatofilho@320:     return gmyth_socket;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Try to open an asynchronous connection to the MythTV backend.
renatofilho@320:  * 
renatofilho@320:  * @param fd 			Socket descriptor.
renatofilho@320:  * @param remote 	Remote address.
renatofilho@320:  * @param len 		Newly created socket length field.
renatofilho@320:  * @param timeout	Timeval argument with the time interval to timeout before closing.
renatofilho@320:  * @param err			Error message number.
renatofilho@320:  * @return Any numerical value below 0, if an error had been found.
renatofilho@320:  */
renatofilho@320: static gint 
renatofilho@320: gmyth_socket_try_connect ( gint fd, struct sockaddr *remote, gint len,
renatofilho@320:                struct timeval *timeout, gint *err)
renatofilho@320: {
renatofilho@320: 	  /*g_return_val_if_fail( timeout != NULL, 0 );*/	  
renatofilho@320: 	  gint saveflags, ret, back_err;
renatofilho@320: 	  
renatofilho@320: 	  fd_set fd_w;
renatofilho@320: 	
renatofilho@320: 	  saveflags = fcntl( fd, F_GETFL, 0 );
renatofilho@320: 	  if( saveflags < 0 ) {
renatofilho@320: 	    g_warning( "[%s] Problems when getting socket flags on fcntl.\n", __FUNCTION__ );
renatofilho@320: 	    *err=errno;
renatofilho@320: 	    return -1;
renatofilho@320: 	  }
renatofilho@320: 	
renatofilho@320: 	  /* Set non blocking */
renatofilho@320: 	  if( fcntl( fd, F_SETFL, saveflags | O_NONBLOCK ) < 0) {
renatofilho@320: 	  	g_warning( "[%s] Problems when setting non-blocking using fcntl.\n", __FUNCTION__ );
renatofilho@320: 	    *err=errno;
renatofilho@320: 	    return -1;
renatofilho@320: 	  }
renatofilho@320: 	
renatofilho@320: 	  /* This will return immediately */
renatofilho@320: 	  *err= connect ( fd, remote, len );
renatofilho@320: 		back_err=errno;
renatofilho@320: 	
renatofilho@320: 		/* restore flags */
renatofilho@320: 	  if( fcntl( fd, F_SETFL, saveflags ) < 0) {
renatofilho@320: 	    g_warning( "[%s] Problems when trying to restore flags with fcntl.\n", __FUNCTION__ );
renatofilho@320: 	    *err=errno;
renatofilho@320: 	    return -1;
renatofilho@320: 	  }
renatofilho@320: 	
renatofilho@320: 	  /* return unless the connection was successful or the connect is
renatofilho@320: 	     still in progress. */
renatofilho@320: 	  if( *err < 0 && back_err != EINPROGRESS) {
renatofilho@320: 	    g_warning( "[%s] Connection unsucessfully (it is not in progress).\n", __FUNCTION__ );
renatofilho@320: 	    *err = errno;
renatofilho@320: 	    return -1;
renatofilho@320: 	  }
renatofilho@320: 	
renatofilho@320: 	  FD_ZERO( &fd_w );
renatofilho@320: 	  FD_SET( fd, &fd_w );
renatofilho@320: 	
renatofilho@320: 	  *err = select( FD_SETSIZE, NULL, &fd_w, NULL, timeout);
renatofilho@320: 	  if ( *err < 0 ) {
renatofilho@320: 	    g_warning( "[%s] Connection unsucessfull (timed out).\n", __FUNCTION__ );
renatofilho@320: 	    *err=errno;
renatofilho@320: 	    return -1;
renatofilho@320: 	  }
renatofilho@320: 	
renatofilho@320: 	  /* 0 means it timeout out & no fds changed */
renatofilho@320: 	  if(*err==0) {
renatofilho@320: 	    close(fd);
renatofilho@320: 	    *err=ETIMEDOUT;
renatofilho@320: 	    return -1;
renatofilho@320: 	  }
renatofilho@320: 	
renatofilho@320: 	  /* Get the return code from the connect */
renatofilho@320: 	  len = sizeof( ret );
renatofilho@320: 	  *err=getsockopt( fd, SOL_SOCKET, SO_ERROR, &ret, (socklen_t *) &len);
renatofilho@320: 	  
renatofilho@320: 	  if( *err < 0 ) {
renatofilho@320: 	    g_warning( "[%s] Connection usnsucessfull.\n", __FUNCTION__ );
renatofilho@320: 	    *err=errno;
renatofilho@320: 	    return -1;
renatofilho@320: 	  }
renatofilho@320: 	
renatofilho@320: 	  /* ret=0 means success, otherwise it contains the errno */
renatofilho@320: 	  if (ret) {
renatofilho@320: 	    *err=ret;
renatofilho@320: 	    return -1;
renatofilho@320: 	  }
renatofilho@320: 	
renatofilho@320: 	  *err=0;
renatofilho@320: 	  return 0;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Connects to the backend.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @param hostname The backend hostname or IP address.
renatofilho@320:  * @param port The backend port.
renatofilho@320:  * @return TRUE if success, FALSE if error.
renatofilho@320:  */
renatofilho@320: 
renatofilho@320: 
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_connect (GMythSocket *gmyth_socket,
renatofilho@320: 	const gchar *hostname, gint port)
renatofilho@320: {
renatofilho@320:     return gmyth_socket_connect_with_timeout (gmyth_socket,
renatofilho@320: 		    hostname, port, 0);
renatofilho@320: }
renatofilho@320: 
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_connect_with_timeout (GMythSocket *gmyth_socket,
renatofilho@320: 	const gchar *hostname, gint port, guint timeout)
renatofilho@320: {
renatofilho@320:     struct addrinfo *addr_info_data = NULL, *addr_info0 = NULL;
renatofilho@320:     gint ret_code = -1;
renatofilho@320:     gint errno;
renatofilho@320:     gboolean ret = TRUE;
renatofilho@320: 
renatofilho@320:     gmyth_debug ("CONNECTING %s:%d", hostname, port);
renatofilho@320: 
renatofilho@320:     if ( hostname == NULL )
renatofilho@320:         gmyth_debug ( "Invalid hostname parameter!\n");
renatofilho@320: 
renatofilho@320:     /* store hostname and port number */
renatofilho@320:     if (gmyth_socket->hostname != NULL) {
renatofilho@320:         //g_free (gmyth_socket->hostname);
renatofilho@320:         gmyth_socket->hostname = NULL;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     errno = gmyth_socket_toaddrinfo ( hostname, port, &addr_info_data );
renatofilho@320: 
renatofilho@320:     g_return_val_if_fail( addr_info_data != NULL && hostname != NULL, FALSE );
renatofilho@320: 
renatofilho@320:     gmyth_socket->hostname = g_strdup( hostname );
renatofilho@320:     gmyth_socket->port = port;
renatofilho@320: 
renatofilho@320:     for ( addr_info0 = addr_info_data; addr_info0; addr_info0 = addr_info_data->ai_next ) {
renatofilho@320:         /* init socket descriptor */
renatofilho@320:         gmyth_socket->sd = socket( addr_info0->ai_family, addr_info0->ai_socktype,
renatofilho@320:                          addr_info0->ai_protocol );
renatofilho@320: 
renatofilho@320:         if ( gmyth_socket->sd < 0 )
renatofilho@320:             continue;
renatofilho@320: 
renatofilho@320:         struct timeval *timeout_val = g_new0 (struct timeval, 1);
renatofilho@320: 	if (timeout != 0) {
renatofilho@320: 	    /*timeout_val = g_new0 (struct timeval, 1);*/
renatofilho@320: 	    
renatofilho@320:             timeout_val->tv_sec = timeout;
renatofilho@320:             timeout_val->tv_usec = 0;
renatofilho@320: 	} else {
renatofilho@320:             timeout_val->tv_sec = 5;
renatofilho@320:             timeout_val->tv_usec = 100;
renatofilho@320: 	}
renatofilho@320:         
renatofilho@320:         if (gmyth_socket_try_connect (gmyth_socket->sd, (struct sockaddr *)addr_info0->ai_addr,
renatofilho@320:                 addr_info0->ai_addrlen, timeout_val, &ret_code ) < 0 )
renatofilho@320:         {
renatofilho@320:             g_printerr( "[%s] Error connecting to backend!\n", __FUNCTION__ );
renatofilho@320:             if (ret_code == ETIMEDOUT)
renatofilho@320:                 g_printerr( "[%s]\tBackend host unreachable!\n", __FUNCTION__ );
renatofilho@320: 
renatofilho@320:             close (gmyth_socket->sd);
renatofilho@320:             gmyth_socket->sd = -1;
renatofilho@320:             g_printerr ("ERROR: %s\n", gai_strerror(ret_code));
renatofilho@320: 	    g_free (timeout_val);
renatofilho@320:             continue;
renatofilho@320:         }
renatofilho@320: 
renatofilho@320: 	g_free (timeout_val);
renatofilho@320: 
renatofilho@320:         /* only will be reached if none of the error above occurred */
renatofilho@320:         break;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     freeaddrinfo (addr_info_data);
renatofilho@320:     addr_info_data = NULL;
renatofilho@320: 
renatofilho@320:     if (gmyth_socket->sd_io_ch != NULL) {
renatofilho@320:         g_io_channel_unref (gmyth_socket->sd_io_ch);
renatofilho@320:         gmyth_socket->sd_io_ch = NULL;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     gmyth_socket->sd_io_ch = g_io_channel_unix_new (gmyth_socket->sd);
renatofilho@320:     
renatofilho@320:     //GIOFlags flags = g_io_channel_get_flags (gmyth_socket->sd_io_ch);
renatofilho@320: 		/* unset the nonblock flag */
renatofilho@320: 		//flags &= ~G_IO_FLAG_NONBLOCK;
renatofilho@320: 		/* unset the nonblocking stuff for some time, because GNUTLS doesn't like
renatofilho@320: 		 * that */
renatofilho@320: 		//g_io_channel_set_flags (gmyth_socket->sd_io_ch, flags, NULL);
renatofilho@320: 
renatofilho@320:     ret = ( ret_code == 0 ) ? TRUE : FALSE ;
renatofilho@320:     return ret;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Gets the GIOChannel associated to the given GMythSocket.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  */
renatofilho@320: GIOChannel *
renatofilho@320: gmyth_socket_get_io_channel( GMythSocket *gmyth_socket )
renatofilho@320: {
renatofilho@320:     g_return_val_if_fail( gmyth_socket != NULL, NULL );
renatofilho@320: 
renatofilho@320:     return gmyth_socket->sd_io_ch;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Verifies if the socket is able to read.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @return TRUE if the socket is able to read, FALSE if not.
renatofilho@320:  */
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_is_able_to_read( GMythSocket *gmyth_socket )
renatofilho@320: {
renatofilho@320:     gboolean ret = TRUE;
renatofilho@320: 
renatofilho@320:     /* verify if the input (read) buffer is ready to receive data */
renatofilho@320:     GIOCondition io_cond = g_io_channel_get_buffer_condition( gmyth_socket->sd_io_ch );
renatofilho@320: 
renatofilho@320:     if ( ( io_cond & G_IO_IN ) == 0 ) {
renatofilho@320: 	g_warning ("[%s] IO channel is not able to send data!\n", __FUNCTION__);
renatofilho@320: 	ret = FALSE;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     return ret;
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Verifies if the socket is able to write.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @return TRUE if the socket is able to write, FALSE if not.
renatofilho@320:  */
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_is_able_to_write( GMythSocket *gmyth_socket )
renatofilho@320: {
renatofilho@320:     gboolean ret = TRUE;
renatofilho@320: 
renatofilho@320:     /* verify if the input (read) buffer is ready to receive data */
renatofilho@320:     GIOCondition io_cond = g_io_channel_get_buffer_condition( gmyth_socket->sd_io_ch );
renatofilho@320: 
renatofilho@320:     if ( ( ( io_cond & G_IO_OUT ) == 0 ) || ( ( io_cond & G_IO_HUP ) == 0 ) ) {
renatofilho@320: 	g_warning ("[%s] IO channel is not able to send data!\n", __FUNCTION__);
renatofilho@320: 	ret = FALSE;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     return ret;
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Sends a command to the backend.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket the GMythSocket instance.
renatofilho@320:  * @param command The string command to be sent.
renatofilho@320:  */
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_send_command(GMythSocket *gmyth_socket, GString *command) 
renatofilho@320: {
renatofilho@320:     gboolean ret = TRUE;
renatofilho@320: 
renatofilho@320:     GIOStatus io_status = G_IO_STATUS_NORMAL;
renatofilho@320:     //GIOCondition io_cond;
renatofilho@320:     GError* error = NULL;
renatofilho@320:    
renatofilho@320:     
renatofilho@320:     gchar *buffer = NULL;
renatofilho@320: 
renatofilho@320:     gsize bytes_written = 0;
renatofilho@320: 
renatofilho@320:     if( command == NULL || ( command->len <= 0 ) || command->str == NULL ) {
renatofilho@320: 		g_warning ("[%s] Invalid NULL command parameter!\n", __FUNCTION__);
renatofilho@320: 		ret = FALSE;
renatofilho@320: 		goto done;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     //g_static_mutex_lock( &mutex );
renatofilho@320:     gmyth_debug ("Sending command to backend: %s\n", command->str);
renatofilho@320: 
renatofilho@320:     buffer = g_strnfill( BUFLEN, ' ' );
renatofilho@320:     g_snprintf( buffer, MYTH_PROTOCOL_FIELD_SIZE+1, "%-8d", command->len);
renatofilho@320: 
renatofilho@320:     command = g_string_prepend(command, buffer);
renatofilho@320: 
renatofilho@320:     /* write bytes to socket */    
renatofilho@320:     io_status = g_io_channel_write_chars( gmyth_socket->sd_io_ch, command->str, 
renatofilho@320: 	    command->len, &bytes_written, &error );
renatofilho@320: 
renatofilho@320: 
renatofilho@320:     if( (io_status == G_IO_STATUS_ERROR) || ( bytes_written <= 0 ) ) {
renatofilho@320: 		g_warning ("[%s] Error while writing to socket", __FUNCTION__);
renatofilho@320: 		ret = FALSE;
renatofilho@320:     } else if ( bytes_written < command->len ) {
renatofilho@320: 		g_warning ("[%s] Not all data was written socket", __FUNCTION__);
renatofilho@320: 		ret = FALSE;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     io_status = g_io_channel_flush( gmyth_socket->sd_io_ch, &error );
renatofilho@320: 
renatofilho@320:     if ( ( bytes_written != command->len ) || ( io_status == G_IO_STATUS_ERROR ) )
renatofilho@320:     {
renatofilho@320: 		g_warning ("[%s] Some problem occurred when sending data to the socket\n", __FUNCTION__);
renatofilho@320: 	
renatofilho@320: 		ret = TRUE;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     //g_static_mutex_unlock( &mutex );
renatofilho@320: done:
renatofilho@320:     if ( error != NULL ) {
renatofilho@320: 		g_printerr( "[%s] Error found reading data from IO channel: (%d, %s)\n", __FUNCTION__, error->code, error->message );
renatofilho@320: 		ret = FALSE;
renatofilho@320: 		g_error_free( error );
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     if ( buffer!= NULL )
renatofilho@320: 		g_free( buffer );
renatofilho@320: 
renatofilho@320:     return ret;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Starts Mythtv protocol level connection. Checks Mythtv protocol version
renatofilho@320:  * supported by the backend and send the "ANN" command.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket the GMythSocket instance.
renatofilho@320:  * @param hostname_backend The backend hostname or IP address.
renatofilho@320:  * @param port The backend port to connect.
renatofilho@320:  * @param blocking_client A flag to choose between blocking and non-blocking
renatofilho@320:  * @param with_events	Sets the connection flag to receive events.
renatofilho@320:  * 										backend connection. 
renatofilho@320:  */
renatofilho@320: static gboolean
renatofilho@320: gmyth_socket_connect_to_backend_and_events (GMythSocket *gmyth_socket, 
renatofilho@320: 	const gchar *hostname_backend, gint port, gboolean blocking_client,
renatofilho@320: 	gboolean with_events)
renatofilho@320: {
renatofilho@320:     if (!gmyth_socket_connect (gmyth_socket, hostname_backend, port)) {
renatofilho@320: 		g_warning ("[%s] Could not open socket to backend machine [%s]\n", __FUNCTION__,
renatofilho@320: 					hostname_backend );
renatofilho@320: 		return FALSE;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     if ( gmyth_socket_check_protocol_version (gmyth_socket) ) {
renatofilho@320: 
renatofilho@320: 	GString *result;
renatofilho@320: 	GString *base_str = g_string_new("");
renatofilho@320: 	GString *hostname = NULL;
renatofilho@320: 
renatofilho@320: 	hostname = gmyth_socket_get_local_hostname();
renatofilho@320: 	if (hostname == NULL) {
renatofilho@320: 	    g_debug ("Hostname not available, setting to n800frontend\n");
renatofilho@320: 	    hostname = g_strdup ("n800frontend");
renatofilho@320: 	}
renatofilho@320: 
renatofilho@320: 	g_string_printf(base_str, "ANN %s %s %u", 
renatofilho@320: 		(blocking_client ? "Playback" : "Monitor"),
renatofilho@320: 		hostname->str, with_events);
renatofilho@320: 
renatofilho@320: 	gmyth_socket_send_command (gmyth_socket, base_str);
renatofilho@320: 	result = gmyth_socket_receive_response (gmyth_socket);
renatofilho@320: 
renatofilho@320: 	if (result != NULL) {
renatofilho@320: 	    gmyth_debug ("Response received from backend: %s", result->str);
renatofilho@320: 	    g_string_free (result, TRUE);
renatofilho@320: 	}
renatofilho@320: 
renatofilho@320: 	g_string_free (hostname, TRUE);
renatofilho@320: 	g_string_free (base_str, TRUE);
renatofilho@320: 
renatofilho@320: 	return TRUE;
renatofilho@320:     } else {
renatofilho@320: 	g_warning ("[%s] GMythSocket could not connect to the backend", __FUNCTION__);	
renatofilho@320: 	return FALSE;
renatofilho@320:     }
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Starts Mythtv protocol level connection. Checks Mythtv protocol version
renatofilho@320:  * supported by the backend and send the "ANN" command.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket the GMythSocket instance.
renatofilho@320:  * @param hostname_backend The backend hostname or IP address.
renatofilho@320:  * @param port The backend port to connect.
renatofilho@320:  * @param blocking_client A flag to choose between blocking and non-blocking 
renatofilho@320:  */
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_connect_to_backend (GMythSocket *gmyth_socket, 
renatofilho@320: 	const gchar *hostname_backend, gint port, gboolean blocking_client)
renatofilho@320: {
renatofilho@320:     if (!gmyth_socket_connect_to_backend_and_events ( gmyth_socket, hostname_backend, port,
renatofilho@320:     		blocking_client, FALSE) ) {
renatofilho@320: 		gmyth_debug ("Could not open socket to backend machine [%s]\n",
renatofilho@320: 					hostname_backend );
renatofilho@320: 		return FALSE;
renatofilho@320:     }
renatofilho@320:     
renatofilho@320:     return TRUE;
renatofilho@320: 
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Starts Mythtv protocol level connection. Checks Mythtv protocol version
renatofilho@320:  * supported by the backend and send the "ANN" command.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket the GMythSocket instance.
renatofilho@320:  * @param hostname_backend The backend hostname or IP address.
renatofilho@320:  * @param port The backend port to connect.
renatofilho@320:  * @param blocking_client A flag to choose between blocking and non-blocking 
renatofilho@320:  */
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_connect_to_backend_events (GMythSocket *gmyth_socket, 
renatofilho@320: 	const gchar *hostname_backend, gint port, gboolean blocking_client)
renatofilho@320: {
renatofilho@320:     if (!gmyth_socket_connect_to_backend_and_events ( gmyth_socket, hostname_backend, port,
renatofilho@320:     		blocking_client, TRUE) ) {
renatofilho@320: 		gmyth_debug ("Could not open socket to backend machine in order to receive events [%s]\n",
renatofilho@320: 					hostname_backend );
renatofilho@320: 		return FALSE;
renatofilho@320:     }
renatofilho@320:     
renatofilho@320:     return TRUE;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Closes the socket connection to the backend.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  */
renatofilho@320: void
renatofilho@320: gmyth_socket_close_connection (GMythSocket *gmyth_socket)
renatofilho@320: {
renatofilho@320:     close (gmyth_socket->sd);	
renatofilho@320:     gmyth_socket->sd = -1;
renatofilho@320: 
renatofilho@320:     if (gmyth_socket->sd_io_ch != NULL) {
renatofilho@320:         g_io_channel_unref (gmyth_socket->sd_io_ch);
renatofilho@320:         gmyth_socket->sd_io_ch = NULL;
renatofilho@320:     }
renatofilho@320: }
renatofilho@320: 
renatofilho@320: 
renatofilho@320: /** Try the MythTV version numbers, and get the version returned by
renatofilho@320:  * the possible REJECT message, in order to contruct a new
renatofilho@320:  * MythTV version request.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @param mythtv_version The Mythtv protocol version to be tested
renatofilho@320:  * 
renatofilho@320:  * @return The actual MythTV the client is connected to.
renatofilho@320:  */
renatofilho@320: gint
renatofilho@320: gmyth_socket_check_protocol_version_number (GMythSocket *gmyth_socket, gint mythtv_version)
renatofilho@320: {
renatofilho@320:     GString *response = NULL;
renatofilho@320:     GString *payload = NULL;
renatofilho@320:     gboolean res = TRUE;
renatofilho@320:     gint mythtv_new_version = MYTHTV_CANNOT_NEGOTIATE_VERSION;
renatofilho@320:     guint max_iterations = MYTHTV_MAX_VERSION_CHECKS;
renatofilho@320: 
renatofilho@320: try_new_version:
renatofilho@320:     payload = g_string_new ("MYTH_PROTO_VERSION");
renatofilho@320:     g_string_append_printf( payload, " %d", mythtv_version );
renatofilho@320: 
renatofilho@320:     gmyth_socket_send_command(gmyth_socket, payload);
renatofilho@320:     response = gmyth_socket_receive_response(gmyth_socket);
renatofilho@320: 
renatofilho@320:     if (response == NULL) {
renatofilho@320: 		g_warning ("[%s] Check protocol version error! Not answered!", __FUNCTION__);
renatofilho@320: 		res = FALSE;	
renatofilho@320: 		goto done;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     res = g_str_has_prefix (response->str, "ACCEPT");
renatofilho@320:     if (!res) {
renatofilho@320: 		g_warning ("[%s] Protocol version request error: %s", __FUNCTION__, response->str);
renatofilho@320: 	/* get the version number returned by the REJECT message */
renatofilho@320: 	if ( ( res = g_str_has_prefix (response->str, "REJECT") ) == TRUE ) {
renatofilho@320:         gchar *new_version = NULL;
renatofilho@320: 	    new_version = g_strrstr( response->str, "]" );
renatofilho@320: 	    if (new_version!=NULL) {
renatofilho@320: 		++new_version; /* skip ']' character */
renatofilho@320: 		if ( new_version != NULL ) {
renatofilho@320: 		    gmyth_debug ( "[%s] got MythTV version = %s.\n", __FUNCTION__, new_version );
renatofilho@320: 		    mythtv_version = (gint)g_ascii_strtoull (new_version, NULL, 10 );
renatofilho@320: 		    /* do reconnection to the socket (socket is closed if the MythTV version was wrong) */
renatofilho@320: 		    gmyth_socket_connect( gmyth_socket, gmyth_socket->hostname, gmyth_socket->port );
renatofilho@320:             new_version =NULL;
renatofilho@320: 		    if ( --max_iterations > 0 ) 
renatofilho@320: 		    	goto try_new_version;
renatofilho@320: 		    else
renatofilho@320: 		    	goto done;
renatofilho@320: 		}
renatofilho@320: 	    }
renatofilho@320: 	}
renatofilho@320:     }
renatofilho@320:     
renatofilho@320:     /* change the return value to a valid one */
renatofilho@320:     if ( res ) {
renatofilho@320:     	mythtv_new_version = mythtv_version;
renatofilho@320:     	gmyth_socket->mythtv_version = mythtv_new_version;
renatofilho@320:     }
renatofilho@320: 
renatofilho@320: done:
renatofilho@320:     if ( payload != NULL )
renatofilho@320: 		g_string_free (payload, TRUE);
renatofilho@320:     if ( response != NULL )
renatofilho@320: 		g_string_free (response, TRUE);
renatofilho@320: 
renatofilho@320:     return mythtv_new_version;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Verifies if the Mythtv backend supported the GMyth supported version.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @return TRUE if supports, FALSE if not.
renatofilho@320:  */
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_check_protocol_version (GMythSocket *gmyth_socket)
renatofilho@320: {
renatofilho@320:     return ( ( gmyth_socket->mythtv_version = 
renatofilho@320:     		gmyth_socket_check_protocol_version_number ( gmyth_socket, 
renatofilho@320:     							MYTHTV_VERSION_DEFAULT ) ) != MYTHTV_CANNOT_NEGOTIATE_VERSION );
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Returns the Mythtv backend supported version.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @return The actual MythTV version number.
renatofilho@320:  */
renatofilho@320: gint
renatofilho@320: gmyth_socket_get_protocol_version (GMythSocket *gmyth_socket) 
renatofilho@320: {
renatofilho@320: 	return gmyth_socket->mythtv_version;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Receives a backend answer after a gmyth_socket_send_command_call ().
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @return The response received, or NULL if error or nothing was received.
renatofilho@320:  */
renatofilho@320: GString*
renatofilho@320: gmyth_socket_receive_response(GMythSocket *gmyth_socket)
renatofilho@320: {
renatofilho@320:     GIOStatus io_status = G_IO_STATUS_NORMAL;
renatofilho@320:     GError* error = NULL;
renatofilho@320:     gchar *buffer;
renatofilho@320: 
renatofilho@320:     GString *str = NULL;
renatofilho@320: 
renatofilho@320:     gsize bytes_read = 0;
renatofilho@320:     gint  len = 0;
renatofilho@320:     GIOCondition io_cond = g_io_channel_get_buffer_condition (gmyth_socket->sd_io_ch);
renatofilho@320: 
renatofilho@320:     g_return_val_if_fail( gmyth_socket != NULL, NULL );
renatofilho@320: 
renatofilho@320:     /* verify if the input (read) buffer is ready to receive data */
renatofilho@320: 
renatofilho@320:     //g_static_mutex_lock( &mutex );
renatofilho@320: 
renatofilho@320:     //buffer = g_new0 (gchar, MYTH_PROTOCOL_FIELD_SIZE);
renatofilho@320:     buffer = g_strnfill (MYTH_PROTOCOL_FIELD_SIZE, ' ');
renatofilho@320:     io_status = g_io_channel_read_chars (gmyth_socket->sd_io_ch, buffer, MYTH_PROTOCOL_FIELD_SIZE, &bytes_read, &error);
renatofilho@320: 
renatofilho@320:     /* verify if the input (read) buffer is ready to receive data */
renatofilho@320:     io_cond = g_io_channel_get_buffer_condition (gmyth_socket->sd_io_ch);
renatofilho@320: 
renatofilho@320:     gmyth_debug ( "[%s] Bytes read = %d\n", __FUNCTION__, bytes_read );
renatofilho@320: 
renatofilho@320:     if( (io_status == G_IO_STATUS_ERROR) || (bytes_read <= 0) ) {
renatofilho@320: 		g_warning ("[%s] Error in mythprotocol response from backend\n", __FUNCTION__);
renatofilho@320: 		str = NULL;
renatofilho@320: 		//return NULL;
renatofilho@320:     } else {
renatofilho@320: 
renatofilho@320: 		io_status = g_io_channel_flush( gmyth_socket->sd_io_ch, &error );
renatofilho@320: 		/* verify if the input (read) buffer is ready to receive data */
renatofilho@320: 		io_cond = g_io_channel_get_buffer_condition( gmyth_socket->sd_io_ch );
renatofilho@320: 	
renatofilho@320: 		//if ( ( io_cond & G_IO_IN ) != 0 ) {
renatofilho@320:             //gchar *buffer_aux = NULL;
renatofilho@320: 
renatofilho@320: 		    /* removes trailing whitespace */
renatofilho@320: 		    //buffer_aux = g_strstrip (buffer);
renatofilho@320: 		    len = (gint)g_ascii_strtoull ( g_strstrip (buffer), NULL, 10 );
renatofilho@320: 
renatofilho@320:             if (buffer != NULL) {
renatofilho@320:                 g_free (buffer);
renatofilho@320:                 buffer = NULL;
renatofilho@320:             }
renatofilho@320:             
renatofilho@320:             /*            
renatofilho@320:             if (buffer_aux != NULL) {
renatofilho@320:                 g_free (buffer_aux);
renatofilho@320:                 buffer_aux = NULL;
renatofilho@320:             }
renatofilho@320:             */
renatofilho@320: 
renatofilho@320:             buffer = g_new0 (gchar, len+1);
renatofilho@320: 	
renatofilho@320: 		    bytes_read = 0;
renatofilho@320: 		    io_status = g_io_channel_read_chars( gmyth_socket->sd_io_ch, buffer, len, &bytes_read, &error);
renatofilho@320: 		    buffer[bytes_read] = '\0';
renatofilho@320: 		//}
renatofilho@320:     }  
renatofilho@320: 
renatofilho@320:     //g_static_mutex_unlock( &mutex );
renatofilho@320: 
renatofilho@320:     gmyth_debug ("Response received from backend: {%s}\n", buffer);
renatofilho@320: 
renatofilho@320:     if ( ( bytes_read != len ) || ( io_status == G_IO_STATUS_ERROR ) )
renatofilho@320: 		str = NULL;
renatofilho@320:     else
renatofilho@320: 		str = g_string_new (buffer);
renatofilho@320: 
renatofilho@320:     if ( error != NULL ) {
renatofilho@320: 		g_printerr( "[%s] Error found receiving response from the IO channel: (%d, %s)\n", __FUNCTION__, error->code, error->message );
renatofilho@320: 		str = NULL;
renatofilho@320: 		g_error_free (error);
renatofilho@320:     }
renatofilho@320: 
renatofilho@320:     g_free (buffer);
renatofilho@320:     return str;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Format a Mythtv command from the str_list entries and send it to backend.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @param str_list The string list to form the command
renatofilho@320:  * @return TRUE if command was sent, FALSE if any error happens.
renatofilho@320:  */
renatofilho@320: gboolean
renatofilho@320: gmyth_socket_write_stringlist(GMythSocket *gmyth_socket, GMythStringList* str_list)
renatofilho@320: {
renatofilho@320: 
renatofilho@320:     GList *tmp_list = NULL;
renatofilho@320:     GPtrArray *ptr_array = NULL;
renatofilho@320:     gchar *str_array = NULL;
renatofilho@320: 
renatofilho@320:     g_static_mutex_lock( &mutex );
renatofilho@320: 
renatofilho@320:     ptr_array = g_ptr_array_sized_new (g_list_length(str_list->glist));
renatofilho@320: 
renatofilho@320:     // FIXME: change this implementation!
renatofilho@320:     tmp_list = str_list->glist;
renatofilho@320:     for(; tmp_list; tmp_list = tmp_list->next) {
renatofilho@320: 	if ( tmp_list->data != NULL ) {
renatofilho@320: 	    g_ptr_array_add(ptr_array, ((GString*)tmp_list->data)->str);
renatofilho@320: 	} else {
renatofilho@320: 	    g_ptr_array_add (ptr_array, "");
renatofilho@320: 	}
renatofilho@320:     }
renatofilho@320:     g_ptr_array_add(ptr_array, NULL); // g_str_joinv() needs a NULL terminated string
renatofilho@320: 
renatofilho@320:     str_array = g_strjoinv (MYTH_SEPARATOR, (gchar **) (ptr_array->pdata));
renatofilho@320: 
renatofilho@320:     g_static_mutex_unlock( &mutex );
renatofilho@320: 
renatofilho@320:     gmyth_debug ( "[%s] Sending socket request: %s\n", __FUNCTION__, str_array );
renatofilho@320: 
renatofilho@320:     // Sends message to backend	
renatofilho@320:     // TODO: implement looping to send remaining data, and add timeout testing!    
renatofilho@320:     GString *command = g_string_new(str_array);
renatofilho@320:     gmyth_socket_send_command(gmyth_socket, command);
renatofilho@320:     g_string_free (command, TRUE);
renatofilho@320: 
renatofilho@320:     g_free (str_array);
renatofilho@320:     g_ptr_array_free (ptr_array, TRUE);
renatofilho@320: 
renatofilho@320:     return TRUE;
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /* Receives a backend command response and split it into the given string list.
renatofilho@320:  * 
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @param str_list the string list to be filled.
renatofilho@320:  * @return The number of received strings.
renatofilho@320:  */
renatofilho@320: gint
renatofilho@320: gmyth_socket_read_stringlist (GMythSocket *gmyth_socket, GMythStringList* str_list)
renatofilho@320: {
renatofilho@320:     GString *response;
renatofilho@320:     gchar **str_array;
renatofilho@320:     gint i;
renatofilho@320: 
renatofilho@320:     response = gmyth_socket_receive_response(gmyth_socket);
renatofilho@320:     g_static_mutex_lock( &mutex );
renatofilho@320: 
renatofilho@320:     gmyth_string_list_clear_all (str_list);	
renatofilho@320:     str_array = g_strsplit (response->str, MYTH_SEPARATOR, -1);
renatofilho@320: 
renatofilho@320:     for (i=0; i< g_strv_length (str_array); i++) {
renatofilho@320: 	gmyth_string_list_append_char_array (str_list, str_array[i] );
renatofilho@320:     }
renatofilho@320:     g_static_mutex_unlock( &mutex );
renatofilho@320: 
renatofilho@320:     g_string_free (response, TRUE);
renatofilho@320:     g_strfreev (str_array);
renatofilho@320: 
renatofilho@320:     return gmyth_string_list_length (str_list);
renatofilho@320: }
renatofilho@320: 
renatofilho@320: /** Formats a Mythtv protocol command based on str_list and sends it to
renatofilho@320:  * the connected backend. The backend response is overwritten into str_list.
renatofilho@320:  *
renatofilho@320:  * @param gmyth_socket The GMythSocket instance.
renatofilho@320:  * @param str_list The string list to be sent, and on which the answer 
renatofilho@320:  * will be written.
renatofilho@320:  * @return TRUE if command was sent and an answer was received, FALSE if any
renatofilho@320:  * error happens.
renatofilho@320:  */
renatofilho@320: gint
renatofilho@320: gmyth_socket_sendreceive_stringlist (GMythSocket *gmyth_socket, GMythStringList *str_list)
renatofilho@320: {
renatofilho@320:     gmyth_socket_write_stringlist (gmyth_socket, str_list);
renatofilho@320: 
renatofilho@320:     return gmyth_socket_read_stringlist (gmyth_socket, str_list);
renatofilho@320: }