input.c 25.5 KB
Newer Older
1 2
/*****************************************************************************
 * input.c: input thread
Michel Kaempf's avatar
Michel Kaempf committed
3 4
 * Read an MPEG2 stream, demultiplex and parse it before sending it to
 * decoders.
5 6
 *****************************************************************************
 * Copyright (C) 1998, 1999, 2000 VideoLAN
Sam Hocevar's avatar
 
Sam Hocevar committed
7
 * $Id: input.c,v 1.116 2001/05/31 03:12:49 sam Exp $
8
 *
9
 * Authors: Christophe Massiot <massiot@via.ecp.fr>
10 11 12 13 14
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
15
 * 
16 17
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 19
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
20
 *
21 22 23
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
24
 *****************************************************************************/
Michel Kaempf's avatar
Michel Kaempf committed
25

26
/*****************************************************************************
Michel Kaempf's avatar
Michel Kaempf committed
27
 * Preamble
28
 *****************************************************************************/
29 30
#include "defs.h"

31 32 33 34
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
Sam Hocevar's avatar
 
Sam Hocevar committed
35 36

#ifdef HAVE_UNISTD_H
Sam Hocevar's avatar
 
Sam Hocevar committed
37
#   include <unistd.h>
Sam Hocevar's avatar
 
Sam Hocevar committed
38
#elif defined( _MSC_VER ) && defined( _WIN32 )
Sam Hocevar's avatar
 
Sam Hocevar committed
39
#   include <io.h>
Sam Hocevar's avatar
 
Sam Hocevar committed
40 41
#endif

42
#include <string.h>
Sam Hocevar's avatar
 
Sam Hocevar committed
43 44
#include <errno.h>

Sam Hocevar's avatar
 
Sam Hocevar committed
45 46 47
#ifdef STRNCASECMP_IN_STRINGS_H
#   include <strings.h>
#endif
48 49

#ifdef WIN32
Sam Hocevar's avatar
 
Sam Hocevar committed
50 51 52 53 54 55 56 57
#   include <winsock2.h>
#elif !defined( SYS_BEOS ) && !defined( SYS_NTO )
#   include <netdb.h>                                         /* hostent ... */
#   include <sys/socket.h>
#   include <netinet/in.h>
#   include <arpa/inet.h>
#   include <sys/types.h>
#   include <sys/socket.h>
Sam Hocevar's avatar
 
Sam Hocevar committed
58
#endif
Henri Fallon's avatar
 
Henri Fallon committed
59

60 61 62 63
#ifdef STATS
#   include <sys/times.h>
#endif

Michel Kaempf's avatar
Michel Kaempf committed
64
#include "config.h"
65 66
#include "common.h"
#include "threads.h"
Michel Kaempf's avatar
Michel Kaempf committed
67
#include "mtime.h"
Sam Hocevar's avatar
 
Sam Hocevar committed
68
#include "netutils.h"
Sam Hocevar's avatar
 
Sam Hocevar committed
69
#include "modules.h"
70

71
#include "intf_msg.h"
Sam Hocevar's avatar
 
Sam Hocevar committed
72
#include "intf_playlist.h"
73

74 75 76
#include "stream_control.h"
#include "input_ext-intf.h"
#include "input_ext-dec.h"
Michel Lespinasse's avatar
Yop,  
Michel Lespinasse committed
77

78
#include "input.h"
Sam Hocevar's avatar
 
Sam Hocevar committed
79 80 81
#include "interface.h"

#include "main.h"
Michel Kaempf's avatar
Michel Kaempf committed
82

83
/*****************************************************************************
Michel Kaempf's avatar
Michel Kaempf committed
84
 * Local prototypes
85
 *****************************************************************************/
Sam Hocevar's avatar
 
Sam Hocevar committed
86 87 88 89 90
static void RunThread       ( input_thread_t *p_input );
static  int InitThread      ( input_thread_t *p_input );
static void ErrorThread     ( input_thread_t *p_input );
static void DestroyThread   ( input_thread_t *p_input );
static void EndThread       ( input_thread_t *p_input );
Michel Kaempf's avatar
Michel Kaempf committed
91

Sam Hocevar's avatar
 
Sam Hocevar committed
92 93 94 95 96
static void FileOpen        ( input_thread_t *p_input );
static void FileClose       ( input_thread_t *p_input );
static void NetworkOpen     ( input_thread_t *p_input );
static void NetworkClose    ( input_thread_t *p_input );

97
/*****************************************************************************
98
 * input_CreateThread: creates a new input thread
99
 *****************************************************************************
100 101 102 103
 * This function creates a new input, and returns a pointer
 * to its description. On error, it returns NULL.
 * If pi_status is NULL, then the function will block until the thread is ready.
 * If not, it will be updated using one of the THREAD_* constants.
104
 *****************************************************************************/
Sam Hocevar's avatar
 
Sam Hocevar committed
105
input_thread_t *input_CreateThread ( playlist_item_t *p_item, int *pi_status )
Michel Kaempf's avatar
Michel Kaempf committed
106
{
107 108 109
    input_thread_t *    p_input;                        /* thread descriptor */
    int                 i_status;                           /* thread status */

110 111 112
    /* Allocate descriptor */
    p_input = (input_thread_t *)malloc( sizeof(input_thread_t) );
    if( p_input == NULL )
Michel Kaempf's avatar
Michel Kaempf committed
113
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
114 115
        intf_ErrMsg( "input error: can't allocate input thread (%s)",
                     strerror(errno) );
Michel Kaempf's avatar
Michel Kaempf committed
116 117
        return( NULL );
    }
