mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-09-08 21:28:45 +00:00
Code Issues 1 Projects Releases Wiki Activity

ext/mythtv/gstmythtvsrc.c: Clean up a bit, mostly the debug statements; fix deadlock in _set_property() in the error ...

Browse source 
Original commit message from CVS:
* ext/mythtv/gstmythtvsrc.c: (do_read_request_response),
(gst_mythtv_src_create), (gst_mythtv_src_get_position),
(gst_mythtv_src_do_seek), (gst_mythtv_src_start),
(gst_mythtv_src_next_program_chain), (gst_mythtv_src_get_size),
(gst_mythtv_src_handle_event), (gst_mythtv_src_handle_query),
(gst_mythtv_src_change_state), (gst_mythtv_src_set_property),
(gst_mythtv_src_uri_get_type):
Clean up a bit, mostly the debug statements; fix deadlock in
_set_property() in the error cases; fix up query function.
This commit is contained in:
Tim-Philipp Müller 2007-01-13 12:37:55 +00:00
parent 57f11c5ed8
commit 96ba4fcc58
2 changed files with 68 additions and 94 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
ChangeLog
View file

@ -1,3 +1,15 @@
2007-01-13 Tim-Philipp Müller <tim at centricular dot net>
* ext/mythtv/gstmythtvsrc.c: (do_read_request_response),
(gst_mythtv_src_create), (gst_mythtv_src_get_position),
(gst_mythtv_src_do_seek), (gst_mythtv_src_start),
(gst_mythtv_src_next_program_chain), (gst_mythtv_src_get_size),
(gst_mythtv_src_handle_event), (gst_mythtv_src_handle_query),
(gst_mythtv_src_change_state), (gst_mythtv_src_set_property),
(gst_mythtv_src_uri_get_type):
Clean up a bit, mostly the debug statements; fix deadlock in
_set_property() in the error cases; fix up query function.
2007-01-12 Andy Wingo <wingo@pobox.com> 2007-01-12 Andy Wingo <wingo@pobox.com>
* ext/ladspa/gstsignalprocessor.c (gst_signal_processor_fixate) * ext/ladspa/gstsignalprocessor.c (gst_signal_processor_fixate)
@ -19,7 +31,7 @@
* ext/mythtv/Makefile.am: * ext/mythtv/Makefile.am:
* ext/mythtv/gstmythtvsrc.c: * ext/mythtv/gstmythtvsrc.c:
* ext/mythtv/gstmythtvsrc.h: * ext/mythtv/gstmythtvsrc.h:
MythTV client source plugin created. MythTV client source plugin created (#354451).
2007-01-12 Wim Taymans <wim@fluendo.com> 2007-01-12 Wim Taymans <wim@fluendo.com>

148
ext/mythtv/gstmythtvsrc.c
View file

@ -325,8 +325,7 @@ do_read_request_response (GstMythtvSrc * src, guint size, GByteArray * data_ptr)
guint sizetoread = size; guint sizetoread = size;
gint max_iters = GMYTHTV_TRANSFER_MAX_RESENDS; gint max_iters = GMYTHTV_TRANSFER_MAX_RESENDS;
GST_LOG_OBJECT (src, "Starting: [%s] Reading %d bytes...", __FUNCTION__, GST_LOG_OBJECT (src, "Starting: Reading %d bytes...", sizetoread);
sizetoread);
/* Loop sending the Myth File Transfer request: /* Loop sending the Myth File Transfer request:
* Retry whilst authentication fails and we supply it. */ * Retry whilst authentication fails and we supply it. */
@ -347,13 +346,11 @@ do_read_request_response (GstMythtvSrc * src, guint size, GByteArray * data_ptr)
goto eos; goto eos;
} else { } else {
if (len == GMYTHTV_FILE_TRANSFER_READ_ERROR) { /* -314 */ if (len == GMYTHTV_FILE_TRANSFER_READ_ERROR) { /* -314 */
GST_INFO_OBJECT (src, "[%s] [LiveTV] FileTransfer READ_ERROR!", GST_INFO_OBJECT (src, "[LiveTV] FileTransfer READ_ERROR!");
__FUNCTION__);
goto done; goto done;
} else if (len == GMYTHTV_FILE_TRANSFER_NEXT_PROG_CHAIN) { /* -315 */ } else if (len == GMYTHTV_FILE_TRANSFER_NEXT_PROG_CHAIN) { /* -315 */
GST_INFO_OBJECT (src, GST_INFO_OBJECT (src,
"[%s] [LiveTV] FileTransfer - Go to the next program chain!", "[LiveTV] FileTransfer - Go to the next program chain!");
__FUNCTION__);
continue; continue;
} }
goto done; goto done;
@ -393,11 +390,11 @@ gst_mythtv_src_create (GstPushSrc * psrc, GstBuffer ** outbuf)
if (G_UNLIKELY (src->update_prog_chain)) if (G_UNLIKELY (src->update_prog_chain))
goto change_progchain; goto change_progchain;
GST_DEBUG_OBJECT (src, "[%s] offset = %llu, size = %d...", __FUNCTION__, GST_DEBUG_OBJECT (src, "offset = %" G_GUINT64_FORMAT ", size = %d...",
src->read_offset, MAX_READ_SIZE); src->read_offset, MAX_READ_SIZE);
GST_DEBUG_OBJECT (src, "[%s]Create: buffer_remain: %d, buffer_size = %d.", GST_DEBUG_OBJECT (src, "Create: buffer_remain: %d, buffer_size = %d.",
__FUNCTION__, (gint) src->buffer_remain, src->bytes_queue->len); (gint) src->buffer_remain, src->bytes_queue->len);
/* just get from the byte array, no network effort... */ /* just get from the byte array, no network effort... */
if ((src->buffer_remain = src->bytes_queue->len) < MAX_READ_SIZE) { if ((src->buffer_remain = src->bytes_queue->len) < MAX_READ_SIZE) {
@ -430,8 +427,8 @@ gst_mythtv_src_create (GstPushSrc * psrc, GstBuffer ** outbuf)
g_byte_array_append (src->bytes_queue, buffer->data, read); g_byte_array_append (src->bytes_queue, buffer->data, read);
if (read > buffer_size_inter) if (read > buffer_size_inter)
GST_WARNING_OBJECT (src, GST_WARNING_OBJECT (src,
"[%s]INCREASED buffer size! Backend sent more than we ask him... (%d)", "INCREASED buffer size! Backend sent more than we ask him... (%d)",
__FUNCTION__, abs (read - buffer_size_inter)); abs (read - buffer_size_inter));
src->buffer_remain += read; src->buffer_remain += read;
@ -441,8 +438,8 @@ gst_mythtv_src_create (GstPushSrc * psrc, GstBuffer ** outbuf)
} }
GST_DEBUG_OBJECT (src, GST_DEBUG_OBJECT (src,
"[%s]BYTES READ (actual) = %d, BYTES READ (cumulative) = %llu, " "BYTES READ (actual) = %d, BYTES READ (cumulative) = %llu, "
"OFFSET = %llu, CONTENT SIZE = %llu.", __FUNCTION__, read, "OFFSET = %llu, CONTENT SIZE = %llu.", read,
src->bytes_read, src->read_offset, src->content_size); src->bytes_read, src->read_offset, src->content_size);
} }
@ -455,9 +452,9 @@ gst_mythtv_src_create (GstPushSrc * psrc, GstBuffer ** outbuf)
/* gets the first buffer_size bytes from the byte array buffer variable */ /* gets the first buffer_size bytes from the byte array buffer variable */
/* guint8 *buf = g_memdup( src->bytes_queue->data, buffer_size ); */ /* guint8 *buf = g_memdup( src->bytes_queue->data, buffer_size ); */
GST_DEBUG_OBJECT (src, "[%s] read from network? %s!, buffer_remain = %d", GST_DEBUG_OBJECT (src, "read from network? %s!, buffer_remain = %d",
__FUNCTION__, (read ==
read == -1 ? "NO, got from buffer" : "YES, go see the backend's log file", -1) ? "NO, got from buffer" : "YES, go see the backend's log file",
src->buffer_remain); src->buffer_remain);
GST_BUFFER_SIZE (*outbuf) = buffer_size; GST_BUFFER_SIZE (*outbuf) = buffer_size;
@ -473,19 +470,19 @@ gst_mythtv_src_create (GstPushSrc * psrc, GstBuffer ** outbuf)
src->read_offset += GST_BUFFER_SIZE (*outbuf); src->read_offset += GST_BUFFER_SIZE (*outbuf);
src->bytes_read += GST_BUFFER_SIZE (*outbuf); src->bytes_read += GST_BUFFER_SIZE (*outbuf);
GST_DEBUG_OBJECT (src, "[%s]Buffer output with size: %d", __FUNCTION__, GST_DEBUG_OBJECT (src, "Buffer output with size: %d",
GST_BUFFER_SIZE (*outbuf)); GST_BUFFER_SIZE (*outbuf));
/* flushs the newly buffer got from byte array */ /* flushs the newly buffer got from byte array */
src->bytes_queue = src->bytes_queue =
g_byte_array_remove_range (src->bytes_queue, 0, buffer_size); g_byte_array_remove_range (src->bytes_queue, 0, buffer_size);
GST_DEBUG_OBJECT (src, "Got buffer: [%s]BUFFER --->SIZE = %d, OFFSET = %llu, " GST_DEBUG_OBJECT (src, "Got buffer: BUFFER --->SIZE = %d, OFFSET = %llu, "
"OFFSET_END = %llu.", __FUNCTION__, GST_BUFFER_SIZE (*outbuf), "OFFSET_END = %llu.", GST_BUFFER_SIZE (*outbuf),
GST_BUFFER_OFFSET (*outbuf), GST_BUFFER_OFFSET_END (*outbuf)); GST_BUFFER_OFFSET (*outbuf), GST_BUFFER_OFFSET_END (*outbuf));
GST_DEBUG_OBJECT (src, "[%s]CONTENT_SIZE = %llu, BYTES_READ = %llu.", GST_DEBUG_OBJECT (src, "CONTENT_SIZE = %llu, BYTES_READ = %llu.",
__FUNCTION__, src->content_size, src->bytes_read); src->content_size, src->bytes_read);
if (G_UNLIKELY (src->eos) || (!src->live_tv if (G_UNLIKELY (src->eos) || (!src->live_tv
&& (src->bytes_read >= src->content_size))) && (src->bytes_read >= src->content_size)))
@ -548,8 +545,7 @@ gst_mythtv_src_get_position (GstMythtvSrc * src)
src->content_size = size_tmp; src->content_size = size_tmp;
else if (size_tmp > 0 && --max_tries > 0) else if (size_tmp > 0 && --max_tries > 0)
goto get_file_pos; goto get_file_pos;
GST_LOG_OBJECT (src, "[%s] GET_POSITION: file_position = %lld", GST_LOG_OBJECT (src, "GET_POSITION: file_position = %lld", size_tmp);
__FUNCTION__, 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; src->prev_content_size = src->content_size;
} }
@ -566,15 +562,14 @@ gst_mythtv_src_do_seek (GstBaseSrc * base, GstSegment * segment)
gint64 actual_seek = segment->start; gint64 actual_seek = segment->start;
gboolean ret = TRUE; gboolean ret = TRUE;
GST_LOG_OBJECT (src, "[%s]DO Seek called! (start = %lld, stop = %lld)", GST_LOG_OBJECT (src, "seek, segment: %" GST_SEGMENT_FORMAT, segment);
__FUNCTION__, segment->start, segment->stop);
if (segment->format == GST_FORMAT_TIME) { if (segment->format == GST_FORMAT_TIME) {
goto done; goto done;
} }
GST_LOG_OBJECT (src, GST_LOG_OBJECT (src,
"[%s]Trying to seek at the value (actual_seek = %lld, read_offset = %lld)", "Trying to seek at the value (actual_seek = %lld, read_offset = %lld)",
__FUNCTION__, actual_seek, src->read_offset); actual_seek, src->read_offset);
/* verify if it needs to seek */ /* verify if it needs to seek */
if (src->read_offset != actual_seek) { if (src->read_offset != actual_seek) {
@ -582,8 +577,8 @@ gst_mythtv_src_do_seek (GstBaseSrc * base, GstSegment * segment)
gmyth_file_transfer_seek (src->file_transfer, segment->start, SEEK_SET); gmyth_file_transfer_seek (src->file_transfer, segment->start, SEEK_SET);
GST_LOG_OBJECT (src, GST_LOG_OBJECT (src,
"[%s] Segment offset start = %lld, SRC Offset = %lld, NEW actual backend SEEK Offset = %lld.", "Segment offset start = %lld, SRC Offset = %lld, NEW actual backend SEEK Offset = %lld.",
__FUNCTION__, segment->start, src->read_offset, new_offset); segment->start, src->read_offset, new_offset);
if (G_UNLIKELY (new_offset < 0)) { if (G_UNLIKELY (new_offset < 0)) {
ret = FALSE; ret = FALSE;
if (src->live_tv) if (src->live_tv)
@ -595,8 +590,7 @@ gst_mythtv_src_do_seek (GstBaseSrc * base, GstSegment * segment)
src->read_offset = new_offset; src->read_offset = new_offset;
if (ret == FALSE) { if (ret == FALSE) {
GST_INFO_OBJECT (src, "[%s] Failed to set the SEEK on segment!", GST_INFO_OBJECT (src, "Failed to set the SEEK on segment!");
__FUNCTION__);
} }
} }
@ -657,15 +651,13 @@ gst_mythtv_src_start (GstBaseSrc * bsrc)
if (src->channel_num != GST_GMYTHTV_CHANNEL_DEFAULT_NUM) { if (src->channel_num != GST_GMYTHTV_CHANNEL_DEFAULT_NUM) {
if (gmyth_livetv_channel_setup (src->spawn_livetv, src->channel_num, if (gmyth_livetv_channel_setup (src->spawn_livetv, src->channel_num,
src->backend_info) == FALSE) { src->backend_info) == FALSE) {
GST_INFO_OBJECT (src, "[%s] LiveTV setup felt down on error!!", GST_INFO_OBJECT (src, "LiveTV setup felt down on error");
__FUNCTION__);
ret = FALSE; ret = FALSE;
goto init_failed; goto init_failed;
} }
} else { } else {
if (gmyth_livetv_setup (src->spawn_livetv, src->backend_info) == FALSE) { if (gmyth_livetv_setup (src->spawn_livetv, src->backend_info) == FALSE) {
GST_INFO_OBJECT (src, "[%s] LiveTV setup felt down on error!!", GST_INFO_OBJECT (src, "LiveTV setup felt down on error");
__FUNCTION__);
ret = FALSE; ret = FALSE;
goto init_failed; goto init_failed;
} }
@ -674,8 +666,7 @@ gst_mythtv_src_start (GstBaseSrc * bsrc)
src->file_transfer = gmyth_livetv_create_file_transfer (src->spawn_livetv); src->file_transfer = gmyth_livetv_create_file_transfer (src->spawn_livetv);
if (NULL == src->file_transfer) { if (NULL == src->file_transfer) {
GST_INFO_OBJECT (src, "[%s] [LiveTV] FileTransfer equals to NULL!!!", GST_INFO_OBJECT (src, "[LiveTV] FileTransfer equals to NULL");
__FUNCTION__);
ret = FALSE; ret = FALSE;
goto init_failed; goto init_failed;
} }
@ -688,10 +679,10 @@ gst_mythtv_src_start (GstBaseSrc * bsrc)
} }
if (NULL == src->file_transfer) { if (NULL == src->file_transfer) {
GST_INFO_OBJECT (src, "[%s] FileTransfer equals to NULL!!!", __FUNCTION__); GST_INFO_OBJECT (src, "FileTransfer is NULL");
goto init_failed; goto init_failed;
} }
/*GST_INFO_OBJECT( src, "[%s] uri = %s.", __FUNCTION__, src->spawn_livetv->file_transfer ); */ /*GST_INFO_OBJECT( src, "uri = %s", src->spawn_livetv->file_transfer); */
if (src->live_tv == TRUE && ret == TRUE) { if (src->live_tv == TRUE && ret == TRUE) {
/* loop finished, set the max tries variable to zero again... */ /* loop finished, set the max tries variable to zero again... */
@ -704,8 +695,7 @@ gst_mythtv_src_start (GstBaseSrc * bsrc)
/* IS_RECORDING again, just like the MythTV backend does... */ /* IS_RECORDING again, just like the MythTV backend does... */
gmyth_livetv_is_recording (src->spawn_livetv); gmyth_livetv_is_recording (src->spawn_livetv);
sleep (9); sleep (9); /* FIXME: this is evil (tpm) */
} }
if (ret == FALSE) { if (ret == FALSE) {
@ -812,8 +802,7 @@ gst_mythtv_src_next_program_chain (GstMythtvSrc * src)
if (src->live_tv) { if (src->live_tv) {
if (gmyth_livetv_next_program_chain (src->spawn_livetv) == FALSE) { if (gmyth_livetv_next_program_chain (src->spawn_livetv) == FALSE) {
GST_INFO_OBJECT (src, "[%s]Failed to go to the next program chain!!!", GST_INFO_OBJECT (src, "Failed to go to the next program chain!");
__FUNCTION__);
ret = FALSE; ret = FALSE;
goto init_failed; goto init_failed;
} }
@ -822,11 +811,10 @@ gst_mythtv_src_next_program_chain (GstMythtvSrc * src)
chain_id_local = gmyth_tvchain_get_id (src->spawn_livetv->tvchain); chain_id_local = gmyth_tvchain_get_id (src->spawn_livetv->tvchain);
if (chain_id_local != NULL) { if (chain_id_local != NULL) {
src->live_chain_id = g_strdup (chain_id_local->str); src->live_chain_id = g_strdup (chain_id_local->str);
GST_DEBUG_OBJECT (src, "[%s] Local chain ID = %s.", __FUNCTION__, GST_DEBUG_OBJECT (src, "Local chain ID = %s", src->live_chain_id);
src->live_chain_id);
} }
src->live_tv_id = src->spawn_livetv->recorder->recorder_num; src->live_tv_id = src->spawn_livetv->recorder->recorder_num;
GST_LOG_OBJECT (src, "[%s] LiveTV id = %d, URI path = %s.", __FUNCTION__, GST_LOG_OBJECT (src, "LiveTV id = %d, URI path = %s",
src->live_tv_id, src->uri_name); src->live_tv_id, src->uri_name);
} }
@ -913,8 +901,8 @@ gst_mythtv_src_get_size (GstBaseSrc * bsrc, guint64 * size)
GstMythtvSrc *src = GST_MYTHTV_SRC (bsrc); GstMythtvSrc *src = GST_MYTHTV_SRC (bsrc);
gboolean ret = TRUE; gboolean ret = TRUE;
GST_LOG_OBJECT (src, "[%s] Differs from previous content size: %d (max.: %d)", GST_LOG_OBJECT (src, "Differs from previous content size: %d (max.: %d)",
__FUNCTION__, abs (src->content_size - src->prev_content_size), abs (src->content_size - src->prev_content_size),
GMYTHTV_TRANSFER_MAX_BUFFER); GMYTHTV_TRANSFER_MAX_BUFFER);
if (src->live_tv) { if (src->live_tv) {
@ -934,8 +922,7 @@ gst_mythtv_src_get_size (GstBaseSrc * bsrc, guint64 * size)
} }
*size = src->content_size; *size = src->content_size;
GST_LOG_OBJECT (src, "[%s] Content size = %lld", __FUNCTION__, GST_LOG_OBJECT (src, "Content size = %lld", src->content_size);
src->content_size);
return ret; return ret;
@ -974,7 +961,7 @@ gst_mythtv_src_handle_event (GstPad * pad, GstEvent * event)
switch (GST_EVENT_TYPE (event)) { switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_EOS: case GST_EVENT_EOS:
GST_WARNING_OBJECT (src, "[%s] Got EOS event!!!", __FUNCTION__); GST_WARNING_OBJECT (src, "Got EOS event");
if (src->live_tv) { if (src->live_tv) {
cont_size = gst_mythtv_src_get_position (src); cont_size = gst_mythtv_src_get_position (src);
@ -1011,15 +998,12 @@ gst_mythtv_src_handle_query (GstPad * pad, GstQuery * query)
switch (GST_QUERY_TYPE (query)) { switch (GST_QUERY_TYPE (query)) {
case GST_QUERY_POSITION: case GST_QUERY_POSITION:
{ {
gint64 pos = -1; gst_query_parse_position (query, &formt, NULL);
gst_query_parse_position (query, &formt, &pos);
res = TRUE;
if (formt == GST_FORMAT_BYTES) { if (formt == GST_FORMAT_BYTES) {
gst_query_set_position (query, formt, pos = myth->read_offset); gst_query_set_position (query, formt, myth->read_offset);
GST_DEBUG_OBJECT (myth, "POS %lld (BYTES).", pos); GST_DEBUG_OBJECT (myth, "POS %" G_GINT64_FORMAT, myth->read_offset);
res = TRUE;
} else if (formt == GST_FORMAT_TIME) { } else if (formt == GST_FORMAT_TIME) {
GST_DEBUG_OBJECT (myth, "POS %lld (TIME).", pos);
res = gst_pad_query_default (pad, query); res = gst_pad_query_default (pad, query);
} }
break; break;
@ -1036,18 +1020,15 @@ gst_mythtv_src_handle_query (GstPad * pad, GstQuery * query)
gst_util_uint64_scale_int (GST_SECOND, nuv->h->i_video_blocks, fps); gst_util_uint64_scale_int (GST_SECOND, nuv->h->i_video_blocks, fps);
} }
#endif #endif
gint64 dur = -1;
gst_query_parse_duration (query, &formt, &dur); gst_query_parse_duration (query, &formt, NULL);
if (formt == GST_FORMAT_BYTES) { if (formt == GST_FORMAT_BYTES) {
gst_query_set_duration (query, formt, dur = myth->content_size); gst_query_set_duration (query, formt, myth->content_size);
GST_DEBUG_OBJECT (myth, "DURATION %lld (BYTES).", dur); GST_DEBUG_OBJECT (myth, "SIZE %" G_GINT64_FORMAT, myth->content_size);
res = TRUE;
} else if (formt == GST_FORMAT_TIME) { } else if (formt == GST_FORMAT_TIME) {
GST_DEBUG_OBJECT (myth, "DURATION %lld (TIME).", dur);
gst_query_ref (query);
res = gst_pad_query_default (pad, query); res = gst_pad_query_default (pad, query);
} }
res = TRUE;
break; break;
} }
default: default:
@ -1072,22 +1053,16 @@ gst_mythtv_src_change_state (GstElement * element, GstStateChange transition)
case GST_STATE_CHANGE_NULL_TO_READY: case GST_STATE_CHANGE_NULL_TO_READY:
break; break;
case GST_STATE_CHANGE_READY_TO_PAUSED: case GST_STATE_CHANGE_READY_TO_PAUSED:
GST_INFO_OBJECT (src, "[%s] READY to PAUSED called!", __FUNCTION__);
break; break;
case GST_STATE_CHANGE_PAUSED_TO_PLAYING: case GST_STATE_CHANGE_PAUSED_TO_PLAYING:
GST_INFO_OBJECT (src, "[%s] PAUSED to PLAYING called!", __FUNCTION__);
if (src->live_tv) { if (src->live_tv) {
if (!gmyth_recorder_send_frontend_ready_command (src->spawn_livetv-> if (!gmyth_recorder_send_frontend_ready_command (src->spawn_livetv->
recorder)) recorder))
GST_WARNING_OBJECT (src, GST_WARNING_OBJECT (src,
"[%s] Couldn't send the FRONTEND_READY message to the backend!", "Couldn't send the FRONTEND_READY message to the backend!");
__FUNCTION__);
else else
GST_DEBUG_OBJECT (src, GST_DEBUG_OBJECT (src, "FRONTEND_READY was sent to the backend");
"[%s] Message FRONTEND_READY was sent to the backend!",
__FUNCTION__);
} }
break; break;
default: default:
break; break;
@ -1099,24 +1074,17 @@ gst_mythtv_src_change_state (GstElement * element, GstStateChange transition)
switch (transition) { switch (transition) {
case GST_STATE_CHANGE_READY_TO_NULL: case GST_STATE_CHANGE_READY_TO_NULL:
GST_INFO_OBJECT (src, "[%s] READY to NULL called!", __FUNCTION__);
break; break;
case GST_STATE_CHANGE_PLAYING_TO_PAUSED: case GST_STATE_CHANGE_PLAYING_TO_PAUSED:
GST_INFO_OBJECT (src, "[%s] PLAYING to PAUSED called!", __FUNCTION__);
case GST_STATE_CHANGE_PAUSED_TO_READY: case GST_STATE_CHANGE_PAUSED_TO_READY:
GST_INFO_OBJECT (src, "[%s] PAUSED to READY called!", __FUNCTION__);
if (src->live_tv) { if (src->live_tv) {
if (!gmyth_recorder_send_frontend_ready_command (src->spawn_livetv-> if (!gmyth_recorder_send_frontend_ready_command (src->spawn_livetv->
recorder)) recorder))
GST_WARNING_OBJECT (src, GST_WARNING_OBJECT (src,
"[%s] Couldn't send the FRONTEND_READY message to the backend!", "Couldn't send the FRONTEND_READY message to the backend!");
__FUNCTION__);
else else
GST_DEBUG_OBJECT (src, GST_DEBUG_OBJECT (src, "FRONTEND_READY was sent to the backend");
"[%s] Message FRONTEND_READY was sent to the backend!",
__FUNCTION__);
} }
break; break;
default: default:
break; break;
@ -1198,9 +1166,9 @@ gst_mythtv_src_set_property (GObject * object, guint prop_id,
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break; break;
} }
GST_OBJECT_UNLOCK (mythtvsrc);
done: done:
return; GST_OBJECT_UNLOCK (mythtvsrc);
} }
static void static void
@ -1270,11 +1238,6 @@ gst_mythtv_src_get_property (GObject * object, guint prop_id,
GST_OBJECT_UNLOCK (mythtvsrc); GST_OBJECT_UNLOCK (mythtvsrc);
} }
/* entry point to initialize the plug-in
* initialize the plug-in itself
* register the element factories and pad templates
* register the features
*/
static gboolean static gboolean
plugin_init (GstPlugin * plugin) plugin_init (GstPlugin * plugin)
{ {
@ -1282,17 +1245,16 @@ plugin_init (GstPlugin * plugin)
GST_TYPE_MYTHTV_SRC); GST_TYPE_MYTHTV_SRC);
} }
/* this is the structure that gst-register looks for
* so keep the name plugin_desc, or you cannot get your plug-in registered */
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR, GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
GST_VERSION_MINOR, GST_VERSION_MINOR,
"mythtv", "mythtv",
"lib MythTV src", "lib MythTV src",
plugin_init, VERSION, "LGPL", "GStreamer", "http://gstreamer.net/") plugin_init, VERSION, GST_LICENSE, GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN);
/*** GSTURIHANDLER INTERFACE *************************************************/ /*** GSTURIHANDLER INTERFACE *************************************************/
static guint gst_mythtv_src_uri_get_type (void) static guint
gst_mythtv_src_uri_get_type (void)
{ {
return GST_URI_SRC; return GST_URI_SRC;
} }