src/os2/specific.c

   1 /*****************************************************************************
   2  * specific.c: OS/2 specific features
   3  *****************************************************************************
   4  * Copyright (C) 2010 KO Myung-Hun
   5  *
   6  * This program is free software; you can redistribute it and/or modify it
   7  * under the terms of the GNU Lesser General Public License as published by
   8  * the Free Software Foundation; either version 2.1 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14  * GNU Lesser General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Lesser General Public License
  17  * along with this program; if not, write to the Free Software Foundation,
  18  * Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
  19  *****************************************************************************/
  20
  21 #ifdef HAVE_CONFIG_H
  22 # include "config.h"
  23 #endif
  24
  25 #include <vlc_common.h>
  26 #include "../libvlc.h"
  27 #include <vlc_playlist_legacy.h>
  28 #include <vlc_input.h>
  29 #include <vlc_interface.h>
  30 #include <vlc_url.h>
  31
  32 #include <fcntl.h>
  33 #include <io.h>
  34
  35 #define VLC_IPC_PIPE "\\PIPE\\VLC\\IPC\\"VERSION
  36
  37 #define IPC_CMD_GO      0x00
  38 #define IPC_CMD_ENQUEUE 0x01
  39 #define IPC_CMD_QUIT    0xFF
  40
  41 extern int _fmode_bin;
  42
  43 static HPIPE hpipeIPC     = NULLHANDLE;
  44 static int   tidIPCFirst  = -1;
  45 static int   tidIPCHelper = -1;
  46
  47 static void IPCHelperThread( void *arg )
  48 {
  49     libvlc_int_t *libvlc = arg;
  50
  51     ULONG  ulCmd;
  52     int    i_argc;
  53     char **ppsz_argv;
  54     size_t i_len;
  55     ULONG  cbActual;
  56     int    i_options;
  57
  58     /* Add files to the playlist */
  59     playlist_t *p_playlist;
  60
  61     do
  62     {
  63         DosConnectNPipe( hpipeIPC );
  64
  65         /* Read command */
  66         DosRead( hpipeIPC, &ulCmd, sizeof( ulCmd ), &cbActual );
  67         if( ulCmd == IPC_CMD_QUIT )
  68             continue;
  69
  70         /* Read a count of arguments */
  71         DosRead( hpipeIPC, &i_argc, sizeof( i_argc ), &cbActual );
  72
  73         ppsz_argv = vlc_alloc( i_argc, sizeof( *ppsz_argv ));
  74
  75         for( int i_opt = 0; i_opt < i_argc; i_opt++ )
  76         {
  77             /* Read a length of argv */
  78             DosRead( hpipeIPC, &i_len, sizeof( i_len ), &cbActual );
  79
  80             ppsz_argv[ i_opt ] = malloc( i_len );
  81
  82             /* Read argv */
  83             DosRead( hpipeIPC, ppsz_argv[ i_opt ], i_len, &cbActual );
  84         }
  85
  86         p_playlist = libvlc_priv(libvlc)->playlist;
  87
  88         for( int i_opt = 0; i_opt < i_argc;)
  89         {
  90             i_options = 0;
  91
  92             /* Count the input options */
  93             while( i_opt + i_options + 1 < i_argc &&
  94                    *ppsz_argv[ i_opt + i_options + 1 ] == ':' )
  95                 i_options++;
  96
  97
  98             if( p_playlist )
  99             {
 100                 playlist_AddExt( p_playlist, ppsz_argv[ i_opt ], NULL,
 101                                  i_opt == 0 && ulCmd != IPC_CMD_ENQUEUE,
 102                                  i_options,
 103                                  ( char const ** )
 104                                      ( i_options ? &ppsz_argv[ i_opt + 1 ] :
 105                                                    NULL ),
 106                                  VLC_INPUT_OPTION_TRUSTED );
 107             }
 108
 109             for( ; i_options >= 0; i_options-- )
 110                 free( ppsz_argv[ i_opt++ ]);
 111         }
 112
 113         free( ppsz_argv );
 114     } while( !DosDisConnectNPipe( hpipeIPC ) && ulCmd != IPC_CMD_QUIT );
 115
 116     DosClose( hpipeIPC );
 117     hpipeIPC = NULLHANDLE;
 118
 119     tidIPCFirst  = -1;
 120     tidIPCHelper = -1;
 121 }
 122
 123 void system_Init( void )
 124 {
 125     /* Set the default file-translation mode */
 126     _fmode_bin = 1;
 127     setmode( fileno( stdin ), O_BINARY ); /* Needed for pipes */
 128 }
 129
 130 void system_Configure( libvlc_int_t *p_this, int i_argc, const char *const ppsz_argv[] )
 131 {
 132     if( var_InheritBool( p_this, "high-priority" ) )
 133     {
 134         if( !DosSetPriority( PRTYS_PROCESS, PRTYC_REGULAR, PRTYD_MAXIMUM, 0 ) )
 135         {
 136             msg_Dbg( p_this, "raised process priority" );
 137         }
 138         else
 139         {
 140             msg_Dbg( p_this, "could not raise process priority" );
 141         }
 142     }
 143
 144     if( var_InheritBool( p_this, "one-instance" )
 145         || ( var_InheritBool( p_this, "one-instance-when-started-from-file" )
 146              && var_InheritBool( p_this, "started-from-file" ) ) )
 147     {
 148         HPIPE hpipe;
 149         ULONG ulAction;
 150         ULONG rc;
 151
 152         msg_Info( p_this, "one instance mode ENABLED");
 153
 154         /* Use a named pipe to check if another instance is already running */
 155         for(;;)
 156         {
 157             rc = DosOpen( VLC_IPC_PIPE, &hpipe, &ulAction, 0, 0,
 158                           OPEN_ACTION_OPEN_IF_EXISTS,
 159                           OPEN_ACCESS_READWRITE | OPEN_SHARE_DENYREADWRITE |
 160                           OPEN_FLAGS_FAIL_ON_ERROR,
 161                           NULL );
 162
 163             if( rc == ERROR_PIPE_BUSY )
 164                 DosWaitNPipe( VLC_IPC_PIPE, -1 );
 165             else
 166                 break;
 167         }
 168
 169         if( rc )
 170         {
 171             rc = DosCreateNPipe( VLC_IPC_PIPE,  &hpipeIPC,
 172                                  NP_ACCESS_DUPLEX,
 173                                  NP_WAIT | NP_TYPE_MESSAGE |
 174                                  NP_READMODE_MESSAGE | 0x01,
 175                                  32768, 32768, 0 );
 176             if( rc )
 177             {
 178                 /* Failed to create a named pipe. Just ignore the option and
 179                  * go on as normal. */
 180                 msg_Err( p_this, "one instance mode DISABLED "
 181                          "(a named pipe couldn't be created)" );
 182                 return;
 183             }
 184
 185             /* We are the 1st instance. */
 186
 187             /* Save the tid of the first instance */
 188             tidIPCFirst = _gettid();
 189
 190             /* Run the helper thread */
 191             tidIPCHelper = _beginthread( IPCHelperThread, NULL, 1024 * 1024,
 192                                          p_this );
 193             if( tidIPCHelper == -1 )
 194             {
 195                 msg_Err( p_this, "one instance mode DISABLED "
 196                          "(IPC helper thread couldn't be created)");
 197
 198                 tidIPCFirst = -1;
 199             }
 200         }
 201         else
 202         {
 203             /* Another instance is running */
 204             ULONG ulCmd = var_InheritBool( p_this, "playlist-enqueue") ?
 205                               IPC_CMD_ENQUEUE : IPC_CMD_GO;
 206             ULONG cbActual;
 207
 208             /* Write a command */
 209             DosWrite( hpipe, &ulCmd, sizeof( ulCmd ), &cbActual );
 210
 211             /* We assume that the remaining parameters are filenames
 212              * and their input options */
 213
 214             /* Write a count of arguments */
 215             DosWrite( hpipe, &i_argc, sizeof( i_argc ), &cbActual );
 216
 217             for( int i_opt = 0; i_opt < i_argc; i_opt++ )
 218             {
 219                 /* We need to resolve relative paths in this instance */
 220                 char *mrl;
 221                 if( strstr( ppsz_argv[ i_opt ], "://" ))
 222                     mrl = strdup( ppsz_argv[ i_opt ] );
 223                 else
 224                     mrl = vlc_path2uri( ppsz_argv[ i_opt ], NULL );
 225
 226                 if( !mrl )
 227                     mrl = ( char * )ppsz_argv[ i_opt ];
 228
 229                 size_t i_len = strlen( mrl ) + 1;
 230
 231                 /* Write a length of an argument */
 232                 DosWrite( hpipe, &i_len, sizeof( i_len ), &cbActual );
 233
 234                 /* Write an argument */
 235                 DosWrite( hpipe, mrl, i_len, &cbActual );
 236
 237                 if( mrl != ppsz_argv[ i_opt ])
 238                     free( mrl );
 239             }
 240
 241             /* Close a named pipe of a client side */
 242             DosClose( hpipe );
 243
 244             /* Bye bye */
 245             system_End();
 246             exit( 0 );
 247         }
 248     }
 249 }
 250
 251 /**
 252  * Cleans up after system_Init() and system_Configure().
 253  */
 254 void system_End(void)
 255 {
 256     if( tidIPCFirst == _gettid())
 257     {
 258         HPIPE hpipe;
 259         ULONG ulAction;
 260         ULONG cbActual;
 261         ULONG rc;
 262
 263         do
 264         {
 265             rc = DosOpen( VLC_IPC_PIPE, &hpipe, &ulAction, 0, 0,
 266                           OPEN_ACTION_OPEN_IF_EXISTS,
 267                           OPEN_ACCESS_READWRITE | OPEN_SHARE_DENYREADWRITE |
 268                           OPEN_FLAGS_FAIL_ON_ERROR,
 269                           NULL );
 270
 271             if( rc == ERROR_PIPE_BUSY )
 272                 DosWaitNPipe( VLC_IPC_PIPE, -1 );
 273             else if( rc )
 274                 DosSleep( 1 );
 275         } while( rc );
 276
 277         /* Ask for IPCHelper to quit */
 278         ULONG ulCmd = IPC_CMD_QUIT;
 279         DosWrite( hpipe, &ulCmd, sizeof( ulCmd ), &cbActual );
 280
 281         DosClose( hpipe );
 282
 283         TID tid = tidIPCHelper;
 284         DosWaitThread( &tid, DCWW_WAIT );
 285     }
 286 }
 287