renatofilho@320: /** renatofilho@320: * GMyth Library renatofilho@320: * renatofilho@320: * @file gmyth/gmyth_tvchain.c renatofilho@320: * renatofilho@320: * @brief

This component contains functions for creating and accessing renatofilho@320: * the tvchain functions for live tv playback. renatofilho@320: * renatofilho@320: * Copyright (C) 2006 INdT - Instituto Nokia de Tecnologia. renatofilho@320: * @author Hallyson Luiz de Morais Melo renatofilho@320: * renatofilho@320: *//* renatofilho@320: * renatofilho@320: * This program is free software; you can redistribute it and/or modify renatofilho@320: * it under the terms of the GNU Lesser General Public License as published by renatofilho@320: * the Free Software Foundation; either version 2 of the License, or renatofilho@320: * (at your option) any later version. renatofilho@320: * renatofilho@320: * This program is distributed in the hope that it will be useful, renatofilho@320: * but WITHOUT ANY WARRANTY; without even the implied warranty of renatofilho@320: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the renatofilho@320: * GNU General Public License for more details. renatofilho@320: * renatofilho@320: * You should have received a copy of the GNU Lesser General Public License renatofilho@320: * along with this program; if not, write to the Free Software renatofilho@320: * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA renatofilho@320: */ renatofilho@320: renatofilho@320: #ifdef HAVE_CONFIG_H renatofilho@320: #include "config.h" renatofilho@320: #endif renatofilho@320: renatofilho@320: #include "gmyth_tvchain.h" renatofilho@320: renatofilho@320: #include renatofilho@320: #include renatofilho@320: #include renatofilho@320: #include renatofilho@320: #include renatofilho@320: renatofilho@320: #include "gmyth_epg.h" renatofilho@320: #include "gmyth_util.h" renatofilho@320: #include "gmyth_query.h" renatofilho@320: #include "gmyth_scheduler.h" renatofilho@320: #include "gmyth_debug.h" renatofilho@320: renatofilho@320: static void gmyth_tvchain_class_init (GMythTVChainClass *klass); renatofilho@320: static void gmyth_tvchain_init (GMythTVChain *object); renatofilho@320: renatofilho@320: static void gmyth_tvchain_dispose (GObject *object); renatofilho@320: static void gmyth_tvchain_finalize (GObject *object); renatofilho@320: renatofilho@320: G_DEFINE_TYPE(GMythTVChain, gmyth_tvchain, G_TYPE_OBJECT) renatofilho@320: renatofilho@320: static GStaticMutex mutex = G_STATIC_MUTEX_INIT; renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_tvchain_class_init (GMythTVChainClass *klass) renatofilho@320: { renatofilho@320: GObjectClass *gobject_class; renatofilho@320: renatofilho@320: gobject_class = (GObjectClass *) klass; renatofilho@320: renatofilho@320: gobject_class->dispose = gmyth_tvchain_dispose; renatofilho@320: gobject_class->finalize = gmyth_tvchain_finalize; renatofilho@320: } renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_tvchain_init (GMythTVChain *tvchain) renatofilho@320: { renatofilho@320: tvchain->tvchain_id = NULL; renatofilho@320: renatofilho@320: tvchain->cur_chanid = g_string_new (""); renatofilho@320: tvchain->cur_startts = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_tvchain_dispose (GObject *object) renatofilho@320: { renatofilho@320: GMythTVChain *tvchain = GMYTH_TVCHAIN(object); renatofilho@320: renatofilho@320: if ( tvchain->tvchain_id != NULL ) { renatofilho@320: g_string_free( tvchain->tvchain_id, TRUE ); renatofilho@320: tvchain->tvchain_id = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: if ( tvchain->tvchain_list != NULL ) { renatofilho@320: g_list_free( tvchain->tvchain_list ); renatofilho@320: tvchain->tvchain_list = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: if ( tvchain->cur_chanid != NULL ) { renatofilho@320: g_string_free( tvchain->cur_chanid, TRUE ); renatofilho@320: tvchain->cur_chanid = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: if ( tvchain->backend_info) { renatofilho@320: g_object_unref (tvchain->backend_info); renatofilho@320: tvchain->backend_info = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: renatofilho@320: G_OBJECT_CLASS (gmyth_tvchain_parent_class)->dispose (object); renatofilho@320: } renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_tvchain_finalize (GObject *object) renatofilho@320: { renatofilho@320: g_signal_handlers_destroy (object); renatofilho@320: renatofilho@320: G_OBJECT_CLASS (gmyth_tvchain_parent_class)->finalize (object); renatofilho@320: } renatofilho@320: renatofilho@320: /** Initializes the tvchain and generates the tvchain id. renatofilho@320: * renatofilho@320: * @param tvchain The GMythTVChain instance. renatofilho@320: * @param hostname The local hostname used to generate the tvchain id. renatofilho@320: */ renatofilho@320: gboolean renatofilho@320: gmyth_tvchain_initialize (GMythTVChain *tvchain, GMythBackendInfo *backend_info) renatofilho@320: { renatofilho@320: const char *hostname; renatofilho@320: renatofilho@320: assert (tvchain); renatofilho@320: g_return_val_if_fail (backend_info != NULL, FALSE); renatofilho@320: renatofilho@320: g_object_ref (backend_info); renatofilho@320: tvchain->backend_info = backend_info; renatofilho@320: renatofilho@320: hostname = gmyth_backend_info_get_hostname (backend_info); renatofilho@320: renatofilho@320: if (tvchain->tvchain_id == NULL) { renatofilho@320: gchar *isodate = NULL; renatofilho@320: GTimeVal *cur_time = g_new0( GTimeVal, 1 ); renatofilho@320: //struct tm* gmyth_util_time_val_to_date ( const GTimeVal* time ) renatofilho@320: renatofilho@320: g_get_current_time(cur_time); renatofilho@320: isodate = gmyth_util_time_to_isoformat_from_time_val_fmt ( "%Y-%m-%dT%H:%M:%S", cur_time ); renatofilho@320: renatofilho@320: tvchain->tvchain_id = g_string_sized_new (7 + strlen (hostname) + strlen(isodate)); renatofilho@320: g_string_printf(tvchain->tvchain_id, renatofilho@320: "live-%s-%s", hostname, isodate); renatofilho@320: renatofilho@320: gmyth_debug ("[%s] tv_chain_id: %s", __FUNCTION__, tvchain->tvchain_id->str); renatofilho@320: renatofilho@320: if (isodate) renatofilho@320: g_free(isodate); renatofilho@320: renatofilho@320: if ( cur_time ) renatofilho@320: g_free( cur_time ); renatofilho@320: } else { renatofilho@320: g_warning ("[%s] TVchain already initialized", __FUNCTION__); renatofilho@320: } renatofilho@320: renatofilho@320: return TRUE; renatofilho@320: } renatofilho@320: renatofilho@320: /** Gets the tvchain id. renatofilho@320: * renatofilho@320: * @param tvchain The GMythTVChain instance. renatofilho@320: * @return The tvchain id. renatofilho@320: */ renatofilho@320: GString* renatofilho@320: gmyth_tvchain_get_id (GMythTVChain *tvchain) renatofilho@320: { renatofilho@320: g_return_val_if_fail( tvchain != NULL && tvchain->tvchain_id != NULL, NULL ); renatofilho@320: renatofilho@320: return g_string_new (tvchain->tvchain_id->str); renatofilho@320: } renatofilho@320: renatofilho@320: /** Reloads all tvchain entries in the database. renatofilho@320: * renatofilho@320: * @param tvchain The GMythTVChain instance. renatofilho@320: * @return TRUE if success, or FALSE if error. renatofilho@320: */ renatofilho@320: gboolean renatofilho@320: gmyth_tvchain_reload_all (GMythTVChain *tvchain) renatofilho@320: { renatofilho@320: MYSQL_ROW msql_row; renatofilho@320: MYSQL_RES *msql_res = NULL; renatofilho@320: GMythQuery *gmyth_query = NULL; renatofilho@320: gboolean ret = TRUE; renatofilho@320: GString *stmt_str = NULL; renatofilho@320: renatofilho@320: g_static_mutex_lock( &mutex ); renatofilho@320: renatofilho@320: /* gets the initial size of the TVChain entries list */ renatofilho@320: guint prev_size = g_list_length (tvchain->tvchain_list); renatofilho@320: renatofilho@320: gmyth_debug ("[%s] chainid: %s", __FUNCTION__, tvchain->tvchain_id->str); renatofilho@320: renatofilho@320: if ( tvchain != NULL && tvchain->tvchain_list != NULL ) { renatofilho@320: g_list_free (tvchain->tvchain_list); renatofilho@320: tvchain->tvchain_list = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: // TODO: Reuse gmyth_query already connected from context renatofilho@320: gmyth_query = gmyth_query_new (); renatofilho@320: if (!gmyth_query_connect (gmyth_query, tvchain->backend_info)) { renatofilho@320: g_warning ("[%s] Could not connect to db", __FUNCTION__); renatofilho@320: g_static_mutex_unlock( &mutex ); renatofilho@320: ret = FALSE; renatofilho@320: goto done; renatofilho@320: } renatofilho@320: renatofilho@320: stmt_str = g_string_new (""); renatofilho@320: g_string_printf (stmt_str, renatofilho@320: "SELECT chanid, starttime, endtime, discontinuity, " renatofilho@320: "chainpos, hostprefix, cardtype, channame, input " renatofilho@320: "FROM tvchain " renatofilho@320: "WHERE chainid = \"%s\" ORDER BY chainpos;", renatofilho@320: tvchain->tvchain_id->str); renatofilho@320: renatofilho@320: msql_res = gmyth_query_process_statement(gmyth_query, stmt_str->str); renatofilho@320: if (msql_res != NULL) { renatofilho@320: renatofilho@320: while ((msql_row = mysql_fetch_row (msql_res)) != NULL) { renatofilho@320: struct LiveTVChainEntry *entry = g_new0 (struct LiveTVChainEntry, 1); renatofilho@320: entry->chanid = g_string_new (msql_row[0]); renatofilho@320: entry->starttime = gmyth_util_string_to_time_val ((const gchar*) msql_row[1]); renatofilho@320: entry->endtime = gmyth_util_string_to_time_val ((const gchar*) msql_row[2]); renatofilho@320: entry->discontinuity = g_ascii_strtoull (msql_row[3], NULL, 10 ) != 0; renatofilho@320: entry->hostprefix = g_string_new (msql_row[5]); renatofilho@320: entry->cardtype = g_string_new (msql_row[6]); renatofilho@320: entry->channum = g_string_new (msql_row[7]); renatofilho@320: entry->inputname = g_string_new (msql_row[8]); renatofilho@320: renatofilho@320: //m_maxpos = query.value(4).toInt() + 1; renatofilho@320: g_print( "[%s] Reading TV chain entry (channel %s): [%s, %s, %s]\n", __FUNCTION__, entry->channum->str, entry->chanid->str, renatofilho@320: (gchar*)msql_row[1], (gchar*)msql_row[2] ); renatofilho@320: renatofilho@320: /* add this to get the actual start timestamp of the last recording */ renatofilho@320: if ( tvchain->cur_startts < entry->starttime ) renatofilho@320: tvchain->cur_startts = entry->starttime; renatofilho@320: renatofilho@320: tvchain->tvchain_list = g_list_append (tvchain->tvchain_list, entry); renatofilho@320: } renatofilho@320: } else { renatofilho@320: g_warning ("gmyth_tvchain_reload_all query error!\n"); renatofilho@320: g_static_mutex_unlock( &mutex ); renatofilho@320: renatofilho@320: ret = FALSE; renatofilho@320: goto done; renatofilho@320: } renatofilho@320: renatofilho@320: g_static_mutex_unlock( &mutex ); renatofilho@320: renatofilho@320: tvchain->cur_pos = gmyth_tvchain_program_is_at (tvchain, tvchain->cur_chanid, tvchain->cur_startts); renatofilho@320: g_print( "[%s] TVChain current position = %d.\n", __FUNCTION__, tvchain->cur_pos ); renatofilho@320: renatofilho@320: if (tvchain->cur_pos < 0) renatofilho@320: tvchain->cur_pos = 0; renatofilho@320: renatofilho@320: // if (m_switchid >= 0) renatofilho@320: // m_switchid = ProgramIsAt(m_switchentry.chanid,m_switchentry.starttime); renatofilho@320: renatofilho@320: if (prev_size != g_list_length (tvchain->tvchain_list)) { renatofilho@320: gmyth_debug ("[%s] Added new recording", __FUNCTION__); renatofilho@320: } renatofilho@320: renatofilho@320: done: renatofilho@320: if ( stmt_str != NULL ) renatofilho@320: g_string_free (stmt_str, TRUE); renatofilho@320: renatofilho@320: if ( msql_res != NULL ) renatofilho@320: mysql_free_result (msql_res); renatofilho@320: renatofilho@320: if ( gmyth_query != NULL ) renatofilho@320: g_object_unref (gmyth_query); renatofilho@320: renatofilho@320: return ret; renatofilho@320: } renatofilho@320: renatofilho@320: /** Returns the internal index for the TV chain related to the given renatofilho@320: * channel and start time. renatofilho@320: * renatofilho@320: * @param tvchain The GMythTVChain instance. renatofilho@320: * @param chanid The channel id. renatofilho@320: * @param startts The program start time. renatofilho@320: */ renatofilho@320: gint renatofilho@320: gmyth_tvchain_program_is_at (GMythTVChain *tvchain, GString *chanid, GTimeVal* startts) renatofilho@320: { renatofilho@320: gint count = 0; renatofilho@320: struct LiveTVChainEntry *entry; renatofilho@320: GList *tmp_list = tvchain->tvchain_list; renatofilho@320: guint list_size = g_list_length (tvchain->tvchain_list); renatofilho@320: renatofilho@320: g_static_mutex_lock( &mutex ); renatofilho@320: renatofilho@320: for (; tmp_list && ( count < list_size ); tmp_list = tvchain->tvchain_list->next, count++) renatofilho@320: { renatofilho@320: entry = (struct LiveTVChainEntry*) tmp_list->data; renatofilho@320: if ( !g_strncasecmp (entry->chanid->str, chanid->str, chanid->len) renatofilho@320: && entry->starttime == startts ) renatofilho@320: { renatofilho@320: g_static_mutex_unlock( &mutex ); renatofilho@320: return count; renatofilho@320: } renatofilho@320: } renatofilho@320: g_static_mutex_unlock( &mutex ); renatofilho@320: renatofilho@320: return -1; renatofilho@320: } renatofilho@320: renatofilho@320: /** Get the program info associated to the tvchain. renatofilho@320: * renatofilho@320: * @param tvchain The GMythTVChain instance. renatofilho@320: * @param index The tvchain index. renatofilho@320: * @return The program info structure. renatofilho@320: */ renatofilho@320: GMythProgramInfo* renatofilho@320: gmyth_tvchain_get_program_at (GMythTVChain *tvchain, gint index) renatofilho@320: { renatofilho@320: struct LiveTVChainEntry *entry; renatofilho@320: renatofilho@320: entry = gmyth_tvchain_get_entry_at (tvchain, index); renatofilho@320: renatofilho@320: if (entry) renatofilho@320: return gmyth_tvchain_entry_to_program (tvchain, entry); renatofilho@320: renatofilho@320: return NULL; renatofilho@320: } renatofilho@320: renatofilho@320: /** Gets a LiveTVChainEntry associated to the tvchain by its index. renatofilho@320: * renatofilho@320: * @param tvchain The GMythTVChain instance. renatofilho@320: * @param index The tvchain entry index renatofilho@320: * @return The LiveTVchainEntry structure. renatofilho@320: */ renatofilho@320: struct LiveTVChainEntry* renatofilho@320: gmyth_tvchain_get_entry_at (GMythTVChain *tvchain, gint index) renatofilho@320: { renatofilho@320: struct LiveTVChainEntry* chain_entry = NULL; renatofilho@320: renatofilho@320: g_return_val_if_fail( tvchain != NULL && tvchain->tvchain_list != NULL, NULL ); renatofilho@320: renatofilho@320: g_static_mutex_lock( &mutex ); renatofilho@320: renatofilho@320: gint size = g_list_length (tvchain->tvchain_list); renatofilho@320: gint new_index = (index < 0 || index >= size) ? size - 1 : index; renatofilho@320: renatofilho@320: if (new_index >= 0) renatofilho@320: chain_entry = (struct LiveTVChainEntry*) g_list_nth_data (tvchain->tvchain_list, new_index); renatofilho@320: renatofilho@320: g_static_mutex_unlock( &mutex ); renatofilho@320: renatofilho@320: if ( chain_entry != NULL ) { renatofilho@320: gmyth_debug ("[%s] Got TV Chain entry at %d.\n", __FUNCTION__, new_index ); renatofilho@320: renatofilho@320: } else { renatofilho@320: g_warning ("[%s] failed to get entry at index %d", __FUNCTION__, index); renatofilho@320: } renatofilho@320: renatofilho@320: return chain_entry; renatofilho@320: } renatofilho@320: renatofilho@320: /** Gets the program info from backend database associated to the tv chain entry. renatofilho@320: * renatofilho@320: * @param tvchain The GMythTVChain instance. renatofilho@320: * @param entry the LiveTVChainEntry to be converted. renatofilho@320: * @return The progrma info. renatofilho@320: */ renatofilho@320: GMythProgramInfo* renatofilho@320: gmyth_tvchain_entry_to_program (GMythTVChain *tvchain, struct LiveTVChainEntry *entry) renatofilho@320: { renatofilho@320: GMythProgramInfo *proginfo = NULL; renatofilho@320: renatofilho@320: g_return_val_if_fail( tvchain != NULL, NULL ); renatofilho@320: renatofilho@320: if ( !entry || !tvchain ) { renatofilho@320: g_warning ("gmyth_tvchain_entry_to_program() received NULL argument"); renatofilho@320: return NULL; renatofilho@320: } renatofilho@320: renatofilho@320: GMythScheduler *scheduler = gmyth_scheduler_new (); renatofilho@320: renatofilho@320: gmyth_scheduler_connect( scheduler, tvchain->backend_info ); renatofilho@320: proginfo = gmyth_scheduler_get_recorded (scheduler, renatofilho@320: entry->chanid, entry->starttime); renatofilho@320: gmyth_scheduler_disconnect( scheduler ); renatofilho@320: renatofilho@320: if (proginfo) { renatofilho@320: proginfo->pathname = g_string_prepend (proginfo->pathname, entry->hostprefix->str); renatofilho@320: } else { renatofilho@320: g_warning ("tvchain_entry_to_program( chan id = %s, starttime = %ld) failed!", entry->chanid->str, entry->starttime->tv_sec); renatofilho@320: } renatofilho@320: renatofilho@320: return proginfo; renatofilho@320: }