Mercurialgmyth / file revision
summary | shortlog | changelog | graph | tags | branches | files | changeset | file | revisions | annotate | diff | raw
maemo-ui/src/mmyth_tvplayer.c
author rosfran
Fri Nov 24 18:51:42 2006 +0000 (2006-11-24)
branchtrunk
changeset 110 ce35e2e839f4
parent 64 f926338c6952
child 208 c3c073032757
permissions -rw-r--r--
[svn r111] Put the gmyth_livetv calls in the right place... 
     1 /**

     2  * GMyth Library

     3  *

     4  * @file gmyth/mmyth_tvplayer.c

     5  * 

     6  * @brief <p> This component provides playback of the remote A/V using

     7  * GStreamer.

     8  * 

     9  * Copyright (C) 2006 INdT - Instituto Nokia de Tecnologia.

    10  * @author Hallyson Luiz de Morais Melo <hallyson.melo@indt.org.br>

    11  *

    12  *//*

    13  * 

    14  * This program is free software; you can redistribute it and/or modify

    15  * it under the terms of the GNU Lesser General Public License as published by

    16  * the Free Software Foundation; either version 2 of the License, or

    17  * (at your option) any later version.

    18  *

    19  * This program is distributed in the hope that it will be useful,

    20  * but WITHOUT ANY WARRANTY; without even the implied warranty of

    21  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

    22  * GNU General Public License for more details.

    23  *

    24  * You should have received a copy of the GNU Lesser General Public License

    25  * along with this program; if not, write to the Free Software

    26  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

    27  */

    28 

    29 #include "mmyth_tvplayer.h"

    30  

    31 #include <gdk/gdkx.h>

    32 

    33 #include "gmyth_context.h"

    34 #include "gmyth_remote_util.h"

    35 

    36 typedef struct _GstPlayerWindowStateChange

    37 {

    38     GstElement *play;

    39     GstState old_state, new_state;

    40     MMythTVPlayer *tvplayer;

    41 } GstPlayerWindowStateChange;

    42 

    43 typedef struct _GstPlayerWindowTagFound

    44 {

    45     GstElement *play;

    46     GstTagList *taglist;

    47     MMythTVPlayer *tvplayer;

    48 } GstPlayerWindowTagFound;

    49 

    50 /*

    51 static gboolean idle_state (gpointer data);

    52 */

    53 static gboolean bus_call (GstBus * bus, GstMessage * msg, gpointer data);

    54 

    55 static void mmyth_tvplayer_class_init          (MMythTVPlayerClass *klass);

    56 static void mmyth_tvplayer_init                (MMythTVPlayer *object);

    57 

    58 static void mmyth_tvplayer_dispose  (GObject *object);

    59 static void mmyth_tvplayer_finalize (GObject *object);

    60 

    61 G_DEFINE_TYPE(MMythTVPlayer, mmyth_tvplayer, G_TYPE_OBJECT)

    62 

    63 static gboolean mmyth_tvplayer_create_pipeline (MMythTVPlayer* tvplayer);

    64 static void     new_pad_cb (GstElement *element, 

    65                             GstPad *pad, gpointer data);

    66 

    67 static gboolean expose_cb (GtkWidget * widget, 

    68                            GdkEventExpose * event, 

    69                            gpointer user_data);

    70 

    71 static void

    72 mmyth_tvplayer_class_init (MMythTVPlayerClass *klass)

    73 {

    74 	GObjectClass *gobject_class;

    75 

    76     gobject_class = (GObjectClass *) klass;

    77 	

    78     gobject_class->dispose  = mmyth_tvplayer_dispose;

    79     gobject_class->finalize = mmyth_tvplayer_finalize;	

    80 }

    81 

    82 static void

    83 new_pad_cb (GstElement *element, GstPad *pad, gpointer data)

    84 {

    85 	MMythTVPlayer *tvplayer = MMYTH_TVPLAYER (data);

    86 	GstPadLinkReturn ret;

    87 	char *s;

    88 	

    89 	s = gst_caps_to_string (pad->caps);

    90 

    91 	if ( s[0] == 'a') {

    92 		ret = gst_pad_link (pad, gst_element_get_pad (tvplayer->audioqueue1, "sink"));

    93 	} else {

    94 		ret = gst_pad_link (pad, gst_element_get_pad (tvplayer->videoqueue1, "sink")); 

    95 	}

    96 	

    97 	g_free(s);

    98 }

    99 

   100 static gboolean

   101 expose_cb (GtkWidget * widget, GdkEventExpose * event, gpointer user_data)

   102 {

   103 	MMythTVPlayer *tvplayer = MMYTH_TVPLAYER (user_data);

   104 

   105 	if (tvplayer && tvplayer->videow) {

   106 		gst_x_overlay_set_xwindow_id (GST_X_OVERLAY (tvplayer->gst_videosink),

   107 				GDK_WINDOW_XWINDOW (widget->window));

   108 		return TRUE;

   109 	}

   110 

   111 	g_warning ("MMythTVPlayer expose called before setting video window\n");

   112 

   113 	return FALSE;

   114 }

   115 

   116 static void

   117 mmyth_tvplayer_init (MMythTVPlayer *tvplayer)

   118 {

   119 	tvplayer->gst_pipeline = NULL;

   120 	tvplayer->gst_source = NULL;

   121 	tvplayer->gst_videodec = NULL;

   122 	tvplayer->gst_videosink = NULL;

   123 	tvplayer->gst_videocolortrs = NULL;

   124 	tvplayer->videoqueue1 = NULL;

   125 	tvplayer->videoqueue2 = NULL;

   126 	tvplayer->audioqueue1 = NULL;

   127 	tvplayer->audioqueue2 = NULL;   

   128 

   129 	/* GTKWidget for rendering the video */

   130 	tvplayer->videow = NULL;

   131 	tvplayer->expose_handler = 0;

   132 

   133 	tvplayer->backend_hostname = NULL;

   134 	tvplayer->backend_port = 0;

   135 	tvplayer->local_hostname = NULL;

   136 

   137 	tvplayer->recorder = NULL;

   138 	tvplayer->tvchain = NULL;

   139 	tvplayer->proginfo = NULL;

   140 }

   141 

   142 static void

   143 mmyth_tvplayer_dispose (GObject *object)

   144 {

   145 

   146 	G_OBJECT_CLASS (mmyth_tvplayer_parent_class)->dispose (object);

   147 }

   148 

   149 static void

   150 mmyth_tvplayer_finalize (GObject *object)

   151 {

   152 	g_signal_handlers_destroy (object);

   153 

   154 	MMythTVPlayer *tvplayer = MMYTH_TVPLAYER (object);

   155 

   156 	g_debug ("[%s] Finalizing tvplayer", __FUNCTION__);

   157 	

   158 	if (tvplayer->videow != NULL) {

   159 		if (g_signal_handler_is_connected (tvplayer->videow, 

   160 						tvplayer->expose_handler)) {

   161 			g_signal_handler_disconnect (tvplayer->videow,

   162 				tvplayer->expose_handler);

   163 		}

   164 		g_object_unref (tvplayer->videow);

   165 	}

   166 	

   167 	if ( tvplayer->recorder != NULL )

   168 		g_object_unref (tvplayer->recorder);

   169 	if ( tvplayer->tvchain != NULL )

   170 		g_object_unref (tvplayer->tvchain);

   171 	if ( tvplayer->proginfo != NULL )

   172 		g_object_unref (tvplayer->proginfo);	

   173 

   174 	// Release Gstreamer elements

   175 	if ( tvplayer->gst_pipeline != NULL )

   176 		g_object_unref (tvplayer->gst_pipeline);	

   177 	if ( tvplayer->gst_source != NULL )

   178 		g_object_unref (tvplayer->gst_source);	

   179 	if ( tvplayer->gst_videodec != NULL )

   180 		g_object_unref (tvplayer->gst_videodec);	

   181 	if ( tvplayer->gst_videocolortrs != NULL )

   182 		g_object_unref (tvplayer->gst_videocolortrs);

   183 	if ( tvplayer->gst_videosink != NULL )

   184 		g_object_unref (tvplayer->gst_videosink);	

   185 	if ( tvplayer->videoqueue1 != NULL )

   186 		g_object_unref (tvplayer->videoqueue1);

   187 	if ( tvplayer->videoqueue2 != NULL )

   188 		g_object_unref (tvplayer->videoqueue2);

   189 	if ( tvplayer->audioqueue1 != NULL )

   190 		g_object_unref (tvplayer->audioqueue1);	

   191 	if ( tvplayer->audioqueue2 != NULL )

   192 		g_object_unref (tvplayer->audioqueue2);	

   193 

   194 	G_OBJECT_CLASS (mmyth_tvplayer_parent_class)->finalize (object);

   195 }

   196 

   197 /** Creates a new instance of MMythTVPlayer. 

   198  * 

   199  * @return a new instance of MMythTVPlayer.

   200  */

   201 MMythTVPlayer *

   202 mmyth_tvplayer_new ()

   203 {

   204     MMythTVPlayer *tvplayer = 

   205         MMYTH_TVPLAYER (g_object_new(MMYTH_TVPLAYER_TYPE, NULL));

   206     

   207     return tvplayer;

   208 }

   209 

   210 /** Initializes the tv player.

   211  *

   212  * @param tvplayer the object instance.

   213  * @return gboolean TRUE if the pipeline was created 

   214  * successfully, FALSE otherwise.

   215  */

   216 gboolean

   217 mmyth_tvplayer_initialize (MMythTVPlayer *tvplayer)

   218 {

   219 	

   220     if (!mmyth_tvplayer_create_pipeline (tvplayer)) {

   221     	g_warning ("[%s] Error while creating pipeline. TV Player not initialized", __FUNCTION__);

   222 		return FALSE;

   223 	} else {

   224 		g_debug ("[%s] GStreamer pipeline created", __FUNCTION__);	

   225     }

   226 

   227 	return TRUE;

   228 }

   229 

   230 /** Creates the GStreamer pipeline used by the player.

   231  *

   232  * @param tvplayer the object instance.

   233  * @return gboolean TRUE if the pipeline was created 

   234  * successfully, FALSE otherwise.

   235  */

   236 static gboolean

   237 mmyth_tvplayer_create_pipeline (MMythTVPlayer* tvplayer)

   238 {

   239     GstElement *pipeline;

   240     GstElement *source, *parser;

   241     GstElement *videodec, *videosink;

   242     GstElement *videocolortrs;

   243 #ifndef MAEMO_PLATFORM    

   244     GstElement *audiodec, *audioconv;

   245 #endif

   246     GstElement *audiosink;

   247     GstElement *videoqueue1, *videoqueue2, *audioqueue1, *audioqueue2;

   248 

   249     g_debug ("MMythTVPlayer: Setting the Gstreamer pipeline\n");

   250 	

   251     pipeline = gst_pipeline_new ("video-player");

   252     source = gst_element_factory_make ("mythtvsrc", "myth-source");

   253     parser = gst_element_factory_make ("nuvdemux", "nuv-demux");

   254 

   255     /* Gstreamer Video elements */

   256     videoqueue1 = gst_element_factory_make ("queue", "video-queue1");

   257     videodec = gst_element_factory_make ("ffdec_mpeg4", "video-decoder");

   258     videoqueue2 = gst_element_factory_make ("queue", "video-queue2");

   259     videocolortrs = gst_element_factory_make ("ffmpegcolorspace", "image-color-transforms");

   260 

   261 #ifdef MAEMO_PLATFORM

   262     videosink = gst_element_factory_make ("sdlvideosink", "image-output");

   263 #else

   264     videosink = gst_element_factory_make ("xvimagesink", "image-output");

   265 #endif

   266     

   267     /* Gstreamer Audio elements */

   268     audioqueue1 = gst_element_factory_make ("queue", "audio-queue1");    

   269     audioqueue2 = gst_element_factory_make ("queue", "audio-queue2");

   270 #ifdef MAEMO_PLATFORM    

   271     audiosink = gst_element_factory_make ("dspmp3sink", "audio-output");

   272 #else    

   273     audiodec = gst_element_factory_make ("mad", "audio-decoder");

   274     audioconv = gst_element_factory_make ("audioconvert", "audio-converter");

   275     audiosink = gst_element_factory_make ("alsasink", "audio-output");

   276 #endif    

   277     

   278     if (!(pipeline && source && parser && videodec && videosink) ||

   279     	!(videoqueue1 && videoqueue2 && audioqueue1 && audioqueue2 && audiosink)) {

   280         /* FIXME: hanlde the error correctly */

   281         /* video_alignment is not being created (below) 

   282            and is causing problems to the ui */

   283 

   284 	    tvplayer->gst_pipeline = NULL;

   285 	    tvplayer->gst_videodec = NULL;

   286 	    tvplayer->gst_videosink = NULL;

   287 	    tvplayer->gst_videocolortrs = NULL;

   288            

   289         g_warning ("GstElement creation error!\n");

   290         return FALSE;

   291     }

   292 

   293 #ifndef MAEMO_PLATFORM    

   294     if (!(audiodec && audioconv)) {

   295         g_warning ("GstElement for audio stream creation error!");

   296         return FALSE;

   297     }

   298 #endif    

   299     

   300     tvplayer->gst_pipeline = pipeline;

   301     tvplayer->gst_source = source;

   302     tvplayer->gst_videodec = videodec;

   303     tvplayer->gst_videosink = videosink;

   304     tvplayer->gst_videocolortrs = videocolortrs;

   305     g_object_ref (tvplayer->gst_pipeline);

   306     g_object_ref (tvplayer->gst_source);

   307     g_object_ref (tvplayer->gst_videodec);

   308     g_object_ref (tvplayer->gst_videosink);

   309     g_object_ref (tvplayer->gst_videocolortrs);

   310 

   311     tvplayer->videoqueue1 = videoqueue1;

   312     tvplayer->videoqueue2 = videoqueue2;

   313     tvplayer->audioqueue1 = audioqueue1;

   314     tvplayer->audioqueue2 = audioqueue2;

   315     g_object_ref (tvplayer->videoqueue1);

   316     g_object_ref (tvplayer->videoqueue2);

   317     g_object_ref (tvplayer->audioqueue1);

   318     g_object_ref (tvplayer->audioqueue2);

   319   	

   320     g_object_set (G_OBJECT (videosink), "sync", TRUE, NULL);

   321     g_object_set (G_OBJECT (audiosink), "sync", FALSE, NULL);

   322 

   323     gst_bus_add_watch (gst_pipeline_get_bus (GST_PIPELINE (tvplayer->gst_pipeline)),

   324                        bus_call, tvplayer);

   325 

   326     gst_bin_add_many (GST_BIN (pipeline), source, parser, videoqueue1,

   327     			videodec, videoqueue2, videocolortrs, videosink, audioqueue1, 

   328 			audiodec, audioconv, audioqueue2, audiosink, NULL);

   329 

   330     {

   331 //        GstCaps *rtpcaps = gst_caps_new_simple ("application/x-rtp", NULL);

   332 //        gst_element_link_filtered(source, parser, rtpcaps);

   333     }

   334     

   335     gst_element_link (source, parser);

   336     gst_element_link_many (videoqueue1, videodec, videoqueue2, videocolortrs, videosink, NULL);

   337     gst_element_link_many (audioqueue1, audiodec, audioconv, audioqueue2, audiosink, NULL);

   338     

   339     g_signal_connect (parser, "pad-added", G_CALLBACK (new_pad_cb), tvplayer);

   340     

   341     return TRUE;

   342 }

   343 

   344 /** Configures the backend and the tv player 

   345  * for playing the recorded content A/V.

   346  *

   347  * FIXME: Change filename to program info or other structure about the recorded

   348  *

   349  * @param tvplayer the object instance.

   350  * @param filename the file uri of the recorded content to be played.

   351  * @return TRUE if successfull, FALSE if any error happens.

   352  */

   353 gboolean

   354 mmyth_tvplayer_record_setup (MMythTVPlayer *tvplayer, gchar *filename)

   355 {

   356 	GMythSettings *msettings = gmyth_context_get_settings();

   357 	

   358 	// FIXME: we should receive the uri instead of filename

   359 	GString *hostname = gmyth_settings_get_backend_hostname (msettings);

   360 	int port = gmyth_settings_get_backend_port(msettings);

   361 	

   362 	GString *fullpath = g_string_new ("myth://");

   363 	g_string_append_printf (fullpath, "%s:%d/%s", hostname->str, port, filename);

   364 	

   365 	tvplayer->is_livetv = FALSE;

   366 

   367 	g_debug ("[%s] Setting record uri to gstreamer pipeline to %s", __FUNCTION__, fullpath->str);

   368 		

   369     g_object_set (G_OBJECT (tvplayer->gst_source), "location",

   370           fullpath->str, NULL);

   371           

   372     return TRUE;

   373 }

   374 

   375 /** Configures the backend and the tv player 

   376  * for playing the live tv.

   377  *

   378  * @param tvplayer the object instance.

   379  * @return TRUE if successfull, FALSE if any error happens.

   380  */

   381 gboolean

   382 mmyth_tvplayer_livetv_setup (MMythTVPlayer *tvplayer)

   383 {

   384 	GMythSettings *msettings = gmyth_context_get_settings ();

   385 	gboolean res = TRUE;

   386 

   387 	res = gmyth_context_check_connection();

   388 	if (!res) {

   389 		g_warning ("[%s] LiveTV can not connect to backend", __FUNCTION__);	

   390 		res = FALSE;

   391 		goto error;

   392 	}

   393 

   394 	tvplayer->backend_hostname = gmyth_settings_get_backend_hostname(msettings);

   395 	tvplayer->backend_port = gmyth_settings_get_backend_port (msettings);

   396 

   397 	tvplayer->local_hostname  = g_string_new("");    

   398 	gmyth_context_get_local_hostname (tvplayer->local_hostname);

   399 

   400 	if ( tvplayer->local_hostname == NULL ) {

   401 		res = FALSE;

   402 		goto error;

   403 	}

   404 

   405 	// Gets the remote encoder num

   406 	tvplayer->recorder = remote_request_next_free_recorder (-1);

   407 

   408 	if ( tvplayer->recorder == NULL ) {

   409 		g_warning ("[%s] None remote encoder available", __FUNCTION__);

   410 		res = FALSE;

   411 		goto error;

   412 	}

   413 

   414 	// Creates livetv chain handler

   415 	tvplayer->tvchain = GMYTH_TVCHAIN ( g_object_new(GMYTH_TVCHAIN_TYPE, NULL) );

   416 	gmyth_tvchain_initialize ( tvplayer->tvchain, tvplayer->local_hostname );

   417 

   418 	if ( tvplayer->tvchain == NULL || tvplayer->tvchain->tvchain_id == NULL ) {

   419 		res = FALSE;

   420 		goto error;

   421 	}

   422 

   423 	// Init remote encoder. Opens its control socket.

   424 	res = gmyth_recorder_setup(tvplayer->recorder);

   425 	if ( !res ) {

   426 		g_warning ("[%s] Fail while setting remote encoder\n", __FUNCTION__);

   427 		res = FALSE;

   428 		goto error;

   429 	}

   430 	// Spawn live tv. Uses the socket to send mythprotocol data to start livetv in the backend (remotelly)

   431 	res = gmyth_recorder_spawntv ( tvplayer->recorder,

   432 			gmyth_tvchain_get_id(tvplayer->tvchain) );

   433 	if (!res) {

   434 		g_warning ("[%s] Fail while spawn tv\n", __FUNCTION__);

   435 		res = FALSE;

   436 		goto error;

   437 	}

   438 

   439 	// Reload all TV chain from Mysql database.

   440 	gmyth_tvchain_reload_all (tvplayer->tvchain);

   441 

   442 	if ( tvplayer->tvchain == NULL ) {

   443 		res = FALSE;

   444 		goto error;

   445 	}

   446 

   447 	// Get program info from database using chanid and starttime

   448 	tvplayer->proginfo = gmyth_tvchain_get_program_at (tvplayer->tvchain, -1);

   449 	if ( tvplayer->proginfo == NULL ) {

   450 		g_warning ("[%s] LiveTV not successfully started.\n", __FUNCTION__ );

   451 		res = FALSE;

   452 		goto error;

   453 	} else {

   454 		g_debug ("[%s] MythLiveTV: All requests to backend to start TV were OK.\n", __FUNCTION__ );

   455 	}

   456 

   457 	return res;

   458 

   459 error:

   460 	if ( tvplayer->backend_hostname != NULL ) {

   461 		g_string_free( tvplayer->backend_hostname, TRUE );

   462 		res = FALSE;

   463 	}

   464 

   465 	if ( tvplayer->local_hostname != NULL ) {

   466 		g_string_free( tvplayer->local_hostname, TRUE );

   467 		res = FALSE;

   468 	}

   469 

   470 	if ( tvplayer->recorder != NULL ) {

   471 		g_object_unref (tvplayer->recorder);

   472 		tvplayer->recorder = NULL;

   473 	}

   474 

   475 	if ( tvplayer->tvchain != NULL ) {

   476 		g_object_unref (tvplayer->tvchain);

   477 		tvplayer->tvchain = NULL;

   478 	}

   479 

   480 	if ( tvplayer->proginfo != NULL ) {

   481 		g_object_unref (tvplayer->proginfo);

   482 		tvplayer->proginfo = NULL;

   483 	}

   484 

   485 	return res;

   486 

   487 }

   488 

   489 /** Sets the GTK video widget for the tv player. 

   490  *

   491  * @param tvplayer the object instance.

   492  * @param videow the GTK video window.

   493  * @return TRUE if successfull, FALSE if any error happens.

   494  */

   495 gboolean

   496 mmyth_tvplayer_set_widget (MMythTVPlayer *tvplayer, GtkWidget *videow)

   497 {

   498 	tvplayer->videow = videow;

   499 	g_object_ref (videow);

   500 	

   501 	g_debug ("[%s] Setting widget for tv player render", __FUNCTION__);

   502 	

   503     tvplayer->expose_handler = g_signal_connect (tvplayer->videow, "expose-event", 

   504                                                  G_CALLBACK (expose_cb), tvplayer);

   505 

   506     //g_signal_connect(miptv_ui->videow, "size_request", G_CALLBACK(cb_preferred_video_size), miptv_ui);

   507 

   508     return TRUE;

   509 }

   510 

   511 static gboolean

   512 bus_call (GstBus * bus, GstMessage * msg, gpointer data)

   513 {

   514     //MMythTVPlayer *tvplayer = MMYTH_TVPLAYER ( data );

   515     //GMainLoop *loop = tvplayer->loop;

   516 

   517     switch (GST_MESSAGE_TYPE (msg)) {

   518         case GST_MESSAGE_EOS:

   519 			printf ("End of stream\n");

   520             //g_idle_add ((GSourceFunc) idle_eos, data);

   521             gst_element_set_state ( GST_ELEMENT (GST_MESSAGE_SRC (msg)), GST_STATE_NULL );

   522 	    gst_element_set_locked_state ( GST_ELEMENT (GST_MESSAGE_SRC (msg)), TRUE );

   523             break;

   524         case GST_MESSAGE_ERROR:

   525         {

   526                 gchar *debug;

   527                 GError *err;

   528 

   529                 gst_message_parse_error (msg, &err, &debug);

   530                 g_free (debug);

   531 

   532                 printf ("Error: %s\n", err->message);

   533                 g_error_free (err);

   534 

   535                 //g_main_loop_quit (loop);

   536         }

   537             break;

   538         default:

   539             printf (gst_message_type_get_name (GST_MESSAGE_TYPE (msg)));

   540             printf ("\n");

   541             break;

   542     }

   543 

   544     return TRUE;

   545 }

   546 

   547 

   548 #if 0

   549 static gboolean

   550 idle_state (gpointer data)

   551 {

   552     GstPlayerWindowStateChange *st = data;

   553 

   554     if (st->old_state == GST_STATE_PLAYING) {

   555         if (st->miptv_ui->idle_id != 0) {

   556             g_source_remove (st->miptv_ui->idle_id);

   557             st->miptv_ui->idle_id = 0;

   558         }

   559     }

   560     else if (st->new_state == GST_STATE_PLAYING) {

   561         if (st->miptv_ui->idle_id != 0)

   562             g_source_remove (st->miptv_ui->idle_id);

   563 

   564         st->miptv_ui->idle_id = g_idle_add (cb_iterate, st->miptv_ui);

   565     }

   566 

   567     /* new movie loaded? */

   568     if (st->old_state == GST_STATE_READY && st->new_state > GST_STATE_READY) {

   569 

   570         /* gboolean have_video = FALSE; */

   571 

   572         gtk_widget_show (st->miptv_ui->videow);

   573 

   574         gtk_window_resize (GTK_WINDOW (st->miptv_ui->main_window), 1, 1);

   575 

   576     }

   577 

   578     /* discarded movie? */

   579     if (st->old_state > GST_STATE_READY && st->new_state == GST_STATE_READY) {

   580 

   581         if (st->miptv_ui->tagcache) {

   582             gst_tag_list_free (st->miptv_ui->tagcache);

   583             st->miptv_ui->tagcache = NULL;

   584         }

   585     }

   586 

   587     gst_object_unref (GST_OBJECT (st->play));

   588     //g_object_unref (G_OBJECT (st->win));

   589     g_free (st);

   590 

   591     /* once */

   592     return FALSE;

   593 }

   594 

   595 #endif

   596 

   597 /** Stops playing the current A/V.

   598  *

   599  * FIXME: How to proceed differently between livetv 

   600  * and recorded content?

   601  *

   602  * @param tvplayer the object instance.

   603  * @return void 

   604  */

   605 void

   606 mmyth_tvplayer_stop_playing (MMythTVPlayer *tvplayer) 

   607 {

   608     g_debug ("[%s] Setting gstreamer pipeline state to NULL", __FUNCTION__);

   609 

   610     gst_element_set_state (tvplayer->gst_pipeline, GST_STATE_NULL);

   611     

   612     if (tvplayer->is_livetv) {

   613 	    if (!gmyth_recorder_stop_livetv (tvplayer->recorder)) {

   614 	    	g_warning ("[%s] Error while stoping remote encoder", __FUNCTION__);	

   615 	    }

   616     }

   617 }

   618 

   619 /** Queries if the tvplayer is active playing A/V content.

   620  *

   621  * @param tvplayer the object instance.

   622  * @return TRUE if the tvplayer is active, FALSE otherwise.

   623  */

   624 gboolean

   625 mmyth_tvplayer_is_playing (MMythTVPlayer *tvplayer)

   626 {

   627 	return (GST_STATE (tvplayer->gst_pipeline) == GST_STATE_PLAYING);

   628 }

   629 

   630 /** Static function that sets the tvplayer state to PLAYING.

   631  *

   632  * @param tvplayer the object instance.

   633  * @return TRUE if the tvplayer is active, FALSE otherwise.

   634  */

   635 static gboolean

   636 idle_play (gpointer data)

   637 {

   638     MMythTVPlayer *tvplayer = MMYTH_TVPLAYER (data);

   639 

   640 	g_debug ("MMythTVPlayer: Setting pipeline state to PLAYING\n");

   641 

   642     gst_element_set_state (tvplayer->gst_pipeline, GST_STATE_PLAYING);

   643 

   644     return FALSE;

   645 }

   646 

   647 /** Start playing A/V with the tvplayer attributes.

   648  *

   649  * @param tvplayer the object instance.

   650  */

   651 void

   652 mmyth_tvplayer_start_playing (MMythTVPlayer *tvplayer)

   653 {

   654 

   655 	// FIXME: Move this to livetv_setup??

   656 	if (tvplayer->is_livetv) {

   657 

   658 	#if 0

   659 		if (!tvplayer || !(tvplayer->proginfo) || !(tvplayer->local_hostname)

   660 				|| !(tvplayer->gst_source)) {

   661 			g_warning ("GMythtvPlayer not ready to start playing\n");		

   662 		}

   663 

   664 		if (!(tvplayer->proginfo->pathname)) {

   665 			g_warning ("[%s] Playback url is null, could not play the myth content", __FUNCTION__);

   666 			return;

   667 		}

   668 

   669 		g_debug ("MMythTVPlayer: Start playing %s", tvplayer->proginfo->pathname->str);

   670 #endif

   671 		g_object_set (G_OBJECT (tvplayer->gst_source), "mythtv-live",

   672 				TRUE, NULL);

   673 #if 0

   674 		if ( tvplayer->tvchain != NULL ) {

   675 			GString *str_chainid = gmyth_tvchain_get_id(tvplayer->tvchain);

   676 			g_print( "[%s]\tCHAIN ID: %s\n", __FUNCTION__, str_chainid->str );

   677 

   678 			g_object_set (G_OBJECT (tvplayer->gst_source), "mythtv-live-chainid", 

   679 					g_strdup( str_chainid->str ), NULL);      

   680 			if ( str_chainid!=NULL)

   681 				g_string_free( str_chainid, FALSE );

   682 		}

   683 

   684 		if ( tvplayer->recorder != NULL )	

   685 			g_object_set (G_OBJECT (tvplayer->gst_source), "mythtv-live-id",

   686 					tvplayer->recorder->recorder_num, NULL );

   687 		g_debug ("[%s] Setting location to %s", __FUNCTION__, 

   688 				tvplayer->proginfo->pathname->str);

   689 

   690 		/* Sets the gstreamer properties acording to the service access address */

   691 		g_object_set (G_OBJECT (tvplayer->gst_source), "location",

   692 				tvplayer->proginfo->pathname->str, NULL);              

   693 #endif

   694 	}

   695 

   696 	g_object_set (G_OBJECT (tvplayer->gst_source), "mythtv-version",

   697               MYTHTV_VERSION_DEFAULT, NULL);

   698 

   699     g_object_set (G_OBJECT (tvplayer->gst_source), "mythtv-debug",

   700               TRUE, NULL);

   701 

   702     g_idle_add (idle_play, tvplayer);

   703 

   704 }

   705
gmyth