]>
Commit | Line | Data |
---|---|---|
1 | ///////////////////////////////////////////////////////////////////////////// | |
2 | // Name: utilsexec.cpp | |
3 | // Purpose: Execution-related utilities | |
4 | // Author: Stefan Csomor | |
5 | // Modified by: David Elliott | |
6 | // Created: 1998-01-01 | |
7 | // RCS-ID: $Id$ | |
8 | // Copyright: (c) Stefan Csomor | |
9 | // Licence: wxWindows licence | |
10 | ///////////////////////////////////////////////////////////////////////////// | |
11 | ||
12 | #ifdef __GNUG__ | |
13 | //#pragma implementation | |
14 | #endif | |
15 | ||
16 | #include "wx/log.h" | |
17 | #include "wx/utils.h" | |
18 | #ifdef __DARWIN__ | |
19 | #include "wx/unix/execute.h" | |
20 | #include <unistd.h> | |
21 | #include <sys/wait.h> | |
22 | extern "C" { | |
23 | #include <mach/mach.h> | |
24 | } | |
25 | #include <CoreFoundation/CFMachPort.h> | |
26 | #endif | |
27 | ||
28 | #include <stdio.h> | |
29 | #include <stdlib.h> | |
30 | #include <string.h> | |
31 | ||
32 | #ifndef __DARWIN__ | |
33 | #define wxEXECUTE_WIN_MESSAGE 10000 | |
34 | ||
35 | long wxExecute(const wxString& command, int flags, wxProcess *handler) | |
36 | { | |
37 | // TODO | |
38 | wxFAIL_MSG( _T("wxExecute() not yet implemented") ); | |
39 | return 0; | |
40 | } | |
41 | #endif | |
42 | ||
43 | #ifdef __DARWIN__ | |
44 | void wxMAC_MachPortEndProcessDetect(CFMachPortRef port, void *data) | |
45 | { | |
46 | wxEndProcessData *proc_data = (wxEndProcessData*)data; | |
47 | wxLogDebug(wxT("Wow.. this actually worked!")); | |
48 | int status = 0; | |
49 | int rc = waitpid(abs(proc_data->pid), &status, WNOHANG); | |
50 | if(!rc) | |
51 | { | |
52 | wxLogDebug(wxT("Mach port was invalidated, but process hasn't terminated!")); | |
53 | return; | |
54 | } | |
55 | if((rc != -1) && WIFEXITED(status)) | |
56 | proc_data->exitcode = WEXITSTATUS(status); | |
57 | else | |
58 | proc_data->exitcode = -1; | |
59 | wxHandleProcessTermination(proc_data); | |
60 | } | |
61 | ||
62 | int wxAddProcessCallbackForPid(wxEndProcessData *proc_data, int pid) | |
63 | { | |
64 | if(pid < 1) | |
65 | return -1; | |
66 | kern_return_t kernResult; | |
67 | mach_port_t taskOfOurProcess; | |
68 | mach_port_t machPortForProcess; | |
69 | taskOfOurProcess = mach_task_self(); | |
70 | if(taskOfOurProcess == MACH_PORT_NULL) | |
71 | { | |
72 | wxLogDebug(wxT("No mach_task_self()")); | |
73 | return -1; | |
74 | } | |
75 | wxLogDebug(wxT("pid=%d"),pid); | |
76 | kernResult = task_for_pid(taskOfOurProcess,pid, &machPortForProcess); | |
77 | if(kernResult != KERN_SUCCESS) | |
78 | { | |
79 | wxLogDebug(wxT("no task_for_pid()")); | |
80 | // try seeing if it is already dead or something | |
81 | // FIXME: a better method would be to call the callback function | |
82 | // from idle time until the process terminates. Of course, how | |
83 | // likely is it that it will take more than 0.1 seconds for the | |
84 | // mach terminate event to make its way to the BSD subsystem? | |
85 | usleep(100); // sleep for 0.1 seconds | |
86 | wxMAC_MachPortEndProcessDetect(NULL, (void*)proc_data); | |
87 | return -1; | |
88 | } | |
89 | CFMachPortContext termcb_contextinfo; | |
90 | termcb_contextinfo.version = NULL; | |
91 | termcb_contextinfo.info = (void*)proc_data; | |
92 | termcb_contextinfo.retain = NULL; | |
93 | termcb_contextinfo.release = NULL; | |
94 | termcb_contextinfo.copyDescription = NULL; | |
95 | CFMachPortRef CFMachPortForProcess; | |
96 | Boolean ShouldFreePort; | |
97 | CFMachPortForProcess = CFMachPortCreateWithPort(NULL, machPortForProcess, NULL, &termcb_contextinfo, &ShouldFreePort); | |
98 | if(!CFMachPortForProcess) | |
99 | { | |
100 | wxLogDebug(wxT("No CFMachPortForProcess")); | |
101 | mach_port_deallocate(taskOfOurProcess, machPortForProcess); | |
102 | return -1; | |
103 | } | |
104 | if(ShouldFreePort) | |
105 | { | |
106 | kernResult = mach_port_deallocate(taskOfOurProcess, machPortForProcess); | |
107 | if(kernResult!=KERN_SUCCESS) | |
108 | { | |
109 | wxLogDebug(wxT("Couldn't deallocate mach port")); | |
110 | return -1; | |
111 | } | |
112 | } | |
113 | CFMachPortSetInvalidationCallBack(CFMachPortForProcess, &wxMAC_MachPortEndProcessDetect); | |
114 | CFRunLoopSourceRef runloopsource; | |
115 | runloopsource = CFMachPortCreateRunLoopSource(NULL,CFMachPortForProcess, (CFIndex)0); | |
116 | if(!runloopsource) | |
117 | { | |
118 | wxLogDebug(wxT("Couldn't create runloopsource")); | |
119 | return -1; | |
120 | } | |
121 | ||
122 | CFRelease(CFMachPortForProcess); | |
123 | ||
124 | CFRunLoopAddSource(CFRunLoopGetCurrent(),runloopsource,kCFRunLoopDefaultMode); | |
125 | CFRelease(runloopsource); | |
126 | wxLogDebug(wxT("Successfully added notification to the runloop")); | |
127 | return 0; | |
128 | } | |
129 | #endif |