X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/b956262276312c23ae0f9ae30fa9b2cd34011645..137c8bde085d6d5b7c459902d2ea1a198ab48765:/src/cocoa/utilsexc.mm?ds=sidebyside diff --git a/src/cocoa/utilsexc.mm b/src/cocoa/utilsexc.mm index d54f8af2f5..348c1c1060 100644 --- a/src/cocoa/utilsexc.mm +++ b/src/cocoa/utilsexc.mm @@ -1,141 +1,33 @@ ///////////////////////////////////////////////////////////////////////////// -// Name: utilsexec.mm +// Name: src/cocoa/utilsexec.mm // Purpose: Execution-related utilities for wxCocoa -// Author: Ryan Norton (carbon darwin version based off of Stefan's code) +// Author: Ryan Norton // Modified by: // Created: 2004-10-05 // RCS-ID: $Id$ // Copyright: (c) Ryan Norton -// Licence: wxWindows licence +// Licence: wxWindows licence +// Notes: This code may be useful on platforms other than Darwin. +// On Darwin we share the CoreFoundation code with wxMac. ///////////////////////////////////////////////////////////////////////////// -#ifdef __GNUG__ -//#pragma implementation -#endif +#include "wx/wxprec.h" -#include "wx/log.h" -#include "wx/utils.h" -#ifdef __DARWIN__ -#include "wx/unix/execute.h" -#include -#include -extern "C" { -#include -} -#include +#ifndef WX_PRECOMP + #include "wx/utils.h" #endif -#include -#include -#include - -#ifndef __DARWIN__ - -long wxExecute(const wxString& command, int flags, wxProcess *WXUNUSED(handler)) -{ - wxFAIL_MSG( _T("wxExecute() not yet implemented") ); - return 0; -} - -#endif - -#ifdef __DARWIN__ -void wxMAC_MachPortEndProcessDetect(CFMachPortRef port, void *data) -{ - wxEndProcessData *proc_data = (wxEndProcessData*)data; - wxLogDebug(wxT("Wow.. this actually worked!")); - int status = 0; - int rc = waitpid(abs(proc_data->pid), &status, WNOHANG); - if(!rc) - { - wxLogDebug(wxT("Mach port was invalidated, but process hasn't terminated!")); - return; - } - if((rc != -1) && WIFEXITED(status)) - proc_data->exitcode = WEXITSTATUS(status); - else - proc_data->exitcode = -1; - wxHandleProcessTermination(proc_data); -} - -int wxAddProcessCallbackForPid(wxEndProcessData *proc_data, int pid) -{ - if(pid < 1) - return -1; - kern_return_t kernResult; - mach_port_t taskOfOurProcess; - mach_port_t machPortForProcess; - taskOfOurProcess = mach_task_self(); - if(taskOfOurProcess == MACH_PORT_NULL) - { - wxLogDebug(wxT("No mach_task_self()")); - return -1; - } - wxLogDebug(wxT("pid=%d"),pid); - kernResult = task_for_pid(taskOfOurProcess,pid, &machPortForProcess); - if(kernResult != KERN_SUCCESS) - { - wxLogDebug(wxT("no task_for_pid()")); - // try seeing if it is already dead or something - // FIXME: a better method would be to call the callback function - // from idle time until the process terminates. Of course, how - // likely is it that it will take more than 0.1 seconds for the - // mach terminate event to make its way to the BSD subsystem? - usleep(100); // sleep for 0.1 seconds - wxMAC_MachPortEndProcessDetect(NULL, (void*)proc_data); - return -1; - } - CFMachPortContext termcb_contextinfo; - termcb_contextinfo.version = NULL; - termcb_contextinfo.info = (void*)proc_data; - termcb_contextinfo.retain = NULL; - termcb_contextinfo.release = NULL; - termcb_contextinfo.copyDescription = NULL; - CFMachPortRef CFMachPortForProcess; - Boolean ShouldFreePort; - CFMachPortForProcess = CFMachPortCreateWithPort(NULL, machPortForProcess, NULL, &termcb_contextinfo, &ShouldFreePort); - if(!CFMachPortForProcess) - { - wxLogDebug(wxT("No CFMachPortForProcess")); - mach_port_deallocate(taskOfOurProcess, machPortForProcess); - return -1; - } - if(ShouldFreePort) - { - kernResult = mach_port_deallocate(taskOfOurProcess, machPortForProcess); - if(kernResult!=KERN_SUCCESS) - { - wxLogDebug(wxT("Couldn't deallocate mach port")); - return -1; - } - } - CFMachPortSetInvalidationCallBack(CFMachPortForProcess, &wxMAC_MachPortEndProcessDetect); - CFRunLoopSourceRef runloopsource; - runloopsource = CFMachPortCreateRunLoopSource(NULL,CFMachPortForProcess, (CFIndex)0); - if(!runloopsource) - { - wxLogDebug(wxT("Couldn't create runloopsource")); - return -1; - } - - CFRelease(CFMachPortForProcess); - - CFRunLoopAddSource(CFRunLoopGetCurrent(),runloopsource,kCFRunLoopDefaultMode); - CFRelease(runloopsource); - wxLogDebug(wxT("Successfully added notification to the runloop")); - return 0; -} -#endif +#include "wx/unix/execute.h" -/* -#ifdef __GNUG__ -#pragma implementation -#endif +#if 0 -#include "wx/utils.h" +#ifndef WX_PRECOMP + #if wxUSE_STREAMS + #include "wx/stream.h" + #endif // wxUSE_STREAMS +#endif //WX_PRECOMP #include "wx/process.h" -#include "wx/stream.h" #include "wx/cocoa/string.h" @@ -152,14 +44,14 @@ int wxAddProcessCallbackForPid(wxEndProcessData *proc_data, int pid) class wxPipeInputStream : public wxInputStream { public: - wxPipeInputStream(NSPipe* thePipe) : + wxPipeInputStream(NSPipe* thePipe) : m_thePipe(thePipe), m_theHandle([m_thePipe fileHandleForReading]) { } ~wxPipeInputStream() - { + { [m_thePipe release]; } @@ -170,23 +62,23 @@ protected: memcpy(buffer, [theData bytes], [theData length]); return [theData length]; } - - - NSPipe* m_thePipe; - NSFileHandle* m_theHandle; + + + NSPipe* m_thePipe; + NSFileHandle* m_theHandle; }; class wxPipeOutputStream : public wxOutputStream { public: - wxPipeOutputStream(NSPipe* thePipe) : + wxPipeOutputStream(NSPipe* thePipe) : m_thePipe(thePipe), m_theHandle([m_thePipe fileHandleForWriting]) { } ~wxPipeOutputStream() - { + { [m_thePipe release]; } @@ -194,14 +86,14 @@ protected: virtual size_t OnSysWrite(const void *buffer, size_t bufsize) { - NSData* theData = [NSData dataWithBytesNoCopy:(void*)buffer + NSData* theData = [NSData dataWithBytesNoCopy:(void*)buffer length:bufsize]; [m_theHandle writeData:theData]; return bufsize; } - - NSPipe* m_thePipe; - NSFileHandle* m_theHandle; + + NSPipe* m_thePipe; + NSFileHandle* m_theHandle; }; @interface wxTaskHandler : NSObject @@ -215,89 +107,88 @@ protected: @implementation wxTaskHandler : NSObject --(id)init:(void*)handle processIdentifier:(long)pid +-(id)init:(void*)handle processIdentifier:(long)pid { self = [super init]; - + m_handle = handle; m_pid = pid; - [[NSNotificationCenter defaultCenter] addObserver:self - selector:@selector(termHandler:) - name:NSTaskDidTerminateNotification + [[NSNotificationCenter defaultCenter] addObserver:self + selector:@selector(termHandler:) + name:NSTaskDidTerminateNotification object:nil]; return self; } -- (void)termHandler:(NSNotification *)aNotification +- (void)termHandler:(NSNotification *)aNotification { NSTask* theTask = [aNotification object]; - + if ([theTask processIdentifier] == m_pid) { - ((wxProcess*)m_handle)->OnTerminate([theTask processIdentifier], + ((wxProcess*)m_handle)->OnTerminate([theTask processIdentifier], [theTask terminationStatus]); - + [self release]; } } @end -long wxExecute(const wxString& command, - int sync, - wxProcess *handle) +long wxExecute(const wxString& command, + int sync, + wxProcess *handle) { NSTask* theTask = [[NSTask alloc] init]; - + if (handle && handle->IsRedirected()) { NSPipe* theStdinPipe = [[NSPipe alloc] init]; NSPipe* theStderrPipe = [[NSPipe alloc] init]; NSPipe* theStdoutPipe = [[NSPipe alloc] init]; - + [theTask setStandardInput:theStdinPipe]; [theTask setStandardError:theStderrPipe]; [theTask setStandardOutput:theStdoutPipe]; - + handle->SetPipeStreams(new wxPipeInputStream(theStdoutPipe), new wxPipeOutputStream(theStdinPipe), new wxPipeInputStream(theStderrPipe) ); } - - NSArray* theQuoteArguments = + + NSArray* theQuoteArguments = [wxNSStringWithWxString(command) componentsSeparatedByString:@"\""]; - - NSMutableArray* theSeperatedArguments = + + NSMutableArray* theSeparatedArguments = [NSMutableArray arrayWithCapacity:10]; - + for (unsigned i = 0; i < [theQuoteArguments count]; ++i) { - [theSeperatedArguments addObjectsFromArray: + [theSeparatedArguments addObjectsFromArray: [[theQuoteArguments objectAtIndex:i] componentsSeparatedByString:@" "] ]; - + if(++i < [theQuoteArguments count]) - [theSeperatedArguments addObject:[theQuoteArguments objectAtIndex:i]]; + [theSeparatedArguments addObject:[theQuoteArguments objectAtIndex:i]]; } - - [theTask setLaunchPath:[theSeperatedArguments objectAtIndex:0]]; - [theTask setArguments:theSeperatedArguments]; + + [theTask setLaunchPath:[theSeparatedArguments objectAtIndex:0]]; + [theTask setArguments:theSeparatedArguments]; [theTask launch]; - + if(sync & wxEXEC_ASYNC) { - [[wxTaskHandler alloc]init:handle + [[wxTaskHandler alloc]init:handle processIdentifier:[theTask processIdentifier]]; - + return 0; } else { [theTask waitUntilExit]; - + return [theTask terminationStatus]; - } + } } - -*/ \ No newline at end of file +#endif //0