118

119 120 121
    /* Packets read once */
    p_input->i_read_once = INPUT_READ_ONCE;

122 123 124
    /* Initialize thread properties */
    p_input->b_die              = 0;
    p_input->b_error            = 0;
Sam Hocevar's avatar
 
Sam Hocevar committed
125 126 127 128 129
    p_input->b_eof              = 0;

    /* Set target */
    p_input->p_source           = p_item->psz_name;

130
    /* I have never understood that stuff --Meuuh */
131 132
    p_input->pi_status          = (pi_status != NULL) ? pi_status : &i_status;
    *p_input->pi_status         = THREAD_CREATE;
Michel Kaempf's avatar
Michel Kaempf committed
133

134
    /* Initialize stream description */
135 136
    p_input->stream.i_es_number = 0;
    p_input->stream.i_selected_es_number = 0;
137
    p_input->stream.i_pgrm_number = 0;
138
    p_input->stream.i_new_status = p_input->stream.i_new_rate = 0;
Christophe Massiot's avatar
Christophe Massiot committed
139
    p_input->stream.i_mux_rate = 0;
Michel Kaempf's avatar
Michel Kaempf committed
140

141
    /* no stream, no area */
Stéphane Borel's avatar
 
Stéphane Borel committed
142 143
    p_input->stream.i_area_nb = 0;
    p_input->stream.pp_areas = NULL;
144
    p_input->stream.p_selected_area = NULL;
145
    p_input->stream.p_new_area = NULL;
Stéphane Borel's avatar
 
Stéphane Borel committed
146 147
    /* By default there is one areas in a stream */
    input_AddArea( p_input );
148
    p_input->stream.p_selected_area = p_input->stream.pp_areas[0];
Stéphane Borel's avatar
 
Stéphane Borel committed
149

150 151 152 153 154
    /* Initialize stream control properties. */
    p_input->stream.control.i_status = PLAYING_S;
    p_input->stream.control.i_rate = DEFAULT_RATE;
    p_input->stream.control.b_mute = 0;
    p_input->stream.control.b_bw = 0;
Michel Kaempf's avatar
Michel Kaempf committed
155

Sam Hocevar's avatar
 
Sam Hocevar committed
156 157 158 159 160 161 162 163
    /* Setup callbacks */
    p_input->pf_file_open     = FileOpen;
    p_input->pf_file_close    = FileClose;
#if !defined( SYS_BEOS ) && !defined( SYS_NTO )
    p_input->pf_network_open  = NetworkOpen;
    p_input->pf_network_close = NetworkClose;
#endif

Michel Kaempf's avatar
Michel Kaempf committed
164
    /* Create thread and set locks. */
165
    vlc_mutex_init( &p_input->stream.stream_lock );
166
    vlc_cond_init( &p_input->stream.stream_wait );
167 168 169
    vlc_mutex_init( &p_input->stream.control.control_lock );
    if( vlc_thread_create( &p_input->thread_id, "input", (void *) RunThread,
                           (void *) p_input ) )
Michel Kaempf's avatar
Michel Kaempf committed
170
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
171 172
        intf_ErrMsg( "input error: can't create input thread (%s)",
                     strerror(errno) );
Michel Kaempf's avatar
Michel Kaempf committed
173 174 175
        free( p_input );
        return( NULL );
    }
176

177 178 179 180
    /* If status is NULL, wait until the thread is created */
    if( pi_status == NULL )
    {
        do
181
        {
182
            msleep( THREAD_SLEEP );
183
        } while( (i_status != THREAD_READY) && (i_status != THREAD_ERROR)
Sam Hocevar's avatar
 
Sam Hocevar committed
184
                && (i_status != THREAD_FATAL) );
185 186
        if( i_status != THREAD_READY )
        {
187 188
            return( NULL );
        }
189
    }
Michel Kaempf's avatar
Michel Kaempf committed
190 191 192
    return( p_input );
}

193
/*****************************************************************************
Michel Kaempf's avatar
Michel Kaempf committed
194
 * input_DestroyThread: mark an input thread as zombie
195
 *****************************************************************************
Michel Kaempf's avatar
Michel Kaempf committed
196
 * This function should not return until the thread is effectively cancelled.
197
 *****************************************************************************/
198
void input_DestroyThread( input_thread_t *p_input, int *pi_status )
Michel Kaempf's avatar
Michel Kaempf committed
199
{
200
    int         i_status;                                   /* thread status */
201 202 203

    /* Set status */
    p_input->pi_status = (pi_status != NULL) ? pi_status : &i_status;
204 205
    *p_input->pi_status = THREAD_DESTROY;

206 207
    /* Request thread destruction */
    p_input->b_die = 1;
Michel Kaempf's avatar
Michel Kaempf committed
208

209 210 211 212 213
    /* Make the thread exit of an eventual vlc_cond_wait() */
    vlc_mutex_lock( &p_input->stream.stream_lock );
    vlc_cond_signal( &p_input->stream.stream_wait );
    vlc_mutex_unlock( &p_input->stream.stream_lock );

214 215 216 217 218 219
    /* If status is NULL, wait until thread has been destroyed */
    if( pi_status == NULL )
    {
        do
        {
            msleep( THREAD_SLEEP );
220 221
        } while ( (i_status != THREAD_OVER) && (i_status != THREAD_ERROR)
                  && (i_status != THREAD_FATAL) );
222
    }
Michel Kaempf's avatar
Michel Kaempf committed
223 224
}

