]> git.saurik.com Git - wxWidgets.git/blob - src/unix/utilsunx.cpp
Don't generate any events from wxSpinCtrl and wxSpinCtrlDouble methods.
[wxWidgets.git] / src / unix / utilsunx.cpp
1 /////////////////////////////////////////////////////////////////////////////
2 // Name: src/unix/utilsunx.cpp
3 // Purpose: generic Unix implementation of many wx functions (for wxBase)
4 // Author: Vadim Zeitlin
5 // Copyright: (c) 1998 Robert Roebling, Vadim Zeitlin
6 // (c) 2013 Rob Bresalier, Vadim Zeitlin
7 // Licence: wxWindows licence
8 /////////////////////////////////////////////////////////////////////////////
9
10 // ============================================================================
11 // declarations
12 // ============================================================================
13
14 // ----------------------------------------------------------------------------
15 // headers
16 // ----------------------------------------------------------------------------
17
18 // for compilers that support precompilation, includes "wx.h".
19 #include "wx/wxprec.h"
20
21 #include "wx/utils.h"
22
23 #define USE_PUTENV (!defined(HAVE_SETENV) && defined(HAVE_PUTENV))
24
25 #ifndef WX_PRECOMP
26 #include "wx/string.h"
27 #include "wx/intl.h"
28 #include "wx/log.h"
29 #include "wx/app.h"
30 #include "wx/wxcrtvararg.h"
31 #if USE_PUTENV
32 #include "wx/module.h"
33 #include "wx/hashmap.h"
34 #endif
35 #endif
36
37 #include "wx/apptrait.h"
38
39 #include "wx/process.h"
40 #include "wx/scopedptr.h"
41 #include "wx/thread.h"
42
43 #include "wx/cmdline.h"
44
45 #include "wx/wfstream.h"
46
47 #include "wx/private/selectdispatcher.h"
48 #include "wx/private/fdiodispatcher.h"
49 #include "wx/unix/execute.h"
50 #include "wx/unix/pipe.h"
51 #include "wx/unix/private.h"
52
53 #include "wx/evtloop.h"
54 #include "wx/mstream.h"
55 #include "wx/private/fdioeventloopsourcehandler.h"
56
57 #include <pwd.h>
58 #include <sys/wait.h> // waitpid()
59
60 #ifdef HAVE_SYS_SELECT_H
61 # include <sys/select.h>
62 #endif
63
64 #define HAS_PIPE_STREAMS (wxUSE_STREAMS && wxUSE_FILE)
65
66 #if HAS_PIPE_STREAMS
67
68 #include "wx/private/pipestream.h"
69 #include "wx/private/streamtempinput.h"
70 #include "wx/unix/private/executeiohandler.h"
71
72 #endif // HAS_PIPE_STREAMS
73
74 // not only the statfs syscall is called differently depending on platform, but
75 // one of its incarnations, statvfs(), takes different arguments under
76 // different platforms and even different versions of the same system (Solaris
77 // 7 and 8): if you want to test for this, don't forget that the problems only
78 // appear if the large files support is enabled
79 #ifdef HAVE_STATFS
80 #ifdef __BSD__
81 #include <sys/param.h>
82 #include <sys/mount.h>
83 #else // !__BSD__
84 #include <sys/vfs.h>
85 #endif // __BSD__/!__BSD__
86
87 #define wxStatfs statfs
88
89 #ifndef HAVE_STATFS_DECL
90 // some systems lack statfs() prototype in the system headers (AIX 4)
91 extern "C" int statfs(const char *path, struct statfs *buf);
92 #endif
93 #endif // HAVE_STATFS
94
95 #ifdef HAVE_STATVFS
96 #include <sys/statvfs.h>
97
98 #define wxStatfs statvfs
99 #endif // HAVE_STATVFS
100
101 #if defined(HAVE_STATFS) || defined(HAVE_STATVFS)
102 // WX_STATFS_T is detected by configure
103 #define wxStatfs_t WX_STATFS_T
104 #endif
105
106 // SGI signal.h defines signal handler arguments differently depending on
107 // whether _LANGUAGE_C_PLUS_PLUS is set or not - do set it
108 #if defined(__SGI__) && !defined(_LANGUAGE_C_PLUS_PLUS)
109 #define _LANGUAGE_C_PLUS_PLUS 1
110 #endif // SGI hack
111
112 #include <stdarg.h>
113 #include <dirent.h>
114 #include <string.h>
115 #include <sys/stat.h>
116 #include <sys/types.h>
117 #include <sys/wait.h>
118 #include <unistd.h>
119 #include <errno.h>
120 #include <netdb.h>
121 #include <signal.h>
122 #include <time.h> // nanosleep() and/or usleep()
123 #include <ctype.h> // isspace()
124 #include <sys/time.h> // needed for FD_SETSIZE
125
126 #ifdef HAVE_UNAME
127 #include <sys/utsname.h> // for uname()
128 #endif // HAVE_UNAME
129
130 // Used by wxGetFreeMemory().
131 #ifdef __SGI__
132 #include <sys/sysmp.h>
133 #include <sys/sysinfo.h> // for SAGET and MINFO structures
134 #endif
135
136 #ifdef HAVE_SETPRIORITY
137 #include <sys/resource.h> // for setpriority()
138 #endif
139
140 // ----------------------------------------------------------------------------
141 // conditional compilation
142 // ----------------------------------------------------------------------------
143
144 // many versions of Unices have this function, but it is not defined in system
145 // headers - please add your system here if it is the case for your OS.
146 // SunOS < 5.6 (i.e. Solaris < 2.6) and DG-UX are like this.
147 #if !defined(HAVE_USLEEP) && \
148 ((defined(__SUN__) && !defined(__SunOs_5_6) && \
149 !defined(__SunOs_5_7) && !defined(__SUNPRO_CC)) || \
150 defined(__osf__) || defined(__EMX__))
151 extern "C"
152 {
153 #ifdef __EMX__
154 /* I copied this from the XFree86 diffs. AV. */
155 #define INCL_DOSPROCESS
156 #include <os2.h>
157 inline void usleep(unsigned long delay)
158 {
159 DosSleep(delay ? (delay/1000l) : 1l);
160 }
161 #else // Unix
162 int usleep(unsigned int usec);
163 #endif // __EMX__/Unix
164 };
165
166 #define HAVE_USLEEP 1
167 #endif // Unices without usleep()
168
169 // ============================================================================
170 // implementation
171 // ============================================================================
172
173 // ----------------------------------------------------------------------------
174 // sleeping
175 // ----------------------------------------------------------------------------
176
177 void wxSleep(int nSecs)
178 {
179 sleep(nSecs);
180 }
181
182 void wxMicroSleep(unsigned long microseconds)
183 {
184 #if defined(HAVE_NANOSLEEP)
185 timespec tmReq;
186 tmReq.tv_sec = (time_t)(microseconds / 1000000);
187 tmReq.tv_nsec = (microseconds % 1000000) * 1000;
188
189 // we're not interested in remaining time nor in return value
190 (void)nanosleep(&tmReq, NULL);
191 #elif defined(HAVE_USLEEP)
192 // uncomment this if you feel brave or if you are sure that your version
193 // of Solaris has a safe usleep() function but please notice that usleep()
194 // is known to lead to crashes in MT programs in Solaris 2.[67] and is not
195 // documented as MT-Safe
196 #if defined(__SUN__) && wxUSE_THREADS
197 #error "usleep() cannot be used in MT programs under Solaris."
198 #endif // Sun
199
200 usleep(microseconds);
201 #elif defined(HAVE_SLEEP)
202 // under BeOS sleep() takes seconds (what about other platforms, if any?)
203 sleep(microseconds * 1000000);
204 #else // !sleep function
205 #error "usleep() or nanosleep() function required for wxMicroSleep"
206 #endif // sleep function
207 }
208
209 void wxMilliSleep(unsigned long milliseconds)
210 {
211 wxMicroSleep(milliseconds*1000);
212 }
213
214 // ----------------------------------------------------------------------------
215 // process management
216 // ----------------------------------------------------------------------------
217
218 int wxKill(long pid, wxSignal sig, wxKillError *rc, int flags)
219 {
220 int err = kill((pid_t) (flags & wxKILL_CHILDREN) ? -pid : pid, (int)sig);
221 if ( rc )
222 {
223 switch ( err ? errno : 0 )
224 {
225 case 0:
226 *rc = wxKILL_OK;
227 break;
228
229 case EINVAL:
230 *rc = wxKILL_BAD_SIGNAL;
231 break;
232
233 case EPERM:
234 *rc = wxKILL_ACCESS_DENIED;
235 break;
236
237 case ESRCH:
238 *rc = wxKILL_NO_PROCESS;
239 break;
240
241 default:
242 // this goes against Unix98 docs so log it
243 wxLogDebug(wxT("unexpected kill(2) return value %d"), err);
244
245 // something else...
246 *rc = wxKILL_ERROR;
247 }
248 }
249
250 return err;
251 }
252
253 // Shutdown or reboot the PC
254 bool wxShutdown(int flags)
255 {
256 flags &= ~wxSHUTDOWN_FORCE;
257
258 wxChar level;
259 switch ( flags )
260 {
261 case wxSHUTDOWN_POWEROFF:
262 level = wxT('0');
263 break;
264
265 case wxSHUTDOWN_REBOOT:
266 level = wxT('6');
267 break;
268
269 case wxSHUTDOWN_LOGOFF:
270 // TODO: use dcop to log off?
271 return false;
272
273 default:
274 wxFAIL_MSG( wxT("unknown wxShutdown() flag") );
275 return false;
276 }
277
278 return system(wxString::Format("init %c", level).mb_str()) == 0;
279 }
280
281 // ----------------------------------------------------------------------------
282 // wxStream classes to support IO redirection in wxExecute
283 // ----------------------------------------------------------------------------
284
285 #if HAS_PIPE_STREAMS
286
287 bool wxPipeInputStream::CanRead() const
288 {
289 if ( m_lasterror == wxSTREAM_EOF )
290 return false;
291
292 // check if there is any input available
293 struct timeval tv;
294 tv.tv_sec = 0;
295 tv.tv_usec = 0;
296
297 const int fd = m_file->fd();
298
299 fd_set readfds;
300
301 wxFD_ZERO(&readfds);
302 wxFD_SET(fd, &readfds);
303
304 switch ( select(fd + 1, &readfds, NULL, NULL, &tv) )
305 {
306 case -1:
307 wxLogSysError(_("Impossible to get child process input"));
308 // fall through
309
310 case 0:
311 return false;
312
313 default:
314 wxFAIL_MSG(wxT("unexpected select() return value"));
315 // still fall through
316
317 case 1:
318 // input available -- or maybe not, as select() returns 1 when a
319 // read() will complete without delay, but it could still not read
320 // anything
321 return !Eof();
322 }
323 }
324
325 size_t wxPipeOutputStream::OnSysWrite(const void *buffer, size_t size)
326 {
327 // We need to suppress error logging here, because on writing to a pipe
328 // which is full, wxFile::Write reports a system error. However, this is
329 // not an extraordinary situation, and it should not be reported to the
330 // user (but if really needed, the program can recognize it by checking
331 // whether LastRead() == 0.) Other errors will be reported below.
332 size_t ret;
333 {
334 wxLogNull logNo;
335 ret = m_file->Write(buffer, size);
336 }
337
338 switch ( m_file->GetLastError() )
339 {
340 // pipe is full
341 #ifdef EAGAIN
342 case EAGAIN:
343 #endif
344 #if defined(EWOULDBLOCK) && (EWOULDBLOCK != EAGAIN)
345 case EWOULDBLOCK:
346 #endif
347 // do not treat it as an error
348 m_file->ClearLastError();
349 // fall through
350
351 // no error
352 case 0:
353 break;
354
355 // some real error
356 default:
357 wxLogSysError(_("Can't write to child process's stdin"));
358 m_lasterror = wxSTREAM_WRITE_ERROR;
359 }
360
361 return ret;
362 }
363
364 #endif // HAS_PIPE_STREAMS
365
366 // ----------------------------------------------------------------------------
367 // wxShell
368 // ----------------------------------------------------------------------------
369
370 static wxString wxMakeShellCommand(const wxString& command)
371 {
372 wxString cmd;
373 if ( !command )
374 {
375 // just an interactive shell
376 cmd = wxT("xterm");
377 }
378 else
379 {
380 // execute command in a shell
381 cmd << wxT("/bin/sh -c '") << command << wxT('\'');
382 }
383
384 return cmd;
385 }
386
387 bool wxShell(const wxString& command)
388 {
389 return wxExecute(wxMakeShellCommand(command), wxEXEC_SYNC) == 0;
390 }
391
392 bool wxShell(const wxString& command, wxArrayString& output)
393 {
394 wxCHECK_MSG( !command.empty(), false, wxT("can't exec shell non interactively") );
395
396 return wxExecute(wxMakeShellCommand(command), output);
397 }
398
399 namespace
400 {
401
402 // helper class for storing arguments as char** array suitable for passing to
403 // execvp(), whatever form they were passed to us
404 class ArgsArray
405 {
406 public:
407 ArgsArray(const wxArrayString& args)
408 {
409 Init(args.size());
410
411 for ( int i = 0; i < m_argc; i++ )
412 {
413 m_argv[i] = wxStrdup(args[i]);
414 }
415 }
416
417 #if wxUSE_UNICODE
418 ArgsArray(wchar_t **wargv)
419 {
420 int argc = 0;
421 while ( wargv[argc] )
422 argc++;
423
424 Init(argc);
425
426 for ( int i = 0; i < m_argc; i++ )
427 {
428 m_argv[i] = wxSafeConvertWX2MB(wargv[i]).release();
429 }
430 }
431 #endif // wxUSE_UNICODE
432
433 ~ArgsArray()
434 {
435 for ( int i = 0; i < m_argc; i++ )
436 {
437 free(m_argv[i]);
438 }
439
440 delete [] m_argv;
441 }
442
443 operator char**() const { return m_argv; }
444
445 private:
446 void Init(int argc)
447 {
448 m_argc = argc;
449 m_argv = new char *[m_argc + 1];
450 m_argv[m_argc] = NULL;
451 }
452
453 int m_argc;
454 char **m_argv;
455
456 wxDECLARE_NO_COPY_CLASS(ArgsArray);
457 };
458
459 } // anonymous namespace
460
461 // ----------------------------------------------------------------------------
462 // wxExecute implementations
463 // ----------------------------------------------------------------------------
464
465 #if defined(__DARWIN__)
466 bool wxMacLaunch(char **argv);
467 #endif
468
469 long wxExecute(const wxString& command, int flags, wxProcess *process,
470 const wxExecuteEnv *env)
471 {
472 ArgsArray argv(wxCmdLineParser::ConvertStringToArgs(command,
473 wxCMD_LINE_SPLIT_UNIX));
474
475 return wxExecute(argv, flags, process, env);
476 }
477
478 #if wxUSE_UNICODE
479
480 long wxExecute(wchar_t **wargv, int flags, wxProcess *process,
481 const wxExecuteEnv *env)
482 {
483 ArgsArray argv(wargv);
484
485 return wxExecute(argv, flags, process, env);
486 }
487
488 #endif // wxUSE_UNICODE
489
490 namespace
491 {
492
493 // Helper function of wxExecute(): wait for the process termination without
494 // dispatching any events.
495 //
496 // This is used in wxEXEC_NOEVENTS case.
497 int BlockUntilChildExit(wxExecuteData& execData)
498 {
499 wxCHECK_MSG( wxTheApp, -1,
500 wxS("Can't block until child exit without wxTheApp") );
501
502 #if wxUSE_SELECT_DISPATCHER
503
504 // Even if we don't want to dispatch events, we still need to handle
505 // child IO notifications and process termination concurrently, i.e.
506 // we can't simply block waiting for the child to terminate as we would
507 // dead lock if it writes more than the pipe buffer size (typically
508 // 4KB) bytes of output -- it would then block waiting for us to read
509 // the data while we'd block waiting for it to terminate.
510 //
511 // So while we don't use the full blown event loop, we still do use a
512 // dispatcher with which we register just the 3 FDs we're interested
513 // in: the child stdout and stderr and the pipe written to by the
514 // signal handler so that we could react to the child process
515 // termination too.
516
517 // Notice that we must create a new dispatcher object here instead of
518 // reusing the global wxFDIODispatcher::Get() because we want to
519 // monitor only the events on the FDs explicitly registered with this
520 // one and not all the other ones that could be registered with the
521 // global dispatcher (think about the case of nested wxExecute() calls).
522 wxSelectDispatcher dispatcher;
523
524 // Do register all the FDs we want to monitor here: first, the one used to
525 // handle the signals asynchronously.
526 wxScopedPtr<wxFDIOHandler>
527 signalHandler(wxTheApp->RegisterSignalWakeUpPipe(dispatcher));
528
529 #if wxUSE_STREAMS
530 // And then the two for the child output and error streams if necessary.
531 wxScopedPtr<wxFDIOHandler>
532 stdoutHandler,
533 stderrHandler;
534 if ( execData.IsRedirected() )
535 {
536 stdoutHandler.reset(new wxExecuteFDIOHandler
537 (
538 dispatcher,
539 execData.fdOut,
540 execData.bufOut
541 ));
542 stderrHandler.reset(new wxExecuteFDIOHandler
543 (
544 dispatcher,
545 execData.fdErr,
546 execData.bufErr
547 ));
548 }
549 #endif // wxUSE_STREAMS
550
551 // And dispatch until the PID is reset from wxExecuteData::OnExit().
552 while ( execData.pid )
553 {
554 dispatcher.Dispatch();
555 }
556
557 return execData.exitcode;
558 #else // !wxUSE_SELECT_DISPATCHER
559 wxFAIL_MSG( wxS("Can't block until child exit without wxSelectDispatcher") );
560
561 return -1;
562 #endif // wxUSE_SELECT_DISPATCHER/!wxUSE_SELECT_DISPATCHER
563 }
564
565 } // anonymous namespace
566
567 // wxExecute: the real worker function
568 long wxExecute(char **argv, int flags, wxProcess *process,
569 const wxExecuteEnv *env)
570 {
571 // for the sync execution, we return -1 to indicate failure, but for async
572 // case we return 0 which is never a valid PID
573 //
574 // we define this as a macro, not a variable, to avoid compiler warnings
575 // about "ERROR_RETURN_CODE value may be clobbered by fork()"
576 #define ERROR_RETURN_CODE ((flags & wxEXEC_SYNC) ? -1 : 0)
577
578 wxCHECK_MSG( *argv, ERROR_RETURN_CODE, wxT("can't exec empty command") );
579
580 #if wxUSE_THREADS
581 // fork() doesn't mix well with POSIX threads: on many systems the program
582 // deadlocks or crashes for some reason. Probably our code is buggy and
583 // doesn't do something which must be done to allow this to work, but I
584 // don't know what yet, so for now just warn the user (this is the least we
585 // can do) about it
586 wxASSERT_MSG( wxThread::IsMain(),
587 wxT("wxExecute() can be called only from the main thread") );
588 #endif // wxUSE_THREADS
589
590 #if defined(__WXCOCOA__) || ( defined(__WXOSX_MAC__) && wxOSX_USE_COCOA_OR_CARBON )
591 // wxMacLaunch() only executes app bundles and only does it asynchronously.
592 // It returns false if the target is not an app bundle, thus falling
593 // through to the regular code for non app bundles.
594 if ( !(flags & wxEXEC_SYNC) && wxMacLaunch(argv) )
595 {
596 // we don't have any PID to return so just make up something non null
597 return -1;
598 }
599 #endif // __DARWIN__
600
601 // this struct contains all information which we use for housekeeping
602 wxScopedPtr<wxExecuteData> execDataPtr(new wxExecuteData);
603 wxExecuteData& execData = *execDataPtr;
604
605 execData.flags = flags;
606 execData.process = process;
607
608 // create pipes for inter process communication
609 wxPipe pipeIn, // stdin
610 pipeOut, // stdout
611 pipeErr; // stderr
612
613 if ( process && process->IsRedirected() )
614 {
615 if ( !pipeIn.Create() || !pipeOut.Create() || !pipeErr.Create() )
616 {
617 wxLogError( _("Failed to execute '%s'\n"), *argv );
618
619 return ERROR_RETURN_CODE;
620 }
621 }
622
623 // priority: we need to map wxWidgets priority which is in the range 0..100
624 // to Unix nice value which is in the range -20..19. As there is an odd
625 // number of elements in our range and an even number in the Unix one, we
626 // have to do it in this rather ugly way to guarantee that:
627 // 1. wxPRIORITY_{MIN,DEFAULT,MAX} map to -20, 0 and 19 respectively.
628 // 2. The mapping is monotonously increasing.
629 // 3. The mapping is onto the target range.
630 int prio = process ? process->GetPriority() : 0;
631 if ( prio <= 50 )
632 prio = (2*prio)/5 - 20;
633 else if ( prio < 55 )
634 prio = 1;
635 else
636 prio = (2*prio)/5 - 21;
637
638 // fork the process
639 //
640 // NB: do *not* use vfork() here, it completely breaks this code for some
641 // reason under Solaris (and maybe others, although not under Linux)
642 // But on OpenVMS we do not have fork so we have to use vfork and
643 // cross our fingers that it works.
644 #ifdef __VMS
645 pid_t pid = vfork();
646 #else
647 pid_t pid = fork();
648 #endif
649 if ( pid == -1 ) // error?
650 {
651 wxLogSysError( _("Fork failed") );
652
653 return ERROR_RETURN_CODE;
654 }
655 else if ( pid == 0 ) // we're in child
656 {
657 // NB: we used to close all the unused descriptors of the child here
658 // but this broke some programs which relied on e.g. FD 1 being
659 // always opened so don't do it any more, after all there doesn't
660 // seem to be any real problem with keeping them opened
661
662 #if !defined(__VMS) && !defined(__EMX__)
663 if ( flags & wxEXEC_MAKE_GROUP_LEADER )
664 {
665 // Set process group to child process' pid. Then killing -pid
666 // of the parent will kill the process and all of its children.
667 setsid();
668 }
669 #endif // !__VMS
670
671 #if defined(HAVE_SETPRIORITY)
672 if ( prio && setpriority(PRIO_PROCESS, 0, prio) != 0 )
673 {
674 wxLogSysError(_("Failed to set process priority"));
675 }
676 #endif // HAVE_SETPRIORITY
677
678 // redirect stdin, stdout and stderr
679 if ( pipeIn.IsOk() )
680 {
681 if ( dup2(pipeIn[wxPipe::Read], STDIN_FILENO) == -1 ||
682 dup2(pipeOut[wxPipe::Write], STDOUT_FILENO) == -1 ||
683 dup2(pipeErr[wxPipe::Write], STDERR_FILENO) == -1 )
684 {
685 wxLogSysError(_("Failed to redirect child process input/output"));
686 }
687
688 pipeIn.Close();
689 pipeOut.Close();
690 pipeErr.Close();
691 }
692
693 // Close all (presumably accidentally) inherited file descriptors to
694 // avoid descriptor leaks. This means that we don't allow inheriting
695 // them purposefully but this seems like a lesser evil in wx code.
696 // Ideally we'd provide some flag to indicate that none (or some?) of
697 // the descriptors do not need to be closed but for now this is better
698 // than never closing them at all as wx code never used FD_CLOEXEC.
699
700 // TODO: Iterating up to FD_SETSIZE is both inefficient (because it may
701 // be quite big) and incorrect (because in principle we could
702 // have more opened descriptions than this number). Unfortunately
703 // there is no good portable solution for closing all descriptors
704 // above a certain threshold but non-portable solutions exist for
705 // most platforms, see [http://stackoverflow.com/questions/899038/
706 // getting-the-highest-allocated-file-descriptor]
707 for ( int fd = 0; fd < (int)FD_SETSIZE; ++fd )
708 {
709 if ( fd != STDIN_FILENO &&
710 fd != STDOUT_FILENO &&
711 fd != STDERR_FILENO )
712 {
713 close(fd);
714 }
715 }
716
717
718 // Process additional options if we have any
719 if ( env )
720 {
721 // Change working directory if it is specified
722 if ( !env->cwd.empty() )
723 wxSetWorkingDirectory(env->cwd);
724
725 // Change environment if needed.
726 //
727 // NB: We can't use execve() currently because we allow using
728 // non full paths to wxExecute(), i.e. we want to search for
729 // the program in PATH. However it just might be simpler/better
730 // to do the search manually and use execve() envp parameter to
731 // set up the environment of the child process explicitly
732 // instead of doing what we do below.
733 if ( !env->env.empty() )
734 {
735 wxEnvVariableHashMap oldenv;
736 wxGetEnvMap(&oldenv);
737
738 // Remove unwanted variables
739 wxEnvVariableHashMap::const_iterator it;
740 for ( it = oldenv.begin(); it != oldenv.end(); ++it )
741 {
742 if ( env->env.find(it->first) == env->env.end() )
743 wxUnsetEnv(it->first);
744 }
745
746 // And add the new ones (possibly replacing the old values)
747 for ( it = env->env.begin(); it != env->env.end(); ++it )
748 wxSetEnv(it->first, it->second);
749 }
750 }
751
752 execvp(*argv, argv);
753
754 fprintf(stderr, "execvp(");
755 for ( char **a = argv; *a; a++ )
756 fprintf(stderr, "%s%s", a == argv ? "" : ", ", *a);
757 fprintf(stderr, ") failed with error %d!\n", errno);
758
759 // there is no return after successful exec()
760 _exit(-1);
761
762 // some compilers complain about missing return - of course, they
763 // should know that exit() doesn't return but what else can we do if
764 // they don't?
765 //
766 // and, sure enough, other compilers complain about unreachable code
767 // after exit() call, so we can just always have return here...
768 #if defined(__VMS) || defined(__INTEL_COMPILER)
769 return 0;
770 #endif
771 }
772 else // we're in parent
773 {
774 execData.OnStart(pid);
775
776 // prepare for IO redirection
777
778 #if HAS_PIPE_STREAMS
779
780 if ( process && process->IsRedirected() )
781 {
782 // Avoid deadlocks which could result from trying to write to the
783 // child input pipe end while the child itself is writing to its
784 // output end and waiting for us to read from it.
785 if ( !pipeIn.MakeNonBlocking(wxPipe::Write) )
786 {
787 // This message is not terrible useful for the user but what
788 // else can we do? Also, should we fail here or take the risk
789 // to continue and deadlock? Currently we choose the latter but
790 // it might not be the best idea.
791 wxLogSysError(_("Failed to set up non-blocking pipe, "
792 "the program might hang."));
793 #if wxUSE_LOG
794 wxLog::FlushActive();
795 #endif
796 }
797
798 wxOutputStream *inStream =
799 new wxPipeOutputStream(pipeIn.Detach(wxPipe::Write));
800
801 const int fdOut = pipeOut.Detach(wxPipe::Read);
802 wxPipeInputStream *outStream = new wxPipeInputStream(fdOut);
803
804 const int fdErr = pipeErr.Detach(wxPipe::Read);
805 wxPipeInputStream *errStream = new wxPipeInputStream(fdErr);
806
807 process->SetPipeStreams(outStream, inStream, errStream);
808
809 if ( flags & wxEXEC_SYNC )
810 {
811 execData.bufOut.Init(outStream);
812 execData.bufErr.Init(errStream);
813
814 execData.fdOut = fdOut;
815 execData.fdErr = fdErr;
816 }
817 }
818 #endif // HAS_PIPE_STREAMS
819
820 if ( pipeIn.IsOk() )
821 {
822 pipeIn.Close();
823 pipeOut.Close();
824 pipeErr.Close();
825 }
826
827 // For the asynchronous case we don't have to do anything else, just
828 // let the process run.
829 if ( !(flags & wxEXEC_SYNC) )
830 {
831 // Ensure that the housekeeping data is kept alive, it will be
832 // destroyed only when the child terminates.
833 execDataPtr.release();
834
835 return execData.pid;
836 }
837
838
839 // If we don't need to dispatch any events, things are relatively
840 // simple and we don't need to delegate to wxAppTraits.
841 if ( flags & wxEXEC_NOEVENTS )
842 {
843 return BlockUntilChildExit(execData);
844 }
845
846
847 // If we do need to dispatch events, enter a local event loop waiting
848 // until the child exits. As the exact kind of event loop depends on
849 // the sort of application we're in (console or GUI), we delegate this
850 // to wxAppTraits which virtualizes all the differences between the
851 // console and the GUI programs.
852 return wxApp::GetValidTraits().WaitForChild(execData);
853 }
854
855 #if !defined(__VMS) && !defined(__INTEL_COMPILER)
856 return ERROR_RETURN_CODE;
857 #endif
858 }
859
860 #undef ERROR_RETURN_CODE
861
862 // ----------------------------------------------------------------------------
863 // file and directory functions
864 // ----------------------------------------------------------------------------
865
866 const wxChar* wxGetHomeDir( wxString *home )
867 {
868 *home = wxGetUserHome();
869 wxString tmp;
870 if ( home->empty() )
871 *home = wxT("/");
872 #ifdef __VMS
873 tmp = *home;
874 if ( tmp.Last() != wxT(']'))
875 if ( tmp.Last() != wxT('/')) *home << wxT('/');
876 #endif
877 return home->c_str();
878 }
879
880 wxString wxGetUserHome( const wxString &user )
881 {
882 struct passwd *who = (struct passwd *) NULL;
883
884 if ( !user )
885 {
886 wxChar *ptr;
887
888 if ((ptr = wxGetenv(wxT("HOME"))) != NULL)
889 {
890 return ptr;
891 }
892
893 if ((ptr = wxGetenv(wxT("USER"))) != NULL ||
894 (ptr = wxGetenv(wxT("LOGNAME"))) != NULL)
895 {
896 who = getpwnam(wxSafeConvertWX2MB(ptr));
897 }
898
899 // make sure the user exists!
900 if ( !who )
901 {
902 who = getpwuid(getuid());
903 }
904 }
905 else
906 {
907 who = getpwnam (user.mb_str());
908 }
909
910 return wxSafeConvertMB2WX(who ? who->pw_dir : 0);
911 }
912
913 // ----------------------------------------------------------------------------
914 // network and user id routines
915 // ----------------------------------------------------------------------------
916
917 // private utility function which returns output of the given command, removing
918 // the trailing newline
919 static wxString wxGetCommandOutput(const wxString &cmd)
920 {
921 // Suppress stderr from the shell to avoid outputting errors if the command
922 // doesn't exist.
923 FILE *f = popen((cmd + " 2>/dev/null").ToAscii(), "r");
924 if ( !f )
925 {
926 // Notice that this doesn't happen simply if the command doesn't exist,
927 // but only in case of some really catastrophic failure inside popen()
928 // so we should really notify the user about this as this is not normal.
929 wxLogSysError(wxT("Executing \"%s\" failed"), cmd);
930 return wxString();
931 }
932
933 wxString s;
934 char buf[256];
935 while ( !feof(f) )
936 {
937 if ( !fgets(buf, sizeof(buf), f) )
938 break;
939
940 s += wxString::FromAscii(buf);
941 }
942
943 pclose(f);
944
945 if ( !s.empty() && s.Last() == wxT('\n') )
946 s.RemoveLast();
947
948 return s;
949 }
950
951 // retrieve either the hostname or FQDN depending on platform (caller must
952 // check whether it's one or the other, this is why this function is for
953 // private use only)
954 static bool wxGetHostNameInternal(wxChar *buf, int sz)
955 {
956 wxCHECK_MSG( buf, false, wxT("NULL pointer in wxGetHostNameInternal") );
957
958 *buf = wxT('\0');
959
960 // we're using uname() which is POSIX instead of less standard sysinfo()
961 #if defined(HAVE_UNAME)
962 struct utsname uts;
963 bool ok = uname(&uts) != -1;
964 if ( ok )
965 {
966 wxStrlcpy(buf, wxSafeConvertMB2WX(uts.nodename), sz);
967 }
968 #elif defined(HAVE_GETHOSTNAME)
969 char cbuf[sz];
970 bool ok = gethostname(cbuf, sz) != -1;
971 if ( ok )
972 {
973 wxStrlcpy(buf, wxSafeConvertMB2WX(cbuf), sz);
974 }
975 #else // no uname, no gethostname
976 wxFAIL_MSG(wxT("don't know host name for this machine"));
977
978 bool ok = false;
979 #endif // uname/gethostname
980
981 if ( !ok )
982 {
983 wxLogSysError(_("Cannot get the hostname"));
984 }
985
986 return ok;
987 }
988
989 bool wxGetHostName(wxChar *buf, int sz)
990 {
991 bool ok = wxGetHostNameInternal(buf, sz);
992
993 if ( ok )
994 {
995 // BSD systems return the FQDN, we only want the hostname, so extract
996 // it (we consider that dots are domain separators)
997 wxChar *dot = wxStrchr(buf, wxT('.'));
998 if ( dot )
999 {
1000 // nuke it
1001 *dot = wxT('\0');
1002 }
1003 }
1004
1005 return ok;
1006 }
1007
1008 bool wxGetFullHostName(wxChar *buf, int sz)
1009 {
1010 bool ok = wxGetHostNameInternal(buf, sz);
1011
1012 if ( ok )
1013 {
1014 if ( !wxStrchr(buf, wxT('.')) )
1015 {
1016 struct hostent *host = gethostbyname(wxSafeConvertWX2MB(buf));
1017 if ( !host )
1018 {
1019 wxLogSysError(_("Cannot get the official hostname"));
1020
1021 ok = false;
1022 }
1023 else
1024 {
1025 // the canonical name
1026 wxStrlcpy(buf, wxSafeConvertMB2WX(host->h_name), sz);
1027 }
1028 }
1029 //else: it's already a FQDN (BSD behaves this way)
1030 }
1031
1032 return ok;
1033 }
1034
1035 bool wxGetUserId(wxChar *buf, int sz)
1036 {
1037 struct passwd *who;
1038
1039 *buf = wxT('\0');
1040 if ((who = getpwuid(getuid ())) != NULL)
1041 {
1042 wxStrlcpy (buf, wxSafeConvertMB2WX(who->pw_name), sz);
1043 return true;
1044 }
1045
1046 return false;
1047 }
1048
1049 bool wxGetUserName(wxChar *buf, int sz)
1050 {
1051 #ifdef HAVE_PW_GECOS
1052 struct passwd *who;
1053
1054 *buf = wxT('\0');
1055 if ((who = getpwuid (getuid ())) != NULL)
1056 {
1057 char *comma = strchr(who->pw_gecos, ',');
1058 if (comma)
1059 *comma = '\0'; // cut off non-name comment fields
1060 wxStrlcpy(buf, wxSafeConvertMB2WX(who->pw_gecos), sz);
1061 return true;
1062 }
1063
1064 return false;
1065 #else // !HAVE_PW_GECOS
1066 return wxGetUserId(buf, sz);
1067 #endif // HAVE_PW_GECOS/!HAVE_PW_GECOS
1068 }
1069
1070 bool wxIsPlatform64Bit()
1071 {
1072 const wxString machine = wxGetCommandOutput(wxT("uname -m"));
1073
1074 // the test for "64" is obviously not 100% reliable but seems to work fine
1075 // in practice
1076 return machine.Contains(wxT("64")) ||
1077 machine.Contains(wxT("alpha"));
1078 }
1079
1080 #ifdef __LINUX__
1081 wxLinuxDistributionInfo wxGetLinuxDistributionInfo()
1082 {
1083 const wxString id = wxGetCommandOutput(wxT("lsb_release --id"));
1084 const wxString desc = wxGetCommandOutput(wxT("lsb_release --description"));
1085 const wxString rel = wxGetCommandOutput(wxT("lsb_release --release"));
1086 const wxString codename = wxGetCommandOutput(wxT("lsb_release --codename"));
1087
1088 wxLinuxDistributionInfo ret;
1089
1090 id.StartsWith("Distributor ID:\t", &ret.Id);
1091 desc.StartsWith("Description:\t", &ret.Description);
1092 rel.StartsWith("Release:\t", &ret.Release);
1093 codename.StartsWith("Codename:\t", &ret.CodeName);
1094
1095 return ret;
1096 }
1097 #endif
1098
1099 // these functions are in src/osx/utilsexc_base.cpp for wxMac
1100 #ifndef __DARWIN__
1101
1102 wxOperatingSystemId wxGetOsVersion(int *verMaj, int *verMin)
1103 {
1104 // get OS version
1105 int major, minor;
1106 wxString release = wxGetCommandOutput(wxT("uname -r"));
1107 if ( release.empty() ||
1108 wxSscanf(release.c_str(), wxT("%d.%d"), &major, &minor) != 2 )
1109 {
1110 // failed to get version string or unrecognized format
1111 major =
1112 minor = -1;
1113 }
1114
1115 if ( verMaj )
1116 *verMaj = major;
1117 if ( verMin )
1118 *verMin = minor;
1119
1120 // try to understand which OS are we running
1121 wxString kernel = wxGetCommandOutput(wxT("uname -s"));
1122 if ( kernel.empty() )
1123 kernel = wxGetCommandOutput(wxT("uname -o"));
1124
1125 if ( kernel.empty() )
1126 return wxOS_UNKNOWN;
1127
1128 return wxPlatformInfo::GetOperatingSystemId(kernel);
1129 }
1130
1131 wxString wxGetOsDescription()
1132 {
1133 return wxGetCommandOutput(wxT("uname -s -r -m"));
1134 }
1135
1136 #endif // !__DARWIN__
1137
1138 unsigned long wxGetProcessId()
1139 {
1140 return (unsigned long)getpid();
1141 }
1142
1143 wxMemorySize wxGetFreeMemory()
1144 {
1145 #if defined(__LINUX__)
1146 // get it from /proc/meminfo
1147 FILE *fp = fopen("/proc/meminfo", "r");
1148 if ( fp )
1149 {
1150 long memFree = -1;
1151
1152 char buf[1024];
1153 if ( fgets(buf, WXSIZEOF(buf), fp) && fgets(buf, WXSIZEOF(buf), fp) )
1154 {
1155 // /proc/meminfo changed its format in kernel 2.6
1156 if ( wxPlatformInfo().CheckOSVersion(2, 6) )
1157 {
1158 unsigned long cached, buffers;
1159 sscanf(buf, "MemFree: %ld", &memFree);
1160
1161 fgets(buf, WXSIZEOF(buf), fp);
1162 sscanf(buf, "Buffers: %lu", &buffers);
1163
1164 fgets(buf, WXSIZEOF(buf), fp);
1165 sscanf(buf, "Cached: %lu", &cached);
1166
1167 // add to "MemFree" also the "Buffers" and "Cached" values as
1168 // free(1) does as otherwise the value never makes sense: for
1169 // kernel 2.6 it's always almost 0
1170 memFree += buffers + cached;
1171
1172 // values here are always expressed in kB and we want bytes
1173 memFree *= 1024;
1174 }
1175 else // Linux 2.4 (or < 2.6, anyhow)
1176 {
1177 long memTotal, memUsed;
1178 sscanf(buf, "Mem: %ld %ld %ld", &memTotal, &memUsed, &memFree);
1179 }
1180 }
1181
1182 fclose(fp);
1183
1184 return (wxMemorySize)memFree;
1185 }
1186 #elif defined(__SGI__)
1187 struct rminfo realmem;
1188 if ( sysmp(MP_SAGET, MPSA_RMINFO, &realmem, sizeof realmem) == 0 )
1189 return ((wxMemorySize)realmem.physmem * sysconf(_SC_PAGESIZE));
1190 #elif defined(_SC_AVPHYS_PAGES)
1191 return ((wxMemorySize)sysconf(_SC_AVPHYS_PAGES))*sysconf(_SC_PAGESIZE);
1192 //#elif defined(__FREEBSD__) -- might use sysctl() to find it out, probably
1193 #endif
1194
1195 // can't find it out
1196 return -1;
1197 }
1198
1199 bool wxGetDiskSpace(const wxString& path, wxDiskspaceSize_t *pTotal, wxDiskspaceSize_t *pFree)
1200 {
1201 #if defined(HAVE_STATFS) || defined(HAVE_STATVFS)
1202 // the case to "char *" is needed for AIX 4.3
1203 wxStatfs_t fs;
1204 if ( wxStatfs((char *)(const char*)path.fn_str(), &fs) != 0 )
1205 {
1206 wxLogSysError( wxT("Failed to get file system statistics") );
1207
1208 return false;
1209 }
1210
1211 // under Solaris we also have to use f_frsize field instead of f_bsize
1212 // which is in general a multiple of f_frsize
1213 #ifdef HAVE_STATVFS
1214 wxDiskspaceSize_t blockSize = fs.f_frsize;
1215 #else // HAVE_STATFS
1216 wxDiskspaceSize_t blockSize = fs.f_bsize;
1217 #endif // HAVE_STATVFS/HAVE_STATFS
1218
1219 if ( pTotal )
1220 {
1221 *pTotal = wxDiskspaceSize_t(fs.f_blocks) * blockSize;
1222 }
1223
1224 if ( pFree )
1225 {
1226 *pFree = wxDiskspaceSize_t(fs.f_bavail) * blockSize;
1227 }
1228
1229 return true;
1230 #else // !HAVE_STATFS && !HAVE_STATVFS
1231 return false;
1232 #endif // HAVE_STATFS
1233 }
1234
1235 // ----------------------------------------------------------------------------
1236 // env vars
1237 // ----------------------------------------------------------------------------
1238
1239 #if USE_PUTENV
1240
1241 WX_DECLARE_STRING_HASH_MAP(char *, wxEnvVars);
1242
1243 static wxEnvVars gs_envVars;
1244
1245 class wxSetEnvModule : public wxModule
1246 {
1247 public:
1248 virtual bool OnInit() { return true; }
1249 virtual void OnExit()
1250 {
1251 for ( wxEnvVars::const_iterator i = gs_envVars.begin();
1252 i != gs_envVars.end();
1253 ++i )
1254 {
1255 free(i->second);
1256 }
1257
1258 gs_envVars.clear();
1259 }
1260
1261 DECLARE_DYNAMIC_CLASS(wxSetEnvModule)
1262 };
1263
1264 IMPLEMENT_DYNAMIC_CLASS(wxSetEnvModule, wxModule)
1265
1266 #endif // USE_PUTENV
1267
1268 bool wxGetEnv(const wxString& var, wxString *value)
1269 {
1270 // wxGetenv is defined as getenv()
1271 char *p = wxGetenv(var);
1272 if ( !p )
1273 return false;
1274
1275 if ( value )
1276 {
1277 *value = p;
1278 }
1279
1280 return true;
1281 }
1282
1283 static bool wxDoSetEnv(const wxString& variable, const char *value)
1284 {
1285 #if defined(HAVE_SETENV)
1286 if ( !value )
1287 {
1288 #ifdef HAVE_UNSETENV
1289 // don't test unsetenv() return value: it's void on some systems (at
1290 // least Darwin)
1291 unsetenv(variable.mb_str());
1292 return true;
1293 #else
1294 value = ""; // we can't pass NULL to setenv()
1295 #endif
1296 }
1297
1298 return setenv(variable.mb_str(), value, 1 /* overwrite */) == 0;
1299 #elif defined(HAVE_PUTENV)
1300 wxString s = variable;
1301 if ( value )
1302 s << wxT('=') << value;
1303
1304 // transform to ANSI
1305 const wxWX2MBbuf p = s.mb_str();
1306
1307 char *buf = (char *)malloc(strlen(p) + 1);
1308 strcpy(buf, p);
1309
1310 // store the string to free() it later
1311 wxEnvVars::iterator i = gs_envVars.find(variable);
1312 if ( i != gs_envVars.end() )
1313 {
1314 free(i->second);
1315 i->second = buf;
1316 }
1317 else // this variable hadn't been set before
1318 {
1319 gs_envVars[variable] = buf;
1320 }
1321
1322 return putenv(buf) == 0;
1323 #else // no way to set an env var
1324 return false;
1325 #endif
1326 }
1327
1328 bool wxSetEnv(const wxString& variable, const wxString& value)
1329 {
1330 return wxDoSetEnv(variable, value.mb_str());
1331 }
1332
1333 bool wxUnsetEnv(const wxString& variable)
1334 {
1335 return wxDoSetEnv(variable, NULL);
1336 }
1337
1338 // ----------------------------------------------------------------------------
1339 // signal handling
1340 // ----------------------------------------------------------------------------
1341
1342 #if wxUSE_ON_FATAL_EXCEPTION
1343
1344 #include <signal.h>
1345
1346 extern "C" void wxFatalSignalHandler(wxTYPE_SA_HANDLER)
1347 {
1348 if ( wxTheApp )
1349 {
1350 // give the user a chance to do something special about this
1351 wxTheApp->OnFatalException();
1352 }
1353
1354 abort();
1355 }
1356
1357 bool wxHandleFatalExceptions(bool doit)
1358 {
1359 // old sig handlers
1360 static bool s_savedHandlers = false;
1361 static struct sigaction s_handlerFPE,
1362 s_handlerILL,
1363 s_handlerBUS,
1364 s_handlerSEGV;
1365
1366 bool ok = true;
1367 if ( doit && !s_savedHandlers )
1368 {
1369 // install the signal handler
1370 struct sigaction act;
1371
1372 // some systems extend it with non std fields, so zero everything
1373 memset(&act, 0, sizeof(act));
1374
1375 act.sa_handler = wxFatalSignalHandler;
1376 sigemptyset(&act.sa_mask);
1377 act.sa_flags = 0;
1378
1379 ok &= sigaction(SIGFPE, &act, &s_handlerFPE) == 0;
1380 ok &= sigaction(SIGILL, &act, &s_handlerILL) == 0;
1381 ok &= sigaction(SIGBUS, &act, &s_handlerBUS) == 0;
1382 ok &= sigaction(SIGSEGV, &act, &s_handlerSEGV) == 0;
1383 if ( !ok )
1384 {
1385 wxLogDebug(wxT("Failed to install our signal handler."));
1386 }
1387
1388 s_savedHandlers = true;
1389 }
1390 else if ( s_savedHandlers )
1391 {
1392 // uninstall the signal handler
1393 ok &= sigaction(SIGFPE, &s_handlerFPE, NULL) == 0;
1394 ok &= sigaction(SIGILL, &s_handlerILL, NULL) == 0;
1395 ok &= sigaction(SIGBUS, &s_handlerBUS, NULL) == 0;
1396 ok &= sigaction(SIGSEGV, &s_handlerSEGV, NULL) == 0;
1397 if ( !ok )
1398 {
1399 wxLogDebug(wxT("Failed to uninstall our signal handler."));
1400 }
1401
1402 s_savedHandlers = false;
1403 }
1404 //else: nothing to do
1405
1406 return ok;
1407 }
1408
1409 #endif // wxUSE_ON_FATAL_EXCEPTION
1410
1411 // ----------------------------------------------------------------------------
1412 // wxExecute support
1413 // ----------------------------------------------------------------------------
1414
1415 int wxAppTraits::WaitForChild(wxExecuteData& execData)
1416 {
1417 #if wxUSE_CONSOLE_EVENTLOOP
1418 wxConsoleEventLoop loop;
1419 return RunLoopUntilChildExit(execData, loop);
1420 #else // !wxUSE_CONSOLE_EVENTLOOP
1421 wxFAIL_MSG( wxS("Can't wait for child process without wxConsoleEventLoop") );
1422
1423 return -1;
1424 #endif // wxUSE_CONSOLE_EVENTLOOP/!wxUSE_CONSOLE_EVENTLOOP
1425 }
1426
1427 // This function is common code for both console and GUI applications and used
1428 // by wxExecute() to wait for the child exit while dispatching events.
1429 //
1430 // Notice that it should not be used for all the other cases, e.g. when we
1431 // don't need to wait for the child (wxEXEC_ASYNC) or when the events must not
1432 // dispatched (wxEXEC_NOEVENTS).
1433 int
1434 wxAppTraits::RunLoopUntilChildExit(wxExecuteData& execData,
1435 wxEventLoopBase& loop)
1436 {
1437 // It is possible that wxExecuteData::OnExit() had already been called
1438 // and reset the PID to 0, in which case we don't need to do anything
1439 // at all.
1440 if ( !execData.pid )
1441 return execData.exitcode;
1442
1443 #if wxUSE_STREAMS
1444 // Monitor the child streams if necessary.
1445 wxScopedPtr<wxEventLoopSourceHandler>
1446 stdoutHandler,
1447 stderrHandler;
1448 if ( execData.IsRedirected() )
1449 {
1450 stdoutHandler.reset(new wxExecuteEventLoopSourceHandler
1451 (
1452 execData.fdOut, execData.bufOut
1453 ));
1454 stderrHandler.reset(new wxExecuteEventLoopSourceHandler
1455 (
1456 execData.fdErr, execData.bufErr
1457 ));
1458 }
1459 #endif // wxUSE_STREAMS
1460
1461 // Store the event loop in the data associated with the child
1462 // process so that it could exit the loop when the child exits.
1463 execData.syncEventLoop = &loop;
1464
1465 // And run it.
1466 loop.Run();
1467
1468 // The exit code will have been set when the child termination was detected.
1469 return execData.exitcode;
1470 }
1471
1472 // ----------------------------------------------------------------------------
1473 // wxExecuteData
1474 // ----------------------------------------------------------------------------
1475
1476 namespace
1477 {
1478
1479 // Helper function that checks whether the child with the given PID has exited
1480 // and fills the provided parameter with its return code if it did.
1481 bool CheckForChildExit(int pid, int* exitcodeOut)
1482 {
1483 wxASSERT_MSG( pid > 0, "invalid PID" );
1484
1485 int status, rc;
1486
1487 // loop while we're getting EINTR
1488 for ( ;; )
1489 {
1490 rc = waitpid(pid, &status, WNOHANG);
1491
1492 if ( rc != -1 || errno != EINTR )
1493 break;
1494 }
1495
1496 switch ( rc )
1497 {
1498 case 0:
1499 // No error but the child is still running.
1500 return false;
1501
1502 case -1:
1503 // Checking child status failed. Invalid PID?
1504 wxLogLastError(wxString::Format("waitpid(%d)", pid));
1505 return false;
1506
1507 default:
1508 // Child did terminate.
1509 wxASSERT_MSG( rc == pid, "unexpected waitpid() return value" );
1510
1511 // notice that the caller expects the exit code to be signed, e.g. -1
1512 // instead of 255 so don't assign WEXITSTATUS() to an int
1513 signed char exitcode;
1514 if ( WIFEXITED(status) )
1515 exitcode = WEXITSTATUS(status);
1516 else if ( WIFSIGNALED(status) )
1517 exitcode = -WTERMSIG(status);
1518 else
1519 {
1520 wxLogError("Child process (PID %d) exited for unknown reason, "
1521 "status = %d", pid, status);
1522 exitcode = -1;
1523 }
1524
1525 if ( exitcodeOut )
1526 *exitcodeOut = exitcode;
1527
1528 return true;
1529 }
1530 }
1531
1532 } // anonymous namespace
1533
1534 wxExecuteData::ChildProcessesData wxExecuteData::ms_childProcesses;
1535
1536 /* static */
1537 void wxExecuteData::OnSomeChildExited(int WXUNUSED(sig))
1538 {
1539 // We know that some child process has terminated, but we don't know which
1540 // one, so check all of them (notice that more than one could have exited).
1541 //
1542 // An alternative approach would be to call waitpid(-1, &status, WNOHANG)
1543 // (in a loop to take care of the multiple children exiting case) and
1544 // perhaps this would be more efficient. But for now this seems to work.
1545
1546
1547 // Make a copy of the list before iterating over it to avoid problems due
1548 // to deleting entries from it in the process.
1549 const ChildProcessesData allChildProcesses = ms_childProcesses;
1550 for ( ChildProcessesData::const_iterator it = allChildProcesses.begin();
1551 it != allChildProcesses.end();
1552 ++it )
1553 {
1554 const int pid = it->first;
1555
1556 // Check whether this child exited.
1557 int exitcode;
1558 if ( !CheckForChildExit(pid, &exitcode) )
1559 continue;
1560
1561 // And handle its termination if it did.
1562 //
1563 // Notice that this will implicitly remove it from ms_childProcesses.
1564 it->second->OnExit(exitcode);
1565 }
1566 }
1567
1568 void wxExecuteData::OnStart(int pid_)
1569 {
1570 wxCHECK_RET( wxTheApp,
1571 wxS("Ensure wxTheApp is set before calling wxExecute()") );
1572
1573 // Setup the signal handler for SIGCHLD to be able to detect the child
1574 // termination.
1575 //
1576 // Notice that SetSignalHandler() is idempotent, so it's fine to call
1577 // it more than once with the same handler.
1578 wxTheApp->SetSignalHandler(SIGCHLD, OnSomeChildExited);
1579
1580
1581 // Remember the child PID to be able to wait for it later.
1582 pid = pid_;
1583
1584 // Also save it in wxProcess where it will be accessible to the user code.
1585 if ( process )
1586 process->SetPid(pid);
1587
1588 // Finally, add this object itself to the list of child processes so that
1589 // we can check for its termination the next time we get SIGCHLD.
1590 ms_childProcesses[pid] = this;
1591 }
1592
1593 void wxExecuteData::OnExit(int exitcode_)
1594 {
1595 // Remove this process from the hash list of child processes that are
1596 // still open as soon as possible to ensure we don't process it again even
1597 // if another SIGCHLD happens.
1598 if ( !ms_childProcesses.erase(pid) )
1599 {
1600 wxFAIL_MSG(wxString::Format(wxS("Data for PID %d not in the list?"), pid));
1601 }
1602
1603
1604 exitcode = exitcode_;
1605
1606 #if wxUSE_STREAMS
1607 if ( IsRedirected() )
1608 {
1609 // Read the remaining data in a blocking way: this is fine because the
1610 // child has already exited and hence all the data must be already
1611 // available in the streams buffers.
1612 bufOut.ReadAll();
1613 bufErr.ReadAll();
1614 }
1615 #endif // wxUSE_STREAMS
1616
1617 // Notify user about termination if required
1618 if ( !(flags & wxEXEC_SYNC) )
1619 {
1620 if ( process )
1621 process->OnTerminate(pid, exitcode);
1622
1623 // in case of asynchronous execution we don't need this object any more
1624 // after the child terminates
1625 delete this;
1626 }
1627 else // sync execution
1628 {
1629 // let wxExecute() know that the process has terminated
1630 pid = 0;
1631
1632 // Stop the event loop for synchronous wxExecute() if we're running one.
1633 if ( syncEventLoop )
1634 syncEventLoop->ScheduleExit();
1635 }
1636 }