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