225
/*****************************************************************************
226
 * RunThread: main thread loop
227
 *****************************************************************************
228
 * Thread in charge of processing the network packets and demultiplexing.
229
 *****************************************************************************/
230
static void RunThread( input_thread_t *p_input )
Michel Kaempf's avatar
Michel Kaempf committed
231
{
232
    int                     i_error, i;
Sam Hocevar's avatar
 
Sam Hocevar committed
233
    data_packet_t **        pp_packets;
Michel Kaempf's avatar
Michel Kaempf committed
234

Sam Hocevar's avatar
 
Sam Hocevar committed
235 236 237 238 239 240 241 242 243 244
    if( InitThread( p_input ) )
    {

        /* If we failed, wait before we are killed, and exit */
        *p_input->pi_status = THREAD_ERROR;
        p_input->b_error = 1;
        ErrorThread( p_input );
        DestroyThread( p_input );
        return;
    }
Michel Kaempf's avatar
Michel Kaempf committed
245

246 247 248 249 250
    /* initialization is completed */
    vlc_mutex_lock( &p_input->stream.stream_lock );
    p_input->stream.b_changed = 1;
    vlc_mutex_unlock( &p_input->stream.stream_lock );

Sam Hocevar's avatar
 
Sam Hocevar committed
251 252 253
    pp_packets = (data_packet_t **) malloc( p_input->i_read_once *
                                        sizeof( data_packet_t * ) );
    if( pp_packets == NULL )
254
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
255
        intf_ErrMsg( "input error: out of memory" );
Sam Hocevar's avatar
 
Sam Hocevar committed
256
        free( pp_packets );
Sam Hocevar's avatar
 
Sam Hocevar committed
257 258
        p_input->b_error = 1;
    }
259

Sam Hocevar's avatar
 
Sam Hocevar committed
260 261
    while( !p_input->b_die && !p_input->b_error && !p_input->b_eof )
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
262
#ifdef STATS
Sam Hocevar's avatar
 
Sam Hocevar committed
263
        p_input->c_loops++;
Sam Hocevar's avatar
 
Sam Hocevar committed
264 265
#endif

266
        vlc_mutex_lock( &p_input->stream.stream_lock );
267

268 269 270 271 272 273
        if( p_input->stream.p_new_area )
        {
            p_input->pf_set_area( p_input, p_input->stream.p_new_area );
            p_input->stream.p_new_area = NULL;
        }

274
        if( p_input->stream.p_selected_area->i_seek != NO_SEEK )
Sam Hocevar's avatar
 
Sam Hocevar committed
275
        {
276 277
            if( p_input->stream.b_seekable && p_input->pf_seek != NULL )
            {
278 279
                p_input->pf_seek( p_input,
                                  p_input->stream.p_selected_area->i_seek );
280 281 282 283 284 285 286 287 288 289 290 291 292

                for( i = 0; i < p_input->stream.i_pgrm_number; i++ )
                {
                    pgrm_descriptor_t * p_pgrm
                                            = p_input->stream.pp_programs[i];
                    /* Escape all decoders for the stream discontinuity they
                     * will encounter. */
                    input_EscapeDiscontinuity( p_input, p_pgrm );

                    /* Reinitialize synchro. */
                    p_pgrm->i_synchro_state = SYNCHRO_REINIT;
                }
            }
293
            p_input->stream.p_selected_area->i_seek = NO_SEEK;
Sam Hocevar's avatar
 
Sam Hocevar committed
294
        }
295

296 297 298 299 300 301 302 303 304 305 306 307
        if( p_input->stream.p_removed_es )
        {
            input_UnselectES( p_input, p_input->stream.p_removed_es );
            p_input->stream.p_removed_es = NULL;
        }

        if( p_input->stream.p_newly_selected_es )
        {
            input_SelectES( p_input, p_input->stream.p_newly_selected_es );
            p_input->stream.p_newly_selected_es = NULL;
        }

308
        vlc_mutex_unlock( &p_input->stream.stream_lock );
Sam Hocevar's avatar
 
Sam Hocevar committed
309 310

        i_error = p_input->pf_read( p_input, pp_packets );
Sam Hocevar's avatar
 
Sam Hocevar committed
311

Sam Hocevar's avatar
 
Sam Hocevar committed
312
        /* Demultiplex read packets. */
313
        for( i = 0; i < p_input->i_read_once && pp_packets[i] != NULL; i++ )
Sam Hocevar's avatar
 
Sam Hocevar committed
314 315 316
        {
            p_input->pf_demux( p_input, pp_packets[i] );
        }
Sam Hocevar's avatar
 
Sam Hocevar committed
317

Sam Hocevar's avatar
 
