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

GMythFileTransfer deals with the file streaming media remote/local renatofilho@320: * transfering to the MythTV frontend. renatofilho@320: * renatofilho@320: * Copyright (C) 2006 INdT - Instituto Nokia de Tecnologia. renatofilho@320: * @author Rosfran Lins Borges 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: * GStreamer MythTV plug-in properties: renatofilho@320: * - location (backend server hostname/URL) [ex.: myth://192.168.1.73:28722/1000_1092091.nuv] renatofilho@320: * - path (qurl - remote file to be opened) renatofilho@320: * - port number * renatofilho@320: */ renatofilho@320: renatofilho@320: #ifdef HAVE_CONFIG_H renatofilho@320: #include "config.h" renatofilho@320: #endif renatofilho@320: renatofilho@320: #include "gmyth_file_transfer.h" renatofilho@320: #include "gmyth_livetv.h" renatofilho@320: #include "gmyth_util.h" renatofilho@320: #include "gmyth_socket.h" renatofilho@320: #include "gmyth_stringlist.h" renatofilho@320: #include "gmyth_debug.h" renatofilho@320: #include "gmyth_uri.h" renatofilho@320: #include "gmyth_marshal.h" renatofilho@320: renatofilho@320: #include renatofilho@320: #include renatofilho@320: renatofilho@320: #include renatofilho@320: #include renatofilho@320: #include renatofilho@320: #include renatofilho@320: #include renatofilho@320: #include renatofilho@320: #include renatofilho@320: renatofilho@320: #define GMYTHTV_QUERY_HEADER "QUERY_FILETRANSFER " renatofilho@320: renatofilho@320: /* default values to the file transfer parameters */ renatofilho@320: #define GMYTHTV_USER_READ_AHEAD TRUE renatofilho@320: #define GMYTHTV_RETRIES -1 renatofilho@320: #define GMYTHTV_FILE_SIZE 0 renatofilho@320: renatofilho@320: #define GMYTHTV_BUFFER_SIZE 64*1024 renatofilho@320: renatofilho@320: #define GMYTHTV_VERSION 30 renatofilho@320: renatofilho@320: #define GMYTHTV_TRANSFER_MAX_WAITS 700 renatofilho@320: renatofilho@320: #ifdef GMYTHTV_ENABLE_DEBUG renatofilho@320: #define GMYTHTV_ENABLE_DEBUG 1 renatofilho@320: #else renatofilho@320: #undef GMYTHTV_ENABLE_DEBUG renatofilho@320: #endif renatofilho@320: renatofilho@320: /* this NDEBUG is to maintain compatibility with GMyth library */ renatofilho@320: #ifndef NDEBUG renatofilho@320: #define GMYTHTV_ENABLE_DEBUG 1 renatofilho@320: #endif renatofilho@320: renatofilho@320: enum myth_sock_types { renatofilho@320: GMYTH_PLAYBACK_TYPE = 0, renatofilho@320: GMYTH_MONITOR_TYPE, renatofilho@320: GMYTH_FILETRANSFER_TYPE, renatofilho@320: GMYTH_RINGBUFFER_TYPE renatofilho@320: }; renatofilho@320: renatofilho@320: #define GMYTH_FILE_TRANSFER_GET_PRIVATE(obj) (G_TYPE_INSTANCE_GET_PRIVATE ((obj), GMYTH_FILE_TRANSFER_TYPE, GMythFileTransferPrivate)) renatofilho@320: renatofilho@320: struct _GMythFileTransferPrivate { renatofilho@320: renatofilho@320: GMythLiveTV *livetv; renatofilho@320: renatofilho@320: gboolean do_next_program_chain; renatofilho@320: renatofilho@320: }; renatofilho@320: renatofilho@320: static void gmyth_file_transfer_class_init (GMythFileTransferClass *klass); renatofilho@320: static void gmyth_file_transfer_init (GMythFileTransfer *object); renatofilho@320: renatofilho@320: static void gmyth_file_transfer_dispose (GObject *object); renatofilho@320: static void gmyth_file_transfer_finalize (GObject *object); renatofilho@320: renatofilho@320: static void gmyth_file_transfer_program_info_changed( GMythFileTransfer *transfer, renatofilho@320: gint msg_code, gpointer livetv_transfer ); renatofilho@320: renatofilho@320: static gboolean gmyth_connect_to_backend (GMythFileTransfer *transfer); renatofilho@320: renatofilho@320: void gmyth_file_transfer_close( GMythFileTransfer *transfer ); renatofilho@320: renatofilho@320: static gboolean myth_control_acquire_context( gboolean do_wait ); renatofilho@320: renatofilho@320: static gboolean myth_control_release_context( ); renatofilho@320: renatofilho@320: G_DEFINE_TYPE(GMythFileTransfer, gmyth_file_transfer, G_TYPE_OBJECT) renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_file_transfer_class_init (GMythFileTransferClass *klass) renatofilho@320: { renatofilho@320: GObjectClass *gobject_class; renatofilho@320: GMythFileTransferClass *gtransfer_class; renatofilho@320: renatofilho@320: gobject_class = (GObjectClass *) klass; renatofilho@320: gtransfer_class = (GMythFileTransferClass *) gobject_class; renatofilho@320: renatofilho@320: gobject_class->dispose = gmyth_file_transfer_dispose; renatofilho@320: gobject_class->finalize = gmyth_file_transfer_finalize; renatofilho@320: renatofilho@320: g_type_class_add_private (gobject_class, sizeof (GMythFileTransferPrivate)); renatofilho@320: renatofilho@320: gtransfer_class->program_info_changed_handler = gmyth_file_transfer_program_info_changed; renatofilho@320: renatofilho@320: gtransfer_class->program_info_changed_handler_signal_id = renatofilho@320: g_signal_new ( "program-info-changed", renatofilho@320: G_TYPE_FROM_CLASS (gtransfer_class), renatofilho@320: G_SIGNAL_RUN_LAST | G_SIGNAL_NO_RECURSE | G_SIGNAL_NO_HOOKS, renatofilho@320: 0, renatofilho@320: NULL, renatofilho@320: NULL, renatofilho@320: gmyth_marshal_VOID__INT_POINTER, renatofilho@320: G_TYPE_NONE, renatofilho@320: 2, renatofilho@320: G_TYPE_INT, renatofilho@320: G_TYPE_POINTER ); renatofilho@320: renatofilho@320: } renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_file_transfer_init (GMythFileTransfer *transfer) renatofilho@320: { renatofilho@320: g_return_if_fail( transfer != NULL ); renatofilho@320: renatofilho@320: transfer->readposition = 0; renatofilho@320: transfer->filesize = GMYTHTV_FILE_SIZE; renatofilho@320: renatofilho@320: transfer->priv = GMYTH_FILE_TRANSFER_GET_PRIVATE(transfer); renatofilho@320: renatofilho@320: transfer->priv->do_next_program_chain = FALSE; renatofilho@320: transfer->priv->livetv = NULL; renatofilho@320: renatofilho@320: transfer->control_sock = NULL; renatofilho@320: transfer->sock = NULL; renatofilho@320: renatofilho@320: transfer->mutex = g_mutex_new(); renatofilho@320: renatofilho@320: g_signal_connect ( G_OBJECT (transfer), "program-info-changed", renatofilho@320: (GCallback)(GMYTH_FILE_TRANSFER_GET_CLASS(transfer)->program_info_changed_handler), renatofilho@320: NULL ); renatofilho@320: renatofilho@320: } renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_file_transfer_dispose (GObject *object) renatofilho@320: { renatofilho@320: GMythFileTransfer *transfer = GMYTH_FILE_TRANSFER (object); renatofilho@320: renatofilho@320: if ( transfer->mutex != NULL ) renatofilho@320: { renatofilho@320: g_mutex_free( transfer->mutex ); renatofilho@320: transfer->mutex = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: if ( transfer->control_sock != NULL ) renatofilho@320: { renatofilho@320: g_object_unref( transfer->control_sock ); renatofilho@320: transfer->control_sock = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: if ( transfer->sock != NULL ) renatofilho@320: { renatofilho@320: g_object_unref( transfer->sock ); renatofilho@320: transfer->sock = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: if ( transfer->filename != NULL ) renatofilho@320: { renatofilho@320: g_free( transfer->filename ); renatofilho@320: transfer->filename = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: G_OBJECT_CLASS (gmyth_file_transfer_parent_class)->dispose (object); renatofilho@320: } renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_file_transfer_finalize (GObject *object) renatofilho@320: { renatofilho@320: g_signal_handlers_destroy (object); renatofilho@320: renatofilho@320: G_OBJECT_CLASS (gmyth_file_transfer_parent_class)->finalize (object); renatofilho@320: } renatofilho@320: renatofilho@320: // fixme: do we need the card_id???? renatofilho@320: GMythFileTransfer* renatofilho@320: gmyth_file_transfer_new ( const GMythBackendInfo *backend_info) renatofilho@320: { renatofilho@320: GMythFileTransfer *transfer = GMYTH_FILE_TRANSFER (g_object_new (GMYTH_FILE_TRANSFER_TYPE, NULL)); renatofilho@320: renatofilho@320: transfer->backend_info = (GMythBackendInfo *)backend_info; renatofilho@320: g_object_ref (transfer->backend_info); renatofilho@320: renatofilho@320: return transfer; renatofilho@320: } renatofilho@320: renatofilho@320: GMythFileTransfer* renatofilho@320: gmyth_file_transfer_new_with_uri (const gchar* uri_str) renatofilho@320: { renatofilho@320: GMythFileTransfer *transfer = GMYTH_FILE_TRANSFER (g_object_new (GMYTH_FILE_TRANSFER_TYPE, NULL)); renatofilho@320: renatofilho@320: transfer->backend_info = gmyth_backend_info_new_with_uri (uri_str); renatofilho@320: renatofilho@320: return transfer; renatofilho@320: } renatofilho@320: renatofilho@320: gboolean renatofilho@320: gmyth_file_transfer_open (GMythFileTransfer *transfer, const gchar* filename) renatofilho@320: { renatofilho@320: gboolean ret = TRUE; renatofilho@320: renatofilho@320: g_return_val_if_fail (transfer != NULL, FALSE); renatofilho@320: g_return_val_if_fail (filename != NULL, FALSE); renatofilho@320: renatofilho@320: if (transfer->filename != NULL) renatofilho@320: { renatofilho@320: g_free (transfer->filename); renatofilho@320: transfer->filename = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: transfer->filename = g_strdup (filename); renatofilho@320: renatofilho@320: /* configure the control socket */ renatofilho@320: if (transfer->control_sock == NULL) { renatofilho@320: if (!gmyth_connect_to_backend (transfer)) { renatofilho@320: gmyth_debug ("Connection to backend failed (Control Socket).\n"); renatofilho@320: ret = FALSE; renatofilho@320: } renatofilho@320: } else { renatofilho@320: g_warning("Remote transfer control socket already created.\n"); renatofilho@320: } renatofilho@320: renatofilho@320: gmyth_debug ("Got file with size = %lld.\n", transfer->filesize); renatofilho@320: renatofilho@320: return ret; renatofilho@320: renatofilho@320: } renatofilho@320: renatofilho@320: static gboolean renatofilho@320: gmyth_connect_to_backend (GMythFileTransfer *transfer) renatofilho@320: { renatofilho@320: GString *base_str = NULL; renatofilho@320: GString *hostname = NULL; renatofilho@320: GMythStringList *strlist = NULL; renatofilho@320: gboolean ret = TRUE; renatofilho@320: renatofilho@320: g_return_val_if_fail (transfer != NULL, FALSE ); renatofilho@320: renatofilho@320: base_str = g_string_new (""); renatofilho@320: renatofilho@320: /* Creates the control socket */ renatofilho@320: if (transfer->control_sock != NULL) { renatofilho@320: g_object_unref (transfer->control_sock); renatofilho@320: transfer->control_sock = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: transfer->control_sock = gmyth_socket_new(); renatofilho@320: renatofilho@320: // Connects the socket, send Mythtv ANN command and verify Mythtv protocol version renatofilho@320: if (!gmyth_socket_connect_to_backend (transfer->control_sock, renatofilho@320: transfer->backend_info->hostname, transfer->backend_info->port, TRUE)) { renatofilho@320: renatofilho@320: g_object_unref (transfer->control_sock); renatofilho@320: transfer->control_sock = NULL; renatofilho@320: return FALSE; renatofilho@320: } renatofilho@320: renatofilho@320: /* Creates the data socket */ renatofilho@320: if (transfer->sock != NULL) { renatofilho@320: g_object_unref (transfer->sock); renatofilho@320: transfer->sock = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: transfer->sock = gmyth_socket_new (); renatofilho@320: gmyth_socket_connect (transfer->sock, transfer->backend_info->hostname, transfer->backend_info->port); renatofilho@320: renatofilho@320: strlist = gmyth_string_list_new(); renatofilho@320: hostname = gmyth_socket_get_local_hostname(); renatofilho@320: gmyth_debug( "[%s] MythTV version (from backend) = %d.\n", __FUNCTION__, transfer->control_sock->mythtv_version ); renatofilho@320: if ( transfer->control_sock->mythtv_version > 26 ) renatofilho@320: g_string_printf( base_str, "ANN FileTransfer %s 1 -1", hostname->str); renatofilho@320: else renatofilho@320: g_string_printf( base_str, "ANN FileTransfer %s", hostname->str); renatofilho@320: renatofilho@320: gmyth_string_list_append_string (strlist, base_str ); renatofilho@320: gmyth_string_list_append_char_array (strlist, transfer->filename); renatofilho@320: renatofilho@320: gmyth_socket_write_stringlist (transfer->sock, strlist ); renatofilho@320: gmyth_socket_read_stringlist (transfer->sock, strlist ); renatofilho@320: renatofilho@320: /* file identification used in future file transfer requests to backend */ renatofilho@320: transfer->file_id = gmyth_string_list_get_int( strlist, 1 ); renatofilho@320: renatofilho@320: /* Myth URI stream file size - decoded using two 8-bytes sequences (64 bits/long long types) */ renatofilho@320: transfer->filesize = gmyth_util_decode_long_long( strlist, 2 ); renatofilho@320: renatofilho@320: gmyth_debug ( "[%s] ***** Received: recordernum = %d, filesize = %" G_GUINT64_FORMAT "\n", __FUNCTION__, renatofilho@320: transfer->file_id, transfer->filesize ); renatofilho@320: renatofilho@320: if (transfer->filesize < 0 ) { renatofilho@320: gmyth_debug ( "[%s] Got filesize equals to %llu is lesser than 0 [invalid stream file]\n", __FUNCTION__, transfer->filesize ); renatofilho@320: g_object_unref (transfer->sock); renatofilho@320: transfer->sock = NULL; renatofilho@320: ret = FALSE; renatofilho@320: goto cleanup; renatofilho@320: } renatofilho@320: renatofilho@320: cleanup: renatofilho@320: renatofilho@320: if ( strlist != NULL ) renatofilho@320: g_object_unref( strlist ); renatofilho@320: renatofilho@320: g_string_free (base_str, TRUE); renatofilho@320: g_string_free (hostname, TRUE); renatofilho@320: renatofilho@320: return ret; renatofilho@320: } renatofilho@320: renatofilho@320: void renatofilho@320: gmyth_file_transfer_emit_program_info_changed_signal ( GMythFileTransfer *transfer, gint msg_code, renatofilho@320: gpointer live_tv ) renatofilho@320: { renatofilho@320: /* renatofilho@320: g_signal_emit_by_name ( G_OBJECT(transfer), renatofilho@320: "program-info-changed", renatofilho@320: msg_code, live_tv ); renatofilho@320: */ renatofilho@320: renatofilho@320: gmyth_debug( "Calling signal handler... [FILE_TRANSFER]" ); renatofilho@320: renatofilho@320: g_signal_emit ( transfer, renatofilho@320: GMYTH_FILE_TRANSFER_GET_CLASS (transfer)->program_info_changed_handler_signal_id, renatofilho@320: 0, /* details */ renatofilho@320: msg_code, live_tv ); renatofilho@320: renatofilho@320: } renatofilho@320: renatofilho@320: gboolean renatofilho@320: gmyth_file_transfer_is_open (GMythFileTransfer *transfer) renatofilho@320: { renatofilho@320: GMythStringList *strlist; renatofilho@320: GString *query; renatofilho@320: renatofilho@320: g_return_val_if_fail (transfer->control_sock != NULL, FALSE); renatofilho@320: g_return_val_if_fail (transfer->sock != NULL, FALSE); renatofilho@320: renatofilho@320: strlist = gmyth_string_list_new(); renatofilho@320: query = g_string_new (GMYTHTV_QUERY_HEADER); renatofilho@320: g_string_append_printf (query, "%d", transfer->file_id ); renatofilho@320: renatofilho@320: gmyth_string_list_append_string (strlist, query ); renatofilho@320: gmyth_string_list_append_char_array( strlist, "IS_OPEN" ); renatofilho@320: renatofilho@320: gmyth_socket_write_stringlist( transfer->control_sock, strlist ); renatofilho@320: gmyth_socket_read_stringlist( transfer->control_sock, strlist ); renatofilho@320: renatofilho@320: g_string_free (query, TRUE); renatofilho@320: g_object_unref (strlist); renatofilho@320: renatofilho@320: return ( strlist != NULL && gmyth_string_list_get_int( strlist, 0 ) == 1 ); renatofilho@320: } renatofilho@320: renatofilho@320: void renatofilho@320: gmyth_file_transfer_close( GMythFileTransfer *transfer ) renatofilho@320: { renatofilho@320: GMythStringList *strlist; renatofilho@320: GString *query; renatofilho@320: renatofilho@320: g_return_if_fail (transfer->control_sock != NULL); renatofilho@320: renatofilho@320: strlist = gmyth_string_list_new( ); renatofilho@320: query = g_string_new (GMYTHTV_QUERY_HEADER); renatofilho@320: g_string_append_printf( query, "%d", transfer->file_id); renatofilho@320: renatofilho@320: gmyth_string_list_append_string( strlist, query ); renatofilho@320: gmyth_string_list_append_char_array( strlist, "DONE" ); renatofilho@320: renatofilho@320: if ( gmyth_socket_sendreceive_stringlist(transfer->control_sock, strlist) <= 0 ) { renatofilho@320: // fixme: time out??? renatofilho@320: g_printerr( "Remote file timeout.\n" ); renatofilho@320: } renatofilho@320: renatofilho@320: g_string_free (query, TRUE); renatofilho@320: g_object_unref (strlist); renatofilho@320: renatofilho@320: if (transfer->sock) { renatofilho@320: g_object_unref( transfer->sock ); renatofilho@320: transfer->sock = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: if (transfer->control_sock) { renatofilho@320: g_object_unref( transfer->control_sock ); renatofilho@320: transfer->control_sock = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: } renatofilho@320: renatofilho@320: gint64 renatofilho@320: gmyth_file_transfer_seek(GMythFileTransfer *transfer, guint64 pos, gint whence) renatofilho@320: { renatofilho@320: GMythStringList *strlist = gmyth_string_list_new(); renatofilho@320: GString *query; renatofilho@320: renatofilho@320: g_return_val_if_fail (transfer->sock != NULL, -1); renatofilho@320: g_return_val_if_fail (transfer->control_sock != NULL, -1); renatofilho@320: renatofilho@320: strlist = gmyth_string_list_new(); renatofilho@320: query = g_string_new (GMYTHTV_QUERY_HEADER); renatofilho@320: g_string_append_printf (query, "%d", transfer->file_id); renatofilho@320: renatofilho@320: myth_control_acquire_context( TRUE ); renatofilho@320: renatofilho@320: gmyth_string_list_append_string( strlist, query ); renatofilho@320: gmyth_string_list_append_char_array( strlist, "SEEK" ); renatofilho@320: gmyth_string_list_append_uint64( strlist, pos ); renatofilho@320: renatofilho@320: gmyth_string_list_append_int( strlist, whence ); renatofilho@320: renatofilho@320: if (pos > 0 ) renatofilho@320: gmyth_string_list_append_uint64( strlist, pos ); renatofilho@320: else renatofilho@320: gmyth_string_list_append_uint64( strlist, transfer->readposition ); renatofilho@320: renatofilho@320: gmyth_socket_sendreceive_stringlist( transfer->control_sock, strlist ); renatofilho@320: renatofilho@320: gint64 retval = gmyth_string_list_get_int64(strlist, 0); renatofilho@320: transfer->readposition = retval; renatofilho@320: gmyth_debug ( "[%s] got reading position pointer from the streaming = %lld\n", renatofilho@320: __FUNCTION__, retval ); renatofilho@320: renatofilho@320: myth_control_release_context( ); renatofilho@320: renatofilho@320: return retval; renatofilho@320: } renatofilho@320: renatofilho@320: static gboolean renatofilho@320: myth_control_acquire_context( gboolean do_wait ) renatofilho@320: { renatofilho@320: gboolean ret = TRUE; renatofilho@320: //guint max_iter = 50; renatofilho@320: renatofilho@320: //g_mutex_lock( mutex ); renatofilho@320: renatofilho@320: //while ( !has_io_access ) renatofilho@320: // g_cond_wait( io_watcher_cond, mutex ); renatofilho@320: renatofilho@320: //has_io_access = FALSE; renatofilho@320: renatofilho@320: //myth_control_acquire_context (FALSE); renatofilho@320: renatofilho@320: /* renatofilho@320: if ( do_wait ) { renatofilho@320: while ( --max_iter > 0 && !g_main_context_wait( io_watcher_context, io_watcher_cond, mutex ) ) renatofilho@320: ret = FALSE; renatofilho@320: } else if ( !g_main_context_acquire( io_watcher_context ) ) renatofilho@320: ret = FALSE; renatofilho@320: */ renatofilho@320: renatofilho@320: //g_static_mutex_lock( &st_mutex ); renatofilho@320: renatofilho@320: return ret; renatofilho@320: } renatofilho@320: renatofilho@320: static gboolean renatofilho@320: myth_control_release_context( ) renatofilho@320: { renatofilho@320: gboolean ret = TRUE; renatofilho@320: renatofilho@320: //g_static_mutex_unlock( &st_mutex ); renatofilho@320: renatofilho@320: //g_main_context_release( io_watcher_context ); renatofilho@320: renatofilho@320: //g_main_context_wakeup( io_watcher_context ); renatofilho@320: renatofilho@320: //has_io_access = TRUE; renatofilho@320: renatofilho@320: //g_cond_broadcast( io_watcher_cond ); renatofilho@320: renatofilho@320: //g_mutex_unlock( mutex ); renatofilho@320: renatofilho@320: return ret; renatofilho@320: } renatofilho@320: renatofilho@320: gint renatofilho@320: gmyth_file_transfer_read(GMythFileTransfer *transfer, GByteArray *data, gint size, gboolean read_unlimited) renatofilho@320: { renatofilho@320: gint bytes_sent = 0; renatofilho@320: gsize bytes_read = 0; renatofilho@320: gsize total_read = 0; renatofilho@320: renatofilho@320: GError *error = NULL; renatofilho@320: renatofilho@320: GIOChannel *io_channel; renatofilho@320: GIOChannel *io_channel_control; renatofilho@320: renatofilho@320: GIOCondition io_cond; renatofilho@320: GIOCondition io_cond_control; renatofilho@320: GIOStatus io_status = G_IO_STATUS_NORMAL, io_status_control = G_IO_STATUS_NORMAL; renatofilho@320: renatofilho@320: gboolean ret = TRUE; renatofilho@320: renatofilho@320: GString *query; renatofilho@320: renatofilho@320: g_return_val_if_fail ( data != NULL, -2 ); renatofilho@320: renatofilho@320: io_channel = transfer->sock->sd_io_ch; renatofilho@320: io_channel_control = transfer->control_sock->sd_io_ch; renatofilho@320: renatofilho@320: io_status = g_io_channel_set_encoding( io_channel, NULL, &error ); renatofilho@320: if ( io_status == G_IO_STATUS_NORMAL ) renatofilho@320: gmyth_debug ( "[%s] Setting encoding to binary data socket).\n", __FUNCTION__ ); renatofilho@320: renatofilho@320: io_cond = g_io_channel_get_buffer_condition( io_channel ); renatofilho@320: renatofilho@320: io_cond_control = g_io_channel_get_buffer_condition( io_channel ); renatofilho@320: if ( transfer->sock == NULL || ( io_status == G_IO_STATUS_ERROR ) ) { renatofilho@320: g_printerr( "gmyth_file_transfer_read(): Called with no raw socket.\n" ); renatofilho@320: //exit(0); // fixme remove this renatofilho@320: return -1; renatofilho@320: } renatofilho@320: renatofilho@320: if ( transfer->control_sock == NULL || ( io_status_control == G_IO_STATUS_ERROR ) ) { renatofilho@320: g_printerr( "gmyth_file_transfer_read(): Called with no control socket.\n" ); renatofilho@320: //exit(0); // fixme remove this renatofilho@320: return -1; renatofilho@320: } renatofilho@320: renatofilho@320: query = g_string_new (GMYTHTV_QUERY_HEADER); renatofilho@320: g_string_append_printf ( query, "%d", transfer->file_id ); renatofilho@320: gmyth_debug ("[%s] Transfer_query = %s\n", __FUNCTION__, query->str ); renatofilho@320: renatofilho@320: /* send requests to the maximum number of REQUEST_BLOCK messages */ renatofilho@320: guint max_tries = 5; renatofilho@320: renatofilho@320: myth_control_acquire_context( TRUE ); renatofilho@320: renatofilho@320: while (total_read == 0 && --max_tries > 0) { renatofilho@320: GMythStringList *strlist = gmyth_string_list_new(); renatofilho@320: renatofilho@320: gmyth_string_list_append_char_array( strlist, query->str ); renatofilho@320: gmyth_string_list_append_char_array( strlist, "REQUEST_BLOCK" ); renatofilho@320: gmyth_string_list_append_int( strlist, size ); renatofilho@320: renatofilho@320: // Request the block to the backend renatofilho@320: gmyth_socket_write_stringlist( transfer->control_sock, strlist ); renatofilho@320: renatofilho@320: // Receives the backand answer renatofilho@320: gmyth_socket_read_stringlist( transfer->control_sock, strlist ); renatofilho@320: renatofilho@320: if ( strlist != NULL && gmyth_string_list_length( strlist ) > 0 ) renatofilho@320: { renatofilho@320: bytes_sent = gmyth_string_list_get_int( strlist, 0 ); // -1 on backend error renatofilho@320: gmyth_debug ( "[%s] got SENT buffer message = %d\n", __FUNCTION__, bytes_sent ); renatofilho@320: renatofilho@320: if ( bytes_sent >= 0 ) renatofilho@320: { renatofilho@320: gchar *data_buffer = g_new0 ( gchar, bytes_sent ); renatofilho@320: while ( 0 != bytes_sent ) renatofilho@320: { renatofilho@320: io_status = g_io_channel_read_chars( io_channel, data_buffer + total_read, renatofilho@320: (gsize) bytes_sent, &bytes_read, &error ); renatofilho@320: renatofilho@320: total_read += bytes_read; renatofilho@320: bytes_sent -= bytes_read; renatofilho@320: renatofilho@320: /* append new data to the increasing byte array */ renatofilho@320: data = g_byte_array_append (data, (const guint8*)data_buffer, bytes_read); renatofilho@320: gmyth_debug ("Total transfer data read: %d\n", total_read); renatofilho@320: } renatofilho@320: g_free (data_buffer); renatofilho@320: } /* if */ renatofilho@320: } else if ( !(transfer->priv != NULL && transfer->priv->livetv != NULL && renatofilho@320: transfer->priv->do_next_program_chain) ) { renatofilho@320: total_read = GMYTHTV_FILE_TRANSFER_READ_ERROR; renatofilho@320: g_object_unref (strlist); renatofilho@320: strlist = NULL; renatofilho@320: break; renatofilho@320: } renatofilho@320: g_object_unref (strlist); renatofilho@320: strlist = NULL; renatofilho@320: } renatofilho@320: renatofilho@320: if ( bytes_sent == 0 && max_tries == 0 ) renatofilho@320: { renatofilho@320: gmyth_debug( "Trying to move to the next program chain..." ); renatofilho@320: transfer->priv = GMYTH_FILE_TRANSFER_GET_PRIVATE(transfer); renatofilho@320: renatofilho@320: if ( transfer->priv != NULL && transfer->priv->livetv != NULL && renatofilho@320: transfer->priv->do_next_program_chain ) renatofilho@320: { renatofilho@320: renatofilho@320: total_read = GMYTHTV_FILE_TRANSFER_NEXT_PROG_CHAIN; renatofilho@320: renatofilho@320: g_mutex_lock( transfer->mutex ); renatofilho@320: renatofilho@320: ret = gmyth_livetv_next_program_chain( transfer->priv->livetv ); renatofilho@320: renatofilho@320: g_mutex_unlock( transfer->mutex ); renatofilho@320: renatofilho@320: if ( !ret ) renatofilho@320: gmyth_debug( "Cannot change to the next program chain!" ); renatofilho@320: else renatofilho@320: gmyth_debug( "OK!!! MOVED to the next program chain [%s]!", renatofilho@320: (gmyth_tvchain_get_id( transfer->priv->livetv->tvchain ))->str ); renatofilho@320: } renatofilho@320: renatofilho@320: } /* if */ renatofilho@320: renatofilho@320: myth_control_release_context( ); renatofilho@320: g_string_free (query, TRUE); renatofilho@320: renatofilho@320: if ( error != NULL ) { renatofilho@320: gmyth_debug ("Cleaning-up ERROR: %s [msg = %s, code = %d]\n", __FUNCTION__, error->message, renatofilho@320: error->code); renatofilho@320: g_error_free (error); renatofilho@320: } renatofilho@320: renatofilho@320: if ( total_read > 0 ) renatofilho@320: transfer->readposition += total_read; renatofilho@320: renatofilho@320: return total_read; renatofilho@320: } renatofilho@320: renatofilho@320: static void renatofilho@320: gmyth_file_transfer_program_info_changed( GMythFileTransfer *transfer, renatofilho@320: gint msg_code, gpointer livetv_transfer ) renatofilho@320: { renatofilho@320: GMythLiveTV *livetv = GMYTH_LIVETV( livetv_transfer ); renatofilho@320: renatofilho@320: gmyth_debug( "Program info changed! ( file transfer orig. = %p, ptr. = [%s], user data = [%s] )", transfer, renatofilho@320: livetv_transfer != NULL ? "[NOT NULL]" : "[NULL]", livetv != NULL ? "[NOT NULL]" : "[NULL]" ); renatofilho@320: renatofilho@320: if ( livetv != NULL && transfer == livetv->file_transfer ) renatofilho@320: { renatofilho@320: gmyth_debug( "YES, the requested program info movement on the LiveTV transfer is authentical!" ); renatofilho@320: } renatofilho@320: renatofilho@320: transfer->priv = GMYTH_FILE_TRANSFER_GET_PRIVATE(transfer); renatofilho@320: renatofilho@320: transfer->priv->livetv = livetv; renatofilho@320: transfer->priv->do_next_program_chain = TRUE; renatofilho@320: renatofilho@320: //g_object_unref( transfer ); renatofilho@320: } renatofilho@320: renatofilho@320: gboolean renatofilho@320: gmyth_file_transfer_settimeout( GMythFileTransfer *transfer, gboolean fast ) renatofilho@320: { renatofilho@320: renatofilho@320: GMythStringList *strlist = NULL; renatofilho@320: renatofilho@320: g_return_val_if_fail (transfer->sock != NULL, FALSE); renatofilho@320: g_return_val_if_fail (transfer->control_sock != NULL, FALSE); renatofilho@320: renatofilho@320: // if ( transfer->timeoutisfast == fast ) renatofilho@320: // return; renatofilho@320: renatofilho@320: strlist = gmyth_string_list_new(); renatofilho@320: gmyth_string_list_append_char_array( strlist, GMYTHTV_QUERY_HEADER ); renatofilho@320: gmyth_string_list_append_char_array( strlist, "SET_TIMEOUT" ); renatofilho@320: gmyth_string_list_append_int( strlist, fast ); renatofilho@320: renatofilho@320: gmyth_socket_write_stringlist( transfer->control_sock, strlist ); renatofilho@320: gmyth_socket_read_stringlist( transfer->control_sock, strlist ); renatofilho@320: renatofilho@320: // transfer->timeoutisfast = fast; renatofilho@320: renatofilho@320: return TRUE; renatofilho@320: } renatofilho@320: renatofilho@320: renatofilho@320: guint64 renatofilho@320: gmyth_file_transfer_get_filesize (GMythFileTransfer *transfer) renatofilho@320: { renatofilho@320: g_return_val_if_fail (transfer != NULL, 0); renatofilho@320: return transfer->filesize; renatofilho@320: }