diff -r 000000000000 -r 86e15690a104 gmyth-upnp/src/gmyth_upnp.c --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/gmyth-upnp/src/gmyth_upnp.c Wed Jan 10 21:47:24 2007 +0000 @@ -0,0 +1,350 @@ +/** + * GMyth Library + * + * @file gmyth/gmyth_upnp.c + * + * @brief

GMythUPnP allows that a MythTV frontend discovers a + * MythTV backend, using the UPnP architecture. + * + * Copyright (C) 2006 INdT - Instituto Nokia de Tecnologia. + * @author Rosfran Lins Borges + * + *//* + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU Lesser 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. + * + * You should have received a copy of the GNU Lesser General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + * + */ + +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + +#include "gmyth_upnp.h" + +#include +#include +#include +#include +#include +#include + +#include "gmyth_backendinfo.h" +#include "gmyth_socket.h" +#include "gmyth_uri.h" +#include "gmyth_debug.h" + +#define GMYTH_UPNP_MAX_SEARCHS 10 + +static void gmyth_upnp_class_init (GMythUPnPClass *klass); +static void gmyth_upnp_init (GMythUPnP *object); + +static void gmyth_upnp_dispose (GObject *object); +static void gmyth_upnp_finalize (GObject *object); + +static gboolean gmyth_upnp_initialize ( GMythUPnP *gmyth_upnp, GMythBackendInfo *gmyth_backend_info ); + +static gboolean gmyth_upnp_print_cp_device_list( CgUpnpControlPoint* controlPt, gchar **udn, + GList **mythtv_servers_lst ); + +G_DEFINE_TYPE(GMythUPnP, gmyth_upnp, G_TYPE_OBJECT) + +static GStaticMutex mutex = G_STATIC_MUTEX_INIT; + +static void +gmyth_upnp_class_init (GMythUPnPClass *klass) +{ + GObjectClass *gobject_class; + + gobject_class = (GObjectClass *) klass; + + gobject_class->dispose = gmyth_upnp_dispose; + gobject_class->finalize = gmyth_upnp_finalize; +} + +static void +gmyth_upnp_init ( GMythUPnP *gmyth_upnp ) +{ + gmyth_upnp->upnp_dev_found = FALSE; + + gmyth_upnp->uri = NULL; + gmyth_upnp->host = NULL; + gmyth_upnp->port = 0; + gmyth_upnp->protocol = NULL; + + gmyth_upnp->gmyth_backend_info = NULL; + + gmyth_upnp->control_point = NULL; + +} + +/** Creates a new instance of GMythUPnP. + * + * @return a new instance of GMythUPnP. + */ +GMythUPnP * +gmyth_upnp_new ( GMythBackendInfo *gmyth_backend_info ) +{ + GMythUPnP *gmyth_upnp = GMYTH_UPNP (g_object_new (GMYTH_UPNP_TYPE, NULL)); + + gmyth_upnp->gmyth_backend_info = gmyth_backend_info; + + if ( !gmyth_upnp_initialize ( gmyth_upnp, gmyth_backend_info ) ) + return NULL; + + return gmyth_upnp; +} + +static void +gmyth_upnp_dispose (GObject *object) +{ + GMythUPnP *gmyth_upnp = GMYTH_UPNP(object); + + if ( gmyth_upnp->control_point != NULL ) { + cg_upnp_controlpoint_stop( gmyth_upnp->control_point ); + cg_upnp_controlpoint_delete( gmyth_upnp->control_point ); + gmyth_upnp->control_point = NULL; + } + + if ( gmyth_upnp->uri != NULL ) { + g_free ( gmyth_upnp->uri ); + gmyth_upnp->uri = NULL; + } + + if ( gmyth_upnp->host != NULL ) { + g_free ( gmyth_upnp->host ); + gmyth_upnp->host = NULL; + } + + if ( gmyth_upnp->protocol != NULL ) { + g_free ( gmyth_upnp->protocol ); + gmyth_upnp->protocol = NULL; + } + + if ( gmyth_upnp->mythtv_servers != NULL ) { + g_list_free( gmyth_upnp->mythtv_servers ); + gmyth_upnp->mythtv_servers = NULL; + } + + G_OBJECT_CLASS (gmyth_upnp_parent_class)->dispose (object); +} + +static void +gmyth_upnp_finalize (GObject *object) +{ + g_signal_handlers_destroy (object); + + G_OBJECT_CLASS (gmyth_upnp_parent_class)->finalize (object); +} + +/** + * Create a control point and start it. + */ +static gboolean +gmyth_upnp_initialize ( GMythUPnP *gmyth_upnp, GMythBackendInfo *gmyth_backend_info ) +{ + + gboolean ret = FALSE; + + GMythURI* uri = NULL; + + guint iter_count = GMYTH_UPNP_MAX_SEARCHS; + + g_return_val_if_fail( gmyth_backend_info != NULL, FALSE ); + + /* Create the cybergarage control point */ + gmyth_upnp->control_point = cg_upnp_controlpoint_new(); + /* cg_upnp_controlpoint_setdevicelistener( gmyth_upnp->control_point, device_listener ); */ + + /* Start the control point */ + if ( cg_upnp_controlpoint_start( gmyth_upnp->control_point ) == FALSE) + { + gmyth_debug( "Unable to start UPnP control point!!!" ); + goto done; + } + else + { + gmyth_debug( "Control point started." ); + } + + while ( gmyth_upnp->upnp_dev_found == FALSE && ( --iter_count > 0 ) ) { + + gmyth_debug( "UPnP MythTV Client control point is searching MythTV AV Device server...\n" ); + + if ( gmyth_upnp->control_point != NULL ) + cg_upnp_controlpoint_search ( gmyth_upnp->control_point, + "urn:schemas-upnp-org:service:ContentDirectory:1" ); + + /* just to avoid clinkc pthread concurrency faults */ + cg_wait( 1000 ); + + /* discover if it was found */ + gmyth_upnp->upnp_dev_found = gmyth_upnp_print_cp_device_list( gmyth_upnp->control_point, &gmyth_upnp->udn, + &gmyth_upnp->mythtv_servers ); + + } + + if ( gmyth_upnp->upnp_dev_found ) { + + gmyth_debug( "Found UPnP MythTV AV Device...\n" ); + + if ( g_list_first( gmyth_upnp->mythtv_servers ) != NULL && (g_list_first( gmyth_upnp->mythtv_servers ))->data != NULL ) + { + gmyth_upnp->uri = (gchar*) (g_list_first( gmyth_upnp->mythtv_servers ))->data; + uri = gmyth_uri_new_with_value( gmyth_upnp->uri ); + + gmyth_upnp->host = gmyth_uri_get_host( uri ); + gmyth_upnp->port = gmyth_uri_get_port( uri ); + gmyth_upnp->protocol = gmyth_uri_get_protocol( uri ); + + /* sets all the discovered data from the UPnP remote device, like host name, IP address, port,... */ + if ( NULL != gmyth_upnp->host ) + gmyth_backend_info_set_hostname ( gmyth_upnp->gmyth_backend_info, gmyth_upnp->host ); + + if ( gmyth_upnp->port > 0 ) + gmyth_backend_info_set_port ( gmyth_upnp->gmyth_backend_info, gmyth_upnp->port ); + + ret = TRUE; + } + } + +done: + + if ( uri != NULL ) + { + g_object_unref( uri ); + uri = NULL; + } + + return ret; + +} + +/** + * Prints the Control Point's device list + */ +static gboolean +gmyth_upnp_print_cp_device_list( CgUpnpControlPoint* controlPt, gchar **udn, GList **mythtv_servers_lst ) +{ + + g_return_val_if_fail( mythtv_servers_lst != NULL, FALSE ); + g_return_val_if_fail( controlPt != NULL, FALSE ); + + gchar* mythtvFriendlyName = "Myth"; + /* begin assertion about the size of discovered devices */ + gint numDevices = cg_upnp_controlpoint_getndevices(controlPt); + gint cntDevs = 0; + //CgUpnpDeviceList *devList = NULL; + CgUpnpDevice *childDev; + gchar *devName = NULL, *dev_url = NULL; + gboolean upnp_dev_found = FALSE; + + gmyth_debug( "UPnP MythTV AV Device list size = %d\n", numDevices ); + + for ( childDev = cg_upnp_controlpoint_getdevices(controlPt); childDev != NULL; + childDev = cg_upnp_device_next(childDev) ) { + devName = cg_upnp_device_getfriendlyname(childDev); + dev_url = cg_upnp_device_getlocationfromssdppacket( childDev ); + gmyth_debug( "Device's friendly name = %s, and device's URL = %s\n", devName, dev_url ); + if ( ( upnp_dev_found = ( g_strstr_len( devName, strlen( devName ), mythtvFriendlyName ) != NULL ) ) == TRUE ) + { + *udn = cg_upnp_device_getudn( childDev ); + *mythtv_servers_lst = g_list_append( *mythtv_servers_lst, dev_url ); + } + ++cntDevs; + } + + if ( upnp_dev_found == TRUE ) { + gmyth_debug( "MythTV AV Device found, from a total of %d devices.\n", cntDevs ); + } else if ( numDevices == cntDevs ) { + gmyth_debug( "MythTV AV Device not found, from a total of %d devices.\n", cntDevs ); + } else { + gmyth_debug( "Control Point's MythTV AV Device count is wrong: iterated over %d devices, but there are %d registered devices.\n", cntDevs, numDevices ); + } + + return upnp_dev_found; + +} + +/** Gets the GMythBackendInfo host object associated to this upnp. + * + * @return The string host object currently valid or NULL if the settings + * were not opened. + */ +gchar* +gmyth_upnp_get_host ( GMythUPnP *gmyth_upnp ) +{ + + if ( NULL == gmyth_upnp || NULL == gmyth_upnp->host ) + { + gmyth_debug ("[%s] GMythUPnP host field not initialized\n", __FUNCTION__); + return NULL; + } + + return gmyth_upnp->host; +} + +/** Gets the GMythBackendInfo port object associated to this upnp. + * + * @return The string object currently valid or NULL if the port number. + */ +gint +gmyth_upnp_get_port( GMythUPnP *gmyth_upnp ) +{ + + if ( NULL == gmyth_upnp || gmyth_upnp->port <= 0 ) + { + gmyth_debug ("[%s] GMythUPnP host field not initialized\n", __FUNCTION__); + return 0; + } + + return gmyth_upnp->port; +} + +/** Gets the UPnP AV devices server's list associated to this upnp. + * + * @return The GList* containing all the URI values for each recognized UPnP device, + * or NULL if it couldn't recognize any MythTV AV device. + */ +GList* +gmyth_upnp_get_servers ( GMythUPnP *gmyth_upnp ) +{ + + if ( NULL == gmyth_upnp || NULL == gmyth_upnp->mythtv_servers ) + { + gmyth_debug ("[%s] GMythUPnP has no MythTV servers recognized.\n", __FUNCTION__); + return NULL; + } + + return gmyth_upnp->mythtv_servers; +} + +/** Gets the GMythBackendInfo object associated to this upnp. + * + * @return The GMythBackendInfo object currently valid or NULL if the settings + * were not opened. + */ +GMythBackendInfo* +gmyth_upnp_get_backend_info ( GMythUPnP *gmyth_upnp ) +{ + + if ( NULL == gmyth_upnp || NULL == gmyth_upnp->gmyth_backend_info ) + { + gmyth_debug ("[%s] GMythUPnP not initialized\n", __FUNCTION__); + return NULL; + } + + return gmyth_upnp->gmyth_backend_info; +} +