]> git.saurik.com Git - wxWidgets.git/blame_incremental - src/msw/utilsexc.cpp
Unhide problem of ambiguity in wxSoundBase::Play.
[wxWidgets.git] / src / msw / utilsexc.cpp
... / ...
CommitLineData
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
86extern "C" WXDLLIMPEXP_BASE HWND
87wxCreateHiddenWindow(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
103static const wxChar *wxMSWEXEC_WNDCLASSNAME = wxT("_wxExecute_Internal_Class");
104static const wxChar *gs_classForHiddenWindow = NULL;
105
106// ----------------------------------------------------------------------------
107// private types
108// ----------------------------------------------------------------------------
109
110// structure describing the process we're being waiting for
111struct wxExecuteData
112{
113public:
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
130class wxExecuteModule : public wxModule
131{
132public:
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
147private:
148 DECLARE_DYNAMIC_CLASS(wxExecuteModule)
149};
150
151#if wxUSE_STREAMS && !defined(__WXWINCE__)
152
153// ----------------------------------------------------------------------------
154// wxPipeStreams
155// ----------------------------------------------------------------------------
156
157class wxPipeInputStream: public wxInputStream
158{
159public:
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
169protected:
170 size_t OnSysRead(void *buffer, size_t len);
171
172protected:
173 HANDLE m_hInput;
174
175 DECLARE_NO_COPY_CLASS(wxPipeInputStream)
176};
177
178class wxPipeOutputStream: public wxOutputStream
179{
180public:
181 wxPipeOutputStream(HANDLE hOutput);
182 virtual ~wxPipeOutputStream();
183
184protected:
185 size_t OnSysWrite(const void *buffer, size_t len);
186
187protected:
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
201class wxPipe
202{
203public:
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
239 {
240 wxASSERT_MSG( which >= 0 && (size_t)which < WXSIZEOF(m_handles),
241 _T("invalid pipe index") );
242
243 return m_handles[which];
244 }
245
246 // detach a descriptor, meaning that the pipe dtor won't close it, and
247 // return it
248 HANDLE Detach(Direction which)
249 {
250 wxASSERT_MSG( which >= 0 && (size_t)which < WXSIZEOF(m_handles),
251 _T("invalid pipe index") );
252
253 HANDLE handle = m_handles[which];
254 m_handles[which] = INVALID_HANDLE_VALUE;
255
256 return handle;
257 }
258
259 // close the pipe descriptors
260 void Close()
261 {
262 for ( size_t n = 0; n < WXSIZEOF(m_handles); n++ )
263 {
264 if ( m_handles[n] != INVALID_HANDLE_VALUE )
265 {
266 ::CloseHandle(m_handles[n]);
267 m_handles[n] = INVALID_HANDLE_VALUE;
268 }
269 }
270 }
271
272 // dtor closes the pipe descriptors
273 ~wxPipe() { Close(); }
274
275private:
276 HANDLE m_handles[2];
277};
278
279#endif // wxUSE_STREAMS
280
281// ============================================================================
282// implementation
283// ============================================================================
284
285// ----------------------------------------------------------------------------
286// process termination detecting support
287// ----------------------------------------------------------------------------
288
289// thread function for the thread monitoring the process termination
290static DWORD __stdcall wxExecuteThread(void *arg)
291{
292 wxExecuteData * const data = (wxExecuteData *)arg;
293
294 if ( ::WaitForSingleObject(data->hProcess, INFINITE) != WAIT_OBJECT_0 )
295 {
296 wxLogDebug(_T("Waiting for the process termination failed!"));
297 }
298
299 // get the exit code
300 if ( !::GetExitCodeProcess(data->hProcess, &data->dwExitCode) )
301 {
302 wxLogLastError(wxT("GetExitCodeProcess"));
303 }
304
305 wxASSERT_MSG( data->dwExitCode != STILL_ACTIVE,
306 wxT("process should have terminated") );
307
308 // send a message indicating process termination to the window
309 ::SendMessage(data->hWnd, wxWM_PROC_TERMINATED, 0, (LPARAM)data);
310
311 return 0;
312}
313
314// window procedure of a hidden window which is created just to receive
315// the notification message when a process exits
316LRESULT APIENTRY _EXPORT wxExecuteWindowCbk(HWND hWnd, UINT message,
317 WPARAM wParam, LPARAM lParam)
318{
319 if ( message == wxWM_PROC_TERMINATED )
320 {
321 DestroyWindow(hWnd); // we don't need it any more
322
323 wxExecuteData * const data = (wxExecuteData *)lParam;
324 if ( data->handler )
325 {
326 data->handler->OnTerminate((int)data->dwProcessId,
327 (int)data->dwExitCode);
328 }
329
330 if ( data->state )
331 {
332 // we're executing synchronously, tell the waiting thread
333 // that the process finished
334 data->state = 0;
335 }
336 else
337 {
338 // asynchronous execution - we should do the clean up
339 delete data;
340 }
341
342 return 0;
343 }
344 else
345 {
346 return ::DefWindowProc(hWnd, message, wParam, lParam);
347 }
348}
349
350// ============================================================================
351// implementation of IO redirection support classes
352// ============================================================================
353
354#if wxUSE_STREAMS && !defined(__WXWINCE__)
355
356// ----------------------------------------------------------------------------
357// wxPipeInputStreams
358// ----------------------------------------------------------------------------
359
360wxPipeInputStream::wxPipeInputStream(HANDLE hInput)
361{
362 m_hInput = hInput;
363}
364
365wxPipeInputStream::~wxPipeInputStream()
366{
367 if ( m_hInput != INVALID_HANDLE_VALUE )
368 ::CloseHandle(m_hInput);
369}
370
371bool wxPipeInputStream::CanRead() const
372{
373 if ( !IsOpened() )
374 return FALSE;
375
376 DWORD nAvailable;
377
378 // function name is misleading, it works with anon pipes as well
379 DWORD rc = ::PeekNamedPipe
380 (
381 m_hInput, // handle
382 NULL, 0, // ptr to buffer and its size
383 NULL, // [out] bytes read
384 &nAvailable, // [out] bytes available
385 NULL // [out] bytes left
386 );
387
388 if ( !rc )
389 {
390 if ( ::GetLastError() != ERROR_BROKEN_PIPE )
391 {
392 // unexpected error
393 wxLogLastError(_T("PeekNamedPipe"));
394 }
395
396 // don't try to continue reading from a pipe if an error occured or if
397 // it had been closed
398 ::CloseHandle(m_hInput);
399
400 wxPipeInputStream *self = wxConstCast(this, wxPipeInputStream);
401
402 self->m_hInput = INVALID_HANDLE_VALUE;
403 self->m_lasterror = wxSTREAM_EOF;
404
405 nAvailable = 0;
406 }
407
408 return nAvailable != 0;
409}
410
411size_t wxPipeInputStream::OnSysRead(void *buffer, size_t len)
412{
413 if ( !IsOpened() )
414 {
415 m_lasterror = wxSTREAM_EOF;
416
417 return 0;
418 }
419
420 DWORD bytesRead;
421 if ( !::ReadFile(m_hInput, buffer, len, &bytesRead, NULL) )
422 {
423 m_lasterror = ::GetLastError() == ERROR_BROKEN_PIPE
424 ? wxSTREAM_EOF
425 : wxSTREAM_READ_ERROR;
426 }
427
428 // bytesRead is set to 0, as desired, if an error occured
429 return bytesRead;
430}
431
432// ----------------------------------------------------------------------------
433// wxPipeOutputStream
434// ----------------------------------------------------------------------------
435
436wxPipeOutputStream::wxPipeOutputStream(HANDLE hOutput)
437{
438 m_hOutput = hOutput;
439}
440
441wxPipeOutputStream::~wxPipeOutputStream()
442{
443 ::CloseHandle(m_hOutput);
444}
445
446size_t wxPipeOutputStream::OnSysWrite(const void *buffer, size_t len)
447{
448 DWORD bytesWritten;
449
450 m_lasterror = wxSTREAM_NO_ERROR;
451 if ( !::WriteFile(m_hOutput, buffer, len, &bytesWritten, NULL) )
452 {
453 m_lasterror = ::GetLastError() == ERROR_BROKEN_PIPE
454 ? wxSTREAM_EOF
455 : wxSTREAM_WRITE_ERROR;
456 }
457
458 return bytesWritten;
459}
460
461#endif // wxUSE_STREAMS
462
463// ============================================================================
464// wxExecute functions family
465// ============================================================================
466
467#if wxUSE_IPC
468
469// connect to the given server via DDE and ask it to execute the command
470static bool wxExecuteDDE(const wxString& ddeServer,
471 const wxString& ddeTopic,
472 const wxString& ddeCommand)
473{
474 bool ok wxDUMMY_INITIALIZE(false);
475
476 wxDDEClient client;
477 wxConnectionBase *conn = client.MakeConnection(wxEmptyString,
478 ddeServer,
479 ddeTopic);
480 if ( !conn )
481 {
482 ok = FALSE;
483 }
484 else // connected to DDE server
485 {
486 // the added complication here is that although most programs use
487 // XTYP_EXECUTE for their DDE API, some important ones -- like Word
488 // and other MS stuff - use XTYP_REQUEST!
489 //
490 // moreover, anotheri mportant program (IE) understands both but
491 // returns an error from Execute() so we must try Request() first
492 // to avoid doing it twice
493 {
494 // we're prepared for this one to fail, so don't show errors
495 wxLogNull noErrors;
496
497 ok = conn->Request(ddeCommand) != NULL;
498 }
499
500 if ( !ok )
501 {
502 // now try execute -- but show the errors
503 ok = conn->Execute(ddeCommand);
504 }
505 }
506
507 return ok;
508}
509
510#endif // wxUSE_IPC
511
512long wxExecute(const wxString& cmd, int flags, wxProcess *handler)
513{
514 wxCHECK_MSG( !!cmd, 0, wxT("empty command in wxExecute") );
515
516#if wxUSE_THREADS
517 // for many reasons, the code below breaks down if it's called from another
518 // thread -- this could be fixed, but as Unix versions don't support this
519 // neither I don't want to waste time on this now
520 wxASSERT_MSG( wxThread::IsMain(),
521 _T("wxExecute() can be called only from the main thread") );
522#endif // wxUSE_THREADS
523
524 wxString command;
525
526#if wxUSE_IPC
527 // DDE hack: this is really not pretty, but we need to allow this for
528 // transparent handling of DDE servers in wxMimeTypesManager. Usually it
529 // returns the command which should be run to view/open/... a file of the
530 // given type. Sometimes, however, this command just launches the server
531 // and an additional DDE request must be made to really open the file. To
532 // keep all this well hidden from the application, we allow a special form
533 // of command: WX_DDE#<command>#DDE_SERVER#DDE_TOPIC#DDE_COMMAND in which
534 // case we execute just <command> and process the rest below
535 wxString ddeServer, ddeTopic, ddeCommand;
536 static const size_t lenDdePrefix = 7; // strlen("WX_DDE:")
537 if ( cmd.Left(lenDdePrefix) == _T("WX_DDE#") )
538 {
539 // speed up the concatenations below
540 ddeServer.reserve(256);
541 ddeTopic.reserve(256);
542 ddeCommand.reserve(256);
543
544 const wxChar *p = cmd.c_str() + 7;
545 while ( *p && *p != _T('#') )
546 {
547 command += *p++;
548 }
549
550 if ( *p )
551 {
552 // skip '#'
553 p++;
554 }
555 else
556 {
557 wxFAIL_MSG(_T("invalid WX_DDE command in wxExecute"));
558 }
559
560 while ( *p && *p != _T('#') )
561 {
562 ddeServer += *p++;
563 }
564
565 if ( *p )
566 {
567 // skip '#'
568 p++;
569 }
570 else
571 {
572 wxFAIL_MSG(_T("invalid WX_DDE command in wxExecute"));
573 }
574
575 while ( *p && *p != _T('#') )
576 {
577 ddeTopic += *p++;
578 }
579
580 if ( *p )
581 {
582 // skip '#'
583 p++;
584 }
585 else
586 {
587 wxFAIL_MSG(_T("invalid WX_DDE command in wxExecute"));
588 }
589
590 while ( *p )
591 {
592 ddeCommand += *p++;
593 }
594
595 // if we want to just launch the program and not wait for its
596 // termination, try to execute DDE command right now, it can succeed if
597 // the process is already running - but as it fails if it's not
598 // running, suppress any errors it might generate
599 if ( !(flags & wxEXEC_SYNC) )
600 {
601 wxLogNull noErrors;
602 if ( wxExecuteDDE(ddeServer, ddeTopic, ddeCommand) )
603 {
604 // a dummy PID - this is a hack, of course, but it's well worth
605 // it as we don't open a new server each time we're called
606 // which would be quite bad
607 return -1;
608 }
609 }
610 }
611 else
612#endif // wxUSE_IPC
613 {
614 // no DDE
615 command = cmd;
616 }
617
618 // the IO redirection is only supported with wxUSE_STREAMS
619 BOOL redirect = FALSE;
620
621#if wxUSE_STREAMS && !defined(__WXWINCE__)
622 wxPipe pipeIn, pipeOut, pipeErr;
623
624 // we'll save here the copy of pipeIn[Write]
625 HANDLE hpipeStdinWrite = INVALID_HANDLE_VALUE;
626
627 // open the pipes to which child process IO will be redirected if needed
628 if ( handler && handler->IsRedirected() )
629 {
630 // create pipes for redirecting stdin, stdout and stderr
631 if ( !pipeIn.Create() || !pipeOut.Create() || !pipeErr.Create() )
632 {
633 wxLogSysError(_("Failed to redirect the child process IO"));
634
635 // indicate failure: we need to return different error code
636 // depending on the sync flag
637 return flags & wxEXEC_SYNC ? -1 : 0;
638 }
639
640 redirect = TRUE;
641 }
642#endif // wxUSE_STREAMS
643
644 // create the process
645 STARTUPINFO si;
646 wxZeroMemory(si);
647 si.cb = sizeof(si);
648
649#if wxUSE_STREAMS && !defined(__WXWINCE__)
650 if ( redirect )
651 {
652 si.dwFlags = STARTF_USESTDHANDLES;
653
654 si.hStdInput = pipeIn[wxPipe::Read];
655 si.hStdOutput = pipeOut[wxPipe::Write];
656 si.hStdError = pipeErr[wxPipe::Write];
657
658 // when the std IO is redirected, we don't show the (console) process
659 // window by default, but this can be overridden by the caller by
660 // specifying wxEXEC_NOHIDE flag
661 if ( !(flags & wxEXEC_NOHIDE) )
662 {
663 si.dwFlags |= STARTF_USESHOWWINDOW;
664 si.wShowWindow = SW_HIDE;
665 }
666
667 // we must duplicate the handle to the write side of stdin pipe to make
668 // it non inheritable: indeed, we must close the writing end of pipeIn
669 // before launching the child process as otherwise this handle will be
670 // inherited by the child which will never close it and so the pipe
671 // will never be closed and the child will be left stuck in ReadFile()
672 HANDLE pipeInWrite = pipeIn.Detach(wxPipe::Write);
673 if ( !::DuplicateHandle
674 (
675 ::GetCurrentProcess(),
676 pipeInWrite,
677 ::GetCurrentProcess(),
678 &hpipeStdinWrite,
679 0, // desired access: unused here
680 FALSE, // not inherited
681 DUPLICATE_SAME_ACCESS // same access as for src handle
682 ) )
683 {
684 wxLogLastError(_T("DuplicateHandle"));
685 }
686
687 ::CloseHandle(pipeInWrite);
688 }
689#endif // wxUSE_STREAMS
690
691 PROCESS_INFORMATION pi;
692 DWORD dwFlags = CREATE_SUSPENDED;
693#ifndef __WXWINCE__
694 dwFlags |= CREATE_DEFAULT_ERROR_MODE ;
695#endif
696
697 bool ok = ::CreateProcess
698 (
699 NULL, // application name (use only cmd line)
700 (wxChar *)
701 command.c_str(), // full command line
702 NULL, // security attributes: defaults for both
703 NULL, // the process and its main thread
704 redirect, // inherit handles if we use pipes
705 dwFlags, // process creation flags
706 NULL, // environment (use the same)
707 NULL, // current directory (use the same)
708 &si, // startup info (unused here)
709 &pi // process info
710 ) != 0;
711
712#if wxUSE_STREAMS && !defined(__WXWINCE__)
713 // we can close the pipe ends used by child anyhow
714 if ( redirect )
715 {
716 ::CloseHandle(pipeIn.Detach(wxPipe::Read));
717 ::CloseHandle(pipeOut.Detach(wxPipe::Write));
718 ::CloseHandle(pipeErr.Detach(wxPipe::Write));
719 }
720#endif // wxUSE_STREAMS
721
722 if ( !ok )
723 {
724#if wxUSE_STREAMS && !defined(__WXWINCE__)
725 // close the other handles too
726 if ( redirect )
727 {
728 ::CloseHandle(pipeOut.Detach(wxPipe::Read));
729 ::CloseHandle(pipeErr.Detach(wxPipe::Read));
730 }
731#endif // wxUSE_STREAMS
732
733 wxLogSysError(_("Execution of command '%s' failed"), command.c_str());
734
735 return flags & wxEXEC_SYNC ? -1 : 0;
736 }
737
738#if wxUSE_STREAMS && !defined(__WXWINCE__)
739 // the input buffer bufOut is connected to stdout, this is why it is
740 // called bufOut and not bufIn
741 wxStreamTempInputBuffer bufOut,
742 bufErr;
743
744 if ( redirect )
745 {
746 // We can now initialize the wxStreams
747 wxPipeInputStream *
748 outStream = new wxPipeInputStream(pipeOut.Detach(wxPipe::Read));
749 wxPipeInputStream *
750 errStream = new wxPipeInputStream(pipeErr.Detach(wxPipe::Read));
751 wxPipeOutputStream *
752 inStream = new wxPipeOutputStream(hpipeStdinWrite);
753
754 handler->SetPipeStreams(outStream, inStream, errStream);
755
756 bufOut.Init(outStream);
757 bufErr.Init(errStream);
758 }
759#endif // wxUSE_STREAMS
760
761 // create a hidden window to receive notification about process
762 // termination
763 HWND hwnd = wxCreateHiddenWindow
764 (
765 &gs_classForHiddenWindow,
766 wxMSWEXEC_WNDCLASSNAME,
767 (WNDPROC)wxExecuteWindowCbk
768 );
769
770 wxASSERT_MSG( hwnd, wxT("can't create a hidden window for wxExecute") );
771
772 // Alloc data
773 wxExecuteData *data = new wxExecuteData;
774 data->hProcess = pi.hProcess;
775 data->dwProcessId = pi.dwProcessId;
776 data->hWnd = hwnd;
777 data->state = (flags & wxEXEC_SYNC) != 0;
778 if ( flags & wxEXEC_SYNC )
779 {
780 // handler may be !NULL for capturing program output, but we don't use
781 // it wxExecuteData struct in this case
782 data->handler = NULL;
783 }
784 else
785 {
786 // may be NULL or not
787 data->handler = handler;
788 }
789
790 DWORD tid;
791 HANDLE hThread = ::CreateThread(NULL,
792 0,
793 wxExecuteThread,
794 (void *)data,
795 0,
796 &tid);
797
798 // resume process we created now - whether the thread creation succeeded or
799 // not
800 if ( ::ResumeThread(pi.hThread) == (DWORD)-1 )
801 {
802 // ignore it - what can we do?
803 wxLogLastError(wxT("ResumeThread in wxExecute"));
804 }
805
806 // close unneeded handle
807 if ( !::CloseHandle(pi.hThread) )
808 wxLogLastError(wxT("CloseHandle(hThread)"));
809
810 if ( !hThread )
811 {
812 wxLogLastError(wxT("CreateThread in wxExecute"));
813
814 DestroyWindow(hwnd);
815 delete data;
816
817 // the process still started up successfully...
818 return pi.dwProcessId;
819 }
820
821 ::CloseHandle(hThread);
822
823#if wxUSE_IPC && !defined(__WXWINCE__)
824 // second part of DDE hack: now establish the DDE conversation with the
825 // just launched process
826 if ( !ddeServer.empty() )
827 {
828 bool ok;
829
830 // give the process the time to init itself
831 //
832 // we use a very big timeout hoping that WaitForInputIdle() will return
833 // much sooner, but not INFINITE just in case the process hangs
834 // completely - like this we will regain control sooner or later
835 switch ( ::WaitForInputIdle(pi.hProcess, 10000 /* 10 seconds */) )
836 {
837 default:
838 wxFAIL_MSG( _T("unexpected WaitForInputIdle() return code") );
839 // fall through
840
841 case -1:
842 wxLogLastError(_T("WaitForInputIdle() in wxExecute"));
843
844 case WAIT_TIMEOUT:
845 wxLogDebug(_T("Timeout too small in WaitForInputIdle"));
846
847 ok = FALSE;
848 break;
849
850 case 0:
851 // ok, process ready to accept DDE requests
852 ok = wxExecuteDDE(ddeServer, ddeTopic, ddeCommand);
853 }
854
855 if ( !ok )
856 {
857 wxLogDebug(_T("Failed to send DDE request to the process \"%s\"."),
858 cmd.c_str());
859 }
860 }
861#endif // wxUSE_IPC
862
863 if ( !(flags & wxEXEC_SYNC) )
864 {
865 // clean up will be done when the process terminates
866
867 // return the pid
868 return pi.dwProcessId;
869 }
870
871 wxAppTraits *traits = wxTheApp ? wxTheApp->GetTraits() : NULL;
872 wxCHECK_MSG( traits, -1, _T("no wxAppTraits in wxExecute()?") );
873
874 // disable all app windows while waiting for the child process to finish
875 void *cookie = traits->BeforeChildWaitLoop();
876
877 // wait until the child process terminates
878 while ( data->state )
879 {
880#if wxUSE_STREAMS && !defined(__WXWINCE__)
881 bufOut.Update();
882 bufErr.Update();
883#endif // wxUSE_STREAMS
884
885 // don't eat 100% of the CPU -- ugly but anything else requires
886 // real async IO which we don't have for the moment
887 ::Sleep(50);
888
889 // we must process messages or we'd never get wxWM_PROC_TERMINATED
890 traits->AlwaysYield();
891 }
892
893 traits->AfterChildWaitLoop(cookie);
894
895 DWORD dwExitCode = data->dwExitCode;
896 delete data;
897
898 // return the exit code
899 return dwExitCode;
900}
901
902long wxExecute(wxChar **argv, int flags, wxProcess *handler)
903{
904 wxString command;
905
906 for ( ;; )
907 {
908 command += *argv++;
909 if ( !*argv )
910 break;
911
912 command += _T(' ');
913 }
914
915 return wxExecute(command, flags, handler);
916}
917