Commit acbd88f2 authored by Sam Hocevar's avatar Sam Hocevar

. input fichier en ligne de commande (le reste a du p�ter, c'est pas

   possible autrement)
parent fe175c11
...@@ -20,3 +20,5 @@ ...@@ -20,3 +20,5 @@
Renaud Dartus <reno@via.ecp.fr> Renaud Dartus <reno@via.ecp.fr>
Henri Fallon <henri@via.ecp.fr> Henri Fallon <henri@via.ecp.fr>
Contributors include Aaron Holtzman for his ac3dec decoder, and the
LiViD team for a few lines of code we borrowed here and there.
...@@ -281,14 +281,15 @@ clean: ...@@ -281,14 +281,15 @@ clean:
rm -f $(C_OBJ) $(CPP_OBJ) $(ASM_OBJ) $(PLUGIN_OBJ) rm -f $(C_OBJ) $(CPP_OBJ) $(ASM_OBJ) $(PLUGIN_OBJ)
distclean: clean distclean: clean
rm -f **/*.o **/*.so **/*~ *.log rm -f */*/*.o plugins/*/*.so **/*~ *.log
rm -f Makefile include/defs.h include/config.h rm -f Makefile include/defs.h include/config.h
rm -f config.status config.cache config.log rm -f config.status config.cache config.log
rm -f vlc gmon.out core rm -f vlc gvlc gmon.out core
rm -rf .dep rm -rf .dep
install: install:
$(INSTALL) vlc $(prefix)/bin $(INSTALL) vlc $(prefix)/bin
$(INSTALL) gvlc $(prefix)/bin
mkdir -p $(prefix)/lib/videolan/vlc mkdir -p $(prefix)/lib/videolan/vlc
$(INSTALL) $(PLUGIN_OBJ) $(prefix)/lib/videolan/vlc $(INSTALL) $(PLUGIN_OBJ) $(prefix)/lib/videolan/vlc
$(INSTALL) share/*.psf $(prefix)/share/videolan/vlc $(INSTALL) share/*.psf $(prefix)/share/videolan/vlc
......
...@@ -19,8 +19,9 @@ ...@@ -19,8 +19,9 @@
vlc \- The VideoLAN Client vlc \- The VideoLAN Client
.SH SYNOPSIS .SH SYNOPSIS
.B vlc .B vlc
.RI [ options ] .RI [ OPTIONS ]
.RI [ parameters ] .RI [ PARAMETERS ]
.RI [ FILE ]...
.SH DESCRIPTION .SH DESCRIPTION
This manual page documents briefly the This manual page documents briefly the
.B vlc .B vlc
...@@ -58,6 +59,19 @@ Grayscale output. ...@@ -58,6 +59,19 @@ Grayscale output.
.B \-\-color .B \-\-color
Color output. Color output.
.TP .TP
.B \-a, \-\-dvdaudio [ ac3 | lpcm | mpeg | off ]
Choose the audio channel type. Most DVDs have AC3 audio channels, but
you can also have Linear PCM or MPEG layer 2 sound. Also, one might decide
not to activate the audio channel.
.TP
.B \-c, \-\-dvdchannel [ 0\-15 ]
Select the audio channel. Most DVDs only have one or two audio channels,
but some of them have a great number of available languages. Note that the
audio channel will also depend on the channel type.
.TP
.B \-s, \-\-dvdsubtitle [ 0\-31 ]
Select the subtitle channel, if there is one in the stream.
.TP
.B \-\-novlans .B \-\-novlans
Disable VLANs support. Disable VLANs support.
.TP .TP
...@@ -94,6 +108,11 @@ also accepts a lot of parameters to customize its behaviour. ...@@ -94,6 +108,11 @@ also accepts a lot of parameters to customize its behaviour.
vlc_fb_dev=<filename> framebuffer device path vlc_fb_dev=<filename> framebuffer device path
vlc_grayscale={1|0} grayscale or color output vlc_grayscale={1|0} grayscale or color output
.TP .TP
.B DVD parameters:
vlc_dvd_audio={ac3|lpcm|mpeg|off} audio type
vlc_dvd_channel=[0-15] audio channel
vlc_dvd_subtitle=[0-31] subtitle channel
.TP
.B Input parameters: .B Input parameters:
vlc_server=<hostname> video server vlc_server=<hostname> video server
vlc_server_port=<port> video server port vlc_server_port=<port> video server port
......
...@@ -227,6 +227,10 @@ ...@@ -227,6 +227,10 @@
* mark it to be presented */ * mark it to be presented */
#define INPUT_PTS_DELAY (2*CLOCK_FREQ) #define INPUT_PTS_DELAY (2*CLOCK_FREQ)
#define INPUT_DVD_AUDIO_VAR "vlc_dvd_audio"
#define INPUT_DVD_CHANNEL_VAR "vlc_dvd_channel"
#define INPUT_DVD_SUBTITLE_VAR "vlc_dvd_subtitle"
/***************************************************************************** /*****************************************************************************
* Audio configuration * Audio configuration
*****************************************************************************/ *****************************************************************************/
......
...@@ -328,7 +328,7 @@ typedef struct input_thread_s ...@@ -328,7 +328,7 @@ typedef struct input_thread_s
/* Input method description */ /* Input method description */
int i_method; /* input method */ int i_method; /* input method */
int i_handle; /* file/socket descriptor */ int i_handle; /* file/socket descriptor */
char * psz_source; /* source */ char * p_source; /* source */
int i_port; /* port number */ int i_port; /* port number */
int i_vlan; /* id for vlan method */ int i_vlan; /* id for vlan method */
input_open_t * p_Open; /* opener of the method */ input_open_t * p_Open; /* opener of the method */
...@@ -371,7 +371,7 @@ typedef struct input_thread_s ...@@ -371,7 +371,7 @@ typedef struct input_thread_s
/***************************************************************************** /*****************************************************************************
* Prototypes * Prototypes
*****************************************************************************/ *****************************************************************************/
input_thread_t *input_CreateThread ( int i_method, char *psz_source, int i_port, input_thread_t *input_CreateThread ( int i_method, void *p_source, int i_port,
int i_vlan, p_vout_thread_t p_vout, int i_vlan, p_vout_thread_t p_vout,
p_aout_thread_t p_aout, int *pi_status ); p_aout_thread_t p_aout, int *pi_status );
void input_DestroyThread ( input_thread_t *p_input, int *pi_status ); void input_DestroyThread ( input_thread_t *p_input, int *pi_status );
......
...@@ -64,6 +64,10 @@ typedef struct intf_thread_s ...@@ -64,6 +64,10 @@ typedef struct intf_thread_s
/* XXX: Channels array - new API */ /* XXX: Channels array - new API */
//p_intf_channel_t * p_channel[INTF_MAX_CHANNELS];/* channel descriptions */ //p_intf_channel_t * p_channel[INTF_MAX_CHANNELS];/* channel descriptions */
/* file list - quick hack */
char **p_playlist;
int i_list_index;
/* Channels array - NULL if not used */ /* Channels array - NULL if not used */
p_intf_channel_t p_channel; /* description of channels */ p_intf_channel_t p_channel; /* description of channels */
......
...@@ -108,7 +108,7 @@ static __inline__ void input_DemuxPSI( input_thread_t *p_input, ...@@ -108,7 +108,7 @@ static __inline__ void input_DemuxPSI( input_thread_t *p_input,
* If pi_status is NULL, then the function will block until the thread is ready. * 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. * If not, it will be updated using one of the THREAD_* constants.
*****************************************************************************/ *****************************************************************************/
input_thread_t *input_CreateThread ( int i_method, char *psz_source, int i_port, int i_vlan, input_thread_t *input_CreateThread ( int i_method, void *p_source, int i_port, int i_vlan,
p_vout_thread_t p_vout, p_aout_thread_t p_aout, int *pi_status ) p_vout_thread_t p_vout, p_aout_thread_t p_aout, int *pi_status )
{ {
input_thread_t * p_input; /* thread descriptor */ input_thread_t * p_input; /* thread descriptor */
...@@ -132,7 +132,7 @@ input_thread_t *input_CreateThread ( int i_method, char *psz_source, int i_port, ...@@ -132,7 +132,7 @@ input_thread_t *input_CreateThread ( int i_method, char *psz_source, int i_port,
/* Initialize input method description */ /* Initialize input method description */
p_input->i_method = i_method; p_input->i_method = i_method;
p_input->psz_source = psz_source; p_input->p_source = p_source;
p_input->i_port = i_port; p_input->i_port = i_port;
p_input->i_vlan = i_vlan; p_input->i_vlan = i_vlan;
switch( i_method ) switch( i_method )
...@@ -208,7 +208,7 @@ input_thread_t *input_CreateThread ( int i_method, char *psz_source, int i_port, ...@@ -208,7 +208,7 @@ input_thread_t *input_CreateThread ( int i_method, char *psz_source, int i_port,
} }
intf_DbgMsg("configuration: method=%d, source=%s, port=%d, vlan=%d\n", intf_DbgMsg("configuration: method=%d, source=%s, port=%d, vlan=%d\n",
i_method, psz_source, i_port, i_vlan ); i_method, p_source, i_port, i_vlan );
/* Let the appropriate method open the socket. */ /* Let the appropriate method open the socket. */
if( p_input->p_Open( p_input ) ) if( p_input->p_Open( p_input ) )
......
...@@ -35,13 +35,14 @@ ...@@ -35,13 +35,14 @@
#include <malloc.h> /* malloc, read ... */ #include <malloc.h> /* malloc, read ... */
#include <string.h> #include <string.h>
#include "config.h" #include "config.h"
#include "common.h" #include "common.h"
#include "threads.h" #include "threads.h"
#include "mtime.h" #include "mtime.h"
#include "intf_msg.h" #include "intf_msg.h"
#include "main.h"
#include "input.h" #include "input.h"
#include "input_file.h" #include "input_file.h"
...@@ -53,13 +54,23 @@ ...@@ -53,13 +54,23 @@
#define TS_PACKET_SIZE 188 #define TS_PACKET_SIZE 188
#define TS_IN_UDP 7 #define TS_IN_UDP 7
#define MAX_AUDIO_CHANNEL 15
#define MAX_SUBTITLES_CHANNEL 31
#define NO_SUBTITLES 255
#define REQUESTED_AC3 0
#define REQUESTED_MPEG 1
#define REQUESTED_LPCM 2
#define REQUESTED_NOAUDIO 255
#define PS_BUFFER_SIZE 16384 #define PS_BUFFER_SIZE 16384
#define NO_PES 0 #define NO_PES 0
#define AUDIO_PES 1 #define AUDIO_PES 1
#define VIDEO_PES 2 #define VIDEO_PES 2
#define AC3_PES 3 #define AC3_PES 3
#define SUBTITLE_PES 4 #define SUBTITLE_PES 4
#define PRIVATE_PES 5 #define LPCM_PES 5
#define PRIVATE_PES 6
#define UNKNOWN_PES 12 #define UNKNOWN_PES 12
#define PCR_PID 0x20 /* 0x20 == first video stream #define PCR_PID 0x20 /* 0x20 == first video stream
...@@ -98,12 +109,23 @@ typedef struct options_s ...@@ -98,12 +109,23 @@ typedef struct options_s
unsigned int pcr_pid; unsigned int pcr_pid;
u8 i_file_type; u8 i_file_type;
int in; int in;
char **playlist;
int i_list_index;
} options_t; } options_t;
typedef struct s_ps typedef struct s_ps
{ {
unsigned int pat_counter; unsigned int pat_counter;
unsigned int pmt_counter; unsigned int pmt_counter;
/*
* These 3 parameters are passed
* as command line arguments
*/
unsigned int audio_channel;
unsigned int subtitles_channel;
unsigned int audio_type;
/* /*
* 16 audio mpeg streams * 16 audio mpeg streams
* 16 audio AV3 streams * 16 audio AV3 streams
...@@ -149,7 +171,7 @@ typedef struct input_file_s ...@@ -149,7 +171,7 @@ typedef struct input_file_s
/* local prototypes */ /* local prototypes */
void ps_fill( input_file_t * p_if, boolean_t wait ); void ps_fill( input_file_t * p_if, boolean_t wait );
ssize_t safe_read(int fd, unsigned char *buf, int count); ssize_t safe_read(options_t *p_options, unsigned char *buf, int count);
void input_DiskThread( input_file_t * p_if ); void input_DiskThread( input_file_t * p_if );
int init_synchro( input_file_t * p_if ); int init_synchro( input_file_t * p_if );
...@@ -255,21 +277,63 @@ static void adjust( input_file_t * p_if, file_ts_packet *ts ) ...@@ -255,21 +277,63 @@ static void adjust( input_file_t * p_if, file_ts_packet *ts )
vlc_mutex_unlock(&p_own_pcr->lock); vlc_mutex_unlock(&p_own_pcr->lock);
} }
/****************************************************************************** /*****************************************************************************
* file_next : Opens the next available file
*****************************************************************************/
int file_next( options_t *options )
{
/* the check for index == 0 should be done _before_ */
options->i_list_index--;
if( options->in != -1 )
{
close( options->in );
}
if( !strcmp( options->playlist[options->i_list_index], "-" ) )
{
/* read stdin */
return ( options->in = 0 );
}
else
{
/* read the actual file */
fprintf( stderr, "Playing file %s\n",
options->playlist[options->i_list_index] );
return ( options->in = open( options->playlist[options->i_list_index],
O_RDONLY | O_NDELAY ) );
}
}
/*****************************************************************************
* safe_read : Buffered reading method * safe_read : Buffered reading method
******************************************************************************/ *****************************************************************************/
ssize_t safe_read(int fd, unsigned char *buf, int count) ssize_t safe_read( options_t *options, unsigned char *buf, int count )
{ {
int ret, cnt=0; int ret, cnt=0;
while(cnt < count) while( cnt < count )
{ {
ret = read(fd, buf+cnt, count-cnt); ret = read( options->in, buf + cnt, count - cnt );
if(ret < 0)
if( ret < 0 )
return ret; return ret;
if(ret == 0)
if( ret == 0 )
{
/* zero means end of file */
if( options->i_list_index )
{
file_next( options );
}
else
{
break; break;
}
}
cnt += ret; cnt += ret;
} }
...@@ -308,49 +372,52 @@ int keep_pcr(int pcr_pid, file_ts_packet *ts) ...@@ -308,49 +372,52 @@ int keep_pcr(int pcr_pid, file_ts_packet *ts)
int get_pid (ps_t *p_ps) int get_pid (ps_t *p_ps)
{ {
int i, tofind, delta; int i, tofind, delta;
char* type;
switch( p_ps->pes_type ) switch( p_ps->pes_type )
{ {
case VIDEO_PES: case VIDEO_PES:
delta = 0x20; delta = 0x20; /* 0x20 - 0x2f */
type = "MPEG video";
tofind = p_ps->pes_id; tofind = p_ps->pes_id;
break; break;
case AUDIO_PES: case AUDIO_PES:
delta = 0x40; delta = 0x40; /* 0x40 - 0x5f */
type = "MPEG audio";
tofind = p_ps->pes_id; tofind = p_ps->pes_id;
break; break;
case SUBTITLE_PES: /* XXX: 0x64 is for the PMT, so don't take it !!! */
delta = 0x60; case AC3_PES:
delta = 0x80; /* 0x80 - 0x8f */
type = "MPEG private (AC3 audio)";
tofind = p_ps->private_id; tofind = p_ps->private_id;
break; break;
case AC3_PES: case LPCM_PES:
delta = 0x80; delta = 0x90; /* 0x90 - 0x9f */
type = "MPEG private (LPCM audio)";
tofind = p_ps->private_id;
break;
case SUBTITLE_PES:
delta = 0xa0; /* 0xa0 - 0xbf */
type = "MPEG private (DVD subtitle)";
tofind = p_ps->private_id; tofind = p_ps->private_id;
break; break;
default: default:
return(-1); return(-1);
}
/* look in the table if we can find one */
for ( i=delta; i < delta + 0x20; i++ )
{
if ( p_ps->association_table[i] == tofind )
return (i);
if( !p_ps->association_table[i] )
break;
} }
/* we must allocate a new entry */ i = delta + (tofind & 0x1f);
if (i == delta + 0x20)
return(-1);
p_ps->association_table[i] = tofind; if( p_ps->association_table[i] == 0)
p_ps->media_counter[i] = 0; {
intf_Msg( "Found %s stream at 0x%.2x, allocating PID 0x%.2x\n",
intf_Msg( "input: allocated new PID 0x%.2x to stream ID 0x%.2x\n", i, tofind ); type, tofind, i );
p_ps->association_table[i] = 1;
}
return ( i ); return ( i );
} }
/****************************************************************************** /******************************************************************************
...@@ -528,34 +595,60 @@ void write_pmt(ps_t *ps, unsigned char *ts) ...@@ -528,34 +595,60 @@ void write_pmt(ps_t *ps, unsigned char *ts)
ts[17] = 0x02; /* stream type = video */ ts[17] = 0x02; /* stream type = video */
ts[18] = 0xe0; ts[19] = 0x20; ts[18] = 0xe0; ts[19] = 0x20;
ts[20] = 0xf0; ts[21] = 0x09; /* es info length */ ts[20] = 0xf0; ts[21] = 0x09; /* es info length */
/* useless info */ /* useless info */
ts[22] = 0x07; ts[23] = 0x04; ts[24] = 0x08; ts[25] = 0x80; ts[26] = 0x24; ts[22] = 0x07; ts[23] = 0x04; ts[24] = 0x08; ts[25] = 0x80; ts[26] = 0x24;
ts[27] = 0x02; ts[28] = 0x11; ts[29] = 0x01; ts[30] = 0xfe; ts[27] = 0x02; ts[28] = 0x11; ts[29] = 0x01; ts[30] = 0xfe;
/* Audio PID */ switch ( ps->audio_type )
ts[31] = 0x88; /* stream type = audio */ /* FIXME : was 0x04 */ {
ts[32] = 0xe0; ts[33] = 0x40; case 12 :
case REQUESTED_AC3 :
/* ac3 */
ts[31] = 0x81; /* stream type = audio */
ts[32] = 0xe0; ts[33] = 0x80 + ps->audio_channel;
ts[34] = 0xf0; ts[35] = 0x00; /* es info length */ ts[34] = 0xf0; ts[35] = 0x00; /* es info length */
break;
/* reserved PID */ case REQUESTED_MPEG :
#if 0 /* mpeg */
ts[36] = 0x82; /* stream type = private */ ts[31] = 0x04; /* stream type = audio */
ts[37] = 0xe0; ts[38] = 0x60; /* subtitles */ ts[32] = 0xe0; ts[33] = 0x40 + ps->audio_channel;
#else ts[34] = 0xf0; ts[35] = 0x00; /* es info length */
ts[36] = 0x81; /* stream type = private */ break;
ts[37] = 0xe0; ts[38] = 0x80; /* ac3 audio */
#endif
ts[39] = 0xf0; ts[40] = 0x0f; /* es info length */
/* useless info */
ts[41] = 0x90; ts[42] = 0x01; ts[43] = 0x85; ts[44] = 0x89; ts[45] = 0x04;
ts[46] = 0x54; ts[47] = 0x53; ts[48] = 0x49; ts[49] = 0x00; ts[50] = 0x0f;
ts[51] = 0x04; ts[52] = 0x00; ts[53] = 0x00; ts[54] = 0x00; ts[55] = 0x10;
/* CRC */ case REQUESTED_LPCM :
ts[56] = 0x96; ts[57] = 0x70; ts[58] = 0x0b; ts[59] = 0x7c; /* for video pts */ /* LPCM audio */
//ts[56] = 0xa1; ts[57] = 0x7c; ts[58] = 0xd8; ts[59] = 0xaa; /* for audio pts */ ts[31] = 0x81;
ts[32] = 0xe0; ts[33] = 0xa0 + ps->audio_channel;
ts[34] = 0xf0; ts[35] = 0x00; /* es info length */
break;
for (i=60 ; i < 188 ; i++) ts[i]=0xFF; /* facultatif ? */ default :
/* No audio */
ts[31] = 0x00;
ts[35] = 0x00; /* es info length */
}
/* Subtitles */
if( ps->subtitles_channel == NO_SUBTITLES )
{
ts[36] = 0x00;
ts[37] = 0x00; ts[38] = 0x00;
ts[39] = 0xf0; ts[40] = 0x00; /* es info length */
}
else
{
ts[36] = 0x82;
ts[37] = 0xe0; ts[38] = 0xa0 + ( ps->subtitles_channel );
ts[39] = 0xf0; ts[40] = 0x00; /* es info length */
}
/* CRC FIXME: not calculated yet*/
ts[41] = 0x96; ts[42] = 0x70; ts[43] = 0x0b; ts[44] = 0x7c;
/* stuffing bytes */
for (i=45 ; i < 188 ; i++) ts[i]=0xff; /* facultatif ? */
ps->sent_ts++; ps->sent_ts++;
} }
...@@ -584,6 +677,10 @@ void ps_thread( input_file_t * p_if ) ...@@ -584,6 +677,10 @@ void ps_thread( input_file_t * p_if )
vlc_cond_init( &p_in_data->notfull ); vlc_cond_init( &p_in_data->notfull );
vlc_cond_init( &p_in_data->notempty ); vlc_cond_init( &p_in_data->notempty );
p_ps->audio_type = main_GetIntVariable( INPUT_DVD_AUDIO_VAR, REQUESTED_AC3 );
p_ps->audio_channel = main_GetIntVariable( INPUT_DVD_CHANNEL_VAR, 0 );
p_ps->subtitles_channel = main_GetIntVariable( INPUT_DVD_SUBTITLE_VAR, 0 );
p_ps->pes_type = NO_PES; p_ps->pes_type = NO_PES;
p_ps->pes_id = 0; p_ps->pes_id = 0;
p_ps->private_id = 0; p_ps->private_id = 0;
...@@ -608,7 +705,8 @@ void ps_thread( input_file_t * p_if ) ...@@ -608,7 +705,8 @@ void ps_thread( input_file_t * p_if )
/* Fill the fifo until it is full */ /* Fill the fifo until it is full */
ps_fill( p_if, 0 ); ps_fill( p_if, 0 );
/* Launch the thread which fills the fifo */ /* Launch the thread which fills the fifo */
vlc_thread_create( &p_if->disk_thread, "disk thread", (vlc_thread_func_t)input_DiskThread, p_if ); vlc_thread_create( &p_if->disk_thread, "disk thread",
(vlc_thread_func_t)input_DiskThread, p_if );
/* Init the synchronization XXX add error detection !!! */ /* Init the synchronization XXX add error detection !!! */
init_synchro( p_if ); init_synchro( p_if );
} }
...@@ -617,7 +715,7 @@ void ps_thread( input_file_t * p_if ) ...@@ -617,7 +715,7 @@ void ps_thread( input_file_t * p_if )
* ps_read : ps reading method * ps_read : ps reading method
******************************************************************************/ ******************************************************************************/
ssize_t ps_read (int fd, ps_t * p_ps, void *ts) ssize_t ps_read( options_t *p_options, ps_t * p_ps, void *ts )
{ {
int pid, readbytes = 0; int pid, readbytes = 0;
int datasize; int datasize;
...@@ -632,7 +730,7 @@ ssize_t ps_read (int fd, ps_t * p_ps, void *ts) ...@@ -632,7 +730,7 @@ ssize_t ps_read (int fd, ps_t * p_ps, void *ts)
/* copy the remaining bits at the beginning of the PS buffer */ /* copy the remaining bits at the beginning of the PS buffer */
memmove ( p_ps->ps_buffer, p_ps->ps_data, datasize); memmove ( p_ps->ps_buffer, p_ps->ps_data, datasize);
/* read some bytes */ /* read some bytes */
readbytes = safe_read(fd, p_ps->ps_buffer + datasize, PS_BUFFER_SIZE - datasize); readbytes = safe_read( p_options, p_ps->ps_buffer + datasize, PS_BUFFER_SIZE - datasize);
if(readbytes == 0) if(readbytes == 0)
{ {
...@@ -759,7 +857,7 @@ ssize_t ps_read (int fd, ps_t * p_ps, void *ts) ...@@ -759,7 +857,7 @@ ssize_t ps_read (int fd, ps_t * p_ps, void *ts)
{ {
case VIDEO_PES: case VIDEO_PES:
case AUDIO_PES: case AUDIO_PES:
case SUBTITLE_PES: case SUBTITLE_PES:
case AC3_PES: case AC3_PES:
pid = get_pid (p_ps); pid = get_pid (p_ps);
write_media_ts(p_ps, ts, pid); write_media_ts(p_ps, ts, pid);
...@@ -787,7 +885,6 @@ void ps_fill( input_file_t * p_if, boolean_t wait ) ...@@ -787,7 +885,6 @@ void ps_fill( input_file_t * p_if, boolean_t wait )
{ {
in_data_t * p_in_data = &p_if->in_data; in_data_t * p_in_data = &p_if->in_data;
ps_t * p_ps = &p_if->ps; ps_t * p_ps = &p_if->ps;
int fd = p_if->options.in;
int i, how_many; int i, how_many;
int pcr_flag; int pcr_flag;
file_ts_packet *ts; file_ts_packet *ts;
...@@ -824,7 +921,7 @@ void ps_fill( input_file_t * p_if, boolean_t wait ) ...@@ -824,7 +921,7 @@ void ps_fill( input_file_t * p_if, boolean_t wait )
/* read a whole UDP packet from the file */ /* read a whole UDP packet from the file */
p_ps->ts_to_write = how_many; p_ps->ts_to_write = how_many;
if(ps_read(fd, p_ps, ts = (file_ts_packet *)(p_in_data->buf + p_in_data->end)) != how_many) if(ps_read(&p_if->options, p_ps, ts = (file_ts_packet *)(p_in_data->buf + p_in_data->end)) != how_many)
{ {
msleep( 50000 ); /* XXX we need an INPUT_IDLE */ msleep( 50000 ); /* XXX we need an INPUT_IDLE */
intf_ErrMsg( "input error: read() error\n" ); intf_ErrMsg( "input error: read() error\n" );
...@@ -904,7 +1001,7 @@ int init_synchro( input_file_t * p_if ) ...@@ -904,7 +1001,7 @@ int init_synchro( input_file_t * p_if )
} }
/***************************************************************************** /*****************************************************************************
* input_FileOpen : open a file descriptor * input_DiskThread : main thread
*****************************************************************************/ *****************************************************************************/
void input_DiskThread( input_file_t * p_if ) void input_DiskThread( input_file_t * p_if )
...@@ -920,14 +1017,18 @@ int input_FileOpen( input_thread_t *p_input ) ...@@ -920,14 +1017,18 @@ int input_FileOpen( input_thread_t *p_input )
{ {
options_t * p_options = &input_file.options; options_t * p_options = &input_file.options;
p_options->in = open( p_input->psz_source, O_RDONLY ); p_options->in = -1;
if( p_options->in < 0 )
p_options->playlist = (char **)p_input->p_source;
p_options->i_list_index = p_input->i_port;
if( file_next( p_options ) < 0 )
{ {
intf_ErrMsg( "input error: cannot open the file %s", p_input->psz_source ); intf_ErrMsg( "input error: cannot open the file %s", p_input->p_source );
} }
input_file.b_die = 0; input_file.b_die = 0;
read( p_options->in, &p_options->i_file_type, 1 ); safe_read( p_options, &p_options->i_file_type, 1 );
switch( p_options->i_file_type ) switch( p_options->i_file_type )
{ {
...@@ -944,7 +1045,7 @@ int input_FileOpen( input_thread_t *p_input ) ...@@ -944,7 +1045,7 @@ int input_FileOpen( input_thread_t *p_input )
} }
return( 0 ); return( 0 );
} }
/***************************************************************************** /*****************************************************************************
......
...@@ -186,12 +186,12 @@ int input_NetworkOpen( input_thread_t *p_input ) ...@@ -186,12 +186,12 @@ int input_NetworkOpen( input_thread_t *p_input )
*/ */
/* Use default host if not specified */ /* Use default host if not specified */
if( p_input->psz_source == NULL ) if( p_input->p_source == NULL )
{ {
p_input->psz_source = main_GetPszVariable( INPUT_SERVER_VAR, INPUT_SERVER_DEFAULT ); p_input->p_source = main_GetPszVariable( INPUT_SERVER_VAR, INPUT_SERVER_DEFAULT );
} }
if( BuildInetAddr( &sa_in, p_input->psz_source, htons(0) ) == (-1) ) if( BuildInetAddr( &sa_in, p_input->p_source, htons(0) ) == (-1) )
{ {
close( p_input->i_handle ); close( p_input->i_handle );
return( -1 ); return( -1 );
......
...@@ -157,9 +157,13 @@ intf_thread_t* intf_Create( void ) ...@@ -157,9 +157,13 @@ intf_thread_t* intf_Create( void )
*****************************************************************************/ *****************************************************************************/
void intf_Run( intf_thread_t *p_intf ) void intf_Run( intf_thread_t *p_intf )
{ {
if( p_intf->p_playlist )
{
p_intf->p_input = input_CreateThread( INPUT_METHOD_TS_FILE, (void *)p_intf->p_playlist, p_intf->i_list_index, 0, p_main->p_intf->p_vout, p_main->p_aout, NULL );
}
/* Execute the initialization script - if a positive number is returned, /* Execute the initialization script - if a positive number is returned,
* the script could be executed but failed */ * the script could be executed but failed */
if( intf_ExecScript( main_GetPszVariable( INTF_INIT_SCRIPT_VAR, INTF_INIT_SCRIPT_DEFAULT ) ) > 0 ) else if( intf_ExecScript( main_GetPszVariable( INTF_INIT_SCRIPT_VAR, INTF_INIT_SCRIPT_DEFAULT ) ) > 0 )
{ {
intf_ErrMsg("warning: error(s) during startup script\n"); intf_ErrMsg("warning: error(s) during startup script\n");
} }
......
...@@ -459,10 +459,12 @@ static int SpawnInput( int i_argc, intf_arg_t *p_argv ) ...@@ -459,10 +459,12 @@ static int SpawnInput( int i_argc, intf_arg_t *p_argv )
{ {
int i_arg; int i_arg;
int i_method = 0; /* method parameter */ int i_method = 0; /* method parameter */
char * psz_source = NULL; /* source parameter */ char * p_source = NULL; /* source parameter */
int i_port = 0; /* port parameter */ int i_port = 0; /* port parameter */
int i_vlan = 0; /* vlan parameter */ int i_vlan = 0; /* vlan parameter */
fprintf( stderr, "spawn input\n" );
/* Parse parameters - see command list above */ /* Parse parameters - see command list above */
for ( i_arg = 1; i_arg < i_argc; i_arg++ ) for ( i_arg = 1; i_arg < i_argc; i_arg++ )
{ {
...@@ -474,7 +476,7 @@ static int SpawnInput( int i_argc, intf_arg_t *p_argv ) ...@@ -474,7 +476,7 @@ static int SpawnInput( int i_argc, intf_arg_t *p_argv )
case 1: /* filename, hostname, ip */ case 1: /* filename, hostname, ip */
case 2: case 2:
case 3: case 3:
psz_source = p_argv[i_arg].psz_str; p_source = p_argv[i_arg].psz_str;
break; break;
case 4: /* port */ case 4: /* port */
i_port = p_argv[i_arg].i_num; i_port = p_argv[i_arg].i_num;
...@@ -491,7 +493,7 @@ static int SpawnInput( int i_argc, intf_arg_t *p_argv ) ...@@ -491,7 +493,7 @@ static int SpawnInput( int i_argc, intf_arg_t *p_argv )
input_DestroyThread( p_main->p_intf->p_input, NULL ); input_DestroyThread( p_main->p_intf->p_input, NULL );
} }
p_main->p_intf->p_input = input_CreateThread( i_method, psz_source, i_port, i_vlan, p_main->p_intf->p_input = input_CreateThread( i_method, p_source, i_port, i_vlan,
p_main->p_intf->p_vout, p_main->p_aout, p_main->p_intf->p_vout, p_main->p_aout,
NULL ); NULL );
return( INTF_NO_ERROR ); return( INTF_NO_ERROR );
......
...@@ -41,6 +41,7 @@ ...@@ -41,6 +41,7 @@
#include "mtime.h" #include "mtime.h"
#include "plugins.h" #include "plugins.h"
#include "input_vlan.h" #include "input_vlan.h"
#include "input_file.h"
#include "intf_msg.h" #include "intf_msg.h"
#include "interface.h" #include "interface.h"
...@@ -106,6 +107,11 @@ static const struct option longopts[] = ...@@ -106,6 +107,11 @@ static const struct option longopts[] =
{ "grayscale", 0, 0, 'g' }, { "grayscale", 0, 0, 'g' },
{ "color", 0, 0, OPT_COLOR }, { "color", 0, 0, OPT_COLOR },
/* DVD options */
{ "dvdaudio", 1, 0, 'a' },
{ "dvdchannel", 1, 0, 'c' },
{ "dvdsubtitle", 1, 0, 's' },
/* Input options */ /* Input options */
{ "novlans", 0, 0, OPT_NOVLANS }, { "novlans", 0, 0, OPT_NOVLANS },
{ "server", 1, 0, OPT_SERVER }, { "server", 1, 0, OPT_SERVER },
...@@ -115,7 +121,7 @@ static const struct option longopts[] = ...@@ -115,7 +121,7 @@ static const struct option longopts[] =
}; };
/* Short options */ /* Short options */
static const char *psz_shortopts = "hHvg"; static const char *psz_shortopts = "hHvga:s:c:";
/***************************************************************************** /*****************************************************************************
* Global variable program_data - this is the one and only, see main.h * Global variable program_data - this is the one and only, see main.h
...@@ -149,6 +155,9 @@ static int TestMMX ( void ); ...@@ -149,6 +155,9 @@ static int TestMMX ( void );
int main( int i_argc, char *ppsz_argv[], char *ppsz_env[] ) int main( int i_argc, char *ppsz_argv[], char *ppsz_env[] )
{ {
main_t main_data; /* root of all data - see main.h */ main_t main_data; /* root of all data - see main.h */
char **p_playlist;
int i_list_index;
p_main = &main_data; /* set up the global variable */ p_main = &main_data; /* set up the global variable */
/* /*
...@@ -180,6 +189,29 @@ int main( int i_argc, char *ppsz_argv[], char *ppsz_env[] ) ...@@ -180,6 +189,29 @@ int main( int i_argc, char *ppsz_argv[], char *ppsz_env[] )
intf_MsgDestroy(); intf_MsgDestroy();
return( errno ); return( errno );
} }
/* get command line files */
i_list_index = 0;
if( optind < i_argc )
{
int i_index = 0;
p_playlist = malloc( (i_list_index = i_argc - optind)
* sizeof(int) );
while( i_argc - i_index > optind )
{
p_playlist[ i_index ] = ppsz_argv[ i_argc - i_index - 1];
i_index++;
}
}
else
{
p_playlist = malloc( sizeof(int) );
p_playlist[ 0 ] = "-";
i_list_index = 1;
}
intf_MsgImm( COPYRIGHT_MESSAGE "\n" ); /* print welcome message */ intf_MsgImm( COPYRIGHT_MESSAGE "\n" ); /* print welcome message */
/* /*
...@@ -212,7 +244,11 @@ int main( int i_argc, char *ppsz_argv[], char *ppsz_env[] ) ...@@ -212,7 +244,11 @@ int main( int i_argc, char *ppsz_argv[], char *ppsz_env[] )
main_data.p_intf = intf_Create(); main_data.p_intf = intf_Create();
if( main_data.p_intf != NULL ) if( main_data.p_intf != NULL )
{ {
main_data.p_intf->p_playlist = p_playlist;
main_data.p_intf->i_list_index = i_list_index;
InitSignalHandler(); /* prepare signals for interception */ InitSignalHandler(); /* prepare signals for interception */
intf_Run( main_data.p_intf ); intf_Run( main_data.p_intf );
intf_Destroy( main_data.p_intf ); intf_Destroy( main_data.p_intf );
} }
...@@ -426,6 +462,24 @@ static int GetConfiguration( int i_argc, char *ppsz_argv[], char *ppsz_env[] ) ...@@ -426,6 +462,24 @@ static int GetConfiguration( int i_argc, char *ppsz_argv[], char *ppsz_env[] )
main_PutIntVariable( VOUT_GRAYSCALE_VAR, 0 ); main_PutIntVariable( VOUT_GRAYSCALE_VAR, 0 );
break; break;
/* DVD options */
case 'a':
if ( ! strcmp(optarg, "mpeg") )
main_PutIntVariable( INPUT_DVD_AUDIO_VAR, REQUESTED_MPEG );
else if ( ! strcmp(optarg, "lpcm") )
main_PutIntVariable( INPUT_DVD_AUDIO_VAR, REQUESTED_LPCM );
else if ( ! strcmp(optarg, "off") )
main_PutIntVariable( INPUT_DVD_AUDIO_VAR, REQUESTED_NOAUDIO );
else
main_PutIntVariable( INPUT_DVD_AUDIO_VAR, REQUESTED_AC3 );
break;
case 'c':
main_PutIntVariable( INPUT_DVD_CHANNEL_VAR, atoi(optarg) );
break;
case 's':
main_PutIntVariable( INPUT_DVD_SUBTITLE_VAR, atoi(optarg) );
break;
/* Input options */ /* Input options */
case OPT_NOVLANS: /* --novlans */ case OPT_NOVLANS: /* --novlans */
p_main->b_vlans = 0; p_main->b_vlans = 0;
...@@ -487,6 +541,10 @@ static void Usage( int i_fashion ) ...@@ -487,6 +541,10 @@ static void Usage( int i_fashion )
" -g, --grayscale \tgrayscale output\n" " -g, --grayscale \tgrayscale output\n"
" --color \tcolor output\n" " --color \tcolor output\n"
"\n" "\n"
" -a, --dvdaudio \tchoose DVD audio type\n"
" -c, --dvdchannel \tchoose DVD audio channel\n"
" -s, --dvdsubtitle \tchoose DVD subtitle channel\n"
"\n"
" --novlans \tdisable vlans\n" " --novlans \tdisable vlans\n"
" --server <host> \tvideo server address\n" " --server <host> \tvideo server address\n"
" --port <port> \tvideo server port\n" " --port <port> \tvideo server port\n"
...@@ -522,6 +580,13 @@ static void Usage( int i_fashion ) ...@@ -522,6 +580,13 @@ static void Usage( int i_fashion )
" " VOUT_FB_DEV_VAR "=<filename> \tframebuffer device path\n" " " VOUT_FB_DEV_VAR "=<filename> \tframebuffer device path\n"
" " VOUT_GRAYSCALE_VAR "={1|0} \tgrayscale or color output\n" ); " " VOUT_GRAYSCALE_VAR "={1|0} \tgrayscale or color output\n" );
/* DVD parameters */
intf_Msg( "\n"
"DVD parameters:\n"
" " INPUT_DVD_AUDIO_VAR "={ac3|lpcm|mpeg|off} \taudio type\n"
" " INPUT_DVD_CHANNEL_VAR "=[0-15] \taudio channel\n"
" " INPUT_DVD_SUBTITLE_VAR "=[0-31] \tsubtitle channel\n" );
/* Input parameters */ /* Input parameters */
intf_Msg( "\n" intf_Msg( "\n"
"Input parameters:\n" "Input parameters:\n"
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment