git.sesse.net Git - vlc/blob - src/interface/interface.c

   1 /*******************************************************************************
   2  * interface.c: interface access for other threads
   3  * (c)1998 VideoLAN
   4  *******************************************************************************
   5  * This library provides basic functions for threads to interact with user
   6  * interface, such as command line.
   7  *******************************************************************************/
   8
   9 /*******************************************************************************
  10  * Preamble
  11  *******************************************************************************/
  12 #include <stdio.h>
  13 #include <unistd.h>
  14 #include <netinet/in.h>
  15 #include <sys/soundcard.h>
  16 #include <sys/uio.h>
  17 #include <X11/Xlib.h>
  18 #include <X11/extensions/XShm.h>
  19
  20 #include <sys/types.h>
  21 #include <sys/stat.h>
  22 #include <fcntl.h>
  23
  24 #include "config.h"
  25 #include "common.h"
  26 #include "mtime.h"
  27 #include "vlc_thread.h"
  28 #include "thread.h"
  29 #include "debug.h"
  30
  31 #include "intf_msg.h"
  32
  33 #include "input.h"
  34 #include "input_netlist.h"
  35 #include "input_vlan.h"
  36 #include "decoder_fifo.h"
  37
  38 #include "audio_output.h"
  39 #include "audio_decoder.h"
  40
  41 #include "video.h"
  42 #include "video_output.h"
  43 #include "video_decoder.h"
  44
  45 #include "xconsole.h"
  46 #include "interface.h"
  47 #include "intf_cmd.h"
  48
  49 #include "pgm_data.h"
  50 /* ?? remove useless headers */
  51
  52 /*
  53  * Local prototypes
  54  */
  55 static int  StartInterface  ( intf_thread_t *p_intf );
  56 static void EndInterface    ( intf_thread_t *p_intf );
  57
  58 /*******************************************************************************
  59  * intf_Run
  60  *******************************************************************************
  61  * what it does:
  62  *     - Create an X11 console
  63  *     - wait for a command and try to execute it
  64  *     - interpret the order returned after the command execution
  65  *     - print the messages of the message queue (intf_FlushMsg)
  66  * return value: 0 if successful, < 0 otherwise
  67  *******************************************************************************/
  68 int intf_Run( intf_thread_t *p_intf )
  69 {
  70     /* When it is started, interface won't die immediatly */
  71     p_intf->b_die = 0;
  72     if( StartInterface( p_intf ) )                                    /* error */
  73     {
  74         return( 1 );
  75     }
  76
  77     /* Main loop */
  78     while(!p_intf->b_die)
  79     {
  80         /* Flush waiting messages */
  81         intf_FlushMsg();
  82
  83         /* Manage specific interfaces */
  84         intf_ManageXConsole( &p_intf->xconsole );               /* X11 console */
  85
  86         /* Sleep to avoid using all CPU - since some interfaces needs to access
  87          * keyboard events, a 100ms delay is a good compromise */
  88         msleep( INTF_IDLE_SLEEP );
  89     }
  90
  91     /* End of interface thread - the main() function will close all remaining
  92      * output threads */
  93     EndInterface( p_intf );
  94     return ( 0 );
  95 }
  96
  97 /* following functions are local */
  98
  99 /*******************************************************************************
 100  * StartInterface: prepare interface before main loop
 101  *******************************************************************************
 102  * This function opens output devices and create specific interfaces. It send
 103  * it's own error messages.
 104  *******************************************************************************/
 105 static int StartInterface( intf_thread_t *p_intf )
 106 {
 107     int i_thread;                                              /* thread index */
 108 #ifdef INIT_SCRIPT
 109     int fd;
 110 #endif
 111
 112     /* Empty all threads array */
 113     for( i_thread = 0; i_thread < VOUT_MAX_THREADS; i_thread++ )
 114     {
 115         p_intf->pp_vout[i_thread] = NULL;
 116     }
 117     for( i_thread = 0; i_thread < INPUT_MAX_THREADS; i_thread++ )
 118     {
 119         p_intf->pp_input[i_thread] = NULL;
 120     }
 121
 122     /* Start X11 Console*/
 123     if( intf_OpenXConsole( &p_intf->xconsole ) )
 124     {
 125         intf_ErrMsg("intf error: can't open X11 console\n");
 126         return( 1 );
 127     }
 128
 129 #ifdef INIT_SCRIPT
 130     /* Execute the initialization script (typically spawn an input thread) */
 131     if ( (fd = open( INIT_SCRIPT, O_RDONLY )) != -1 )
 132     {
 133         /* Startup script does exist */
 134         close( fd );
 135         intf_ExecScript( INIT_SCRIPT );
 136     }
 137 #endif
 138
 139     return( 0 );
 140 }
 141
 142 /*******************************************************************************
 143  * EndInterface: clean interface after main loop
 144  *******************************************************************************
 145  * This function destroys specific interfaces and close output devices.
 146  *******************************************************************************/
 147 static void EndInterface( intf_thread_t *p_intf )
 148 {
 149     int         i_thread;                                      /* thread index */
 150     boolean_t   b_thread;                          /* flag for remaing threads */
 151     int         pi_vout_status[VOUT_MAX_THREADS];       /* vout threads status */
 152
 153
 154
 155     /* Close X11 console */
 156     intf_CloseXConsole( &p_intf->xconsole );
 157
 158     /* Destroy all remaining input threads */
 159     for( i_thread = 0; i_thread < INPUT_MAX_THREADS; i_thread++ )
 160     {
 161         if( p_intf->pp_input[i_thread] != NULL )
 162         {
 163             input_DestroyThread( p_intf->pp_input[i_thread] );
 164         }
 165     }
 166
 167     /* Destroy all remaining video output threads - all destruction orders are send,
 168      * then all THREAD_OVER status are received */
 169     for( i_thread = 0, b_thread = 0; i_thread < VOUT_MAX_THREADS; i_thread++ )
 170     {
 171         if( p_intf->pp_vout[i_thread] != NULL )
 172         {
 173             vout_DestroyThread( p_intf->pp_vout[i_thread], &pi_vout_status[i_thread] );
 174             b_thread = 1;
 175         }
 176     }
 177     while( b_thread )
 178     {
 179         msleep( INTF_IDLE_SLEEP );
 180         b_thread = 0;
 181         for( i_thread = 0; i_thread < VOUT_MAX_THREADS; i_thread++ )
 182         {
 183             if( (p_intf->pp_vout[i_thread] != NULL)
 184                 && (pi_vout_status[i_thread] != THREAD_OVER) )
 185             {
 186                 b_thread = 1;
 187             }
 188         }
 189     }
 190
 191
 192 }