Sam Hocevar committed
318 319 320
        if( i_error )
        {
            if( i_error == 1 )
321
            {
Sam Hocevar's avatar
 
Sam Hocevar committed
322 323
                /* End of file - we do not set b_die because only the
                 * interface is allowed to do so. */
324
                intf_WarnMsg( 3, "input: EOF reached" );
Sam Hocevar's avatar
 
Sam Hocevar committed
325
                p_input->b_eof = 1;
Sam Hocevar's avatar
 
Sam Hocevar committed
326
            }
Sam Hocevar's avatar
 
Sam Hocevar committed
327
            else
Sam Hocevar's avatar
 
Sam Hocevar committed
328
            {
Sam Hocevar's avatar
 
Sam Hocevar committed
329
                p_input->b_error = 1;
330
            }
331 332 333
        }
    }

Sam Hocevar's avatar
 
Sam Hocevar committed
334 335
    free( pp_packets );

Sam Hocevar's avatar
 
Sam Hocevar committed
336
    if( p_input->b_error || p_input->b_eof )
337 338 339
    {
        ErrorThread( p_input );
    }
340

341
    EndThread( p_input );
Sam Hocevar's avatar
 
Sam Hocevar committed
342 343 344

    DestroyThread( p_input );

Sam Hocevar's avatar
 
Sam Hocevar committed
345
    intf_DbgMsg("input: Thread end");
346 347
}

348
/*****************************************************************************
Sam Hocevar's avatar
 
Sam Hocevar committed
349
 * InitThread: init the input Thread
350
 *****************************************************************************/
Sam Hocevar's avatar
 
Sam Hocevar committed
351
static int InitThread( input_thread_t * p_input )
Michel Kaempf's avatar
Michel Kaempf committed
352 353 354
{

#ifdef STATS
355 356 357 358 359 360
    /* Initialize statistics */
    p_input->c_loops                    = 0;
    p_input->c_bytes                    = 0;
    p_input->c_payload_bytes            = 0;
    p_input->c_packets_read             = 0;
    p_input->c_packets_trashed          = 0;
Michel Kaempf's avatar
Michel Kaempf committed
361
#endif
362

Sam Hocevar's avatar
 
Sam Hocevar committed
363 364 365 366
    /* Default, might get overwritten */
    p_input->pf_open = p_input->pf_file_open;
    p_input->pf_close = p_input->pf_file_close;

Sam Hocevar's avatar
 
Sam Hocevar committed
367
    p_input->p_input_module = module_Need( MODULE_CAPABILITY_INPUT,
Sam Hocevar's avatar
 
Sam Hocevar committed
368
                                           (probedata_t *)p_input );
Sam Hocevar's avatar
 
Sam Hocevar committed
369 370

    if( p_input->p_input_module == NULL )
371
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
372 373
        intf_ErrMsg( "input error: no suitable input module for `%s'",
                     p_input->p_source );
Sam Hocevar's avatar
 
Sam Hocevar committed
374
        return( -1 );
Michel Kaempf's avatar
Michel Kaempf committed
375
    }
376

Sam Hocevar's avatar
 
Sam Hocevar committed
377 378
#define f p_input->p_input_module->p_functions->input.functions.input
    p_input->pf_init          = f.pf_init;
Sam Hocevar's avatar
 
Sam Hocevar committed
379 380 381 382 383 384 385 386
    if( f.pf_open != NULL )
    {
        p_input->pf_open          = f.pf_open;
    }
    if( f.pf_close != NULL )
    {
        p_input->pf_close         = f.pf_close;
    }
Sam Hocevar's avatar
 
Sam Hocevar committed
387 388
    p_input->pf_end           = f.pf_end;
    p_input->pf_read          = f.pf_read;
389
    p_input->pf_set_area      = f.pf_set_area;
Sam Hocevar's avatar
 
Sam Hocevar committed
390 391 392 393 394 395 396 397 398
    p_input->pf_demux         = f.pf_demux;
    p_input->pf_new_packet    = f.pf_new_packet;
    p_input->pf_new_pes       = f.pf_new_pes;
    p_input->pf_delete_packet = f.pf_delete_packet;
    p_input->pf_delete_pes    = f.pf_delete_pes;
    p_input->pf_rewind        = f.pf_rewind;
    p_input->pf_seek          = f.pf_seek;
#undef f
    p_input->pf_open( p_input );
399

Sam Hocevar's avatar
 
Sam Hocevar committed
400
    if( p_input->b_error )
401
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
402 403
        /* We barfed -- exit nicely */
        p_input->pf_close( p_input );
Sam Hocevar's avatar
 
Sam Hocevar committed
404
        module_Unneed( p_input->p_input_module );
Sam Hocevar's avatar
 
Sam Hocevar committed
405
        return( -1 );
406
    }
Sam Hocevar's avatar
 
Sam Hocevar committed
407 408

    p_input->pf_init( p_input );
Sam Hocevar's avatar
 
Sam Hocevar committed
409

410 411 412 413
    if( p_input->b_error )
    {
        /* We barfed -- exit nicely */
        p_input->pf_close( p_input );
Sam Hocevar's avatar
 
Sam Hocevar committed
414
        module_Unneed( p_input->p_input_module );
415 416 417
        return( -1 );
    }

Sam Hocevar's avatar
 
Sam Hocevar committed
418
    *p_input->pi_status = THREAD_READY;
Sam Hocevar's avatar
 
Sam Hocevar committed
419 420

    return( 0 );
