xemacs-beta: src/process-nt.c comparison

comparison src/process-nt.c @ 404:2f8bb876ab1d r21-2-32

Import from CVS: tag r21-2-32

author	cvs
date	Mon, 13 Aug 2007 11:16:07 +0200
parents	a86b2b5e0111
children	b8cc9ab3f761

comparison

equal deleted inserted replaced

-:9f011ab08d48
+:2f8bb876ab1d
 /* 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 Ben Wing.
+Copyright (C) 1995, 1996, 2000 Ben Wing.
 This file is part of XEmacs.
 XEmacs is free software; you can redistribute it and/or modify it
 under the terms of the GNU General Public License as published by the
 /* Written by Kirill M. Katsnelson <kkm@kis.ru>, April 1998 */
 #include <config.h>
 #include "lisp.h"
+#include "console-msw.h"
 #include "hash.h"
 #include "lstream.h"
 #include "process.h"
 #include "procimpl.h"
 #include "sysdep.h"
-#ifndef __MINGW32__
 #include <shellapi.h>
-#else
+#ifdef __MINGW32__
 #include <errno.h>
 #endif
 #include <signal.h>
 #ifdef HAVE_SOCKETS
 #include <winsock.h>
 /* Implementation-specific data. Pointed to by Lisp_Process->process_data */
 struct nt_process_data
 {
 HANDLE h_process;
+DWORD dwProcessId;
+HWND hwnd; /* console window */
 int need_enable_child_signals;
 };
+/* 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_Object Vmswindows_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_Object Vmswindows_start_process_inherit_error_mode;
 #define NT_DATA(p) ((struct nt_process_data*)((p)->process_data))
 /*-----------------------------------------------------------------------*/
 /* Process helpers							 */
 HANDLE
 get_nt_process_handle (Lisp_Process *p)
 {
 return (NT_DATA (p)->h_process);
 }
+static struct Lisp_Process *
+find_process_from_pid (DWORD pid)
+{
+Lisp_Object tail, proc;
+for (tail = Vprocess_list; CONSP (tail); tail = XCDR (tail))
+{
+proc = XCAR (tail);
+if (NT_DATA (XPROCESS (proc))->dwProcessId == pid)
+	return XPROCESS (proc);
+}
+return 0;
+}
 /*-----------------------------------------------------------------------*/
 /* Running remote threads. See Microsoft Systems Journal 1994 Number 5	 */
 /* Jeffrey Richter, Load Your 32-bit DLL into Another Process's Address..*/
 /*-----------------------------------------------------------------------*/
 /*-----------------------------------------------------------------------*/
 /* Sending signals							 */
 /*-----------------------------------------------------------------------*/
+/* ---------------------------- the NT way ------------------------------- */
 /*
 * We handle the following signals:
 *
 * SIGKILL, SIGTERM, SIGQUIT, SIGHUP - These four translate to ExitProcess
 *    executed by the remote process
 /*
 * Send signal SIGNO to process H_PROCESS.
 * Return nonzero if successful.
 */
-/* This code assigns a return value of GetProcAddress to function pointers
-of many different types. Instead of heavy obscure casts, we just disable
-warnings about assignments to different function pointer types. */
-#pragma warning (disable : 4113)
 static int
-send_signal (HANDLE h_process, int signo)
+send_signal_the_nt_way (struct nt_process_data *cp, int pid, int signo)
 {
+HANDLE h_process;
 HMODULE h_kernel = GetModuleHandle ("kernel32");
+int close_process = 0;
 DWORD retval;
 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)
