/* Asynchronous subprocess implementation for Win32 Copyright (C) 1985, 1986, 1987, 1988, 1992, 1993, 1994, 1995 Free Software Foundation, Inc. Copyright (C) 1995 Sun Microsystems, Inc. Copyright (C) 1995, 1996, 2000 Ben Wing.This file is part of XEmacs.XEmacs is free software; you can redistribute it and/or modify itunder the terms of the GNU General Public License as published by theFree Software Foundation; either version 2, or (at your option) anylater version.XEmacs is distributed in the hope that it will be useful, but WITHOUTANY WARRANTY; without even the implied warranty of MERCHANTABILITY orFITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public Licensefor more details.You should have received a copy of the GNU General Public Licensealong with XEmacs; see the file COPYING. If not, write tothe Free Software Foundation, Inc., 59 Temple Place - Suite 330,Boston, MA 02111-1307, USA. *//* Written by Kirill M. Katsnelson <kkm@kis.ru>, April 1998 */#include <config.h>#include "lisp.h"#include "buffer.h"#include "console-msw.h"#include "hash.h"#include "lstream.h"#include "nt.h"#include "process.h"#include "procimpl.h"#include "sysdep.h"#include <shellapi.h>#ifdef __MINGW32__#include <errno.h>#endif#include <signal.h>#ifdef HAVE_SOCKETS#include <winsock.h>#endif/* Arbitrary size limit for code fragments passed to run_in_other_process */#define FRAGMENT_CODE_SIZE 32/* Implementation-specific data. Pointed to by Lisp_Process->process_data */structnt_process_data{HANDLEh_process;DWORDdwProcessId;HWNDhwnd;/* console window */intneed_enable_child_signals;};/* Control how args are quoted to ensure correct parsing by child process. */Lisp_ObjectVmswindows_quote_process_args;/* Control whether create_child causes the process to inherit Emacs' console window, or be given a new one of its own. The default is nil, to allow multiple DOS programs to run on Win95. Having separate consoles also allows Emacs to cleanly terminate process groups. */Lisp_ObjectVmswindows_start_process_share_console;/* Control whether create_child cause the process to inherit Emacs' error mode setting. The default is t, to minimize the possibility of subprocesses blocking when accessing unmounted drives. */Lisp_ObjectVmswindows_start_process_inherit_error_mode;#define NT_DATA(p) ((struct nt_process_data*)((p)->process_data))/*-----------------------------------------------------------------------*//* Process helpers *//*-----------------------------------------------------------------------*//* This one breaks process abstraction. Prototype is in console-msw.h, used by select_process method in event-msw.c */HANDLEget_nt_process_handle(Lisp_Process*p){return(NT_DATA(p)->h_process);}staticstructLisp_Process*find_process_from_pid(DWORDpid){Lisp_Objecttail,proc;for(tail=Vprocess_list;CONSP(tail);tail=XCDR(tail)){proc=XCAR(tail);if(NT_DATA(XPROCESS(proc))->dwProcessId==pid)returnXPROCESS(proc);}return0;}/*-----------------------------------------------------------------------*//* Running remote threads. See Microsoft Systems Journal 1994 Number 5 *//* Jeffrey Richter, Load Your 32-bit DLL into Another Process's Address..*//*-----------------------------------------------------------------------*/typedefstruct{HANDLEh_process;HANDLEh_thread;LPVOIDaddress;}process_memory;/* * Allocate SIZE bytes in H_PROCESS address space. Fill in PMC used * further by other routines. Return nonzero if successful. * * The memory in other process is allocated by creating a suspended * thread. Initial stack of that thread is used as the memory * block. The thread entry point is the routine ExitThread in * kernel32.dll, so the allocated memory is freed just by resuming the * thread, which immediately terminates after that. */staticintalloc_process_memory(HANDLEh_process,size_tsize,process_memory*pmc){LPTHREAD_START_ROUTINEadr_ExitThread=(LPTHREAD_START_ROUTINE)GetProcAddress(GetModuleHandle("kernel32"),"ExitThread");DWORDdw_unused;CONTEXTcontext;MEMORY_BASIC_INFORMATIONmbi;pmc->h_process=h_process;pmc->h_thread=CreateRemoteThread(h_process,NULL,size,adr_ExitThread,NULL,CREATE_SUSPENDED,&dw_unused);if(pmc->h_thread==NULL)return0;/* Get context, for thread's stack pointer */context.ContextFlags=CONTEXT_CONTROL;if(!GetThreadContext(pmc->h_thread,&context))gotofailure;/* Determine base address of the committed range */if(sizeof(mbi)!=VirtualQueryEx(h_process,#if defined (_X86_)(LPDWORD)context.Esp-1,#elif defined (_ALPHA_)(LPDWORD)context.IntSp-1,#else#error Unknown processor architecture#endif&mbi,sizeof(mbi)))gotofailure;/* Change the page protection of the allocated memory to executable, read, and write. */if(!VirtualProtectEx(h_process,mbi.BaseAddress,size,PAGE_EXECUTE_READWRITE,&dw_unused))gotofailure;pmc->address=mbi.BaseAddress;return1;failure:ResumeThread(pmc->h_thread);pmc->address=0;return0;}staticvoidfree_process_memory(process_memory*pmc){ResumeThread(pmc->h_thread);}/* * Run ROUTINE in the context of process determined by H_PROCESS. The * routine is passed the address of DATA as parameter. The ROUTINE must * not be longer than ROUTINE_CODE_SIZE bytes. DATA_SIZE is the size of * DATA structure. * * Note that the code must be positionally independent, and compiled * without stack checks (they cause implicit calls into CRT so will * fail). DATA should not refer any data in calling process, as both * routine and its data are copied into remote process. Size of data * and code together should not exceed one page (4K on x86 systems). * * Return the value returned by ROUTINE, or (DWORD)-1 if call failed. */staticDWORDrun_in_other_process(HANDLEh_process,LPTHREAD_START_ROUTINEroutine,LPVOIDdata,size_tdata_size){process_memorypm;constsize_tcode_size=FRAGMENT_CODE_SIZE;/* Need at most 3 extra bytes of memory, for data alignment */size_ttotal_size=code_size+data_size+3;LPVOIDremote_data;HANDLEh_thread;DWORDdw_unused;/* Allocate memory */if(!alloc_process_memory(h_process,total_size,&pm))return(DWORD)-1;/* Copy code */if(!WriteProcessMemory(h_process,pm.address,(LPVOID)routine,code_size,NULL))gotofailure;/* Copy data */if(data_size){remote_data=(LPBYTE)pm.address+((code_size+4)&~3);if(!WriteProcessMemory(h_process,remote_data,data,data_size,NULL))gotofailure;}elseremote_data=NULL;/* Execute the remote copy of code, passing it remote data */h_thread=CreateRemoteThread(h_process,NULL,0,(LPTHREAD_START_ROUTINE)pm.address,remote_data,0,&dw_unused);if(h_thread==NULL)gotofailure;/* Wait till thread finishes */WaitForSingleObject(h_thread,INFINITE);/* Free remote memory */free_process_memory(&pm);/* Return thread's exit code */{DWORDexit_code;GetExitCodeThread(h_thread,&exit_code);CloseHandle(h_thread);returnexit_code;}failure:free_process_memory(&pm);return(DWORD)-1;}/*-----------------------------------------------------------------------*//* Sending signals *//*-----------------------------------------------------------------------*//* ---------------------------- the NT way ------------------------------- *//* * We handle the following signals: * * SIGKILL, SIGTERM, SIGQUIT, SIGHUP - These four translate to ExitProcess * executed by the remote process * SIGINT - The remote process is sent CTRL_BREAK_EVENT * * The MSVC5.0 compiler feels free to re-order functions within a * compilation unit, so we have no way of finding out the size of the * following functions. Therefore these functions must not be larger than * FRAGMENT_CODE_SIZE. *//* * Sending SIGKILL */typedefstruct{void(WINAPI*adr_ExitProcess)(UINT);}sigkill_data;staticDWORDWINAPIsigkill_proc(sigkill_data*data){(*data->adr_ExitProcess)(255);return1;}/* * Sending break or control c */typedefstruct{BOOL(WINAPI*adr_GenerateConsoleCtrlEvent)(DWORD,DWORD);DWORDevent;}sigint_data;staticDWORDWINAPIsigint_proc(sigint_data*data){return(*data->adr_GenerateConsoleCtrlEvent)(data->event,0);}/* * Enabling signals */typedefstruct{BOOL(WINAPI*adr_SetConsoleCtrlHandler)(LPVOID,BOOL);}sig_enable_data;staticDWORDWINAPIsig_enable_proc(sig_enable_data*data){(*data->adr_SetConsoleCtrlHandler)(NULL,FALSE);return1;}/* * Send signal SIGNO to process H_PROCESS. * Return nonzero if successful. */staticintsend_signal_the_nt_way(structnt_process_data*cp,intpid,intsigno){HANDLEh_process;HMODULEh_kernel=GetModuleHandle("kernel32");intclose_process=0;DWORDretval;assert(h_kernel!=NULL);if(cp){pid=cp->dwProcessId;h_process=cp->h_process;}else{close_process=1;/* Try to open the process with required privileges */h_process=OpenProcess(PROCESS_CREATE_THREAD|PROCESS_QUERY_INFORMATION|PROCESS_VM_OPERATION|PROCESS_VM_WRITE,FALSE,pid);if(!h_process)return0;}switch(signo){caseSIGKILL:caseSIGTERM:caseSIGQUIT:caseSIGHUP:{sigkill_datad;d.adr_ExitProcess=(void(WINAPI*)(UINT))GetProcAddress(h_kernel,"ExitProcess");assert(d.adr_ExitProcess);retval=run_in_other_process(h_process,(LPTHREAD_START_ROUTINE)sigkill_proc,&d,sizeof(d));break;}caseSIGINT:{sigint_datad;d.adr_GenerateConsoleCtrlEvent=(BOOL(WINAPI*)(DWORD,DWORD))GetProcAddress(h_kernel,"GenerateConsoleCtrlEvent");assert(d.adr_GenerateConsoleCtrlEvent);d.event=CTRL_C_EVENT;retval=run_in_other_process(h_process,(LPTHREAD_START_ROUTINE)sigint_proc,&d,sizeof(d));break;}default:assert(0);}if(close_process)CloseHandle(h_process);return(int)retval>0?1:0;}/* * Enable CTRL_C_EVENT handling in a new child process */staticvoidenable_child_signals(HANDLEh_process){HMODULEh_kernel=GetModuleHandle("kernel32");sig_enable_datad;assert(h_kernel!=NULL);d.adr_SetConsoleCtrlHandler=(BOOL(WINAPI*)(LPVOID,BOOL))GetProcAddress(h_kernel,"SetConsoleCtrlHandler");assert(d.adr_SetConsoleCtrlHandler);run_in_other_process(h_process,(LPTHREAD_START_ROUTINE)sig_enable_proc,&d,sizeof(d));}#pragma warning (default : 4113)/* ---------------------------- the 95 way ------------------------------- */staticBOOLCALLBACKfind_child_console(HWNDhwnd,structnt_process_data*cp){DWORDthread_id;DWORDprocess_id;thread_id=GetWindowThreadProcessId(hwnd,&process_id);if(process_id==cp->dwProcessId){charwindow_class[32];GetClassName(hwnd,window_class,sizeof(window_class));if(strcmp(window_class,msw_windows9x_p()?"tty":"ConsoleWindowClass")==0){cp->hwnd=hwnd;returnFALSE;}}/* keep looking */returnTRUE;}staticintsend_signal_the_95_way(structnt_process_data*cp,intpid,intsigno){HANDLEh_process;intclose_process=0;intrc=1;if(cp){pid=cp->dwProcessId;h_process=cp->h_process;/* Try to locate console window for process. */EnumWindows(find_child_console,(LPARAM)cp);}else{close_process=1;/* Try to open the process with required privileges */h_process=OpenProcess(PROCESS_TERMINATE,FALSE,pid);if(!h_process)return0;}if(signo==SIGINT){if(NILP(Vmswindows_start_process_share_console)&&cp&&cp->hwnd){BYTEcontrol_scan_code=(BYTE)MapVirtualKey(VK_CONTROL,0);BYTEvk_break_code=VK_CANCEL;BYTEbreak_scan_code=(BYTE)MapVirtualKey(vk_break_code,0);HWNDforeground_window;if(break_scan_code==0){/* Fake Ctrl-C if we can't manage Ctrl-Break. */vk_break_code='C';break_scan_code=(BYTE)MapVirtualKey(vk_break_code,0);}foreground_window=GetForegroundWindow();if(foreground_window){/* NT 5.0, and apparently also Windows 98, will not allow a Window to be set to foreground directly without the user's involvement. The workaround is to attach ourselves to the thread that owns the foreground window, since that is the only thread that can set the foreground window. */DWORDforeground_thread,child_thread;foreground_thread=GetWindowThreadProcessId(foreground_window,NULL);if(foreground_thread==GetCurrentThreadId()||!AttachThreadInput(GetCurrentThreadId(),foreground_thread,TRUE))foreground_thread=0;child_thread=GetWindowThreadProcessId(cp->hwnd,NULL);if(child_thread==GetCurrentThreadId()||!AttachThreadInput(GetCurrentThreadId(),child_thread,TRUE))child_thread=0;/* Set the foreground window to the child. */if(SetForegroundWindow(cp->hwnd)){/* Generate keystrokes as if user had typed Ctrl-Break or Ctrl-C. */keybd_event(VK_CONTROL,control_scan_code,0,0);keybd_event(vk_break_code,break_scan_code,(vk_break_code=='C'?0:KEYEVENTF_EXTENDEDKEY),0);keybd_event(vk_break_code,break_scan_code,(vk_break_code=='C'?0:KEYEVENTF_EXTENDEDKEY)|KEYEVENTF_KEYUP,0);keybd_event(VK_CONTROL,control_scan_code,KEYEVENTF_KEYUP,0);/* Sleep for a bit to give time for Emacs frame to respond to focus change events (if Emacs was active app). */Sleep(100);SetForegroundWindow(foreground_window);}/* Detach from the foreground and child threads now that the foreground switching is over. */if(foreground_thread)AttachThreadInput(GetCurrentThreadId(),foreground_thread,FALSE);if(child_thread)AttachThreadInput(GetCurrentThreadId(),child_thread,FALSE);}}/* Ctrl-Break is NT equivalent of SIGINT. */elseif(!GenerateConsoleCtrlEvent(CTRL_BREAK_EVENT,pid)){#if 0 /* FSF Emacs */ DebPrint (("sys_kill.GenerateConsoleCtrlEvent return %d " "for pid %lu\n", GetLastError (), pid)); errno = EINVAL;#endifrc=0;}}else{if(NILP(Vmswindows_start_process_share_console)&&cp&&cp->hwnd){#if 1if(msw_windows9x_p()){/* Another possibility is to try terminating the VDM out-right by calling the Shell VxD (id 0x17) V86 interface, function #4 "SHELL_Destroy_VM", ie. mov edx,4 mov ebx,vm_handle call shellapi First need to determine the current VM handle, and then arrange for the shellapi call to be made from the system vm (by using Switch_VM_and_callback). Could try to invoke DestroyVM through CallVxD.*/#if 0 /* On Win95, posting WM_QUIT causes the 16-bit subsystem to hang when cmdproxy is used in conjunction with command.com for an interactive shell. Posting WM_CLOSE pops up a dialog that, when Yes is selected, does the same thing. TerminateProcess is also less than ideal in that subprocesses tend to stick around until the machine is shutdown, but at least it doesn't freeze the 16-bit subsystem. */ PostMessage (cp->hwnd, WM_QUIT, 0xff, 0);#endifif(!TerminateProcess(h_process,0xff)){#if 0 /* FSF Emacs */ DebPrint (("sys_kill.TerminateProcess returned %d " "for pid %lu\n", GetLastError (), pid)); errno = EINVAL;#endifrc=0;}}else#endifPostMessage(cp->hwnd,WM_CLOSE,0,0);}/* Kill the process. On W32 this doesn't kill child processes so it doesn't work very well for shells which is why it's not used in every case. */elseif(!TerminateProcess(h_process,0xff)){#if 0 /* FSF Emacs */ DebPrint (("sys_kill.TerminateProcess returned %d " "for pid %lu\n", GetLastError (), pid)); errno = EINVAL;#endifrc=0;}}if(close_process)CloseHandle(h_process);returnrc;}/* -------------------------- all-OS functions ---------------------------- */staticintsend_signal(structnt_process_data*cp,intpid,intsigno){returnsend_signal_the_nt_way(cp,pid,signo)||send_signal_the_95_way(cp,pid,signo);}/* * Signal error if SIGNO is not supported */staticvoidvalidate_signal_number(intsigno){if(signo!=SIGKILL&&signo!=SIGTERM&&signo!=SIGQUIT&&signo!=SIGINT&&signo!=SIGHUP)signal_simple_error("Signal number not supported",make_int(signo));}/*-----------------------------------------------------------------------*//* Process methods *//*-----------------------------------------------------------------------*//* * Allocate and initialize Lisp_Process->process_data */staticvoidnt_alloc_process_data(Lisp_Process*p){p->process_data=xnew_and_zero(structnt_process_data);}staticvoidnt_finalize_process_data(Lisp_Process*p,intfor_disksave){assert(!for_disksave);if(NT_DATA(p)->h_process)CloseHandle(NT_DATA(p)->h_process);}/* * Initialize XEmacs process implementation once */staticvoidnt_init_process(void){/* Initialize winsock */WSADATAwsa_data;/* Request Winsock v1.1 Note the order: (minor=1, major=1) */WSAStartup(MAKEWORD(1,1),&wsa_data);}/* * Fork off a subprocess. P is a pointer to newly created subprocess * object. If this function signals, the caller is responsible for * deleting (and finalizing) the process object. * * The method must return PID of the new process, a (positive??? ####) number * which fits into Lisp_Int. No return value indicates an error, the method * must signal an error instead. */staticvoidsignal_cannot_launch(Lisp_Objectimage_file,DWORDerr){mswindows_set_errno(err);signal_simple_error_2("Error starting",image_file,lisp_strerror(errno));}staticvoidensure_console_window_exists(void){if(msw_windows9x_p())msw_hide_console();}intcompare_env(constvoid*strp1,constvoid*strp2){constchar*str1=*(constchar**)strp1,*str2=*(constchar**)strp2;while(*str1&&*str2&&*str1!='='&&*str2!='='){if((*str1)>(*str2))return1;elseif((*str1)<(*str2))return-1;str1++,str2++;}if(*str1=='='&&*str2=='=')return0;elseif(*str1=='=')return-1;elsereturn1;}staticintnt_create_process(Lisp_Process*p,Lisp_Object*argv,intnargv,Lisp_Objectprogram,Lisp_Objectcur_dir){/* Synched up with sys_spawnve in FSF 20.6. Significantly different but still synchable. */HANDLEhmyshove,hmyslurp,hprocin,hprocout,hprocerr;Extbyte*command_line;BOOLdo_io,windowed;char*proc_env;/* No need to DOS-ize the filename; expand-file-name (called prior) already does this. *//* Find out whether the application is windowed or not */{/* SHGetFileInfo tends to return ERROR_FILE_NOT_FOUND on most errors. This leads to bogus error message. */DWORDimage_type;char*p=strrchr((char*)XSTRING_DATA(program),'.');if(p!=NULL&&(stricmp(p,".exe")==0||stricmp(p,".com")==0||stricmp(p,".bat")==0||stricmp(p,".cmd")==0)){image_type=SHGetFileInfo((char*)XSTRING_DATA(program),0,NULL,0,SHGFI_EXETYPE);}else{charprogname[MAX_PATH];sprintf(progname,"%s.exe",(char*)XSTRING_DATA(program));image_type=SHGetFileInfo(progname,0,NULL,0,SHGFI_EXETYPE);}if(image_type==0)signal_cannot_launch(program,(GetLastError()==ERROR_FILE_NOT_FOUND?ERROR_BAD_FORMAT:GetLastError()));windowed=HIWORD(image_type)!=0;}/* Decide whether to do I/O on process handles, or just mark the process exited immediately upon successful launching. We do I/O if the process is a console one, or if it is windowed but windowed_process_io is non-zero */do_io=!windowed||windowed_process_io;if(do_io){/* Create two unidirectional named pipes */HANDLEhtmp;SECURITY_ATTRIBUTESsa;sa.nLength=sizeof(sa);sa.bInheritHandle=TRUE;sa.lpSecurityDescriptor=NULL;CreatePipe(&hprocin,&hmyshove,&sa,0);CreatePipe(&hmyslurp,&hprocout,&sa,0);/* Duplicate the stdout handle for use as stderr */DuplicateHandle(GetCurrentProcess(),hprocout,GetCurrentProcess(),&hprocerr,0,TRUE,DUPLICATE_SAME_ACCESS);/* Stupid Win32 allows to create a pipe with *both* ends either inheritable or not. We need process ends inheritable, and local ends not inheritable. */DuplicateHandle(GetCurrentProcess(),hmyshove,GetCurrentProcess(),&htmp,0,FALSE,DUPLICATE_CLOSE_SOURCE|DUPLICATE_SAME_ACCESS);hmyshove=htmp;DuplicateHandle(GetCurrentProcess(),hmyslurp,GetCurrentProcess(),&htmp,0,FALSE,DUPLICATE_CLOSE_SOURCE|DUPLICATE_SAME_ACCESS);hmyslurp=htmp;}/* Convert an argv vector into Win32 style command line. */{inti;Bufbyte**quoted_args;intis_dos_app,is_cygnus_app;intdo_quoting=0;charescape_char=0;nargv++;/* include program; we access argv offset by 1 below */quoted_args=alloca_array(Bufbyte*,nargv);/* Determine whether program is a 16-bit DOS executable, or a Win32 executable that is implicitly linked to the Cygnus dll (implying it was compiled with the Cygnus GNU toolchain and hence relies on cygwin.dll to parse the command line - we use this to decide how to escape quote chars in command line args that must be quoted). */mswindows_executable_type(XSTRING_DATA(program),&is_dos_app,&is_cygnus_app);#if 0 /* #### we need to port this. */ /* On Windows 95, if cmdname is a DOS app, we invoke a helper application to start it by specifying the helper app as cmdname, while leaving the real app name as argv[0]. */ if (is_dos_app) { cmdname = (char*) alloca (MAXPATHLEN); if (egetenv ("CMDPROXY")) strcpy ((char*)cmdname, egetenv ("CMDPROXY")); else { strcpy ((char*)cmdname, XSTRING_DATA (Vinvocation_directory)); strcat ((char*)cmdname, "cmdproxy.exe"); } }#endif/* we have to do some conjuring here to put argv and envp into the form CreateProcess wants... argv needs to be a space separated/null terminated list of parameters, and envp is a null separated/double-null terminated list of parameters. Additionally, zero-length args and args containing whitespace or quote chars need to be wrapped in double quotes - for this to work, embedded quotes need to be escaped as well. The aim is to ensure the child process reconstructs the argv array we start with exactly, so we treat quotes at the beginning and end of arguments as embedded quotes. The Win32 GNU-based library from Cygnus doubles quotes to escape them, while MSVC uses backslash for escaping. (Actually the MSVC startup code does attempt to recognize doubled quotes and accept them, but gets it wrong and ends up requiring three quotes to get a single embedded quote!) So by default we decide whether to use quote or backslash as the escape character based on whether the binary is apparently a Cygnus compiled app. Note that using backslash to escape embedded quotes requires additional special handling if an embedded quote is already preceded by backslash, or if an arg requiring quoting ends with backslash. In such cases, the run of escape characters needs to be doubled. For consistency, we apply this special handling as long as the escape character is not quote. Since we have no idea how large argv and envp are likely to be we figure out list lengths on the fly and allocate them. */if(!NILP(Vmswindows_quote_process_args)){do_quoting=1;/* Override escape char by binding mswindows-quote-process-args to desired character, or use t for auto-selection. */if(INTP(Vmswindows_quote_process_args))escape_char=(char)XINT(Vmswindows_quote_process_args);elseescape_char=is_cygnus_app?'"':'\\';}/* do argv... */for(i=0;i<nargv;++i){Bufbyte*targ=XSTRING_DATA(i==0?program:argv[i-1]);Bufbyte*p=targ;intneed_quotes=0;intescape_char_run=0;intarglen=0;if(*p==0)need_quotes=1;for(;*p;p++){if(*p=='"'){/* allow for embedded quotes to be escaped */arglen++;need_quotes=1;/* handle the case where the embedded quote is already escaped */if(escape_char_run>0){/* To preserve the arg exactly, we need to double the preceding escape characters (plus adding one to escape the quote character itself). */arglen+=escape_char_run;}}elseif(*p==' '||*p=='\t'){need_quotes=1;}if(*p==escape_char&&escape_char!='"')escape_char_run++;elseescape_char_run=0;}if(need_quotes){arglen+=2;/* handle the case where the arg ends with an escape char - we must not let the enclosing quote be escaped. */if(escape_char_run>0)arglen+=escape_char_run;}arglen+=strlen(targ)+1;quoted_args[i]=alloca_array(Bufbyte,arglen);}for(i=0;i<nargv;++i){Bufbyte*targ=XSTRING_DATA(i==0?program:argv[i-1]);Bufbyte*p=targ;intneed_quotes=0;Bufbyte*parg=quoted_args[i];if(*p==0)need_quotes=1;if(do_quoting){for(;*p;p++)if(*p==' '||*p=='\t'||*p=='"')need_quotes=1;}if(need_quotes){intescape_char_run=0;Bufbyte*first;Bufbyte*last;p=targ;first=p;last=p+strlen(p)-1;*parg++='"';#if 0 /* This version does not escape quotes if they occur at the beginning or end of the arg - this could lead to incorrect behavior when the arg itself represents a command line containing quoted args. I believe this was originally done as a hack to make some things work, before `mswindows-quote-process-args' was added. */ while (*p) { if (*p == '"' && p > first && p < last) *parg++ = escape_char; /* escape embedded quotes */ *parg++ = *p++; }#elsefor(;*p;p++){if(*p=='"'){/* double preceding escape chars if any */while(escape_char_run>0){*parg++=escape_char;escape_char_run--;}/* escape all quote chars, even at beginning or end */*parg++=escape_char;}*parg++=*p;if(*p==escape_char&&escape_char!='"')escape_char_run++;elseescape_char_run=0;}/* double escape chars before enclosing quote */while(escape_char_run>0){*parg++=escape_char;escape_char_run--;}#endif*parg++='"';}else{strcpy(parg,targ);parg+=strlen(targ);}*parg='\0';}{inttotal_cmdline_len=0;Extcount*extargcount=(Extcount*)alloca_array(Extcount,nargv);Extbyte**extarg=(Extbyte**)alloca_array(Extbyte*,nargv);Extbyte*command_ptr;for(i=0;i<nargv;++i){TO_EXTERNAL_FORMAT(C_STRING,quoted_args[i],ALLOCA,(extarg[i],extargcount[i]),Qmswindows_tstr);/* account for space and terminating null */total_cmdline_len+=extargcount[i]+EITCHAR_SIZE;}command_line=alloca_array(char,total_cmdline_len);command_ptr=command_line;for(i=0;i<nargv;++i){memcpy(command_ptr,extarg[i],extargcount[i]);command_ptr+=extargcount[i];EICOPY_TCHAR(command_ptr,' ');command_ptr+=EITCHAR_SIZE;}EICOPY_TCHAR(command_ptr,'\0');command_ptr+=EITCHAR_SIZE;}}/* Set `proc_env' to a nul-separated array of the strings in Vprocess_environment terminated by 2 nuls. */{char**env;REGISTERLisp_Objecttem;REGISTERchar**new_env;REGISTERintnew_length=0,i,new_space;char*penv;for(tem=Vprocess_environment;(CONSP(tem)&&STRINGP(XCAR(tem)));tem=XCDR(tem))new_length++;/* FSF adds an extra env var to hold the current process ID of the Emacs process. Apparently this is used only by emacsserver.c, which we have superseded to gnuserv.c. (#### Does it work under MS Windows?) sprintf (ppid_env_var_buffer, "EM_PARENT_PROCESS_ID=%d", GetCurrentProcessId ()); arglen += strlen (ppid_env_var_buffer) + 1; numenv++; *//* new_length + 1 to include terminating 0. */env=new_env=alloca_array(char*,new_length+1);/* Copy the Vprocess_environment strings into new_env. */for(tem=Vprocess_environment;(CONSP(tem)&&STRINGP(XCAR(tem)));tem=XCDR(tem)){char**ep=env;char*string=(char*)XSTRING_DATA(XCAR(tem));/* See if this string duplicates any string already in the env. If so, don't put it in. When an env var has multiple definitions, we keep the definition that comes first in process-environment. */for(;ep!=new_env;ep++){char*p=*ep,*q=string;while(1){if(*q==0)/* The string is malformed; might as well drop it. */gotoduplicate;if(*q!=*p)break;if(*q=='=')gotoduplicate;p++,q++;}}*new_env++=string;duplicate:;}*new_env=0;/* Sort the environment variables */new_length=new_env-env;qsort(env,new_length,sizeof(char*),compare_env);/* Work out how much space to allocate */new_space=0;for(i=0;i<new_length;i++){new_space+=strlen(env[i])+1;}new_space++;/* Allocate space and copy variables into it */penv=proc_env=(char*)alloca(new_space);for(i=0;i<new_length;i++){strcpy(penv,env[i]);penv+=strlen(env[i])+1;}*penv=0;}/* Create process */{STARTUPINFOsi;PROCESS_INFORMATIONpi;DWORDerr;DWORDflags;xzero(si);si.dwFlags=STARTF_USESHOWWINDOW;si.wShowWindow=windowed?SW_SHOWNORMAL:SW_HIDE;if(do_io){si.hStdInput=hprocin;si.hStdOutput=hprocout;si.hStdError=hprocerr;si.dwFlags|=STARTF_USESTDHANDLES;}flags=CREATE_SUSPENDED;if(msw_windows9x_p())flags|=(!NILP(Vmswindows_start_process_share_console)?CREATE_NEW_PROCESS_GROUP:CREATE_NEW_CONSOLE);elseflags|=CREATE_NEW_CONSOLE|CREATE_NEW_PROCESS_GROUP;if(NILP(Vmswindows_start_process_inherit_error_mode))flags|=CREATE_DEFAULT_ERROR_MODE;ensure_console_window_exists();err=(CreateProcess(NULL,command_line,NULL,NULL,TRUE,flags,proc_env,(char*)XSTRING_DATA(cur_dir),&si,&pi)?0:GetLastError());if(do_io){/* These just have been inherited; we do not need a copy */CloseHandle(hprocin);CloseHandle(hprocout);CloseHandle(hprocerr);}/* Handle process creation failure */if(err){if(do_io){CloseHandle(hmyshove);CloseHandle(hmyslurp);}signal_cannot_launch(program,GetLastError());}/* The process started successfully */if(do_io){NT_DATA(p)->h_process=pi.hProcess;NT_DATA(p)->dwProcessId=pi.dwProcessId;init_process_io_handles(p,(void*)hmyslurp,(void*)hmyshove,0);}else{/* Indicate as if the process has exited immediately. */p->status_symbol=Qexit;CloseHandle(pi.hProcess);}ResumeThread(pi.hThread);CloseHandle(pi.hThread);/* Remember to enable child signals later if this is not a windowed app. Can't do it right now because that screws up the MKS Toolkit shell. */if(!windowed){NT_DATA(p)->need_enable_child_signals=10;kick_status_notify();}return((int)pi.dwProcessId);}}/* * This method is called to update status fields of the process * structure. If the process has not existed, this method is expected * to do nothing. * * The method is called only for real child processes. */staticvoidnt_update_status_if_terminated(Lisp_Process*p){DWORDexit_code;if(NT_DATA(p)->need_enable_child_signals>1){NT_DATA(p)->need_enable_child_signals-=1;kick_status_notify();}elseif(NT_DATA(p)->need_enable_child_signals==1){enable_child_signals(NT_DATA(p)->h_process);NT_DATA(p)->need_enable_child_signals=0;}if(GetExitCodeProcess(NT_DATA(p)->h_process,&exit_code)&&exit_code!=STILL_ACTIVE){p->tick++;p->core_dumped=0;/* The exit code can be a code returned by process, or an NTSTATUS value. We cannot accurately handle the latter since it is a full 32 bit integer */if(exit_code&0xC0000000){p->status_symbol=Qsignal;p->exit_code=exit_code&0x1FFFFFFF;}else{p->status_symbol=Qexit;p->exit_code=exit_code;}}}/* * Stuff the entire contents of LSTREAM to the process output pipe *//* #### If only this function could be somehow merged with unix_send_process... */staticvoidnt_send_process(Lisp_Objectproc,structlstream*lstream){volatileLisp_Objectvol_proc=proc;Lisp_Process*volatilep=XPROCESS(proc);/* use a reasonable-sized buffer (somewhere around the size of the stream buffer) so as to avoid inundating the stream with blocked data. */Bufbytechunkbuf[512];Bytecountchunklen;while(1){ssize_twriteret;chunklen=Lstream_read(lstream,chunkbuf,512);if(chunklen<=0)break;/* perhaps should abort() if < 0? This should never happen. *//* Lstream_write() will never successfully write less than the amount sent in. In the worst case, it just buffers the unwritten data. */writeret=Lstream_write(XLSTREAM(DATA_OUTSTREAM(p)),chunkbuf,chunklen);Lstream_flush(XLSTREAM(DATA_OUTSTREAM(p)));if(writeret<0){p->status_symbol=Qexit;p->exit_code=ERROR_BROKEN_PIPE;p->core_dumped=0;p->tick++;process_tick++;deactivate_process(*((Lisp_Object*)(&vol_proc)));error("Broken pipe error sending to process %s; closed it",XSTRING_DATA(p->name));}{intwait_ms=25;while(Lstream_was_blocked_p(XLSTREAM(p->pipe_outstream))){/* Buffer is full. Wait, accepting input; that may allow the program to finish doing output and read more. */Faccept_process_output(Qnil,Qzero,make_int(wait_ms));Lstream_flush(XLSTREAM(p->pipe_outstream));wait_ms=min(1000,2*wait_ms);}}}}/* * Send a signal number SIGNO to PROCESS. * CURRENT_GROUP means send to the process group that currently owns * the terminal being used to communicate with PROCESS. * This is used for various commands in shell mode. * If NOMSG is zero, insert signal-announcements into process's buffers * right away. * * If we can, we try to signal PROCESS by sending control characters * down the pty. This allows us to signal inferiors who have changed * their uid, for which killpg would return an EPERM error. * * The method signals an error if the given SIGNO is not valid */staticvoidnt_kill_child_process(Lisp_Objectproc,intsigno,intcurrent_group,intnomsg){Lisp_Process*p=XPROCESS(proc);/* Enable child signals if necessary. This may lose the first but it's better than nothing. */if(NT_DATA(p)->need_enable_child_signals>0){enable_child_signals(NT_DATA(p)->h_process);NT_DATA(p)->need_enable_child_signals=0;}/* Signal error if SIGNO cannot be sent */validate_signal_number(signo);/* Send signal */if(!send_signal(NT_DATA(p),0,signo))signal_simple_error("Cannot send signal to process",proc);}/* * Kill any process in the system given its PID * * Returns zero if a signal successfully sent, or * negative number upon failure */staticintnt_kill_process_by_pid(intpid,intsigno){structLisp_Process*p;/* Signal error if SIGNO cannot be sent */validate_signal_number(signo);p=find_process_from_pid(pid);returnsend_signal(p?NT_DATA(p):0,pid,signo)?0:-1;}/*-----------------------------------------------------------------------*//* Sockets connections *//*-----------------------------------------------------------------------*/#ifdef HAVE_SOCKETS/* #### Hey MS, how long Winsock 2 for '95 will be in beta? */#define SOCK_TIMER_ID 666#define XM_SOCKREPLY (WM_USER + 666)staticintget_internet_address(Lisp_Objecthost,structsockaddr_in*address,Error_behaviorerrb){charbuf[MAXGETHOSTSTRUCT];HWNDhwnd;HANDLEhasync;intsuccess=0;address->sin_family=AF_INET;/* First check if HOST is already a numeric address */{unsignedlonginaddr=inet_addr(XSTRING_DATA(host));if(inaddr!=INADDR_NONE){address->sin_addr.s_addr=inaddr;return1;}}/* Create a window which will receive completion messages */hwnd=CreateWindow("STATIC",NULL,WS_OVERLAPPED,0,0,1,1,NULL,NULL,NULL,NULL);assert(hwnd);/* Post name resolution request */hasync=WSAAsyncGetHostByName(hwnd,XM_SOCKREPLY,XSTRING_DATA(host),buf,sizeof(buf));if(hasync==NULL)gotodone;/* Set a timer to poll for quit every 250 ms */SetTimer(hwnd,SOCK_TIMER_ID,250,NULL);while(1){MSGmsg;GetMessage(&msg,hwnd,0,0);if(msg.message==XM_SOCKREPLY){/* Ok, got an answer */if(WSAGETASYNCERROR(msg.lParam)==NO_ERROR)success=1;else{warn_when_safe(Qstream,Qwarning,"cannot get IP address for host \"%s\"",XSTRING_DATA(host));}gotodone;}elseif(msg.message==WM_TIMER&&msg.wParam==SOCK_TIMER_ID){if(QUITP){WSACancelAsyncRequest(hasync);KillTimer(hwnd,SOCK_TIMER_ID);DestroyWindow(hwnd);REALLY_QUIT;}}DispatchMessage(&msg);}done:KillTimer(hwnd,SOCK_TIMER_ID);DestroyWindow(hwnd);if(success){/* BUF starts with struct hostent */structhostent*he=(structhostent*)buf;address->sin_addr.s_addr=*(unsignedlong*)he->h_addr_list[0];}returnsuccess;}staticLisp_Objectnt_canonicalize_host_name(Lisp_Objecthost){structsockaddr_inaddress;if(!get_internet_address(host,&address,ERROR_ME_NOT))returnhost;if(address.sin_family==AF_INET)returnbuild_string(inet_ntoa(address.sin_addr));elsereturnhost;}/* open a TCP network connection to a given HOST/SERVICE. Treated exactly like a normal process when reading and writing. Only differences are in status display and process deletion. A network connection has no PID; you cannot signal it. All you can do is deactivate and close it via delete-process */staticvoidnt_open_network_stream(Lisp_Objectname,Lisp_Objecthost,Lisp_Objectservice,Lisp_Objectprotocol,void**vinfd,void**voutfd){/* !!#### not Mule-ized */structsockaddr_inaddress;SOCKETs;intport;intretval;CHECK_STRING(host);if(!EQ(protocol,Qtcp))signal_simple_error("Unsupported protocol",protocol);if(INTP(service))port=htons((unsignedshort)XINT(service));else{structservent*svc_info;CHECK_STRING(service);svc_info=getservbyname((char*)XSTRING_DATA(service),"tcp");if(svc_info==0)signal_simple_error("Unknown service",service);port=svc_info->s_port;}get_internet_address(host,&address,ERROR_ME);address.sin_port=port;s=socket(address.sin_family,SOCK_STREAM,0);if(s<0)report_file_error("error creating socket",list1(name));/* We don't want to be blocked on connect */{unsignedlongnonblock=1;ioctlsocket(s,FIONBIO,&nonblock);}retval=connect(s,(structsockaddr*)&address,sizeof(address));if(retval!=NO_ERROR&&WSAGetLastError()!=WSAEWOULDBLOCK)gotoconnect_failed;/* Wait while connection is established */while(1){fd_setfdset;structtimevaltv;intnsel;if(QUITP){closesocket(s);REALLY_QUIT;}/* Poll for quit every 250 ms */tv.tv_sec=0;tv.tv_usec=250*1000;FD_ZERO(&fdset);FD_SET(s,&fdset);nsel=select(0,NULL,&fdset,&fdset,&tv);if(nsel>0){/* Check: was connection successful or not? */tv.tv_usec=0;nsel=select(0,NULL,NULL,&fdset,&tv);if(nsel>0)gotoconnect_failed;elsebreak;}}/* We are connected at this point */*vinfd=(void*)s;DuplicateHandle(GetCurrentProcess(),(HANDLE)s,GetCurrentProcess(),(LPHANDLE)voutfd,0,FALSE,DUPLICATE_SAME_ACCESS);return;connect_failed:closesocket(s);if(INTP(service)){warn_when_safe(Qstream,Qwarning,"failure to open network stream to host \"%s\" for service \"%d\"",XSTRING_DATA(host),(unsignedshort)XINT(service));}else{warn_when_safe(Qstream,Qwarning,"failure to open network stream to host \"%s\" for service \"%s\"",XSTRING_DATA(host),XSTRING_DATA(service));}report_file_error("connection failed",list2(host,name));}#endif/*-----------------------------------------------------------------------*//* Initialization *//*-----------------------------------------------------------------------*/voidprocess_type_create_nt(void){PROCESS_HAS_METHOD(nt,alloc_process_data);PROCESS_HAS_METHOD(nt,finalize_process_data);PROCESS_HAS_METHOD(nt,init_process);PROCESS_HAS_METHOD(nt,create_process);PROCESS_HAS_METHOD(nt,update_status_if_terminated);PROCESS_HAS_METHOD(nt,send_process);PROCESS_HAS_METHOD(nt,kill_child_process);PROCESS_HAS_METHOD(nt,kill_process_by_pid);#ifdef HAVE_SOCKETSPROCESS_HAS_METHOD(nt,canonicalize_host_name);PROCESS_HAS_METHOD(nt,open_network_stream);#ifdef HAVE_MULTICAST#error I won't do this until '95 has winsock2PROCESS_HAS_METHOD(nt,open_multicast_group);#endif#endif}voidsyms_of_process_nt(void){}voidvars_of_process_nt(void){DEFVAR_LISP("mswindows-quote-process-args",&Vmswindows_quote_process_args/*Non-nil enables quoting of process arguments to ensure correct parsing.Because Windows does not directly pass argv arrays to child processes,programs have to reconstruct the argv array by parsing the commandline string. For an argument to contain a space, it must be enclosedin double quotes or it will be parsed as multiple arguments.If the value is a character, that character will be used to escape anyquote characters that appear, otherwise a suitable escape characterwill be chosen based on the type of the program (normal or Cygwin).*/);Vmswindows_quote_process_args=Qt;DEFVAR_LISP("mswindows-start-process-share-console",&Vmswindows_start_process_share_console/*When nil, new child processes are given a new console.When non-nil, they share the Emacs console; this has the limitation ofallowing only only DOS subprocess to run at a time (whether started directlyor indirectly by Emacs), and preventing Emacs from cleanly terminating thesubprocess group, but may allow Emacs to interrupt a subprocess that doesn'totherwise respond to interrupts from Emacs.*/);Vmswindows_start_process_share_console=Qnil;DEFVAR_LISP("mswindows-start-process-inherit-error-mode",&Vmswindows_start_process_inherit_error_mode/* "When nil, new child processes revert to the default error mode.When non-nil, they inherit their error mode setting from Emacs, which stopsthem blocking when trying to access unmounted drives etc.*/);Vmswindows_start_process_inherit_error_mode=Qt;}