X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/bdc72a22686ac141e9bc4559a1171d017fdcb094..1c2d49808c776fcfef8db18018cdd948984a9bf1:/src/unix/utilsunx.cpp?ds=inline diff --git a/src/unix/utilsunx.cpp b/src/unix/utilsunx.cpp index 2082e6bca1..fe4abae50e 100644 --- a/src/unix/utilsunx.cpp +++ b/src/unix/utilsunx.cpp @@ -25,7 +25,11 @@ #include "wx/process.h" #include "wx/thread.h" -#include "wx/unix/execute.h" +#include "wx/stream.h" + +#if wxUSE_GUI + #include "wx/unix/execute.h" +#endif #include #include @@ -41,9 +45,7 @@ #include // for O_WRONLY and friends #include // nanosleep() and/or usleep() #include // isspace() - -// JACS: needed for FD_SETSIZE -#include +#include // needed for FD_SETSIZE #ifdef HAVE_UNAME #include // for uname() @@ -97,14 +99,14 @@ void wxSleep(int nSecs) void wxUsleep(unsigned long milliseconds) { -#ifdef HAVE_NANOSLEEP +#if defined(HAVE_NANOSLEEP) timespec tmReq; - tmReq.tv_sec = milliseconds / 1000; + tmReq.tv_sec = (time_t)(milliseconds / 1000); tmReq.tv_nsec = (milliseconds % 1000) * 1000 * 1000; // we're not interested in remaining time nor in return value (void)nanosleep(&tmReq, (timespec *)NULL); -#elif defined( HAVE_USLEEP ) +#elif defined(HAVE_USLEEP) // uncomment this if you feel brave or if you are sure that your version // of Solaris has a safe usleep() function but please notice that usleep() // is known to lead to crashes in MT programs in Solaris 2.[67] and is not @@ -114,6 +116,9 @@ void wxUsleep(unsigned long milliseconds) #endif // Sun usleep(milliseconds * 1000); // usleep(3) wants microseconds +#elif defined(HAVE_SLEEP) + // under BeOS sleep() takes seconds (what about other platforms, if any?) + sleep(milliseconds * 1000); #else // !sleep function #error "usleep() or nanosleep() function required for wxUsleep" #endif // sleep function @@ -125,7 +130,7 @@ void wxUsleep(unsigned long milliseconds) int wxKill(long pid, wxSignal sig) { - return kill(pid, (int)sig); + return kill((pid_t)pid, (int)sig); } #define WXEXECUTE_NARGS 127 @@ -211,6 +216,8 @@ bool wxShell(const wxString& command) return wxExecute(cmd) != 0; } +#if wxUSE_GUI + void wxHandleProcessTermination(wxEndProcessData *proc_data) { int pid = (proc_data->pid > 0) ? proc_data->pid : -(proc_data->pid); @@ -261,7 +268,94 @@ void wxHandleProcessTermination(wxEndProcessData *proc_data) } } -long wxExecute( wxChar **argv, bool sync, wxProcess *process ) +#endif // wxUSE_GUI + +#if wxUSE_GUI + #define WXUNUSED_UNLESS_GUI(p) p +#else + #define WXUNUSED_UNLESS_GUI(p) +#endif + +// New wxStream classes to clean up the data when the process terminates + +#if wxUSE_GUI +class wxProcessFileInputStream: public wxInputStream { + public: + wxProcessFileInputStream(int fd); + ~wxProcessFileInputStream(); + + protected: + size_t OnSysRead(void *buffer, size_t bufsize); + + protected: + int m_fd; +}; + +class wxProcessFileOutputStream: public wxOutputStream { + public: + wxProcessFileOutputStream(int fd); + ~wxProcessFileOutputStream(); + + protected: + size_t OnSysWrite(const void *buffer, size_t bufsize); + + protected: + int m_fd; +}; + +wxProcessFileInputStream::wxProcessFileInputStream(int fd) +{ + m_fd = fd; +} + +wxProcessFileInputStream::~wxProcessFileInputStream() +{ + close(m_fd); +} + +size_t wxProcessFileInputStream::OnSysRead(void *buffer, size_t bufsize) +{ + int ret; + + ret = read(m_fd, buffer, bufsize); + m_lasterror = wxSTREAM_NOERROR; + if (ret == 0) + m_lasterror = wxSTREAM_EOF; + if (ret == -1) { + m_lasterror = wxSTREAM_READ_ERROR; + ret = 0; + } + return ret; +} + +wxProcessFileOutputStream::wxProcessFileOutputStream(int fd) +{ + m_fd = fd; +} + +wxProcessFileOutputStream::~wxProcessFileOutputStream() +{ + close(m_fd); +} + +size_t wxProcessFileOutputStream::OnSysWrite(const void *buffer, size_t bufsize) +{ + int ret; + + ret = write(m_fd, buffer, bufsize); + m_lasterror = wxSTREAM_NOERROR; + if (ret == -1) { + m_lasterror = wxSTREAM_WRITE_ERROR; + ret = 0; + } + return ret; +} + +#endif + +long wxExecute(wxChar **argv, + bool sync, + wxProcess * WXUNUSED_UNLESS_GUI(process)) { wxCHECK_MSG( *argv, 0, wxT("can't exec empty command") ); @@ -301,6 +395,26 @@ long wxExecute( wxChar **argv, bool sync, wxProcess *process ) } #endif // wxUSE_GUI +#if wxUSE_GUI + int in_pipe[2] = { -1, -1 }; + int out_pipe[2] = { -1, -1 }; + // Only asynchronous mode is interresting + if (!sync && process && process->NeedPipe()) + { + if (pipe(in_pipe) == -1 || pipe(out_pipe) == -1) + { + /* Free fds */ + close(end_proc_detect[0]); + close(end_proc_detect[1]); + wxLogSysError( _("Pipe creation failed (Console pipes)") ); + + ARGS_CLEANUP; + + return 0; + } + } +#endif // wxUSE_GUI + // fork the process #ifdef HAVE_VFORK pid_t pid = vfork(); @@ -309,6 +423,14 @@ long wxExecute( wxChar **argv, bool sync, wxProcess *process ) #endif if (pid == -1) { +#if wxUSE_GUI + close(end_proc_detect[0]); + close(end_proc_detect[1]); + close(in_pipe[0]); + close(in_pipe[1]); + close(out_pipe[0]); + close(out_pipe[1]); +#endif wxLogSysError( _("Fork failed") ); ARGS_CLEANUP; @@ -332,7 +454,7 @@ long wxExecute( wxChar **argv, bool sync, wxProcess *process ) for ( int fd = 0; fd < FD_SETSIZE; fd++ ) { #if wxUSE_GUI - if ( fd == end_proc_detect[1] ) + if ( fd == end_proc_detect[1] || fd == in_pipe[0] || fd == out_pipe[1] ) continue; #endif // wxUSE_GUI @@ -341,6 +463,16 @@ long wxExecute( wxChar **argv, bool sync, wxProcess *process ) } } + // Fake a console by duplicating pipes +#if wxUSE_GUI + if (in_pipe[0] != -1) { + dup2(in_pipe[0], STDIN_FILENO); + dup2(out_pipe[1], STDOUT_FILENO); + close(in_pipe[0]); + close(out_pipe[1]); + } +#endif // wxUSE_GUI + #if 0 close(STDERR_FILENO); @@ -363,7 +495,6 @@ long wxExecute( wxChar **argv, bool sync, wxProcess *process ) #if wxUSE_GUI wxEndProcessData *data = new wxEndProcessData; - ARGS_CLEANUP; if ( sync ) @@ -372,8 +503,8 @@ long wxExecute( wxChar **argv, bool sync, wxProcess *process ) data->process = NULL; // sync execution: indicate it by negating the pid - data->pid = -pid; - data->tag = wxAddProcessCallback(data, end_proc_detect[0]); + data->pid = -pid; + data->tag = wxAddProcessCallback(data, end_proc_detect[0]); // we're in parent close(end_proc_detect[1]); // close writing side @@ -389,12 +520,26 @@ long wxExecute( wxChar **argv, bool sync, wxProcess *process ) } else { + // pipe initialization: construction of the wxStreams + if (process && process->NeedPipe()) { + // These two streams are relative to this process. + wxOutputStream *my_output_stream; + wxInputStream *my_input_stream; + + my_output_stream = new wxProcessFileOutputStream(in_pipe[1]); + my_input_stream = new wxProcessFileInputStream(out_pipe[0]); + close(in_pipe[0]); // close reading side + close(out_pipe[1]); // close writing side + + process->SetPipeStreams(my_input_stream, my_output_stream); + } + // async execution, nothing special to do - caller will be // notified about the process termination if process != NULL, data // will be deleted in GTK_EndProcessDetector - data->process = process; - data->pid = pid; - data->tag = wxAddProcessCallback(data, end_proc_detect[0]); + data->process = process; + data->pid = pid; + data->tag = wxAddProcessCallback(data, end_proc_detect[0]); // we're in parent close(end_proc_detect[1]); // close writing side @@ -566,18 +711,19 @@ bool wxGetUserId(wxChar *buf, int sz) bool wxGetUserName(wxChar *buf, int sz) { struct passwd *who; - char *comma; *buf = wxT('\0'); - if ((who = getpwuid (getuid ())) != NULL) { -#ifndef __VMS__ - comma = strchr(who->pw_gecos, ','); + if ((who = getpwuid (getuid ())) != NULL) + { + // pw_gecos field in struct passwd is not standard +#if HAVE_PW_GECOS + char *comma = strchr(who->pw_gecos, ','); if (comma) *comma = '\0'; // cut off non-name comment fields wxStrncpy (buf, wxConvertMB2WX(who->pw_gecos), sz - 1); -#else +#else // !HAVE_PW_GECOS wxStrncpy (buf, wxConvertMB2WX(who->pw_name), sz - 1); -#endif +#endif // HAVE_PW_GECOS/!HAVE_PW_GECOS return TRUE; }