Commit 81f0e7f9 authored by Christophe Massiot's avatar Christophe Massiot

* L'input devrait �tre capable de se fermer correctement apr�s une

  erreur (j'ai dit _capable_, hein, j'ai pas dit qu'elle le faisait) ;

--Meuuh
parent f48ce6f6
...@@ -49,6 +49,7 @@ ...@@ -49,6 +49,7 @@
* Local prototypes * Local prototypes
******************************************************************************/ ******************************************************************************/
static void input_Thread( input_thread_t *p_input ); static void input_Thread( input_thread_t *p_input );
static void EndThread( input_thread_t *p_input );
static __inline__ int input_ReadPacket( input_thread_t *p_input ); static __inline__ int input_ReadPacket( input_thread_t *p_input );
static __inline__ void input_SortPacket( input_thread_t *p_input, static __inline__ void input_SortPacket( input_thread_t *p_input,
ts_packet_t *ts_packet ); ts_packet_t *ts_packet );
...@@ -217,50 +218,11 @@ input_thread_t *input_CreateThread( input_cfg_t *p_cfg ) ...@@ -217,50 +218,11 @@ input_thread_t *input_CreateThread( input_cfg_t *p_cfg )
******************************************************************************/ ******************************************************************************/
void input_DestroyThread( input_thread_t *p_input ) void input_DestroyThread( input_thread_t *p_input )
{ {
int i_es_loop;
intf_DbgMsg("input debug: requesting termination of input thread\n"); intf_DbgMsg("input debug: requesting termination of input thread\n");
p_input->b_die = 1; /* ask thread to kill itself */ p_input->b_die = 1; /* ask thread to kill itself */
pthread_join( p_input->thread_id, NULL ); /* wait until it's done */
(*p_input->p_clean)( p_input ); /* close input method */ /* Remove this as soon as the "status" flag is implemented */
pthread_join( p_input->thread_id, NULL ); /* wait until it's done */
/* Destroy all decoder threads. */
for( i_es_loop = 0; i_es_loop < INPUT_MAX_ES; i_es_loop++ )
{
if( p_input->pp_selected_es[i_es_loop] )
{
switch( p_input->pp_selected_es[i_es_loop]->i_type )
{
case MPEG1_VIDEO_ES:
case MPEG2_VIDEO_ES:
vdec_DestroyThread( (vdec_thread_t*)(p_input->pp_selected_es[i_es_loop]->p_dec) /*, NULL */ );
break;
case MPEG1_AUDIO_ES:
case MPEG2_AUDIO_ES:
adec_DestroyThread( (adec_thread_t*)(p_input->pp_selected_es[i_es_loop]->p_dec) );
break;
default:
#ifdef DEBUG
/* This should never happen. */
intf_DbgMsg("input debug: unknown stream type ! (%d, %d)\n",
p_input->pp_selected_es[i_es_loop]->i_id,
p_input->pp_selected_es[i_es_loop]->i_type);
#endif
break;
}
}
else
{
/* pp_selected_es should not contain any hole. */
break;
}
}
input_NetlistClean( p_input ); /* clean netlist */
input_PsiClean( p_input ); /* clean PSI information */
input_PcrClean( p_input ); /* clean PCR information */
free( p_input ); /* free input_thread structure */
} }
#if 0 #if 0
...@@ -333,10 +295,61 @@ static void input_Thread( input_thread_t *p_input ) ...@@ -333,10 +295,61 @@ static void input_Thread( input_thread_t *p_input )
} }
/* Ohoh, we have to die as soon as possible. */ /* Ohoh, we have to die as soon as possible. */
EndThread( p_input );
intf_DbgMsg("input debug: thread %p destroyed\n", p_input); intf_DbgMsg("input debug: thread %p destroyed\n", p_input);
pthread_exit( 0 ); pthread_exit( 0 );
} }
/*******************************************************************************
* EndThread: end the input thread
*******************************************************************************/
static void EndThread( input_thread_t *p_input )
{
int i_es_loop;
(*p_input->p_clean)( p_input ); /* close input method */
/* Destroy all decoder threads. */
for( i_es_loop = 0; i_es_loop < INPUT_MAX_ES; i_es_loop++ )
{
if( p_input->pp_selected_es[i_es_loop] )
{
switch( p_input->pp_selected_es[i_es_loop]->i_type )
{
case MPEG1_VIDEO_ES:
case MPEG2_VIDEO_ES:
vdec_DestroyThread( (vdec_thread_t*)(p_input->pp_selected_es[i_es_loop]->p_dec) /*, NULL */ );
break;
case MPEG1_AUDIO_ES:
case MPEG2_AUDIO_ES:
adec_DestroyThread( (adec_thread_t*)(p_input->pp_selected_es[i_es_loop]->p_dec) );
break;
default:
#ifdef DEBUG
/* This should never happen. */
intf_DbgMsg("input debug: unknown stream type ! (%d, %d)\n",
p_input->pp_selected_es[i_es_loop]->i_id,
p_input->pp_selected_es[i_es_loop]->i_type);
#endif
break;
}
}
else
{
/* pp_selected_es should not contain any hole. */
break;
}
}
input_NetlistClean( p_input ); /* clean netlist */
input_PsiClean( p_input ); /* clean PSI information */
input_PcrClean( p_input ); /* clean PCR information */
free( p_input ); /* free input_thread structure */
intf_DbgMsg("input debug: EndThread(%p)\n", p_input);
}
/******************************************************************************* /*******************************************************************************
* input_ReadPacket: reads a packet from the network or the file * input_ReadPacket: reads a packet from the network or the file
*******************************************************************************/ *******************************************************************************/
...@@ -392,10 +405,10 @@ static __inline__ int input_ReadPacket( input_thread_t *p_input ) ...@@ -392,10 +405,10 @@ static __inline__ int input_ReadPacket( input_thread_t *p_input )
INPUT_TS_READ_ONCE ); INPUT_TS_READ_ONCE );
if( i_packet_size == (-1) ) if( i_packet_size == (-1) )
{ {
intf_DbgMsg("Read packet %d %p %d %d\n", i_base_index, // intf_DbgMsg("Read packet %d %p %d %d\n", i_base_index,
&p_input->netlist.p_ts_free[i_base_index], // &p_input->netlist.p_ts_free[i_base_index],
p_input->netlist.i_ts_start, // p_input->netlist.i_ts_start,
p_input->netlist.i_ts_end); // p_input->netlist.i_ts_end);
intf_ErrMsg("input error: readv() failed (%s)\n", strerror(errno)); intf_ErrMsg("input error: readv() failed (%s)\n", strerror(errno));
return( -1 ); return( -1 );
} }
......
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