# HG changeset patch # User rosfran # Date 1161614566 -3600 # Node ID ba5dc9bff3a1b5f23596efbeed22b85fc0fea859 # Parent 9e534ac483e6bfb5d1ba9177c705b5686bb0fb5c [svn r41] Changes prior to move some MythTV depedencies to the GMyth library. diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/Makefile.am --- a/gst-plugins-mythtv/src/Makefile.am Mon Oct 23 14:43:18 2006 +0100 +++ b/gst-plugins-mythtv/src/Makefile.am Mon Oct 23 15:42:46 2006 +0100 @@ -4,9 +4,9 @@ libgstmythtvsrc_la_SOURCES = \ gstmythtvsrc.c \ - myth_uri.c \ - myth_file_transfer.c \ - myth_livetv.c + gmyth_uri.c \ + gmyth_file_transfer.c \ + gmyth_livetv.c libgstmythtvsrc_la_CFLAGS = \ $(GST_CFLAGS) \ @@ -21,7 +21,7 @@ noinst_HEADERS = \ gstmythtvsrc.h \ - myth_uri.h \ - myth_file_transfer.h \ - myth_livetv.h + gmyth_uri.h \ + gmyth_file_transfer.h \ + gmyth_livetv.h diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/Makefile.in --- a/gst-plugins-mythtv/src/Makefile.in Mon Oct 23 14:43:18 2006 +0100 +++ b/gst-plugins-mythtv/src/Makefile.in Mon Oct 23 15:42:46 2006 +0100 @@ -60,9 +60,9 @@ am__DEPENDENCIES_1 = libgstmythtvsrc_la_DEPENDENCIES = $(am__DEPENDENCIES_1) am_libgstmythtvsrc_la_OBJECTS = libgstmythtvsrc_la-gstmythtvsrc.lo \ - libgstmythtvsrc_la-myth_uri.lo \ - libgstmythtvsrc_la-myth_file_transfer.lo \ - libgstmythtvsrc_la-myth_livetv.lo + libgstmythtvsrc_la-gmyth_uri.lo \ + libgstmythtvsrc_la-gmyth_file_transfer.lo \ + libgstmythtvsrc_la-gmyth_livetv.lo libgstmythtvsrc_la_OBJECTS = $(am_libgstmythtvsrc_la_OBJECTS) DEFAULT_INCLUDES = -I. -I$(srcdir) -I$(top_builddir) depcomp = $(SHELL) $(top_srcdir)/depcomp @@ -117,6 +117,7 @@ GMYTH_LIBS = @GMYTH_LIBS@ GOBJECT_CFLAGS = @GOBJECT_CFLAGS@ GOBJECT_LIBS = @GOBJECT_LIBS@ +GREP = @GREP@ GSTBASE_CFLAGS = @GSTBASE_CFLAGS@ GSTBASE_LIBS = @GSTBASE_LIBS@ GST_CFLAGS = @GST_CFLAGS@ @@ -166,13 +167,9 @@ SHELL = @SHELL@ STRIP = @STRIP@ VERSION = @VERSION@ -ac_ct_AR = @ac_ct_AR@ ac_ct_CC = @ac_ct_CC@ ac_ct_CXX = @ac_ct_CXX@ ac_ct_F77 = @ac_ct_F77@ -ac_ct_RANLIB = @ac_ct_RANLIB@ -ac_ct_STRIP = @ac_ct_STRIP@ -ac_pt_PKG_CONFIG = @ac_pt_PKG_CONFIG@ am__fastdepCC_FALSE = @am__fastdepCC_FALSE@ am__fastdepCC_TRUE = @am__fastdepCC_TRUE@ am__fastdepCXX_FALSE = @am__fastdepCXX_FALSE@ @@ -189,23 +186,30 @@ build_os = @build_os@ build_vendor = @build_vendor@ datadir = @datadir@ +datarootdir = @datarootdir@ +docdir = @docdir@ +dvidir = @dvidir@ exec_prefix = @exec_prefix@ host = @host@ host_alias = @host_alias@ host_cpu = @host_cpu@ host_os = @host_os@ host_vendor = @host_vendor@ +htmldir = @htmldir@ includedir = @includedir@ infodir = @infodir@ install_sh = @install_sh@ libdir = @libdir@ libexecdir = @libexecdir@ +localedir = @localedir@ localstatedir = @localstatedir@ mandir = @mandir@ mkdir_p = @mkdir_p@ oldincludedir = @oldincludedir@ +pdfdir = @pdfdir@ prefix = @prefix@ program_transform_name = @program_transform_name@ +psdir = @psdir@ sbindir = @sbindir@ sharedstatedir = @sharedstatedir@ sysconfdir = @sysconfdir@ @@ -214,9 +218,9 @@ plugin_LTLIBRARIES = libgstmythtvsrc.la libgstmythtvsrc_la_SOURCES = \ gstmythtvsrc.c \ - myth_uri.c \ - myth_file_transfer.c \ - myth_livetv.c + gmyth_uri.c \ + gmyth_file_transfer.c \ + gmyth_livetv.c libgstmythtvsrc_la_CFLAGS = \ $(GST_CFLAGS) \ @@ -231,9 +235,9 @@ noinst_HEADERS = \ gstmythtvsrc.h \ - myth_uri.h \ - myth_file_transfer.h \ - myth_livetv.h + gmyth_uri.h \ + gmyth_file_transfer.h \ + gmyth_livetv.h all: all-am @@ -304,10 +308,10 @@ distclean-compile: -rm -f *.tab.c +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libgstmythtvsrc_la-gmyth_file_transfer.Plo@am__quote@ +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libgstmythtvsrc_la-gmyth_livetv.Plo@am__quote@ +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libgstmythtvsrc_la-gmyth_uri.Plo@am__quote@ @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libgstmythtvsrc_la-gstmythtvsrc.Plo@am__quote@ -@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libgstmythtvsrc_la-myth_file_transfer.Plo@am__quote@ -@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libgstmythtvsrc_la-myth_livetv.Plo@am__quote@ -@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libgstmythtvsrc_la-myth_uri.Plo@am__quote@ .c.o: @am__fastdepCC_TRUE@ if $(COMPILE) -MT $@ -MD -MP -MF "$(DEPDIR)/$*.Tpo" -c -o $@ $<; \ @@ -337,26 +341,26 @@ @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@ @am__fastdepCC_FALSE@ $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -c -o libgstmythtvsrc_la-gstmythtvsrc.lo `test -f 'gstmythtvsrc.c' || echo '$(srcdir)/'`gstmythtvsrc.c -libgstmythtvsrc_la-myth_uri.lo: myth_uri.c -@am__fastdepCC_TRUE@ if $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -MT libgstmythtvsrc_la-myth_uri.lo -MD -MP -MF "$(DEPDIR)/libgstmythtvsrc_la-myth_uri.Tpo" -c -o libgstmythtvsrc_la-myth_uri.lo `test -f 'myth_uri.c' || echo '$(srcdir)/'`myth_uri.c; \ -@am__fastdepCC_TRUE@ then mv -f "$(DEPDIR)/libgstmythtvsrc_la-myth_uri.Tpo" "$(DEPDIR)/libgstmythtvsrc_la-myth_uri.Plo"; else rm -f "$(DEPDIR)/libgstmythtvsrc_la-myth_uri.Tpo"; exit 1; fi -@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='myth_uri.c' object='libgstmythtvsrc_la-myth_uri.lo' libtool=yes @AMDEPBACKSLASH@ +libgstmythtvsrc_la-gmyth_uri.lo: gmyth_uri.c +@am__fastdepCC_TRUE@ if $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -MT libgstmythtvsrc_la-gmyth_uri.lo -MD -MP -MF "$(DEPDIR)/libgstmythtvsrc_la-gmyth_uri.Tpo" -c -o libgstmythtvsrc_la-gmyth_uri.lo `test -f 'gmyth_uri.c' || echo '$(srcdir)/'`gmyth_uri.c; \ +@am__fastdepCC_TRUE@ then mv -f "$(DEPDIR)/libgstmythtvsrc_la-gmyth_uri.Tpo" "$(DEPDIR)/libgstmythtvsrc_la-gmyth_uri.Plo"; else rm -f "$(DEPDIR)/libgstmythtvsrc_la-gmyth_uri.Tpo"; exit 1; fi +@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='gmyth_uri.c' object='libgstmythtvsrc_la-gmyth_uri.lo' libtool=yes @AMDEPBACKSLASH@ @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@ -@am__fastdepCC_FALSE@ $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -c -o libgstmythtvsrc_la-myth_uri.lo `test -f 'myth_uri.c' || echo '$(srcdir)/'`myth_uri.c +@am__fastdepCC_FALSE@ $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -c -o libgstmythtvsrc_la-gmyth_uri.lo `test -f 'gmyth_uri.c' || echo '$(srcdir)/'`gmyth_uri.c -libgstmythtvsrc_la-myth_file_transfer.lo: myth_file_transfer.c -@am__fastdepCC_TRUE@ if $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -MT libgstmythtvsrc_la-myth_file_transfer.lo -MD -MP -MF "$(DEPDIR)/libgstmythtvsrc_la-myth_file_transfer.Tpo" -c -o libgstmythtvsrc_la-myth_file_transfer.lo `test -f 'myth_file_transfer.c' || echo '$(srcdir)/'`myth_file_transfer.c; \ -@am__fastdepCC_TRUE@ then mv -f "$(DEPDIR)/libgstmythtvsrc_la-myth_file_transfer.Tpo" "$(DEPDIR)/libgstmythtvsrc_la-myth_file_transfer.Plo"; else rm -f "$(DEPDIR)/libgstmythtvsrc_la-myth_file_transfer.Tpo"; exit 1; fi -@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='myth_file_transfer.c' object='libgstmythtvsrc_la-myth_file_transfer.lo' libtool=yes @AMDEPBACKSLASH@ +libgstmythtvsrc_la-gmyth_file_transfer.lo: gmyth_file_transfer.c +@am__fastdepCC_TRUE@ if $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -MT libgstmythtvsrc_la-gmyth_file_transfer.lo -MD -MP -MF "$(DEPDIR)/libgstmythtvsrc_la-gmyth_file_transfer.Tpo" -c -o libgstmythtvsrc_la-gmyth_file_transfer.lo `test -f 'gmyth_file_transfer.c' || echo '$(srcdir)/'`gmyth_file_transfer.c; \ +@am__fastdepCC_TRUE@ then mv -f "$(DEPDIR)/libgstmythtvsrc_la-gmyth_file_transfer.Tpo" "$(DEPDIR)/libgstmythtvsrc_la-gmyth_file_transfer.Plo"; else rm -f "$(DEPDIR)/libgstmythtvsrc_la-gmyth_file_transfer.Tpo"; exit 1; fi +@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='gmyth_file_transfer.c' object='libgstmythtvsrc_la-gmyth_file_transfer.lo' libtool=yes @AMDEPBACKSLASH@ @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@ -@am__fastdepCC_FALSE@ $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -c -o libgstmythtvsrc_la-myth_file_transfer.lo `test -f 'myth_file_transfer.c' || echo '$(srcdir)/'`myth_file_transfer.c +@am__fastdepCC_FALSE@ $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -c -o libgstmythtvsrc_la-gmyth_file_transfer.lo `test -f 'gmyth_file_transfer.c' || echo '$(srcdir)/'`gmyth_file_transfer.c -libgstmythtvsrc_la-myth_livetv.lo: myth_livetv.c -@am__fastdepCC_TRUE@ if $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -MT libgstmythtvsrc_la-myth_livetv.lo -MD -MP -MF "$(DEPDIR)/libgstmythtvsrc_la-myth_livetv.Tpo" -c -o libgstmythtvsrc_la-myth_livetv.lo `test -f 'myth_livetv.c' || echo '$(srcdir)/'`myth_livetv.c; \ -@am__fastdepCC_TRUE@ then mv -f "$(DEPDIR)/libgstmythtvsrc_la-myth_livetv.Tpo" "$(DEPDIR)/libgstmythtvsrc_la-myth_livetv.Plo"; else rm -f "$(DEPDIR)/libgstmythtvsrc_la-myth_livetv.Tpo"; exit 1; fi -@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='myth_livetv.c' object='libgstmythtvsrc_la-myth_livetv.lo' libtool=yes @AMDEPBACKSLASH@ +libgstmythtvsrc_la-gmyth_livetv.lo: gmyth_livetv.c +@am__fastdepCC_TRUE@ if $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -MT libgstmythtvsrc_la-gmyth_livetv.lo -MD -MP -MF "$(DEPDIR)/libgstmythtvsrc_la-gmyth_livetv.Tpo" -c -o libgstmythtvsrc_la-gmyth_livetv.lo `test -f 'gmyth_livetv.c' || echo '$(srcdir)/'`gmyth_livetv.c; \ +@am__fastdepCC_TRUE@ then mv -f "$(DEPDIR)/libgstmythtvsrc_la-gmyth_livetv.Tpo" "$(DEPDIR)/libgstmythtvsrc_la-gmyth_livetv.Plo"; else rm -f "$(DEPDIR)/libgstmythtvsrc_la-gmyth_livetv.Tpo"; exit 1; fi +@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='gmyth_livetv.c' object='libgstmythtvsrc_la-gmyth_livetv.lo' libtool=yes @AMDEPBACKSLASH@ @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@ -@am__fastdepCC_FALSE@ $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -c -o libgstmythtvsrc_la-myth_livetv.lo `test -f 'myth_livetv.c' || echo '$(srcdir)/'`myth_livetv.c +@am__fastdepCC_FALSE@ $(LIBTOOL) --tag=CC --mode=compile $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libgstmythtvsrc_la_CFLAGS) $(CFLAGS) -c -o libgstmythtvsrc_la-gmyth_livetv.lo `test -f 'gmyth_livetv.c' || echo '$(srcdir)/'`gmyth_livetv.c mostlyclean-libtool: -rm -f *.lo diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/gmyth_file_transfer.c --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/gst-plugins-mythtv/src/gmyth_file_transfer.c Mon Oct 23 15:42:46 2006 +0100 @@ -0,0 +1,1050 @@ +/* vim: set sw=2: -*- Mode: C; tab-width: 2; indent-tabs-mode: t; c-basic-offset: 2; c-indent-level: 2-*- */ +/** + * GStreamer plug-in properties: + * - location (backend server hostname/URL) [ex.: myth://192.168.1.73:28722/1000_1092091.nuv] + * - path (qurl - remote file to be opened) + * - port number + * @author Rosfran Lins Borges + */ + +#include "gmyth_file_transfer.h" +#include "gmyth_uri.h" +#include "gmyth_livetv.h" +#include +#include +#include + +#include +#include + +#include +#include +#include +#include +#include +#include + +#define GMYTHTV_QUERY_HEADER "QUERY_FILETRANSFER" +#define GMYTHTV_RECORDER_HEADER "QUERY_RECORDER" + +/* default values to the file transfer parameters */ +#define GMYTHTV_USER_READ_AHEAD FALSE +#define GMYTHTV_RETRIES 1 +#define GMYTHTV_FILE_SIZE -1 + +#define GMYTHTV_BUFFER_SIZE 8*1024 + +#define GMYTHTV_VERSION 30 + +#define GMYTHTV_TRANSFER_MAX_WAITS 700 + +#ifdef GMYTHTV_ENABLE_DEBUG +#define GMYTHTV_ENABLE_DEBUG 1 +#else +#undef GMYTHTV_ENABLE_DEBUG +#endif + +/* this NDEBUG is to maintain compatibility with GMyth library */ +#ifndef NDEBUG +#define GMYTHTV_ENABLE_DEBUG 1 +#endif + +static guint wait_to_transfer = 0; + +enum myth_sock_types { + GMYTH_PLAYBACK_TYPE = 0, + GMYTH_MONITOR_TYPE, + GMYTH_FILETRANSFER_TYPE, + GMYTH_RINGBUFFER_TYPE +}; + +static GStaticMutex mutex = G_STATIC_MUTEX_INIT; + +static GMainContext *io_watcher_context = NULL; + +static void gmyth_file_transfer_class_init (GMythFileTransferClass *klass); +static void gmyth_file_transfer_init (GMythFileTransfer *object); + +static void gmyth_file_transfer_dispose (GObject *object); +static void gmyth_file_transfer_finalize (GObject *object); + +static GMythSocket *myth_connect_to_transfer_backend( GMythFileTransfer **transfer, guint sock_type ); +static void* myth_init_io_watchers( void *data ); + +void gmyth_file_transfer_close( GMythFileTransfer *transfer ); + +G_DEFINE_TYPE(GMythFileTransfer, gmyth_file_transfer, G_TYPE_OBJECT) + +#if 0 +static guint64 +mmyth_util_decode_long_long( GMythStringList *strlist, guint offset ) +{ + + guint64 ret_value = 0LL; + + g_return_val_if_fail( strlist != NULL, ret_value ); + + if ( offset < gmyth_string_list_length( strlist )) + g_printerr( "[%s] Offset is lower than the GMythStringList (offset = %d)!\n", __FUNCTION__, offset ); + g_return_val_if_fail( offset < gmyth_string_list_length( strlist ), ret_value ); + + gint l1 = gmyth_string_list_get_int( strlist, offset ); + gint l2 = gmyth_string_list_get_int( strlist, offset + 1 ); + + ret_value = ((guint64)(l2) & 0xffffffffLL) | ((guint64)(l1) << 32); + + return ret_value; + +} +#endif + +static void +gmyth_file_transfer_class_init (GMythFileTransferClass *klass) +{ + GObjectClass *gobject_class; + + gobject_class = (GObjectClass *) klass; + + gobject_class->dispose = gmyth_file_transfer_dispose; + gobject_class->finalize = gmyth_file_transfer_finalize; +} + + static void +gmyth_file_transfer_init (GMythFileTransfer *gmyth_file_transfer) +{ + g_return_if_fail( gmyth_file_transfer != NULL ); + gmyth_file_transfer->mythtv_version = GMYTHTV_VERSION; +} + +static void +gmyth_file_transfer_dispose (GObject *object) +{ + GMythFileTransfer *gmyth_file_transfer = GMYTH_FILE_TRANSFER(object); + + gmyth_file_transfer_close( gmyth_file_transfer ); + + G_OBJECT_CLASS (gmyth_file_transfer_parent_class)->dispose (object); +} + + static void +gmyth_file_transfer_finalize (GObject *object) +{ + g_signal_handlers_destroy (object); + + G_OBJECT_CLASS (gmyth_file_transfer_parent_class)->finalize (object); +} + + GMythFileTransfer* +gmyth_file_transfer_new (gint num, GString *uri_str, gshort port, gint mythtv_version) +{ + GMythFileTransfer *transfer = GMYTH_FILE_TRANSFER ( g_object_new ( + GMYTH_FILE_TRANSFER_TYPE, FALSE )); + + if ( mythtv_version > 0 ) + transfer->mythtv_version = mythtv_version; + + transfer->card_id = num; + + transfer->rec_id = -1; + + transfer->recordernum = num; + transfer->uri = gmyth_uri_new ( uri_str->str ); + + transfer->hostname = g_string_new( gmyth_uri_gethost(transfer->uri) ); + g_print( "\t--> transfer->hostname = %s\n", transfer->hostname->str ); + + if ( port >= 0 ) + transfer->port = port; + else + transfer->port = gmyth_uri_getport( transfer->uri ); + + g_print( "\t--> transfer->port = %d\n", transfer->port ); + + transfer->readposition = 0; + transfer->filesize = GMYTHTV_FILE_SIZE; + transfer->timeoutisfast = FALSE; + + transfer->userreadahead = GMYTHTV_USER_READ_AHEAD; + transfer->retries = GMYTHTV_RETRIES; + + transfer->live_tv = FALSE; + + transfer->query = g_string_new( GMYTHTV_QUERY_HEADER ); + g_string_append_printf ( transfer->query, " %d", transfer->recordernum ); + g_print( "\t--> transfer->query = %s\n", transfer->query->str ); + + transfer->control_sock = NULL; + transfer->event_sock = NULL; + transfer->sock = NULL; + + return transfer; +} + +gboolean +gmyth_file_transfer_livetv_setup( GMythFileTransfer **transfer, GMythSocket *live_socket ) +{ + (*transfer)->sock = live_socket; + g_object_ref( live_socket ); + + return TRUE; +} + +gboolean +gmyth_file_transfer_playback_setup( GMythFileTransfer **transfer, gboolean live_tv ) +{ + + gboolean ret = TRUE; + + (*transfer)->live_tv = live_tv; + + printf("[%s] Running config to the %s...\n", __FUNCTION__, live_tv ? "LiveTV" : "FileTransfer" ); + + /* configure the control socket */ + if ((*transfer)->control_sock == NULL) { + + if ( myth_connect_to_transfer_backend ( transfer, GMYTH_PLAYBACK_TYPE ) == NULL ) { + g_printerr( "Connection to backend failed (Control Socket).\n" ); + ret = FALSE; + } + + } else { + g_warning("Remote transfer control socket already created.\n"); + } + + return ret; + +} + +gboolean +gmyth_file_transfer_setup( GMythFileTransfer **transfer, gboolean live_tv ) +{ + GMythStringList *strlist = NULL; + + gboolean ret = TRUE; + + (*transfer)->live_tv = live_tv; + + printf("[%s] Running config to the %s...\n", __FUNCTION__, live_tv ? "LiveTV" : "FileTransfer" ); + +#if 0 + /* configure the control socket */ + if ((*transfer)->event_sock == NULL) { + + if ( myth_connect_to_transfer_backend ( transfer, GMYTH_MONITOR_TYPE ) == NULL ) { + g_printerr( "Connection to backend failed (Event Socket).\n" ); + ret = FALSE; + } + + } else { + g_warning("Remote transfer control socket already created.\n"); + } +#endif + + /* configure the socket */ + if ( (*transfer)->sock == NULL ) { + + //if ( live_tv == FALSE ) { + + if ( myth_connect_to_transfer_backend ( transfer, GMYTH_FILETRANSFER_TYPE ) == NULL ) { + g_printerr ("Connection to backend failed (Raw Transfer Socket).\n"); + ret = FALSE; + } + + if ( !(*transfer)->live_tv && (*transfer)->control_sock != NULL) { + strlist = gmyth_string_list_new(); + g_string_printf ( (*transfer)->query, "%s %d", GMYTHTV_QUERY_HEADER, (*transfer)->recordernum ); + + gmyth_string_list_append_string( strlist, (*transfer)->query ); + gmyth_string_list_append_char_array( strlist, "IS_OPEN" ); + + gmyth_socket_write_stringlist( (*transfer)->control_sock, strlist ); + gmyth_socket_read_stringlist( (*transfer)->control_sock, strlist ); + + if ( strlist!=NULL && gmyth_string_list_get_int( strlist, 0 ) == 1 ) { + g_print( "[%s] Remote Myth FileTransfer socket is open!\n", __FUNCTION__ ); + } else { + g_print( "[%s] Remote Myth FileTransfer socket is CLOSED! See the MythTV Server Backend for configuration details...\n", __FUNCTION__ ); + ret = FALSE; + } + } + + } else { + g_warning("Remote transfer (raw) socket already created.\n"); + } + + return ret; +} + +static GMythSocket * +myth_connect_to_transfer_backend( GMythFileTransfer **transfer, guint sock_type ) +{ + GMythSocket *sock = NULL; + + g_return_val_if_fail( transfer != NULL && *transfer != NULL, NULL ); + g_return_val_if_fail( (*transfer)->uri != NULL, NULL ); + + g_static_mutex_lock (&mutex); + + gchar *path_dir = gmyth_uri_getpath( (*transfer)->uri ); + //g_print( "\t--> %s: path_dir = %s\n", __FUNCTION__, path_dir ); + + gchar *stype = g_strdup( "" ); + + // if ( (*transfer)->live_tv == FALSE ) { + + sock = gmyth_socket_new(); + + gmyth_socket_connect( &sock, (*transfer)->hostname->str, (*transfer)->port ); + + /* + } else { + sock = (*transfer)->sock; + } + */ +#ifdef GMYTHTV_ENABLE_DEBUG + + g_print( "[%s] --> Creating socket... (%s, %d)\n", __FUNCTION__, (*transfer)->hostname->str, (*transfer)->port ); +#endif + + GMythStringList *strlist = NULL; + + GString *hostname = g_string_new( gmyth_uri_gethost( (*transfer)->uri ) ); + GString *base_str = g_string_new( "" ); + + if ( gmyth_socket_check_protocol_version_number (sock, (*transfer)->mythtv_version) ) { + + if (sock == NULL) { + stype = (sock_type==GMYTH_PLAYBACK_TYPE) ? "control socket" : "file data socket"; + g_printerr( "FileTransfer, open_socket(%s): \n" + "\t\t\tCould not connect to server \"%s\" @ port %d\n", stype, + (*transfer)->hostname->str, (*transfer)->port ); + g_object_unref(sock); + g_static_mutex_unlock (&mutex); + return NULL; + } + + hostname = gmyth_socket_get_local_hostname(); + + g_print( "[%s] local hostname = %s\n", __FUNCTION__, hostname->str ); + + if ( sock_type == GMYTH_PLAYBACK_TYPE ) + { + (*transfer)->control_sock = sock; + g_string_printf( base_str, "ANN Playback %s %d", hostname->str, TRUE ); + + gmyth_socket_send_command( (*transfer)->control_sock, base_str ); + GString *resp = gmyth_socket_receive_response( (*transfer)->control_sock ); + g_print( "[%s] Got Playback response from %s: %s\n", __FUNCTION__, base_str->str, resp->str ); + } + else if ( sock_type == GMYTH_MONITOR_TYPE ) + { + (*transfer)->event_sock = sock; + g_string_printf( base_str, "ANN Monitor %s %d", hostname->str, TRUE ); + + gmyth_socket_send_command( (*transfer)->event_sock, base_str ); + GString *resp = gmyth_socket_receive_response( (*transfer)->event_sock ); + g_print( "[%s] Got Monitor response from %s: %s\n", __FUNCTION__, base_str->str, resp->str ); + //g_thread_create( myth_init_io_watchers, (void*)(*transfer), FALSE, NULL ); + myth_init_io_watchers ( (void*)(*transfer) ); + + g_printerr( "[%s] Watch listener function to the IO control channel on thread %p.\n", __FUNCTION__, g_thread_self() ); + + } + else if ( sock_type == GMYTH_FILETRANSFER_TYPE ) + { + (*transfer)->sock = sock; + strlist = gmyth_string_list_new(); + //g_string_printf( base_str, "ANN FileTransfer %s %d %d", hostname->str, + // transfer->userreadahead, transfer->retries ); + g_string_printf( base_str, "ANN FileTransfer %s", hostname->str ); + + gmyth_string_list_append_string( strlist, base_str ); + gmyth_string_list_append_char_array( strlist, path_dir ); + + gmyth_socket_write_stringlist( (*transfer)->sock, strlist ); + gmyth_socket_read_stringlist( (*transfer)->sock, strlist ); + + /* socket number, where all the stream data comes from - got from the MythTV remote backend */ + (*transfer)->recordernum = gmyth_string_list_get_int( strlist, 1 ); + + /* Myth URI stream file size - decoded using two 8-bytes sequences (64 bits/long long types) */ + (*transfer)->filesize = gmyth_util_decode_long_long( strlist, 2 ); + + printf( "[%s] ***** Received: recordernum = %d, filesize = %" G_GUINT64_FORMAT "\n", __FUNCTION__, + (*transfer)->recordernum, (*transfer)->filesize ); + + if ( (*transfer)->filesize <= 0 ) { + g_print( "[%s] Got filesize equals to %llu is lesser than 0 [invalid stream file]\n", __FUNCTION__, (*transfer)->filesize ); + g_object_unref(sock); + sock = NULL; + } + } + else if ( sock_type == GMYTH_RINGBUFFER_TYPE ) + { + (*transfer)->sock = sock; + //gmyth_file_transfer_spawntv( (*transfer), NULL ); + + strlist = gmyth_string_list_new(); + g_string_printf( base_str, "ANN RingBuffer %s %d", hostname->str, (*transfer)->card_id ); + + gmyth_socket_send_command( (*transfer)->sock, base_str ); + GString *resp = gmyth_socket_receive_response( (*transfer)->sock ); + g_print( "[%s] Got RingBuffer response from %s: %s\n", __FUNCTION__, base_str->str, resp->str ); + + } + + } + + printf("[%s] ANN %s sent: %s\n", (sock_type==GMYTH_PLAYBACK_TYPE) ? "Playback" : (sock_type==GMYTH_FILETRANSFER_TYPE) ? "FileTransfer" : "Monitor", __FUNCTION__, base_str->str); + + if ( strlist != NULL ) + g_object_unref( strlist ); + + g_static_mutex_unlock (&mutex); + + return sock; +} + +void +gmyth_file_transfer_spawntv ( GMythFileTransfer *file_transfer, + GString *tvchain_id ) +{ + GMythStringList *str_list; + + g_debug ("gmyth_file_transfer_spawntv.\n"); + + str_list = gmyth_string_list_new (); + + g_string_printf( file_transfer->query, "%s %d", GMYTHTV_RECORDER_HEADER, + file_transfer->card_id ); + gmyth_string_list_append_string (str_list, file_transfer->query); + gmyth_string_list_append_string (str_list, g_string_new ("SPAWN_LIVETV")); + if (tvchain_id!=NULL) { + gmyth_string_list_append_string (str_list, tvchain_id); + gmyth_string_list_append_int (str_list, FALSE); // PIP = FALSE (0) + } + + gmyth_socket_sendreceive_stringlist ( file_transfer->sock, str_list ); + + //GString *str = NULL; + + //if (str_list!=NULL && (str = gmyth_string_list_get_string( str_list, 0 )) != NULL && strcasecmp( str->str, "ok" ) != 0 ) { + // g_print( "[%s]\t\tSpawnLiveTV is OK!\n", __FUNCTION__ ); + //} + if (str_list!=NULL) + g_object_unref (str_list); + +} + +gboolean +gmyth_file_transfer_is_recording ( GMythFileTransfer *file_transfer ) +{ + gboolean ret = TRUE; + + GMythStringList *str_list = gmyth_string_list_new (); + + g_debug ( "[%s]\n", __FUNCTION__ ); + g_static_mutex_lock (&mutex); + + g_string_printf( file_transfer->query, "%s %d", GMYTHTV_RECORDER_HEADER, + file_transfer->rec_id >= 0 ? file_transfer->rec_id : file_transfer->card_id ); + gmyth_string_list_append_string (str_list, file_transfer->query); + gmyth_string_list_append_string (str_list, g_string_new ("IS_RECORDING")); + + gmyth_socket_sendreceive_stringlist ( file_transfer->control_sock, str_list ); + + if ( str_list != NULL && gmyth_string_list_length(str_list) > 0 ) + { + GString *str = NULL; + if ( ( str = gmyth_string_list_get_string( str_list, 0 ) ) != NULL && strcmp( str->str, "bad" )!= 0 ) { + gint is_rec = gmyth_string_list_get_int( str_list, 0 ); + if ( is_rec != 0 ) + ret = TRUE; + else + ret = FALSE; + } + } + g_print( "[%s] %s, stream is %s being recorded!\n", __FUNCTION__, ret ? "YES" : "NO", ret ? "" : "NOT" ); + g_static_mutex_unlock (&mutex); + + if ( str_list != NULL ) + g_object_unref (str_list); + + return ret; + +} + +gint64 +gmyth_file_transfer_get_file_position ( GMythFileTransfer *file_transfer ) +{ + gint64 pos = 0; + + GMythStringList *str_list = gmyth_string_list_new (); + + g_debug ( "[%s]\n", __FUNCTION__ ); + g_static_mutex_lock (&mutex); + + g_string_printf( file_transfer->query, "%s %d", GMYTHTV_RECORDER_HEADER, + file_transfer->rec_id >= 0 ? file_transfer->rec_id : file_transfer->card_id ); + + gmyth_string_list_append_string (str_list, file_transfer->query); + gmyth_string_list_append_string (str_list, g_string_new ("GET_FILE_POSITION")); + + gmyth_socket_sendreceive_stringlist ( file_transfer->control_sock, str_list ); + + if ( str_list != NULL && gmyth_string_list_length(str_list) > 0 ) + { + GString *str = NULL; + if ( ( str = gmyth_string_list_get_string( str_list, 0 ) ) != NULL && strstr ( str->str, "bad" ) == NULL ) + pos = gmyth_util_decode_long_long( str_list, 0 ); + } + g_static_mutex_unlock (&mutex); + +#ifndef GMYTHTV_ENABLE_DEBUG + + g_print( "[%s] Got file position = %lld\n", __FUNCTION__, pos ); +#endif + if (str_list!=NULL) + g_object_unref (str_list); + + return pos; + +} + + glong +gmyth_file_transfer_get_recordernum( GMythFileTransfer *transfer ) +{ + return transfer->recordernum; +} + + glong +gmyth_file_transfer_get_filesize( GMythFileTransfer *transfer ) +{ + return transfer->filesize; +} + + gboolean +gmyth_file_transfer_isopen( GMythFileTransfer *transfer ) +{ + return (transfer->sock != NULL && transfer->control_sock != NULL); +} + + void +gmyth_file_transfer_close( GMythFileTransfer *transfer ) +{ + GMythStringList *strlist; + + if (transfer->control_sock == NULL) + return; + + strlist = gmyth_string_list_new( ); + + g_string_printf( transfer->query, "%s %d", GMYTHTV_QUERY_HEADER, + transfer->recordernum ); + gmyth_string_list_append_string( strlist, transfer->query ); + gmyth_string_list_append_char_array( strlist, "DONE" ); + + + if ( gmyth_socket_sendreceive_stringlist(transfer->control_sock, strlist) <= 0 ) + { + g_printerr( "Remote file timeout.\n" ); + } + + if (transfer->sock) + { + g_object_unref( transfer->sock ); + transfer->sock = NULL; + } + + if (transfer->control_sock) + { + g_object_unref( transfer->control_sock ); + transfer->control_sock = NULL; + } + +} + + void +gmyth_file_transfer_reset_controlsock( GMythFileTransfer *transfer ) +{ + if (transfer->control_sock == NULL) + { + g_printerr( "gmyth_file_transfer_reset_controlsock(): Called with no control socket" ); + return; + } + + GString *str = gmyth_socket_receive_response( transfer->control_sock ); + + g_string_free( str, TRUE ); +} + +void +gmyth_file_transfer_reset_sock( GMythFileTransfer *transfer ) +{ + if ( transfer->sock == NULL ) + { + g_printerr( "gmyth_file_transfer_reset_sock(): Called with no raw socket" ); + return; + } + + GString *str = gmyth_socket_receive_response( transfer->sock ); + + g_string_free( str, TRUE ); +} + +void +gmyth_file_transfer_reset( GMythFileTransfer *transfer ) +{ + gmyth_file_transfer_reset_controlsock( transfer ); + gmyth_file_transfer_reset_sock( transfer ); +} + +gint64 +gmyth_file_transfer_seek(GMythFileTransfer *transfer, guint64 pos, gint whence) +{ + if (transfer->sock == NULL) + { + g_printerr( "[%s] gmyth_file_transfer_seek(): Called with no socket", __FUNCTION__ ); + return 0; + } + + if (transfer->control_sock == NULL) + return 0; + + // if (!controlSock->isOpen() || controlSock->error()) + // return 0; + + GMythStringList *strlist = gmyth_string_list_new(); + g_string_printf (transfer->query, "%s %d", GMYTHTV_QUERY_HEADER, transfer->recordernum); + gmyth_string_list_append_string( strlist, transfer->query ); + gmyth_string_list_append_char_array( strlist, "SEEK" ); + gmyth_string_list_append_uint64( strlist, pos ); + + gmyth_string_list_append_int( strlist, whence ); + + if (pos > 0 ) + gmyth_string_list_append_uint64( strlist, pos ); + else + gmyth_string_list_append_uint64( strlist, transfer->readposition ); + + gmyth_socket_sendreceive_stringlist( transfer->control_sock, strlist ); + + gint64 retval = gmyth_string_list_get_int64(strlist, 0); + transfer->readposition = retval; + g_print( "[%s] got reading position pointer from the streaming = %lld\n", + __FUNCTION__, retval ); + + //gmyth_file_transfer_reset( transfer ); + + return retval; +} + +static gboolean +myth_control_sock_listener( GIOChannel *source, GIOCondition condition, gpointer data ) +{ + + GIOStatus ret; + GError *err = NULL; + gchar *msg = g_strdup(""); + + g_static_mutex_lock( &mutex ); + + gsize len; + if (condition & G_IO_HUP) + g_error ("Read end of pipe died!\n"); + ret = g_io_channel_read_line ( source, &msg, &len, NULL, &err); + if ( ret == G_IO_STATUS_ERROR ) + g_error ("[%s] Error reading: %s\n", __FUNCTION__, err != NULL ? err->message : "" ); + g_print ("\n\n\n\n\n\n[%s]\t\tEVENT: Read %u bytes: %s\n\n\n\n\n", __FUNCTION__, len, msg != NULL ? msg : "" ); + if ( msg != NULL ) + g_free (msg); + + g_static_mutex_unlock( &mutex ); + + return TRUE; + +} + +static void* +myth_init_io_watchers( void *data ) +{ + GMythFileTransfer *transfer = (GMythFileTransfer*)data; + io_watcher_context = g_main_context_new(); + GMainLoop *loop = g_main_loop_new( NULL, FALSE ); + + GSource *source = NULL; + + if ( transfer->event_sock->sd_io_ch != NULL ) + source = g_io_create_watch( transfer->event_sock->sd_io_ch, G_IO_IN | G_IO_HUP ); + else + goto cleanup; + + g_source_set_callback ( source, (GSourceFunc)myth_control_sock_listener, NULL, NULL ); + + g_source_attach( source, io_watcher_context ); + + if (source==NULL) { + g_printerr( "[%s] Error adding watch listener function to the IO control channel!\n", __FUNCTION__ ); + goto cleanup; + } + + g_print( "[%s]\tOK! Starting listener on the MONITOR event socket...\n", __FUNCTION__ ); + + g_main_loop_run( loop ); + +cleanup: + if ( source != NULL ) + g_source_unref( source ); + + g_main_loop_unref( loop ); + + g_main_context_unref( io_watcher_context ); + + return NULL; +} + + +gint +gmyth_file_transfer_read(GMythFileTransfer *transfer, void *data, gint size, gboolean read_unlimited) +{ + gint recv = 0; + gsize bytes_read = 0; + gint sent = 0; + guint remaining = 0; + gboolean response = FALSE; + + GIOChannel *io_channel; + GIOChannel *io_channel_control; + + GIOCondition io_cond; + GIOCondition io_cond_control; + GIOStatus io_status = G_IO_STATUS_NORMAL, io_status_control = G_IO_STATUS_NORMAL; + + gint buf_len = GMYTHTV_BUFFER_SIZE; + + GMythStringList *strlist = NULL; + GError *error = NULL; + + gchar *trash = g_strdup(""); + + g_return_val_if_fail ( data != NULL, -2 ); + + /* gets the size of the entire file, if the size requested is lesser than 0 */ + if ( size <= 0 ) + size = transfer->filesize; + + io_channel = transfer->sock->sd_io_ch; + io_channel_control = transfer->control_sock->sd_io_ch; + + //g_io_channel_set_flags( io_channel, G_IO_FLAG_APPEND | + // G_IO_STATUS_AGAIN | G_IO_FLAG_IS_READABLE | G_IO_FLAG_IS_WRITEABLE | + // G_IO_FLAG_IS_SEEKABLE, NULL ); + + io_status = g_io_channel_set_encoding( io_channel, NULL, &error ); + if ( io_status == G_IO_STATUS_NORMAL ) + g_print( "[%s] Setting encoding to binary data socket).\n", __FUNCTION__ ); + + io_cond = g_io_channel_get_buffer_condition( io_channel ); + + io_cond_control = g_io_channel_get_buffer_condition( io_channel ); + + if ( transfer->sock == NULL || ( io_status == G_IO_STATUS_ERROR ) ) + { + g_printerr( "gmyth_file_transfer_read(): Called with no raw socket.\n" ); + recv = -1; + goto cleanup; + } + + if ( transfer->control_sock == NULL || ( io_status_control == G_IO_STATUS_ERROR ) ) + { + g_printerr( "gmyth_file_transfer_read(): Called with no control socket.\n" ); + recv = -1; + goto cleanup; + } + + /* + if (!controlSock->isOpen() || controlSock->error()) + return -1; + */ + + if ( ( io_cond & G_IO_IN ) != 0 ) { + do + { + trash = g_new0( gchar, GMYTHTV_BUFFER_SIZE ); + + io_status = g_io_channel_read_chars( io_channel, trash, + GMYTHTV_BUFFER_SIZE, &bytes_read, &error); + + g_print( "[%s] cleaning buffer on IO binary channel... %d bytes gone!\n", + __FUNCTION__, bytes_read ); + + if ( trash != NULL ) + g_free( trash ); + + io_cond = g_io_channel_get_buffer_condition( io_channel ); + + } while ( ( io_cond & G_IO_IN ) != 0 && ( io_status != G_IO_STATUS_ERROR ) && (error == NULL) ); + + //if ( trash!= NULL ) + // g_free( trash ); + } + + if ( ( io_cond_control & G_IO_IN ) != 0 ) { + GMythStringList *strlist_tmp = gmyth_string_list_new(); + gmyth_socket_read_stringlist( transfer->control_sock, strlist_tmp ); + g_object_unref( strlist_tmp ); + } + + wait_to_transfer = 0; + + //while ( transfer->live_tv && ( gmyth_file_transfer_get_file_position( transfer ) < 4096 ) && + // wait_to_transfer++ < GMYTHTV_TRANSFER_MAX_WAITS ) + // g_usleep( 1000*50 ); /* waits just for 2/10 second */ + + //g_thread_create( myth_init_io_watchers, (void*)transfer, FALSE, NULL ); + //g_printerr( "[%s] Watch listener function to the IO control channel on thread %p.\n", __FUNCTION__, g_thread_self() ); + + //g_static_mutex_lock (&mutex); + //strlist = gmyth_string_list_new(); + + g_string_printf ( transfer->query, "%s %d", + /*transfer->live_tv ? GMYTHTV_RECORDER_HEADER :*/ GMYTHTV_QUERY_HEADER, + /* transfer->live_tv ? transfer->card_id :*/ transfer->recordernum ); // transfer->recordernum + g_print( "\t[%s] Transfer_query = %s\n", __FUNCTION__, transfer->query->str ); + + sent = size; + remaining = size - recv; + //g_static_mutex_unlock( &mutex ); + //data = (void*)g_new0( gchar, size ); + + //g_io_channel_flush( io_channel, NULL ); + + //g_static_mutex_lock( &mutex ); + + io_cond = g_io_channel_get_buffer_condition( io_channel ); + + while ( recv < size && !response )//&& ( io_cond & G_IO_IN ) != 0 ) + { + g_io_channel_flush( io_channel_control, NULL ); + + strlist = gmyth_string_list_new(); + gmyth_string_list_append_char_array( strlist, transfer->query->str ); + gmyth_string_list_append_char_array( strlist, + /*transfer->live_tv ? "REQUEST_BLOCK_RINGBUF" :*/ "REQUEST_BLOCK" ); + gmyth_string_list_append_int( strlist, remaining ); + gmyth_socket_write_stringlist( transfer->control_sock, strlist ); + + guint count_bytes = 0; + + do + { + //buf_len = ( sent - recv ) > GMYTHTV_BUFFER_SIZE ? GMYTHTV_BUFFER_SIZE : ( sent - recv ); + if ( remaining > GMYTHTV_BUFFER_SIZE ) { + buf_len = GMYTHTV_BUFFER_SIZE; + } else { + buf_len = remaining; + } + + bytes_read = 0; + + io_status = g_io_channel_read_chars( io_channel, data + recv, + buf_len, &bytes_read, &error ); + + //g_static_mutex_unlock( &mutex ); + /* + GString *sss = g_string_new(""); + sss = g_string_append_len( sss, (gchar*)data+recv, bytes_read ); + + g_print( "[%s] Reading buffer (length = %d)\n", __FUNCTION__, bytes_read); + */ + if ( bytes_read > 0 ) + { + //if ( bytes_read <= buf_len ) + recv += bytes_read; + count_bytes += bytes_read; + remaining -= bytes_read; + g_print( "[%s] Reading buffer (bytes read = %d, remaining = %d)\n", __FUNCTION__, bytes_read, remaining ); + if ( remaining == 0 ) { + break; + } + } else { + break; + } + + //if ( remaining > 0 ) { + + if ( io_status == G_IO_STATUS_EOF ) { + g_print( "[%s] got EOS!", __FUNCTION__ ); + break; + } else if ( io_status == G_IO_STATUS_ERROR ) { + g_print( "[%s] gmyth_file_transfer_read(): socket error.\n", __FUNCTION__ ); + break; + } + //} + + /* increase buffer size, to allow get more data (do not obey to the buffer size) */ + if ( read_unlimited == TRUE ) { + // FOR NOW, DO NOTHING!!! + //if ( recv > buf_len ) + // sent += (bytes_read - buf_len) + 1; + } + + /* verify if the input (read) buffer is ready to receive data */ + io_cond = g_io_channel_get_buffer_condition( io_channel ); + + g_print( "[%s]\t io_cond %s prepared for reading! (G_IO_IN) !!!\n\n", __FUNCTION__, + ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" ); + + //if ( recv == size ) + //break; + + } while ( remaining > 0 );//&& ( io_status == G_IO_STATUS_NORMAL ) ); + + // if ( ( recv < size ) ) { + // finish_read = FALSE; + //} + + io_cond_control = g_io_channel_get_buffer_condition( io_channel_control ); + if ( remaining == 0 )//( io_cond_control & G_IO_IN ) != 0 ) + { + gmyth_socket_read_stringlist( transfer->control_sock, strlist ); + if ( strlist != NULL && gmyth_string_list_length( strlist ) > 0 ) + { + sent = gmyth_string_list_get_int( strlist, 0 ); // -1 on backend error + g_print( "[%s] got SENT buffer message = %d\n", __FUNCTION__, sent ); + if ( sent != 0 ) + { + g_print( "[%s]\t received = %d bytes, backend says %d bytes sent, "\ + "io_cond %s prepared for reading! (G_IO_IN) !!!\n\n", __FUNCTION__, + recv, sent, ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" ); + + if ( sent == count_bytes ) + { + response = ( recv == size ); + g_print( "[%s]\t\tsent %d, which is equals to bytes_read = %d\n\n", + __FUNCTION__, sent, count_bytes ); + if ( response == TRUE ) + break; + } + else + { + g_print( "[%s]\t\tsent %d, which is NOT equals to bytes_read = %d\n\n", + __FUNCTION__, sent, count_bytes ); + goto cleanup; + //response = FALSE; + //break; + } + } else { + break; + //goto cleanup; + } // if + } // if - reading control response from backend + } else { + response = FALSE; + } // if - stringlist response + + } // while + + io_cond_control = g_io_channel_get_buffer_condition( io_channel_control ); + // io_cond = g_io_channel_get_buffer_condition( io_channel ); + + if ( ( ( io_cond_control & G_IO_IN ) != 0 ) && + ( response || ( recv == size ) ) ) + { + if ( gmyth_socket_read_stringlist( transfer->control_sock, strlist ) > 0 ) + { + if ( strlist != NULL && gmyth_string_list_length(strlist) > 0 ) + { + sent = gmyth_string_list_get_int( strlist, 0 ); // -1 on backend error + g_print( "[%s]\t received = %d bytes -\tNOW returning from reading buffer I/O socket "\ + "[%s prepared for reading]! (G_IO_IN) !!!\n\n", __FUNCTION__, + sent, ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" ); + } + } + else + { + g_printerr ( "gmyth_file_transfer_read(): No response from control socket."); + recv = -1; + } + + } + else if ( error != NULL ) + { + g_printerr( "[%s] Error occurred: (%d, %s)\n", __FUNCTION__, error->code, error->message ); + } + +cleanup: + //g_static_mutex_unlock (&mutex); + + if ( trash != NULL ) + g_free( trash ); + + if ( strlist != NULL ) + g_object_unref( strlist ); + + g_print( "gmyth_file_transfer_read(): reqd=%d, rcvd=%d, rept=%d, "\ + "(rcvd and rept MUST be the same!)\n", size, + recv, sent ); + + //if ( ( recv != size ) || ( sent != size ) ) { + //recv = size; + //} + + if ( error != NULL ) { + g_printerr( "Cleaning-up ERROR: %s [msg = %s, code = %d]\n", __FUNCTION__, error->message, + error->code ); + g_error_free( error ); + } + + return recv; +} + +void +gmyth_file_transfer_settimeout( GMythFileTransfer *transfer, gboolean fast ) +{ + + GMythStringList *strlist = NULL; + + if ( transfer->timeoutisfast == fast ) + return; + + if ( transfer->sock == NULL ) + { + g_printerr( "gmyth_file_transfer_settimeout(): Called with no socket" ); + return; + } + + if ( transfer->control_sock == NULL ) + return; + + strlist = gmyth_string_list_new(); + gmyth_string_list_append_string( strlist, transfer->query ); + gmyth_string_list_append_char_array( strlist, "SET_TIMEOUT" ); + gmyth_string_list_append_int( strlist, fast ); + + gmyth_socket_write_stringlist( transfer->control_sock, strlist ); + gmyth_socket_read_stringlist( transfer->control_sock, strlist ); + + transfer->timeoutisfast = fast; + +} + +#ifdef DO_TESTING + + int +main( int argc, char *argv[] ) +{ + g_type_init(); + + GMythFileTransfer *file_transfer = gmyth_file_transfer_new( 1, + g_string_new("myth://192.168.1.109:6543/jshks.nuv"), -1, GMYTHTV_VERSION ); + gmyth_file_transfer_setup( &file_transfer ); + gchar *data = g_strdup(""); + + gint num = gmyth_file_transfer_read( file_transfer, data, -1 ); + + return 0; + +} + +#endif diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/gmyth_file_transfer.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/gst-plugins-mythtv/src/gmyth_file_transfer.h Mon Oct 23 15:42:46 2006 +0100 @@ -0,0 +1,93 @@ +/* vim: set sw=2: -*- Mode: C; tab-width: 2; indent-tabs-mode: t; c-basic-offset: 2; c-indent-level: 2-*- */ + +#ifndef __GMYTH_FILE_TRANSFER_H__ +#define __GMYTH_FILE_TRANSFER_H__ + +#include + +#include +#include "gmyth_uri.h" +#include "gmyth_livetv.h" + +#include +#include +#include +#include +#include +#include + +#define G_BEGIN_DECLS + +#define GMYTH_FILE_TRANSFER_TYPE (gmyth_file_transfer_get_type ()) +#define GMYTH_FILE_TRANSFER(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), GMYTH_FILE_TRANSFER_TYPE, GMythFileTransfer)) +#define GMYTH_FILE_TRANSFER_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), GMYTH_FILE_TRANSFER_TYPE, GMythFileTransferClass)) +#define IS_GMYTH_FILE_TRANSFER(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), GMYTH_FILE_TRANSFER_TYPE)) +#define IS_GMYTH_FILE_TRANSFER_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), GMYTH_FILE_TRANSFER_TYPE)) +#define GMYTH_FILE_TRANSFER_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), GMYTH_FILE_TRANSFER_TYPE, GMythFileTransferClass)) + + +typedef struct _GMythFileTransfer GMythFileTransfer; +typedef struct _GMythFileTransferClass GMythFileTransferClass; + +struct _GMythFileTransferClass +{ + GObjectClass parent_class; + + /* callbacks */ + /* no one for now */ +}; + +struct _GMythFileTransfer +{ + GObject parent; + + /* Myth URI structure */ + const GMythURI *uri; + + /* MythTV version number */ + gint mythtv_version; + + /* socket descriptors */ + GMythSocket *control_sock; + GMythSocket *event_sock; + GMythSocket *sock; + + guint64 readposition; + guint64 filesize; + gboolean timeoutisfast; + gboolean userreadahead; + gboolean live_tv; + gint retries; + + GString *query; + + gint rec_id; + gint recordernum; + gint card_id; + GString *hostname; + gint port; +}; + +GType gmyth_file_transfer_get_type (void); + +GMythFileTransfer* gmyth_file_transfer_new (gint num, GString *hostname, gshort port, gint mythtv_version ); + +gint gmyth_file_transfer_read(GMythFileTransfer *transfer, void *data, gint size, gboolean read_unlimited); + +gint64 gmyth_file_transfer_seek(GMythFileTransfer *transfer, guint64 pos, gint whence); + +gboolean gmyth_file_transfer_playback_setup( GMythFileTransfer **transfer, gboolean live_tv ); + +gboolean gmyth_file_transfer_setup( GMythFileTransfer **transfer, gboolean live_tv ); + +gboolean gmyth_file_transfer_livetv_setup( GMythFileTransfer **transfer, GMythSocket *live_sock ); + +void gmyth_file_transfer_spawntv ( GMythFileTransfer *file_transfer, GString *tvchain_id ); + +gboolean gmyth_file_transfer_is_recording( GMythFileTransfer *file_transfer ); + +gint64 gmyth_file_transfer_get_file_position( GMythFileTransfer *file_transfer ); + +#define G_END_DECLS + +#endif /* __GMYTH_FILE_TRANSFER_H__ */ diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/gmyth_livetv.c --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/gst-plugins-mythtv/src/gmyth_livetv.c Mon Oct 23 15:42:46 2006 +0100 @@ -0,0 +1,220 @@ + +#include +#include +#include + +#include "gmyth_livetv.h" +#include "gmyth_file_transfer.h" + +static void gmyth_livetv_class_init (GMythLiveTVClass *klass); +static void gmyth_livetv_init (GMythLiveTV *object); + +static void gmyth_livetv_dispose (GObject *object); +static void gmyth_livetv_finalize (GObject *object); + +static gint tvchain_curr_index = -1; + +G_DEFINE_TYPE(GMythLiveTV, gmyth_livetv, G_TYPE_OBJECT) + +static void +gmyth_livetv_class_init (GMythLiveTVClass *klass) +{ + GObjectClass *gobject_class; + + gobject_class = (GObjectClass *) klass; + + gobject_class->dispose = gmyth_livetv_dispose; + gobject_class->finalize = gmyth_livetv_finalize; +} + +static void +gmyth_livetv_init (GMythLiveTV *livetv) +{ + livetv->backend_hostname = NULL; + livetv->backend_port = 0; + livetv->local_hostname = NULL; + + livetv->remote_encoder = NULL; + livetv->tvchain = NULL; + livetv->proginfo = NULL; +} + +static void +gmyth_livetv_dispose (GObject *object) +{ + + G_OBJECT_CLASS (gmyth_livetv_parent_class)->dispose (object); +} + +static void +gmyth_livetv_finalize (GObject *object) +{ + g_signal_handlers_destroy (object); + + GMythLiveTV *livetv = GMYTH_LIVETV (object); + + g_debug ("[%s] Finalizing livetv", __FUNCTION__); + + if ( livetv->remote_encoder != NULL ) { + g_object_unref (livetv->remote_encoder); + livetv->remote_encoder = NULL; + } + + if ( livetv->tvchain != NULL ) { + g_object_unref (livetv->tvchain); + livetv->tvchain = NULL; + } + + if ( livetv->proginfo != NULL ) { + g_object_unref (livetv->proginfo); + livetv->proginfo = NULL; + } + + G_OBJECT_CLASS ( gmyth_livetv_parent_class )->finalize ( object ); +} + +GMythLiveTV* +gmyth_livetv_new () +{ + GMythLiveTV *livetv = GMYTH_LIVETV ( g_object_new( GMYTH_LIVETV_TYPE, NULL ) ); + + return livetv; +} + +gboolean +gmyth_livetv_setup ( GMythLiveTV *livetv ) +{ + GMythSettings *msettings = gmyth_context_get_settings (); + gboolean res = TRUE; + + livetv->is_livetv = TRUE; + + res = gmyth_context_check_connection(); + if (!res) { + g_warning ("[%s] LiveTV can not connect to backend", __FUNCTION__); + res = FALSE; + goto error; + } + + livetv->backend_hostname = gmyth_settings_get_backend_hostname(msettings); + livetv->backend_port = gmyth_settings_get_backend_port (msettings); + + livetv->local_hostname = g_string_new(""); + gmyth_context_get_local_hostname (livetv->local_hostname); + + if ( livetv->local_hostname == NULL ) { + res = FALSE; + goto error; + } + + // Gets the remote encoder num + livetv->remote_encoder = remote_request_next_free_recorder (-1); + + if ( livetv->remote_encoder == NULL ) { + g_warning ("[%s] None remote encoder available", __FUNCTION__); + res = FALSE; + goto error; + } + + // Creates livetv chain handler + livetv->tvchain = GMYTH_TVCHAIN ( g_object_new(GMYTH_TVCHAIN_TYPE, NULL) ); + gmyth_tvchain_initialize ( livetv->tvchain, livetv->local_hostname ); + + if ( livetv->tvchain == NULL || livetv->tvchain->tvchain_id == NULL ) { + res = FALSE; + goto error; + } + + // Init remote encoder. Opens its control socket. + res = gmyth_remote_encoder_setup(livetv->remote_encoder); + if ( !res ) { + g_warning ("[%s] Fail while setting remote encoder\n", __FUNCTION__); + res = FALSE; + goto error; + } + // Spawn live tv. Uses the socket to send mythprotocol data to start livetv in the backend (remotelly) + res = gmyth_remote_encoder_spawntv ( livetv->remote_encoder, + gmyth_tvchain_get_id(livetv->tvchain) ); + if (!res) { + g_warning ("[%s] Fail while spawn tv\n", __FUNCTION__); + res = FALSE; + goto error; + } + + // Reload all TV chain from Mysql database. + gmyth_tvchain_reload_all (livetv->tvchain); + + if ( livetv->tvchain == NULL ) { + res = FALSE; + goto error; + } + + // Get program info from database using chanid and starttime + livetv->proginfo = gmyth_tvchain_get_program_at (livetv->tvchain, tvchain_curr_index++ ); + if ( livetv->proginfo == NULL ) { + g_warning ("[%s] LiveTV not successfully started.\n", __FUNCTION__ ); + res = FALSE; + goto error; + } else { + g_debug ("[%s] GMythLiveTV: All requests to backend to start TV were OK.\n", __FUNCTION__ ); + } + + return res; + +error: + if ( livetv->backend_hostname != NULL ) { + g_string_free( livetv->backend_hostname, TRUE ); + res = FALSE; + } + + if ( livetv->local_hostname != NULL ) { + g_string_free( livetv->local_hostname, TRUE ); + res = FALSE; + } + + if ( livetv->remote_encoder != NULL ) { + g_object_unref (livetv->remote_encoder); + livetv->remote_encoder = NULL; + } + + if ( livetv->tvchain != NULL ) { + g_object_unref (livetv->tvchain); + livetv->tvchain = NULL; + } + + if ( livetv->proginfo != NULL ) { + g_object_unref (livetv->proginfo); + livetv->proginfo = NULL; + } + + return res; + +} + +// FIXME: How to proceed differently between livetv and recorded content +void +gmyth_livetv_stop_playing (GMythLiveTV *livetv) +{ + g_debug ("[%s] Stopping the LiveTV...\n", __FUNCTION__); + + if (livetv->is_livetv) { + if (!gmyth_remote_encoder_stop_livetv (livetv->remote_encoder)) { + g_warning ("[%s] Error while stoping remote encoder", __FUNCTION__); + } + } +} + +gboolean +gmyth_livetv_is_playing (GMythLiveTV *livetv) +{ + return TRUE; +} + +void +gmyth_livetv_start_playing (GMythLiveTV *livetv) +{ + + // TODO + +} + diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/gmyth_livetv.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/gst-plugins-mythtv/src/gmyth_livetv.h Mon Oct 23 15:42:46 2006 +0100 @@ -0,0 +1,59 @@ +#ifndef GMYTH_LIVETV_H_ +#define GMYTH_LIVETV_H_ + +#include + +#include +#include +#include + +#include "gmyth_file_transfer.h" + +#define G_BEGIN_DECLS + +#define GMYTH_LIVETV_TYPE (gmyth_livetv_get_type ()) +#define GMYTH_LIVETV(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), GMYTH_LIVETV_TYPE, GMythLiveTV)) +#define GMYTH_LIVETV_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), GMYTH_LIVETV_TYPE, GMythLiveTVClass)) +#define IS_GMYTH_LIVETV(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), GMYTH_LIVETV_TYPE)) +#define IS_GMYTH_LIVETV_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), GMYTH_LIVETV_TYPE)) +#define GMYTH_LIVETV_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), GMYTH_LIVETV_TYPE, GMythLiveTVClass)) + +typedef struct _GMythLiveTV GMythLiveTV; +typedef struct _GMythLiveTVClass GMythLiveTVClass; + +struct _GMythLiveTVClass +{ + GObjectClass parent_class; + + /* callbacks */ +}; + +struct _GMythLiveTV +{ + GObject parent; + + // Backend connection related variables + GString *backend_hostname; + gint backend_port; + GString *local_hostname; + + GMythRemoteEncoder *remote_encoder; + GMythTVChain *tvchain; + GMythProgramInfo *proginfo; + + gboolean is_livetv; + +}; + +GType gmyth_livetv_get_type (void); + +GMythLiveTV* gmyth_livetv_new (); + +void gmyth_livetv_start_playing (GMythLiveTV *livetv); +void gmyth_livetv_stop_playing (GMythLiveTV *livetv); + +gboolean gmyth_livetv_setup (GMythLiveTV *livetv); + +#define G_END_DECLS + +#endif /*GMYTH_LIVETV_H_*/ diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/gmyth_uri.c --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/gst-plugins-mythtv/src/gmyth_uri.c Mon Oct 23 15:42:46 2006 +0100 @@ -0,0 +1,208 @@ +/** + * + * GMythURI utils + * - Extracts and parses a URI char string, in according with the RFC 2396 + * [http://www.ietf.org/rfc/rfc2396.txt] + * + * @author Rosfran Borges (rosfran.borges@indt.org.br) + * + */ + +#include "gmyth_uri.h" +#include +#include +#include + +static gint +gmyth_strstr( const gchar *haystack, const gchar *needle ) +{ + + gchar *strPos; + + if (haystack == NULL || needle == NULL) + return -1; + strPos = strstr(haystack, needle); + if (strPos == NULL) + return -1; + + return (strPos - haystack); + +} + +static gboolean +gmyth_uri_isabsolute( const GMythURI *uri ) +{ + gboolean ret = FALSE; + + g_return_val_if_fail( uri != NULL && uri->uri != NULL && uri->protocol != NULL, FALSE ); + + if ( gmyth_strstr( uri->uri->str, GMYTH_URI_PROTOCOL_DELIM ) == 0 || strlen(uri->protocol->str) > 0 ) + ret = TRUE; + + return ret; +} + +static gint +gmyth_strrchr( const gchar *str, const gchar *chars, const gint nchars ) +{ + + gint strLen; + gint i, j; + + if ( str == NULL || chars == NULL ) + return -1; + + strLen = strlen( str ); + for ( i= (strLen-1); 0 <= i; i-- ) { + for ( j=0; jhost = g_string_new(""); + uri->fragment = g_string_new(""); + uri->password = g_string_new(""); + uri->path = g_string_new(""); + uri->protocol = g_string_new(""); + uri->query = g_string_new(""); + uri->uri = g_string_new(""); + uri->user = g_string_new(""); + return uri; +} + +const GMythURI * +gmyth_uri_new( gchar *value ) +{ + + GMythURI *uri = gmyth_uri_init(); + + gchar *protocol; + gint uriLen; + gint currIdx; + gint protoIdx; + gint atIdx; + gint colonIdx; + gint shashIdx; + gchar *host; + gint eblacketIdx; + GString *hostStr; + GString *portStr; + gint hostLen; + gint sharpIdx; + gint questionIdx; + gint queryLen; + + uriLen = strlen(value); + uri->uri = g_string_new( value ); + + currIdx = 0; + + /*** Protocol ****/ + protoIdx = gmyth_strstr( value, GMYTH_URI_PROTOCOL_DELIM ); + if (0 < protoIdx) { + uri->protocol = g_string_append_len( uri->protocol, value, protoIdx ); + currIdx += protoIdx + strlen( GMYTH_URI_PROTOCOL_DELIM ); + } + + /*** User (Password) ****/ + atIdx = gmyth_strstr( value+currIdx, GMYTH_URI_USER_DELIM ); + if ( 0 < atIdx ) { + colonIdx = gmyth_strstr( value+currIdx, GMYTH_URI_COLON_DELIM ); + + if (0 < colonIdx && colonIdx < atIdx) { + uri->user = g_string_append_len( uri->user, value+currIdx, colonIdx ); + uri->password = g_string_append_len( uri->password, value+currIdx+colonIdx+1, atIdx-(colonIdx+1) ); + } + else + uri->user = g_string_append_len( uri->user, value+currIdx, atIdx - currIdx ); + currIdx += atIdx + 1; + } + + /*** Host (Port) ****/ + shashIdx = gmyth_strstr( value+currIdx, GMYTH_URI_SLASH_DELIM ); + if ( 0 < shashIdx ) + uri->host = g_string_append_len( uri->host, value+currIdx, shashIdx ); + else if ( gmyth_uri_isabsolute(uri) == TRUE ) + uri->host = g_string_append_len( uri->host, value+currIdx, strlen(value) - currIdx ); + host = g_strdup( gmyth_uri_gethost(uri) ); + colonIdx = gmyth_strrchr( host, GMYTH_URI_COLON_DELIM, 1 ); + eblacketIdx = gmyth_strrchr( host, GMYTH_URI_EBLACET_DELIM, 1 ); + if ( ( 0 < colonIdx ) && ( eblacketIdx < colonIdx ) ) { + hostStr = g_string_new( host ); + + hostLen = hostStr->len; + /**** host ****/ + uri->host = g_string_erase( uri->host, 0, hostLen ); + uri->host = g_string_insert_len( uri->host, 0, hostStr->str, colonIdx ); + //host = gmyth_uri_gethost( uri ); + if (0 < hostLen) { + if (host[0] == '[' && host[hostLen-1] == ']') + uri->host = g_string_append_len( uri->host, hostStr->str+1, colonIdx-2 ); + } + /**** port ****/ + portStr = g_string_new(""); + portStr = g_string_append_len( portStr, hostStr->str+colonIdx+1, hostLen-colonIdx-1 ); + uri->port = atoi( portStr->str ); + g_string_free( portStr, TRUE ); + g_string_free( hostStr, FALSE ); + } + else { + uri->port = GMYTH_URI_KNKOWN_PORT; + protocol = gmyth_uri_getprotocol(uri); + if ( strcmp(protocol, GMYTH_URI_PROTOCOL_HTTP) == 0 ) + uri->port = GMYTH_URI_DEFAULT_HTTP_PORT; + if ( strcmp(protocol, GMYTH_URI_PROTOCOL_FTP) == 0 ) + uri->port = GMYTH_URI_DEFAULT_FTP_PORT; + } + + if (shashIdx > 0) currIdx += shashIdx; + + /* + Handle relative URL + */ + if (gmyth_uri_isabsolute(uri) == FALSE) + { + + if (shashIdx != 0) + { + /* Add slash delimiter at the beginning of the URL, + if it doesn't exist + */ + uri->path = g_string_new( GMYTH_URI_SLASH_DELIM ); + } + uri->path = g_string_append( uri->path, value ); + + } else { + /* First set path simply to the rest of URI */ + g_string_append_len( uri->path, value+currIdx, uriLen-currIdx ); + } + + /**** Path (Query/Fragment) ****/ + sharpIdx = gmyth_strstr(value+currIdx, GMYTH_URI_SHARP_DELIM); + if (0 < sharpIdx) { + uri->path = g_string_append_len( uri->path, value+currIdx, sharpIdx); + uri->fragment = g_string_append_len( uri->fragment, + value+currIdx+sharpIdx+1, uriLen-(currIdx+sharpIdx+1)); + } + + questionIdx = gmyth_strstr( value+currIdx, GMYTH_URI_QUESTION_DELIM ); + if ( 0 < questionIdx ) { + uri->path = g_string_append_len( uri->path, value+currIdx, questionIdx ); + queryLen = uriLen-(currIdx+questionIdx+1); + if ( 0 < sharpIdx ) + queryLen -= uriLen - (currIdx+sharpIdx+1); + uri->query = g_string_append_len( uri->query, value+currIdx+questionIdx+1, queryLen ); + } + + return uri; + +} diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/gmyth_uri.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/gst-plugins-mythtv/src/gmyth_uri.h Mon Oct 23 15:42:46 2006 +0100 @@ -0,0 +1,63 @@ +/** + * + * GMythURI utils + * - Extracts and parses a URI char string, in according with the RFC 2396 + * [http://www.ietf.org/rfc/rfc2396.txt] + * + * @author Rosfran Borges (rosfran.borges@indt.org.br) + * + */ + +#ifndef _GMYTH_URI_H_ +#define _GMYTH_URI_H_ + +#include + +/**************************************** +* Define +****************************************/ + +#define GMYTH_URI_KNKOWN_PORT (-1) +#define GMYTH_URI_DEFAULT_HTTP_PORT 80 +#define GMYTH_URI_DEFAULT_FTP_PORT 21 +#define GMYTH_URI_DEFAULT_PATH "/" +#define GMYTH_URI_MAXLEN 256 + +#define GMYTH_URI_PROTOCOL_DELIM "://" +#define GMYTH_URI_USER_DELIM "@" +#define GMYTH_URI_COLON_DELIM ":" +#define GMYTH_URI_SLASH_DELIM "/" +#define GMYTH_URI_SBLACET_DELIM "[" +#define GMYTH_URI_EBLACET_DELIM "]" +#define GMYTH_URI_SHARP_DELIM "#" +#define GMYTH_URI_QUESTION_DELIM "?" +#define GMYTH_URI_ESCAPING_CHAR "%" + +#define GMYTH_URI_PROTOCOL_MYTH "myth" +#define GMYTH_URI_PROTOCOL_HTTP "http" +#define GMYTH_URI_PROTOCOL_FTP "ftp" + +/**************************************** +* Data Type +****************************************/ + +typedef struct _GMythURI { + GString *uri; + GString *host; + gint port; + GString *protocol; + GString *path; + GString *fragment; + GString *user; + GString *password; + GString *query; +} GMythURI; + +const GMythURI *gmyth_uri_new( gchar *value ); + +#define gmyth_uri_gethost(urip) (urip->host->str) +#define gmyth_uri_getport(urip) (urip->port) +#define gmyth_uri_getprotocol(urip) (urip->protocol->str) +#define gmyth_uri_getpath(urip) (urip->path->str) + +#endif diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/gstmythtvsrc.c --- a/gst-plugins-mythtv/src/gstmythtvsrc.c Mon Oct 23 14:43:18 2006 +0100 +++ b/gst-plugins-mythtv/src/gstmythtvsrc.c Mon Oct 23 15:42:46 2006 +0100 @@ -18,8 +18,8 @@ #endif #include "gstmythtvsrc.h" -#include "myth_file_transfer.h" -#include "myth_livetv.h" +#include "gmyth_file_transfer.h" +#include "gmyth_livetv.h" #include #include @@ -30,13 +30,13 @@ GST_DEBUG_CATEGORY_STATIC (mythtvsrc_debug); #define GST_CAT_DEFAULT mythtvsrc_debug -#define GST_MYTHTV_ID_NUM 1 +#define GST_GMYTHTV_ID_NUM 1 -#define MYTHTV_VERSION_DEFAULT 30 +#define GMYTHTV_VERSION_DEFAULT 30 -#define MYTHTV_TRANSFER_MAX_WAITS 100 +#define GMYTHTV_TRANSFER_MAX_WAITS 100 -#define MYTHTV_TRANSFER_MAX_BUFFER 1024*1024 +#define GMYTHTV_TRANSFER_MAX_BUFFER 1024*1024 //( 32*1024 ) /* 4*1024 ??? */ @@ -70,12 +70,12 @@ PROP_LOCATION, PROP_URI, #ifndef GST_DISABLE_GST_DEBUG - PROP_MYTHTV_DBG, + PROP_GMYTHTV_DBG, #endif - PROP_MYTHTV_VERSION, - PROP_MYTHTV_LIVE, - PROP_MYTHTV_LIVEID, - PROP_MYTHTV_LIVE_CHAINID + PROP_GMYTHTV_VERSION, + PROP_GMYTHTV_LIVE, + PROP_GMYTHTV_LIVEID, + PROP_GMYTHTV_LIVE_CHAINID }; static void gst_mythtv_src_finalize (GObject * gobject); @@ -168,32 +168,32 @@ "", G_PARAM_READWRITE)); g_object_class_install_property - (gobject_class, PROP_MYTHTV_VERSION, + (gobject_class, PROP_GMYTHTV_VERSION, g_param_spec_int ("mythtv-version", "mythtv-version", "Change Myth TV version", 26, 30, 26, G_PARAM_READWRITE)); g_object_class_install_property - (gobject_class, PROP_MYTHTV_LIVEID, + (gobject_class, PROP_GMYTHTV_LIVEID, g_param_spec_int ("mythtv-live-id", "mythtv-live-id", "Change Myth TV version", - 0, 200, GST_MYTHTV_ID_NUM, G_PARAM_READWRITE)); + 0, 200, GST_GMYTHTV_ID_NUM, G_PARAM_READWRITE)); g_object_class_install_property - (gobject_class, PROP_MYTHTV_LIVE_CHAINID, + (gobject_class, PROP_GMYTHTV_LIVE_CHAINID, g_param_spec_string ("mythtv-live-chainid", "mythtv-live-chainid", "Sets the Myth TV chain ID (from TV Chain)", "", G_PARAM_READWRITE)); g_object_class_install_property - (gobject_class, PROP_MYTHTV_LIVE, + (gobject_class, PROP_GMYTHTV_LIVE, g_param_spec_boolean ("mythtv-live", "mythtv-live", "Enable MythTV Live TV content streaming", FALSE, G_PARAM_READWRITE)); #ifndef GST_DISABLE_GST_DEBUG g_object_class_install_property - (gobject_class, PROP_MYTHTV_DBG, + (gobject_class, PROP_GMYTHTV_DBG, g_param_spec_boolean ("mythtv-debug", "mythtv-debug", "Enable MythTV debug messages", FALSE, G_PARAM_READWRITE)); @@ -218,7 +218,7 @@ this->unique_setup = FALSE; - this->mythtv_version = MYTHTV_VERSION_DEFAULT; + this->mythtv_version = GMYTHTV_VERSION_DEFAULT; this->bytes_read = 0; @@ -293,7 +293,7 @@ while ( sizetoread > 0 ) { - len = myth_file_transfer_read( src->file_transfer, + len = gmyth_file_transfer_read( src->file_transfer, GST_BUFFER_DATA( *outbuf ) + read, sizetoread, TRUE ); if ( len > 0 ) { @@ -305,25 +305,29 @@ goto done; } else if ( /*src->content_size >= src->read_offset && abs ( src->content_size - src->read_offset ) <= 1024 ) ||*/ - ( src->content_size <= ( src->read_offset + size + MYTHTV_TRANSFER_MAX_BUFFER ) ) ) + ( src->content_size <= ( src->read_offset + size + GMYTHTV_TRANSFER_MAX_BUFFER ) ) ) { #if ENABLE_TIMING_POSITION == 1 - guint64 size_tmp = 0; + gint64 size_tmp = 0; if (src->live_tv == TRUE) { get_file_pos: - size_tmp = myth_file_transfer_get_file_position( src->file_transfer ); - if ( size_tmp > ( src->content_size + MYTHTV_TRANSFER_MAX_BUFFER ) ) + size_tmp = gmyth_file_transfer_get_file_position( src->file_transfer ); + if ( size_tmp > ( src->content_size + GMYTHTV_TRANSFER_MAX_BUFFER ) ) src->content_size = size_tmp; - else + else if ( size_tmp > 0 ) goto get_file_pos; - g_print( "\t[%s]\tGET_POSITION: file_position = %llu\n", + g_print( "\t[%s]\tGET_POSITION: file_position = %lld\n", __FUNCTION__, size_tmp ); } #else - guint64 new_offset = myth_file_transfer_get_file_position( src->file_transfer ); - if ( src->content_size < new_offset ) { - src->content_size = new_offset; - } + gint64 new_offset = gmyth_file_transfer_get_file_position( src->file_transfer ); + if ( new_offset > 0 ) { + if ( src->content_size < new_offset ) { + src->content_size = new_offset; + } + } else { + src->update_prog_chain = TRUE; + } #endif goto done; } @@ -377,17 +381,19 @@ /* The caller should know the number of bytes and not read beyond EOS. */ if (G_UNLIKELY (src->eos)) goto eos; + if ( G_UNLIKELY (src->update_prog_chain) ) + goto change_progchain; //GST_OBJECT_LOCK(src); if (G_UNLIKELY (src->read_offset != offset)) { - guint64 new_offset = myth_file_transfer_seek(src->file_transfer, offset, SEEK_SET); - g_print( "[%s] SRC Offset = %llu, NEW actual backend SEEK Offset = %llu.\n", + gint64 new_offset = gmyth_file_transfer_seek(src->file_transfer, offset, SEEK_SET); + g_print( "[%s] SRC Offset = %lld, NEW actual backend SEEK Offset = %lld.\n", __FUNCTION__, src->read_offset, new_offset ); if (G_UNLIKELY (new_offset < 0 ) )//|| new_offset != src->read_offset)) { { //GST_OBJECT_UNLOCK(src); - goto seek_failed; + goto change_progchain; } src->read_offset = offset; @@ -407,6 +413,9 @@ read = do_read_request_response ( src, src->read_offset, size, outbuf ); //g_static_mutex_unlock( &update_size_mutex ); + if (G_UNLIKELY (src->update_prog_chain) ) + goto change_progchain; + if (G_UNLIKELY (read < 0) || *outbuf == NULL) { //if ( src->live_tv ) // goto done; @@ -443,7 +452,7 @@ src->uri_name)); return GST_FLOW_ERROR; } -seek_failed: +change_progchain: { GST_ELEMENT_ERROR (src, RESOURCE, READ, (NULL), ("Seek failed, go to the next program info... (%i, %s)", read, @@ -470,16 +479,16 @@ if ( src->do_start ) { #if ENABLE_TIMING_POSITION == 1 - guint64 size_tmp = 0; + gint64 size_tmp = 0; if (src->live_tv == TRUE) { get_file_pos: g_usleep( 50 ); - size_tmp = myth_file_transfer_get_file_position( src->file_transfer ); - if ( size_tmp > ( src->content_size + MYTHTV_TRANSFER_MAX_BUFFER ) ) + size_tmp = gmyth_file_transfer_get_file_position( src->file_transfer ); + if ( size_tmp > ( src->content_size + GMYTHTV_TRANSFER_MAX_BUFFER ) ) src->content_size = size_tmp; - else + else if ( size_tmp > 0 ) goto get_file_pos; - g_print( "\t[%s]\tGET_POSITION: file_position = %llu\n", + g_print( "\t[%s]\tGET_POSITION: file_position = %lld\n", __FUNCTION__, size_tmp ); } #endif @@ -494,16 +503,16 @@ if ( src->do_start ) { #if ENABLE_TIMING_POSITION == 1 - guint64 size_tmp = 0; + gint64 size_tmp = 0; if (src->live_tv == TRUE) { get_file_pos: g_usleep( 50 ); - size_tmp = myth_file_transfer_get_file_position( src->file_transfer ); - if ( size_tmp > ( src->content_size + MYTHTV_TRANSFER_MAX_BUFFER ) ) + size_tmp = gmyth_file_transfer_get_file_position( src->file_transfer ); + if ( size_tmp > ( src->content_size + GMYTHTV_TRANSFER_MAX_BUFFER ) ) src->content_size = size_tmp; - else + else if ( size_tmp > 0 ) goto get_file_pos; - g_print( "\t[%s]\tGET_POSITION: file_position = %llu\n", + g_print( "\t[%s]\tGET_POSITION: file_position = %lld\n", __FUNCTION__, size_tmp ); } #endif @@ -532,8 +541,8 @@ GST_OBJECT_LOCK(src); if ( src->live_tv ) { - src->spawn_livetv = myth_livetv_new( ); - if ( myth_livetv_setup( src->spawn_livetv ) == FALSE ) { + src->spawn_livetv = gmyth_livetv_new( ); + if ( gmyth_livetv_setup( src->spawn_livetv ) == FALSE ) { ret = FALSE; goto init_failed; } @@ -548,7 +557,7 @@ g_print ( "[%s] LiveTV id = %d, URI path = %s.\n", __FUNCTION__, src->live_tv_id, src->uri_name ); } - src->file_transfer = myth_file_transfer_new( src->live_tv_id, + src->file_transfer = gmyth_file_transfer_new( src->live_tv_id, g_string_new( src->uri_name ), -1, src->mythtv_version ); if ( src->file_transfer == NULL ) { @@ -558,19 +567,19 @@ } /* sets the Playback monitor connection */ - ret = myth_file_transfer_playback_setup( &(src->file_transfer), src->live_tv ); + ret = gmyth_file_transfer_playback_setup( &(src->file_transfer), src->live_tv ); if ( src->live_tv == TRUE && ret == TRUE ) { /* loop finished, set the max tries variable to zero again... */ wait_to_transfer = 0; - while ( wait_to_transfer++ < MYTHTV_TRANSFER_MAX_WAITS && ( myth_file_transfer_is_recording( src->file_transfer ) == FALSE - /*|| ( myth_file_transfer_get_file_position( src->file_transfer ) < ( src->content_size + 327680 ) )*/ ) ) + while ( wait_to_transfer++ < GMYTHTV_TRANSFER_MAX_WAITS && ( gmyth_file_transfer_is_recording( src->file_transfer ) == FALSE + /*|| ( gmyth_file_transfer_get_file_position( src->file_transfer ) < ( src->content_size + 327680 ) )*/ ) ) g_usleep( 100 ); } /* sets the FileTransfer instance connection (video/audio download) */ - ret = myth_file_transfer_setup( &(src->file_transfer), src->live_tv ); + ret = gmyth_file_transfer_setup( &(src->file_transfer), src->live_tv ); if ( ret == FALSE ) { GST_OBJECT_UNLOCK(src); @@ -624,7 +633,7 @@ guint64 size = 0; - mythtv = GST_MYTHTV_SRC( GST_PAD_PARENT (pad) ); + mythtv = GST_GMYTHTV_SRC( GST_PAD_PARENT (pad) ); size = gst_mythtv_src_get_position (mythtv); @@ -690,26 +699,31 @@ if (src->content_size <= 0) { ret= FALSE; - } else if ( abs ( src->content_size - src->read_offset ) <= MYTHTV_TRANSFER_MAX_BUFFER ) { + } else if ( abs ( src->content_size - src->read_offset ) <= GMYTHTV_TRANSFER_MAX_BUFFER ) { //g_static_mutex_lock( &update_size_mutex ); GST_OBJECT_LOCK(src); - guint64 new_offset = myth_file_transfer_get_file_position( src->file_transfer ); - if ( src->content_size < new_offset ) { - src->content_size = new_offset; - } + gint64 new_offset = gmyth_file_transfer_get_file_position( src->file_transfer ); + if ( new_offset > 0 ) { + if ( src->content_size < new_offset ) { + src->content_size = new_offset; + } + } else { + src->update_prog_chain = TRUE; + src->content_size = 0; + } #if ENABLE_TIMING_POSITION == 1 - guint64 size_tmp = 0; + gint64 size_tmp = 0; if (src->live_tv == TRUE) { get_file_pos: g_usleep( 5 ); - size_tmp = myth_file_transfer_get_file_position( src->file_transfer ); - if ( size_tmp > ( src->content_size + MYTHTV_TRANSFER_MAX_BUFFER ) ) + size_tmp = gmyth_file_transfer_get_file_position( src->file_transfer ); + if ( size_tmp > ( src->content_size + GMYTHTV_TRANSFER_MAX_BUFFER ) ) src->content_size = size_tmp; - else + else if ( size_tmp > 0 ) goto get_file_pos; - g_print( "\t[%s]\tGET_POSITION: file_position = %llu\n", + g_print( "\t[%s]\tGET_POSITION: file_position = %lld\n", __FUNCTION__, size_tmp ); } #endif @@ -849,28 +863,28 @@ break; } #ifndef GST_DISABLE_GST_DEBUG - case PROP_MYTHTV_DBG: + case PROP_GMYTHTV_DBG: { mythtvsrc->mythtv_msgs_dbg = g_value_get_boolean (value); break; } #endif - case PROP_MYTHTV_VERSION: + case PROP_GMYTHTV_VERSION: { mythtvsrc->mythtv_version = g_value_get_int (value); break; } - case PROP_MYTHTV_LIVEID: + case PROP_GMYTHTV_LIVEID: { mythtvsrc->live_tv_id = g_value_get_int (value); break; } - case PROP_MYTHTV_LIVE: + case PROP_GMYTHTV_LIVE: { mythtvsrc->live_tv = g_value_get_boolean (value); break; } - case PROP_MYTHTV_LIVE_CHAINID: + case PROP_GMYTHTV_LIVE_CHAINID: { if (!g_value_get_string (value)) { GST_WARNING ("MythTV Live chainid property cannot be NULL"); @@ -918,24 +932,24 @@ break; } #ifndef GST_DISABLE_GST_DEBUG - case PROP_MYTHTV_DBG: + case PROP_GMYTHTV_DBG: g_value_set_boolean ( value, mythtvsrc->mythtv_msgs_dbg ); break; #endif - case PROP_MYTHTV_VERSION: + case PROP_GMYTHTV_VERSION: { g_value_set_int ( value, mythtvsrc->mythtv_version ); break; } - case PROP_MYTHTV_LIVEID: + case PROP_GMYTHTV_LIVEID: { g_value_set_int ( value, mythtvsrc->live_tv_id ); break; } - case PROP_MYTHTV_LIVE: + case PROP_GMYTHTV_LIVE: g_value_set_boolean ( value, mythtvsrc->live_tv ); break; - case PROP_MYTHTV_LIVE_CHAINID: + case PROP_GMYTHTV_LIVE_CHAINID: { gchar *str = g_strdup( "" ); @@ -960,7 +974,7 @@ * register the element factories and pad templates * register the features */ - static gboolean +static gboolean plugin_init (GstPlugin * plugin) { return gst_element_register (plugin, "mythtvsrc", GST_RANK_NONE, diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/gstmythtvsrc.h --- a/gst-plugins-mythtv/src/gstmythtvsrc.h Mon Oct 23 14:43:18 2006 +0100 +++ b/gst-plugins-mythtv/src/gstmythtvsrc.h Mon Oct 23 15:42:46 2006 +0100 @@ -21,8 +21,8 @@ #include #include -#include "myth_file_transfer.h" -#include "myth_livetv.h" +#include "gmyth_file_transfer.h" +#include "gmyth_livetv.h" G_BEGIN_DECLS @@ -44,9 +44,9 @@ GstBaseSrc element; /* MythFileTransfer */ - MythFileTransfer *file_transfer; + GMythFileTransfer *file_transfer; - MythLiveTV *spawn_livetv; + GMythLiveTV *spawn_livetv; gchar *uri_name; gchar *user_agent; @@ -76,6 +76,8 @@ /* enable Myth TV debug messages */ gboolean mythtv_msgs_dbg; + + gboolean update_prog_chain; }; struct _GstMythtvSrcClass { diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/myth_file_transfer.c --- a/gst-plugins-mythtv/src/myth_file_transfer.c Mon Oct 23 14:43:18 2006 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,1050 +0,0 @@ -/* vim: set sw=2: -*- Mode: C; tab-width: 2; indent-tabs-mode: t; c-basic-offset: 2; c-indent-level: 2-*- */ -/** - * GStreamer plug-in properties: - * - location (backend server hostname/URL) [ex.: myth://192.168.1.73:28722/1000_1092091.nuv] - * - path (qurl - remote file to be opened) - * - port number - * @author Rosfran Lins Borges - */ - -#include "myth_file_transfer.h" -#include "myth_uri.h" -#include "myth_livetv.h" -#include -#include -#include - -#include -#include - -#include -#include -#include -#include -#include -#include - -#define MYTHTV_QUERY_HEADER "QUERY_FILETRANSFER" -#define MYTHTV_RECORDER_HEADER "QUERY_RECORDER" - -/* default values to the file transfer parameters */ -#define MYTHTV_USER_READ_AHEAD FALSE -#define MYTHTV_RETRIES 1 -#define MYTHTV_FILE_SIZE -1 - -#define MYTHTV_BUFFER_SIZE 8*1024 - -#define MYTHTV_VERSION 30 - -#define MYTHTV_TRANSFER_MAX_WAITS 700 - -#ifdef MYTHTV_ENABLE_DEBUG -#define MYTHTV_ENABLE_DEBUG 1 -#else -#undef MYTHTV_ENABLE_DEBUG -#endif - -/* this NDEBUG is to maintain compatibility with GMyth library */ -#ifndef NDEBUG -#define MYTHTV_ENABLE_DEBUG 1 -#endif - -static guint wait_to_transfer = 0; - -enum myth_sock_types { - MYTH_PLAYBACK_TYPE = 0, - MYTH_MONITOR_TYPE, - MYTH_FILETRANSFER_TYPE, - MYTH_RINGBUFFER_TYPE -}; - -static GStaticMutex mutex = G_STATIC_MUTEX_INIT; - -static GMainContext *io_watcher_context = NULL; - -static void myth_file_transfer_class_init (MythFileTransferClass *klass); -static void myth_file_transfer_init (MythFileTransfer *object); - -static void myth_file_transfer_dispose (GObject *object); -static void myth_file_transfer_finalize (GObject *object); - -static GMythSocket *myth_connect_to_transfer_backend( MythFileTransfer **transfer, guint sock_type ); -static void* myth_init_io_watchers( void *data ); - -void myth_file_transfer_close( MythFileTransfer *transfer ); - -G_DEFINE_TYPE(MythFileTransfer, myth_file_transfer, G_TYPE_OBJECT) - -#if 0 -static guint64 -mmyth_util_decode_long_long( GMythStringList *strlist, guint offset ) -{ - - guint64 ret_value = 0LL; - - g_return_val_if_fail( strlist != NULL, ret_value ); - - if ( offset < gmyth_string_list_length( strlist )) - g_printerr( "[%s] Offset is lower than the GMythStringList (offset = %d)!\n", __FUNCTION__, offset ); - g_return_val_if_fail( offset < gmyth_string_list_length( strlist ), ret_value ); - - gint l1 = gmyth_string_list_get_int( strlist, offset ); - gint l2 = gmyth_string_list_get_int( strlist, offset + 1 ); - - ret_value = ((guint64)(l2) & 0xffffffffLL) | ((guint64)(l1) << 32); - - return ret_value; - -} -#endif - -static void -myth_file_transfer_class_init (MythFileTransferClass *klass) -{ - GObjectClass *gobject_class; - - gobject_class = (GObjectClass *) klass; - - gobject_class->dispose = myth_file_transfer_dispose; - gobject_class->finalize = myth_file_transfer_finalize; -} - - static void -myth_file_transfer_init (MythFileTransfer *myth_file_transfer) -{ - g_return_if_fail( myth_file_transfer != NULL ); - myth_file_transfer->mythtv_version = MYTHTV_VERSION; -} - -static void -myth_file_transfer_dispose (GObject *object) -{ - MythFileTransfer *myth_file_transfer = MYTH_FILE_TRANSFER(object); - - myth_file_transfer_close( myth_file_transfer ); - - G_OBJECT_CLASS (myth_file_transfer_parent_class)->dispose (object); -} - - static void -myth_file_transfer_finalize (GObject *object) -{ - g_signal_handlers_destroy (object); - - G_OBJECT_CLASS (myth_file_transfer_parent_class)->finalize (object); -} - - MythFileTransfer* -myth_file_transfer_new (gint num, GString *uri_str, gshort port, gint mythtv_version) -{ - MythFileTransfer *transfer = MYTH_FILE_TRANSFER ( g_object_new ( - MYTH_FILE_TRANSFER_TYPE, FALSE )); - - if ( mythtv_version > 0 ) - transfer->mythtv_version = mythtv_version; - - transfer->card_id = num; - - transfer->rec_id = -1; - - transfer->recordernum = num; - transfer->uri = myth_uri_new ( uri_str->str ); - - transfer->hostname = g_string_new( myth_uri_gethost(transfer->uri) ); - g_print( "\t--> transfer->hostname = %s\n", transfer->hostname->str ); - - if ( port >= 0 ) - transfer->port = port; - else - transfer->port = myth_uri_getport( transfer->uri ); - - g_print( "\t--> transfer->port = %d\n", transfer->port ); - - transfer->readposition = 0; - transfer->filesize = MYTHTV_FILE_SIZE; - transfer->timeoutisfast = FALSE; - - transfer->userreadahead = MYTHTV_USER_READ_AHEAD; - transfer->retries = MYTHTV_RETRIES; - - transfer->live_tv = FALSE; - - transfer->query = g_string_new( MYTHTV_QUERY_HEADER ); - g_string_append_printf ( transfer->query, " %d", transfer->recordernum ); - g_print( "\t--> transfer->query = %s\n", transfer->query->str ); - - transfer->control_sock = NULL; - transfer->event_sock = NULL; - transfer->sock = NULL; - - return transfer; -} - -gboolean -myth_file_transfer_livetv_setup( MythFileTransfer **transfer, GMythSocket *live_socket ) -{ - (*transfer)->sock = live_socket; - g_object_ref( live_socket ); - - return TRUE; -} - -gboolean -myth_file_transfer_playback_setup( MythFileTransfer **transfer, gboolean live_tv ) -{ - - gboolean ret = TRUE; - - (*transfer)->live_tv = live_tv; - - printf("[%s] Running config to the %s...\n", __FUNCTION__, live_tv ? "LiveTV" : "FileTransfer" ); - - /* configure the control socket */ - if ((*transfer)->control_sock == NULL) { - - if ( myth_connect_to_transfer_backend ( transfer, MYTH_PLAYBACK_TYPE ) == NULL ) { - g_printerr( "Connection to backend failed (Control Socket).\n" ); - ret = FALSE; - } - - } else { - g_warning("Remote transfer control socket already created.\n"); - } - - return ret; - -} - -gboolean -myth_file_transfer_setup( MythFileTransfer **transfer, gboolean live_tv ) -{ - GMythStringList *strlist = NULL; - - gboolean ret = TRUE; - - (*transfer)->live_tv = live_tv; - - printf("[%s] Running config to the %s...\n", __FUNCTION__, live_tv ? "LiveTV" : "FileTransfer" ); - -#if 0 - /* configure the control socket */ - if ((*transfer)->event_sock == NULL) { - - if ( myth_connect_to_transfer_backend ( transfer, MYTH_MONITOR_TYPE ) == NULL ) { - g_printerr( "Connection to backend failed (Event Socket).\n" ); - ret = FALSE; - } - - } else { - g_warning("Remote transfer control socket already created.\n"); - } -#endif - - /* configure the socket */ - if ( (*transfer)->sock == NULL ) { - - //if ( live_tv == FALSE ) { - - if ( myth_connect_to_transfer_backend ( transfer, MYTH_FILETRANSFER_TYPE ) == NULL ) { - g_printerr ("Connection to backend failed (Raw Transfer Socket).\n"); - ret = FALSE; - } - - if ( !(*transfer)->live_tv && (*transfer)->control_sock != NULL) { - strlist = gmyth_string_list_new(); - g_string_printf ( (*transfer)->query, "%s %d", MYTHTV_QUERY_HEADER, (*transfer)->recordernum ); - - gmyth_string_list_append_string( strlist, (*transfer)->query ); - gmyth_string_list_append_char_array( strlist, "IS_OPEN" ); - - gmyth_socket_write_stringlist( (*transfer)->control_sock, strlist ); - gmyth_socket_read_stringlist( (*transfer)->control_sock, strlist ); - - if ( strlist!=NULL && gmyth_string_list_get_int( strlist, 0 ) == 1 ) { - g_print( "[%s] Remote Myth FileTransfer socket is open!\n", __FUNCTION__ ); - } else { - g_print( "[%s] Remote Myth FileTransfer socket is CLOSED! See the MythTV Server Backend for configuration details...\n", __FUNCTION__ ); - ret = FALSE; - } - } - - } else { - g_warning("Remote transfer (raw) socket already created.\n"); - } - - return ret; -} - -static GMythSocket * -myth_connect_to_transfer_backend( MythFileTransfer **transfer, guint sock_type ) -{ - GMythSocket *sock = NULL; - - g_return_val_if_fail( transfer != NULL && *transfer != NULL, NULL ); - g_return_val_if_fail( (*transfer)->uri != NULL, NULL ); - - g_static_mutex_lock (&mutex); - - gchar *path_dir = myth_uri_getpath( (*transfer)->uri ); - //g_print( "\t--> %s: path_dir = %s\n", __FUNCTION__, path_dir ); - - gchar *stype = g_strdup( "" ); - - // if ( (*transfer)->live_tv == FALSE ) { - - sock = gmyth_socket_new(); - - gmyth_socket_connect( &sock, (*transfer)->hostname->str, (*transfer)->port ); - - /* - } else { - sock = (*transfer)->sock; - } - */ -#ifdef MYTHTV_ENABLE_DEBUG - - g_print( "[%s] --> Creating socket... (%s, %d)\n", __FUNCTION__, (*transfer)->hostname->str, (*transfer)->port ); -#endif - - GMythStringList *strlist = NULL; - - GString *hostname = g_string_new( myth_uri_gethost( (*transfer)->uri ) ); - GString *base_str = g_string_new( "" ); - - if ( gmyth_socket_check_protocol_version_number (sock, (*transfer)->mythtv_version) ) { - - if (sock == NULL) { - stype = (sock_type==MYTH_PLAYBACK_TYPE) ? "control socket" : "file data socket"; - g_printerr( "FileTransfer, open_socket(%s): \n" - "\t\t\tCould not connect to server \"%s\" @ port %d\n", stype, - (*transfer)->hostname->str, (*transfer)->port ); - g_object_unref(sock); - g_static_mutex_unlock (&mutex); - return NULL; - } - - hostname = gmyth_socket_get_local_hostname(); - - g_print( "[%s] local hostname = %s\n", __FUNCTION__, hostname->str ); - - if ( sock_type == MYTH_PLAYBACK_TYPE ) - { - (*transfer)->control_sock = sock; - g_string_printf( base_str, "ANN Playback %s %d", hostname->str, TRUE ); - - gmyth_socket_send_command( (*transfer)->control_sock, base_str ); - GString *resp = gmyth_socket_receive_response( (*transfer)->control_sock ); - g_print( "[%s] Got Playback response from %s: %s\n", __FUNCTION__, base_str->str, resp->str ); - } - else if ( sock_type == MYTH_MONITOR_TYPE ) - { - (*transfer)->event_sock = sock; - g_string_printf( base_str, "ANN Monitor %s %d", hostname->str, TRUE ); - - gmyth_socket_send_command( (*transfer)->event_sock, base_str ); - GString *resp = gmyth_socket_receive_response( (*transfer)->event_sock ); - g_print( "[%s] Got Monitor response from %s: %s\n", __FUNCTION__, base_str->str, resp->str ); - //g_thread_create( myth_init_io_watchers, (void*)(*transfer), FALSE, NULL ); - myth_init_io_watchers ( (void*)(*transfer) ); - - g_printerr( "[%s] Watch listener function to the IO control channel on thread %p.\n", __FUNCTION__, g_thread_self() ); - - } - else if ( sock_type == MYTH_FILETRANSFER_TYPE ) - { - (*transfer)->sock = sock; - strlist = gmyth_string_list_new(); - //g_string_printf( base_str, "ANN FileTransfer %s %d %d", hostname->str, - // transfer->userreadahead, transfer->retries ); - g_string_printf( base_str, "ANN FileTransfer %s", hostname->str ); - - gmyth_string_list_append_string( strlist, base_str ); - gmyth_string_list_append_char_array( strlist, path_dir ); - - gmyth_socket_write_stringlist( (*transfer)->sock, strlist ); - gmyth_socket_read_stringlist( (*transfer)->sock, strlist ); - - /* socket number, where all the stream data comes from - got from the MythTV remote backend */ - (*transfer)->recordernum = gmyth_string_list_get_int( strlist, 1 ); - - /* Myth URI stream file size - decoded using two 8-bytes sequences (64 bits/long long types) */ - (*transfer)->filesize = gmyth_util_decode_long_long( strlist, 2 ); - - printf( "[%s] ***** Received: recordernum = %d, filesize = %" G_GUINT64_FORMAT "\n", __FUNCTION__, - (*transfer)->recordernum, (*transfer)->filesize ); - - if ( (*transfer)->filesize <= 0 ) { - g_print( "[%s] Got filesize equals to %llu is lesser than 0 [invalid stream file]\n", __FUNCTION__, (*transfer)->filesize ); - g_object_unref(sock); - sock = NULL; - } - } - else if ( sock_type == MYTH_RINGBUFFER_TYPE ) - { - (*transfer)->sock = sock; - //myth_file_transfer_spawntv( (*transfer), NULL ); - - strlist = gmyth_string_list_new(); - g_string_printf( base_str, "ANN RingBuffer %s %d", hostname->str, (*transfer)->card_id ); - - gmyth_socket_send_command( (*transfer)->sock, base_str ); - GString *resp = gmyth_socket_receive_response( (*transfer)->sock ); - g_print( "[%s] Got RingBuffer response from %s: %s\n", __FUNCTION__, base_str->str, resp->str ); - - } - - } - - printf("[%s] ANN %s sent: %s\n", (sock_type==MYTH_PLAYBACK_TYPE) ? "Playback" : (sock_type==MYTH_FILETRANSFER_TYPE) ? "FileTransfer" : "Monitor", __FUNCTION__, base_str->str); - - if ( strlist != NULL ) - g_object_unref( strlist ); - - g_static_mutex_unlock (&mutex); - - return sock; -} - -void -myth_file_transfer_spawntv ( MythFileTransfer *file_transfer, - GString *tvchain_id ) -{ - GMythStringList *str_list; - - g_debug ("myth_file_transfer_spawntv.\n"); - - str_list = gmyth_string_list_new (); - - g_string_printf( file_transfer->query, "%s %d", MYTHTV_RECORDER_HEADER, - file_transfer->card_id ); - gmyth_string_list_append_string (str_list, file_transfer->query); - gmyth_string_list_append_string (str_list, g_string_new ("SPAWN_LIVETV")); - if (tvchain_id!=NULL) { - gmyth_string_list_append_string (str_list, tvchain_id); - gmyth_string_list_append_int (str_list, FALSE); // PIP = FALSE (0) - } - - gmyth_socket_sendreceive_stringlist ( file_transfer->sock, str_list ); - - //GString *str = NULL; - - //if (str_list!=NULL && (str = gmyth_string_list_get_string( str_list, 0 )) != NULL && strcasecmp( str->str, "ok" ) != 0 ) { - // g_print( "[%s]\t\tSpawnLiveTV is OK!\n", __FUNCTION__ ); - //} - if (str_list!=NULL) - g_object_unref (str_list); - -} - -gboolean -myth_file_transfer_is_recording ( MythFileTransfer *file_transfer ) -{ - gboolean ret = TRUE; - - GMythStringList *str_list = gmyth_string_list_new (); - - g_debug ( "[%s]\n", __FUNCTION__ ); - g_static_mutex_lock (&mutex); - - g_string_printf( file_transfer->query, "%s %d", MYTHTV_RECORDER_HEADER, - file_transfer->rec_id >= 0 ? file_transfer->rec_id : file_transfer->card_id ); - gmyth_string_list_append_string (str_list, file_transfer->query); - gmyth_string_list_append_string (str_list, g_string_new ("IS_RECORDING")); - - gmyth_socket_sendreceive_stringlist ( file_transfer->control_sock, str_list ); - - if ( str_list != NULL && gmyth_string_list_length(str_list) > 0 ) - { - GString *str = NULL; - if ( ( str = gmyth_string_list_get_string( str_list, 0 ) ) != NULL && strcmp( str->str, "bad" )!= 0 ) { - gint is_rec = gmyth_string_list_get_int( str_list, 0 ); - if ( is_rec != 0 ) - ret = TRUE; - else - ret = FALSE; - } - } - g_print( "[%s] %s, stream is %s being recorded!\n", __FUNCTION__, ret ? "YES" : "NO", ret ? "" : "NOT" ); - g_static_mutex_unlock (&mutex); - - if ( str_list != NULL ) - g_object_unref (str_list); - - return ret; - -} - -guint64 -myth_file_transfer_get_file_position ( MythFileTransfer *file_transfer ) -{ - gint64 pos = 0; - - GMythStringList *str_list = gmyth_string_list_new (); - - g_debug ( "[%s]\n", __FUNCTION__ ); - g_static_mutex_lock (&mutex); - - g_string_printf( file_transfer->query, "%s %d", MYTHTV_RECORDER_HEADER, - file_transfer->rec_id >= 0 ? file_transfer->rec_id : file_transfer->card_id ); - - gmyth_string_list_append_string (str_list, file_transfer->query); - gmyth_string_list_append_string (str_list, g_string_new ("GET_FILE_POSITION")); - - gmyth_socket_sendreceive_stringlist ( file_transfer->control_sock, str_list ); - - if ( str_list != NULL && gmyth_string_list_length(str_list) > 0 ) - { - GString *str = NULL; - if ( ( str = gmyth_string_list_get_string( str_list, 0 ) ) != NULL && strcmp ( str->str, "bad" ) != 0 ) - pos = gmyth_util_decode_long_long( str_list, 0 ); - } - g_static_mutex_unlock (&mutex); - -#ifndef MYTHTV_ENABLE_DEBUG - - g_print( "[%s] Got file position = %llu\n", __FUNCTION__, pos ); -#endif - if (str_list!=NULL) - g_object_unref (str_list); - - return pos; - -} - - glong -myth_file_transfer_get_recordernum( MythFileTransfer *transfer ) -{ - return transfer->recordernum; -} - - glong -myth_file_transfer_get_filesize( MythFileTransfer *transfer ) -{ - return transfer->filesize; -} - - gboolean -myth_file_transfer_isopen( MythFileTransfer *transfer ) -{ - return (transfer->sock != NULL && transfer->control_sock != NULL); -} - - void -myth_file_transfer_close( MythFileTransfer *transfer ) -{ - GMythStringList *strlist; - - if (transfer->control_sock == NULL) - return; - - strlist = gmyth_string_list_new( ); - - g_string_printf( transfer->query, "%s %d", MYTHTV_QUERY_HEADER, - transfer->recordernum ); - gmyth_string_list_append_string( strlist, transfer->query ); - gmyth_string_list_append_char_array( strlist, "DONE" ); - - - if ( gmyth_socket_sendreceive_stringlist(transfer->control_sock, strlist) <= 0 ) - { - g_printerr( "Remote file timeout.\n" ); - } - - if (transfer->sock) - { - g_object_unref( transfer->sock ); - transfer->sock = NULL; - } - - if (transfer->control_sock) - { - g_object_unref( transfer->control_sock ); - transfer->control_sock = NULL; - } - -} - - void -myth_file_transfer_reset_controlsock( MythFileTransfer *transfer ) -{ - if (transfer->control_sock == NULL) - { - g_printerr( "myth_file_transfer_reset_controlsock(): Called with no control socket" ); - return; - } - - GString *str = gmyth_socket_receive_response( transfer->control_sock ); - - g_string_free( str, TRUE ); -} - -void -myth_file_transfer_reset_sock( MythFileTransfer *transfer ) -{ - if ( transfer->sock == NULL ) - { - g_printerr( "myth_file_transfer_reset_sock(): Called with no raw socket" ); - return; - } - - GString *str = gmyth_socket_receive_response( transfer->sock ); - - g_string_free( str, TRUE ); -} - -void -myth_file_transfer_reset( MythFileTransfer *transfer ) -{ - myth_file_transfer_reset_controlsock( transfer ); - myth_file_transfer_reset_sock( transfer ); -} - -guint64 -myth_file_transfer_seek(MythFileTransfer *transfer, guint64 pos, gint whence) -{ - if (transfer->sock == NULL) - { - g_printerr( "[%s] myth_file_transfer_seek(): Called with no socket", __FUNCTION__ ); - return 0; - } - - if (transfer->control_sock == NULL) - return 0; - - // if (!controlSock->isOpen() || controlSock->error()) - // return 0; - - GMythStringList *strlist = gmyth_string_list_new(); - g_string_printf (transfer->query, "%s %d", MYTHTV_QUERY_HEADER, transfer->recordernum); - gmyth_string_list_append_string( strlist, transfer->query ); - gmyth_string_list_append_char_array( strlist, "SEEK" ); - gmyth_string_list_append_uint64( strlist, pos ); - - gmyth_string_list_append_int( strlist, whence ); - - if (pos > 0 ) - gmyth_string_list_append_uint64( strlist, pos ); - else - gmyth_string_list_append_uint64( strlist, transfer->readposition ); - - gmyth_socket_sendreceive_stringlist( transfer->control_sock, strlist ); - - guint64 retval = gmyth_string_list_get_uint64(strlist, 0); - transfer->readposition = retval; - g_print( "[%s] got reading position pointer from the streaming = %llu\n", - __FUNCTION__, retval ); - - //myth_file_transfer_reset( transfer ); - - return retval; -} - -static gboolean -myth_control_sock_listener( GIOChannel *source, GIOCondition condition, gpointer data ) -{ - - GIOStatus ret; - GError *err = NULL; - gchar *msg = g_strdup(""); - - g_static_mutex_lock( &mutex ); - - gsize len; - if (condition & G_IO_HUP) - g_error ("Read end of pipe died!\n"); - ret = g_io_channel_read_line ( source, &msg, &len, NULL, &err); - if ( ret == G_IO_STATUS_ERROR ) - g_error ("[%s] Error reading: %s\n", __FUNCTION__, err != NULL ? err->message : "" ); - g_print ("\n\n\n\n\n\n[%s]\t\tEVENT: Read %u bytes: %s\n\n\n\n\n", __FUNCTION__, len, msg != NULL ? msg : "" ); - if ( msg != NULL ) - g_free (msg); - - g_static_mutex_unlock( &mutex ); - - return TRUE; - -} - -static void* -myth_init_io_watchers( void *data ) -{ - MythFileTransfer *transfer = (MythFileTransfer*)data; - io_watcher_context = g_main_context_new(); - GMainLoop *loop = g_main_loop_new( NULL, FALSE ); - - GSource *source = NULL; - - if ( transfer->event_sock->sd_io_ch != NULL ) - source = g_io_create_watch( transfer->event_sock->sd_io_ch, G_IO_IN | G_IO_HUP ); - else - goto cleanup; - - g_source_set_callback ( source, (GSourceFunc)myth_control_sock_listener, NULL, NULL ); - - g_source_attach( source, io_watcher_context ); - - if (source==NULL) { - g_printerr( "[%s] Error adding watch listener function to the IO control channel!\n", __FUNCTION__ ); - goto cleanup; - } - - g_print( "[%s]\tOK! Starting listener on the MONITOR event socket...\n", __FUNCTION__ ); - - g_main_loop_run( loop ); - -cleanup: - if ( source != NULL ) - g_source_unref( source ); - - g_main_loop_unref( loop ); - - g_main_context_unref( io_watcher_context ); - - return NULL; -} - - -gint -myth_file_transfer_read(MythFileTransfer *transfer, void *data, gint size, gboolean read_unlimited) -{ - gint recv = 0; - gsize bytes_read = 0; - gint sent = 0; - guint remaining = 0; - gboolean response = FALSE; - - GIOChannel *io_channel; - GIOChannel *io_channel_control; - - GIOCondition io_cond; - GIOCondition io_cond_control; - GIOStatus io_status = G_IO_STATUS_NORMAL, io_status_control = G_IO_STATUS_NORMAL; - - gint buf_len = MYTHTV_BUFFER_SIZE; - - GMythStringList *strlist = NULL; - GError *error = NULL; - - gchar *trash = g_strdup(""); - - g_return_val_if_fail ( data != NULL, -2 ); - - /* gets the size of the entire file, if the size requested is lesser than 0 */ - if ( size <= 0 ) - size = transfer->filesize; - - io_channel = transfer->sock->sd_io_ch; - io_channel_control = transfer->control_sock->sd_io_ch; - - //g_io_channel_set_flags( io_channel, G_IO_FLAG_APPEND | - // G_IO_STATUS_AGAIN | G_IO_FLAG_IS_READABLE | G_IO_FLAG_IS_WRITEABLE | - // G_IO_FLAG_IS_SEEKABLE, NULL ); - - io_status = g_io_channel_set_encoding( io_channel, NULL, &error ); - if ( io_status == G_IO_STATUS_NORMAL ) - g_print( "[%s] Setting encoding to binary data socket).\n", __FUNCTION__ ); - - io_cond = g_io_channel_get_buffer_condition( io_channel ); - - io_cond_control = g_io_channel_get_buffer_condition( io_channel ); - - if ( transfer->sock == NULL || ( io_status == G_IO_STATUS_ERROR ) ) - { - g_printerr( "myth_file_transfer_read(): Called with no raw socket.\n" ); - recv = -1; - goto cleanup; - } - - if ( transfer->control_sock == NULL || ( io_status_control == G_IO_STATUS_ERROR ) ) - { - g_printerr( "myth_file_transfer_read(): Called with no control socket.\n" ); - recv = -1; - goto cleanup; - } - - /* - if (!controlSock->isOpen() || controlSock->error()) - return -1; - */ - - if ( ( io_cond & G_IO_IN ) != 0 ) { - do - { - trash = g_new0( gchar, MYTHTV_BUFFER_SIZE ); - - io_status = g_io_channel_read_chars( io_channel, trash, - MYTHTV_BUFFER_SIZE, &bytes_read, &error); - - g_print( "[%s] cleaning buffer on IO binary channel... %d bytes gone!\n", - __FUNCTION__, bytes_read ); - - if ( trash != NULL ) - g_free( trash ); - - io_cond = g_io_channel_get_buffer_condition( io_channel ); - - } while ( ( io_cond & G_IO_IN ) != 0 && ( io_status != G_IO_STATUS_ERROR ) && (error == NULL) ); - - //if ( trash!= NULL ) - // g_free( trash ); - } - - if ( ( io_cond_control & G_IO_IN ) != 0 ) { - GMythStringList *strlist_tmp = gmyth_string_list_new(); - gmyth_socket_read_stringlist( transfer->control_sock, strlist_tmp ); - g_object_unref( strlist_tmp ); - } - - wait_to_transfer = 0; - - //while ( transfer->live_tv && ( myth_file_transfer_get_file_position( transfer ) < 4096 ) && - // wait_to_transfer++ < MYTHTV_TRANSFER_MAX_WAITS ) - // g_usleep( 1000*50 ); /* waits just for 2/10 second */ - - //g_thread_create( myth_init_io_watchers, (void*)transfer, FALSE, NULL ); - //g_printerr( "[%s] Watch listener function to the IO control channel on thread %p.\n", __FUNCTION__, g_thread_self() ); - - //g_static_mutex_lock (&mutex); - //strlist = gmyth_string_list_new(); - - g_string_printf ( transfer->query, "%s %d", - /*transfer->live_tv ? MYTHTV_RECORDER_HEADER :*/ MYTHTV_QUERY_HEADER, - /* transfer->live_tv ? transfer->card_id :*/ transfer->recordernum ); // transfer->recordernum - g_print( "\t[%s] Transfer_query = %s\n", __FUNCTION__, transfer->query->str ); - - sent = size; - remaining = size - recv; - //g_static_mutex_unlock( &mutex ); - //data = (void*)g_new0( gchar, size ); - - //g_io_channel_flush( io_channel, NULL ); - - //g_static_mutex_lock( &mutex ); - - io_cond = g_io_channel_get_buffer_condition( io_channel ); - - while ( recv < size && !response )//&& ( io_cond & G_IO_IN ) != 0 ) - { - g_io_channel_flush( io_channel_control, NULL ); - - strlist = gmyth_string_list_new(); - gmyth_string_list_append_char_array( strlist, transfer->query->str ); - gmyth_string_list_append_char_array( strlist, - /*transfer->live_tv ? "REQUEST_BLOCK_RINGBUF" :*/ "REQUEST_BLOCK" ); - gmyth_string_list_append_int( strlist, remaining ); - gmyth_socket_write_stringlist( transfer->control_sock, strlist ); - - guint count_bytes = 0; - - do - { - //buf_len = ( sent - recv ) > MYTHTV_BUFFER_SIZE ? MYTHTV_BUFFER_SIZE : ( sent - recv ); - if ( remaining > MYTHTV_BUFFER_SIZE ) { - buf_len = MYTHTV_BUFFER_SIZE; - } else { - buf_len = remaining; - } - - bytes_read = 0; - - io_status = g_io_channel_read_chars( io_channel, data + recv, - buf_len, &bytes_read, &error ); - - //g_static_mutex_unlock( &mutex ); - /* - GString *sss = g_string_new(""); - sss = g_string_append_len( sss, (gchar*)data+recv, bytes_read ); - - g_print( "[%s] Reading buffer (length = %d)\n", __FUNCTION__, bytes_read); - */ - if ( bytes_read > 0 ) - { - //if ( bytes_read <= buf_len ) - recv += bytes_read; - count_bytes += bytes_read; - remaining -= bytes_read; - g_print( "[%s] Reading buffer (bytes read = %d, remaining = %d)\n", __FUNCTION__, bytes_read, remaining ); - if ( remaining == 0 ) { - break; - } - } else { - break; - } - - //if ( remaining > 0 ) { - - if ( io_status == G_IO_STATUS_EOF ) { - g_print( "[%s] got EOS!", __FUNCTION__ ); - break; - } else if ( io_status == G_IO_STATUS_ERROR ) { - g_print( "[%s] myth_file_transfer_read(): socket error.\n", __FUNCTION__ ); - break; - } - //} - - /* increase buffer size, to allow get more data (do not obey to the buffer size) */ - if ( read_unlimited == TRUE ) { - // FOR NOW, DO NOTHING!!! - //if ( recv > buf_len ) - // sent += (bytes_read - buf_len) + 1; - } - - /* verify if the input (read) buffer is ready to receive data */ - io_cond = g_io_channel_get_buffer_condition( io_channel ); - - g_print( "[%s]\t io_cond %s prepared for reading! (G_IO_IN) !!!\n\n", __FUNCTION__, - ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" ); - - //if ( recv == size ) - //break; - - } while ( remaining > 0 );//&& ( io_status == G_IO_STATUS_NORMAL ) ); - - // if ( ( recv < size ) ) { - // finish_read = FALSE; - //} - - io_cond_control = g_io_channel_get_buffer_condition( io_channel_control ); - if ( remaining == 0 )//( io_cond_control & G_IO_IN ) != 0 ) - { - gmyth_socket_read_stringlist( transfer->control_sock, strlist ); - if ( strlist != NULL && gmyth_string_list_length( strlist ) > 0 ) - { - sent = gmyth_string_list_get_int( strlist, 0 ); // -1 on backend error - g_print( "[%s] got SENT buffer message = %d\n", __FUNCTION__, sent ); - if ( sent != 0 ) - { - g_print( "[%s]\t received = %d bytes, backend says %d bytes sent, "\ - "io_cond %s prepared for reading! (G_IO_IN) !!!\n\n", __FUNCTION__, - recv, sent, ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" ); - - if ( sent == count_bytes ) - { - response = ( recv == size ); - g_print( "[%s]\t\tsent %d, which is equals to bytes_read = %d\n\n", - __FUNCTION__, sent, count_bytes ); - if ( response == TRUE ) - break; - } - else - { - g_print( "[%s]\t\tsent %d, which is NOT equals to bytes_read = %d\n\n", - __FUNCTION__, sent, count_bytes ); - goto cleanup; - //response = FALSE; - //break; - } - } else { - break; - //goto cleanup; - } // if - } // if - reading control response from backend - } else { - response = FALSE; - } // if - stringlist response - - } // while - - io_cond_control = g_io_channel_get_buffer_condition( io_channel_control ); - // io_cond = g_io_channel_get_buffer_condition( io_channel ); - - if ( ( ( io_cond_control & G_IO_IN ) != 0 ) && - ( response || ( recv == size ) ) ) - { - if ( gmyth_socket_read_stringlist( transfer->control_sock, strlist ) > 0 ) - { - if ( strlist != NULL && gmyth_string_list_length(strlist) > 0 ) - { - sent = gmyth_string_list_get_int( strlist, 0 ); // -1 on backend error - g_print( "[%s]\t received = %d bytes -\tNOW returning from reading buffer I/O socket "\ - "[%s prepared for reading]! (G_IO_IN) !!!\n\n", __FUNCTION__, - sent, ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" ); - } - } - else - { - g_printerr ( "myth_file_transfer_read(): No response from control socket."); - recv = -1; - } - - } - else if ( error != NULL ) - { - g_printerr( "[%s] Error occurred: (%d, %s)\n", __FUNCTION__, error->code, error->message ); - } - -cleanup: - //g_static_mutex_unlock (&mutex); - - if ( trash != NULL ) - g_free( trash ); - - if ( strlist != NULL ) - g_object_unref( strlist ); - - g_print( "myth_file_transfer_read(): reqd=%d, rcvd=%d, rept=%d, "\ - "(rcvd and rept MUST be the same!)\n", size, - recv, sent ); - - //if ( ( recv != size ) || ( sent != size ) ) { - //recv = size; - //} - - if ( error != NULL ) { - g_printerr( "Cleaning-up ERROR: %s [msg = %s, code = %d]\n", __FUNCTION__, error->message, - error->code ); - g_error_free( error ); - } - - return recv; -} - -void -myth_file_transfer_settimeout( MythFileTransfer *transfer, gboolean fast ) -{ - - GMythStringList *strlist = NULL; - - if ( transfer->timeoutisfast == fast ) - return; - - if ( transfer->sock == NULL ) - { - g_printerr( "myth_file_transfer_settimeout(): Called with no socket" ); - return; - } - - if ( transfer->control_sock == NULL ) - return; - - strlist = gmyth_string_list_new(); - gmyth_string_list_append_string( strlist, transfer->query ); - gmyth_string_list_append_char_array( strlist, "SET_TIMEOUT" ); - gmyth_string_list_append_int( strlist, fast ); - - gmyth_socket_write_stringlist( transfer->control_sock, strlist ); - gmyth_socket_read_stringlist( transfer->control_sock, strlist ); - - transfer->timeoutisfast = fast; - -} - -#ifdef DO_TESTING - - int -main( int argc, char *argv[] ) -{ - g_type_init(); - - MythFileTransfer *file_transfer = myth_file_transfer_new( 1, - g_string_new("myth://192.168.1.109:6543/jshks.nuv"), -1, MYTHTV_VERSION ); - myth_file_transfer_setup( &file_transfer ); - gchar *data = g_strdup(""); - - gint num = myth_file_transfer_read( file_transfer, data, -1 ); - - return 0; - -} - -#endif diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/myth_file_transfer.h --- a/gst-plugins-mythtv/src/myth_file_transfer.h Mon Oct 23 14:43:18 2006 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,93 +0,0 @@ -/* vim: set sw=2: -*- Mode: C; tab-width: 2; indent-tabs-mode: t; c-basic-offset: 2; c-indent-level: 2-*- */ - -#ifndef __MYTH_FILE_TRANSFER_H__ -#define __MYTH_FILE_TRANSFER_H__ - -#include - -#include -#include "myth_uri.h" -#include "myth_livetv.h" - -#include -#include -#include -#include -#include -#include - -#define G_BEGIN_DECLS - -#define MYTH_FILE_TRANSFER_TYPE (myth_file_transfer_get_type ()) -#define MYTH_FILE_TRANSFER(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), MYTH_FILE_TRANSFER_TYPE, MythFileTransfer)) -#define MYTH_FILE_TRANSFER_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), MYTH_FILE_TRANSFER_TYPE, MythFileTransferClass)) -#define IS_MYTH_FILE_TRANSFER(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), MYTH_FILE_TRANSFER_TYPE)) -#define IS_MYTH_FILE_TRANSFER_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), MYTH_FILE_TRANSFER_TYPE)) -#define MYTH_FILE_TRANSFER_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), MYTH_FILE_TRANSFER_TYPE, MythFileTransferClass)) - - -typedef struct _MythFileTransfer MythFileTransfer; -typedef struct _MythFileTransferClass MythFileTransferClass; - -struct _MythFileTransferClass -{ - GObjectClass parent_class; - - /* callbacks */ - /* no one for now */ -}; - -struct _MythFileTransfer -{ - GObject parent; - - /* Myth URI structure */ - const MythURI *uri; - - /* MythTV version number */ - gint mythtv_version; - - /* socket descriptors */ - GMythSocket *control_sock; - GMythSocket *event_sock; - GMythSocket *sock; - - guint64 readposition; - guint64 filesize; - gboolean timeoutisfast; - gboolean userreadahead; - gboolean live_tv; - gint retries; - - GString *query; - - gint rec_id; - gint recordernum; - gint card_id; - GString *hostname; - gint port; -}; - -GType myth_file_transfer_get_type (void); - -MythFileTransfer* myth_file_transfer_new (gint num, GString *hostname, gshort port, gint mythtv_version ); - -gint myth_file_transfer_read(MythFileTransfer *transfer, void *data, gint size, gboolean read_unlimited); - -guint64 myth_file_transfer_seek(MythFileTransfer *transfer, guint64 pos, gint whence); - -gboolean myth_file_transfer_playback_setup( MythFileTransfer **transfer, gboolean live_tv ); - -gboolean myth_file_transfer_setup( MythFileTransfer **transfer, gboolean live_tv ); - -gboolean myth_file_transfer_livetv_setup( MythFileTransfer **transfer, GMythSocket *live_sock ); - -void myth_file_transfer_spawntv ( MythFileTransfer *file_transfer, GString *tvchain_id ); - -gboolean myth_file_transfer_is_recording( MythFileTransfer *file_transfer ); - -guint64 myth_file_transfer_get_file_position( MythFileTransfer *file_transfer ); - -#define G_END_DECLS - -#endif /* __MYTH_FILE_TRANSFER_H__ */ diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/myth_livetv.c --- a/gst-plugins-mythtv/src/myth_livetv.c Mon Oct 23 14:43:18 2006 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,220 +0,0 @@ - -#include -#include -#include - -#include "myth_livetv.h" -#include "myth_file_transfer.h" - -static void myth_livetv_class_init (MythLiveTVClass *klass); -static void myth_livetv_init (MythLiveTV *object); - -static void myth_livetv_dispose (GObject *object); -static void myth_livetv_finalize (GObject *object); - -static gint tvchain_curr_index = -1; - -G_DEFINE_TYPE(MythLiveTV, myth_livetv, G_TYPE_OBJECT) - -static void -myth_livetv_class_init (MythLiveTVClass *klass) -{ - GObjectClass *gobject_class; - - gobject_class = (GObjectClass *) klass; - - gobject_class->dispose = myth_livetv_dispose; - gobject_class->finalize = myth_livetv_finalize; -} - -static void -myth_livetv_init (MythLiveTV *livetv) -{ - livetv->backend_hostname = NULL; - livetv->backend_port = 0; - livetv->local_hostname = NULL; - - livetv->remote_encoder = NULL; - livetv->tvchain = NULL; - livetv->proginfo = NULL; -} - -static void -myth_livetv_dispose (GObject *object) -{ - - G_OBJECT_CLASS (myth_livetv_parent_class)->dispose (object); -} - -static void -myth_livetv_finalize (GObject *object) -{ - g_signal_handlers_destroy (object); - - MythLiveTV *livetv = MYTH_LIVETV (object); - - g_debug ("[%s] Finalizing livetv", __FUNCTION__); - - if ( livetv->remote_encoder != NULL ) { - g_object_unref (livetv->remote_encoder); - livetv->remote_encoder = NULL; - } - - if ( livetv->tvchain != NULL ) { - g_object_unref (livetv->tvchain); - livetv->tvchain = NULL; - } - - if ( livetv->proginfo != NULL ) { - g_object_unref (livetv->proginfo); - livetv->proginfo = NULL; - } - - G_OBJECT_CLASS ( myth_livetv_parent_class )->finalize ( object ); -} - -MythLiveTV* -myth_livetv_new () -{ - MythLiveTV *livetv = MYTH_LIVETV ( g_object_new( MYTH_LIVETV_TYPE, NULL ) ); - - return livetv; -} - -gboolean -myth_livetv_setup ( MythLiveTV *livetv ) -{ - GMythSettings *msettings = gmyth_context_get_settings (); - gboolean res = TRUE; - - livetv->is_livetv = TRUE; - - res = gmyth_context_check_connection(); - if (!res) { - g_warning ("[%s] LiveTV can not connect to backend", __FUNCTION__); - res = FALSE; - goto error; - } - - livetv->backend_hostname = gmyth_settings_get_backend_hostname(msettings); - livetv->backend_port = gmyth_settings_get_backend_port (msettings); - - livetv->local_hostname = g_string_new(""); - gmyth_context_get_local_hostname (livetv->local_hostname); - - if ( livetv->local_hostname == NULL ) { - res = FALSE; - goto error; - } - - // Gets the remote encoder num - livetv->remote_encoder = remote_request_next_free_recorder (-1); - - if ( livetv->remote_encoder == NULL ) { - g_warning ("[%s] None remote encoder available", __FUNCTION__); - res = FALSE; - goto error; - } - - // Creates livetv chain handler - livetv->tvchain = GMYTH_TVCHAIN ( g_object_new(GMYTH_TVCHAIN_TYPE, NULL) ); - gmyth_tvchain_initialize ( livetv->tvchain, livetv->local_hostname ); - - if ( livetv->tvchain == NULL || livetv->tvchain->tvchain_id == NULL ) { - res = FALSE; - goto error; - } - - // Init remote encoder. Opens its control socket. - res = gmyth_remote_encoder_setup(livetv->remote_encoder); - if ( !res ) { - g_warning ("[%s] Fail while setting remote encoder\n", __FUNCTION__); - res = FALSE; - goto error; - } - // Spawn live tv. Uses the socket to send mythprotocol data to start livetv in the backend (remotelly) - res = gmyth_remote_encoder_spawntv ( livetv->remote_encoder, - gmyth_tvchain_get_id(livetv->tvchain) ); - if (!res) { - g_warning ("[%s] Fail while spawn tv\n", __FUNCTION__); - res = FALSE; - goto error; - } - - // Reload all TV chain from Mysql database. - gmyth_tvchain_reload_all (livetv->tvchain); - - if ( livetv->tvchain == NULL ) { - res = FALSE; - goto error; - } - - // Get program info from database using chanid and starttime - livetv->proginfo = gmyth_tvchain_get_program_at (livetv->tvchain, tvchain_curr_index++ ); - if ( livetv->proginfo == NULL ) { - g_warning ("[%s] LiveTV not successfully started.\n", __FUNCTION__ ); - res = FALSE; - goto error; - } else { - g_debug ("[%s] MythLiveTV: All requests to backend to start TV were OK.\n", __FUNCTION__ ); - } - - return res; - -error: - if ( livetv->backend_hostname != NULL ) { - g_string_free( livetv->backend_hostname, TRUE ); - res = FALSE; - } - - if ( livetv->local_hostname != NULL ) { - g_string_free( livetv->local_hostname, TRUE ); - res = FALSE; - } - - if ( livetv->remote_encoder != NULL ) { - g_object_unref (livetv->remote_encoder); - livetv->remote_encoder = NULL; - } - - if ( livetv->tvchain != NULL ) { - g_object_unref (livetv->tvchain); - livetv->tvchain = NULL; - } - - if ( livetv->proginfo != NULL ) { - g_object_unref (livetv->proginfo); - livetv->proginfo = NULL; - } - - return res; - -} - -// FIXME: How to proceed differently between livetv and recorded content -void -myth_livetv_stop_playing (MythLiveTV *livetv) -{ - g_debug ("[%s] Stopping the LiveTV...\n", __FUNCTION__); - - if (livetv->is_livetv) { - if (!gmyth_remote_encoder_stop_livetv (livetv->remote_encoder)) { - g_warning ("[%s] Error while stoping remote encoder", __FUNCTION__); - } - } -} - -gboolean -myth_livetv_is_playing (MythLiveTV *livetv) -{ - return TRUE; -} - -void -myth_livetv_start_playing (MythLiveTV *livetv) -{ - - // TODO - -} - diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/myth_livetv.h --- a/gst-plugins-mythtv/src/myth_livetv.h Mon Oct 23 14:43:18 2006 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,59 +0,0 @@ -#ifndef MYTH_LIVETV_H_ -#define MYTH_LIVETV_H_ - -#include - -#include -#include -#include - -#include "myth_file_transfer.h" - -#define G_BEGIN_DECLS - -#define MYTH_LIVETV_TYPE (myth_livetv_get_type ()) -#define MYTH_LIVETV(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), MYTH_LIVETV_TYPE, MythLiveTV)) -#define MYTH_LIVETV_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), MYTH_LIVETV_TYPE, MythLiveTVClass)) -#define IS_MYTH_LIVETV(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), MYTH_LIVETV_TYPE)) -#define IS_MYTH_LIVETV_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), MYTH_LIVETV_TYPE)) -#define MYTH_LIVETV_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), MYTH_LIVETV_TYPE, MythLiveTVClass)) - -typedef struct _MythLiveTV MythLiveTV; -typedef struct _MythLiveTVClass MythLiveTVClass; - -struct _MythLiveTVClass -{ - GObjectClass parent_class; - - /* callbacks */ -}; - -struct _MythLiveTV -{ - GObject parent; - - // Backend connection related variables - GString *backend_hostname; - gint backend_port; - GString *local_hostname; - - GMythRemoteEncoder *remote_encoder; - GMythTVChain *tvchain; - GMythProgramInfo *proginfo; - - gboolean is_livetv; - -}; - -GType myth_livetv_get_type (void); - -MythLiveTV* myth_livetv_new (); - -void myth_livetv_start_playing (MythLiveTV *livetv); -void myth_livetv_stop_playing (MythLiveTV *livetv); - -gboolean myth_livetv_setup (MythLiveTV *livetv); - -#define G_END_DECLS - -#endif /*MYTH_LIVETV_H_*/ diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/myth_uri.c --- a/gst-plugins-mythtv/src/myth_uri.c Mon Oct 23 14:43:18 2006 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,208 +0,0 @@ -/** - * - * MythURI utils - * - Extracts and parses a URI char string, in according with the RFC 2396 - * [http://www.ietf.org/rfc/rfc2396.txt] - * - * @author Rosfran Borges (rosfran.borges@indt.org.br) - * - */ - -#include "myth_uri.h" -#include -#include -#include - -static gint -myth_strstr( const gchar *haystack, const gchar *needle ) -{ - - gchar *strPos; - - if (haystack == NULL || needle == NULL) - return -1; - strPos = strstr(haystack, needle); - if (strPos == NULL) - return -1; - - return (strPos - haystack); - -} - -static gboolean -myth_uri_isabsolute( const MythURI *uri ) -{ - gboolean ret = FALSE; - - g_return_val_if_fail( uri != NULL && uri->uri != NULL && uri->protocol != NULL, FALSE ); - - if ( myth_strstr( uri->uri->str, MYTH_URI_PROTOCOL_DELIM ) == 0 || strlen(uri->protocol->str) > 0 ) - ret = TRUE; - - return ret; -} - -static gint -myth_strrchr( const gchar *str, const gchar *chars, const gint nchars ) -{ - - gint strLen; - gint i, j; - - if ( str == NULL || chars == NULL ) - return -1; - - strLen = strlen( str ); - for ( i= (strLen-1); 0 <= i; i-- ) { - for ( j=0; jhost = g_string_new(""); - uri->fragment = g_string_new(""); - uri->password = g_string_new(""); - uri->path = g_string_new(""); - uri->protocol = g_string_new(""); - uri->query = g_string_new(""); - uri->uri = g_string_new(""); - uri->user = g_string_new(""); - return uri; -} - -const MythURI * -myth_uri_new( gchar *value ) -{ - - MythURI *uri = myth_uri_init(); - - gchar *protocol; - gint uriLen; - gint currIdx; - gint protoIdx; - gint atIdx; - gint colonIdx; - gint shashIdx; - gchar *host; - gint eblacketIdx; - GString *hostStr; - GString *portStr; - gint hostLen; - gint sharpIdx; - gint questionIdx; - gint queryLen; - - uriLen = strlen(value); - uri->uri = g_string_new( value ); - - currIdx = 0; - - /*** Protocol ****/ - protoIdx = myth_strstr( value, MYTH_URI_PROTOCOL_DELIM ); - if (0 < protoIdx) { - uri->protocol = g_string_append_len( uri->protocol, value, protoIdx ); - currIdx += protoIdx + strlen( MYTH_URI_PROTOCOL_DELIM ); - } - - /*** User (Password) ****/ - atIdx = myth_strstr( value+currIdx, MYTH_URI_USER_DELIM ); - if ( 0 < atIdx ) { - colonIdx = myth_strstr( value+currIdx, MYTH_URI_COLON_DELIM ); - - if (0 < colonIdx && colonIdx < atIdx) { - uri->user = g_string_append_len( uri->user, value+currIdx, colonIdx ); - uri->password = g_string_append_len( uri->password, value+currIdx+colonIdx+1, atIdx-(colonIdx+1) ); - } - else - uri->user = g_string_append_len( uri->user, value+currIdx, atIdx - currIdx ); - currIdx += atIdx + 1; - } - - /*** Host (Port) ****/ - shashIdx = myth_strstr( value+currIdx, MYTH_URI_SLASH_DELIM ); - if ( 0 < shashIdx ) - uri->host = g_string_append_len( uri->host, value+currIdx, shashIdx ); - else if ( myth_uri_isabsolute(uri) == TRUE ) - uri->host = g_string_append_len( uri->host, value+currIdx, strlen(value) - currIdx ); - host = g_strdup( myth_uri_gethost(uri) ); - colonIdx = myth_strrchr( host, MYTH_URI_COLON_DELIM, 1 ); - eblacketIdx = myth_strrchr( host, MYTH_URI_EBLACET_DELIM, 1 ); - if ( ( 0 < colonIdx ) && ( eblacketIdx < colonIdx ) ) { - hostStr = g_string_new( host ); - - hostLen = hostStr->len; - /**** host ****/ - uri->host = g_string_erase( uri->host, 0, hostLen ); - uri->host = g_string_insert_len( uri->host, 0, hostStr->str, colonIdx ); - //host = myth_uri_gethost( uri ); - if (0 < hostLen) { - if (host[0] == '[' && host[hostLen-1] == ']') - uri->host = g_string_append_len( uri->host, hostStr->str+1, colonIdx-2 ); - } - /**** port ****/ - portStr = g_string_new(""); - portStr = g_string_append_len( portStr, hostStr->str+colonIdx+1, hostLen-colonIdx-1 ); - uri->port = atoi( portStr->str ); - g_string_free( portStr, TRUE ); - g_string_free( hostStr, FALSE ); - } - else { - uri->port = MYTH_URI_KNKOWN_PORT; - protocol = myth_uri_getprotocol(uri); - if ( strcmp(protocol, MYTH_URI_PROTOCOL_HTTP) == 0 ) - uri->port = MYTH_URI_DEFAULT_HTTP_PORT; - if ( strcmp(protocol, MYTH_URI_PROTOCOL_FTP) == 0 ) - uri->port = MYTH_URI_DEFAULT_FTP_PORT; - } - - if (shashIdx > 0) currIdx += shashIdx; - - /* - Handle relative URL - */ - if (myth_uri_isabsolute(uri) == FALSE) - { - - if (shashIdx != 0) - { - /* Add slash delimiter at the beginning of the URL, - if it doesn't exist - */ - uri->path = g_string_new( MYTH_URI_SLASH_DELIM ); - } - uri->path = g_string_append( uri->path, value ); - - } else { - /* First set path simply to the rest of URI */ - g_string_append_len( uri->path, value+currIdx, uriLen-currIdx ); - } - - /**** Path (Query/Fragment) ****/ - sharpIdx = myth_strstr(value+currIdx, MYTH_URI_SHARP_DELIM); - if (0 < sharpIdx) { - uri->path = g_string_append_len( uri->path, value+currIdx, sharpIdx); - uri->fragment = g_string_append_len( uri->fragment, - value+currIdx+sharpIdx+1, uriLen-(currIdx+sharpIdx+1)); - } - - questionIdx = myth_strstr( value+currIdx, MYTH_URI_QUESTION_DELIM ); - if ( 0 < questionIdx ) { - uri->path = g_string_append_len( uri->path, value+currIdx, questionIdx ); - queryLen = uriLen-(currIdx+questionIdx+1); - if ( 0 < sharpIdx ) - queryLen -= uriLen - (currIdx+sharpIdx+1); - uri->query = g_string_append_len( uri->query, value+currIdx+questionIdx+1, queryLen ); - } - - return uri; - -} diff -r 9e534ac483e6 -r ba5dc9bff3a1 gst-plugins-mythtv/src/myth_uri.h --- a/gst-plugins-mythtv/src/myth_uri.h Mon Oct 23 14:43:18 2006 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,63 +0,0 @@ -/** - * - * MythURI utils - * - Extracts and parses a URI char string, in according with the RFC 2396 - * [http://www.ietf.org/rfc/rfc2396.txt] - * - * @author Rosfran Borges (rosfran.borges@indt.org.br) - * - */ - -#ifndef _MYTH_URI_H_ -#define _MYTH_URI_H_ - -#include - -/**************************************** -* Define -****************************************/ - -#define MYTH_URI_KNKOWN_PORT (-1) -#define MYTH_URI_DEFAULT_HTTP_PORT 80 -#define MYTH_URI_DEFAULT_FTP_PORT 21 -#define MYTH_URI_DEFAULT_PATH "/" -#define MYTH_URI_MAXLEN 256 - -#define MYTH_URI_PROTOCOL_DELIM "://" -#define MYTH_URI_USER_DELIM "@" -#define MYTH_URI_COLON_DELIM ":" -#define MYTH_URI_SLASH_DELIM "/" -#define MYTH_URI_SBLACET_DELIM "[" -#define MYTH_URI_EBLACET_DELIM "]" -#define MYTH_URI_SHARP_DELIM "#" -#define MYTH_URI_QUESTION_DELIM "?" -#define MYTH_URI_ESCAPING_CHAR "%" - -#define MYTH_URI_PROTOCOL_MYTH "myth" -#define MYTH_URI_PROTOCOL_HTTP "http" -#define MYTH_URI_PROTOCOL_FTP "ftp" - -/**************************************** -* Data Type -****************************************/ - -typedef struct _MythURI { - GString *uri; - GString *host; - gint port; - GString *protocol; - GString *path; - GString *fragment; - GString *user; - GString *password; - GString *query; -} MythURI; - -const MythURI *myth_uri_new( gchar *value ); - -#define myth_uri_gethost(urip) (urip->host->str) -#define myth_uri_getport(urip) (urip->port) -#define myth_uri_getprotocol(urip) (urip->protocol->str) -#define myth_uri_getpath(urip) (urip->path->str) - -#endif