Michel Kaempf's avatar
Michel Kaempf committed
421 422
}

423
/*****************************************************************************
424
 * ErrorThread: RunThread() error loop
425
 *****************************************************************************
426
 * This function is called when an error occured during thread main's loop.
427
 *****************************************************************************/
428
static void ErrorThread( input_thread_t *p_input )
Michel Kaempf's avatar
Michel Kaempf committed
429
{
430
    while( !p_input->b_die )
Michel Kaempf's avatar
Michel Kaempf committed
431
    {
432 433
        /* Sleep a while */
        msleep( INPUT_IDLE_SLEEP );
Michel Kaempf's avatar
Michel Kaempf committed
434 435 436
    }
}

437
/*****************************************************************************
438
 * EndThread: end the input thread
439
 *****************************************************************************/
440
static void EndThread( input_thread_t * p_input )
441
{
442
    int *       pi_status;                                  /* thread status */
443

444 445 446
    /* Store status */
    pi_status = p_input->pi_status;
    *pi_status = THREAD_END;
447

Sam Hocevar's avatar
 
Sam Hocevar committed
448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463
#ifdef STATS
    {
        struct tms cpu_usage;
        times( &cpu_usage );

        intf_Msg("input stats: cpu usage (user: %d, system: %d)",
                 cpu_usage.tms_utime, cpu_usage.tms_stime);
    }
#endif

    /* Free all ES and destroy all decoder threads */
    input_EndStream( p_input );

    /* Free demultiplexer's data */
    p_input->pf_end( p_input );

Sam Hocevar's avatar
 
Sam Hocevar committed
464 465 466
    /* Close stream */
    p_input->pf_close( p_input );

Sam Hocevar's avatar
 
Sam Hocevar committed
467
    /* Release modules */
Sam Hocevar's avatar
 
Sam Hocevar committed
468
    module_Unneed( p_input->p_input_module );
Sam Hocevar's avatar
 
Sam Hocevar committed
469

Sam Hocevar's avatar
 
Sam Hocevar committed
470 471 472 473 474 475 476 477 478 479 480
}

/*****************************************************************************
 * DestroyThread: destroy the input thread
 *****************************************************************************/
static void DestroyThread( input_thread_t * p_input )
{
    int *       pi_status;                                  /* thread status */

    /* Store status */
    pi_status = p_input->pi_status;
Sam Hocevar's avatar
 
Sam Hocevar committed
481

Henri Fallon's avatar
 
Henri Fallon committed
482 483
    /* Destroy Mutex locks */
    vlc_mutex_destroy( &p_input->stream.control.control_lock );
Henri Fallon's avatar
 
Henri Fallon committed
484
    vlc_mutex_destroy( &p_input->stream.stream_lock );
Henri Fallon's avatar
 
Henri Fallon committed
485
    
486
    /* Free input structure */
487
    free( p_input );
488

489 490
    /* Update status */
    *pi_status = THREAD_OVER;
491
}
492

493
/*****************************************************************************
Sam Hocevar's avatar
 
Sam Hocevar committed
494
 * FileOpen : open a file descriptor
495
 *****************************************************************************/
Sam Hocevar's avatar
 
Sam Hocevar committed
496
static void FileOpen( input_thread_t * p_input )
Michel Kaempf's avatar
Michel Kaempf committed
497
{
498
    struct stat         stat_info;
Sam Hocevar's avatar
 
Sam Hocevar committed
499 500
    int                 i_stat;

Sam Hocevar's avatar
 
Sam Hocevar committed
501 502 503 504
#if defined( WIN32 )
    char buf[7] = { 0 };
#endif

Sam Hocevar's avatar
 
Sam Hocevar committed
505
    char *psz_name = p_input->p_source;
Michel Kaempf's avatar
Michel Kaempf committed
506

Sam Hocevar's avatar
 
Sam Hocevar committed
507 508 509
    /* FIXME: this code ought to be in the plugin so that code can
     * be shared with the *_Probe function */
    if( ( i_stat = stat( psz_name, &stat_info ) ) == (-1) )
Sam Hocevar's avatar
 
Sam Hocevar committed
510
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
511 512 513 514 515 516 517 518
        int i_size = strlen( psz_name );

        if( ( i_size > 4 )
            && !strncasecmp( psz_name, "dvd:", 4 ) )
        {
            /* get rid of the 'dvd:' stuff and try again */
            psz_name += 4;
            i_stat = stat( psz_name, &stat_info );
Sam Hocevar's avatar
 
Sam Hocevar committed
519 520 521
#if defined( WIN32 )
            snprintf( buf, 7, "\\\\.\\%c:", psz_name[0] );
#endif
Henri Fallon's avatar
 
Henri Fallon committed
522
        }
Sam Hocevar's avatar
 
Sam Hocevar committed
523
        else if( ( i_size > 5 )
Sam Hocevar's avatar
 
Sam Hocevar committed
524 525 526 527 528
                 && !strncasecmp( psz_name, "file:", 5 ) )
        {
            /* get rid of the 'file:' stuff and try again */
            psz_name += 5;
            i_stat = stat( psz_name, &stat_info );
Henri Fallon's avatar
 
Henri Fallon committed
529
        }
Sam Hocevar's avatar
 
Sam Hocevar committed
530

Sam Hocevar's avatar
 
Sam Hocevar committed
531 532 533 534 535
        if( i_stat == (-1) 
#if defined( WIN32 )
        && !buf[0]      
#endif
            )
Sam Hocevar's avatar
 
Sam Hocevar committed
536 537 538 539 540 541
        {
            intf_ErrMsg( "input error: cannot stat() file `%s' (%s)",
                         psz_name, strerror(errno));
            p_input->b_error = 1;
            return;
        }
Sam Hocevar's avatar
 
Sam Hocevar committed
542 543 544 545 546 547 548 549
    }

    vlc_mutex_lock( &p_input->stream.stream_lock );

    /* If we are here we can control the pace... */
    p_input->stream.b_pace_control = 1;

    if( S_ISREG(stat_info.st_mode) || S_ISCHR(stat_info.st_mode)
Sam Hocevar's avatar
 
Sam Hocevar committed
550 551 552 553 554
         || S_ISBLK(stat_info.st_mode)
#if defined( WIN32 )
         || ( buf[0] && ( ( stat_info.st_size = 0 ) == 0 ) )
#endif
         )
