src/msw/utilsexc.cpp

   1 /////////////////////////////////////////////////////////////////////////////
   2 // Name:        msw/utilsexec.cpp
   3 // Purpose:     wxExecute implementation for MSW
   4 // Author:      Julian Smart
   5 // Modified by:
   6 // Created:     04/01/98
   7 // RCS-ID:      $Id$
   8 // Copyright:   (c) 1998-2002 wxWidgets dev team
   9 // Licence:     wxWindows licence
  10 /////////////////////////////////////////////////////////////////////////////
  11
  12 // ============================================================================
  13 // declarations
  14 // ============================================================================
  15
  16 // ----------------------------------------------------------------------------
  17 // headers
  18 // ----------------------------------------------------------------------------
  19
  20 #if defined(__GNUG__) && !defined(NO_GCC_PRAGMA)
  21     #pragma implementation
  22 #endif
  23
  24 // For compilers that support precompilation, includes "wx.h".
  25 #include "wx/wxprec.h"
  26
  27 #ifdef __BORLANDC__
  28     #pragma hdrstop
  29 #endif
  30
  31 #ifndef WX_PRECOMP
  32     #include "wx/utils.h"
  33     #include "wx/app.h"
  34     #include "wx/intl.h"
  35     #include "wx/log.h"
  36 #endif
  37
  38 #include "wx/stream.h"
  39 #include "wx/process.h"
  40
  41 #include "wx/apptrait.h"
  42
  43 #include "wx/module.h"
  44
  45 #include "wx/msw/private.h"
  46
  47 #include <ctype.h>
  48
  49 #if !defined(__GNUWIN32__) && !defined(__SALFORDC__) && !defined(__WXMICROWIN__) && !defined(__WXWINCE__)
  50     #include <direct.h>
  51 #ifndef __MWERKS__
  52     #include <dos.h>
  53 #endif
  54 #endif
  55
  56 #if defined(__GNUWIN32__)
  57     #include <sys/unistd.h>
  58     #include <sys/stat.h>
  59 #endif
  60
  61 #if !defined(__WXMICROWIN__) && !defined(__WXWINCE__)
  62     #ifndef __UNIX__
  63         #include <io.h>
  64     #endif
  65
  66     #ifndef __GNUWIN32__
  67         #include <shellapi.h>
  68     #endif
  69 #endif
  70
  71 #include <stdio.h>
  72 #include <stdlib.h>
  73 #include <string.h>
  74 #ifndef __WATCOMC__
  75     #if !(defined(_MSC_VER) && (_MSC_VER > 800))
  76         #include <errno.h>
  77     #endif
  78 #endif
  79 #include <stdarg.h>
  80
  81 #if wxUSE_IPC
  82     #include "wx/dde.h"         // for WX_DDE hack in wxExecute
  83 #endif // wxUSE_IPC
  84
  85 // implemented in utils.cpp
  86 extern "C" WXDLLIMPEXP_BASE HWND
  87 wxCreateHiddenWindow(LPCTSTR *pclassname, LPCTSTR classname, WNDPROC wndproc);
  88
  89 // ----------------------------------------------------------------------------
  90 // constants
  91 // ----------------------------------------------------------------------------
  92
  93 // this message is sent when the process we're waiting for terminates
  94 #define wxWM_PROC_TERMINATED (WM_USER + 10000)
  95
  96 // ----------------------------------------------------------------------------
  97 // this module globals
  98 // ----------------------------------------------------------------------------
  99
 100 // we need to create a hidden window to receive the process termination
 101 // notifications and for this we need a (Win) class name for it which we will
 102 // register the first time it's needed
 103 static const wxChar *wxMSWEXEC_WNDCLASSNAME = wxT("_wxExecute_Internal_Class");
 104 static const wxChar *gs_classForHiddenWindow = NULL;
 105
 106 // ----------------------------------------------------------------------------
 107 // private types
 108 // ----------------------------------------------------------------------------
 109
 110 // structure describing the process we're being waiting for
 111 struct wxExecuteData
 112 {
 113 public:
 114     ~wxExecuteData()
 115     {
 116         if ( !::CloseHandle(hProcess) )
 117         {
 118             wxLogLastError(wxT("CloseHandle(hProcess)"));
 119         }
 120     }
 121
 122     HWND       hWnd;          // window to send wxWM_PROC_TERMINATED to
 123     HANDLE     hProcess;      // handle of the process
 124     DWORD      dwProcessId;   // pid of the process
 125     wxProcess *handler;
 126     DWORD      dwExitCode;    // the exit code of the process
 127     bool       state;         // set to false when the process finishes
 128 };
 129
 130 class wxExecuteModule : public wxModule
 131 {
 132 public:
 133     virtual bool OnInit() { return true; }
 134     virtual void OnExit()
 135     {
 136         if ( *gs_classForHiddenWindow )
 137         {
 138             if ( !::UnregisterClass(wxMSWEXEC_WNDCLASSNAME, wxGetInstance()) )
 139             {
 140                 wxLogLastError(_T("UnregisterClass(wxExecClass)"));
 141             }
 142
 143             gs_classForHiddenWindow = NULL;
 144         }
 145     }
 146
 147 private:
 148     DECLARE_DYNAMIC_CLASS(wxExecuteModule)
 149 };
 150
 151 #if wxUSE_STREAMS && !defined(__WXWINCE__)
 152
 153 // ----------------------------------------------------------------------------
 154 // wxPipeStreams
 155 // ----------------------------------------------------------------------------
 156
 157 class wxPipeInputStream: public wxInputStream
 158 {
 159 public:
 160     wxPipeInputStream(HANDLE hInput);
 161     virtual ~wxPipeInputStream();
 162
 163     // returns true if the pipe is still opened
 164     bool IsOpened() const { return m_hInput != INVALID_HANDLE_VALUE; }
 165
 166     // returns true if there is any data to be read from the pipe
 167     virtual bool CanRead() const;
 168
 169 protected:
 170     size_t OnSysRead(void *buffer, size_t len);
 171
 172 protected:
 173     HANDLE m_hInput;
 174
 175     DECLARE_NO_COPY_CLASS(wxPipeInputStream)
 176 };
 177
 178 class wxPipeOutputStream: public wxOutputStream
 179 {
 180 public:
 181     wxPipeOutputStream(HANDLE hOutput);
 182     virtual ~wxPipeOutputStream();
 183
 184 protected:
 185     size_t OnSysWrite(const void *buffer, size_t len);
 186
 187 protected:
 188     HANDLE m_hOutput;
 189
 190     DECLARE_NO_COPY_CLASS(wxPipeOutputStream)
 191 };
 192
 193 // define this to let wxexec.cpp know that we know what we're doing
 194 #define _WX_USED_BY_WXEXECUTE_
 195 #include "../common/execcmn.cpp"
 196
 197 // ----------------------------------------------------------------------------
 198 // wxPipe represents a Win32 anonymous pipe
 199 // ----------------------------------------------------------------------------
 200
 201 class wxPipe
 202 {
 203 public:
 204     // the symbolic names for the pipe ends
 205     enum Direction
 206     {
 207         Read,
 208         Write
 209     };
 210
 211     // default ctor doesn't do anything
 212     wxPipe() { m_handles[Read] = m_handles[Write] = INVALID_HANDLE_VALUE; }
 213
 214     // create the pipe, return true if ok, false on error
 215     bool Create()
 216     {
 217         // default secutiry attributes
 218         SECURITY_ATTRIBUTES security;
 219
 220         security.nLength              = sizeof(security);
 221         security.lpSecurityDescriptor = NULL;
 222         security.bInheritHandle       = TRUE; // to pass it to the child
 223
 224         if ( !::CreatePipe(&m_handles[0], &m_handles[1], &security, 0) )
 225         {
 226             wxLogSysError(_("Failed to create an anonymous pipe"));
 227
 228             return false;
 229         }
 230
 231         return true;
 232     }
 233
 234     // return true if we were created successfully
 235     bool IsOk() const { return m_handles[Read] != INVALID_HANDLE_VALUE; }
 236
 237     // return the descriptor for one of the pipe ends
 238     HANDLE operator[](Direction which) const { return m_handles[which]; }
 239
 240     // detach a descriptor, meaning that the pipe dtor won't close it, and
 241     // return it
 242     HANDLE Detach(Direction which)
 243     {
 244         HANDLE handle = m_handles[which];
 245         m_handles[which] = INVALID_HANDLE_VALUE;
 246
 247         return handle;
 248     }
 249
 250     // close the pipe descriptors
 251     void Close()
 252     {
 253         for ( size_t n = 0; n < WXSIZEOF(m_handles); n++ )
 254         {
 255             if ( m_handles[n] != INVALID_HANDLE_VALUE )
 256             {
 257                 ::CloseHandle(m_handles[n]);
 258                 m_handles[n] = INVALID_HANDLE_VALUE;
 259             }
 260         }
 261     }
 262
 263     // dtor closes the pipe descriptors
 264     ~wxPipe() { Close(); }
 265
 266 private:
 267     HANDLE m_handles[2];
 268 };
 269
 270 #endif // wxUSE_STREAMS
 271
 272 // ============================================================================
 273 // implementation
 274 // ============================================================================
 275
 276 // ----------------------------------------------------------------------------
 277 // process termination detecting support
 278 // ----------------------------------------------------------------------------
 279
 280 // thread function for the thread monitoring the process termination
 281 static DWORD __stdcall wxExecuteThread(void *arg)
 282 {
 283     wxExecuteData * const data = (wxExecuteData *)arg;
 284
 285     if ( ::WaitForSingleObject(data->hProcess, INFINITE) != WAIT_OBJECT_0 )
 286     {
 287         wxLogDebug(_T("Waiting for the process termination failed!"));
 288     }
 289
 290     // get the exit code
 291     if ( !::GetExitCodeProcess(data->hProcess, &data->dwExitCode) )
 292     {
 293         wxLogLastError(wxT("GetExitCodeProcess"));
 294     }
 295
 296     wxASSERT_MSG( data->dwExitCode != STILL_ACTIVE,
 297                   wxT("process should have terminated") );
 298
 299     // send a message indicating process termination to the window
 300     ::SendMessage(data->hWnd, wxWM_PROC_TERMINATED, 0, (LPARAM)data);
 301
 302     return 0;
 303 }
 304
 305 // window procedure of a hidden window which is created just to receive
 306 // the notification message when a process exits
 307 LRESULT APIENTRY _EXPORT wxExecuteWindowCbk(HWND hWnd, UINT message,
 308                                             WPARAM wParam, LPARAM lParam)
 309 {
 310     if ( message == wxWM_PROC_TERMINATED )
 311     {
 312         DestroyWindow(hWnd);    // we don't need it any more
 313
 314         wxExecuteData * const data = (wxExecuteData *)lParam;
 315         if ( data->handler )
 316         {
 317             data->handler->OnTerminate((int)data->dwProcessId,
 318                                        (int)data->dwExitCode);
 319         }
 320
 321         if ( data->state )
 322         {
 323             // we're executing synchronously, tell the waiting thread
 324             // that the process finished
 325             data->state = 0;
 326         }
 327         else
 328         {
 329             // asynchronous execution - we should do the clean up
 330             delete data;
 331         }
 332
 333         return 0;
 334     }
 335     else
 336     {
 337         return ::DefWindowProc(hWnd, message, wParam, lParam);
 338     }
 339 }
 340
 341 // ============================================================================
 342 // implementation of IO redirection support classes
 343 // ============================================================================
 344
 345 #if wxUSE_STREAMS && !defined(__WXWINCE__)
 346
 347 // ----------------------------------------------------------------------------
 348 // wxPipeInputStreams
 349 // ----------------------------------------------------------------------------
 350
 351 wxPipeInputStream::wxPipeInputStream(HANDLE hInput)
 352 {
 353     m_hInput = hInput;
 354 }
 355
 356 wxPipeInputStream::~wxPipeInputStream()
 357 {
 358     if ( m_hInput != INVALID_HANDLE_VALUE )
 359         ::CloseHandle(m_hInput);
 360 }
 361
 362 bool wxPipeInputStream::CanRead() const
 363 {
 364     if ( !IsOpened() )
 365         return false;
 366
 367     DWORD nAvailable;
 368
 369     // function name is misleading, it works with anon pipes as well
 370     DWORD rc = ::PeekNamedPipe
 371                     (
 372                       m_hInput,     // handle
 373                       NULL, 0,      // ptr to buffer and its size
 374                       NULL,         // [out] bytes read
 375                       &nAvailable,  // [out] bytes available
 376                       NULL          // [out] bytes left
 377                     );
 378
 379     if ( !rc )
 380     {
 381         if ( ::GetLastError() != ERROR_BROKEN_PIPE )
 382         {
 383             // unexpected error
 384             wxLogLastError(_T("PeekNamedPipe"));
 385         }
 386
 387         // don't try to continue reading from a pipe if an error occured or if
 388         // it had been closed
 389         ::CloseHandle(m_hInput);
 390
 391         wxPipeInputStream *self = wxConstCast(this, wxPipeInputStream);
 392
 393         self->m_hInput = INVALID_HANDLE_VALUE;
 394         self->m_lasterror = wxSTREAM_EOF;
 395
 396         nAvailable = 0;
 397     }
 398
 399     return nAvailable != 0;
 400 }
 401
 402 size_t wxPipeInputStream::OnSysRead(void *buffer, size_t len)
 403 {
 404     if ( !IsOpened() )
 405     {
 406         m_lasterror = wxSTREAM_EOF;
 407
 408         return 0;
 409     }
 410
 411     DWORD bytesRead;
 412     if ( !::ReadFile(m_hInput, buffer, len, &bytesRead, NULL) )
 413     {
 414         m_lasterror = ::GetLastError() == ERROR_BROKEN_PIPE
 415                         ? wxSTREAM_EOF
 416                         : wxSTREAM_READ_ERROR;
 417     }
 418
 419     // bytesRead is set to 0, as desired, if an error occured
 420     return bytesRead;
 421 }
 422
 423 // ----------------------------------------------------------------------------
 424 // wxPipeOutputStream
 425 // ----------------------------------------------------------------------------
 426
 427 wxPipeOutputStream::wxPipeOutputStream(HANDLE hOutput)
 428 {
 429     m_hOutput = hOutput;
 430
 431     // unblock the pipe to prevent deadlocks when we're writing to the pipe
 432     // from which the child process can't read because it is writing in its own
 433     // end of it
 434     DWORD mode = PIPE_READMODE_BYTE | PIPE_NOWAIT;
 435     if ( !::SetNamedPipeHandleState
 436             (
 437                 m_hOutput,
 438                 &mode,
 439                 NULL,       // collection count (we don't set it)
 440                 NULL        // timeout (we don't set it neither)
 441             ) )
 442     {
 443         wxLogLastError(_T("SetNamedPipeHandleState(PIPE_NOWAIT)"));
 444     }
 445 }
 446
 447 wxPipeOutputStream::~wxPipeOutputStream()
 448 {
 449     ::CloseHandle(m_hOutput);
 450 }
 451
 452 size_t wxPipeOutputStream::OnSysWrite(const void *buffer, size_t len)
 453 {
 454     m_lasterror = wxSTREAM_NO_ERROR;
 455
 456     DWORD totalWritten = 0;
 457     while ( len > 0 )
 458     {
 459         DWORD chunkWritten;
 460         if ( !::WriteFile(m_hOutput, buffer, len, &chunkWritten, NULL) )
 461         {
 462             m_lasterror = ::GetLastError() == ERROR_BROKEN_PIPE
 463                                 ? wxSTREAM_EOF
 464                                 : wxSTREAM_WRITE_ERROR;
 465             break;
 466         }
 467
 468         if ( !chunkWritten )
 469             break;
 470
 471         buffer = (char *)buffer + chunkWritten;
 472         totalWritten += chunkWritten;
 473         len -= chunkWritten;
 474     }
 475
 476     return totalWritten;
 477 }
 478
 479 #endif // wxUSE_STREAMS
 480
 481 // ============================================================================
 482 // wxExecute functions family
 483 // ============================================================================
 484
 485 #if wxUSE_IPC
 486
 487 // connect to the given server via DDE and ask it to execute the command
 488 static bool wxExecuteDDE(const wxString& ddeServer,
 489                          const wxString& ddeTopic,
 490                          const wxString& ddeCommand)
 491 {
 492     bool ok wxDUMMY_INITIALIZE(false);
 493
 494     wxDDEClient client;
 495     wxConnectionBase *conn = client.MakeConnection(wxEmptyString,
 496                                                    ddeServer,
 497                                                    ddeTopic);
 498     if ( !conn )
 499     {
 500         ok = false;
 501     }
 502     else // connected to DDE server
 503     {
 504         // the added complication here is that although most programs use
 505         // XTYP_EXECUTE for their DDE API, some important ones -- like Word
 506         // and other MS stuff - use XTYP_REQUEST!
 507         //
 508         // moreover, anotheri mportant program (IE) understands both but
 509         // returns an error from Execute() so we must try Request() first
 510         // to avoid doing it twice
 511         {
 512             // we're prepared for this one to fail, so don't show errors
 513             wxLogNull noErrors;
 514
 515             ok = conn->Request(ddeCommand) != NULL;
 516         }
 517
 518         if ( !ok )
 519         {
 520             // now try execute -- but show the errors
 521             ok = conn->Execute(ddeCommand);
 522         }
 523     }
 524
 525     return ok;
 526 }
 527
 528 #endif // wxUSE_IPC
 529
 530 long wxExecute(const wxString& cmd, int flags, wxProcess *handler)
 531 {
 532     wxCHECK_MSG( !cmd.IsEmpty(), 0, wxT("empty command in wxExecute") );
 533
 534 #if wxUSE_THREADS
 535     // for many reasons, the code below breaks down if it's called from another
 536     // thread -- this could be fixed, but as Unix versions don't support this
 537     // neither I don't want to waste time on this now
 538     wxASSERT_MSG( wxThread::IsMain(),
 539                     _T("wxExecute() can be called only from the main thread") );
 540 #endif // wxUSE_THREADS
 541
 542     wxString command;
 543
 544 #if wxUSE_IPC
 545     // DDE hack: this is really not pretty, but we need to allow this for
 546     // transparent handling of DDE servers in wxMimeTypesManager. Usually it
 547     // returns the command which should be run to view/open/... a file of the
 548     // given type. Sometimes, however, this command just launches the server
 549     // and an additional DDE request must be made to really open the file. To
 550     // keep all this well hidden from the application, we allow a special form
 551     // of command: WX_DDE#<command>#DDE_SERVER#DDE_TOPIC#DDE_COMMAND in which
 552     // case we execute just <command> and process the rest below
 553     wxString ddeServer, ddeTopic, ddeCommand;
 554     static const size_t lenDdePrefix = 7;   // strlen("WX_DDE:")
 555     if ( cmd.Left(lenDdePrefix) == _T("WX_DDE#") )
 556     {
 557         // speed up the concatenations below
 558         ddeServer.reserve(256);
 559         ddeTopic.reserve(256);
 560         ddeCommand.reserve(256);
 561
 562         const wxChar *p = cmd.c_str() + 7;
 563         while ( *p && *p != _T('#') )
 564         {
 565             command += *p++;
 566         }
 567
 568         if ( *p )
 569         {
 570             // skip '#'
 571             p++;
 572         }
 573         else
 574         {
 575             wxFAIL_MSG(_T("invalid WX_DDE command in wxExecute"));
 576         }
 577
 578         while ( *p && *p != _T('#') )
 579         {
 580             ddeServer += *p++;
 581         }
 582
 583         if ( *p )
 584         {
 585             // skip '#'
 586             p++;
 587         }
 588         else
 589         {
 590             wxFAIL_MSG(_T("invalid WX_DDE command in wxExecute"));
 591         }
 592
 593         while ( *p && *p != _T('#') )
 594         {
 595             ddeTopic += *p++;
 596         }
 597
 598         if ( *p )
 599         {
 600             // skip '#'
 601             p++;
 602         }
 603         else
 604         {
 605             wxFAIL_MSG(_T("invalid WX_DDE command in wxExecute"));
 606         }
 607
 608         while ( *p )
 609         {
 610             ddeCommand += *p++;
 611         }
 612
 613         // if we want to just launch the program and not wait for its
 614         // termination, try to execute DDE command right now, it can succeed if
 615         // the process is already running - but as it fails if it's not
 616         // running, suppress any errors it might generate
 617         if ( !(flags & wxEXEC_SYNC) )
 618         {
 619             wxLogNull noErrors;
 620             if ( wxExecuteDDE(ddeServer, ddeTopic, ddeCommand) )
 621             {
 622                 // a dummy PID - this is a hack, of course, but it's well worth
 623                 // it as we don't open a new server each time we're called
 624                 // which would be quite bad
 625                 return -1;
 626             }
 627         }
 628     }
 629     else
 630 #endif // wxUSE_IPC
 631     {
 632         // no DDE
 633         command = cmd;
 634     }
 635
 636     // the IO redirection is only supported with wxUSE_STREAMS
 637     BOOL redirect = FALSE;
 638
 639 #if wxUSE_STREAMS && !defined(__WXWINCE__)
 640     wxPipe pipeIn, pipeOut, pipeErr;
 641
 642     // we'll save here the copy of pipeIn[Write]
 643     HANDLE hpipeStdinWrite = INVALID_HANDLE_VALUE;
 644
 645     // open the pipes to which child process IO will be redirected if needed
 646     if ( handler && handler->IsRedirected() )
 647     {
 648         // create pipes for redirecting stdin, stdout and stderr
 649         if ( !pipeIn.Create() || !pipeOut.Create() || !pipeErr.Create() )
 650         {
 651             wxLogSysError(_("Failed to redirect the child process IO"));
 652
 653             // indicate failure: we need to return different error code
 654             // depending on the sync flag
 655             return flags & wxEXEC_SYNC ? -1 : 0;
 656         }
 657
 658         redirect = TRUE;
 659     }
 660 #endif // wxUSE_STREAMS
 661
 662     // create the process
 663     STARTUPINFO si;
 664     wxZeroMemory(si);
 665     si.cb = sizeof(si);
 666
 667 #if wxUSE_STREAMS && !defined(__WXWINCE__)
 668     if ( redirect )
 669     {
 670         si.dwFlags = STARTF_USESTDHANDLES;
 671
 672         si.hStdInput = pipeIn[wxPipe::Read];
 673         si.hStdOutput = pipeOut[wxPipe::Write];
 674         si.hStdError = pipeErr[wxPipe::Write];
 675
 676         // when the std IO is redirected, we don't show the (console) process
 677         // window by default, but this can be overridden by the caller by
 678         // specifying wxEXEC_NOHIDE flag
 679         if ( !(flags & wxEXEC_NOHIDE) )
 680         {
 681             si.dwFlags |= STARTF_USESHOWWINDOW;
 682             si.wShowWindow = SW_HIDE;
 683         }
 684
 685         // we must duplicate the handle to the write side of stdin pipe to make
 686         // it non inheritable: indeed, we must close the writing end of pipeIn
 687         // before launching the child process as otherwise this handle will be
 688         // inherited by the child which will never close it and so the pipe
 689         // will never be closed and the child will be left stuck in ReadFile()
 690         HANDLE pipeInWrite = pipeIn.Detach(wxPipe::Write);
 691         if ( !::DuplicateHandle
 692                 (
 693                     ::GetCurrentProcess(),
 694                     pipeInWrite,
 695                     ::GetCurrentProcess(),
 696                     &hpipeStdinWrite,
 697                     0,                      // desired access: unused here
 698                     FALSE,                  // not inherited
 699                     DUPLICATE_SAME_ACCESS   // same access as for src handle
 700                 ) )
 701         {
 702             wxLogLastError(_T("DuplicateHandle"));
 703         }
 704
 705         ::CloseHandle(pipeInWrite);
 706     }
 707 #endif // wxUSE_STREAMS
 708
 709     PROCESS_INFORMATION pi;
 710     DWORD dwFlags = CREATE_SUSPENDED;
 711 #ifndef __WXWINCE__
 712     dwFlags |= CREATE_DEFAULT_ERROR_MODE ;
 713 #endif
 714
 715     bool ok = ::CreateProcess
 716                 (
 717                  NULL,              // application name (use only cmd line)
 718                  (wxChar *)
 719                  command.c_str(),   // full command line
 720                  NULL,              // security attributes: defaults for both
 721                  NULL,              //   the process and its main thread
 722                  redirect,          // inherit handles if we use pipes
 723                  dwFlags,           // process creation flags
 724                  NULL,              // environment (use the same)
 725                  NULL,              // current directory (use the same)
 726                  &si,               // startup info (unused here)
 727                  &pi                // process info
 728                 ) != 0;
 729
 730 #if wxUSE_STREAMS && !defined(__WXWINCE__)
 731     // we can close the pipe ends used by child anyhow
 732     if ( redirect )
 733     {
 734         ::CloseHandle(pipeIn.Detach(wxPipe::Read));
 735         ::CloseHandle(pipeOut.Detach(wxPipe::Write));
 736         ::CloseHandle(pipeErr.Detach(wxPipe::Write));
 737     }
 738 #endif // wxUSE_STREAMS
 739
 740     if ( !ok )
 741     {
 742 #if wxUSE_STREAMS && !defined(__WXWINCE__)
 743         // close the other handles too
 744         if ( redirect )
 745         {
 746             ::CloseHandle(pipeOut.Detach(wxPipe::Read));
 747             ::CloseHandle(pipeErr.Detach(wxPipe::Read));
 748         }
 749 #endif // wxUSE_STREAMS
 750
 751         wxLogSysError(_("Execution of command '%s' failed"), command.c_str());
 752
 753         return flags & wxEXEC_SYNC ? -1 : 0;
 754     }
 755
 756 #if wxUSE_STREAMS && !defined(__WXWINCE__)
 757     // the input buffer bufOut is connected to stdout, this is why it is
 758     // called bufOut and not bufIn
 759     wxStreamTempInputBuffer bufOut,
 760                             bufErr;
 761
 762     if ( redirect )
 763     {
 764         // We can now initialize the wxStreams
 765         wxPipeInputStream *
 766             outStream = new wxPipeInputStream(pipeOut.Detach(wxPipe::Read));
 767         wxPipeInputStream *
 768             errStream = new wxPipeInputStream(pipeErr.Detach(wxPipe::Read));
 769         wxPipeOutputStream *
 770             inStream = new wxPipeOutputStream(hpipeStdinWrite);
 771
 772         handler->SetPipeStreams(outStream, inStream, errStream);
 773
 774         bufOut.Init(outStream);
 775         bufErr.Init(errStream);
 776     }
 777 #endif // wxUSE_STREAMS
 778
 779     // create a hidden window to receive notification about process
 780     // termination
 781     HWND hwnd = wxCreateHiddenWindow
 782                 (
 783                     &gs_classForHiddenWindow,
 784                     wxMSWEXEC_WNDCLASSNAME,
 785                     (WNDPROC)wxExecuteWindowCbk
 786                 );
 787
 788     wxASSERT_MSG( hwnd, wxT("can't create a hidden window for wxExecute") );
 789
 790     // Alloc data
 791     wxExecuteData *data = new wxExecuteData;
 792     data->hProcess    = pi.hProcess;
 793     data->dwProcessId = pi.dwProcessId;
 794     data->hWnd        = hwnd;
 795     data->state       = (flags & wxEXEC_SYNC) != 0;
 796     if ( flags & wxEXEC_SYNC )
 797     {
 798         // handler may be !NULL for capturing program output, but we don't use
 799         // it wxExecuteData struct in this case
 800         data->handler = NULL;
 801     }
 802     else
 803     {
 804         // may be NULL or not
 805         data->handler = handler;
 806     }
 807
 808     DWORD tid;
 809     HANDLE hThread = ::CreateThread(NULL,
 810                                     0,
 811                                     wxExecuteThread,
 812                                     (void *)data,
 813                                     0,
 814                                     &tid);
 815
 816     // resume process we created now - whether the thread creation succeeded or
 817     // not
 818     if ( ::ResumeThread(pi.hThread) == (DWORD)-1 )
 819     {
 820         // ignore it - what can we do?
 821         wxLogLastError(wxT("ResumeThread in wxExecute"));
 822     }
 823
 824     // close unneeded handle
 825     if ( !::CloseHandle(pi.hThread) )
 826         wxLogLastError(wxT("CloseHandle(hThread)"));
 827
 828     if ( !hThread )
 829     {
 830         wxLogLastError(wxT("CreateThread in wxExecute"));
 831
 832         DestroyWindow(hwnd);
 833         delete data;
 834
 835         // the process still started up successfully...
 836         return pi.dwProcessId;
 837     }
 838
 839     ::CloseHandle(hThread);
 840
 841 #if wxUSE_IPC && !defined(__WXWINCE__)
 842     // second part of DDE hack: now establish the DDE conversation with the
 843     // just launched process
 844     if ( !ddeServer.empty() )
 845     {
 846         bool ok;
 847
 848         // give the process the time to init itself
 849         //
 850         // we use a very big timeout hoping that WaitForInputIdle() will return
 851         // much sooner, but not INFINITE just in case the process hangs
 852         // completely - like this we will regain control sooner or later
 853         switch ( ::WaitForInputIdle(pi.hProcess, 10000 /* 10 seconds */) )
 854         {
 855             default:
 856                 wxFAIL_MSG( _T("unexpected WaitForInputIdle() return code") );
 857                 // fall through
 858
 859             case -1:
 860                 wxLogLastError(_T("WaitForInputIdle() in wxExecute"));
 861
 862             case WAIT_TIMEOUT:
 863                 wxLogDebug(_T("Timeout too small in WaitForInputIdle"));
 864
 865                 ok = false;
 866                 break;
 867
 868             case 0:
 869                 // ok, process ready to accept DDE requests
 870                 ok = wxExecuteDDE(ddeServer, ddeTopic, ddeCommand);
 871         }
 872
 873         if ( !ok )
 874         {
 875             wxLogDebug(_T("Failed to send DDE request to the process \"%s\"."),
 876                        cmd.c_str());
 877         }
 878     }
 879 #endif // wxUSE_IPC
 880
 881     if ( !(flags & wxEXEC_SYNC) )
 882     {
 883         // clean up will be done when the process terminates
 884
 885         // return the pid
 886         return pi.dwProcessId;
 887     }
 888
 889     wxAppTraits *traits = wxTheApp ? wxTheApp->GetTraits() : NULL;
 890     wxCHECK_MSG( traits, -1, _T("no wxAppTraits in wxExecute()?") );
 891
 892     // disable all app windows while waiting for the child process to finish
 893     void *cookie = traits->BeforeChildWaitLoop();
 894
 895     // wait until the child process terminates
 896     while ( data->state )
 897     {
 898 #if wxUSE_STREAMS && !defined(__WXWINCE__)
 899         bufOut.Update();
 900         bufErr.Update();
 901 #endif // wxUSE_STREAMS
 902
 903         // don't eat 100% of the CPU -- ugly but anything else requires
 904         // real async IO which we don't have for the moment
 905         ::Sleep(50);
 906
 907         // we must process messages or we'd never get wxWM_PROC_TERMINATED
 908         traits->AlwaysYield();
 909     }
 910
 911     traits->AfterChildWaitLoop(cookie);
 912
 913     DWORD dwExitCode = data->dwExitCode;
 914     delete data;
 915
 916     // return the exit code
 917     return dwExitCode;
 918 }
 919
 920 long wxExecute(wxChar **argv, int flags, wxProcess *handler)
 921 {
 922     wxString command;
 923
 924     for ( ;; )
 925     {
 926         command += *argv++;
 927         if ( !*argv )
 928             break;
 929
 930         command += _T(' ');
 931     }
 932
 933     return wxExecute(command, flags, handler);
 934 }
 935