src/os2/utilsexc.cpp

   1 /////////////////////////////////////////////////////////////////////////////
   2 // Name:        src/os2/utilsexec.cpp
   3 // Purpose:     Various utilities
   4 // Author:      David Webster
   5 // Modified by:
   6 // Created:     10/17/99
   7 // RCS-ID:      $Id$
   8 // Copyright:   (c) David Webster
   9 // Licence:     wxWindows licence
  10 /////////////////////////////////////////////////////////////////////////////
  11
  12 // For compilers that support precompilation, includes "wx.h".
  13 #include "wx/wxprec.h"
  14
  15 #ifndef WX_PRECOMP
  16     #include "wx/utils.h"
  17     #include "wx/app.h"
  18     #include "wx/intl.h"
  19     #include "wx/log.h"
  20 #endif
  21
  22 #include "wx/process.h"
  23
  24 #include "wx/os2/private.h"
  25
  26 #define PURE_32
  27 #ifndef __EMX__
  28     #include <upm.h>
  29     #ifndef __WATCOMC__
  30         #include <netcons.h>
  31         #include <netbios.h>
  32     #endif
  33 #endif
  34
  35 #include <ctype.h>
  36 #ifdef __EMX__
  37 #include <dirent.h>
  38 #endif
  39
  40 #include <sys/stat.h>
  41 #include <io.h>
  42
  43 #include <stdio.h>
  44 #include <stdlib.h>
  45 #include <string.h>
  46 #include <errno.h>
  47 #include <stdarg.h>
  48
  49
  50 // this message is sent when the process we're waiting for terminates
  51 #define wxWM_PROC_TERMINATED (WM_USER + 10000)
  52
  53 #ifndef NO_ERROR
  54 #  define NO_ERROR  0
  55 #endif
  56
  57 // structure describing the process we're being waiting for
  58 struct wxExecuteData
  59 {
  60 public:
  61     ~wxExecuteData()
  62     {
  63 //         cout << "Closing thread: " << endl;
  64         DosExit(EXIT_PROCESS, 0);
  65     }
  66
  67     HWND         hWnd;          // window to send wxWM_PROC_TERMINATED to [not used]
  68     RESULTCODES  vResultCodes;
  69     wxProcess*   pHandler;
  70     ULONG        ulExitCode;    // the exit code of the process
  71     bool         bState;        // set to false when the process finishes
  72 };
  73
  74 static ULONG wxExecuteThread(wxExecuteData* pData)
  75 {
  76     ULONG ulRc;
  77     PID   vPidChild;
  78
  79 //     cout << "Executing thread: " << endl;
  80
  81     ulRc = ::DosWaitChild( DCWA_PROCESSTREE
  82                           ,DCWW_NOWAIT
  83                           ,&pData->vResultCodes
  84                           ,&vPidChild
  85                           ,pData->vResultCodes.codeTerminate // process PID to look at
  86                          );
  87     if (ulRc != NO_ERROR)
  88     {
  89         wxLogLastError(wxT("DosWaitChild"));
  90     }
  91     delete pData;
  92     return 0;
  93 }
  94
  95 // window procedure of a hidden window which is created just to receive
  96 // the notification message when a process exits
  97 MRESULT APIENTRY wxExecuteWindowCbk( HWND   hWnd,
  98                                      ULONG  ulMessage,
  99                                      MPARAM WXUNUSED(wParam),
 100                                      MPARAM lParam)
 101 {
 102     if (ulMessage == wxWM_PROC_TERMINATED)
 103     {
 104         wxExecuteData*              pData = (wxExecuteData *)lParam;
 105
 106         if (pData->pHandler)
 107         {
 108             pData->pHandler->OnTerminate( (int)pData->vResultCodes.codeTerminate
 109                                          ,(int)pData->vResultCodes.codeResult
 110                                         );
 111         }
 112
 113         if (pData->bState)
 114         {
 115             // we're executing synchronously, tell the waiting thread
 116             // that the process finished
 117             pData->bState = 0;
 118         }
 119         else
 120         {
 121             // asynchronous execution - we should do the clean up
 122             delete pData;
 123         }
 124         ::WinDestroyWindow(hWnd);    // we don't need it any more
 125     }
 126     return 0;
 127 }
 128
 129 long wxExecute( const wxString& rCommand,
 130                 int flags,
 131                 wxProcess* pHandler,
 132                 const wxExecuteEnv *env)
 133 {
 134     if (rCommand.empty())
 135     {
 136 //         cout << "empty command in wxExecute." << endl;
 137         return 0;
 138     }
 139
 140     // create the process
 141     UCHAR                           vLoadError[CCHMAXPATH] = {0};
 142     RESULTCODES                     vResultCodes = {0};
 143     ULONG                           ulExecFlag;
 144     PSZ                             zArgs = NULL;
 145     PSZ                             zEnvs = NULL;
 146     APIRET                          rc;
 147     TID                             vTID;
 148
 149     if (flags & wxEXEC_SYNC)
 150         ulExecFlag = EXEC_SYNC;
 151     else
 152         ulExecFlag = EXEC_ASYNCRESULT;
 153
 154     rc = ::DosExecPgm( (PCHAR)vLoadError
 155                       ,sizeof(vLoadError)
 156                       ,ulExecFlag
 157                       ,zArgs
 158                       ,zEnvs
 159                       ,&vResultCodes
 160                       ,rCommand.c_str()
 161                      );
 162     if (rc != NO_ERROR)
 163     {
 164         wxLogSysError(_("Execution of command '%s' failed with error: %ul"), rCommand.c_str(), rc);
 165         return 0;
 166     }
 167 //     cout << "Executing: " << rCommand.c_str() << endl;
 168     // Alloc data
 169     wxExecuteData*                  pData = new wxExecuteData;
 170
 171     pData->vResultCodes = vResultCodes;
 172     pData->hWnd         = NULLHANDLE;
 173     pData->bState       = (flags & wxEXEC_SYNC) != 0;
 174     if (flags & wxEXEC_SYNC)
 175     {
 176         wxASSERT_MSG(!pHandler, wxT("wxProcess param ignored for sync execution"));
 177         pData->pHandler = NULL;
 178     }
 179     else
 180     {
 181         // may be NULL or not
 182         pData->pHandler = pHandler;
 183     }
 184
 185     rc = ::DosCreateThread( &vTID
 186                            ,(PFNTHREAD)&wxExecuteThread
 187                            ,(ULONG)pData
 188                            ,CREATE_READY|STACK_SPARSE
 189                            ,8192
 190                           );
 191     if (rc != NO_ERROR)
 192     {
 193         wxLogLastError(wxT("CreateThread in wxExecute"));
 194         delete pData;
 195
 196         // the process still started up successfully...
 197         return vResultCodes.codeTerminate;
 198     }
 199     if (!(flags & wxEXEC_SYNC))
 200     {
 201         // return the pid
 202         // warning: don't exit your app unless you actively
 203         // kill and cleanup you child processes
 204         // Maybe detach the process here???
 205         // If cmd.exe need to pass DETACH to detach the process here
 206         return vResultCodes.codeTerminate;
 207     }
 208
 209     // waiting until command executed
 210     ::DosWaitThread(&vTID, DCWW_WAIT);
 211
 212     ULONG ulExitCode = pData->vResultCodes.codeResult;
 213     delete pData;
 214
 215     // return the exit code
 216     return (long)ulExitCode;
 217 }
 218
 219 long wxExecute(
 220   char**                            ppArgv
 221 , int                               flags
 222 , wxProcess*                        pHandler
 223 , const wxExecuteEnv *env
 224 )
 225 {
 226     wxString                        sCommand;
 227
 228     while (*ppArgv != NULL)
 229     {
 230         wxString                    sArg((wxChar*)(*ppArgv++));
 231
 232
 233         sCommand << sArg.c_str() << ' ';
 234     }
 235     sCommand.RemoveLast();
 236     return wxExecute( sCommand
 237                      ,flags
 238                      ,pHandler
 239                      , env
 240                     );
 241 }
 242
 243 bool wxGetFullHostName( wxChar* zBuf, int nMaxSize)
 244 {
 245     return wxGetHostName( zBuf, nMaxSize );
 246 }