Sam Hocevar's avatar
 
Sam Hocevar committed
555 556
    {
        p_input->stream.b_seekable = 1;
557
        p_input->stream.p_selected_area->i_size = stat_info.st_size;
Sam Hocevar's avatar
 
Sam Hocevar committed
558
    }
Jean-Marc Dressler's avatar
 
Jean-Marc Dressler committed
559
    else if( S_ISFIFO(stat_info.st_mode)
Sam Hocevar's avatar
 
Sam Hocevar committed
560
#if !defined( SYS_BEOS ) && !defined( WIN32 )
Jean-Marc Dressler's avatar
 
Jean-Marc Dressler committed
561 562 563
             || S_ISSOCK(stat_info.st_mode)
#endif
             )
564
    {
565
        p_input->stream.b_seekable = 0;
566
        p_input->stream.p_selected_area->i_size = 0;
Benoit Steiner's avatar
 
Benoit Steiner committed
567 568 569
    }
    else
    {
570
        vlc_mutex_unlock( &p_input->stream.stream_lock );
Sam Hocevar's avatar
 
Sam Hocevar committed
571
        intf_ErrMsg( "input error: unknown file type for `%s'",
Sam Hocevar's avatar
 
Sam Hocevar committed
572
                     psz_name );
Sam Hocevar's avatar
 
Sam Hocevar committed
573 574 575
        p_input->b_error = 1;
        return;
    }
576

577
    p_input->stream.p_selected_area->i_tell = 0;
Sam Hocevar's avatar
 
Sam Hocevar committed
578 579
    vlc_mutex_unlock( &p_input->stream.stream_lock );

580
    intf_WarnMsg( 1, "input: opening file `%s'", p_input->p_source );
Sam Hocevar's avatar
 
Sam Hocevar committed
581
#ifndef WIN32
Sam Hocevar's avatar
 
Sam Hocevar committed
582
    if( (p_input->i_handle = open( psz_name,
Sam Hocevar's avatar
 
Sam Hocevar committed
583
                                   /*O_NONBLOCK | O_LARGEFILE*/0 )) == (-1) )
Sam Hocevar's avatar
 
Sam Hocevar committed
584
#else
Sam Hocevar's avatar
 
Sam Hocevar committed
585 586 587 588
    if( ( buf[0] && ( (HANDLE) p_input->i_handle = CreateFile( buf, 
        GENERIC_READ | GENERIC_WRITE, FILE_SHARE_READ | FILE_SHARE_WRITE, 
        NULL, OPEN_EXISTING, 0, NULL ) ) == INVALID_HANDLE_VALUE ) ||
        ( !buf[0] && (p_input->i_handle = open( psz_name, O_BINARY ) ) == (-1) ) )
Sam Hocevar's avatar
 
Sam Hocevar committed
589
#endif
Sam Hocevar's avatar
 
Sam Hocevar committed
590
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
591
        intf_ErrMsg( "input error: cannot open file (%s)", strerror(errno) );
Sam Hocevar's avatar
 
Sam Hocevar committed
592 593
        p_input->b_error = 1;
        return;
Michel Kaempf's avatar
Michel Kaempf committed
594 595 596
    }

}
Stéphane Borel's avatar
Stéphane Borel committed
597 598

/*****************************************************************************
Sam Hocevar's avatar
 
Sam Hocevar committed
599
 * FileClose : close a file descriptor
Stéphane Borel's avatar
Stéphane Borel committed
600
 *****************************************************************************/
Sam Hocevar's avatar
 
Sam Hocevar committed
601
static void FileClose( input_thread_t * p_input )
Stéphane Borel's avatar
Stéphane Borel committed
602
{
603
    intf_WarnMsg( 1, "input: closing file `%s'", p_input->p_source );
Sam Hocevar's avatar
 
Sam Hocevar committed
604 605 606 607 608 609 610 611
#if defined( WIN32 )
    if( ( strlen( p_input->p_source ) > 4 ) &&
        !strncasecmp( p_input->p_source, "dvd:", 4 ) )
    {
        CloseHandle( (HANDLE) p_input->i_handle );
    }
    else
#endif
Sam Hocevar's avatar
 
Sam Hocevar committed
612
    close( p_input->i_handle );
Stéphane Borel's avatar
Stéphane Borel committed
613

Sam Hocevar's avatar
 
Sam Hocevar committed
614
    return;
Stéphane Borel's avatar
Stéphane Borel committed
615
}
Sam Hocevar's avatar
 
