Converted spawnve, but not tested the result yet.
[bpt/emacs.git] / src / w32proc.c
1 /* Process support for GNU Emacs on the Microsoft Windows API.
2 Copyright (C) 1992, 1995, 1999-2013 Free Software Foundation, Inc.
3
4 This file is part of GNU Emacs.
5
6 GNU Emacs is free software: you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation, either version 3 of the License, or
9 (at your option) any later version.
10
11 GNU Emacs is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
15
16 You should have received a copy of the GNU General Public License
17 along with GNU Emacs. If not, see <http://www.gnu.org/licenses/>. */
18
19 /*
20 Drew Bliss Oct 14, 1993
21 Adapted from alarm.c by Tim Fleehart
22 */
23
24 #include <mingw_time.h>
25 #include <stdio.h>
26 #include <stdlib.h>
27 #include <errno.h>
28 #include <ctype.h>
29 #include <io.h>
30 #include <fcntl.h>
31 #include <signal.h>
32 #include <sys/file.h>
33 #include <mbstring.h>
34
35 /* must include CRT headers *before* config.h */
36 #include <config.h>
37
38 #undef signal
39 #undef wait
40 #undef spawnve
41 #undef select
42 #undef kill
43
44 #include <windows.h>
45 #ifdef __GNUC__
46 /* This definition is missing from mingw32 headers. */
47 extern BOOL WINAPI IsValidLocale (LCID, DWORD);
48 #endif
49
50 #ifdef HAVE_LANGINFO_CODESET
51 #include <nl_types.h>
52 #include <langinfo.h>
53 #endif
54
55 #include "lisp.h"
56 #include "w32.h"
57 #include "w32common.h"
58 #include "w32heap.h"
59 #include "systime.h"
60 #include "syswait.h"
61 #include "process.h"
62 #include "syssignal.h"
63 #include "w32term.h"
64 #include "dispextern.h" /* for xstrcasecmp */
65 #include "coding.h"
66
67 #define RVA_TO_PTR(var,section,filedata) \
68 ((void *)((section)->PointerToRawData \
69 + ((DWORD_PTR)(var) - (section)->VirtualAddress) \
70 + (filedata).file_base))
71
72 Lisp_Object Qhigh, Qlow;
73
74 /* Signal handlers...SIG_DFL == 0 so this is initialized correctly. */
75 static signal_handler sig_handlers[NSIG];
76
77 static sigset_t sig_mask;
78
79 static CRITICAL_SECTION crit_sig;
80
81 /* Improve on the CRT 'signal' implementation so that we could record
82 the SIGCHLD handler and fake interval timers. */
83 signal_handler
84 sys_signal (int sig, signal_handler handler)
85 {
86 signal_handler old;
87
88 /* SIGCHLD is needed for supporting subprocesses, see sys_kill
89 below. SIGALRM and SIGPROF are used by setitimer. All the
90 others are the only ones supported by the MS runtime. */
91 if (!(sig == SIGCHLD || sig == SIGSEGV || sig == SIGILL
92 || sig == SIGFPE || sig == SIGABRT || sig == SIGTERM
93 || sig == SIGALRM || sig == SIGPROF))
94 {
95 errno = EINVAL;
96 return SIG_ERR;
97 }
98 old = sig_handlers[sig];
99 /* SIGABRT is treated specially because w32.c installs term_ntproc
100 as its handler, so we don't want to override that afterwards.
101 Aborting Emacs works specially anyway: either by calling
102 emacs_abort directly or through terminate_due_to_signal, which
103 calls emacs_abort through emacs_raise. */
104 if (!(sig == SIGABRT && old == term_ntproc))
105 {
106 sig_handlers[sig] = handler;
107 if (!(sig == SIGCHLD || sig == SIGALRM || sig == SIGPROF))
108 signal (sig, handler);
109 }
110 return old;
111 }
112
113 /* Emulate sigaction. */
114 int
115 sigaction (int sig, const struct sigaction *act, struct sigaction *oact)
116 {
117 signal_handler old = SIG_DFL;
118 int retval = 0;
119
120 if (act)
121 old = sys_signal (sig, act->sa_handler);
122 else if (oact)
123 old = sig_handlers[sig];
124
125 if (old == SIG_ERR)
126 {
127 errno = EINVAL;
128 retval = -1;
129 }
130 if (oact)
131 {
132 oact->sa_handler = old;
133 oact->sa_flags = 0;
134 oact->sa_mask = empty_mask;
135 }
136 return retval;
137 }
138
139 /* Emulate signal sets and blocking of signals used by timers. */
140
141 int
142 sigemptyset (sigset_t *set)
143 {
144 *set = 0;
145 return 0;
146 }
147
148 int
149 sigaddset (sigset_t *set, int signo)
150 {
151 if (!set)
152 {
153 errno = EINVAL;
154 return -1;
155 }
156 if (signo < 0 || signo >= NSIG)
157 {
158 errno = EINVAL;
159 return -1;
160 }
161
162 *set |= (1U << signo);
163
164 return 0;
165 }
166
167 int
168 sigfillset (sigset_t *set)
169 {
170 if (!set)
171 {
172 errno = EINVAL;
173 return -1;
174 }
175
176 *set = 0xFFFFFFFF;
177 return 0;
178 }
179
180 int
181 sigprocmask (int how, const sigset_t *set, sigset_t *oset)
182 {
183 if (!(how == SIG_BLOCK || how == SIG_UNBLOCK || how == SIG_SETMASK))
184 {
185 errno = EINVAL;
186 return -1;
187 }
188
189 if (oset)
190 *oset = sig_mask;
191
192 if (!set)
193 return 0;
194
195 switch (how)
196 {
197 case SIG_BLOCK:
198 sig_mask |= *set;
199 break;
200 case SIG_SETMASK:
201 sig_mask = *set;
202 break;
203 case SIG_UNBLOCK:
204 /* FIXME: Catch signals that are blocked and reissue them when
205 they are unblocked. Important for SIGALRM and SIGPROF only. */
206 sig_mask &= ~(*set);
207 break;
208 }
209
210 return 0;
211 }
212
213 int
214 pthread_sigmask (int how, const sigset_t *set, sigset_t *oset)
215 {
216 if (sigprocmask (how, set, oset) == -1)
217 return EINVAL;
218 return 0;
219 }
220
221 int
222 sigismember (const sigset_t *set, int signo)
223 {
224 if (signo < 0 || signo >= NSIG)
225 {
226 errno = EINVAL;
227 return -1;
228 }
229 if (signo > sizeof (*set) * BITS_PER_CHAR)
230 emacs_abort ();
231
232 return (*set & (1U << signo)) != 0;
233 }
234
235 pid_t
236 getpgrp (void)
237 {
238 return getpid ();
239 }
240
241 pid_t
242 tcgetpgrp (int fd)
243 {
244 return getpid ();
245 }
246
247 int
248 setpgid (pid_t pid, pid_t pgid)
249 {
250 return 0;
251 }
252
253 pid_t
254 setsid (void)
255 {
256 return getpid ();
257 }
258
259 /* Emulations of interval timers.
260
261 Limitations: only ITIMER_REAL and ITIMER_PROF are supported.
262
263 Implementation: a separate thread is started for each timer type,
264 the thread calls the appropriate signal handler when the timer
265 expires, after stopping the thread which installed the timer. */
266
267 struct itimer_data {
268 volatile ULONGLONG expire;
269 volatile ULONGLONG reload;
270 volatile int terminate;
271 int type;
272 HANDLE caller_thread;
273 HANDLE timer_thread;
274 };
275
276 static ULONGLONG ticks_now;
277 static struct itimer_data real_itimer, prof_itimer;
278 static ULONGLONG clocks_min;
279 /* If non-zero, itimers are disabled. Used during shutdown, when we
280 delete the critical sections used by the timer threads. */
281 static int disable_itimers;
282
283 static CRITICAL_SECTION crit_real, crit_prof;
284
285 /* GetThreadTimes is not available on Windows 9X and possibly also on 2K. */
286 typedef BOOL (WINAPI *GetThreadTimes_Proc) (
287 HANDLE hThread,
288 LPFILETIME lpCreationTime,
289 LPFILETIME lpExitTime,
290 LPFILETIME lpKernelTime,
291 LPFILETIME lpUserTime);
292
293 static GetThreadTimes_Proc s_pfn_Get_Thread_Times;
294
295 #define MAX_SINGLE_SLEEP 30
296 #define TIMER_TICKS_PER_SEC 1000
297
298 /* Return a suitable time value, in 1-ms units, for THREAD, a handle
299 to a thread. If THREAD is NULL or an invalid handle, return the
300 current wall-clock time since January 1, 1601 (UTC). Otherwise,
301 return the sum of kernel and user times used by THREAD since it was
302 created, plus its creation time. */
303 static ULONGLONG
304 w32_get_timer_time (HANDLE thread)
305 {
306 ULONGLONG retval;
307 int use_system_time = 1;
308 /* The functions below return times in 100-ns units. */
309 const int tscale = 10 * TIMER_TICKS_PER_SEC;
310
311 if (thread && thread != INVALID_HANDLE_VALUE
312 && s_pfn_Get_Thread_Times != NULL)
313 {
314 FILETIME creation_ftime, exit_ftime, kernel_ftime, user_ftime;
315 ULARGE_INTEGER temp_creation, temp_kernel, temp_user;
316
317 if (s_pfn_Get_Thread_Times (thread, &creation_ftime, &exit_ftime,
318 &kernel_ftime, &user_ftime))
319 {
320 use_system_time = 0;
321 temp_creation.LowPart = creation_ftime.dwLowDateTime;
322 temp_creation.HighPart = creation_ftime.dwHighDateTime;
323 temp_kernel.LowPart = kernel_ftime.dwLowDateTime;
324 temp_kernel.HighPart = kernel_ftime.dwHighDateTime;
325 temp_user.LowPart = user_ftime.dwLowDateTime;
326 temp_user.HighPart = user_ftime.dwHighDateTime;
327 retval =
328 temp_creation.QuadPart / tscale + temp_kernel.QuadPart / tscale
329 + temp_user.QuadPart / tscale;
330 }
331 else
332 DebPrint (("GetThreadTimes failed with error code %lu\n",
333 GetLastError ()));
334 }
335
336 if (use_system_time)
337 {
338 FILETIME current_ftime;
339 ULARGE_INTEGER temp;
340
341 GetSystemTimeAsFileTime (&current_ftime);
342
343 temp.LowPart = current_ftime.dwLowDateTime;
344 temp.HighPart = current_ftime.dwHighDateTime;
345
346 retval = temp.QuadPart / tscale;
347 }
348
349 return retval;
350 }
351
352 /* Thread function for a timer thread. */
353 static DWORD WINAPI
354 timer_loop (LPVOID arg)
355 {
356 struct itimer_data *itimer = (struct itimer_data *)arg;
357 int which = itimer->type;
358 int sig = (which == ITIMER_REAL) ? SIGALRM : SIGPROF;
359 CRITICAL_SECTION *crit = (which == ITIMER_REAL) ? &crit_real : &crit_prof;
360 const DWORD max_sleep = MAX_SINGLE_SLEEP * 1000 / TIMER_TICKS_PER_SEC;
361 HANDLE hth = (which == ITIMER_REAL) ? NULL : itimer->caller_thread;
362
363 while (1)
364 {
365 DWORD sleep_time;
366 signal_handler handler;
367 ULONGLONG now, expire, reload;
368
369 /* Load new values if requested by setitimer. */
370 EnterCriticalSection (crit);
371 expire = itimer->expire;
372 reload = itimer->reload;
373 LeaveCriticalSection (crit);
374 if (itimer->terminate)
375 return 0;
376
377 if (expire == 0)
378 {
379 /* We are idle. */
380 Sleep (max_sleep);
381 continue;
382 }
383
384 if (expire > (now = w32_get_timer_time (hth)))
385 sleep_time = expire - now;
386 else
387 sleep_time = 0;
388 /* Don't sleep too long at a time, to be able to see the
389 termination flag without too long a delay. */
390 while (sleep_time > max_sleep)
391 {
392 if (itimer->terminate)
393 return 0;
394 Sleep (max_sleep);
395 EnterCriticalSection (crit);
396 expire = itimer->expire;
397 LeaveCriticalSection (crit);
398 sleep_time =
399 (expire > (now = w32_get_timer_time (hth))) ? expire - now : 0;
400 }
401 if (itimer->terminate)
402 return 0;
403 if (sleep_time > 0)
404 {
405 Sleep (sleep_time * 1000 / TIMER_TICKS_PER_SEC);
406 /* Always sleep past the expiration time, to make sure we
407 never call the handler _before_ the expiration time,
408 always slightly after it. Sleep(5) makes sure we don't
409 hog the CPU by calling 'w32_get_timer_time' with high
410 frequency, and also let other threads work. */
411 while (w32_get_timer_time (hth) < expire)
412 Sleep (5);
413 }
414
415 EnterCriticalSection (crit);
416 expire = itimer->expire;
417 LeaveCriticalSection (crit);
418 if (expire == 0)
419 continue;
420
421 /* Time's up. */
422 handler = sig_handlers[sig];
423 if (!(handler == SIG_DFL || handler == SIG_IGN || handler == SIG_ERR)
424 /* FIXME: Don't ignore masked signals. Instead, record that
425 they happened and reissue them when the signal is
426 unblocked. */
427 && !sigismember (&sig_mask, sig)
428 /* Simulate masking of SIGALRM and SIGPROF when processing
429 fatal signals. */
430 && !fatal_error_in_progress
431 && itimer->caller_thread)
432 {
433 /* Simulate a signal delivered to the thread which installed
434 the timer, by suspending that thread while the handler
435 runs. */
436 HANDLE th = itimer->caller_thread;
437 DWORD result = SuspendThread (th);
438
439 if (result == (DWORD)-1)
440 return 2;
441
442 handler (sig);
443 ResumeThread (th);
444 }
445
446 /* Update expiration time and loop. */
447 EnterCriticalSection (crit);
448 expire = itimer->expire;
449 if (expire == 0)
450 {
451 LeaveCriticalSection (crit);
452 continue;
453 }
454 reload = itimer->reload;
455 if (reload > 0)
456 {
457 now = w32_get_timer_time (hth);
458 if (expire <= now)
459 {
460 ULONGLONG lag = now - expire;
461
462 /* If we missed some opportunities (presumably while
463 sleeping or while the signal handler ran), skip
464 them. */
465 if (lag > reload)
466 expire = now - (lag % reload);
467
468 expire += reload;
469 }
470 }
471 else
472 expire = 0; /* become idle */
473 itimer->expire = expire;
474 LeaveCriticalSection (crit);
475 }
476 return 0;
477 }
478
479 static void
480 stop_timer_thread (int which)
481 {
482 struct itimer_data *itimer =
483 (which == ITIMER_REAL) ? &real_itimer : &prof_itimer;
484 int i;
485 DWORD err, exit_code = 255;
486 BOOL status;
487
488 /* Signal the thread that it should terminate. */
489 itimer->terminate = 1;
490
491 if (itimer->timer_thread == NULL)
492 return;
493
494 /* Wait for the timer thread to terminate voluntarily, then kill it
495 if it doesn't. This loop waits twice more than the maximum
496 amount of time a timer thread sleeps, see above. */
497 for (i = 0; i < MAX_SINGLE_SLEEP / 5; i++)
498 {
499 if (!((status = GetExitCodeThread (itimer->timer_thread, &exit_code))
500 && exit_code == STILL_ACTIVE))
501 break;
502 Sleep (10);
503 }
504 if ((status == FALSE && (err = GetLastError ()) == ERROR_INVALID_HANDLE)
505 || exit_code == STILL_ACTIVE)
506 {
507 if (!(status == FALSE && err == ERROR_INVALID_HANDLE))
508 TerminateThread (itimer->timer_thread, 0);
509 }
510
511 /* Clean up. */
512 CloseHandle (itimer->timer_thread);
513 itimer->timer_thread = NULL;
514 if (itimer->caller_thread)
515 {
516 CloseHandle (itimer->caller_thread);
517 itimer->caller_thread = NULL;
518 }
519 }
520
521 /* This is called at shutdown time from term_ntproc. */
522 void
523 term_timers (void)
524 {
525 if (real_itimer.timer_thread)
526 stop_timer_thread (ITIMER_REAL);
527 if (prof_itimer.timer_thread)
528 stop_timer_thread (ITIMER_PROF);
529
530 /* We are going to delete the critical sections, so timers cannot
531 work after this. */
532 disable_itimers = 1;
533
534 DeleteCriticalSection (&crit_real);
535 DeleteCriticalSection (&crit_prof);
536 DeleteCriticalSection (&crit_sig);
537 }
538
539 /* This is called at initialization time from init_ntproc. */
540 void
541 init_timers (void)
542 {
543 /* GetThreadTimes is not available on all versions of Windows, so
544 need to probe for its availability dynamically, and call it
545 through a pointer. */
546 s_pfn_Get_Thread_Times = NULL; /* in case dumped Emacs comes with a value */
547 if (os_subtype != OS_9X)
548 s_pfn_Get_Thread_Times =
549 (GetThreadTimes_Proc)GetProcAddress (GetModuleHandle ("kernel32.dll"),
550 "GetThreadTimes");
551
552 /* Make sure we start with zeroed out itimer structures, since
553 dumping may have left there traces of threads long dead. */
554 memset (&real_itimer, 0, sizeof real_itimer);
555 memset (&prof_itimer, 0, sizeof prof_itimer);
556
557 InitializeCriticalSection (&crit_real);
558 InitializeCriticalSection (&crit_prof);
559 InitializeCriticalSection (&crit_sig);
560
561 disable_itimers = 0;
562 }
563
564 static int
565 start_timer_thread (int which)
566 {
567 DWORD exit_code;
568 HANDLE th;
569 struct itimer_data *itimer =
570 (which == ITIMER_REAL) ? &real_itimer : &prof_itimer;
571
572 if (itimer->timer_thread
573 && GetExitCodeThread (itimer->timer_thread, &exit_code)
574 && exit_code == STILL_ACTIVE)
575 return 0;
576
577 /* Clean up after possibly exited thread. */
578 if (itimer->timer_thread)
579 {
580 CloseHandle (itimer->timer_thread);
581 itimer->timer_thread = NULL;
582 }
583 if (itimer->caller_thread)
584 {
585 CloseHandle (itimer->caller_thread);
586 itimer->caller_thread = NULL;
587 }
588
589 /* Start a new thread. */
590 if (!DuplicateHandle (GetCurrentProcess (), GetCurrentThread (),
591 GetCurrentProcess (), &th, 0, FALSE,
592 DUPLICATE_SAME_ACCESS))
593 {
594 errno = ESRCH;
595 return -1;
596 }
597 itimer->terminate = 0;
598 itimer->type = which;
599 itimer->caller_thread = th;
600 /* Request that no more than 64KB of stack be reserved for this
601 thread, to avoid reserving too much memory, which would get in
602 the way of threads we start to wait for subprocesses. See also
603 new_child below. */
604 itimer->timer_thread = CreateThread (NULL, 64 * 1024, timer_loop,
605 (void *)itimer, 0x00010000, NULL);
606
607 if (!itimer->timer_thread)
608 {
609 CloseHandle (itimer->caller_thread);
610 itimer->caller_thread = NULL;
611 errno = EAGAIN;
612 return -1;
613 }
614
615 /* This is needed to make sure that the timer thread running for
616 profiling gets CPU as soon as the Sleep call terminates. */
617 if (which == ITIMER_PROF)
618 SetThreadPriority (itimer->timer_thread, THREAD_PRIORITY_TIME_CRITICAL);
619
620 return 0;
621 }
622
623 /* Most of the code of getitimer and setitimer (but not of their
624 subroutines) was shamelessly stolen from itimer.c in the DJGPP
625 library, see www.delorie.com/djgpp. */
626 int
627 getitimer (int which, struct itimerval *value)
628 {
629 volatile ULONGLONG *t_expire;
630 volatile ULONGLONG *t_reload;
631 ULONGLONG expire, reload;
632 __int64 usecs;
633 CRITICAL_SECTION *crit;
634 struct itimer_data *itimer;
635
636 if (disable_itimers)
637 return -1;
638
639 if (!value)
640 {
641 errno = EFAULT;
642 return -1;
643 }
644
645 if (which != ITIMER_REAL && which != ITIMER_PROF)
646 {
647 errno = EINVAL;
648 return -1;
649 }
650
651 itimer = (which == ITIMER_REAL) ? &real_itimer : &prof_itimer;
652
653 ticks_now = w32_get_timer_time ((which == ITIMER_REAL)
654 ? NULL
655 : GetCurrentThread ());
656
657 t_expire = &itimer->expire;
658 t_reload = &itimer->reload;
659 crit = (which == ITIMER_REAL) ? &crit_real : &crit_prof;
660
661 EnterCriticalSection (crit);
662 reload = *t_reload;
663 expire = *t_expire;
664 LeaveCriticalSection (crit);
665
666 if (expire)
667 expire -= ticks_now;
668
669 value->it_value.tv_sec = expire / TIMER_TICKS_PER_SEC;
670 usecs =
671 (expire % TIMER_TICKS_PER_SEC) * (__int64)1000000 / TIMER_TICKS_PER_SEC;
672 value->it_value.tv_usec = usecs;
673 value->it_interval.tv_sec = reload / TIMER_TICKS_PER_SEC;
674 usecs =
675 (reload % TIMER_TICKS_PER_SEC) * (__int64)1000000 / TIMER_TICKS_PER_SEC;
676 value->it_interval.tv_usec= usecs;
677
678 return 0;
679 }
680
681 int
682 setitimer(int which, struct itimerval *value, struct itimerval *ovalue)
683 {
684 volatile ULONGLONG *t_expire, *t_reload;
685 ULONGLONG expire, reload, expire_old, reload_old;
686 __int64 usecs;
687 CRITICAL_SECTION *crit;
688 struct itimerval tem, *ptem;
689
690 if (disable_itimers)
691 return -1;
692
693 /* Posix systems expect timer values smaller than the resolution of
694 the system clock be rounded up to the clock resolution. First
695 time we are called, measure the clock tick resolution. */
696 if (!clocks_min)
697 {
698 ULONGLONG t1, t2;
699
700 for (t1 = w32_get_timer_time (NULL);
701 (t2 = w32_get_timer_time (NULL)) == t1; )
702 ;
703 clocks_min = t2 - t1;
704 }
705
706 if (ovalue)
707 ptem = ovalue;
708 else
709 ptem = &tem;
710
711 if (getitimer (which, ptem)) /* also sets ticks_now */
712 return -1; /* errno already set */
713
714 t_expire =
715 (which == ITIMER_REAL) ? &real_itimer.expire : &prof_itimer.expire;
716 t_reload =
717 (which == ITIMER_REAL) ? &real_itimer.reload : &prof_itimer.reload;
718
719 crit = (which == ITIMER_REAL) ? &crit_real : &crit_prof;
720
721 if (!value
722 || (value->it_value.tv_sec == 0 && value->it_value.tv_usec == 0))
723 {
724 EnterCriticalSection (crit);
725 /* Disable the timer. */
726 *t_expire = 0;
727 *t_reload = 0;
728 LeaveCriticalSection (crit);
729 return 0;
730 }
731
732 reload = value->it_interval.tv_sec * TIMER_TICKS_PER_SEC;
733
734 usecs = value->it_interval.tv_usec;
735 if (value->it_interval.tv_sec == 0
736 && usecs && usecs * TIMER_TICKS_PER_SEC < clocks_min * 1000000)
737 reload = clocks_min;
738 else
739 {
740 usecs *= TIMER_TICKS_PER_SEC;
741 reload += usecs / 1000000;
742 }
743
744 expire = value->it_value.tv_sec * TIMER_TICKS_PER_SEC;
745 usecs = value->it_value.tv_usec;
746 if (value->it_value.tv_sec == 0
747 && usecs * TIMER_TICKS_PER_SEC < clocks_min * 1000000)
748 expire = clocks_min;
749 else
750 {
751 usecs *= TIMER_TICKS_PER_SEC;
752 expire += usecs / 1000000;
753 }
754
755 expire += ticks_now;
756
757 EnterCriticalSection (crit);
758 expire_old = *t_expire;
759 reload_old = *t_reload;
760 if (!(expire == expire_old && reload == reload_old))
761 {
762 *t_reload = reload;
763 *t_expire = expire;
764 }
765 LeaveCriticalSection (crit);
766
767 return start_timer_thread (which);
768 }
769
770 int
771 alarm (int seconds)
772 {
773 #ifdef HAVE_SETITIMER
774 struct itimerval new_values, old_values;
775
776 new_values.it_value.tv_sec = seconds;
777 new_values.it_value.tv_usec = 0;
778 new_values.it_interval.tv_sec = new_values.it_interval.tv_usec = 0;
779
780 if (setitimer (ITIMER_REAL, &new_values, &old_values) < 0)
781 return 0;
782 return old_values.it_value.tv_sec;
783 #else
784 return seconds;
785 #endif
786 }
787
788 /* Defined in <process.h> which conflicts with the local copy */
789 #define _P_NOWAIT 1
790
791 /* Child process management list. */
792 int child_proc_count = 0;
793 child_process child_procs[ MAX_CHILDREN ];
794
795 static DWORD WINAPI reader_thread (void *arg);
796
797 /* Find an unused process slot. */
798 child_process *
799 new_child (void)
800 {
801 child_process *cp;
802 DWORD id;
803
804 for (cp = child_procs + (child_proc_count-1); cp >= child_procs; cp--)
805 if (!CHILD_ACTIVE (cp) && cp->procinfo.hProcess == NULL)
806 goto Initialize;
807 if (child_proc_count == MAX_CHILDREN)
808 {
809 int i = 0;
810 child_process *dead_cp = NULL;
811
812 DebPrint (("new_child: No vacant slots, looking for dead processes\n"));
813 for (cp = child_procs + (child_proc_count-1); cp >= child_procs; cp--)
814 if (!CHILD_ACTIVE (cp) && cp->procinfo.hProcess)
815 {
816 DWORD status = 0;
817
818 if (!GetExitCodeProcess (cp->procinfo.hProcess, &status))
819 {
820 DebPrint (("new_child.GetExitCodeProcess: error %lu for PID %lu\n",
821 GetLastError (), cp->procinfo.dwProcessId));
822 status = STILL_ACTIVE;
823 }
824 if (status != STILL_ACTIVE
825 || WaitForSingleObject (cp->procinfo.hProcess, 0) == WAIT_OBJECT_0)
826 {
827 DebPrint (("new_child: Freeing slot of dead process %d, fd %d\n",
828 cp->procinfo.dwProcessId, cp->fd));
829 CloseHandle (cp->procinfo.hProcess);
830 cp->procinfo.hProcess = NULL;
831 CloseHandle (cp->procinfo.hThread);
832 cp->procinfo.hThread = NULL;
833 /* Free up to 2 dead slots at a time, so that if we
834 have a lot of them, they will eventually all be
835 freed when the tornado ends. */
836 if (i == 0)
837 dead_cp = cp;
838 else
839 break;
840 i++;
841 }
842 }
843 if (dead_cp)
844 {
845 cp = dead_cp;
846 goto Initialize;
847 }
848 }
849 if (child_proc_count == MAX_CHILDREN)
850 return NULL;
851 cp = &child_procs[child_proc_count++];
852
853 Initialize:
854 /* Last opportunity to avoid leaking handles before we forget them
855 for good. */
856 if (cp->procinfo.hProcess)
857 CloseHandle (cp->procinfo.hProcess);
858 if (cp->procinfo.hThread)
859 CloseHandle (cp->procinfo.hThread);
860 memset (cp, 0, sizeof (*cp));
861 cp->fd = -1;
862 cp->pid = -1;
863 cp->procinfo.hProcess = NULL;
864 cp->status = STATUS_READ_ERROR;
865
866 /* use manual reset event so that select() will function properly */
867 cp->char_avail = CreateEvent (NULL, TRUE, FALSE, NULL);
868 if (cp->char_avail)
869 {
870 cp->char_consumed = CreateEvent (NULL, FALSE, FALSE, NULL);
871 if (cp->char_consumed)
872 {
873 /* The 0x00010000 flag is STACK_SIZE_PARAM_IS_A_RESERVATION.
874 It means that the 64K stack we are requesting in the 2nd
875 argument is how much memory should be reserved for the
876 stack. If we don't use this flag, the memory requested
877 by the 2nd argument is the amount actually _committed_,
878 but Windows reserves 8MB of memory for each thread's
879 stack. (The 8MB figure comes from the -stack
880 command-line argument we pass to the linker when building
881 Emacs, but that's because we need a large stack for
882 Emacs's main thread.) Since we request 2GB of reserved
883 memory at startup (see w32heap.c), which is close to the
884 maximum memory available for a 32-bit process on Windows,
885 the 8MB reservation for each thread causes failures in
886 starting subprocesses, because we create a thread running
887 reader_thread for each subprocess. As 8MB of stack is
888 way too much for reader_thread, forcing Windows to
889 reserve less wins the day. */
890 cp->thrd = CreateThread (NULL, 64 * 1024, reader_thread, cp,
891 0x00010000, &id);
892 if (cp->thrd)
893 return cp;
894 }
895 }
896 delete_child (cp);
897 return NULL;
898 }
899
900 void
901 delete_child (child_process *cp)
902 {
903 int i;
904
905 /* Should not be deleting a child that is still needed. */
906 for (i = 0; i < MAXDESC; i++)
907 if (fd_info[i].cp == cp)
908 emacs_abort ();
909
910 if (!CHILD_ACTIVE (cp) && cp->procinfo.hProcess == NULL)
911 return;
912
913 /* reap thread if necessary */
914 if (cp->thrd)
915 {
916 DWORD rc;
917
918 if (GetExitCodeThread (cp->thrd, &rc) && rc == STILL_ACTIVE)
919 {
920 /* let the thread exit cleanly if possible */
921 cp->status = STATUS_READ_ERROR;
922 SetEvent (cp->char_consumed);
923 #if 0
924 /* We used to forcibly terminate the thread here, but it
925 is normally unnecessary, and in abnormal cases, the worst that
926 will happen is we have an extra idle thread hanging around
927 waiting for the zombie process. */
928 if (WaitForSingleObject (cp->thrd, 1000) != WAIT_OBJECT_0)
929 {
930 DebPrint (("delete_child.WaitForSingleObject (thread) failed "
931 "with %lu for fd %ld\n", GetLastError (), cp->fd));
932 TerminateThread (cp->thrd, 0);
933 }
934 #endif
935 }
936 CloseHandle (cp->thrd);
937 cp->thrd = NULL;
938 }
939 if (cp->char_avail)
940 {
941 CloseHandle (cp->char_avail);
942 cp->char_avail = NULL;
943 }
944 if (cp->char_consumed)
945 {
946 CloseHandle (cp->char_consumed);
947 cp->char_consumed = NULL;
948 }
949
950 /* update child_proc_count (highest numbered slot in use plus one) */
951 if (cp == child_procs + child_proc_count - 1)
952 {
953 for (i = child_proc_count-1; i >= 0; i--)
954 if (CHILD_ACTIVE (&child_procs[i])
955 || child_procs[i].procinfo.hProcess != NULL)
956 {
957 child_proc_count = i + 1;
958 break;
959 }
960 }
961 if (i < 0)
962 child_proc_count = 0;
963 }
964
965 /* Find a child by pid. */
966 static child_process *
967 find_child_pid (DWORD pid)
968 {
969 child_process *cp;
970
971 for (cp = child_procs + (child_proc_count-1); cp >= child_procs; cp--)
972 if ((CHILD_ACTIVE (cp) || cp->procinfo.hProcess != NULL)
973 && pid == cp->pid)
974 return cp;
975 return NULL;
976 }
977
978 void
979 release_listen_threads (void)
980 {
981 int i;
982
983 for (i = child_proc_count - 1; i >= 0; i--)
984 {
985 if (CHILD_ACTIVE (&child_procs[i])
986 && (fd_info[child_procs[i].fd].flags & FILE_LISTEN))
987 child_procs[i].status = STATUS_READ_ERROR;
988 }
989 }
990
991 /* Thread proc for child process and socket reader threads. Each thread
992 is normally blocked until woken by select() to check for input by
993 reading one char. When the read completes, char_avail is signaled
994 to wake up the select emulator and the thread blocks itself again. */
995 static DWORD WINAPI
996 reader_thread (void *arg)
997 {
998 child_process *cp;
999
1000 /* Our identity */
1001 cp = (child_process *)arg;
1002
1003 /* We have to wait for the go-ahead before we can start */
1004 if (cp == NULL
1005 || WaitForSingleObject (cp->char_consumed, INFINITE) != WAIT_OBJECT_0
1006 || cp->fd < 0)
1007 return 1;
1008
1009 for (;;)
1010 {
1011 int rc;
1012
1013 if (cp->fd >= 0 && fd_info[cp->fd].flags & FILE_LISTEN)
1014 rc = _sys_wait_accept (cp->fd);
1015 else
1016 rc = _sys_read_ahead (cp->fd);
1017
1018 /* Don't bother waiting for the event if we already have been
1019 told to exit by delete_child. */
1020 if (cp->status == STATUS_READ_ERROR || !cp->char_avail)
1021 break;
1022
1023 /* The name char_avail is a misnomer - it really just means the
1024 read-ahead has completed, whether successfully or not. */
1025 if (!SetEvent (cp->char_avail))
1026 {
1027 DebPrint (("reader_thread.SetEvent(0x%x) failed with %lu for fd %ld (PID %d)\n",
1028 (DWORD_PTR)cp->char_avail, GetLastError (),
1029 cp->fd, cp->pid));
1030 return 1;
1031 }
1032
1033 if (rc == STATUS_READ_ERROR)
1034 return 1;
1035
1036 /* If the read died, the child has died so let the thread die */
1037 if (rc == STATUS_READ_FAILED)
1038 break;
1039
1040 /* Don't bother waiting for the acknowledge if we already have
1041 been told to exit by delete_child. */
1042 if (cp->status == STATUS_READ_ERROR || !cp->char_consumed)
1043 break;
1044
1045 /* Wait until our input is acknowledged before reading again */
1046 if (WaitForSingleObject (cp->char_consumed, INFINITE) != WAIT_OBJECT_0)
1047 {
1048 DebPrint (("reader_thread.WaitForSingleObject failed with "
1049 "%lu for fd %ld\n", GetLastError (), cp->fd));
1050 break;
1051 }
1052 /* delete_child sets status to STATUS_READ_ERROR when it wants
1053 us to exit. */
1054 if (cp->status == STATUS_READ_ERROR)
1055 break;
1056 }
1057 return 0;
1058 }
1059
1060 /* To avoid Emacs changing directory, we just record here the
1061 directory the new process should start in. This is set just before
1062 calling sys_spawnve, and is not generally valid at any other time.
1063 Note that this directory's name is UTF-8 encoded. */
1064 static char * process_dir;
1065
1066 static BOOL
1067 create_child (char *exe, char *cmdline, char *env, int is_gui_app,
1068 int * pPid, child_process *cp)
1069 {
1070 STARTUPINFO start;
1071 SECURITY_ATTRIBUTES sec_attrs;
1072 #if 0
1073 SECURITY_DESCRIPTOR sec_desc;
1074 #endif
1075 DWORD flags;
1076 char dir[ MAX_PATH ];
1077 char *p;
1078
1079 if (cp == NULL) emacs_abort ();
1080
1081 memset (&start, 0, sizeof (start));
1082 start.cb = sizeof (start);
1083
1084 #ifdef HAVE_NTGUI
1085 if (NILP (Vw32_start_process_show_window) && !is_gui_app)
1086 start.dwFlags = STARTF_USESTDHANDLES | STARTF_USESHOWWINDOW;
1087 else
1088 start.dwFlags = STARTF_USESTDHANDLES;
1089 start.wShowWindow = SW_HIDE;
1090
1091 start.hStdInput = GetStdHandle (STD_INPUT_HANDLE);
1092 start.hStdOutput = GetStdHandle (STD_OUTPUT_HANDLE);
1093 start.hStdError = GetStdHandle (STD_ERROR_HANDLE);
1094 #endif /* HAVE_NTGUI */
1095
1096 #if 0
1097 /* Explicitly specify no security */
1098 if (!InitializeSecurityDescriptor (&sec_desc, SECURITY_DESCRIPTOR_REVISION))
1099 goto EH_Fail;
1100 if (!SetSecurityDescriptorDacl (&sec_desc, TRUE, NULL, FALSE))
1101 goto EH_Fail;
1102 #endif
1103 sec_attrs.nLength = sizeof (sec_attrs);
1104 sec_attrs.lpSecurityDescriptor = NULL /* &sec_desc */;
1105 sec_attrs.bInheritHandle = FALSE;
1106
1107 filename_to_ansi (process_dir, dir);
1108 /* Can't use unixtodos_filename here, since that needs its file name
1109 argument encoded in UTF-8. OTOH, process_dir, which _is_ in
1110 UTF-8, points, to the directory computed by our caller, and we
1111 don't want to modify that, either. */
1112 for (p = dir; *p; p = CharNextA (p))
1113 if (*p == '/')
1114 *p = '\\';
1115
1116 flags = (!NILP (Vw32_start_process_share_console)
1117 ? CREATE_NEW_PROCESS_GROUP
1118 : CREATE_NEW_CONSOLE);
1119 if (NILP (Vw32_start_process_inherit_error_mode))
1120 flags |= CREATE_DEFAULT_ERROR_MODE;
1121 if (!CreateProcessA (exe, cmdline, &sec_attrs, NULL, TRUE,
1122 flags, env, dir, &start, &cp->procinfo))
1123 goto EH_Fail;
1124
1125 cp->pid = (int) cp->procinfo.dwProcessId;
1126
1127 /* Hack for Windows 95, which assigns large (ie negative) pids */
1128 if (cp->pid < 0)
1129 cp->pid = -cp->pid;
1130
1131 *pPid = cp->pid;
1132
1133 return TRUE;
1134
1135 EH_Fail:
1136 DebPrint (("create_child.CreateProcess failed: %ld\n", GetLastError ()););
1137 return FALSE;
1138 }
1139
1140 /* create_child doesn't know what emacs's file handle will be for waiting
1141 on output from the child, so we need to make this additional call
1142 to register the handle with the process
1143 This way the select emulator knows how to match file handles with
1144 entries in child_procs. */
1145 void
1146 register_child (pid_t pid, int fd)
1147 {
1148 child_process *cp;
1149
1150 cp = find_child_pid ((DWORD)pid);
1151 if (cp == NULL)
1152 {
1153 DebPrint (("register_child unable to find pid %lu\n", pid));
1154 return;
1155 }
1156
1157 #ifdef FULL_DEBUG
1158 DebPrint (("register_child registered fd %d with pid %lu\n", fd, pid));
1159 #endif
1160
1161 cp->fd = fd;
1162
1163 /* thread is initially blocked until select is called; set status so
1164 that select will release thread */
1165 cp->status = STATUS_READ_ACKNOWLEDGED;
1166
1167 /* attach child_process to fd_info */
1168 if (fd_info[fd].cp != NULL)
1169 {
1170 DebPrint (("register_child: fd_info[%d] apparently in use!\n", fd));
1171 emacs_abort ();
1172 }
1173
1174 fd_info[fd].cp = cp;
1175 }
1176
1177 /* Called from waitpid when a process exits. */
1178 static void
1179 reap_subprocess (child_process *cp)
1180 {
1181 if (cp->procinfo.hProcess)
1182 {
1183 /* Reap the process */
1184 #ifdef FULL_DEBUG
1185 /* Process should have already died before we are called. */
1186 if (WaitForSingleObject (cp->procinfo.hProcess, 0) != WAIT_OBJECT_0)
1187 DebPrint (("reap_subprocess: child for fd %d has not died yet!", cp->fd));
1188 #endif
1189 CloseHandle (cp->procinfo.hProcess);
1190 cp->procinfo.hProcess = NULL;
1191 CloseHandle (cp->procinfo.hThread);
1192 cp->procinfo.hThread = NULL;
1193 }
1194
1195 /* If cp->fd was not closed yet, we might be still reading the
1196 process output, so don't free its resources just yet. The call
1197 to delete_child on behalf of this subprocess will be made by
1198 sys_read when the subprocess output is fully read. */
1199 if (cp->fd < 0)
1200 delete_child (cp);
1201 }
1202
1203 /* Wait for a child process specified by PID, or for any of our
1204 existing child processes (if PID is nonpositive) to die. When it
1205 does, close its handle. Return the pid of the process that died
1206 and fill in STATUS if non-NULL. */
1207
1208 pid_t
1209 waitpid (pid_t pid, int *status, int options)
1210 {
1211 DWORD active, retval;
1212 int nh;
1213 child_process *cp, *cps[MAX_CHILDREN];
1214 HANDLE wait_hnd[MAX_CHILDREN];
1215 DWORD timeout_ms;
1216 int dont_wait = (options & WNOHANG) != 0;
1217
1218 nh = 0;
1219 /* According to Posix:
1220
1221 PID = -1 means status is requested for any child process.
1222
1223 PID > 0 means status is requested for a single child process
1224 whose pid is PID.
1225
1226 PID = 0 means status is requested for any child process whose
1227 process group ID is equal to that of the calling process. But
1228 since Windows has only a limited support for process groups (only
1229 for console processes and only for the purposes of passing
1230 Ctrl-BREAK signal to them), and since we have no documented way
1231 of determining whether a given process belongs to our group, we
1232 treat 0 as -1.
1233
1234 PID < -1 means status is requested for any child process whose
1235 process group ID is equal to the absolute value of PID. Again,
1236 since we don't support process groups, we treat that as -1. */
1237 if (pid > 0)
1238 {
1239 int our_child = 0;
1240
1241 /* We are requested to wait for a specific child. */
1242 for (cp = child_procs + (child_proc_count-1); cp >= child_procs; cp--)
1243 {
1244 /* Some child_procs might be sockets; ignore them. Also
1245 ignore subprocesses whose output is not yet completely
1246 read. */
1247 if (CHILD_ACTIVE (cp)
1248 && cp->procinfo.hProcess
1249 && cp->pid == pid)
1250 {
1251 our_child = 1;
1252 break;
1253 }
1254 }
1255 if (our_child)
1256 {
1257 if (cp->fd < 0 || (fd_info[cp->fd].flags & FILE_AT_EOF) != 0)
1258 {
1259 wait_hnd[nh] = cp->procinfo.hProcess;
1260 cps[nh] = cp;
1261 nh++;
1262 }
1263 else if (dont_wait)
1264 {
1265 /* PID specifies our subprocess, but its status is not
1266 yet available. */
1267 return 0;
1268 }
1269 }
1270 if (nh == 0)
1271 {
1272 /* No such child process, or nothing to wait for, so fail. */
1273 errno = ECHILD;
1274 return -1;
1275 }
1276 }
1277 else
1278 {
1279 for (cp = child_procs + (child_proc_count-1); cp >= child_procs; cp--)
1280 {
1281 if (CHILD_ACTIVE (cp)
1282 && cp->procinfo.hProcess
1283 && (cp->fd < 0 || (fd_info[cp->fd].flags & FILE_AT_EOF) != 0))
1284 {
1285 wait_hnd[nh] = cp->procinfo.hProcess;
1286 cps[nh] = cp;
1287 nh++;
1288 }
1289 }
1290 if (nh == 0)
1291 {
1292 /* Nothing to wait on, so fail. */
1293 errno = ECHILD;
1294 return -1;
1295 }
1296 }
1297
1298 if (dont_wait)
1299 timeout_ms = 0;
1300 else
1301 timeout_ms = 1000; /* check for quit about once a second. */
1302
1303 do
1304 {
1305 QUIT;
1306 active = WaitForMultipleObjects (nh, wait_hnd, FALSE, timeout_ms);
1307 } while (active == WAIT_TIMEOUT && !dont_wait);
1308
1309 if (active == WAIT_FAILED)
1310 {
1311 errno = EBADF;
1312 return -1;
1313 }
1314 else if (active == WAIT_TIMEOUT && dont_wait)
1315 {
1316 /* PID specifies our subprocess, but it didn't exit yet, so its
1317 status is not yet available. */
1318 #ifdef FULL_DEBUG
1319 DebPrint (("Wait: PID %d not reap yet\n", cp->pid));
1320 #endif
1321 return 0;
1322 }
1323 else if (active >= WAIT_OBJECT_0
1324 && active < WAIT_OBJECT_0+MAXIMUM_WAIT_OBJECTS)
1325 {
1326 active -= WAIT_OBJECT_0;
1327 }
1328 else if (active >= WAIT_ABANDONED_0
1329 && active < WAIT_ABANDONED_0+MAXIMUM_WAIT_OBJECTS)
1330 {
1331 active -= WAIT_ABANDONED_0;
1332 }
1333 else
1334 emacs_abort ();
1335
1336 if (!GetExitCodeProcess (wait_hnd[active], &retval))
1337 {
1338 DebPrint (("Wait.GetExitCodeProcess failed with %lu\n",
1339 GetLastError ()));
1340 retval = 1;
1341 }
1342 if (retval == STILL_ACTIVE)
1343 {
1344 /* Should never happen. */
1345 DebPrint (("Wait.WaitForMultipleObjects returned an active process\n"));
1346 if (pid > 0 && dont_wait)
1347 return 0;
1348 errno = EINVAL;
1349 return -1;
1350 }
1351
1352 /* Massage the exit code from the process to match the format expected
1353 by the WIFSTOPPED et al macros in syswait.h. Only WIFSIGNALED and
1354 WIFEXITED are supported; WIFSTOPPED doesn't make sense under NT. */
1355
1356 if (retval == STATUS_CONTROL_C_EXIT)
1357 retval = SIGINT;
1358 else
1359 retval <<= 8;
1360
1361 if (pid > 0 && active != 0)
1362 emacs_abort ();
1363 cp = cps[active];
1364 pid = cp->pid;
1365 #ifdef FULL_DEBUG
1366 DebPrint (("Wait signaled with process pid %d\n", cp->pid));
1367 #endif
1368
1369 if (status)
1370 *status = retval;
1371 reap_subprocess (cp);
1372
1373 return pid;
1374 }
1375
1376 /* Old versions of w32api headers don't have separate 32-bit and
1377 64-bit defines, but the one they have matches the 32-bit variety. */
1378 #ifndef IMAGE_NT_OPTIONAL_HDR32_MAGIC
1379 # define IMAGE_NT_OPTIONAL_HDR32_MAGIC IMAGE_NT_OPTIONAL_HDR_MAGIC
1380 # define IMAGE_OPTIONAL_HEADER32 IMAGE_OPTIONAL_HEADER
1381 #endif
1382
1383 /* Implementation note: This function works with file names encoded in
1384 the current ANSI codepage. */
1385 static void
1386 w32_executable_type (char * filename,
1387 int * is_dos_app,
1388 int * is_cygnus_app,
1389 int * is_gui_app)
1390 {
1391 file_data executable;
1392 char * p;
1393
1394 /* Default values in case we can't tell for sure. */
1395 *is_dos_app = FALSE;
1396 *is_cygnus_app = FALSE;
1397 *is_gui_app = FALSE;
1398
1399 if (!open_input_file (&executable, filename))
1400 return;
1401
1402 p = strrchr (filename, '.');
1403
1404 /* We can only identify DOS .com programs from the extension. */
1405 if (p && xstrcasecmp (p, ".com") == 0)
1406 *is_dos_app = TRUE;
1407 else if (p && (xstrcasecmp (p, ".bat") == 0
1408 || xstrcasecmp (p, ".cmd") == 0))
1409 {
1410 /* A DOS shell script - it appears that CreateProcess is happy to
1411 accept this (somewhat surprisingly); presumably it looks at
1412 COMSPEC to determine what executable to actually invoke.
1413 Therefore, we have to do the same here as well. */
1414 /* Actually, I think it uses the program association for that
1415 extension, which is defined in the registry. */
1416 p = egetenv ("COMSPEC");
1417 if (p)
1418 w32_executable_type (p, is_dos_app, is_cygnus_app, is_gui_app);
1419 }
1420 else
1421 {
1422 /* Look for DOS .exe signature - if found, we must also check that
1423 it isn't really a 16- or 32-bit Windows exe, since both formats
1424 start with a DOS program stub. Note that 16-bit Windows
1425 executables use the OS/2 1.x format. */
1426
1427 IMAGE_DOS_HEADER * dos_header;
1428 IMAGE_NT_HEADERS * nt_header;
1429
1430 dos_header = (PIMAGE_DOS_HEADER) executable.file_base;
1431 if (dos_header->e_magic != IMAGE_DOS_SIGNATURE)
1432 goto unwind;
1433
1434 nt_header = (PIMAGE_NT_HEADERS) ((unsigned char *) dos_header + dos_header->e_lfanew);
1435
1436 if ((char *) nt_header > (char *) dos_header + executable.size)
1437 {
1438 /* Some dos headers (pkunzip) have bogus e_lfanew fields. */
1439 *is_dos_app = TRUE;
1440 }
1441 else if (nt_header->Signature != IMAGE_NT_SIGNATURE
1442 && LOWORD (nt_header->Signature) != IMAGE_OS2_SIGNATURE)
1443 {
1444 *is_dos_app = TRUE;
1445 }
1446 else if (nt_header->Signature == IMAGE_NT_SIGNATURE)
1447 {
1448 IMAGE_DATA_DIRECTORY *data_dir = NULL;
1449 if (nt_header->OptionalHeader.Magic == IMAGE_NT_OPTIONAL_HDR32_MAGIC)
1450 {
1451 /* Ensure we are using the 32 bit structure. */
1452 IMAGE_OPTIONAL_HEADER32 *opt
1453 = (IMAGE_OPTIONAL_HEADER32*) &(nt_header->OptionalHeader);
1454 data_dir = opt->DataDirectory;
1455 *is_gui_app = (opt->Subsystem == IMAGE_SUBSYSTEM_WINDOWS_GUI);
1456 }
1457 /* MingW 3.12 has the required 64 bit structs, but in case older
1458 versions don't, only check 64 bit exes if we know how. */
1459 #ifdef IMAGE_NT_OPTIONAL_HDR64_MAGIC
1460 else if (nt_header->OptionalHeader.Magic
1461 == IMAGE_NT_OPTIONAL_HDR64_MAGIC)
1462 {
1463 IMAGE_OPTIONAL_HEADER64 *opt
1464 = (IMAGE_OPTIONAL_HEADER64*) &(nt_header->OptionalHeader);
1465 data_dir = opt->DataDirectory;
1466 *is_gui_app = (opt->Subsystem == IMAGE_SUBSYSTEM_WINDOWS_GUI);
1467 }
1468 #endif
1469 if (data_dir)
1470 {
1471 /* Look for cygwin.dll in DLL import list. */
1472 IMAGE_DATA_DIRECTORY import_dir =
1473 data_dir[IMAGE_DIRECTORY_ENTRY_IMPORT];
1474 IMAGE_IMPORT_DESCRIPTOR * imports;
1475 IMAGE_SECTION_HEADER * section;
1476
1477 section = rva_to_section (import_dir.VirtualAddress, nt_header);
1478 imports = RVA_TO_PTR (import_dir.VirtualAddress, section,
1479 executable);
1480
1481 for ( ; imports->Name; imports++)
1482 {
1483 char * dllname = RVA_TO_PTR (imports->Name, section,
1484 executable);
1485
1486 /* The exact name of the cygwin dll has changed with
1487 various releases, but hopefully this will be reasonably
1488 future proof. */
1489 if (strncmp (dllname, "cygwin", 6) == 0)
1490 {
1491 *is_cygnus_app = TRUE;
1492 break;
1493 }
1494 }
1495 }
1496 }
1497 }
1498
1499 unwind:
1500 close_file_data (&executable);
1501 }
1502
1503 static int
1504 compare_env (const void *strp1, const void *strp2)
1505 {
1506 const char *str1 = *(const char **)strp1, *str2 = *(const char **)strp2;
1507
1508 while (*str1 && *str2 && *str1 != '=' && *str2 != '=')
1509 {
1510 /* Sort order in command.com/cmd.exe is based on uppercasing
1511 names, so do the same here. */
1512 if (toupper (*str1) > toupper (*str2))
1513 return 1;
1514 else if (toupper (*str1) < toupper (*str2))
1515 return -1;
1516 str1++, str2++;
1517 }
1518
1519 if (*str1 == '=' && *str2 == '=')
1520 return 0;
1521 else if (*str1 == '=')
1522 return -1;
1523 else
1524 return 1;
1525 }
1526
1527 static void
1528 merge_and_sort_env (char **envp1, char **envp2, char **new_envp)
1529 {
1530 char **optr, **nptr;
1531 int num;
1532
1533 nptr = new_envp;
1534 optr = envp1;
1535 while (*optr)
1536 *nptr++ = *optr++;
1537 num = optr - envp1;
1538
1539 optr = envp2;
1540 while (*optr)
1541 *nptr++ = *optr++;
1542 num += optr - envp2;
1543
1544 qsort (new_envp, num, sizeof (char *), compare_env);
1545
1546 *nptr = NULL;
1547 }
1548
1549 /* When a new child process is created we need to register it in our list,
1550 so intercept spawn requests. */
1551 int
1552 sys_spawnve (int mode, char *cmdname, char **argv, char **envp)
1553 {
1554 Lisp_Object program, full;
1555 char *cmdline, *env, *parg, **targ;
1556 int arglen, numenv;
1557 pid_t pid;
1558 child_process *cp;
1559 int is_dos_app, is_cygnus_app, is_gui_app;
1560 int do_quoting = 0;
1561 /* We pass our process ID to our children by setting up an environment
1562 variable in their environment. */
1563 char ppid_env_var_buffer[64];
1564 char *extra_env[] = {ppid_env_var_buffer, NULL};
1565 /* These are the characters that cause an argument to need quoting.
1566 Arguments with whitespace characters need quoting to prevent the
1567 argument being split into two or more. Arguments with wildcards
1568 are also quoted, for consistency with posix platforms, where wildcards
1569 are not expanded if we run the program directly without a shell.
1570 Some extra whitespace characters need quoting in Cygwin programs,
1571 so this list is conditionally modified below. */
1572 char *sepchars = " \t*?";
1573 /* This is for native w32 apps; modified below for Cygwin apps. */
1574 char escape_char = '\\';
1575 char cmdname_a[MAX_PATH];
1576
1577 /* We don't care about the other modes */
1578 if (mode != _P_NOWAIT)
1579 {
1580 errno = EINVAL;
1581 return -1;
1582 }
1583
1584 /* Handle executable names without an executable suffix. The caller
1585 already searched exec-path and verified the file is executable,
1586 but start-process doesn't do that for file names that are already
1587 absolute. So we double-check this here, just in case. */
1588 if (faccessat (AT_FDCWD, cmdname, X_OK, AT_EACCESS) != 0)
1589 {
1590 struct gcpro gcpro1;
1591
1592 program = build_string (cmdname);
1593 full = Qnil;
1594 GCPRO1 (program);
1595 openp (Vexec_path, program, Vexec_suffixes, &full, make_number (X_OK));
1596 UNGCPRO;
1597 if (NILP (full))
1598 {
1599 errno = EINVAL;
1600 return -1;
1601 }
1602 program = ENCODE_FILE (full);
1603 cmdname = SDATA (program);
1604 }
1605
1606 /* make sure argv[0] and cmdname are both in DOS format */
1607 unixtodos_filename (cmdname);
1608 /* argv[0] was encoded by caller using ENCODE_FILE, so it is in
1609 UTF-8. All the other arguments are encoded by ENCODE_SYSTEM or
1610 some such, and are in some ANSI codepage. We need to have
1611 argv[0] encoded in ANSI codepage. */
1612 filename_to_ansi (cmdname, cmdname_a);
1613 /* We explicitly require that the command's file name be encodable
1614 in the current ANSI codepage, because we will be invoking it via
1615 the ANSI APIs. */
1616 if (_mbspbrk (cmdname_a, "?"))
1617 {
1618 errno = ENOENT;
1619 return -1;
1620 }
1621 /* From here on, CMDNAME is an ANSI-encoded string. */
1622 cmdname = cmdname_a
1623 argv[0] = cmdname;
1624
1625 /* Determine whether program is a 16-bit DOS executable, or a 32-bit Windows
1626 executable that is implicitly linked to the Cygnus dll (implying it
1627 was compiled with the Cygnus GNU toolchain and hence relies on
1628 cygwin.dll to parse the command line - we use this to decide how to
1629 escape quote chars in command line args that must be quoted).
1630
1631 Also determine whether it is a GUI app, so that we don't hide its
1632 initial window unless specifically requested. */
1633 w32_executable_type (cmdname, &is_dos_app, &is_cygnus_app, &is_gui_app);
1634
1635 /* On Windows 95, if cmdname is a DOS app, we invoke a helper
1636 application to start it by specifying the helper app as cmdname,
1637 while leaving the real app name as argv[0]. */
1638 if (is_dos_app)
1639 {
1640 char *p;
1641
1642 cmdname = alloca (MAX_PATH);
1643 if (egetenv ("CMDPROXY"))
1644 strcpy (cmdname, egetenv ("CMDPROXY"));
1645 else
1646 {
1647 strcpy (cmdname, SDATA (Vinvocation_directory));
1648 strcat (cmdname, "cmdproxy.exe");
1649 }
1650
1651 /* Can't use unixtodos_filename here, since that needs its file
1652 name argument encoded in UTF-8. */
1653 for (p = cmdname; *p; p = CharNextA (p))
1654 if (*p == '/')
1655 *p = '\\';
1656 }
1657
1658 /* we have to do some conjuring here to put argv and envp into the
1659 form CreateProcess wants... argv needs to be a space separated/null
1660 terminated list of parameters, and envp is a null
1661 separated/double-null terminated list of parameters.
1662
1663 Additionally, zero-length args and args containing whitespace or
1664 quote chars need to be wrapped in double quotes - for this to work,
1665 embedded quotes need to be escaped as well. The aim is to ensure
1666 the child process reconstructs the argv array we start with
1667 exactly, so we treat quotes at the beginning and end of arguments
1668 as embedded quotes.
1669
1670 The w32 GNU-based library from Cygnus doubles quotes to escape
1671 them, while MSVC uses backslash for escaping. (Actually the MSVC
1672 startup code does attempt to recognize doubled quotes and accept
1673 them, but gets it wrong and ends up requiring three quotes to get a
1674 single embedded quote!) So by default we decide whether to use
1675 quote or backslash as the escape character based on whether the
1676 binary is apparently a Cygnus compiled app.
1677
1678 Note that using backslash to escape embedded quotes requires
1679 additional special handling if an embedded quote is already
1680 preceded by backslash, or if an arg requiring quoting ends with
1681 backslash. In such cases, the run of escape characters needs to be
1682 doubled. For consistency, we apply this special handling as long
1683 as the escape character is not quote.
1684
1685 Since we have no idea how large argv and envp are likely to be we
1686 figure out list lengths on the fly and allocate them. */
1687
1688 if (!NILP (Vw32_quote_process_args))
1689 {
1690 do_quoting = 1;
1691 /* Override escape char by binding w32-quote-process-args to
1692 desired character, or use t for auto-selection. */
1693 if (INTEGERP (Vw32_quote_process_args))
1694 escape_char = XINT (Vw32_quote_process_args);
1695 else
1696 escape_char = is_cygnus_app ? '"' : '\\';
1697 }
1698
1699 /* Cygwin apps needs quoting a bit more often. */
1700 if (escape_char == '"')
1701 sepchars = "\r\n\t\f '";
1702
1703 /* do argv... */
1704 arglen = 0;
1705 targ = argv;
1706 while (*targ)
1707 {
1708 char * p = *targ;
1709 int need_quotes = 0;
1710 int escape_char_run = 0;
1711
1712 if (*p == 0)
1713 need_quotes = 1;
1714 for ( ; *p; p++)
1715 {
1716 if (escape_char == '"' && *p == '\\')
1717 /* If it's a Cygwin app, \ needs to be escaped. */
1718 arglen++;
1719 else if (*p == '"')
1720 {
1721 /* allow for embedded quotes to be escaped */
1722 arglen++;
1723 need_quotes = 1;
1724 /* handle the case where the embedded quote is already escaped */
1725 if (escape_char_run > 0)
1726 {
1727 /* To preserve the arg exactly, we need to double the
1728 preceding escape characters (plus adding one to
1729 escape the quote character itself). */
1730 arglen += escape_char_run;
1731 }
1732 }
1733 else if (strchr (sepchars, *p) != NULL)
1734 {
1735 need_quotes = 1;
1736 }
1737
1738 if (*p == escape_char && escape_char != '"')
1739 escape_char_run++;
1740 else
1741 escape_char_run = 0;
1742 }
1743 if (need_quotes)
1744 {
1745 arglen += 2;
1746 /* handle the case where the arg ends with an escape char - we
1747 must not let the enclosing quote be escaped. */
1748 if (escape_char_run > 0)
1749 arglen += escape_char_run;
1750 }
1751 arglen += strlen (*targ++) + 1;
1752 }
1753 cmdline = alloca (arglen);
1754 targ = argv;
1755 parg = cmdline;
1756 while (*targ)
1757 {
1758 char * p = *targ;
1759 int need_quotes = 0;
1760
1761 if (*p == 0)
1762 need_quotes = 1;
1763
1764 if (do_quoting)
1765 {
1766 for ( ; *p; p++)
1767 if ((strchr (sepchars, *p) != NULL) || *p == '"')
1768 need_quotes = 1;
1769 }
1770 if (need_quotes)
1771 {
1772 int escape_char_run = 0;
1773 char * first;
1774 char * last;
1775
1776 p = *targ;
1777 first = p;
1778 last = p + strlen (p) - 1;
1779 *parg++ = '"';
1780 #if 0
1781 /* This version does not escape quotes if they occur at the
1782 beginning or end of the arg - this could lead to incorrect
1783 behavior when the arg itself represents a command line
1784 containing quoted args. I believe this was originally done
1785 as a hack to make some things work, before
1786 `w32-quote-process-args' was added. */
1787 while (*p)
1788 {
1789 if (*p == '"' && p > first && p < last)
1790 *parg++ = escape_char; /* escape embedded quotes */
1791 *parg++ = *p++;
1792 }
1793 #else
1794 for ( ; *p; p++)
1795 {
1796 if (*p == '"')
1797 {
1798 /* double preceding escape chars if any */
1799 while (escape_char_run > 0)
1800 {
1801 *parg++ = escape_char;
1802 escape_char_run--;
1803 }
1804 /* escape all quote chars, even at beginning or end */
1805 *parg++ = escape_char;
1806 }
1807 else if (escape_char == '"' && *p == '\\')
1808 *parg++ = '\\';
1809 *parg++ = *p;
1810
1811 if (*p == escape_char && escape_char != '"')
1812 escape_char_run++;
1813 else
1814 escape_char_run = 0;
1815 }
1816 /* double escape chars before enclosing quote */
1817 while (escape_char_run > 0)
1818 {
1819 *parg++ = escape_char;
1820 escape_char_run--;
1821 }
1822 #endif
1823 *parg++ = '"';
1824 }
1825 else
1826 {
1827 strcpy (parg, *targ);
1828 parg += strlen (*targ);
1829 }
1830 *parg++ = ' ';
1831 targ++;
1832 }
1833 *--parg = '\0';
1834
1835 /* and envp... */
1836 arglen = 1;
1837 targ = envp;
1838 numenv = 1; /* for end null */
1839 while (*targ)
1840 {
1841 arglen += strlen (*targ++) + 1;
1842 numenv++;
1843 }
1844 /* extra env vars... */
1845 sprintf (ppid_env_var_buffer, "EM_PARENT_PROCESS_ID=%lu",
1846 GetCurrentProcessId ());
1847 arglen += strlen (ppid_env_var_buffer) + 1;
1848 numenv++;
1849
1850 /* merge env passed in and extra env into one, and sort it. */
1851 targ = (char **) alloca (numenv * sizeof (char *));
1852 merge_and_sort_env (envp, extra_env, targ);
1853
1854 /* concatenate env entries. */
1855 env = alloca (arglen);
1856 parg = env;
1857 while (*targ)
1858 {
1859 strcpy (parg, *targ);
1860 parg += strlen (*targ++);
1861 *parg++ = '\0';
1862 }
1863 *parg++ = '\0';
1864 *parg = '\0';
1865
1866 cp = new_child ();
1867 if (cp == NULL)
1868 {
1869 errno = EAGAIN;
1870 return -1;
1871 }
1872
1873 /* Now create the process. */
1874 if (!create_child (cmdname, cmdline, env, is_gui_app, &pid, cp))
1875 {
1876 delete_child (cp);
1877 errno = ENOEXEC;
1878 return -1;
1879 }
1880
1881 return pid;
1882 }
1883
1884 /* Emulate the select call
1885 Wait for available input on any of the given rfds, or timeout if
1886 a timeout is given and no input is detected
1887 wfds and efds are not supported and must be NULL.
1888
1889 For simplicity, we detect the death of child processes here and
1890 synchronously call the SIGCHLD handler. Since it is possible for
1891 children to be created without a corresponding pipe handle from which
1892 to read output, we wait separately on the process handles as well as
1893 the char_avail events for each process pipe. We only call
1894 wait/reap_process when the process actually terminates.
1895
1896 To reduce the number of places in which Emacs can be hung such that
1897 C-g is not able to interrupt it, we always wait on interrupt_handle
1898 (which is signaled by the input thread when C-g is detected). If we
1899 detect that we were woken up by C-g, we return -1 with errno set to
1900 EINTR as on Unix. */
1901
1902 /* From w32console.c */
1903 extern HANDLE keyboard_handle;
1904
1905 /* From w32xfns.c */
1906 extern HANDLE interrupt_handle;
1907
1908 /* From process.c */
1909 extern int proc_buffered_char[];
1910
1911 int
1912 sys_select (int nfds, SELECT_TYPE *rfds, SELECT_TYPE *wfds, SELECT_TYPE *efds,
1913 struct timespec *timeout, void *ignored)
1914 {
1915 SELECT_TYPE orfds;
1916 DWORD timeout_ms, start_time;
1917 int i, nh, nc, nr;
1918 DWORD active;
1919 child_process *cp, *cps[MAX_CHILDREN];
1920 HANDLE wait_hnd[MAXDESC + MAX_CHILDREN];
1921 int fdindex[MAXDESC]; /* mapping from wait handles back to descriptors */
1922
1923 timeout_ms =
1924 timeout ? (timeout->tv_sec * 1000 + timeout->tv_nsec / 1000000) : INFINITE;
1925
1926 /* If the descriptor sets are NULL but timeout isn't, then just Sleep. */
1927 if (rfds == NULL && wfds == NULL && efds == NULL && timeout != NULL)
1928 {
1929 Sleep (timeout_ms);
1930 return 0;
1931 }
1932
1933 /* Otherwise, we only handle rfds, so fail otherwise. */
1934 if (rfds == NULL || wfds != NULL || efds != NULL)
1935 {
1936 errno = EINVAL;
1937 return -1;
1938 }
1939
1940 orfds = *rfds;
1941 FD_ZERO (rfds);
1942 nr = 0;
1943
1944 /* Always wait on interrupt_handle, to detect C-g (quit). */
1945 wait_hnd[0] = interrupt_handle;
1946 fdindex[0] = -1;
1947
1948 /* Build a list of pipe handles to wait on. */
1949 nh = 1;
1950 for (i = 0; i < nfds; i++)
1951 if (FD_ISSET (i, &orfds))
1952 {
1953 if (i == 0)
1954 {
1955 if (keyboard_handle)
1956 {
1957 /* Handle stdin specially */
1958 wait_hnd[nh] = keyboard_handle;
1959 fdindex[nh] = i;
1960 nh++;
1961 }
1962
1963 /* Check for any emacs-generated input in the queue since
1964 it won't be detected in the wait */
1965 if (detect_input_pending ())
1966 {
1967 FD_SET (i, rfds);
1968 return 1;
1969 }
1970 }
1971 else
1972 {
1973 /* Child process and socket/comm port input. */
1974 cp = fd_info[i].cp;
1975 if (cp)
1976 {
1977 int current_status = cp->status;
1978
1979 if (current_status == STATUS_READ_ACKNOWLEDGED)
1980 {
1981 /* Tell reader thread which file handle to use. */
1982 cp->fd = i;
1983 /* Wake up the reader thread for this process */
1984 cp->status = STATUS_READ_READY;
1985 if (!SetEvent (cp->char_consumed))
1986 DebPrint (("sys_select.SetEvent failed with "
1987 "%lu for fd %ld\n", GetLastError (), i));
1988 }
1989
1990 #ifdef CHECK_INTERLOCK
1991 /* slightly crude cross-checking of interlock between threads */
1992
1993 current_status = cp->status;
1994 if (WaitForSingleObject (cp->char_avail, 0) == WAIT_OBJECT_0)
1995 {
1996 /* char_avail has been signaled, so status (which may
1997 have changed) should indicate read has completed
1998 but has not been acknowledged. */
1999 current_status = cp->status;
2000 if (current_status != STATUS_READ_SUCCEEDED
2001 && current_status != STATUS_READ_FAILED)
2002 DebPrint (("char_avail set, but read not completed: status %d\n",
2003 current_status));
2004 }
2005 else
2006 {
2007 /* char_avail has not been signaled, so status should
2008 indicate that read is in progress; small possibility
2009 that read has completed but event wasn't yet signaled
2010 when we tested it (because a context switch occurred
2011 or if running on separate CPUs). */
2012 if (current_status != STATUS_READ_READY
2013 && current_status != STATUS_READ_IN_PROGRESS
2014 && current_status != STATUS_READ_SUCCEEDED
2015 && current_status != STATUS_READ_FAILED)
2016 DebPrint (("char_avail reset, but read status is bad: %d\n",
2017 current_status));
2018 }
2019 #endif
2020 wait_hnd[nh] = cp->char_avail;
2021 fdindex[nh] = i;
2022 if (!wait_hnd[nh]) emacs_abort ();
2023 nh++;
2024 #ifdef FULL_DEBUG
2025 DebPrint (("select waiting on child %d fd %d\n",
2026 cp-child_procs, i));
2027 #endif
2028 }
2029 else
2030 {
2031 /* Unable to find something to wait on for this fd, skip */
2032
2033 /* Note that this is not a fatal error, and can in fact
2034 happen in unusual circumstances. Specifically, if
2035 sys_spawnve fails, eg. because the program doesn't
2036 exist, and debug-on-error is t so Fsignal invokes a
2037 nested input loop, then the process output pipe is
2038 still included in input_wait_mask with no child_proc
2039 associated with it. (It is removed when the debugger
2040 exits the nested input loop and the error is thrown.) */
2041
2042 DebPrint (("sys_select: fd %ld is invalid! ignoring\n", i));
2043 }
2044 }
2045 }
2046
2047 count_children:
2048 /* Add handles of child processes. */
2049 nc = 0;
2050 for (cp = child_procs + (child_proc_count-1); cp >= child_procs; cp--)
2051 /* Some child_procs might be sockets; ignore them. Also some
2052 children may have died already, but we haven't finished reading
2053 the process output; ignore them too. */
2054 if ((CHILD_ACTIVE (cp) && cp->procinfo.hProcess)
2055 && (cp->fd < 0
2056 || (fd_info[cp->fd].flags & FILE_SEND_SIGCHLD) == 0
2057 || (fd_info[cp->fd].flags & FILE_AT_EOF) != 0)
2058 )
2059 {
2060 wait_hnd[nh + nc] = cp->procinfo.hProcess;
2061 cps[nc] = cp;
2062 nc++;
2063 }
2064
2065 /* Nothing to look for, so we didn't find anything */
2066 if (nh + nc == 0)
2067 {
2068 if (timeout)
2069 Sleep (timeout_ms);
2070 return 0;
2071 }
2072
2073 start_time = GetTickCount ();
2074
2075 /* Wait for input or child death to be signaled. If user input is
2076 allowed, then also accept window messages. */
2077 if (FD_ISSET (0, &orfds))
2078 active = MsgWaitForMultipleObjects (nh + nc, wait_hnd, FALSE, timeout_ms,
2079 QS_ALLINPUT);
2080 else
2081 active = WaitForMultipleObjects (nh + nc, wait_hnd, FALSE, timeout_ms);
2082
2083 if (active == WAIT_FAILED)
2084 {
2085 DebPrint (("select.WaitForMultipleObjects (%d, %lu) failed with %lu\n",
2086 nh + nc, timeout_ms, GetLastError ()));
2087 /* don't return EBADF - this causes wait_reading_process_output to
2088 abort; WAIT_FAILED is returned when single-stepping under
2089 Windows 95 after switching thread focus in debugger, and
2090 possibly at other times. */
2091 errno = EINTR;
2092 return -1;
2093 }
2094 else if (active == WAIT_TIMEOUT)
2095 {
2096 return 0;
2097 }
2098 else if (active >= WAIT_OBJECT_0
2099 && active < WAIT_OBJECT_0+MAXIMUM_WAIT_OBJECTS)
2100 {
2101 active -= WAIT_OBJECT_0;
2102 }
2103 else if (active >= WAIT_ABANDONED_0
2104 && active < WAIT_ABANDONED_0+MAXIMUM_WAIT_OBJECTS)
2105 {
2106 active -= WAIT_ABANDONED_0;
2107 }
2108 else
2109 emacs_abort ();
2110
2111 /* Loop over all handles after active (now officially documented as
2112 being the first signaled handle in the array). We do this to
2113 ensure fairness, so that all channels with data available will be
2114 processed - otherwise higher numbered channels could be starved. */
2115 do
2116 {
2117 if (active == nh + nc)
2118 {
2119 /* There are messages in the lisp thread's queue; we must
2120 drain the queue now to ensure they are processed promptly,
2121 because if we don't do so, we will not be woken again until
2122 further messages arrive.
2123
2124 NB. If ever we allow window message procedures to callback
2125 into lisp, we will need to ensure messages are dispatched
2126 at a safe time for lisp code to be run (*), and we may also
2127 want to provide some hooks in the dispatch loop to cater
2128 for modeless dialogs created by lisp (ie. to register
2129 window handles to pass to IsDialogMessage).
2130
2131 (*) Note that MsgWaitForMultipleObjects above is an
2132 internal dispatch point for messages that are sent to
2133 windows created by this thread. */
2134 if (drain_message_queue ()
2135 /* If drain_message_queue returns non-zero, that means
2136 we received a WM_EMACS_FILENOTIFY message. If this
2137 is a TTY frame, we must signal the caller that keyboard
2138 input is available, so that w32_console_read_socket
2139 will be called to pick up the notifications. If we
2140 don't do that, file notifications will only work when
2141 the Emacs TTY frame has focus. */
2142 && FRAME_TERMCAP_P (SELECTED_FRAME ())
2143 /* they asked for stdin reads */
2144 && FD_ISSET (0, &orfds)
2145 /* the stdin handle is valid */
2146 && keyboard_handle)
2147 {
2148 FD_SET (0, rfds);
2149 if (nr == 0)
2150 nr = 1;
2151 }
2152 }
2153 else if (active >= nh)
2154 {
2155 cp = cps[active - nh];
2156
2157 /* We cannot always signal SIGCHLD immediately; if we have not
2158 finished reading the process output, we must delay sending
2159 SIGCHLD until we do. */
2160
2161 if (cp->fd >= 0 && (fd_info[cp->fd].flags & FILE_AT_EOF) == 0)
2162 fd_info[cp->fd].flags |= FILE_SEND_SIGCHLD;
2163 /* SIG_DFL for SIGCHLD is ignore */
2164 else if (sig_handlers[SIGCHLD] != SIG_DFL &&
2165 sig_handlers[SIGCHLD] != SIG_IGN)
2166 {
2167 #ifdef FULL_DEBUG
2168 DebPrint (("select calling SIGCHLD handler for pid %d\n",
2169 cp->pid));
2170 #endif
2171 sig_handlers[SIGCHLD] (SIGCHLD);
2172 }
2173 }
2174 else if (fdindex[active] == -1)
2175 {
2176 /* Quit (C-g) was detected. */
2177 errno = EINTR;
2178 return -1;
2179 }
2180 else if (fdindex[active] == 0)
2181 {
2182 /* Keyboard input available */
2183 FD_SET (0, rfds);
2184 nr++;
2185 }
2186 else
2187 {
2188 /* must be a socket or pipe - read ahead should have
2189 completed, either succeeding or failing. */
2190 FD_SET (fdindex[active], rfds);
2191 nr++;
2192 }
2193
2194 /* Even though wait_reading_process_output only reads from at most
2195 one channel, we must process all channels here so that we reap
2196 all children that have died. */
2197 while (++active < nh + nc)
2198 if (WaitForSingleObject (wait_hnd[active], 0) == WAIT_OBJECT_0)
2199 break;
2200 } while (active < nh + nc);
2201
2202 /* If no input has arrived and timeout hasn't expired, wait again. */
2203 if (nr == 0)
2204 {
2205 DWORD elapsed = GetTickCount () - start_time;
2206
2207 if (timeout_ms > elapsed) /* INFINITE is MAX_UINT */
2208 {
2209 if (timeout_ms != INFINITE)
2210 timeout_ms -= elapsed;
2211 goto count_children;
2212 }
2213 }
2214
2215 return nr;
2216 }
2217
2218 /* Substitute for certain kill () operations */
2219
2220 static BOOL CALLBACK
2221 find_child_console (HWND hwnd, LPARAM arg)
2222 {
2223 child_process * cp = (child_process *) arg;
2224 DWORD thread_id;
2225 DWORD process_id;
2226
2227 thread_id = GetWindowThreadProcessId (hwnd, &process_id);
2228 if (process_id == cp->procinfo.dwProcessId)
2229 {
2230 char window_class[32];
2231
2232 GetClassName (hwnd, window_class, sizeof (window_class));
2233 if (strcmp (window_class,
2234 (os_subtype == OS_9X)
2235 ? "tty"
2236 : "ConsoleWindowClass") == 0)
2237 {
2238 cp->hwnd = hwnd;
2239 return FALSE;
2240 }
2241 }
2242 /* keep looking */
2243 return TRUE;
2244 }
2245
2246 /* Emulate 'kill', but only for other processes. */
2247 int
2248 sys_kill (pid_t pid, int sig)
2249 {
2250 child_process *cp;
2251 HANDLE proc_hand;
2252 int need_to_free = 0;
2253 int rc = 0;
2254
2255 /* Each process is in its own process group. */
2256 if (pid < 0)
2257 pid = -pid;
2258
2259 /* Only handle signals that will result in the process dying */
2260 if (sig != 0
2261 && sig != SIGINT && sig != SIGKILL && sig != SIGQUIT && sig != SIGHUP)
2262 {
2263 errno = EINVAL;
2264 return -1;
2265 }
2266
2267 if (sig == 0)
2268 {
2269 /* It will take _some_ time before PID 4 or less on Windows will
2270 be Emacs... */
2271 if (pid <= 4)
2272 {
2273 errno = EPERM;
2274 return -1;
2275 }
2276 proc_hand = OpenProcess (PROCESS_QUERY_INFORMATION, 0, pid);
2277 if (proc_hand == NULL)
2278 {
2279 DWORD err = GetLastError ();
2280
2281 switch (err)
2282 {
2283 case ERROR_ACCESS_DENIED: /* existing process, but access denied */
2284 errno = EPERM;
2285 return -1;
2286 case ERROR_INVALID_PARAMETER: /* process PID does not exist */
2287 errno = ESRCH;
2288 return -1;
2289 }
2290 }
2291 else
2292 CloseHandle (proc_hand);
2293 return 0;
2294 }
2295
2296 cp = find_child_pid (pid);
2297 if (cp == NULL)
2298 {
2299 /* We were passed a PID of something other than our subprocess.
2300 If that is our own PID, we will send to ourself a message to
2301 close the selected frame, which does not necessarily
2302 terminates Emacs. But then we are not supposed to call
2303 sys_kill with our own PID. */
2304 proc_hand = OpenProcess (PROCESS_TERMINATE, 0, pid);
2305 if (proc_hand == NULL)
2306 {
2307 errno = EPERM;
2308 return -1;
2309 }
2310 need_to_free = 1;
2311 }
2312 else
2313 {
2314 proc_hand = cp->procinfo.hProcess;
2315 pid = cp->procinfo.dwProcessId;
2316
2317 /* Try to locate console window for process. */
2318 EnumWindows (find_child_console, (LPARAM) cp);
2319 }
2320
2321 if (sig == SIGINT || sig == SIGQUIT)
2322 {
2323 if (NILP (Vw32_start_process_share_console) && cp && cp->hwnd)
2324 {
2325 BYTE control_scan_code = (BYTE) MapVirtualKey (VK_CONTROL, 0);
2326 /* Fake Ctrl-C for SIGINT, and Ctrl-Break for SIGQUIT. */
2327 BYTE vk_break_code = (sig == SIGINT) ? 'C' : VK_CANCEL;
2328 BYTE break_scan_code = (BYTE) MapVirtualKey (vk_break_code, 0);
2329 HWND foreground_window;
2330
2331 if (break_scan_code == 0)
2332 {
2333 /* Fake Ctrl-C for SIGQUIT if we can't manage Ctrl-Break. */
2334 vk_break_code = 'C';
2335 break_scan_code = (BYTE) MapVirtualKey (vk_break_code, 0);
2336 }
2337
2338 foreground_window = GetForegroundWindow ();
2339 if (foreground_window)
2340 {
2341 /* NT 5.0, and apparently also Windows 98, will not allow
2342 a Window to be set to foreground directly without the
2343 user's involvement. The workaround is to attach
2344 ourselves to the thread that owns the foreground
2345 window, since that is the only thread that can set the
2346 foreground window. */
2347 DWORD foreground_thread, child_thread;
2348 foreground_thread =
2349 GetWindowThreadProcessId (foreground_window, NULL);
2350 if (foreground_thread == GetCurrentThreadId ()
2351 || !AttachThreadInput (GetCurrentThreadId (),
2352 foreground_thread, TRUE))
2353 foreground_thread = 0;
2354
2355 child_thread = GetWindowThreadProcessId (cp->hwnd, NULL);
2356 if (child_thread == GetCurrentThreadId ()
2357 || !AttachThreadInput (GetCurrentThreadId (),
2358 child_thread, TRUE))
2359 child_thread = 0;
2360
2361 /* Set the foreground window to the child. */
2362 if (SetForegroundWindow (cp->hwnd))
2363 {
2364 /* Generate keystrokes as if user had typed Ctrl-Break or
2365 Ctrl-C. */
2366 keybd_event (VK_CONTROL, control_scan_code, 0, 0);
2367 keybd_event (vk_break_code, break_scan_code,
2368 (vk_break_code == 'C' ? 0 : KEYEVENTF_EXTENDEDKEY), 0);
2369 keybd_event (vk_break_code, break_scan_code,
2370 (vk_break_code == 'C' ? 0 : KEYEVENTF_EXTENDEDKEY)
2371 | KEYEVENTF_KEYUP, 0);
2372 keybd_event (VK_CONTROL, control_scan_code,
2373 KEYEVENTF_KEYUP, 0);
2374
2375 /* Sleep for a bit to give time for Emacs frame to respond
2376 to focus change events (if Emacs was active app). */
2377 Sleep (100);
2378
2379 SetForegroundWindow (foreground_window);
2380 }
2381 /* Detach from the foreground and child threads now that
2382 the foreground switching is over. */
2383 if (foreground_thread)
2384 AttachThreadInput (GetCurrentThreadId (),
2385 foreground_thread, FALSE);
2386 if (child_thread)
2387 AttachThreadInput (GetCurrentThreadId (),
2388 child_thread, FALSE);
2389 }
2390 }
2391 /* Ctrl-Break is NT equivalent of SIGINT. */
2392 else if (!GenerateConsoleCtrlEvent (CTRL_BREAK_EVENT, pid))
2393 {
2394 DebPrint (("sys_kill.GenerateConsoleCtrlEvent return %d "
2395 "for pid %lu\n", GetLastError (), pid));
2396 errno = EINVAL;
2397 rc = -1;
2398 }
2399 }
2400 else
2401 {
2402 if (NILP (Vw32_start_process_share_console) && cp && cp->hwnd)
2403 {
2404 #if 1
2405 if (os_subtype == OS_9X)
2406 {
2407 /*
2408 Another possibility is to try terminating the VDM out-right by
2409 calling the Shell VxD (id 0x17) V86 interface, function #4
2410 "SHELL_Destroy_VM", ie.
2411
2412 mov edx,4
2413 mov ebx,vm_handle
2414 call shellapi
2415
2416 First need to determine the current VM handle, and then arrange for
2417 the shellapi call to be made from the system vm (by using
2418 Switch_VM_and_callback).
2419
2420 Could try to invoke DestroyVM through CallVxD.
2421
2422 */
2423 #if 0
2424 /* On Windows 95, posting WM_QUIT causes the 16-bit subsystem
2425 to hang when cmdproxy is used in conjunction with
2426 command.com for an interactive shell. Posting
2427 WM_CLOSE pops up a dialog that, when Yes is selected,
2428 does the same thing. TerminateProcess is also less
2429 than ideal in that subprocesses tend to stick around
2430 until the machine is shutdown, but at least it
2431 doesn't freeze the 16-bit subsystem. */
2432 PostMessage (cp->hwnd, WM_QUIT, 0xff, 0);
2433 #endif
2434 if (!TerminateProcess (proc_hand, 0xff))
2435 {
2436 DebPrint (("sys_kill.TerminateProcess returned %d "
2437 "for pid %lu\n", GetLastError (), pid));
2438 errno = EINVAL;
2439 rc = -1;
2440 }
2441 }
2442 else
2443 #endif
2444 PostMessage (cp->hwnd, WM_CLOSE, 0, 0);
2445 }
2446 /* Kill the process. On W32 this doesn't kill child processes
2447 so it doesn't work very well for shells which is why it's not
2448 used in every case. */
2449 else if (!TerminateProcess (proc_hand, 0xff))
2450 {
2451 DebPrint (("sys_kill.TerminateProcess returned %d "
2452 "for pid %lu\n", GetLastError (), pid));
2453 errno = EINVAL;
2454 rc = -1;
2455 }
2456 }
2457
2458 if (need_to_free)
2459 CloseHandle (proc_hand);
2460
2461 return rc;
2462 }
2463
2464 /* The following two routines are used to manipulate stdin, stdout, and
2465 stderr of our child processes.
2466
2467 Assuming that in, out, and err are *not* inheritable, we make them
2468 stdin, stdout, and stderr of the child as follows:
2469
2470 - Save the parent's current standard handles.
2471 - Set the std handles to inheritable duplicates of the ones being passed in.
2472 (Note that _get_osfhandle() is an io.h procedure that retrieves the
2473 NT file handle for a crt file descriptor.)
2474 - Spawn the child, which inherits in, out, and err as stdin,
2475 stdout, and stderr. (see Spawnve)
2476 - Close the std handles passed to the child.
2477 - Reset the parent's standard handles to the saved handles.
2478 (see reset_standard_handles)
2479 We assume that the caller closes in, out, and err after calling us. */
2480
2481 void
2482 prepare_standard_handles (int in, int out, int err, HANDLE handles[3])
2483 {
2484 HANDLE parent;
2485 HANDLE newstdin, newstdout, newstderr;
2486
2487 parent = GetCurrentProcess ();
2488
2489 handles[0] = GetStdHandle (STD_INPUT_HANDLE);
2490 handles[1] = GetStdHandle (STD_OUTPUT_HANDLE);
2491 handles[2] = GetStdHandle (STD_ERROR_HANDLE);
2492
2493 /* make inheritable copies of the new handles */
2494 if (!DuplicateHandle (parent,
2495 (HANDLE) _get_osfhandle (in),
2496 parent,
2497 &newstdin,
2498 0,
2499 TRUE,
2500 DUPLICATE_SAME_ACCESS))
2501 report_file_error ("Duplicating input handle for child", Qnil);
2502
2503 if (!DuplicateHandle (parent,
2504 (HANDLE) _get_osfhandle (out),
2505 parent,
2506 &newstdout,
2507 0,
2508 TRUE,
2509 DUPLICATE_SAME_ACCESS))
2510 report_file_error ("Duplicating output handle for child", Qnil);
2511
2512 if (!DuplicateHandle (parent,
2513 (HANDLE) _get_osfhandle (err),
2514 parent,
2515 &newstderr,
2516 0,
2517 TRUE,
2518 DUPLICATE_SAME_ACCESS))
2519 report_file_error ("Duplicating error handle for child", Qnil);
2520
2521 /* and store them as our std handles */
2522 if (!SetStdHandle (STD_INPUT_HANDLE, newstdin))
2523 report_file_error ("Changing stdin handle", Qnil);
2524
2525 if (!SetStdHandle (STD_OUTPUT_HANDLE, newstdout))
2526 report_file_error ("Changing stdout handle", Qnil);
2527
2528 if (!SetStdHandle (STD_ERROR_HANDLE, newstderr))
2529 report_file_error ("Changing stderr handle", Qnil);
2530 }
2531
2532 void
2533 reset_standard_handles (int in, int out, int err, HANDLE handles[3])
2534 {
2535 /* close the duplicated handles passed to the child */
2536 CloseHandle (GetStdHandle (STD_INPUT_HANDLE));
2537 CloseHandle (GetStdHandle (STD_OUTPUT_HANDLE));
2538 CloseHandle (GetStdHandle (STD_ERROR_HANDLE));
2539
2540 /* now restore parent's saved std handles */
2541 SetStdHandle (STD_INPUT_HANDLE, handles[0]);
2542 SetStdHandle (STD_OUTPUT_HANDLE, handles[1]);
2543 SetStdHandle (STD_ERROR_HANDLE, handles[2]);
2544 }
2545
2546 void
2547 set_process_dir (char * dir)
2548 {
2549 process_dir = dir;
2550 }
2551
2552 /* To avoid problems with winsock implementations that work over dial-up
2553 connections causing or requiring a connection to exist while Emacs is
2554 running, Emacs no longer automatically loads winsock on startup if it
2555 is present. Instead, it will be loaded when open-network-stream is
2556 first called.
2557
2558 To allow full control over when winsock is loaded, we provide these
2559 two functions to dynamically load and unload winsock. This allows
2560 dial-up users to only be connected when they actually need to use
2561 socket services. */
2562
2563 /* From w32.c */
2564 extern HANDLE winsock_lib;
2565 extern BOOL term_winsock (void);
2566 extern BOOL init_winsock (int load_now);
2567
2568 DEFUN ("w32-has-winsock", Fw32_has_winsock, Sw32_has_winsock, 0, 1, 0,
2569 doc: /* Test for presence of the Windows socket library `winsock'.
2570 Returns non-nil if winsock support is present, nil otherwise.
2571
2572 If the optional argument LOAD-NOW is non-nil, the winsock library is
2573 also loaded immediately if not already loaded. If winsock is loaded,
2574 the winsock local hostname is returned (since this may be different from
2575 the value of `system-name' and should supplant it), otherwise t is
2576 returned to indicate winsock support is present. */)
2577 (Lisp_Object load_now)
2578 {
2579 int have_winsock;
2580
2581 have_winsock = init_winsock (!NILP (load_now));
2582 if (have_winsock)
2583 {
2584 if (winsock_lib != NULL)
2585 {
2586 /* Return new value for system-name. The best way to do this
2587 is to call init_system_name, saving and restoring the
2588 original value to avoid side-effects. */
2589 Lisp_Object orig_hostname = Vsystem_name;
2590 Lisp_Object hostname;
2591
2592 init_system_name ();
2593 hostname = Vsystem_name;
2594 Vsystem_name = orig_hostname;
2595 return hostname;
2596 }
2597 return Qt;
2598 }
2599 return Qnil;
2600 }
2601
2602 DEFUN ("w32-unload-winsock", Fw32_unload_winsock, Sw32_unload_winsock,
2603 0, 0, 0,
2604 doc: /* Unload the Windows socket library `winsock' if loaded.
2605 This is provided to allow dial-up socket connections to be disconnected
2606 when no longer needed. Returns nil without unloading winsock if any
2607 socket connections still exist. */)
2608 (void)
2609 {
2610 return term_winsock () ? Qt : Qnil;
2611 }
2612
2613 \f
2614 /* Some miscellaneous functions that are Windows specific, but not GUI
2615 specific (ie. are applicable in terminal or batch mode as well). */
2616
2617 DEFUN ("w32-short-file-name", Fw32_short_file_name, Sw32_short_file_name, 1, 1, 0,
2618 doc: /* Return the short file name version (8.3) of the full path of FILENAME.
2619 If FILENAME does not exist, return nil.
2620 All path elements in FILENAME are converted to their short names. */)
2621 (Lisp_Object filename)
2622 {
2623 char shortname[MAX_PATH];
2624
2625 CHECK_STRING (filename);
2626
2627 /* first expand it. */
2628 filename = Fexpand_file_name (filename, Qnil);
2629
2630 /* luckily, this returns the short version of each element in the path. */
2631 if (w32_get_short_filename (SDATA (ENCODE_FILE (filename)),
2632 shortname, MAX_PATH) == 0)
2633 return Qnil;
2634
2635 dostounix_filename (shortname);
2636
2637 /* No need to DECODE_FILE, because 8.3 names are pure ASCII. */
2638 return build_string (shortname);
2639 }
2640
2641
2642 DEFUN ("w32-long-file-name", Fw32_long_file_name, Sw32_long_file_name,
2643 1, 1, 0,
2644 doc: /* Return the long file name version of the full path of FILENAME.
2645 If FILENAME does not exist, return nil.
2646 All path elements in FILENAME are converted to their long names. */)
2647 (Lisp_Object filename)
2648 {
2649 char longname[ MAX_UTF8_PATH ];
2650 int drive_only = 0;
2651
2652 CHECK_STRING (filename);
2653
2654 if (SBYTES (filename) == 2
2655 && *(SDATA (filename) + 1) == ':')
2656 drive_only = 1;
2657
2658 /* first expand it. */
2659 filename = Fexpand_file_name (filename, Qnil);
2660
2661 if (!w32_get_long_filename (SDATA (ENCODE_FILE (filename)), longname,
2662 MAX_UTF8_PATH))
2663 return Qnil;
2664
2665 dostounix_filename (longname);
2666
2667 /* If we were passed only a drive, make sure that a slash is not appended
2668 for consistency with directories. Allow for drive mapping via SUBST
2669 in case expand-file-name is ever changed to expand those. */
2670 if (drive_only && longname[1] == ':' && longname[2] == '/' && !longname[3])
2671 longname[2] = '\0';
2672
2673 return DECODE_FILE (build_unibyte_string (longname));
2674 }
2675
2676 DEFUN ("w32-set-process-priority", Fw32_set_process_priority,
2677 Sw32_set_process_priority, 2, 2, 0,
2678 doc: /* Set the priority of PROCESS to PRIORITY.
2679 If PROCESS is nil, the priority of Emacs is changed, otherwise the
2680 priority of the process whose pid is PROCESS is changed.
2681 PRIORITY should be one of the symbols high, normal, or low;
2682 any other symbol will be interpreted as normal.
2683
2684 If successful, the return value is t, otherwise nil. */)
2685 (Lisp_Object process, Lisp_Object priority)
2686 {
2687 HANDLE proc_handle = GetCurrentProcess ();
2688 DWORD priority_class = NORMAL_PRIORITY_CLASS;
2689 Lisp_Object result = Qnil;
2690
2691 CHECK_SYMBOL (priority);
2692
2693 if (!NILP (process))
2694 {
2695 DWORD pid;
2696 child_process *cp;
2697
2698 CHECK_NUMBER (process);
2699
2700 /* Allow pid to be an internally generated one, or one obtained
2701 externally. This is necessary because real pids on Windows 95 are
2702 negative. */
2703
2704 pid = XINT (process);
2705 cp = find_child_pid (pid);
2706 if (cp != NULL)
2707 pid = cp->procinfo.dwProcessId;
2708
2709 proc_handle = OpenProcess (PROCESS_SET_INFORMATION, FALSE, pid);
2710 }
2711
2712 if (EQ (priority, Qhigh))
2713 priority_class = HIGH_PRIORITY_CLASS;
2714 else if (EQ (priority, Qlow))
2715 priority_class = IDLE_PRIORITY_CLASS;
2716
2717 if (proc_handle != NULL)
2718 {
2719 if (SetPriorityClass (proc_handle, priority_class))
2720 result = Qt;
2721 if (!NILP (process))
2722 CloseHandle (proc_handle);
2723 }
2724
2725 return result;
2726 }
2727
2728 #ifdef HAVE_LANGINFO_CODESET
2729 /* Emulation of nl_langinfo. Used in fns.c:Flocale_info. */
2730 char *
2731 nl_langinfo (nl_item item)
2732 {
2733 /* Conversion of Posix item numbers to their Windows equivalents. */
2734 static const LCTYPE w32item[] = {
2735 LOCALE_IDEFAULTANSICODEPAGE,
2736 LOCALE_SDAYNAME1, LOCALE_SDAYNAME2, LOCALE_SDAYNAME3,
2737 LOCALE_SDAYNAME4, LOCALE_SDAYNAME5, LOCALE_SDAYNAME6, LOCALE_SDAYNAME7,
2738 LOCALE_SMONTHNAME1, LOCALE_SMONTHNAME2, LOCALE_SMONTHNAME3,
2739 LOCALE_SMONTHNAME4, LOCALE_SMONTHNAME5, LOCALE_SMONTHNAME6,
2740 LOCALE_SMONTHNAME7, LOCALE_SMONTHNAME8, LOCALE_SMONTHNAME9,
2741 LOCALE_SMONTHNAME10, LOCALE_SMONTHNAME11, LOCALE_SMONTHNAME12
2742 };
2743
2744 static char *nl_langinfo_buf = NULL;
2745 static int nl_langinfo_len = 0;
2746
2747 if (nl_langinfo_len <= 0)
2748 nl_langinfo_buf = xmalloc (nl_langinfo_len = 1);
2749
2750 if (item < 0 || item >= _NL_NUM)
2751 nl_langinfo_buf[0] = 0;
2752 else
2753 {
2754 LCID cloc = GetThreadLocale ();
2755 int need_len = GetLocaleInfo (cloc, w32item[item] | LOCALE_USE_CP_ACP,
2756 NULL, 0);
2757
2758 if (need_len <= 0)
2759 nl_langinfo_buf[0] = 0;
2760 else
2761 {
2762 if (item == CODESET)
2763 {
2764 need_len += 2; /* for the "cp" prefix */
2765 if (need_len < 8) /* for the case we call GetACP */
2766 need_len = 8;
2767 }
2768 if (nl_langinfo_len <= need_len)
2769 nl_langinfo_buf = xrealloc (nl_langinfo_buf,
2770 nl_langinfo_len = need_len);
2771 if (!GetLocaleInfo (cloc, w32item[item] | LOCALE_USE_CP_ACP,
2772 nl_langinfo_buf, nl_langinfo_len))
2773 nl_langinfo_buf[0] = 0;
2774 else if (item == CODESET)
2775 {
2776 if (strcmp (nl_langinfo_buf, "0") == 0 /* CP_ACP */
2777 || strcmp (nl_langinfo_buf, "1") == 0) /* CP_OEMCP */
2778 sprintf (nl_langinfo_buf, "cp%u", GetACP ());
2779 else
2780 {
2781 memmove (nl_langinfo_buf + 2, nl_langinfo_buf,
2782 strlen (nl_langinfo_buf) + 1);
2783 nl_langinfo_buf[0] = 'c';
2784 nl_langinfo_buf[1] = 'p';
2785 }
2786 }
2787 }
2788 }
2789 return nl_langinfo_buf;
2790 }
2791 #endif /* HAVE_LANGINFO_CODESET */
2792
2793 DEFUN ("w32-get-locale-info", Fw32_get_locale_info,
2794 Sw32_get_locale_info, 1, 2, 0,
2795 doc: /* Return information about the Windows locale LCID.
2796 By default, return a three letter locale code which encodes the default
2797 language as the first two characters, and the country or regional variant
2798 as the third letter. For example, ENU refers to `English (United States)',
2799 while ENC means `English (Canadian)'.
2800
2801 If the optional argument LONGFORM is t, the long form of the locale
2802 name is returned, e.g. `English (United States)' instead; if LONGFORM
2803 is a number, it is interpreted as an LCTYPE constant and the corresponding
2804 locale information is returned.
2805
2806 If LCID (a 16-bit number) is not a valid locale, the result is nil. */)
2807 (Lisp_Object lcid, Lisp_Object longform)
2808 {
2809 int got_abbrev;
2810 int got_full;
2811 char abbrev_name[32] = { 0 };
2812 char full_name[256] = { 0 };
2813
2814 CHECK_NUMBER (lcid);
2815
2816 if (!IsValidLocale (XINT (lcid), LCID_SUPPORTED))
2817 return Qnil;
2818
2819 if (NILP (longform))
2820 {
2821 got_abbrev = GetLocaleInfo (XINT (lcid),
2822 LOCALE_SABBREVLANGNAME | LOCALE_USE_CP_ACP,
2823 abbrev_name, sizeof (abbrev_name));
2824 if (got_abbrev)
2825 return build_string (abbrev_name);
2826 }
2827 else if (EQ (longform, Qt))
2828 {
2829 got_full = GetLocaleInfo (XINT (lcid),
2830 LOCALE_SLANGUAGE | LOCALE_USE_CP_ACP,
2831 full_name, sizeof (full_name));
2832 if (got_full)
2833 return DECODE_SYSTEM (build_string (full_name));
2834 }
2835 else if (NUMBERP (longform))
2836 {
2837 got_full = GetLocaleInfo (XINT (lcid),
2838 XINT (longform),
2839 full_name, sizeof (full_name));
2840 /* GetLocaleInfo's return value includes the terminating null
2841 character, when the returned information is a string, whereas
2842 make_unibyte_string needs the string length without the
2843 terminating null. */
2844 if (got_full)
2845 return make_unibyte_string (full_name, got_full - 1);
2846 }
2847
2848 return Qnil;
2849 }
2850
2851
2852 DEFUN ("w32-get-current-locale-id", Fw32_get_current_locale_id,
2853 Sw32_get_current_locale_id, 0, 0, 0,
2854 doc: /* Return Windows locale id for current locale setting.
2855 This is a numerical value; use `w32-get-locale-info' to convert to a
2856 human-readable form. */)
2857 (void)
2858 {
2859 return make_number (GetThreadLocale ());
2860 }
2861
2862 static DWORD
2863 int_from_hex (char * s)
2864 {
2865 DWORD val = 0;
2866 static char hex[] = "0123456789abcdefABCDEF";
2867 char * p;
2868
2869 while (*s && (p = strchr (hex, *s)) != NULL)
2870 {
2871 unsigned digit = p - hex;
2872 if (digit > 15)
2873 digit -= 6;
2874 val = val * 16 + digit;
2875 s++;
2876 }
2877 return val;
2878 }
2879
2880 /* We need to build a global list, since the EnumSystemLocale callback
2881 function isn't given a context pointer. */
2882 Lisp_Object Vw32_valid_locale_ids;
2883
2884 static BOOL CALLBACK
2885 enum_locale_fn (LPTSTR localeNum)
2886 {
2887 DWORD id = int_from_hex (localeNum);
2888 Vw32_valid_locale_ids = Fcons (make_number (id), Vw32_valid_locale_ids);
2889 return TRUE;
2890 }
2891
2892 DEFUN ("w32-get-valid-locale-ids", Fw32_get_valid_locale_ids,
2893 Sw32_get_valid_locale_ids, 0, 0, 0,
2894 doc: /* Return list of all valid Windows locale ids.
2895 Each id is a numerical value; use `w32-get-locale-info' to convert to a
2896 human-readable form. */)
2897 (void)
2898 {
2899 Vw32_valid_locale_ids = Qnil;
2900
2901 EnumSystemLocales (enum_locale_fn, LCID_SUPPORTED);
2902
2903 Vw32_valid_locale_ids = Fnreverse (Vw32_valid_locale_ids);
2904 return Vw32_valid_locale_ids;
2905 }
2906
2907
2908 DEFUN ("w32-get-default-locale-id", Fw32_get_default_locale_id, Sw32_get_default_locale_id, 0, 1, 0,
2909 doc: /* Return Windows locale id for default locale setting.
2910 By default, the system default locale setting is returned; if the optional
2911 parameter USERP is non-nil, the user default locale setting is returned.
2912 This is a numerical value; use `w32-get-locale-info' to convert to a
2913 human-readable form. */)
2914 (Lisp_Object userp)
2915 {
2916 if (NILP (userp))
2917 return make_number (GetSystemDefaultLCID ());
2918 return make_number (GetUserDefaultLCID ());
2919 }
2920
2921
2922 DEFUN ("w32-set-current-locale", Fw32_set_current_locale, Sw32_set_current_locale, 1, 1, 0,
2923 doc: /* Make Windows locale LCID be the current locale setting for Emacs.
2924 If successful, the new locale id is returned, otherwise nil. */)
2925 (Lisp_Object lcid)
2926 {
2927 CHECK_NUMBER (lcid);
2928
2929 if (!IsValidLocale (XINT (lcid), LCID_SUPPORTED))
2930 return Qnil;
2931
2932 if (!SetThreadLocale (XINT (lcid)))
2933 return Qnil;
2934
2935 /* Need to set input thread locale if present. */
2936 if (dwWindowsThreadId)
2937 /* Reply is not needed. */
2938 PostThreadMessage (dwWindowsThreadId, WM_EMACS_SETLOCALE, XINT (lcid), 0);
2939
2940 return make_number (GetThreadLocale ());
2941 }
2942
2943
2944 /* We need to build a global list, since the EnumCodePages callback
2945 function isn't given a context pointer. */
2946 Lisp_Object Vw32_valid_codepages;
2947
2948 static BOOL CALLBACK
2949 enum_codepage_fn (LPTSTR codepageNum)
2950 {
2951 DWORD id = atoi (codepageNum);
2952 Vw32_valid_codepages = Fcons (make_number (id), Vw32_valid_codepages);
2953 return TRUE;
2954 }
2955
2956 DEFUN ("w32-get-valid-codepages", Fw32_get_valid_codepages,
2957 Sw32_get_valid_codepages, 0, 0, 0,
2958 doc: /* Return list of all valid Windows codepages. */)
2959 (void)
2960 {
2961 Vw32_valid_codepages = Qnil;
2962
2963 EnumSystemCodePages (enum_codepage_fn, CP_SUPPORTED);
2964
2965 Vw32_valid_codepages = Fnreverse (Vw32_valid_codepages);
2966 return Vw32_valid_codepages;
2967 }
2968
2969
2970 DEFUN ("w32-get-console-codepage", Fw32_get_console_codepage,
2971 Sw32_get_console_codepage, 0, 0, 0,
2972 doc: /* Return current Windows codepage for console input. */)
2973 (void)
2974 {
2975 return make_number (GetConsoleCP ());
2976 }
2977
2978
2979 DEFUN ("w32-set-console-codepage", Fw32_set_console_codepage,
2980 Sw32_set_console_codepage, 1, 1, 0,
2981 doc: /* Make Windows codepage CP be the codepage for Emacs tty keyboard input.
2982 This codepage setting affects keyboard input in tty mode.
2983 If successful, the new CP is returned, otherwise nil. */)
2984 (Lisp_Object cp)
2985 {
2986 CHECK_NUMBER (cp);
2987
2988 if (!IsValidCodePage (XINT (cp)))
2989 return Qnil;
2990
2991 if (!SetConsoleCP (XINT (cp)))
2992 return Qnil;
2993
2994 return make_number (GetConsoleCP ());
2995 }
2996
2997
2998 DEFUN ("w32-get-console-output-codepage", Fw32_get_console_output_codepage,
2999 Sw32_get_console_output_codepage, 0, 0, 0,
3000 doc: /* Return current Windows codepage for console output. */)
3001 (void)
3002 {
3003 return make_number (GetConsoleOutputCP ());
3004 }
3005
3006
3007 DEFUN ("w32-set-console-output-codepage", Fw32_set_console_output_codepage,
3008 Sw32_set_console_output_codepage, 1, 1, 0,
3009 doc: /* Make Windows codepage CP be the codepage for Emacs console output.
3010 This codepage setting affects display in tty mode.
3011 If successful, the new CP is returned, otherwise nil. */)
3012 (Lisp_Object cp)
3013 {
3014 CHECK_NUMBER (cp);
3015
3016 if (!IsValidCodePage (XINT (cp)))
3017 return Qnil;
3018
3019 if (!SetConsoleOutputCP (XINT (cp)))
3020 return Qnil;
3021
3022 return make_number (GetConsoleOutputCP ());
3023 }
3024
3025
3026 DEFUN ("w32-get-codepage-charset", Fw32_get_codepage_charset,
3027 Sw32_get_codepage_charset, 1, 1, 0,
3028 doc: /* Return charset ID corresponding to codepage CP.
3029 Returns nil if the codepage is not valid. */)
3030 (Lisp_Object cp)
3031 {
3032 CHARSETINFO info;
3033
3034 CHECK_NUMBER (cp);
3035
3036 if (!IsValidCodePage (XINT (cp)))
3037 return Qnil;
3038
3039 if (TranslateCharsetInfo ((DWORD *) XINT (cp), &info, TCI_SRCCODEPAGE))
3040 return make_number (info.ciCharset);
3041
3042 return Qnil;
3043 }
3044
3045
3046 DEFUN ("w32-get-valid-keyboard-layouts", Fw32_get_valid_keyboard_layouts,
3047 Sw32_get_valid_keyboard_layouts, 0, 0, 0,
3048 doc: /* Return list of Windows keyboard languages and layouts.
3049 The return value is a list of pairs of language id and layout id. */)
3050 (void)
3051 {
3052 int num_layouts = GetKeyboardLayoutList (0, NULL);
3053 HKL * layouts = (HKL *) alloca (num_layouts * sizeof (HKL));
3054 Lisp_Object obj = Qnil;
3055
3056 if (GetKeyboardLayoutList (num_layouts, layouts) == num_layouts)
3057 {
3058 while (--num_layouts >= 0)
3059 {
3060 DWORD kl = (DWORD) layouts[num_layouts];
3061
3062 obj = Fcons (Fcons (make_number (kl & 0xffff),
3063 make_number ((kl >> 16) & 0xffff)),
3064 obj);
3065 }
3066 }
3067
3068 return obj;
3069 }
3070
3071
3072 DEFUN ("w32-get-keyboard-layout", Fw32_get_keyboard_layout,
3073 Sw32_get_keyboard_layout, 0, 0, 0,
3074 doc: /* Return current Windows keyboard language and layout.
3075 The return value is the cons of the language id and the layout id. */)
3076 (void)
3077 {
3078 DWORD kl = (DWORD) GetKeyboardLayout (dwWindowsThreadId);
3079
3080 return Fcons (make_number (kl & 0xffff),
3081 make_number ((kl >> 16) & 0xffff));
3082 }
3083
3084
3085 DEFUN ("w32-set-keyboard-layout", Fw32_set_keyboard_layout,
3086 Sw32_set_keyboard_layout, 1, 1, 0,
3087 doc: /* Make LAYOUT be the current keyboard layout for Emacs.
3088 The keyboard layout setting affects interpretation of keyboard input.
3089 If successful, the new layout id is returned, otherwise nil. */)
3090 (Lisp_Object layout)
3091 {
3092 DWORD kl;
3093
3094 CHECK_CONS (layout);
3095 CHECK_NUMBER_CAR (layout);
3096 CHECK_NUMBER_CDR (layout);
3097
3098 kl = (XINT (XCAR (layout)) & 0xffff)
3099 | (XINT (XCDR (layout)) << 16);
3100
3101 /* Synchronize layout with input thread. */
3102 if (dwWindowsThreadId)
3103 {
3104 if (PostThreadMessage (dwWindowsThreadId, WM_EMACS_SETKEYBOARDLAYOUT,
3105 (WPARAM) kl, 0))
3106 {
3107 MSG msg;
3108 GetMessage (&msg, NULL, WM_EMACS_DONE, WM_EMACS_DONE);
3109
3110 if (msg.wParam == 0)
3111 return Qnil;
3112 }
3113 }
3114 else if (!ActivateKeyboardLayout ((HKL) kl, 0))
3115 return Qnil;
3116
3117 return Fw32_get_keyboard_layout ();
3118 }
3119
3120 \f
3121 void
3122 syms_of_ntproc (void)
3123 {
3124 DEFSYM (Qhigh, "high");
3125 DEFSYM (Qlow, "low");
3126
3127 defsubr (&Sw32_has_winsock);
3128 defsubr (&Sw32_unload_winsock);
3129
3130 defsubr (&Sw32_short_file_name);
3131 defsubr (&Sw32_long_file_name);
3132 defsubr (&Sw32_set_process_priority);
3133 defsubr (&Sw32_get_locale_info);
3134 defsubr (&Sw32_get_current_locale_id);
3135 defsubr (&Sw32_get_default_locale_id);
3136 defsubr (&Sw32_get_valid_locale_ids);
3137 defsubr (&Sw32_set_current_locale);
3138
3139 defsubr (&Sw32_get_console_codepage);
3140 defsubr (&Sw32_set_console_codepage);
3141 defsubr (&Sw32_get_console_output_codepage);
3142 defsubr (&Sw32_set_console_output_codepage);
3143 defsubr (&Sw32_get_valid_codepages);
3144 defsubr (&Sw32_get_codepage_charset);
3145
3146 defsubr (&Sw32_get_valid_keyboard_layouts);
3147 defsubr (&Sw32_get_keyboard_layout);
3148 defsubr (&Sw32_set_keyboard_layout);
3149
3150 DEFVAR_LISP ("w32-quote-process-args", Vw32_quote_process_args,
3151 doc: /* Non-nil enables quoting of process arguments to ensure correct parsing.
3152 Because Windows does not directly pass argv arrays to child processes,
3153 programs have to reconstruct the argv array by parsing the command
3154 line string. For an argument to contain a space, it must be enclosed
3155 in double quotes or it will be parsed as multiple arguments.
3156
3157 If the value is a character, that character will be used to escape any
3158 quote characters that appear, otherwise a suitable escape character
3159 will be chosen based on the type of the program. */);
3160 Vw32_quote_process_args = Qt;
3161
3162 DEFVAR_LISP ("w32-start-process-show-window",
3163 Vw32_start_process_show_window,
3164 doc: /* When nil, new child processes hide their windows.
3165 When non-nil, they show their window in the method of their choice.
3166 This variable doesn't affect GUI applications, which will never be hidden. */);
3167 Vw32_start_process_show_window = Qnil;
3168
3169 DEFVAR_LISP ("w32-start-process-share-console",
3170 Vw32_start_process_share_console,
3171 doc: /* When nil, new child processes are given a new console.
3172 When non-nil, they share the Emacs console; this has the limitation of
3173 allowing only one DOS subprocess to run at a time (whether started directly
3174 or indirectly by Emacs), and preventing Emacs from cleanly terminating the
3175 subprocess group, but may allow Emacs to interrupt a subprocess that doesn't
3176 otherwise respond to interrupts from Emacs. */);
3177 Vw32_start_process_share_console = Qnil;
3178
3179 DEFVAR_LISP ("w32-start-process-inherit-error-mode",
3180 Vw32_start_process_inherit_error_mode,
3181 doc: /* When nil, new child processes revert to the default error mode.
3182 When non-nil, they inherit their error mode setting from Emacs, which stops
3183 them blocking when trying to access unmounted drives etc. */);
3184 Vw32_start_process_inherit_error_mode = Qt;
3185
3186 DEFVAR_INT ("w32-pipe-read-delay", w32_pipe_read_delay,
3187 doc: /* Forced delay before reading subprocess output.
3188 This is done to improve the buffering of subprocess output, by
3189 avoiding the inefficiency of frequently reading small amounts of data.
3190
3191 If positive, the value is the number of milliseconds to sleep before
3192 reading the subprocess output. If negative, the magnitude is the number
3193 of time slices to wait (effectively boosting the priority of the child
3194 process temporarily). A value of zero disables waiting entirely. */);
3195 w32_pipe_read_delay = 50;
3196
3197 DEFVAR_LISP ("w32-downcase-file-names", Vw32_downcase_file_names,
3198 doc: /* Non-nil means convert all-upper case file names to lower case.
3199 This applies when performing completions and file name expansion.
3200 Note that the value of this setting also affects remote file names,
3201 so you probably don't want to set to non-nil if you use case-sensitive
3202 filesystems via ange-ftp. */);
3203 Vw32_downcase_file_names = Qnil;
3204
3205 #if 0
3206 DEFVAR_LISP ("w32-generate-fake-inodes", Vw32_generate_fake_inodes,
3207 doc: /* Non-nil means attempt to fake realistic inode values.
3208 This works by hashing the truename of files, and should detect
3209 aliasing between long and short (8.3 DOS) names, but can have
3210 false positives because of hash collisions. Note that determining
3211 the truename of a file can be slow. */);
3212 Vw32_generate_fake_inodes = Qnil;
3213 #endif
3214
3215 DEFVAR_LISP ("w32-get-true-file-attributes", Vw32_get_true_file_attributes,
3216 doc: /* Non-nil means determine accurate file attributes in `file-attributes'.
3217 This option controls whether to issue additional system calls to determine
3218 accurate link counts, file type, and ownership information. It is more
3219 useful for files on NTFS volumes, where hard links and file security are
3220 supported, than on volumes of the FAT family.
3221
3222 Without these system calls, link count will always be reported as 1 and file
3223 ownership will be attributed to the current user.
3224 The default value `local' means only issue these system calls for files
3225 on local fixed drives. A value of nil means never issue them.
3226 Any other non-nil value means do this even on remote and removable drives
3227 where the performance impact may be noticeable even on modern hardware. */);
3228 Vw32_get_true_file_attributes = Qlocal;
3229
3230 staticpro (&Vw32_valid_locale_ids);
3231 staticpro (&Vw32_valid_codepages);
3232 }
3233 /* end of w32proc.c */