1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/branches/gmyth-0.1b/src/gmyth_tvchain.c Wed Feb 14 21:28:49 2007 +0000
1.3 @@ -0,0 +1,390 @@
1.4 +/**
1.5 + * GMyth Library
1.6 + *
1.7 + * @file gmyth/gmyth_tvchain.c
1.8 + *
1.9 + * @brief <p> This component contains functions for creating and accessing
1.10 + * the tvchain functions for live tv playback.
1.11 + *
1.12 + * Copyright (C) 2006 INdT - Instituto Nokia de Tecnologia.
1.13 + * @author Hallyson Luiz de Morais Melo <hallyson.melo@indt.org.br>
1.14 + *
1.15 + *//*
1.16 + *
1.17 + * This program is free software; you can redistribute it and/or modify
1.18 + * it under the terms of the GNU Lesser General Public License as published by
1.19 + * the Free Software Foundation; either version 2 of the License, or
1.20 + * (at your option) any later version.
1.21 + *
1.22 + * This program is distributed in the hope that it will be useful,
1.23 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
1.24 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
1.25 + * GNU General Public License for more details.
1.26 + *
1.27 + * You should have received a copy of the GNU Lesser General Public License
1.28 + * along with this program; if not, write to the Free Software
1.29 + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
1.30 + */
1.31 +
1.32 +#ifdef HAVE_CONFIG_H
1.33 +#include "config.h"
1.34 +#endif
1.35 +
1.36 +#include "gmyth_tvchain.h"
1.37 +
1.38 +#include <glib.h>
1.39 +#include <time.h>
1.40 +#include <stdio.h>
1.41 +#include <stdlib.h>
1.42 +#include <assert.h>
1.43 +
1.44 +#include "gmyth_epg.h"
1.45 +#include "gmyth_util.h"
1.46 +#include "gmyth_query.h"
1.47 +#include "gmyth_scheduler.h"
1.48 +#include "gmyth_debug.h"
1.49 +
1.50 +static void gmyth_tvchain_class_init (GMythTVChainClass *klass);
1.51 +static void gmyth_tvchain_init (GMythTVChain *object);
1.52 +
1.53 +static void gmyth_tvchain_dispose (GObject *object);
1.54 +static void gmyth_tvchain_finalize (GObject *object);
1.55 +
1.56 +G_DEFINE_TYPE(GMythTVChain, gmyth_tvchain, G_TYPE_OBJECT)
1.57 +
1.58 +static GStaticMutex mutex = G_STATIC_MUTEX_INIT;
1.59 +
1.60 +static void
1.61 +gmyth_tvchain_class_init (GMythTVChainClass *klass)
1.62 +{
1.63 + GObjectClass *gobject_class;
1.64 +
1.65 + gobject_class = (GObjectClass *) klass;
1.66 +
1.67 + gobject_class->dispose = gmyth_tvchain_dispose;
1.68 + gobject_class->finalize = gmyth_tvchain_finalize;
1.69 +}
1.70 +
1.71 +static void
1.72 +gmyth_tvchain_init (GMythTVChain *tvchain)
1.73 +{
1.74 + tvchain->tvchain_id = NULL;
1.75 +
1.76 + tvchain->cur_chanid = g_string_new ("");
1.77 + tvchain->cur_startts = NULL;
1.78 +}
1.79 +
1.80 +static void
1.81 +gmyth_tvchain_dispose (GObject *object)
1.82 +{
1.83 + GMythTVChain *tvchain = GMYTH_TVCHAIN(object);
1.84 +
1.85 + if ( tvchain->tvchain_id != NULL ) {
1.86 + g_string_free( tvchain->tvchain_id, TRUE );
1.87 + tvchain->tvchain_id = NULL;
1.88 + }
1.89 +
1.90 + if ( tvchain->tvchain_list != NULL ) {
1.91 + g_list_free( tvchain->tvchain_list );
1.92 + tvchain->tvchain_list = NULL;
1.93 + }
1.94 +
1.95 + if ( tvchain->cur_chanid != NULL ) {
1.96 + g_string_free( tvchain->cur_chanid, TRUE );
1.97 + tvchain->cur_chanid = NULL;
1.98 + }
1.99 +
1.100 + if ( tvchain->backend_info) {
1.101 + g_object_unref (tvchain->backend_info);
1.102 + tvchain->backend_info = NULL;
1.103 + }
1.104 +
1.105 +
1.106 + G_OBJECT_CLASS (gmyth_tvchain_parent_class)->dispose (object);
1.107 +}
1.108 +
1.109 +static void
1.110 +gmyth_tvchain_finalize (GObject *object)
1.111 +{
1.112 + g_signal_handlers_destroy (object);
1.113 +
1.114 + G_OBJECT_CLASS (gmyth_tvchain_parent_class)->finalize (object);
1.115 +}
1.116 +
1.117 +/** Initializes the tvchain and generates the tvchain id.
1.118 + *
1.119 + * @param tvchain The GMythTVChain instance.
1.120 + * @param hostname The local hostname used to generate the tvchain id.
1.121 + */
1.122 +gboolean
1.123 +gmyth_tvchain_initialize (GMythTVChain *tvchain, GMythBackendInfo *backend_info)
1.124 +{
1.125 + const char *hostname;
1.126 +
1.127 + assert (tvchain);
1.128 + g_return_val_if_fail (backend_info != NULL, FALSE);
1.129 +
1.130 + g_object_ref (backend_info);
1.131 + tvchain->backend_info = backend_info;
1.132 +
1.133 + hostname = gmyth_backend_info_get_hostname (backend_info);
1.134 +
1.135 + if (tvchain->tvchain_id == NULL) {
1.136 + gchar *isodate = NULL;
1.137 + GTimeVal *cur_time = g_new0( GTimeVal, 1 );
1.138 + //struct tm* gmyth_util_time_val_to_date ( const GTimeVal* time )
1.139 +
1.140 + g_get_current_time(cur_time);
1.141 + isodate = gmyth_util_time_to_isoformat_from_time_val_fmt ( "%Y-%m-%dT%H:%M:%S", cur_time );
1.142 +
1.143 + tvchain->tvchain_id = g_string_sized_new (7 + strlen (hostname) + strlen(isodate));
1.144 + g_string_printf(tvchain->tvchain_id,
1.145 + "live-%s-%s", hostname, isodate);
1.146 +
1.147 + gmyth_debug ("[%s] tv_chain_id: %s", __FUNCTION__, tvchain->tvchain_id->str);
1.148 +
1.149 + if (isodate)
1.150 + g_free(isodate);
1.151 +
1.152 + if ( cur_time )
1.153 + g_free( cur_time );
1.154 + } else {
1.155 + g_warning ("[%s] TVchain already initialized", __FUNCTION__);
1.156 + }
1.157 +
1.158 + return TRUE;
1.159 +}
1.160 +
1.161 +/** Gets the tvchain id.
1.162 + *
1.163 + * @param tvchain The GMythTVChain instance.
1.164 + * @return The tvchain id.
1.165 + */
1.166 +GString*
1.167 +gmyth_tvchain_get_id (GMythTVChain *tvchain)
1.168 +{
1.169 + g_return_val_if_fail( tvchain != NULL && tvchain->tvchain_id != NULL, NULL );
1.170 +
1.171 + return g_string_new (tvchain->tvchain_id->str);
1.172 +}
1.173 +
1.174 +/** Reloads all tvchain entries in the database.
1.175 + *
1.176 + * @param tvchain The GMythTVChain instance.
1.177 + * @return TRUE if success, or FALSE if error.
1.178 + */
1.179 +gboolean
1.180 +gmyth_tvchain_reload_all (GMythTVChain *tvchain)
1.181 +{
1.182 + MYSQL_ROW msql_row;
1.183 + MYSQL_RES *msql_res = NULL;
1.184 + GMythQuery *gmyth_query = NULL;
1.185 + gboolean ret = TRUE;
1.186 + GString *stmt_str = NULL;
1.187 +
1.188 + g_static_mutex_lock( &mutex );
1.189 +
1.190 + /* gets the initial size of the TVChain entries list */
1.191 + guint prev_size = g_list_length (tvchain->tvchain_list);
1.192 +
1.193 + gmyth_debug ("[%s] chainid: %s", __FUNCTION__, tvchain->tvchain_id->str);
1.194 +
1.195 + if ( tvchain != NULL && tvchain->tvchain_list != NULL ) {
1.196 + g_list_free (tvchain->tvchain_list);
1.197 + tvchain->tvchain_list = NULL;
1.198 + }
1.199 +
1.200 + // TODO: Reuse gmyth_query already connected from context
1.201 + gmyth_query = gmyth_query_new ();
1.202 + if (!gmyth_query_connect (gmyth_query, tvchain->backend_info)) {
1.203 + g_warning ("[%s] Could not connect to db", __FUNCTION__);
1.204 + g_static_mutex_unlock( &mutex );
1.205 + ret = FALSE;
1.206 + goto done;
1.207 + }
1.208 +
1.209 + stmt_str = g_string_new ("");
1.210 + g_string_printf (stmt_str,
1.211 + "SELECT chanid, starttime, endtime, discontinuity, "
1.212 + "chainpos, hostprefix, cardtype, channame, input "
1.213 + "FROM tvchain "
1.214 + "WHERE chainid = \"%s\" ORDER BY chainpos;",
1.215 + tvchain->tvchain_id->str);
1.216 +
1.217 + msql_res = gmyth_query_process_statement(gmyth_query, stmt_str->str);
1.218 + if (msql_res != NULL) {
1.219 +
1.220 + while ((msql_row = mysql_fetch_row (msql_res)) != NULL) {
1.221 + struct LiveTVChainEntry *entry = g_new0 (struct LiveTVChainEntry, 1);
1.222 + entry->chanid = g_string_new (msql_row[0]);
1.223 + entry->starttime = gmyth_util_string_to_time_val ((const gchar*) msql_row[1]);
1.224 + entry->endtime = gmyth_util_string_to_time_val ((const gchar*) msql_row[2]);
1.225 + entry->discontinuity = g_ascii_strtoull (msql_row[3], NULL, 10 ) != 0;
1.226 + entry->hostprefix = g_string_new (msql_row[5]);
1.227 + entry->cardtype = g_string_new (msql_row[6]);
1.228 + entry->channum = g_string_new (msql_row[7]);
1.229 + entry->inputname = g_string_new (msql_row[8]);
1.230 +
1.231 + //m_maxpos = query.value(4).toInt() + 1;
1.232 + g_print( "[%s] Reading TV chain entry (channel %s): [%s, %s, %s]\n", __FUNCTION__, entry->channum->str, entry->chanid->str,
1.233 + (gchar*)msql_row[1], (gchar*)msql_row[2] );
1.234 +
1.235 + /* add this to get the actual start timestamp of the last recording */
1.236 + if ( tvchain->cur_startts < entry->starttime )
1.237 + tvchain->cur_startts = entry->starttime;
1.238 +
1.239 + tvchain->tvchain_list = g_list_append (tvchain->tvchain_list, entry);
1.240 + }
1.241 + } else {
1.242 + g_warning ("gmyth_tvchain_reload_all query error!\n");
1.243 + g_static_mutex_unlock( &mutex );
1.244 +
1.245 + ret = FALSE;
1.246 + goto done;
1.247 + }
1.248 +
1.249 + g_static_mutex_unlock( &mutex );
1.250 +
1.251 + tvchain->cur_pos = gmyth_tvchain_program_is_at (tvchain, tvchain->cur_chanid, tvchain->cur_startts);
1.252 + g_print( "[%s] TVChain current position = %d.\n", __FUNCTION__, tvchain->cur_pos );
1.253 +
1.254 + if (tvchain->cur_pos < 0)
1.255 + tvchain->cur_pos = 0;
1.256 +
1.257 + // if (m_switchid >= 0)
1.258 + // m_switchid = ProgramIsAt(m_switchentry.chanid,m_switchentry.starttime);
1.259 +
1.260 + if (prev_size != g_list_length (tvchain->tvchain_list)) {
1.261 + gmyth_debug ("[%s] Added new recording", __FUNCTION__);
1.262 + }
1.263 +
1.264 +done:
1.265 + if ( stmt_str != NULL )
1.266 + g_string_free (stmt_str, TRUE);
1.267 +
1.268 + if ( msql_res != NULL )
1.269 + mysql_free_result (msql_res);
1.270 +
1.271 + if ( gmyth_query != NULL )
1.272 + g_object_unref (gmyth_query);
1.273 +
1.274 + return ret;
1.275 +}
1.276 +
1.277 +/** Returns the internal index for the TV chain related to the given
1.278 + * channel and start time.
1.279 + *
1.280 + * @param tvchain The GMythTVChain instance.
1.281 + * @param chanid The channel id.
1.282 + * @param startts The program start time.
1.283 + */
1.284 +gint
1.285 +gmyth_tvchain_program_is_at (GMythTVChain *tvchain, GString *chanid, GTimeVal* startts)
1.286 +{
1.287 + gint count = 0;
1.288 + struct LiveTVChainEntry *entry;
1.289 + GList *tmp_list = tvchain->tvchain_list;
1.290 + guint list_size = g_list_length (tvchain->tvchain_list);
1.291 +
1.292 + g_static_mutex_lock( &mutex );
1.293 +
1.294 + for (; tmp_list && ( count < list_size ); tmp_list = tvchain->tvchain_list->next, count++)
1.295 + {
1.296 + entry = (struct LiveTVChainEntry*) tmp_list->data;
1.297 + if ( !g_strncasecmp (entry->chanid->str, chanid->str, chanid->len)
1.298 + && entry->starttime == startts )
1.299 + {
1.300 + g_static_mutex_unlock( &mutex );
1.301 + return count;
1.302 + }
1.303 + }
1.304 + g_static_mutex_unlock( &mutex );
1.305 +
1.306 + return -1;
1.307 +}
1.308 +
1.309 +/** Get the program info associated to the tvchain.
1.310 + *
1.311 + * @param tvchain The GMythTVChain instance.
1.312 + * @param index The tvchain index.
1.313 + * @return The program info structure.
1.314 + */
1.315 +GMythProgramInfo*
1.316 +gmyth_tvchain_get_program_at (GMythTVChain *tvchain, gint index)
1.317 +{
1.318 + struct LiveTVChainEntry *entry;
1.319 +
1.320 + entry = gmyth_tvchain_get_entry_at (tvchain, index);
1.321 +
1.322 + if (entry)
1.323 + return gmyth_tvchain_entry_to_program (tvchain, entry);
1.324 +
1.325 + return NULL;
1.326 +}
1.327 +
1.328 +/** Gets a LiveTVChainEntry associated to the tvchain by its index.
1.329 + *
1.330 + * @param tvchain The GMythTVChain instance.
1.331 + * @param index The tvchain entry index
1.332 + * @return The LiveTVchainEntry structure.
1.333 + */
1.334 +struct LiveTVChainEntry*
1.335 +gmyth_tvchain_get_entry_at (GMythTVChain *tvchain, gint index)
1.336 +{
1.337 + struct LiveTVChainEntry* chain_entry = NULL;
1.338 +
1.339 + g_return_val_if_fail( tvchain != NULL && tvchain->tvchain_list != NULL, NULL );
1.340 +
1.341 + g_static_mutex_lock( &mutex );
1.342 +
1.343 + gint size = g_list_length (tvchain->tvchain_list);
1.344 + gint new_index = (index < 0 || index >= size) ? size - 1 : index;
1.345 +
1.346 + if (new_index >= 0)
1.347 + chain_entry = (struct LiveTVChainEntry*) g_list_nth_data (tvchain->tvchain_list, new_index);
1.348 +
1.349 + g_static_mutex_unlock( &mutex );
1.350 +
1.351 + if ( chain_entry != NULL ) {
1.352 + gmyth_debug ("[%s] Got TV Chain entry at %d.\n", __FUNCTION__, new_index );
1.353 +
1.354 + } else {
1.355 + g_warning ("[%s] failed to get entry at index %d", __FUNCTION__, index);
1.356 + }
1.357 +
1.358 + return chain_entry;
1.359 +}
1.360 +
1.361 +/** Gets the program info from backend database associated to the tv chain entry.
1.362 + *
1.363 + * @param tvchain The GMythTVChain instance.
1.364 + * @param entry the LiveTVChainEntry to be converted.
1.365 + * @return The progrma info.
1.366 + */
1.367 +GMythProgramInfo*
1.368 +gmyth_tvchain_entry_to_program (GMythTVChain *tvchain, struct LiveTVChainEntry *entry)
1.369 +{
1.370 + GMythProgramInfo *proginfo = NULL;
1.371 +
1.372 + g_return_val_if_fail( tvchain != NULL, NULL );
1.373 +
1.374 + if ( !entry || !tvchain ) {
1.375 + g_warning ("gmyth_tvchain_entry_to_program() received NULL argument");
1.376 + return NULL;
1.377 + }
1.378 +
1.379 + GMythScheduler *scheduler = gmyth_scheduler_new ();
1.380 +
1.381 + gmyth_scheduler_connect( scheduler, tvchain->backend_info );
1.382 + proginfo = gmyth_scheduler_get_recorded (scheduler,
1.383 + entry->chanid, entry->starttime);
1.384 + gmyth_scheduler_disconnect( scheduler );
1.385 +
1.386 + if (proginfo) {
1.387 + proginfo->pathname = g_string_prepend (proginfo->pathname, entry->hostprefix->str);
1.388 + } else {
1.389 + g_warning ("tvchain_entry_to_program( chan id = %s, starttime = %ld) failed!", entry->chanid->str, entry->starttime->tv_sec);
1.390 + }
1.391 +
1.392 + return proginfo;
1.393 +}