Sam Hocevar committed
616

Henri Fallon's avatar
 
Henri Fallon committed
617

618
#if !defined( SYS_BEOS ) && !defined( SYS_NTO )
Henri Fallon's avatar
 
Henri Fallon committed
619
/*****************************************************************************
Sam Hocevar's avatar
 
Sam Hocevar committed
620
 * NetworkOpen : open a network socket 
Henri Fallon's avatar
 
Henri Fallon committed
621
 *****************************************************************************/
Sam Hocevar's avatar
 
Sam Hocevar committed
622
static void NetworkOpen( input_thread_t * p_input )
Henri Fallon's avatar
 
Henri Fallon committed
623
{
Henri Fallon's avatar
 
Henri Fallon committed
624
    char                *psz_server = NULL;
625
    char                *psz_broadcast = NULL;
Henri Fallon's avatar
 
Henri Fallon committed
626
    int                 i_port = 0;
Sam Hocevar's avatar
 
Sam Hocevar committed
627 628
    int                 i_opt;
    struct sockaddr_in  sock;
629

Sam Hocevar's avatar
 
Sam Hocevar committed
630 631 632 633 634 635 636 637 638 639 640
#ifdef WIN32
    /* WinSock Library Init. */
    WSADATA Data;
    int i_err = WSAStartup( MAKEWORD( 1, 1 ), &Data );

    if( i_err )
    {
        intf_ErrMsg( "input: can't initiate WinSocks, error %i", i_err );
        return ;
    }
#endif
Henri Fallon's avatar
 
Henri Fallon committed
641 642
    
    /* Get the remote server */
Sam Hocevar's avatar
 
Sam Hocevar committed
643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676
    if( p_input->p_source != NULL )
    {
        psz_server = p_input->p_source;

        /* Skip the protocol name */
        while( *psz_server && *psz_server != ':' )
        {
            psz_server++;
        }

        /* Skip the "://" part */
        while( *psz_server && (*psz_server == ':' || *psz_server == '/') )
        {
            psz_server++;
        }

        /* Found a server name */
        if( *psz_server )
        {
            char *psz_port = psz_server;

            /* Skip the hostname part */
            while( *psz_port && *psz_port != ':' )
            {
                psz_port++;
            }

            /* Found a port name */
            if( *psz_port )
            {
                /* Replace ':' with '\0' */
                *psz_port = '\0';
                psz_port++;

677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701
                psz_broadcast = psz_port;
                while( *psz_broadcast && *psz_broadcast != ':' )
                {
                    psz_broadcast++;
                }

                if( *psz_broadcast )
                {
                    *psz_broadcast = '\0';
                    psz_broadcast++;
                    while( *psz_broadcast && *psz_broadcast == ':' )
                    {
                        psz_broadcast++;
                    }
                }
                else
                {
                    psz_broadcast = NULL;
                }

                /* port before broadcast address */
                if( *psz_port != ':' )
                {
                    i_port = atoi( psz_port );
                }
Sam Hocevar's avatar
 
Sam Hocevar committed
702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718
            }
        }
        else
        {
            psz_server = NULL;
        }
    }

    /* Check that we got a valid server */
    if( psz_server == NULL )
    {
        psz_server = main_GetPszVariable( INPUT_SERVER_VAR, 
                                          INPUT_SERVER_DEFAULT );
    }

    /* Check that we got a valid port */
    if( i_port == 0 )
Henri Fallon's avatar
 
Henri Fallon committed
719
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
720
        i_port = main_GetIntVariable( INPUT_PORT_VAR, INPUT_PORT_DEFAULT );
Henri Fallon's avatar
 
Henri Fallon committed
721
    }
722 723 724 725

    if( psz_broadcast == NULL )
    {
        /* Are we broadcasting ? */
726 727 728 729 730 731 732 733 734 735
        if( main_GetIntVariable( INPUT_BROADCAST_VAR,
                                 INPUT_BROADCAST_DEFAULT ) )
        {
            psz_broadcast = main_GetPszVariable( INPUT_BCAST_ADDR_VAR,
                                                 INPUT_BCAST_ADDR_DEFAULT );
        }
        else
        {
           psz_broadcast = NULL; 
        }
736 737 738 739 740
    }

    intf_WarnMsg( 2, "input: server: %s port: %d broadcast: %s",
                     psz_server, i_port, psz_broadcast );

Henri Fallon's avatar
 
Henri Fallon committed
741 742 743 744 745
    /* Open a SOCK_DGRAM (UDP) socket, in the AF_INET domain, automatic (0)
     * protocol */
    p_input->i_handle = socket( AF_INET, SOCK_DGRAM, 0 );
    if( p_input->i_handle == -1 )
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
746
        intf_ErrMsg("input error: can't create socket : %s", strerror(errno));
Henri Fallon's avatar
 
Henri Fallon committed
747 748 749 750 751
        p_input->b_error = 1;
        return;
    }

    /* We may want to reuse an already used socket */
Sam Hocevar's avatar
 
