[svn r35] Performance optimization.
1 /* vim: set sw=2: -*- Mode: C; tab-width: 2; indent-tabs-mode: t; c-basic-offset: 2; c-indent-level: 2-*- */
3 * GStreamer plug-in properties:
4 * - location (backend server hostname/URL) [ex.: myth://192.168.1.73:28722/1000_1092091.nuv]
5 * - path (qurl - remote file to be opened)
7 * @author Rosfran Lins Borges <rosfran.borges@indt.org.br>
10 #include "myth_file_transfer.h"
12 #include "myth_livetv.h"
13 #include <gmyth/gmyth_util.h>
14 #include <gmyth/gmyth_socket.h>
15 #include <gmyth/gmyth_stringlist.h>
20 #include <arpa/inet.h>
21 #include <sys/types.h>
22 #include <sys/socket.h>
27 #define MYTHTV_QUERY_HEADER "QUERY_FILETRANSFER"
28 #define MYTHTV_RECORDER_HEADER "QUERY_RECORDER"
30 /* default values to the file transfer parameters */
31 #define MYTHTV_USER_READ_AHEAD FALSE
32 #define MYTHTV_RETRIES 1
33 #define MYTHTV_FILE_SIZE -1
35 #define MYTHTV_BUFFER_SIZE 256*1024
37 #define MYTHTV_VERSION 30
39 #define MYTHTV_TRANSFER_MAX_WAITS 700
41 #ifdef MYTHTV_ENABLE_DEBUG
42 #define MYTHTV_ENABLE_DEBUG 1
44 #undef MYTHTV_ENABLE_DEBUG
47 /* this NDEBUG is to maintain compatibility with GMyth library */
49 #define MYTHTV_ENABLE_DEBUG 1
52 static guint wait_to_transfer = 0;
54 enum myth_sock_types {
55 MYTH_PLAYBACK_TYPE = 0,
57 MYTH_FILETRANSFER_TYPE,
61 static GStaticMutex mutex = G_STATIC_MUTEX_INIT;
63 static void myth_file_transfer_class_init (MythFileTransferClass *klass);
64 static void myth_file_transfer_init (MythFileTransfer *object);
66 static void myth_file_transfer_dispose (GObject *object);
67 static void myth_file_transfer_finalize (GObject *object);
69 static GMythSocket *myth_connect_to_transfer_backend( MythFileTransfer **transfer, guint sock_type );
70 static void* myth_init_io_watchers( void *data );
72 void myth_file_transfer_close( MythFileTransfer *transfer );
74 G_DEFINE_TYPE(MythFileTransfer, myth_file_transfer, G_TYPE_OBJECT)
77 mmyth_util_decode_long_long( GMythStringList *strlist, guint offset )
80 guint64 ret_value = 0LL;
82 g_return_val_if_fail( strlist != NULL, ret_value );
84 if ( offset < gmyth_string_list_length( strlist ))
85 g_printerr( "[%s] Offset is lower than the GMythStringList (offset = %d)!\n", __FUNCTION__, offset );
86 g_return_val_if_fail( offset < gmyth_string_list_length( strlist ), ret_value );
88 gint l1 = gmyth_string_list_get_int( strlist, offset );
89 gint l2 = gmyth_string_list_get_int( strlist, offset + 1 );
91 ret_value = ((guint64)(l2) & 0xffffffffLL) | ((guint64)(l1) << 32);
98 myth_file_transfer_class_init (MythFileTransferClass *klass)
100 GObjectClass *gobject_class;
102 gobject_class = (GObjectClass *) klass;
104 gobject_class->dispose = myth_file_transfer_dispose;
105 gobject_class->finalize = myth_file_transfer_finalize;
109 myth_file_transfer_init (MythFileTransfer *myth_file_transfer)
111 g_return_if_fail( myth_file_transfer != NULL );
112 myth_file_transfer->mythtv_version = MYTHTV_VERSION;
116 myth_file_transfer_dispose (GObject *object)
118 MythFileTransfer *myth_file_transfer = MYTH_FILE_TRANSFER(object);
120 myth_file_transfer_close( myth_file_transfer );
122 G_OBJECT_CLASS (myth_file_transfer_parent_class)->dispose (object);
126 myth_file_transfer_finalize (GObject *object)
128 g_signal_handlers_destroy (object);
130 G_OBJECT_CLASS (myth_file_transfer_parent_class)->finalize (object);
134 myth_file_transfer_new (gint num, GString *uri_str, gshort port, gint mythtv_version)
136 MythFileTransfer *transfer = MYTH_FILE_TRANSFER ( g_object_new (
137 MYTH_FILE_TRANSFER_TYPE, FALSE ));
139 if ( mythtv_version > 0 )
140 transfer->mythtv_version = mythtv_version;
142 transfer->card_id = num;
144 transfer->rec_id = -1;
146 transfer->recordernum = num;
147 transfer->uri = myth_uri_new ( uri_str->str );
149 transfer->hostname = g_string_new( myth_uri_gethost(transfer->uri) );
150 g_print( "\t--> transfer->hostname = %s\n", transfer->hostname->str );
153 transfer->port = port;
155 transfer->port = myth_uri_getport( transfer->uri );
157 g_print( "\t--> transfer->port = %d\n", transfer->port );
159 transfer->readposition = 0;
160 transfer->filesize = MYTHTV_FILE_SIZE;
161 transfer->timeoutisfast = FALSE;
163 transfer->userreadahead = MYTHTV_USER_READ_AHEAD;
164 transfer->retries = MYTHTV_RETRIES;
166 transfer->live_tv = FALSE;
168 transfer->query = g_string_new( MYTHTV_QUERY_HEADER );
169 g_string_append_printf ( transfer->query, " %d", transfer->recordernum );
170 g_print( "\t--> transfer->query = %s\n", transfer->query->str );
172 transfer->control_sock = NULL;
173 transfer->event_sock = NULL;
174 transfer->sock = NULL;
180 myth_file_transfer_livetv_setup( MythFileTransfer **transfer, GMythSocket *live_socket )
182 (*transfer)->sock = live_socket;
183 g_object_ref( live_socket );
189 myth_file_transfer_playback_setup( MythFileTransfer **transfer, gboolean live_tv )
194 (*transfer)->live_tv = live_tv;
196 printf("[%s] Running config to the %s...\n", __FUNCTION__, live_tv ? "LiveTV" : "FileTransfer" );
198 /* configure the control socket */
199 if ((*transfer)->control_sock == NULL) {
201 if ( myth_connect_to_transfer_backend ( transfer, MYTH_PLAYBACK_TYPE ) == NULL ) {
202 g_printerr( "Connection to backend failed (Control Socket).\n" );
207 g_warning("Remote transfer control socket already created.\n");
215 myth_file_transfer_setup( MythFileTransfer **transfer, gboolean live_tv )
217 GMythStringList *strlist = NULL;
221 (*transfer)->live_tv = live_tv;
223 printf("[%s] Running config to the %s...\n", __FUNCTION__, live_tv ? "LiveTV" : "FileTransfer" );
226 /* configure the control socket */
227 if ((*transfer)->control_sock == NULL) {
229 if ( myth_connect_to_transfer_backend ( transfer, MYTH_PLAYBACK_TYPE ) == NULL ) {
230 g_printerr( "Connection to backend failed (Event Socket).\n" );
235 g_warning("Remote transfer control socket already created.\n");
239 /* configure the socket */
240 if ( (*transfer)->sock == NULL ) {
242 //if ( live_tv == FALSE ) {
244 if ( myth_connect_to_transfer_backend ( transfer, MYTH_FILETRANSFER_TYPE ) == NULL ) {
245 g_printerr ("Connection to backend failed (Raw Transfer Socket).\n");
249 if ( !(*transfer)->live_tv && (*transfer)->control_sock != NULL) {
250 strlist = gmyth_string_list_new();
251 g_string_printf ( (*transfer)->query, "%s %d", MYTHTV_QUERY_HEADER, (*transfer)->recordernum );
253 gmyth_string_list_append_string( strlist, (*transfer)->query );
254 gmyth_string_list_append_char_array( strlist, "IS_OPEN" );
256 gmyth_socket_write_stringlist( (*transfer)->control_sock, strlist );
257 gmyth_socket_read_stringlist( (*transfer)->control_sock, strlist );
259 if ( strlist!=NULL && gmyth_string_list_get_int( strlist, 0 ) == 1 ) {
260 g_print( "[%s] Remote Myth FileTransfer socket is open!\n", __FUNCTION__ );
262 g_print( "[%s] Remote Myth FileTransfer socket is CLOSED! See the MythTV Server Backend for configuration details...\n", __FUNCTION__ );
268 g_warning("Remote transfer (raw) socket already created.\n");
275 myth_connect_to_transfer_backend( MythFileTransfer **transfer, guint sock_type )
277 GMythSocket *sock = NULL;
279 g_return_val_if_fail( transfer != NULL && *transfer != NULL, NULL );
280 g_return_val_if_fail( (*transfer)->uri != NULL, NULL );
282 g_static_mutex_lock (&mutex);
284 gchar *path_dir = myth_uri_getpath( (*transfer)->uri );
285 //g_print( "\t--> %s: path_dir = %s\n", __FUNCTION__, path_dir );
287 gchar *stype = g_strdup( "" );
289 // if ( (*transfer)->live_tv == FALSE ) {
291 sock = gmyth_socket_new();
293 gmyth_socket_connect( &sock, (*transfer)->hostname->str, (*transfer)->port );
297 sock = (*transfer)->sock;
300 #ifdef MYTHTV_ENABLE_DEBUG
302 g_print( "[%s] --> Creating socket... (%s, %d)\n", __FUNCTION__, (*transfer)->hostname->str, (*transfer)->port );
305 GMythStringList *strlist = NULL;
307 GString *hostname = g_string_new( myth_uri_gethost( (*transfer)->uri ) );
308 GString *base_str = g_string_new( "" );
310 if ( gmyth_socket_check_protocol_version_number (sock, (*transfer)->mythtv_version) ) {
313 stype = (sock_type==MYTH_PLAYBACK_TYPE) ? "control socket" : "file data socket";
314 g_printerr( "FileTransfer, open_socket(%s): \n"
315 "\t\t\tCould not connect to server \"%s\" @ port %d\n", stype,
316 (*transfer)->hostname->str, (*transfer)->port );
317 g_object_unref(sock);
318 g_static_mutex_unlock (&mutex);
322 hostname = gmyth_socket_get_local_hostname();
324 g_print( "[%s] local hostname = %s\n", __FUNCTION__, hostname->str );
326 if ( sock_type == MYTH_PLAYBACK_TYPE )
328 (*transfer)->control_sock = sock;
329 g_string_printf( base_str, "ANN Playback %s %d", hostname->str, FALSE );
331 gmyth_socket_send_command( (*transfer)->control_sock, base_str );
332 GString *resp = gmyth_socket_receive_response( (*transfer)->control_sock );
333 g_print( "[%s] Got Playback response from %s: %s\n", __FUNCTION__, base_str->str, resp->str );
335 else if ( sock_type == MYTH_MONITOR_TYPE )
337 (*transfer)->event_sock = sock;
338 g_string_printf( base_str, "ANN Monitor %s %d", hostname->str, TRUE );
340 gmyth_socket_send_command( (*transfer)->event_sock, base_str );
341 GString *resp = gmyth_socket_receive_response( (*transfer)->event_sock );
342 g_print( "[%s] Got Monitor response from %s: %s\n", __FUNCTION__, base_str->str, resp->str );
343 g_thread_create( myth_init_io_watchers, (void*)(*transfer), FALSE, NULL );
345 g_printerr( "[%s] Watch listener function to the IO control channel on thread %p.\n", __FUNCTION__, g_thread_self() );
348 else if ( sock_type == MYTH_FILETRANSFER_TYPE )
350 (*transfer)->sock = sock;
351 strlist = gmyth_string_list_new();
352 //g_string_printf( base_str, "ANN FileTransfer %s %d %d", hostname->str,
353 // transfer->userreadahead, transfer->retries );
354 g_string_printf( base_str, "ANN FileTransfer %s", hostname->str );
356 gmyth_string_list_append_string( strlist, base_str );
357 gmyth_string_list_append_char_array( strlist, path_dir );
359 gmyth_socket_write_stringlist( (*transfer)->sock, strlist );
360 gmyth_socket_read_stringlist( (*transfer)->sock, strlist );
362 /* socket number, where all the stream data comes from - got from the MythTV remote backend */
363 (*transfer)->recordernum = gmyth_string_list_get_int( strlist, 1 );
365 /* Myth URI stream file size - decoded using two 8-bytes sequences (64 bits/long long types) */
366 (*transfer)->filesize = mmyth_util_decode_long_long( strlist, 2 );
368 printf( "[%s] ***** Received: recordernum = %d, filesize = %" G_GUINT64_FORMAT "\n", __FUNCTION__,
369 (*transfer)->recordernum, (*transfer)->filesize );
371 if ( (*transfer)->filesize <= 0 ) {
372 g_print( "[%s] Got filesize equals to %llu is lesser than 0 [invalid stream file]\n", __FUNCTION__, (*transfer)->filesize );
373 g_object_unref(sock);
377 else if ( sock_type == MYTH_RINGBUFFER_TYPE )
379 (*transfer)->sock = sock;
380 //myth_file_transfer_spawntv( (*transfer), NULL );
382 strlist = gmyth_string_list_new();
383 g_string_printf( base_str, "ANN RingBuffer %s %d", hostname->str, (*transfer)->card_id );
385 gmyth_socket_send_command( (*transfer)->sock, base_str );
386 GString *resp = gmyth_socket_receive_response( (*transfer)->sock );
387 g_print( "[%s] Got RingBuffer response from %s: %s\n", __FUNCTION__, base_str->str, resp->str );
393 printf("[%s] ANN %s sent: %s\n", (sock_type==MYTH_PLAYBACK_TYPE) ? "Playback" : (sock_type==MYTH_FILETRANSFER_TYPE) ? "FileTransfer" : "Monitor", __FUNCTION__, base_str->str);
395 if ( strlist != NULL )
396 g_object_unref( strlist );
398 g_static_mutex_unlock (&mutex);
404 myth_file_transfer_spawntv ( MythFileTransfer *file_transfer,
405 GString *tvchain_id )
407 GMythStringList *str_list;
409 g_debug ("myth_file_transfer_spawntv.\n");
411 str_list = gmyth_string_list_new ();
413 g_string_printf( file_transfer->query, "%s %d", MYTHTV_RECORDER_HEADER,
414 file_transfer->card_id );
415 gmyth_string_list_append_string (str_list, file_transfer->query);
416 gmyth_string_list_append_string (str_list, g_string_new ("SPAWN_LIVETV"));
417 if (tvchain_id!=NULL) {
418 gmyth_string_list_append_string (str_list, tvchain_id);
419 gmyth_string_list_append_int (str_list, FALSE); // PIP = FALSE (0)
422 gmyth_socket_sendreceive_stringlist ( file_transfer->sock, str_list );
424 //GString *str = NULL;
426 //if (str_list!=NULL && (str = gmyth_string_list_get_string( str_list, 0 )) != NULL && strcasecmp( str->str, "ok" ) != 0 ) {
427 // g_print( "[%s]\t\tSpawnLiveTV is OK!\n", __FUNCTION__ );
430 g_object_unref (str_list);
435 myth_file_transfer_is_recording ( MythFileTransfer *file_transfer )
439 GMythStringList *str_list = gmyth_string_list_new ();
441 g_debug ( "[%s]\n", __FUNCTION__ );
442 g_static_mutex_lock (&mutex);
444 g_string_printf( file_transfer->query, "%s %d", MYTHTV_RECORDER_HEADER,
445 file_transfer->rec_id >= 0 ? file_transfer->rec_id : file_transfer->card_id );
446 gmyth_string_list_append_string (str_list, file_transfer->query);
447 gmyth_string_list_append_string (str_list, g_string_new ("IS_RECORDING"));
449 gmyth_socket_sendreceive_stringlist ( file_transfer->control_sock, str_list );
451 if ( str_list != NULL && gmyth_string_list_length(str_list) > 0 )
454 if ( ( str = gmyth_string_list_get_string( str_list, 0 ) ) != NULL && strcmp( str->str, "bad" )!= 0 ) {
455 gint is_rec = gmyth_string_list_get_int( str_list, 0 );
462 g_print( "[%s] %s, stream is %s being recorded!\n", __FUNCTION__, ret ? "YES" : "NO", ret ? "" : "NOT" );
463 g_static_mutex_unlock (&mutex);
465 if ( str_list != NULL )
466 g_object_unref (str_list);
473 myth_file_transfer_get_file_position ( MythFileTransfer *file_transfer )
477 GMythStringList *str_list = gmyth_string_list_new ();
479 g_debug ( "[%s]\n", __FUNCTION__ );
480 g_static_mutex_lock (&mutex);
482 g_string_printf( file_transfer->query, "%s %d", MYTHTV_RECORDER_HEADER,
483 file_transfer->rec_id >= 0 ? file_transfer->rec_id : file_transfer->card_id );
485 gmyth_string_list_append_string (str_list, file_transfer->query);
486 gmyth_string_list_append_string (str_list, g_string_new ("GET_FILE_POSITION"));
488 gmyth_socket_sendreceive_stringlist ( file_transfer->control_sock, str_list );
490 if ( str_list != NULL && gmyth_string_list_length(str_list) > 0 )
493 if ( ( str = gmyth_string_list_get_string( str_list, 0 ) ) != NULL && strcmp ( str->str, "bad" ) != 0 )
494 pos = gmyth_util_decode_long_long( str_list, 0 );
496 g_static_mutex_unlock (&mutex);
498 #ifndef MYTHTV_ENABLE_DEBUG
500 g_print( "[%s] Got file position = %llu\n", __FUNCTION__, pos );
503 g_object_unref (str_list);
510 myth_file_transfer_get_recordernum( MythFileTransfer *transfer )
512 return transfer->recordernum;
516 myth_file_transfer_get_filesize( MythFileTransfer *transfer )
518 return transfer->filesize;
522 myth_file_transfer_isopen( MythFileTransfer *transfer )
524 return (transfer->sock != NULL && transfer->control_sock != NULL);
528 myth_file_transfer_close( MythFileTransfer *transfer )
530 GMythStringList *strlist;
532 if (transfer->control_sock == NULL)
535 strlist = gmyth_string_list_new( );
537 g_string_printf( transfer->query, "%s %d", MYTHTV_QUERY_HEADER,
538 transfer->recordernum );
539 gmyth_string_list_append_string( strlist, transfer->query );
540 gmyth_string_list_append_char_array( strlist, "DONE" );
543 if ( gmyth_socket_sendreceive_stringlist(transfer->control_sock, strlist) <= 0 )
545 g_printerr( "Remote file timeout.\n" );
550 g_object_unref( transfer->sock );
551 transfer->sock = NULL;
554 if (transfer->control_sock)
556 g_object_unref( transfer->control_sock );
557 transfer->control_sock = NULL;
563 myth_file_transfer_reset_controlsock( MythFileTransfer *transfer )
565 if (transfer->control_sock == NULL)
567 g_printerr( "myth_file_transfer_reset_controlsock(): Called with no control socket" );
571 GString *str = gmyth_socket_receive_response( transfer->control_sock );
573 g_string_free( str, TRUE );
577 myth_file_transfer_reset_sock( MythFileTransfer *transfer )
579 if ( transfer->sock == NULL )
581 g_printerr( "myth_file_transfer_reset_sock(): Called with no raw socket" );
585 GString *str = gmyth_socket_receive_response( transfer->sock );
587 g_string_free( str, TRUE );
591 myth_file_transfer_reset( MythFileTransfer *transfer )
593 myth_file_transfer_reset_controlsock( transfer );
594 myth_file_transfer_reset_sock( transfer );
598 myth_file_transfer_seek(MythFileTransfer *transfer, guint64 pos, gint whence)
600 if (transfer->sock == NULL)
602 g_printerr( "[%s] myth_file_transfer_seek(): Called with no socket", __FUNCTION__ );
606 if (transfer->control_sock == NULL)
609 // if (!controlSock->isOpen() || controlSock->error())
612 GMythStringList *strlist = gmyth_string_list_new();
613 g_string_printf (transfer->query, "%s %d", MYTHTV_QUERY_HEADER, transfer->recordernum);
614 gmyth_string_list_append_string( strlist, transfer->query );
615 gmyth_string_list_append_char_array( strlist, "SEEK" );
616 gmyth_string_list_append_uint64( strlist, pos );
618 gmyth_string_list_append_int( strlist, whence );
621 gmyth_string_list_append_uint64( strlist, pos );
623 gmyth_string_list_append_uint64( strlist, transfer->readposition );
625 gmyth_socket_sendreceive_stringlist( transfer->control_sock, strlist );
627 guint64 retval = gmyth_string_list_get_uint64(strlist, 0);
628 transfer->readposition = retval;
629 g_print( "[%s] got reading position pointer from the streaming = %llu\n",
630 __FUNCTION__, retval );
632 //myth_file_transfer_reset( transfer );
638 myth_control_sock_listener( GIOChannel *source, GIOCondition condition, gpointer data )
643 gchar *msg = g_strdup("");
646 if (condition & G_IO_HUP)
647 g_error ("Read end of pipe died!\n");
648 ret = g_io_channel_read_line ( source, &msg, &len, NULL, &err);
649 if ( ret == G_IO_STATUS_ERROR )
650 g_error ("[%s] Error reading: %s\n", __FUNCTION__, err != NULL ? err->message : "" );
651 g_print ("\n\n\n\n\n\n[%s]\t\tEVENT: Read %u bytes: %s\n\n\n\n\n", __FUNCTION__, len, msg != NULL ? msg : "" );
660 myth_init_io_watchers( void *data )
662 MythFileTransfer *transfer = (MythFileTransfer*)data;
663 GMainContext *context = g_main_context_new();
664 GMainLoop *loop = g_main_loop_new( NULL, FALSE );
666 GSource *source = NULL;
668 if ( transfer->event_sock->sd_io_ch != NULL )
669 source = g_io_create_watch( transfer->event_sock->sd_io_ch, G_IO_IN | G_IO_HUP );
671 g_source_set_callback ( source, (GSourceFunc)myth_control_sock_listener, NULL, NULL );
673 g_source_attach( source, context );
676 g_printerr( "[%s] Error adding watch listener function to the IO control channel!\n", __FUNCTION__ );
678 g_main_loop_run( loop );
680 g_source_unref( source );
682 g_main_loop_unref( loop );
684 g_main_context_unref( context );
690 myth_file_transfer_read(MythFileTransfer *transfer, void *data, gint size, gboolean read_unlimited)
693 gsize bytes_read = 0;
696 gboolean response = FALSE;
698 GIOChannel *io_channel;
699 GIOChannel *io_channel_control;
701 GIOCondition io_cond;
702 GIOCondition io_cond_control;
703 GIOStatus io_status = G_IO_STATUS_NORMAL, io_status_control = G_IO_STATUS_NORMAL;
705 gint buf_len = MYTHTV_BUFFER_SIZE;
707 GMythStringList *strlist = NULL;
708 GError *error = NULL;
710 gchar *trash = g_strdup("");
712 g_return_val_if_fail ( data != NULL, -2 );
714 /* gets the size of the entire file, if the size requested is lesser than 0 */
716 size = transfer->filesize;
718 io_channel = transfer->sock->sd_io_ch;
719 io_channel_control = transfer->control_sock->sd_io_ch;
721 //g_io_channel_set_flags( io_channel, G_IO_FLAG_APPEND |
722 // G_IO_STATUS_AGAIN | G_IO_FLAG_IS_READABLE | G_IO_FLAG_IS_WRITEABLE |
723 // G_IO_FLAG_IS_SEEKABLE, NULL );
725 io_status = g_io_channel_set_encoding( io_channel, NULL, &error );
726 if ( io_status == G_IO_STATUS_NORMAL )
727 g_print( "[%s] Setting encoding to binary data socket).\n", __FUNCTION__ );
729 io_cond = g_io_channel_get_buffer_condition( io_channel );
731 io_cond_control = g_io_channel_get_buffer_condition( io_channel );
733 if ( transfer->sock == NULL || ( io_status == G_IO_STATUS_ERROR ) )
735 g_printerr( "myth_file_transfer_read(): Called with no raw socket.\n" );
740 if ( transfer->control_sock == NULL || ( io_status_control == G_IO_STATUS_ERROR ) )
742 g_printerr( "myth_file_transfer_read(): Called with no control socket.\n" );
748 if (!controlSock->isOpen() || controlSock->error())
752 if ( ( io_cond & G_IO_IN ) != 0 ) {
755 trash = g_new0( gchar, MYTHTV_BUFFER_SIZE );
757 io_status = g_io_channel_read_chars( io_channel, trash,
758 MYTHTV_BUFFER_SIZE, &bytes_read, &error);
760 g_print( "[%s] cleaning buffer on IO binary channel... %d bytes gone!\n",
761 __FUNCTION__, bytes_read );
766 io_cond = g_io_channel_get_buffer_condition( io_channel );
768 } while ( ( io_cond & G_IO_IN ) != 0 && ( io_status != G_IO_STATUS_ERROR ) && (error == NULL) );
770 //if ( trash!= NULL )
774 if ( ( io_cond_control & G_IO_IN ) != 0 ) {
775 GMythStringList *strlist_tmp = gmyth_string_list_new();
776 gmyth_socket_read_stringlist( transfer->control_sock, strlist_tmp );
777 g_object_unref( strlist_tmp );
780 wait_to_transfer = 0;
782 //while ( transfer->live_tv && ( myth_file_transfer_get_file_position( transfer ) < 4096 ) &&
783 // wait_to_transfer++ < MYTHTV_TRANSFER_MAX_WAITS )
784 // g_usleep( 1000*50 ); /* waits just for 2/10 second */
786 //g_thread_create( myth_init_io_watchers, (void*)transfer, FALSE, NULL );
787 //g_printerr( "[%s] Watch listener function to the IO control channel on thread %p.\n", __FUNCTION__, g_thread_self() );
789 //g_static_mutex_lock (&mutex);
790 //strlist = gmyth_string_list_new();
792 g_string_printf ( transfer->query, "%s %d",
793 /*transfer->live_tv ? MYTHTV_RECORDER_HEADER :*/ MYTHTV_QUERY_HEADER,
794 /* transfer->live_tv ? transfer->card_id :*/ transfer->recordernum ); // transfer->recordernum
795 g_print( "\t[%s] Transfer_query = %s\n", __FUNCTION__, transfer->query->str );
798 remaining = size - recv;
799 //g_static_mutex_unlock( &mutex );
800 //data = (void*)g_new0( gchar, size );
802 //g_io_channel_flush( io_channel, NULL );
804 //g_static_mutex_lock( &mutex );
806 io_cond = g_io_channel_get_buffer_condition( io_channel );
808 while ( recv < size && !response )//&& ( io_cond & G_IO_IN ) != 0 )
810 g_io_channel_flush( io_channel_control, NULL );
812 strlist = gmyth_string_list_new();
813 gmyth_string_list_append_char_array( strlist, transfer->query->str );
814 gmyth_string_list_append_char_array( strlist,
815 /*transfer->live_tv ? "REQUEST_BLOCK_RINGBUF" :*/ "REQUEST_BLOCK" );
816 gmyth_string_list_append_int( strlist, remaining );
817 gmyth_socket_write_stringlist( transfer->control_sock, strlist );
819 guint count_bytes = 0;
823 //buf_len = ( sent - recv ) > MYTHTV_BUFFER_SIZE ? MYTHTV_BUFFER_SIZE : ( sent - recv );
824 if ( remaining > MYTHTV_BUFFER_SIZE ) {
825 buf_len = MYTHTV_BUFFER_SIZE;
832 io_status = g_io_channel_read_chars( io_channel, data + recv,
833 buf_len, &bytes_read, &error );
835 //g_static_mutex_unlock( &mutex );
837 GString *sss = g_string_new("");
838 sss = g_string_append_len( sss, (gchar*)data+recv, bytes_read );
840 g_print( "[%s] Reading buffer (length = %d)\n", __FUNCTION__, bytes_read);
842 if ( bytes_read > 0 )
844 //if ( bytes_read <= buf_len )
846 count_bytes += bytes_read;
847 remaining -= bytes_read;
848 g_print( "[%s] Reading buffer (bytes read = %d, remaining = %d)\n", __FUNCTION__, bytes_read, remaining );
849 if ( remaining == 0 ) {
856 //if ( remaining > 0 ) {
858 if ( io_status == G_IO_STATUS_EOF ) {
859 g_print( "[%s] got EOS!", __FUNCTION__ );
861 } else if ( io_status == G_IO_STATUS_ERROR ) {
862 g_print( "[%s] myth_file_transfer_read(): socket error.\n", __FUNCTION__ );
867 /* increase buffer size, to allow get more data (do not obey to the buffer size) */
868 if ( read_unlimited == TRUE ) {
869 // FOR NOW, DO NOTHING!!!
870 //if ( recv > buf_len )
871 // sent += (bytes_read - buf_len) + 1;
874 /* verify if the input (read) buffer is ready to receive data */
875 io_cond = g_io_channel_get_buffer_condition( io_channel );
877 g_print( "[%s]\t io_cond %s prepared for reading! (G_IO_IN) !!!\n\n", __FUNCTION__,
878 ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" );
880 //if ( recv == size )
883 } while ( remaining > 0 );//&& ( io_status == G_IO_STATUS_NORMAL ) );
885 // if ( ( recv < size ) ) {
886 // finish_read = FALSE;
889 io_cond_control = g_io_channel_get_buffer_condition( io_channel_control );
890 if ( remaining == 0 )//( io_cond_control & G_IO_IN ) != 0 )
892 gmyth_socket_read_stringlist( transfer->control_sock, strlist );
893 if ( strlist != NULL && gmyth_string_list_length( strlist ) > 0 )
895 sent = gmyth_string_list_get_int( strlist, 0 ); // -1 on backend error
896 g_print( "[%s] got SENT buffer message = %d\n", __FUNCTION__, sent );
899 g_print( "[%s]\t received = %d bytes, backend says %d bytes sent, "\
900 "io_cond %s prepared for reading! (G_IO_IN) !!!\n\n", __FUNCTION__,
901 recv, sent, ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" );
903 if ( sent == count_bytes )
905 response = ( recv == size );
906 g_print( "[%s]\t\tsent %d, which is equals to bytes_read = %d\n\n",
907 __FUNCTION__, sent, count_bytes );
908 if ( response == TRUE )
913 g_print( "[%s]\t\tsent %d, which is NOT equals to bytes_read = %d\n\n",
914 __FUNCTION__, sent, count_bytes );
923 } // if - reading control response from backend
926 } // if - stringlist response
930 io_cond_control = g_io_channel_get_buffer_condition( io_channel_control );
931 // io_cond = g_io_channel_get_buffer_condition( io_channel );
933 if ( ( ( io_cond_control & G_IO_IN ) != 0 ) &&
934 ( response || ( recv == size ) ) )
936 if ( gmyth_socket_read_stringlist( transfer->control_sock, strlist ) > 0 )
938 if ( strlist != NULL && gmyth_string_list_length(strlist) > 0 )
940 sent = gmyth_string_list_get_int( strlist, 0 ); // -1 on backend error
941 g_print( "[%s]\t received = %d bytes -\tNOW returning from reading buffer I/O socket "\
942 "[%s prepared for reading]! (G_IO_IN) !!!\n\n", __FUNCTION__,
943 sent, ( ( io_cond & G_IO_IN ) != 0 ) ? "IS" : "IS NOT" );
948 g_printerr ( "myth_file_transfer_read(): No response from control socket.");
953 else if ( error != NULL )
955 g_printerr( "[%s] Error occurred: (%d, %s)\n", __FUNCTION__, error->code, error->message );
959 //g_static_mutex_unlock (&mutex);
964 if ( strlist != NULL )
965 g_object_unref( strlist );
967 g_print( "myth_file_transfer_read(): reqd=%d, rcvd=%d, rept=%d, "\
968 "(rcvd and rept MUST be the same!)\n", size,
971 //if ( ( recv != size ) || ( sent != size ) ) {
975 if ( error != NULL ) {
976 g_printerr( "Cleaning-up ERROR: %s [msg = %s, code = %d]\n", __FUNCTION__, error->message,
978 g_error_free( error );
985 myth_file_transfer_settimeout( MythFileTransfer *transfer, gboolean fast )
988 GMythStringList *strlist = NULL;
990 if ( transfer->timeoutisfast == fast )
993 if ( transfer->sock == NULL )
995 g_printerr( "myth_file_transfer_settimeout(): Called with no socket" );
999 if ( transfer->control_sock == NULL )
1002 strlist = gmyth_string_list_new();
1003 gmyth_string_list_append_string( strlist, transfer->query );
1004 gmyth_string_list_append_char_array( strlist, "SET_TIMEOUT" );
1005 gmyth_string_list_append_int( strlist, fast );
1007 gmyth_socket_write_stringlist( transfer->control_sock, strlist );
1008 gmyth_socket_read_stringlist( transfer->control_sock, strlist );
1010 transfer->timeoutisfast = fast;
1017 main( int argc, char *argv[] )
1021 MythFileTransfer *file_transfer = myth_file_transfer_new( 1,
1022 g_string_new("myth://192.168.1.109:6543/jshks.nuv"), -1, MYTHTV_VERSION );
1023 myth_file_transfer_setup( &file_transfer );
1024 gchar *data = g_strdup("");
1026 gint num = myth_file_transfer_read( file_transfer, data, -1 );