Mercurialgmyth / file revision
summary | shortlog | changelog | graph | tags | branches | files | changeset | file | revisions | annotate | diff | raw
libgnomevfs2-mythtv/modules/mythtv-method.c
author rosfran
Tue Feb 06 15:00:23 2007 +0000 (2007-02-06)
branchtrunk
changeset 328 73461d8db7ec
parent 327 41995e0df2ba
child 331 f32837103d17
permissions -rwxr-xr-x
[svn r330] Some minor fixes on do_open callback. 
     1 /*

     2  * @author Hallyson Melo <hallyson.melo@indt.org.br>

     3  *

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

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

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

     7  * (at your option) any later version.

     8  *

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

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

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

    12  * GNU General Public License for more details.

    13  *

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

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

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

    17  */

    18 

    19 #ifdef HAVE_CONFIG_H

    20 #include <config.h>

    21 #endif

    22 

    23 #include <string.h>

    24 #include <glib.h>

    25 #include <math.h>

    26 

    27 #include <libgnomevfs/gnome-vfs-module.h>

    28 #include <libgnomevfs/gnome-vfs-utils.h>

    29 

    30 #include <gmyth/gmyth_file_transfer.h>

    31 #include <gmyth/gmyth_livetv.h>

    32 #include <gmyth/gmyth_uri.h>

    33 #include <gmyth/gmyth_recorder.h>

    34 #include <gmyth/gmyth_backendinfo.h>

    35 #include <gmyth/gmyth_util.h>

    36 

    37 #define GST_MYTHTV_ID_NUM               1

    38 #define MYTHTV_VERSION_DEFAULT          30

    39 #define MYTHTV_TRANSFER_MAX_WAITS       100

    40 

    41 #define MYTHTV_BUFFER_SIZE							1024*64

    42 

    43 static GnomeVFSResult do_read (GnomeVFSMethod *method,

    44                                GnomeVFSMethodHandle *method_handle,

    45                                gpointer buffer,

    46                                GnomeVFSFileSize num_bytes,

    47                                GnomeVFSFileSize *bytes_read,

    48                                GnomeVFSContext *context);

    49 

    50 typedef struct {

    51     GMythFileTransfer *file_transfer;

    52     GMythLiveTV 			*livetv;

    53     gchar 						*channel_name;

    54     

    55     gint mythtv_version;

    56     gint64 content_size;

    57     guint64 bytes_read;

    58 

    59     GByteArray *buffer;

    60     gsize buffer_remain;

    61 } MythtvHandle;

    62 

    63 static GnomeVFSResult

    64 do_open (GnomeVFSMethod *method,

    65          GnomeVFSMethodHandle **method_handle,

    66          GnomeVFSURI *uri,

    67          GnomeVFSOpenMode mode,

    68          GnomeVFSContext *context)

    69 {

    70     MythtvHandle *myth_handle;

    71     GMythBackendInfo *backend_info;

    72     GMythURI *gmyth_uri = NULL;

    73     gboolean ret = TRUE;

    74     gboolean is_livetv = FALSE;

    75 

    76     _GNOME_VFS_METHOD_PARAM_CHECK (method_handle != NULL);

    77     _GNOME_VFS_METHOD_PARAM_CHECK (uri != NULL);

    78 

    79     myth_handle = g_new0 (MythtvHandle, 1);

    80 

    81     if (mode & GNOME_VFS_OPEN_WRITE) {

    82         return GNOME_VFS_ERROR_NOT_PERMITTED;

    83     }

    84 

    85     if (gnome_vfs_uri_get_host_name (uri) == NULL) {

    86     	return GNOME_VFS_ERROR_INVALID_HOST_NAME;

    87     }

    88 

    89     /* Initialize mythtv handler*/

    90     myth_handle->file_transfer = NULL;

    91     myth_handle->livetv = NULL;

    92     myth_handle->mythtv_version = MYTHTV_VERSION_DEFAULT;

    93     myth_handle->bytes_read = 0;

    94     myth_handle->content_size = (GnomeVFSFileSize) - 1;

    95 

    96     /* Creates and fills out the backend info structure */    

    97 	  backend_info = gmyth_backend_info_new_with_uri ( 

    98 	  			gnome_vfs_unescape_string( gnome_vfs_uri_to_string( uri, GNOME_VFS_URI_HIDE_NONE ), "" ) );

    99 	  

   100 	  /* creates an instance of  */  

   101 	  gmyth_uri = gmyth_uri_new_with_value( 

   102 	  		gnome_vfs_unescape_string( gnome_vfs_uri_to_string( uri, GNOME_VFS_URI_HIDE_NONE ), "" ) );

   103 

   104 	  is_livetv = gmyth_uri_is_livetv( gmyth_uri );

   105 

   106 	  /* Connect to the backend */	  

   107 	  if ( gmyth_uri != NULL && is_livetv == TRUE ) {

   108 	    myth_handle->livetv = gmyth_livetv_new ();

   109 	    

   110 	    myth_handle->channel_name = gmyth_uri_get_channel_name( gmyth_uri );

   111 	    

   112 	    g_print( "[%s] Channel name = %s", __FUNCTION__, myth_handle->channel_name );

   113 	

   114 	    if ( myth_handle->channel_name != NULL ) {

   115 	      if (gmyth_livetv_channel_name_setup (myth_handle->livetv, myth_handle->channel_name,

   116 	              backend_info) == FALSE) {

   117 	        g_object_unref( gmyth_uri );

   118 	        ret = FALSE;

   119 	      }

   120 	    } else {

   121 	      if ( gmyth_livetv_setup (myth_handle->livetv, backend_info) == FALSE ) {

   122 	      	g_object_unref( gmyth_uri );

   123 	        ret = FALSE;

   124 	      }

   125 	    }

   126 	

   127 	    myth_handle->file_transfer = gmyth_livetv_create_file_transfer (myth_handle->livetv);

   128 	

   129 	    if (NULL == myth_handle->file_transfer) {

   130 	      ret = FALSE;

   131 	    }

   132 	    

   133   		if ( !gmyth_file_transfer_open( myth_handle->file_transfer, myth_handle->livetv->uri != NULL ? 

   134 								gmyth_uri_get_path(myth_handle->livetv->uri) : 

   135 								myth_handle->livetv->proginfo->pathname->str ) )

   136 			{

   137 				g_object_unref( myth_handle->file_transfer );

   138 				myth_handle->file_transfer = NULL;

   139 				ret = FALSE;

   140 			}

   141 	    

   142 	  } else {

   143 	

   144 	    myth_handle->file_transfer = gmyth_file_transfer_new (backend_info);

   145 	    

   146 	    /* Verifies if the file exists */

   147 	    if (!gmyth_util_file_exists (backend_info, gmyth_uri_get_path (gmyth_uri))) {

   148 	        g_object_unref (backend_info);

   149 					ret = FALSE;

   150 	    }

   151 	    

   152 	    /* sets the Playback monitor connection */

   153 	    ret = gmyth_file_transfer_open ( myth_handle->file_transfer, 

   154 	    		gmyth_uri_get_path (gmyth_uri) );

   155 		

   156 	  } /* if - LiveTV or not? */

   157 	  

   158     if (ret == FALSE) {

   159 	    g_warning ("MythTV FileTransfer open error.\n");

   160 	    return GNOME_VFS_ERROR_NOT_OPEN;

   161 	  }

   162 

   163     g_object_unref (backend_info);

   164     

   165 	  //if ( gmyth_uri != NULL )

   166 	  //	g_object_unref( gmyth_uri );

   167 	  

   168 	  g_return_val_if_fail (myth_handle->file_transfer != NULL, GNOME_VFS_ERROR_NOT_OPEN);

   169 	  

   170 	  if ( myth_handle->file_transfer->filesize < 0 && is_livetv ) {

   171 	  	myth_handle->content_size = (GnomeVFSFileSize) - 1;

   172 			myth_handle->content_size = gmyth_recorder_get_file_position( myth_handle->livetv->recorder );

   173 	  } else		

   174     	myth_handle->content_size = myth_handle->file_transfer->filesize;

   175     

   176     myth_handle->buffer = g_byte_array_sized_new (MYTHTV_BUFFER_SIZE);

   177     myth_handle->buffer_remain = 0;

   178 

   179     *method_handle = (GnomeVFSMethodHandle *) myth_handle;

   180 

   181     return GNOME_VFS_OK;

   182 }

   183 

   184 static GnomeVFSResult

   185 do_read (GnomeVFSMethod *method,

   186          GnomeVFSMethodHandle *method_handle,

   187          gpointer buffer,

   188          GnomeVFSFileSize num_bytes,

   189          GnomeVFSFileSize *bytes_read,

   190          GnomeVFSContext *context)

   191 {

   192   MythtvHandle *myth_handle = (MythtvHandle *) method_handle;

   193   GnomeVFSFileSize bytes_to_read;

   194 

   195   *bytes_read = 0;

   196 

   197   if (myth_handle->bytes_read >= myth_handle->content_size)

   198       return GNOME_VFS_ERROR_EOF;

   199 

   200   // fixme: change this to min math function

   201   if (myth_handle->content_size > 0 && num_bytes > ( myth_handle->content_size - myth_handle->bytes_read ))

   202     bytes_to_read = myth_handle->content_size - myth_handle->bytes_read;

   203   else

   204     bytes_to_read = num_bytes;

   205 

   206   /* Loop sending the Myth File Transfer request:

   207   * Retry whilst authentication fails and we supply it. */

   208   //if (myth_handle->buffer_remain  < MYTHTV_BUFFER_SIZE) {

   209   if ( ( myth_handle->buffer_remain = myth_handle->buffer->len ) < MYTHTV_BUFFER_SIZE ) {

   210   	GByteArray *tmp_buffer = g_byte_array_new();

   211 

   212 		printf ("XXXXXXXXXXXXXX Pedindo %d %d\n", MYTHTV_BUFFER_SIZE, myth_handle->buffer_remain);

   213 

   214     gint len = gmyth_file_transfer_read (myth_handle->file_transfer,

   215           tmp_buffer, MYTHTV_BUFFER_SIZE - myth_handle->buffer_remain, TRUE);

   216 

   217 		if (len < 0) {

   218 	    g_byte_array_free (tmp_buffer, TRUE);

   219 	    g_warning ("Fail to read bytes");

   220 	    return GNOME_VFS_ERROR_IO;

   221 	  } /*else if (len == 0) {

   222 		    g_byte_array_free (tmp_buffer, TRUE);

   223 		    g_warning ("End of file probably achieved");

   224 		    return GNOME_VFS_ERROR_EOF;

   225 		}*/

   226 	

   227 	    myth_handle->buffer = g_byte_array_append (myth_handle->buffer,

   228 	    		tmp_buffer->data, len);

   229 	

   230 			myth_handle->buffer_remain += len;

   231 

   232       g_byte_array_free (tmp_buffer, TRUE);

   233     	tmp_buffer = NULL;

   234     }

   235     

   236     bytes_to_read = (bytes_to_read > myth_handle->buffer_remain) ? myth_handle->buffer_remain : bytes_to_read;

   237     /* gets the first buffer_size bytes from the byte array buffer variable */ 

   238 

   239     g_memmove (buffer, myth_handle->buffer->data, bytes_to_read);

   240 

   241     myth_handle->bytes_read += bytes_to_read;

   242     myth_handle->buffer_remain -= bytes_to_read;    

   243 

   244   	/* flushs the newly buffer got from byte array */

   245   	myth_handle->buffer = g_byte_array_remove_range (myth_handle->buffer, 0, bytes_to_read);

   246     *bytes_read = bytes_to_read;

   247   

   248     return GNOME_VFS_OK;

   249 }

   250 

   251 static GnomeVFSResult

   252 do_close (GnomeVFSMethod *method,

   253           GnomeVFSMethodHandle *method_handle,

   254           GnomeVFSContext *context)

   255 {

   256 

   257     MythtvHandle *myth_handle = (MythtvHandle *) method_handle;

   258 

   259     if (myth_handle->file_transfer) {

   260 	    gmyth_file_transfer_close (myth_handle->file_transfer);

   261         g_object_unref (myth_handle->file_transfer);

   262     	myth_handle->file_transfer = NULL;

   263     }

   264     

   265     if (myth_handle->livetv) {

   266       g_object_unref (myth_handle->livetv);

   267     	myth_handle->livetv = NULL;

   268     }

   269     

   270     if (myth_handle->buffer) {

   271 		g_byte_array_free (myth_handle->buffer, TRUE);

   272 		myth_handle->buffer = NULL;

   273     }

   274 

   275     g_free (myth_handle);

   276 

   277     return GNOME_VFS_OK;

   278 }

   279 

   280 static GnomeVFSResult

   281 do_get_file_info (GnomeVFSMethod *method,

   282                   GnomeVFSURI *uri,

   283                   GnomeVFSFileInfo *file_info,

   284                   GnomeVFSFileInfoOptions options,

   285                   GnomeVFSContext *context)

   286 {

   287     GMythFileTransfer *file_transfer = NULL;

   288     //GMythLiveTV 			*livetv 			 = NULL;

   289     GMythBackendInfo  *backend_info  = NULL;

   290     GMythURI					*gmyth_uri		 = NULL;

   291     gboolean 					is_livetv 		 = FALSE;

   292     gboolean					ret						 = TRUE;

   293     

   294     file_info->size =     (GnomeVFSFileSize) - 1;

   295     /* Creates and fills out the backend info structure */    

   296 	  backend_info = gmyth_backend_info_new_with_uri ( 

   297 	  			gnome_vfs_unescape_string( gnome_vfs_uri_to_string( uri, GNOME_VFS_URI_HIDE_NONE ), "" ) );

   298 	  

   299 	  /* creates an instance of */  

   300 	  gmyth_uri = gmyth_uri_new_with_value( 

   301 	  		gnome_vfs_unescape_string( gnome_vfs_uri_to_string( uri, GNOME_VFS_URI_HIDE_NONE ), "" ) );

   302 

   303 	  is_livetv = gmyth_uri_is_livetv( gmyth_uri );

   304 

   305     file_info->name = g_strdup (gmyth_uri_get_path (gmyth_uri));

   306     file_info->valid_fields = file_info->valid_fields

   307         | GNOME_VFS_FILE_INFO_FIELDS_TYPE

   308         | GNOME_VFS_FILE_INFO_FIELDS_MIME_TYPE

   309         | GNOME_VFS_FILE_INFO_FIELDS_PERMISSIONS;

   310     file_info->type = GNOME_VFS_FILE_TYPE_REGULAR;

   311     /* fixme: get from file extension? */

   312     file_info->mime_type = g_strdup ("video/x-nuv");

   313     file_info->permissions =

   314         GNOME_VFS_PERM_USER_READ |

   315         GNOME_VFS_PERM_OTHER_READ |

   316         GNOME_VFS_PERM_GROUP_READ;

   317 

   318 	  /* Connect to the backend */

   319 	  if ( gmyth_uri != NULL && is_livetv == TRUE ) {

   320 	    /*

   321 	    livetv = gmyth_livetv_new ();	    

   322 	        

   323 	    gint channel_num = gmyth_uri_get_channel_num( gmyth_uri );

   324 	

   325 	    if ( channel_num != -1 ) {

   326 	      if (gmyth_livetv_channel_setup (livetv, channel_num,

   327 	              backend_info) == FALSE) {

   328 	        g_object_unref( gmyth_uri );

   329 	        ret = FALSE;

   330 	      }

   331 	    } else {

   332 	      if ( gmyth_livetv_setup (livetv, backend_info) == FALSE ) {

   333 	      	g_object_unref( gmyth_uri );

   334 	        ret = FALSE;

   335 	      }

   336 	    }

   337 	

   338 	    file_transfer = gmyth_livetv_create_file_transfer (livetv);	    

   339 	

   340 	    if (NULL == file_transfer) {

   341 	      ret = FALSE;

   342 	    }

   343 	    */

   344 	    

   345 	  } else {

   346 	

   347 	    file_transfer = gmyth_file_transfer_new (backend_info);

   348 	    

   349 	    /* Verifies if the file exists */

   350 	    if (!gmyth_util_file_exists (backend_info, gmyth_uri_get_path (gmyth_uri))) {

   351 	        g_object_unref (backend_info);

   352 					return GNOME_VFS_ERROR_NOT_FOUND;

   353 	    }

   354 	    

   355 	    /* sets the Playback monitor connection */

   356 	    ret = gmyth_file_transfer_open ( file_transfer, gmyth_uri_get_path (gmyth_uri) );

   357 		

   358 	  } /* if - LiveTV or not? */

   359 	  

   360 	  /*	  

   361     if (ret == FALSE) {

   362 	    g_warning ("MythTV FileTransfer open error\n");

   363 	    return GNOME_VFS_ERROR_NOT_OPEN;

   364 	  }

   365 	  */

   366 	  if ( is_livetv )

   367 	  {

   368 	  	/*

   369 	  	GMythProgramInfo *prog_info = gmyth_recorder_get_current_program_info ( GMythRecorder *recorder )

   370 	  	if ( file_transfer->filesize < 0 )

   371 				file_info->size = gmyth_recorder_get_file_position( livetv->recorder );

   372 			else

   373 			*/

   374 			file_info->size =(GnomeVFSFileSize) - 1;

   375 	  } else {		

   376     	file_info->size = gmyth_file_transfer_get_filesize (file_transfer);

   377 	  }

   378     

   379     file_info->block_count = GNOME_VFS_FILE_INFO_FIELDS_BLOCK_COUNT;

   380     file_info->io_block_size = GNOME_VFS_FILE_INFO_FIELDS_IO_BLOCK_SIZE;

   381     

   382     g_object_unref (backend_info);

   383     g_object_unref (file_transfer);

   384     //g_object_unref (livetv);    

   385 

   386     return GNOME_VFS_OK;

   387 }

   388 

   389 static gboolean

   390 do_is_local (GnomeVFSMethod *method,

   391              const GnomeVFSURI *uri)

   392 {

   393 	return FALSE;

   394 }

   395 

   396 static GnomeVFSMethod method = {

   397 	sizeof (GnomeVFSMethod),

   398 	do_open,

   399 	NULL,

   400 	do_close,

   401 	do_read,

   402 	NULL,

   403 	NULL,

   404 	NULL,

   405 	NULL,

   406 	NULL,

   407 	NULL,

   408 	NULL,

   409 	do_get_file_info,

   410 	NULL,

   411 	do_is_local,

   412 	NULL,

   413 	NULL,

   414 	NULL,

   415 	NULL,

   416 	NULL,

   417 	NULL,

   418 	NULL,

   419 	NULL,

   420 	NULL,

   421 	NULL,

   422 	NULL,

   423 	NULL,

   424 };

   425 

   426 

   427 GnomeVFSMethod *

   428 vfs_module_init (const char *method_name, const char *args)

   429 {

   430 	return &method;

   431 }

   432 

   433 void

   434 vfs_module_shutdown (GnomeVFSMethod *method)

   435 {

   436 }
gmyth