Sam Hocevar committed
752
    i_opt = 1;
Henri Fallon's avatar
 
Henri Fallon committed
753
    if( setsockopt( p_input->i_handle, SOL_SOCKET, SO_REUSEADDR,
Sam Hocevar's avatar
 
Sam Hocevar committed
754
                    (void*) &i_opt, sizeof( i_opt ) ) == -1 )
Henri Fallon's avatar
 
Henri Fallon committed
755
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
756 757
        intf_ErrMsg( "input error: can't configure socket (SO_REUSEADDR: %s)",
                     strerror(errno));
Henri Fallon's avatar
 
Henri Fallon committed
758 759 760 761 762 763 764
        close( p_input->i_handle );
        p_input->b_error = 1;
        return;
    }

    /* Increase the receive buffer size to 1/2MB (8Mb/s during 1/2s) to avoid
     * packet loss caused by scheduling problems */
Sam Hocevar's avatar
 
Sam Hocevar committed
765 766
    i_opt = 0x80000;
    if( setsockopt( p_input->i_handle, SOL_SOCKET, SO_RCVBUF,
Sam Hocevar's avatar
 
Sam Hocevar committed
767
                    (void*) &i_opt, sizeof( i_opt ) ) == -1 )
Henri Fallon's avatar
 
Henri Fallon committed
768
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
769 770
        intf_ErrMsg( "input error: can't configure socket (SO_RCVBUF: %s)", 
                     strerror(errno));
Henri Fallon's avatar
 
Henri Fallon committed
771 772 773 774 775 776
        close( p_input->i_handle );
        p_input->b_error = 1;
        return;
    }

    /* Build the local socket */
Sam Hocevar's avatar
 
Sam Hocevar committed
777
    if ( network_BuildLocalAddr( &sock, i_port, psz_broadcast ) == -1 )
Henri Fallon's avatar
 
Henri Fallon committed
778
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
779
        intf_ErrMsg( "input error: can't build local address" );
Henri Fallon's avatar
 
Henri Fallon committed
780 781 782 783 784 785
        close( p_input->i_handle );
        p_input->b_error = 1;
        return;
    }
    
    /* Bind it */
Sam Hocevar's avatar
 
Sam Hocevar committed
786 787
    if( bind( p_input->i_handle, (struct sockaddr *)&sock, 
              sizeof( sock ) ) < 0 )
Henri Fallon's avatar
 
Henri Fallon committed
788
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
789
        intf_ErrMsg("input error: can't bind socket (%s)", strerror(errno));
Henri Fallon's avatar
 
Henri Fallon committed
790 791 792 793 794 795
        close( p_input->i_handle );
        p_input->b_error = 1;
        return;
    }

    /* Build socket for remote connection */
Sam Hocevar's avatar
 
Sam Hocevar committed
796
    if ( network_BuildRemoteAddr( &sock, psz_server ) == -1 )
Henri Fallon's avatar
 
Henri Fallon committed
797
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
798
        intf_ErrMsg( "input error: can't build remote address" );
Henri Fallon's avatar
 
Henri Fallon committed
799 800 801 802 803 804
        close( p_input->i_handle );
        p_input->b_error = 1;
        return;
    }

    /* And connect it ... should we really connect ? */
Sam Hocevar's avatar
 
Sam Hocevar committed
805 806
    if( connect( p_input->i_handle, (struct sockaddr *) &sock,
                 sizeof( sock ) ) == (-1) )
Henri Fallon's avatar
 
Henri Fallon committed
807
    {
Sam Hocevar's avatar
 
Sam Hocevar committed
808
        intf_ErrMsg( "input error: can't connect socket, %s", 
Henri Fallon's avatar
 
Henri Fallon committed
809
                     strerror(errno) );
Henri Fallon's avatar
 
Henri Fallon committed
810 811 812 813 814 815 816
        close( p_input->i_handle );
        p_input->b_error = 1;
        return;
    }

    /* We can't pace control, but FIXME : bug in meuuh's code to sync PCR
     * with the server. */
Henri Fallon's avatar
 
Henri Fallon committed
817
    p_input->stream.b_pace_control = 0;
Sam Hocevar's avatar
 
Sam Hocevar committed
818
    p_input->stream.b_seekable = 0;
Sam Hocevar's avatar
 
Sam Hocevar committed
819 820

    intf_WarnMsg( 3, "input: successfully opened network mode" );
Henri Fallon's avatar
 
Henri Fallon committed
821 822 823 824 825
    
    return;
}

/*****************************************************************************
Sam Hocevar's avatar
 
Sam Hocevar committed
826
 * NetworkClose : close a network socket
Henri Fallon's avatar
 
Henri Fallon committed
827
 *****************************************************************************/
Sam Hocevar's avatar
 
Sam Hocevar committed
828
static void NetworkClose( input_thread_t * p_input )
Henri Fallon's avatar
 
Henri Fallon committed
829 830
{
    close( p_input->i_handle );
831

Sam Hocevar's avatar
 
Sam Hocevar committed
832 833 834
#ifdef WIN32 
    WSACleanup();
#endif
835

Henri Fallon's avatar
 
Henri Fallon committed
836
}
Sam Hocevar's avatar
 
Sam Hocevar committed
837
#endif
Sam Hocevar's avatar
 
Sam Hocevar committed
838