+	return 0;
+}
 switch (signo)
 {
 case SIGKILL:
 case SIGTERM:
 case SIGQUIT:
 case SIGHUP:
 {
 	sigkill_data d;
-	d.adr_ExitProcess = GetProcAddress (h_kernel, "ExitProcess");
+	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;
 }
 case SIGINT:
 {
 	sigint_data d;
 	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,
 }
 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
 HMODULE h_kernel = GetModuleHandle ("kernel32");
 sig_enable_data d;
 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 ------------------------------- */
+static BOOL CALLBACK
+find_child_console (HWND hwnd, struct nt_process_data *cp)
+{
+DWORD thread_id;
+DWORD process_id;
+thread_id = GetWindowThreadProcessId (hwnd, &process_id);
+if (process_id == cp->dwProcessId)
+{
+char window_class[32];
+GetClassName (hwnd, window_class, sizeof (window_class));
+if (strcmp (window_class,
+		  msw_windows9x_p ()
+		  ? "tty"
+		  : "ConsoleWindowClass") == 0)
+	{
+	  cp->hwnd = hwnd;
+	  return FALSE;
+	}
+}
+/* keep looking */
+return TRUE;
+}
+static int
+send_signal_the_95_way (struct nt_process_data *cp, int pid, int signo)
+{
+HANDLE h_process;
+int close_process = 0;
+int rc = 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)
+	return 0;
+}
+if (signo == SIGINT)
+{
+if (NILP (Vmswindows_start_process_share_console) && cp && cp->hwnd)
+	{
+	  BYTE control_scan_code = (BYTE) MapVirtualKey (VK_CONTROL, 0);
+	  BYTE vk_break_code = VK_CANCEL;
+	  BYTE break_scan_code = (BYTE) MapVirtualKey (vk_break_code, 0);
+	  HWND foreground_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.  */
+DWORD foreground_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.  */
+else if (!GenerateConsoleCtrlEvent (CTRL_BREAK_EVENT, pid))
+{
+#if 0 /* FSF Emacs */
+	  DebPrint (("sys_kill.GenerateConsoleCtrlEvent return %d "
+		     "for pid %lu\n", GetLastError (), pid));
+	  errno = EINVAL;
+#endif
+	  rc = 0;
+	}
+}
+else
+{
+if (NILP (Vmswindows_start_process_share_console) && cp && cp->hwnd)
+	{
+#if 1
+	  if (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);
+#endif
+	      if (!TerminateProcess (h_process, 0xff))
+		{
+#if 0 /* FSF Emacs */
+		  DebPrint (("sys_kill.TerminateProcess returned %d "
+			     "for pid %lu\n", GetLastError (), pid));
+		  errno = EINVAL;
+#endif
+		  rc = 0;
+		}
+	    }
+	  else
+#endif
+	    PostMessage (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.  */
+else if (!TerminateProcess (h_process, 0xff))
+{
+#if 0 /* FSF Emacs */
+	  DebPrint (("sys_kill.TerminateProcess returned %d "
+		     "for pid %lu\n", GetLastError (), pid));
+	  errno = EINVAL;
+#endif
+	  rc = 0;
+}
+}
+if (close_process)
+CloseHandle (h_process);
+return rc;
+}
+/* -------------------------- all-OS functions ---------------------------- */
+static int
+send_signal (struct nt_process_data *cp, int pid, int signo)
+{
+return send_signal_the_nt_way (cp, pid, signo)
+|| send_signal_the_95_way (cp, pid, signo);
+}
 /*
 * Signal error if SIGNO is not supported
 */
 static void
 validate_signal_number (int signo)
 static void
 nt_finalize_process_data (Lisp_Process *p, int for_disksave)
 {
 assert (!for_disksave);
-if (NT_DATA(p)->h_process)
+if (NT_DATA (p)->h_process)
-CloseHandle (NT_DATA(p)->h_process);
+CloseHandle (NT_DATA (p)->h_process);
 }
 /*
 * Initialize XEmacs process implementation once
 */
 static void
 signal_cannot_launch (Lisp_Object image_file, DWORD err)
 {
 mswindows_set_errno (err);
 signal_simple_error_2 ("Error starting", image_file, lisp_strerror (errno));
+}
+static void
+ensure_console_window_exists ()
+{
+if (msw_windows9x_p ())
+msw_hide_console ();
 }
 static int
 nt_create_process (Lisp_Process *p,
 		   Lisp_Object *argv, int nargv,
 /* Create process */
 {
 STARTUPINFO si;
 PROCESS_INFORMATION pi;
 DWORD err;
+DWORD flags;
 xzero (si);
 si.dwFlags = STARTF_USESHOWWINDOW;
 si.wShowWindow = windowed ? SW_SHOWNORMAL : SW_HIDE;
 if (do_io)
 	si.hStdOutput = hprocout;
 	si.hStdError = hprocerr;
 	si.dwFlags |= STARTF_USESTDHANDLES;
 }
-err = (CreateProcess (NULL, command_line, NULL, NULL, TRUE,
+flags = CREATE_SUSPENDED;
-			  CREATE_NEW_CONSOLE | CREATE_NEW_PROCESS_GROUP
+if (msw_windows9x_p ())
-			  | CREATE_SUSPENDED,
+flags |= (!NILP (Vmswindows_start_process_share_console)
+		? CREATE_NEW_PROCESS_GROUP
+		: CREATE_NEW_CONSOLE);
+else
+flags |= 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)
 {
 /* 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. */
 {
 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)
+if (NT_DATA (p)->need_enable_child_signals > 0)
 {
-enable_child_signals(NT_DATA(p)->h_process);
+enable_child_signals (NT_DATA(p)->h_process);
-NT_DATA(p)->need_enable_child_signals = 0;
+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)->h_process, signo))
+if (!send_signal (NT_DATA (p), 0, signo))
-error ("Cannot send signal to process");
+signal_simple_error ("Cannot send signal to process", proc);
 }
 /*
 * Kill any process in the system given its PID.
 *
 * negative number upon failure
 */
 static int
 nt_kill_process_by_pid (int pid, int signo)
 {
-HANDLE h_process;
+struct Lisp_Process *p;
-int send_result;
 /* Signal error if SIGNO cannot be sent */
 validate_signal_number (signo);
-/* Try to open the process with required privileges */
+p = find_process_from_pid (pid);
-h_process = OpenProcess (PROCESS_CREATE_THREAD
+return send_signal (p ? NT_DATA (p) : 0, pid, signo) ? 0 : -1;
-			   | PROCESS_QUERY_INFORMATION
-			   | PROCESS_VM_OPERATION
-			   | PROCESS_VM_WRITE,
-			   FALSE, pid);
-if (h_process == NULL)
-return -1;
-send_result = send_signal (h_process, signo);
-CloseHandle (h_process);
-return send_result ? 0 : -1;
 }
 /*-----------------------------------------------------------------------*/
 /* Sockets connections							 */
 /*-----------------------------------------------------------------------*/
 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 */
 static void
-nt_open_network_stream (Lisp_Object name, Lisp_Object host, Lisp_Object service,
+nt_open_network_stream (Lisp_Object name, Lisp_Object host,
+			Lisp_Object service,
 			Lisp_Object protocol, void** vinfd, void** voutfd)
 {
+/* !!#### not Mule-ized */
 struct sockaddr_in address;
 SOCKET s;
 int port;
 int retval;
 CHECK_STRING (host);
 if (!EQ (protocol, Qtcp))
-error ("Unsupported protocol \"%s\"",
+signal_simple_error ("Unsupported protocol", protocol);
-	   string_data (symbol_name (XSYMBOL (protocol))));
 if (INTP (service))
 port = htons ((unsigned short) XINT (service));
 else
 {
 struct servent *svc_info;
 CHECK_STRING (service);
 svc_info = getservbyname ((char *) XSTRING_DATA (service), "tcp");
 if (svc_info == 0)
-	error ("Unknown service \"%s\"", XSTRING_DATA (service));
+	signal_simple_error ("Unknown service", service);
 port = svc_info->s_port;
 }
 get_internet_address (host, &address, ERROR_ME);
 address.sin_port = port;
 		   0, FALSE, DUPLICATE_SAME_ACCESS);
 return;
 connect_failed:
 closesocket (s);
-if (INTP (service)) {
+if (INTP (service))
-warn_when_safe(Qstream, Qwarning,
+{
-		   "failure to open network stream to host \"%s\" for service \"%d\"",
+warn_when_safe (Qstream, Qwarning,
-		   XSTRING_DATA (host),
+		      "failure to open network stream to host \"%s\" for service \"%d\"",
-		   (unsigned short) XINT (service));
+		      XSTRING_DATA (host),
-}
+		      (unsigned short) XINT (service));
-else {
+}
-warn_when_safe(Qstream, Qwarning,
+else
-		   "failure to open network stream to host \"%s\" for service \"%s\"",
+{
-		   XSTRING_DATA (host),
+warn_when_safe (Qstream, Qwarning,
-		   XSTRING_DATA (service));
+		      "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
 }
 void
 vars_of_process_nt (void)
 {
-}
+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 of
+allowing only only DOS subprocess to run at a time (whether started directly
+or indirectly by Emacs), and preventing Emacs from cleanly terminating the
+subprocess group, but may allow Emacs to interrupt a subprocess that doesn't
+otherwise 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 stops
+them blocking when trying to access unmounted drives etc.
+*/ );
+Vmswindows_start_process_inherit_error_mode = Qt;
+}

Mercurial > hg > xemacs-beta

comparison src/process-nt.c @ 404:2f8bb876ab1d r21-2-32