diff options
Diffstat (limited to 'ext/mythtv')
| -rw-r--r-- | ext/mythtv/gstmythtvsrc.c | 914 | ||||
| -rw-r--r-- | ext/mythtv/gstmythtvsrc.h | 138 |
2 files changed, 366 insertions, 686 deletions
diff --git a/ext/mythtv/gstmythtvsrc.c b/ext/mythtv/gstmythtvsrc.c index 326e786e..cd142033 100644 --- a/ext/mythtv/gstmythtvsrc.c +++ b/ext/mythtv/gstmythtvsrc.c @@ -1,30 +1,71 @@ -/* GStreamer MythTV Plug-in +/* + * GStreamer MythTV Plug-in * Copyright (C) <2006> Rosfran Borges <rosfran.borges@indt.org.br> + * Copyright (C) <2007> Renato Filho <renato.filho@indt.org.br> + * This library is free software; you can + * redistribute it and/or modify it under the terms of the GNU Library + * General Public License as published by the Free Software Foundation; + * either version 2 of the License, or (at your option) any later version. + * This library is distributed in the hope that it will be useful, but + * WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Library + * General Public License for more details. You should have received a copy + * of the GNU Library General Public License along with this library; if + * not, write to the Free Software Foundation, Inc., 59 Temple Place - Suite + * 330, Boston, MA 02111-1307, USA. + */ + +/** + * SECTION:element-mythtvsrc * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Library General Public - * License as published by the Free Software Foundation; either - * version 2 of the License, or (at your option) any later version. + * <refsect2> + * <para> + * MythTVSrc allows to access a remote MythTV backend streaming Video/Audio server, + * and to render audio and video content through a TCP/IP connection to a specific + * port on this server, and based on a known MythTV protocol that is based on + * some message passing, such as REQUEST_BLOCK on a specified number of bytes, to get + * some chunk of remote file data. + * You should pass the information aboute the remote MythTV backend server + * through the <link linkend="GstMythTVSrc--location">location</link> property. + * </para> + * <title>Examples</title> + * <para> + * If you want to get the LiveTV content (set channel, TV tuner, RemoteEncoder, + * Recorder), + * put the following URI: + * + * <programlisting> + * myth://xxx.xxx.xxx.xxx:6543/livetv?channel=BBC + * </programlisting> * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Library General Public License for more details. + * This URI will say to the gmyth library to configure the Recorder instance (used to + * change the channel, start the TV multimedia content transmition, etc.), using + * the IP address (xxx.xxx.xxx.xxx) and port number (6543) of the MythTV backend + * server, and setting the channel name to "BBC". + * + * To get a already recorded the MythTV NUV file, put the following URI: + * + * <programlisting> + * myth://xxx.xxx.xxx.xxx:6543/filename.nuv + * </programlisting> * - * You should have received a copy of the GNU Library General Public - * License along with this library; if not, write to the - * Free Software Foundation, Inc., 59 Temple Place - Suite 330, - * Boston, MA 02111-1307, USA. - */ -/* - * When using the LiveTV content, put the location URI in the following - * format: + * This URI will say to the gmyth library to configure the Recorder instance (used to + * change the channel, start the TV multimedia content transmition, etc.), using + * the IP address (xxx.xxx.xxx.xxx) and port number (6543) of the MythTV backend + * server, and setting the channel name to "BBC". + * + * Another possible way to use the LiveTV content, and just in the case you want to + * use the mysql database, put the location URI in the following format: * - * myth://mythtv:mythtv@xxx.xxx.xxx.xxx:6543/?mythconverg + * <programlisting> + * myth://mythtv:mythtv@xxx.xxx.xxx.xxx:6543/?mythconverg&channel=9 + * </programlisting> * * Where the first field is the protocol (myth), the second and third are user * name (mythtv) and password (mythtv), then backend host name and port number, * and the last field is the database name (mythconverg). + * </para> + * </refsect2> */ #ifdef HAVE_CONFIG_H @@ -32,7 +73,9 @@ #endif #include "gstmythtvsrc.h" +#include <gmyth/gmyth_file.h> #include <gmyth/gmyth_file_transfer.h> +#include <gmyth/gmyth_file_local.h> #include <gmyth/gmyth_livetv.h> #include <gmyth/gmyth_socket.h> @@ -42,47 +85,32 @@ #include <unistd.h> GST_DEBUG_CATEGORY_STATIC (mythtvsrc_debug); -#define GST_CAT_DEFAULT mythtvsrc_debug - -#define GST_GMYTHTV_ID_NUM 1 - -#define GST_GMYTHTV_CHANNEL_DEFAULT_NUM (-1) - -#define GMYTHTV_VERSION_DEFAULT 30 - -#define GMYTHTV_TRANSFER_MAX_WAITS 100 - -#define GMYTHTV_TRANSFER_MAX_RESENDS 2 - -#define GMYTHTV_TRANSFER_MAX_BUFFER (128*1024) - -#define MAX_READ_SIZE (4*1024) - -#define GST_FLOW_ERROR_NO_DATA (-101) - -#define REQUEST_MAX_SIZE (64*1024) - -#define INTERNAL_BUFFER_SIZE (90*1024) +#define GST_GMYTHTV_ID_NUM 1 +#define GST_GMYTHTV_CHANNEL_DEFAULT_NUM (-1) +#define GMYTHTV_VERSION_DEFAULT 30 +#define GMYTHTV_TRANSFER_MAX_WAITS 100 +#define GMYTHTV_TRANSFER_MAX_RESENDS 2 +#define GMYTHTV_TRANSFER_MAX_BUFFER (128*1024) +#define READ_SIZE (14*1024) +#define READ_SIZE_LIVETV (80*1024) +#define GST_FLOW_ERROR_NO_DATA (-101) static const GstElementDetails gst_mythtv_src_details = GST_ELEMENT_DETAILS ("MythTV client source", "Source/Network", "Control and receive data as a client over the network " "via raw socket connections using the MythTV protocol", - "Rosfran Borges <rosfran.borges@indt.org.br>"); + "Rosfran Borges <rosfran.borges@indt.org.br>," + "Renato Filho <renato.filho@indt.org.br>"); static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC, GST_PAD_ALWAYS, - GST_STATIC_CAPS ("video/x-nuv")); - + GST_STATIC_CAPS_ANY); enum { PROP_0, PROP_LOCATION, -#ifndef GST_DISABLE_GST_DEBUG - PROP_GMYTHTV_DBG, -#endif PROP_GMYTHTV_VERSION, PROP_GMYTHTV_LIVE, PROP_GMYTHTV_LIVEID, @@ -91,6 +119,8 @@ enum PROP_GMYTHTV_CHANNEL_NUM }; +static void gst_mythtv_src_clear (GstMythtvSrc * mythtv_src); + static void gst_mythtv_src_finalize (GObject * gobject); static GstFlowReturn gst_mythtv_src_create (GstPushSrc * psrc, @@ -104,15 +134,13 @@ static gboolean gst_mythtv_src_is_seekable (GstBaseSrc * push_src); static gboolean gst_mythtv_src_do_seek (GstBaseSrc * base, GstSegment * segment); -static gboolean gst_mythtv_src_next_program_chain (GstMythtvSrc * src); - static GstStateChangeReturn gst_mythtv_src_change_state (GstElement * element, GstStateChange transition); -static void gst_mythtv_src_set_property (GObject * object, guint prop_id, - const GValue * value, GParamSpec * pspec); -static void gst_mythtv_src_get_property (GObject * object, guint prop_id, - GValue * value, GParamSpec * pspec); +static void gst_mythtv_src_set_property (GObject * object, + guint prop_id, const GValue * value, GParamSpec * pspec); +static void gst_mythtv_src_get_property (GObject * object, + guint prop_id, GValue * value, GParamSpec * pspec); static void gst_mythtv_src_uri_handler_init (gpointer g_iface, gpointer iface_data); @@ -121,8 +149,8 @@ static gboolean gst_mythtv_src_handle_query (GstPad * pad, GstQuery * query); static gboolean gst_mythtv_src_handle_event (GstPad * pad, GstEvent * event); -static gint do_read_request_response (GstMythtvSrc * src, guint size, - GByteArray * data_ptr); +static GMythFileReadResult do_read_request_response (GstMythtvSrc * src, + guint size, GByteArray * data_ptr); static void _urihandler_init (GType type) @@ -139,10 +167,8 @@ _urihandler_init (GType type) } GST_BOILERPLATE_FULL (GstMythtvSrc, gst_mythtv_src, GstPushSrc, - GST_TYPE_PUSH_SRC, _urihandler_init); - -static void -gst_mythtv_src_base_init (gpointer g_class) + GST_TYPE_PUSH_SRC, _urihandler_init) + static void gst_mythtv_src_base_init (gpointer g_class) { GstElementClass *element_class = GST_ELEMENT_CLASS (g_class); @@ -175,9 +201,7 @@ gst_mythtv_src_class_init (GstMythtvSrcClass * klass) g_param_spec_string ("location", "Location", "The location. In the form:" "\n\t\t\tmyth://a.com/file.nuv" - "\n\t\t\tmyth://a.com:23223/file.nuv" - "\n\t\t\tmyth://a.com/?channel=123" - "\n\t\t\tmyth://a.com/?channel=Channel%203" + "\n\t\t\tmyth://a.com:23223/file.nuv " "\n\t\t\ta.com/file.nuv - default scheme 'myth'", "", G_PARAM_READWRITE)); @@ -206,27 +230,18 @@ gst_mythtv_src_class_init (GstMythtvSrcClass * klass) (gobject_class, PROP_GMYTHTV_ENABLE_TIMING_POSITION, g_param_spec_boolean ("mythtv-enable-timing-position", "mythtv-enable-timing-position", - "Enable MythTV Live TV content size continuous updating", FALSE, - G_PARAM_READWRITE)); + "Enable MythTV Live TV content size continuous updating", + FALSE, G_PARAM_READWRITE)); g_object_class_install_property (gobject_class, PROP_GMYTHTV_CHANNEL_NUM, - g_param_spec_int ("mythtv-channel", "mythtv-channel", - "Change MythTV channel number", - -1, 99999, GST_GMYTHTV_CHANNEL_DEFAULT_NUM, G_PARAM_READWRITE)); - -#ifndef GST_DISABLE_GST_DEBUG - g_object_class_install_property - (gobject_class, PROP_GMYTHTV_DBG, - g_param_spec_boolean ("mythtv-debug", "mythtv-debug", - "Enable MythTV debug messages", FALSE, G_PARAM_READWRITE)); -#endif + g_param_spec_string ("mythtv-channel", "mythtv-channel", + "Change MythTV channel number", "", G_PARAM_READWRITE)); gstbasesrc_class->start = gst_mythtv_src_start; gstbasesrc_class->stop = gst_mythtv_src_stop; gstbasesrc_class->get_size = gst_mythtv_src_get_size; gstbasesrc_class->is_seekable = gst_mythtv_src_is_seekable; - gstbasesrc_class->do_seek = gst_mythtv_src_do_seek; gstpushsrc_class->create = gst_mythtv_src_create; @@ -237,42 +252,25 @@ gst_mythtv_src_class_init (GstMythtvSrcClass * klass) static void gst_mythtv_src_init (GstMythtvSrc * this, GstMythtvSrcClass * g_class) { - this->file_transfer = NULL; - + this->file = NULL; this->unique_setup = FALSE; - this->mythtv_version = GMYTHTV_VERSION_DEFAULT; - this->state = GST_MYTHTV_SRC_FILE_TRANSFER; - this->bytes_read = 0; - this->prev_content_size = 0; - this->content_size = 0; this->read_offset = 0; - this->content_size_last = 0; - this->live_tv = FALSE; - this->enable_timing_position = FALSE; this->update_prog_chain = FALSE; - this->user_agent = g_strdup ("mythtvsrc"); - this->mythtv_caps = NULL; this->update_prog_chain = FALSE; - - this->channel_num = GST_GMYTHTV_CHANNEL_DEFAULT_NUM; - + this->channel_name = NULL; this->eos = FALSE; - - this->bytes_queue = NULL; - this->wait_to_transfer = 0; - + this->spawn_livetv = NULL; gst_base_src_set_format (GST_BASE_SRC (this), GST_FORMAT_BYTES); - gst_pad_set_event_function (GST_BASE_SRC_PAD (GST_BASE_SRC (this)), gst_mythtv_src_handle_event); gst_pad_set_query_function (GST_BASE_SRC_PAD (GST_BASE_SRC (this)), @@ -281,101 +279,105 @@ gst_mythtv_src_init (GstMythtvSrc * this, GstMythtvSrcClass * g_class) } static void -gst_mythtv_src_finalize (GObject * gobject) +gst_mythtv_src_clear (GstMythtvSrc * mythtv_src) { - GstMythtvSrc *this = GST_MYTHTV_SRC (gobject); + mythtv_src->unique_setup = FALSE; - if (this->mythtv_caps) { - gst_caps_unref (this->mythtv_caps); - this->mythtv_caps = NULL; + if (mythtv_src->spawn_livetv) { + g_object_unref (mythtv_src->spawn_livetv); + mythtv_src->spawn_livetv = NULL; } - if (this->file_transfer) { - g_object_unref (this->file_transfer); - this->file_transfer = NULL; + if (mythtv_src->file) { + g_object_unref (mythtv_src->file); + mythtv_src->file = NULL; } - if (this->spawn_livetv) { - g_object_unref (this->spawn_livetv); - this->spawn_livetv = NULL; + if (mythtv_src->backend_info) { + g_object_unref (mythtv_src->backend_info); + mythtv_src->backend_info = NULL; } +} - if (this->backend_info) { - g_object_unref (this->backend_info); - this->backend_info = NULL; - } +static void +gst_mythtv_src_finalize (GObject * gobject) +{ + GstMythtvSrc *this = GST_MYTHTV_SRC (gobject); + + gst_mythtv_src_clear (this); if (this->uri_name) { g_free (this->uri_name); + this->uri_name = NULL; } if (this->user_agent) { g_free (this->user_agent); - } - - if (this->bytes_queue) { - g_byte_array_free (this->bytes_queue, TRUE); - this->bytes_queue = NULL; + this->user_agent = NULL; } G_OBJECT_CLASS (parent_class)->finalize (gobject); } -static gint +static GMythFileReadResult do_read_request_response (GstMythtvSrc * src, guint size, GByteArray * data_ptr) { gint read = 0; guint sizetoread = size; gint max_iters = GMYTHTV_TRANSFER_MAX_RESENDS; + GMythFileReadResult result; GST_LOG_OBJECT (src, "Starting: Reading %d bytes...", sizetoread); - /* Loop sending the Myth File Transfer request: - * Retry whilst authentication fails and we supply it. */ - gint len = 0; + result = GMYTH_FILE_READ_OK; + /* + * Loop sending the Myth File Transfer request: Retry whilst + * authentication fails and we supply it. + */ while (sizetoread == size && --max_iters > 0) { - - len = gmyth_file_transfer_read (src->file_transfer, - data_ptr, sizetoread, TRUE); - - if (len > 0) { - read += len; - sizetoread -= len; - } else if (len < 0) { - + /* + * if ( gmyth_backend_info_is_local_file(src->backend_info) ) + */ + if (IS_GMYTH_FILE_LOCAL (src->file)) + result = gmyth_file_local_read (GMYTH_FILE_LOCAL (src->file), + data_ptr, sizetoread, src->live_tv); + else if (IS_GMYTH_FILE_TRANSFER (src->file)) + result = gmyth_file_transfer_read (GMYTH_FILE_TRANSFER (src->file), + data_ptr, sizetoread, src->live_tv); + + if (data_ptr->len > 0) { + read += data_ptr->len; + sizetoread -= data_ptr->len; + } else if (data_ptr->len <= 0) { if (src->live_tv == FALSE) { - read = -1; + result = GMYTH_FILE_READ_EOF; goto eos; } else { - if (len == GMYTHTV_FILE_TRANSFER_READ_ERROR) { /* -314 */ + if (result == GMYTH_FILE_READ_ERROR) { /* -314 */ GST_INFO_OBJECT (src, "[LiveTV] FileTransfer READ_ERROR!"); - goto done; - } else if (len == GMYTHTV_FILE_TRANSFER_NEXT_PROG_CHAIN) { /* -315 */ - GST_INFO_OBJECT (src, - "[LiveTV] FileTransfer - Go to the next program chain!"); - continue; } goto done; } - - } else if (len == 0) - goto done; - + } + /* + * else if (data_ptr->len == 0) goto done; + */ if (read == sizetoread) goto done; } - if ((read < 0 && !src->live_tv) || max_iters == 0) + if ((read < 0 && !src->live_tv) || max_iters == 0) { + result = GMYTH_FILE_READ_EOF; goto eos; - + } goto done; eos: src->eos = TRUE; done: - return read; + return result; } static GstFlowReturn @@ -383,162 +385,65 @@ gst_mythtv_src_create (GstPushSrc * psrc, GstBuffer ** outbuf) { GstMythtvSrc *src; GstFlowReturn ret = GST_FLOW_OK; - gint read = -1; + GByteArray *buffer; + GMythFileReadResult result = GMYTH_FILE_READ_OK; src = GST_MYTHTV_SRC (psrc); - /* 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; + buffer = g_byte_array_new (); + if (src->live_tv) + result = do_read_request_response (src, READ_SIZE_LIVETV, buffer); + else + result = do_read_request_response (src, READ_SIZE, buffer); - GST_DEBUG_OBJECT (src, "offset = %" G_GUINT64_FORMAT ", size = %d...", - src->read_offset, MAX_READ_SIZE); + if (result == GMYTH_FILE_READ_ERROR) + goto read_error; - GST_DEBUG_OBJECT (src, "Create: buffer_remain: %d, buffer_size = %d.", - (gint) src->buffer_remain, src->bytes_queue->len); - - /* just get from the byte array, no network effort... */ - if ((src->buffer_remain = src->bytes_queue->len) < MAX_READ_SIZE) { - GByteArray *buffer = NULL; - guint buffer_size_inter = (INTERNAL_BUFFER_SIZE - src->buffer_remain); - - if (buffer_size_inter > REQUEST_MAX_SIZE) - buffer_size_inter = REQUEST_MAX_SIZE; - - buffer = g_byte_array_new (); - - read = do_read_request_response (src, buffer_size_inter, buffer); - - if (G_UNLIKELY (read < 0)) { - if (src->live_tv) - goto change_progchain; - else - goto read_error; - } else if (G_UNLIKELY (read == 0)) { - if (!src->live_tv) - goto eos; - else - goto done; - } - - if (G_UNLIKELY (src->update_prog_chain)) - goto change_progchain; - - src->bytes_queue = - g_byte_array_append (src->bytes_queue, buffer->data, read); - if (read > buffer_size_inter) - GST_WARNING_OBJECT (src, - "INCREASED buffer size! Backend sent more than we ask him... (%d)", - abs (read - buffer_size_inter)); - - src->buffer_remain += read; - - if (buffer != NULL) { - g_byte_array_free (buffer, TRUE); - buffer = NULL; - } - - GST_DEBUG_OBJECT (src, - "BYTES READ (actual) = %d, BYTES READ (cumulative) = %llu, " - "OFFSET = %llu, CONTENT SIZE = %llu.", read, - src->bytes_read, src->read_offset, src->content_size); - - } - - guint buffer_size = - (src->buffer_remain < MAX_READ_SIZE) ? src->buffer_remain : MAX_READ_SIZE; *outbuf = gst_buffer_new (); - - /* gets the first buffer_size bytes from the byte array buffer variable */ - /* guint8 *buf = g_memdup( src->bytes_queue->data, buffer_size ); */ - - GST_DEBUG_OBJECT (src, "read from network? %s!, buffer_remain = %d", - (read == - -1) ? "NO, got from buffer" : "YES, go see the backend's log file", - src->buffer_remain); - - GST_BUFFER_SIZE (*outbuf) = buffer_size; + GST_BUFFER_SIZE (*outbuf) = buffer->len; GST_BUFFER_MALLOCDATA (*outbuf) = g_malloc0 (GST_BUFFER_SIZE (*outbuf)); GST_BUFFER_DATA (*outbuf) = GST_BUFFER_MALLOCDATA (*outbuf); - g_memmove (GST_BUFFER_DATA ((*outbuf)), src->bytes_queue->data, + g_memmove (GST_BUFFER_DATA ((*outbuf)), buffer->data, GST_BUFFER_SIZE (*outbuf)); GST_BUFFER_OFFSET (*outbuf) = src->read_offset; GST_BUFFER_OFFSET_END (*outbuf) = src->read_offset + GST_BUFFER_SIZE (*outbuf); - src->buffer_remain -= GST_BUFFER_SIZE (*outbuf); - src->read_offset += GST_BUFFER_SIZE (*outbuf); src->bytes_read += GST_BUFFER_SIZE (*outbuf); - GST_DEBUG_OBJECT (src, "Buffer output with size: %d", - GST_BUFFER_SIZE (*outbuf)); - - /* flushs the newly buffer got from byte array */ - src->bytes_queue = - g_byte_array_remove_range (src->bytes_queue, 0, buffer_size); - - GST_DEBUG_OBJECT (src, "Got buffer: BUFFER --->SIZE = %d, OFFSET = %llu, " - "OFFSET_END = %llu.", GST_BUFFER_SIZE (*outbuf), - GST_BUFFER_OFFSET (*outbuf), GST_BUFFER_OFFSET_END (*outbuf)); - GST_DEBUG_OBJECT (src, "CONTENT_SIZE = %llu, BYTES_READ = %llu.", - src->content_size, src->bytes_read); + g_byte_array_free (buffer, TRUE); - if (G_UNLIKELY (src->eos) || (!src->live_tv - && (src->bytes_read >= src->content_size))) - goto eos; - -done: - { - const gchar *reason = gst_flow_get_name (ret); + if (result == GMYTH_FILE_READ_NEXT_PROG_CHAIN) { + GstPad *peer; - GST_DEBUG_OBJECT (src, "DONE task, reason %s", reason); - return ret; - } -eos: - { - const gchar *reason = gst_flow_get_name (ret); + peer = gst_pad_get_peer (GST_BASE_SRC_PAD (GST_BASE_SRC (psrc))); + gst_pad_send_event (peer, + gst_event_new_new_segment (FALSE, 1.0, GST_FORMAT_BYTES, 0, -1, 0)); - GST_DEBUG_OBJECT (src, "pausing task, reason %s", reason); - return GST_FLOW_UNEXPECTED; - } - /* ERRORS */ -read_error: - { - GST_ELEMENT_ERROR (src, RESOURCE, READ, - (NULL), ("Could not read any bytes (%i, %s)", read, src->uri_name)); - return GST_FLOW_ERROR; + gst_object_unref (peer); } -change_progchain: - { - GST_ELEMENT_ERROR (src, RESOURCE, READ, - (NULL), ("Seek failed, go to the next program info... (%i, %s)", read, - src->uri_name)); - gst_pad_push_event (GST_BASE_SRC_PAD (GST_BASE_SRC (psrc)), - gst_event_new_new_segment (TRUE, 1.0, GST_FORMAT_TIME, 0, -1, 0)); - /* go to the next program chain */ - src->unique_setup = FALSE; - src->update_prog_chain = TRUE; + if (src->eos || (!src->live_tv && (src->bytes_read >= src->content_size))) + ret = GST_FLOW_UNEXPECTED; - gst_mythtv_src_next_program_chain (src); - - return GST_FLOW_ERROR_NO_DATA; - } + return ret; +read_error: + GST_ELEMENT_ERROR (src, RESOURCE, READ, + (NULL), ("Could not read any bytes (%i, %s)", read, src->uri_name)); + return GST_FLOW_ERROR; } gint64 gst_mythtv_src_get_position (GstMythtvSrc * src) { - gint64 size_tmp = 0; guint max_tries = 2; - if (src->live_tv == TRUE && (abs (src->content_size - src->bytes_read) < + if (src->live_tv == TRUE && + (abs (src->content_size - src->bytes_read) < GMYTHTV_TRANSFER_MAX_BUFFER)) { get_file_pos: @@ -549,12 +454,12 @@ gst_mythtv_src_get_position (GstMythtvSrc * src) else if (size_tmp > 0 && --max_tries > 0) goto get_file_pos; GST_LOG_OBJECT (src, "GET_POSITION: file_position = %lld", size_tmp); - /* sets the last content size amount before it can be updated */ + /* + * sets the last content size amount before it can be updated + */ src->prev_content_size = src->content_size; } - return src->content_size; - } static gboolean @@ -573,20 +478,19 @@ gst_mythtv_src_do_seek (GstBaseSrc * base, GstSegment * segment) GST_LOG_OBJECT (src, "Trying to seek at the value (actual_seek = %lld, read_offset = %lld)", actual_seek, src->read_offset); - /* verify if it needs to seek */ + /* + * verify if it needs to seek + */ if (src->read_offset != actual_seek) { - - new_offset = - gmyth_file_transfer_seek (src->file_transfer, segment->start, SEEK_SET); - - GST_LOG_OBJECT (src, - "Segment offset start = %lld, SRC Offset = %lld, NEW actual backend SEEK Offset = %lld.", - segment->start, src->read_offset, new_offset); + if (IS_GMYTH_FILE_LOCAL (src->file)) + new_offset = gmyth_file_local_seek (GMYTH_FILE_LOCAL (src->file), + segment->start, G_SEEK_SET); + else if (IS_GMYTH_FILE_TRANSFER (src->file)) + new_offset = gmyth_file_transfer_seek (GMYTH_FILE_TRANSFER (src->file), + segment->start, SEEK_SET); if (G_UNLIKELY (new_offset < 0)) { ret = FALSE; - if (src->live_tv) - goto change_progchain; - else + if (!src->live_tv) goto eos; } @@ -595,38 +499,19 @@ gst_mythtv_src_do_seek (GstBaseSrc * base, GstSegment * segment) if (ret == FALSE) { GST_INFO_OBJECT (src, "Failed to set the SEEK on segment!"); } - } done: return ret; eos: - { - - GST_DEBUG_OBJECT (src, "EOS found on seeking!!!"); - return FALSE; - } -change_progchain: - { - GST_ELEMENT_ERROR (src, RESOURCE, READ, - (NULL), ("Seek failed, go to the next program info... (%i, %s)", read, - src->uri_name)); - - gst_pad_push_event (GST_BASE_SRC_PAD (base), - gst_event_new_new_segment (TRUE, 1.0, GST_FORMAT_TIME, 0, -1, 0)); - /* go to the next program chain */ - src->unique_setup = FALSE; - src->update_prog_chain = TRUE; - - gst_mythtv_src_next_program_chain (src); - - return TRUE; - } - + GST_DEBUG_OBJECT (src, "EOS found on seeking!!!"); + return FALSE; } -/* create a socket for connecting to remote server */ +/* + * create a socket for connecting to remote server + */ static gboolean gst_mythtv_src_start (GstBaseSrc * bsrc) { @@ -635,9 +520,7 @@ gst_mythtv_src_start (GstBaseSrc * bsrc) GString *chain_id_local = NULL; GMythURI *gmyth_uri = NULL; gboolean ret = TRUE; - - if (G_UNLIKELY (src->update_prog_chain)) - goto change_progchain; + GstMessage *msg; if (src->unique_setup == FALSE) { src->unique_setup = TRUE; @@ -646,86 +529,112 @@ gst_mythtv_src_start (GstBaseSrc * bsrc) } gmyth_uri = gmyth_uri_new_with_value (src->uri_name); - src->backend_info = gmyth_backend_info_new_with_uri (src->uri_name); - /* testing UPnP... */ - /* gmyth_backend_info_set_hostname( src->backend_info, NULL ); */ - if (src->live_tv || gmyth_uri_is_livetv (gmyth_uri)) { - gint ch; + src->live_tv = gmyth_uri_is_livetv (gmyth_uri); + + if (src->live_tv) { + src->spawn_livetv = gmyth_livetv_new (src->backend_info); + gchar *ch = gmyth_uri_get_channel_name (gmyth_uri); - src->spawn_livetv = gmyth_livetv_new (); + if (ch != NULL) + src->channel_name = ch; - ch = gmyth_uri_get_channel_num (gmyth_uri); - if (ch != -1) - src->channel_num = ch; + if (src->channel_name != NULL) { + gboolean result; - if (src->channel_num != GST_GMYTHTV_CHANNEL_DEFAULT_NUM) { - if (gmyth_livetv_channel_setup (src->spawn_livetv, src->channel_num, - src->backend_info) == FALSE) { + result = gmyth_livetv_channel_name_setup (src->spawn_livetv, + src->channel_name); + if (result == FALSE) { GST_INFO_OBJECT (src, "LiveTV setup felt down on error"); ret = FALSE; goto init_failed; } } else { - if (gmyth_livetv_setup (src->spawn_livetv, src->backend_info) == FALSE) { + if (gmyth_livetv_setup (src->spawn_livetv) == FALSE) { GST_INFO_OBJECT (src, "LiveTV setup felt down on error"); ret = FALSE; goto init_failed; } } - src->file_transfer = gmyth_livetv_create_file_transfer (src->spawn_livetv); - - if (NULL == src->file_transfer) { + src->file = + GMYTH_FILE (gmyth_livetv_create_file_transfer (src->spawn_livetv)); + if (NULL == src->file) { GST_INFO_OBJECT (src, "[LiveTV] FileTransfer equals to NULL"); ret = FALSE; goto init_failed; } - } else { - - src->file_transfer = gmyth_file_transfer_new (src->backend_info); - - ret = gmyth_file_transfer_open (src->file_transfer, src->uri_name); + /* + * Check if the file is local to this specific client renderer + */ + if (gmyth_uri_is_local_file (gmyth_uri)) + ret = gmyth_file_local_open (GMYTH_FILE_LOCAL (src->file)); + else + ret = gmyth_file_transfer_open (GMYTH_FILE_TRANSFER (src->file), + (src->spawn_livetv->uri != NULL ? + gmyth_uri_get_path (src->spawn_livetv->uri) : + src->spawn_livetv->proginfo->pathname->str)); + /* + * sets the mythtvsrc "location" property + */ + g_object_set (src, "location", gmyth_file_get_uri (src->file), NULL); + + if (!ret) { + GST_INFO_OBJECT (src, + "Error: couldn't open the FileTransfer from LiveTV source!"); + g_object_unref (src->file); + src->file = NULL; + goto init_failed; + } + } /* If live-tv */ + else { + /* + * Check if the file is local to this specific client renderer, + * and tries to open a local connection + */ + if (gmyth_uri_is_local_file (gmyth_uri)) { + src->file = GMYTH_FILE (gmyth_file_local_new (src->backend_info)); + ret = gmyth_file_local_open (GMYTH_FILE_LOCAL (src->file)); + } else { + src->file = GMYTH_FILE (gmyth_file_transfer_new (src->backend_info)); + ret = + gmyth_file_transfer_open (GMYTH_FILE_TRANSFER (src->file), + src->uri_name); + } } - if (NULL == src->file_transfer) { + if (NULL == src->file) { GST_INFO_OBJECT (src, "FileTransfer is NULL"); goto init_failed; } - /*GST_INFO_OBJECT( src, "uri = %s", src->spawn_livetv->file_transfer); */ if (ret == FALSE) { -#ifndef GST_DISABLE_GST_DEBUG - if (src->mythtv_msgs_dbg) - GST_INFO_OBJECT (src, - "MythTV FileTransfer request failed when setting up socket connection!"); -#endif + GST_INFO_OBJECT (src, + "MythTV FileTransfer request failed when setting up socket connection!"); goto begin_req_failed; } GST_INFO_OBJECT (src, "MythTV FileTransfer filesize = %lld, content_size = %lld!", - src->file_transfer->filesize, src->content_size); + gmyth_file_get_filesize (src->file), src->content_size); - src->content_size = src->file_transfer->filesize; + src->content_size = gmyth_file_get_filesize (src->file); - src->do_start = FALSE; + msg = gst_message_new_duration (GST_OBJECT (src), GST_FORMAT_BYTES, + src->content_size); + gst_element_post_message (GST_ELEMENT (src), msg); - /* this is used for the buffer cache */ - src->bytes_queue = g_byte_array_sized_new (INTERNAL_BUFFER_SIZE); - src->buffer_remain = 0; + src->do_start = FALSE; gst_pad_push_event (GST_BASE_SRC_PAD (GST_BASE_SRC (src)), - gst_event_new_new_segment (TRUE, 1.0, GST_FORMAT_TIME, 0, - src->content_size, 0)); - + gst_event_new_new_segment (TRUE, 1.0, + GST_FORMAT_TIME, 0, src->content_size, 0)); done: - /*if ( gmyth_uri != NULL ) - { - g_object_unref( gmyth_uri ); - gmyth_uri = NULL; - } */ + if (gmyth_uri != NULL) { + g_object_unref (gmyth_uri); + gmyth_uri = NULL; + } if (chain_id_local != NULL) { g_string_free (chain_id_local, TRUE); @@ -734,156 +643,39 @@ done: return TRUE; - /* ERRORS */ + /* + * ERRORS + */ init_failed: - { - if (src->spawn_livetv != NULL) - g_object_unref (src->spawn_livetv); - - GST_ELEMENT_ERROR (src, LIBRARY, INIT, - (NULL), ("Could not initialize MythTV library (%i, %s)", ret, - src->uri_name)); - return FALSE; - } -begin_req_failed: - { - GST_ELEMENT_ERROR (src, LIBRARY, INIT, - (NULL), ("Could not begin request sent to MythTV server (%i, %s)", ret, - src->uri_name)); - return FALSE; - } -change_progchain: - { - GST_ELEMENT_ERROR (src, RESOURCE, READ, - (NULL), ("Seek failed, go to the next program info... (%s)", - src->uri_name)); - - gst_pad_push_event (GST_BASE_SRC_PAD (GST_BASE_SRC (src)), - gst_event_new_new_segment (TRUE, 1.0, GST_FORMAT_TIME, 0, -1, 0)); - - /* go to the next program chain */ - src->unique_setup = FALSE; - src->update_prog_chain = TRUE; - - gst_mythtv_src_next_program_chain (src); - - return TRUE; - } -} - -/* create a new socket for connecting to the next program chain */ -static gboolean -gst_mythtv_src_next_program_chain (GstMythtvSrc * src) -{ - GString *chain_id_local = NULL; - - gboolean ret = TRUE; - - if (!src->live_tv) - goto init_failed; - - if (src->unique_setup == FALSE) { - src->unique_setup = TRUE; - } else { - goto done; + if (gmyth_uri != NULL) { + g_object_unref (gmyth_uri); + gmyth_uri = NULL; } - GST_PAD_STREAM_LOCK (GST_BASE_SRC_PAD (GST_BASE_SRC (src))); - - if (src->file_transfer) { - g_object_unref (src->file_transfer); - src->file_transfer = NULL; - } - - if (src->uri_name) { - g_free (src->uri_name); + if (src->spawn_livetv != NULL) { + g_object_unref (src->spawn_livetv); + src->spawn_livetv = NULL; } - if (src->backend_info == NULL) - src->backend_info = gmyth_backend_info_new_with_uri (src->uri_name); + GST_ELEMENT_ERROR (src, LIBRARY, INIT, + (NULL), + ("Could not initialize MythTV library (%i, %s)", ret, src->uri_name)); - if (src->live_tv) { - if (gmyth_livetv_next_program_chain (src->spawn_livetv) == FALSE) { - GST_INFO_OBJECT (src, "Failed to go to the next program chain!"); - ret = FALSE; - goto init_failed; - } - /* set up the uri variable */ - src->uri_name = g_strdup (src->spawn_livetv->proginfo->pathname->str); - chain_id_local = gmyth_tvchain_get_id (src->spawn_livetv->tvchain); - if (chain_id_local != NULL) { - src->live_chain_id = g_strdup (chain_id_local->str); - GST_DEBUG_OBJECT (src, "Local chain ID = %s", src->live_chain_id); - } - src->live_tv_id = src->spawn_livetv->recorder->recorder_num; - GST_LOG_OBJECT (src, "LiveTV id = %d, URI path = %s", - src->live_tv_id, src->uri_name); - } - src->file_transfer = gmyth_file_transfer_new (src->backend_info); + gst_mythtv_src_clear (src); - if (src->file_transfer == NULL) { - goto init_failed; - } - - ret = gmyth_file_transfer_open (src->file_transfer, src->uri_name); - - /* sets the Playback monitor connection */ - - /* sets the FileTransfer instance connection (video/audio download) */ - - if (ret == FALSE) { -#ifndef GST_DISABLE_GST_DEBUG - if (src->mythtv_msgs_dbg) - GST_ERROR_OBJECT (src, - "MythTV FileTransfer request failed when setting up socket connection!"); -#endif - goto begin_req_failed; - } - src->content_size_last = src->content_size; - - src->content_size = src->file_transfer->filesize; - if (src->live_tv) { - src->wait_to_transfer = 0; - while (src->wait_to_transfer++ < GMYTHTV_TRANSFER_MAX_WAITS && - src->content_size < GMYTHTV_TRANSFER_MAX_BUFFER) - src->content_size = gst_mythtv_src_get_position (src); - } - - src->read_offset = 0; - - if (src->bytes_queue != NULL) { - g_byte_array_free (src->bytes_queue, TRUE); - } - - src->bytes_queue = g_byte_array_sized_new (INTERNAL_BUFFER_SIZE); - -done: - src->update_prog_chain = FALSE; - - GST_PAD_STREAM_UNLOCK (GST_BASE_SRC_PAD (GST_BASE_SRC (src))); - - return TRUE; - - /* ERRORS */ -init_failed: - { - if (src->spawn_livetv != NULL) - g_object_unref (src->spawn_livetv); - - GST_ELEMENT_ERROR (src, LIBRARY, INIT, - (NULL), ("Could not initialize MythTV library (%i, %s)", ret, - src->uri_name)); - return FALSE; - } + return FALSE; begin_req_failed: - { - GST_ELEMENT_ERROR (src, LIBRARY, INIT, - (NULL), ("Could not begin request sent to MythTV server (%i, %s)", ret, - src->uri_name)); - return FALSE; + if (gmyth_uri != NULL) { + g_object_unref (gmyth_uri); + gmyth_uri = NULL; } + GST_ELEMENT_ERROR (src, LIBRARY, INIT, + (NULL), + ("Could not begin request sent to MythTV server (%i, %s)", + ret, src->uri_name)); + return FALSE; } static gboolean @@ -892,7 +684,8 @@ gst_mythtv_src_get_size (GstBaseSrc * bsrc, guint64 * size) GstMythtvSrc *src = GST_MYTHTV_SRC (bsrc); gboolean ret = TRUE; - GST_LOG_OBJECT (src, "Differs from previous content size: %d (max.: %d)", + GST_LOG_OBJECT (src, + "Differs from previous content size: %d (max.: %d)", abs (src->content_size - src->prev_content_size), GMYTHTV_TRANSFER_MAX_BUFFER); @@ -901,45 +694,31 @@ gst_mythtv_src_get_size (GstBaseSrc * bsrc, guint64 * size) } else if (src->live_tv && src->enable_timing_position && (abs (src->content_size - src->bytes_read) < GMYTHTV_TRANSFER_MAX_BUFFER)) { + gint64 new_offset; - gint64 new_offset = - gmyth_recorder_get_file_position (src->spawn_livetv->recorder); + new_offset = gmyth_recorder_get_file_position (src->spawn_livetv->recorder); if (new_offset > 0 && new_offset > src->content_size) { src->content_size = new_offset; } else if (new_offset < src->content_size) { src->update_prog_chain = TRUE; } - } *size = src->content_size; GST_LOG_OBJECT (src, "Content size = %lld", src->content_size); - return ret; - } -/* close the socket and associated resources - * used both to recover from errors and go to NULL state */ +/* + * close the socket and associated resources used both to recover from + * errors and go to NULL state + */ static gboolean gst_mythtv_src_stop (GstBaseSrc * bsrc) { - GstMythtvSrc *src; - - src = GST_MYTHTV_SRC (bsrc); - - if (src->uri_name) { - g_free (src->uri_name); - src->uri_name = NULL; - } - - if (src->mythtv_caps) { - gst_caps_unref (src->mythtv_caps); - src->mythtv_caps = NULL; - } - - src->eos = FALSE; + GstMythtvSrc *src = GST_MYTHTV_SRC (bsrc); + gst_mythtv_src_clear (src); return TRUE; } @@ -948,12 +727,10 @@ gst_mythtv_src_handle_event (GstPad * pad, GstEvent * event) { GstMythtvSrc *src = GST_MYTHTV_SRC (GST_PAD_PARENT (pad)); gint64 cont_size = 0; - gboolean ret = FALSE; + gboolean ret = TRUE; switch (GST_EVENT_TYPE (event)) { case GST_EVENT_EOS: - GST_WARNING_OBJECT (src, "Got EOS event"); - if (src->live_tv) { cont_size = gst_mythtv_src_get_position (src); if (cont_size > src->content_size) { @@ -969,7 +746,7 @@ gst_mythtv_src_handle_event (GstPad * pad, GstEvent * event) default: ret = gst_pad_event_default (pad, event); } - + GST_DEBUG_OBJECT (src, "HANDLE EVENT %d", ret); return ret; } @@ -986,9 +763,9 @@ gst_mythtv_src_handle_query (GstPad * pad, GstQuery * query) GstMythtvSrc *myth = GST_MYTHTV_SRC (gst_pad_get_parent (pad)); GstFormat formt; + switch (GST_QUERY_TYPE (query)) { case GST_QUERY_POSITION: - { gst_query_parse_position (query, &formt, NULL); if (formt == GST_FORMAT_BYTES) { gst_query_set_position (query, formt, myth->read_offset); @@ -998,35 +775,21 @@ gst_mythtv_src_handle_query (GstPad * pad, GstQuery * query) res = gst_pad_query_default (pad, query); } break; - } case GST_QUERY_DURATION: - { -#if 0 - if (myth->duration != 0) { - gint64 total; - gint64 fps; - - fps = nuv->h->i_fpsn / nuv->h->i_fpsd; - total = - gst_util_uint64_scale_int (GST_SECOND, nuv->h->i_video_blocks, fps); - } -#endif - gst_query_parse_duration (query, &formt, NULL); if (formt == GST_FORMAT_BYTES) { - gst_query_set_duration (query, formt, myth->content_size); - GST_DEBUG_OBJECT (myth, "SIZE %" G_GINT64_FORMAT, myth->content_size); + gint64 size = myth->content_size; + + gst_query_set_duration (query, GST_FORMAT_BYTES, 10); + GST_DEBUG_OBJECT (myth, "SIZE %" G_GINT64_FORMAT, size); res = TRUE; } else if (formt == GST_FORMAT_TIME) { res = gst_pad_query_default (pad, query); } break; - } default: - { res = gst_pad_query_default (pad, query); break; - } } gst_object_unref (myth); @@ -1044,11 +807,15 @@ gst_mythtv_src_change_state (GstElement * element, GstStateChange transition) case GST_STATE_CHANGE_NULL_TO_READY: break; case GST_STATE_CHANGE_READY_TO_PAUSED: + if (!src->uri_name) { + GST_WARNING_OBJECT (src, "Invalid location"); + return ret; + } break; case GST_STATE_CHANGE_PAUSED_TO_PLAYING: if (src->live_tv) { - if (!gmyth_recorder_send_frontend_ready_command (src->spawn_livetv-> - recorder)) + if (!gmyth_recorder_send_frontend_ready_command + (src->spawn_livetv->recorder)) GST_WARNING_OBJECT (src, "Couldn't send the FRONTEND_READY message to the backend!"); else @@ -1060,22 +827,16 @@ gst_mythtv_src_change_state (GstElement * element, GstStateChange transition) } ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition); - if (ret == GST_STATE_CHANGE_FAILURE) + if (ret == GST_STATE_CHANGE_FAILURE) { return ret; + } switch (transition) { case GST_STATE_CHANGE_READY_TO_NULL: + gst_mythtv_src_clear (src); break; case GST_STATE_CHANGE_PLAYING_TO_PAUSED: case GST_STATE_CHANGE_PAUSED_TO_READY: - if (src->live_tv) { - if (!gmyth_recorder_send_frontend_ready_command (src->spawn_livetv-> - recorder)) - GST_WARNING_OBJECT (src, - "Couldn't send the FRONTEND_READY message to the backend!"); - else - GST_DEBUG_OBJECT (src, "FRONTEND_READY was sent to the backend"); - } break; default: break; @@ -1093,7 +854,6 @@ gst_mythtv_src_set_property (GObject * object, guint prop_id, GST_OBJECT_LOCK (mythtvsrc); switch (prop_id) { case PROP_LOCATION: - { if (!g_value_get_string (value)) { GST_WARNING ("location property cannot be NULL"); break; @@ -1104,40 +864,23 @@ gst_mythtv_src_set_property (GObject * object, guint prop_id, mythtvsrc->uri_name = NULL; } mythtvsrc->uri_name = g_value_dup_string (value); - - break; - } -#ifndef GST_DISABLE_GST_DEBUG - case PROP_GMYTHTV_DBG: - { - mythtvsrc->mythtv_msgs_dbg = g_value_get_boolean (value); break; - } -#endif case PROP_GMYTHTV_VERSION: - { mythtvsrc->mythtv_version = g_value_get_int (value); break; - } case PROP_GMYTHTV_LIVEID: - { mythtvsrc->live_tv_id = g_value_get_int (value); break; - } case PROP_GMYTHTV_LIVE: - { mythtvsrc->live_tv = g_value_get_boolean (value); break; - } case PROP_GMYTHTV_ENABLE_TIMING_POSITION: - { mythtvsrc->enable_timing_position = g_value_get_boolean (value); break; - } case PROP_GMYTHTV_LIVE_CHAINID: - { if (!g_value_get_string (value)) { - GST_WARNING ("MythTV Live chainid property cannot be NULL"); + GST_WARNING_OBJECT (object, + "MythTV Live chainid property cannot be NULL"); break; } @@ -1147,12 +890,9 @@ gst_mythtv_src_set_property (GObject * object, guint prop_id, } mythtvsrc->live_chain_id = g_value_dup_string (value); break; - } case PROP_GMYTHTV_CHANNEL_NUM: - { - mythtvsrc->channel_num = g_value_get_int (value); + mythtvsrc->channel_name = g_value_dup_string (value); break; - } default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; @@ -1170,33 +910,14 @@ gst_mythtv_src_get_property (GObject * object, guint prop_id, GST_OBJECT_LOCK (mythtvsrc); switch (prop_id) { case PROP_LOCATION: - { - gchar *str = g_strdup (""); - - if (mythtvsrc->uri_name == NULL) { - g_free (mythtvsrc->uri_name); - mythtvsrc->uri_name = NULL; - } else { - str = g_strdup (mythtvsrc->uri_name); - } - g_value_set_string (value, str); + g_value_set_string (value, mythtvsrc->uri_name); break; - } -#ifndef GST_DISABLE_GST_DEBUG - case PROP_GMYTHTV_DBG: - g_value_set_boolean (value, mythtvsrc->mythtv_msgs_dbg); - break; -#endif case PROP_GMYTHTV_VERSION: - { g_value_set_int (value, mythtvsrc->mythtv_version); break; - } case PROP_GMYTHTV_LIVEID: - { g_value_set_int (value, mythtvsrc->live_tv_id); break; - } case PROP_GMYTHTV_LIVE: g_value_set_boolean (value, mythtvsrc->live_tv); break; @@ -1204,23 +925,11 @@ gst_mythtv_src_get_property (GObject * object, guint prop_id, g_value_set_boolean (value, mythtvsrc->enable_timing_position); break; case PROP_GMYTHTV_LIVE_CHAINID: - { - gchar *str = g_strdup (""); - - if (mythtvsrc->live_chain_id == NULL) { - g_free (mythtvsrc->live_chain_id); - mythtvsrc->live_chain_id = NULL; - } else { - str = g_strdup (mythtvsrc->live_chain_id); - } - g_value_set_string (value, str); + g_value_set_string (value, mythtvsrc->live_chain_id); break; - } case PROP_GMYTHTV_CHANNEL_NUM: - { - g_value_set_int (value, mythtvsrc->channel_num); + g_value_set_string (value, mythtvsrc->channel_name); break; - } default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; @@ -1273,7 +982,8 @@ gst_mythtv_src_uri_set_uri (GstURIHandler * handler, const gchar * uri) gchar *protocol; protocol = gst_uri_get_protocol (uri); - if ((strcmp (protocol, "myth") != 0) && (strcmp (protocol, "myths") != 0)) { + if ((strcmp (protocol, "myth") != 0) + && (strcmp (protocol, "myths") != 0)) { g_free (protocol); return FALSE; } diff --git a/ext/mythtv/gstmythtvsrc.h b/ext/mythtv/gstmythtvsrc.h index 5765dd1e..75c6de5b 100644 --- a/ext/mythtv/gstmythtvsrc.h +++ b/ext/mythtv/gstmythtvsrc.h @@ -1,20 +1,19 @@ -/* GStreamer - * Copyright (C) <2006> Rosfran Borges <rosfran.borges@indt.org.br> +/* + * GStreamer + * Copyright (C) <2006> INdT - Rosfran Borges <rosfran.borges@indt.org.br> + * Copyright (C) <2007> INdT - Rentao Filho <renato.filho@indt.org.br> * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Library General Public - * License as published by the Free Software Foundation; either - * version 2 of the License, or (at your option) any later version. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Library General Public License for more details. - * - * You should have received a copy of the GNU Library General Public - * License along with this library; if not, write to the - * Free Software Foundation, Inc., 59 Temple Place - Suite 330, - * Boston, MA 02111-1307, USA. + * This library is free software; you can + * redistribute it and/or modify it under the terms of the GNU Library + * General Public License as published by the Free Software Foundation; + * either version 2 of the License, or (at your option) any later version. + * This library is distributed in the hope that it will be useful, but + * WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Library + * General Public License for more details. You should have received a copy + * of the GNU Library General Public License along with this library; if + * not, write to the Free Software Foundation, Inc., 59 Temple Place - Suite + * 330, Boston, MA 02111-1307, USA. */ #ifndef __GST_MYTHTV_SRC_H__ @@ -26,12 +25,13 @@ #include <stdio.h> #include <gmyth/gmyth_socket.h> +#include <gmyth/gmyth_file.h> #include <gmyth/gmyth_file_transfer.h> +#include <gmyth/gmyth_file_local.h> #include <gmyth/gmyth_livetv.h> #include <gmyth/gmyth_backendinfo.h> G_BEGIN_DECLS - #define GST_TYPE_MYTHTV_SRC \ (gst_mythtv_src_get_type()) #define GST_MYTHTV_SRC(obj) \ @@ -42,90 +42,60 @@ G_BEGIN_DECLS (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_MYTHTV_SRC)) #define GST_IS_MYTHTV_SRC_CLASS(klass) \ (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_MYTHTV_SRC)) - typedef struct _GstMythtvSrc GstMythtvSrc; typedef struct _GstMythtvSrcClass GstMythtvSrcClass; -typedef enum { +typedef enum { GST_MYTHTV_SRC_FILE_TRANSFER, GST_MYTHTV_SRC_NEXT_PROGRAM_CHAIN, GST_MYTHTV_SRC_INVALID_DATA } GstMythtvState; struct _GstMythtvSrc { - GstPushSrc element; + GstPushSrc element; - /* MythFileTransfer */ - GMythFileTransfer *file_transfer; - - GMythLiveTV *spawn_livetv; - + /* + * MythFileTransfer + */ + GMythFile *file; + GMythLiveTV *spawn_livetv; GMythBackendInfo *backend_info; - - GstMythtvState state; - - gchar *uri_name; - gchar *user_agent; - - gchar *live_chain_id; - - gint mythtv_version; - - gint64 content_size; - - gint64 prev_content_size; - - gint64 content_size_last; - - guint64 bytes_read; - - gint64 read_offset; - - gint buffer_remain; - - gboolean eos; - - gboolean do_start; - - gboolean unique_setup; - - gboolean live_tv; - - gboolean enable_timing_position; - - gint live_tv_id; - - gint channel_num; - - guint mode; - - /* MythTV capabilities */ - GstCaps *mythtv_caps; - - GstPad *sinkpad; - - GStaticRecMutex *th_mutex; - - GByteArray *bytes_queue; - -#ifndef GST_DISABLE_GST_DEBUG - /* enable Myth TV debug messages */ - gboolean mythtv_msgs_dbg; -#endif - - gboolean update_prog_chain; - - /* stablish a maximum iteration value to the IS_RECORDING message */ - guint wait_to_transfer; - + GstMythtvState state; + gchar *uri_name; + gchar *user_agent; + gchar *live_chain_id; + gint mythtv_version; + gint64 content_size; + gint64 prev_content_size; + gint64 content_size_last; + guint64 bytes_read; + gint64 read_offset; + gboolean eos; + gboolean do_start; + gboolean unique_setup; + gboolean live_tv; + gboolean enable_timing_position; + gint live_tv_id; + gchar *channel_name; + guint mode; + + /* + * MythTV capabilities + */ + GstCaps *mythtv_caps; + gboolean update_prog_chain; + + /* + * stablish a maximum iteration value to the IS_RECORDING message + */ + guint wait_to_transfer; }; struct _GstMythtvSrcClass { GstPushSrcClass parent_class; }; -GType gst_mythtv_src_get_type (void); +GType gst_mythtv_src_get_type(void); G_END_DECLS - #endif /* __GST_MYTHTV_SRC_H__ */ |