aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorDave Love2000-02-01 15:01:28 +0000
committerDave Love2000-02-01 15:01:28 +0000
commit8c983bf2575825fdaef0caa7b2cd5a9561969629 (patch)
treeb42a618ee68fa1e78a2be17265809e619053ecc7 /src
parent9a90d84c17fc094f9ba8f9347632390668f33a0e (diff)
downloademacs-8c983bf2575825fdaef0caa7b2cd5a9561969629.tar.gz
emacs-8c983bf2575825fdaef0caa7b2cd5a9561969629.zip
(Fstart_process): Doc fix.
Diffstat (limited to 'src')
-rw-r--r--src/process.c3
-rw-r--r--src/process.c-dl4976
2 files changed, 4978 insertions, 1 deletions
diff --git a/src/process.c b/src/process.c
index 71e244fc7fb..9fe2c5af942 100644
--- a/src/process.c
+++ b/src/process.c
@@ -1023,7 +1023,6 @@ static Lisp_Object start_process_unwind ();
1023 1023
1024DEFUN ("start-process", Fstart_process, Sstart_process, 3, MANY, 0, 1024DEFUN ("start-process", Fstart_process, Sstart_process, 3, MANY, 0,
1025 "Start a program in a subprocess. Return the process object for it.\n\ 1025 "Start a program in a subprocess. Return the process object for it.\n\
1026Args are NAME BUFFER PROGRAM &rest PROGRAM-ARGS\n\
1027NAME is name for process. It is modified if necessary to make it unique.\n\ 1026NAME is name for process. It is modified if necessary to make it unique.\n\
1028BUFFER is the buffer or (buffer-name) to associate with the process.\n\ 1027BUFFER is the buffer or (buffer-name) to associate with the process.\n\
1029 Process output goes at end of that buffer, unless you specify\n\ 1028 Process output goes at end of that buffer, unless you specify\n\
@@ -2835,6 +2834,7 @@ read_process_output_error_handler (error)
2835 Vinhibit_quit = Qt; 2834 Vinhibit_quit = Qt;
2836 update_echo_area (); 2835 update_echo_area ();
2837 Fsleep_for (make_number (2), Qnil); 2836 Fsleep_for (make_number (2), Qnil);
2837 return Qt;
2838} 2838}
2839 2839
2840/* Read pending output from the process channel, 2840/* Read pending output from the process channel,
@@ -4263,6 +4263,7 @@ exec_sentinel_error_handler (error)
4263 Vinhibit_quit = Qt; 4263 Vinhibit_quit = Qt;
4264 update_echo_area (); 4264 update_echo_area ();
4265 Fsleep_for (make_number (2), Qnil); 4265 Fsleep_for (make_number (2), Qnil);
4266 return Qt;
4266} 4267}
4267 4268
4268static void 4269static void
diff --git a/src/process.c-dl b/src/process.c-dl
new file mode 100644
index 00000000000..58d25180165
--- /dev/null
+++ b/src/process.c-dl
@@ -0,0 +1,4976 @@
1/* Asynchronous subprocess control for GNU Emacs.
2 Copyright (C) 1985, 86, 87, 88, 93, 94, 95, 96, 98, 1999
3 Free Software Foundation, Inc.
4
5This file is part of GNU Emacs.
6
7GNU Emacs is free software; you can redistribute it and/or modify
8it under the terms of the GNU General Public License as published by
9the Free Software Foundation; either version 2, or (at your option)
10any later version.
11
12GNU Emacs is distributed in the hope that it will be useful,
13but WITHOUT ANY WARRANTY; without even the implied warranty of
14MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15GNU General Public License for more details.
16
17You should have received a copy of the GNU General Public License
18along with GNU Emacs; see the file COPYING. If not, write to
19the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
20Boston, MA 02111-1307, USA. */
21
22
23#define _GNU_SOURCE /* to get strsignal declared with glibc 2 */
24#include <config.h>
25#include <signal.h>
26
27/* This file is split into two parts by the following preprocessor
28 conditional. The 'then' clause contains all of the support for
29 asynchronous subprocesses. The 'else' clause contains stub
30 versions of some of the asynchronous subprocess routines that are
31 often called elsewhere in Emacs, so we don't have to #ifdef the
32 sections that call them. */
33
34
35#ifdef subprocesses
36
37#include <stdio.h>
38#include <errno.h>
39#include <setjmp.h>
40#include <sys/types.h> /* some typedefs are used in sys/file.h */
41#include <sys/file.h>
42#include <sys/stat.h>
43#ifdef HAVE_UNISTD_H
44#include <unistd.h>
45#endif
46
47#ifdef WINDOWSNT
48#include <stdlib.h>
49#include <fcntl.h>
50#endif /* not WINDOWSNT */
51
52#ifdef HAVE_SOCKETS /* TCP connection support, if kernel can do it */
53#include <sys/socket.h>
54#include <netdb.h>
55#include <netinet/in.h>
56#include <arpa/inet.h>
57#ifdef NEED_NET_ERRNO_H
58#include <net/errno.h>
59#endif /* NEED_NET_ERRNO_H */
60#endif /* HAVE_SOCKETS */
61
62/* TERM is a poor-man's SLIP, used on GNU/Linux. */
63#ifdef TERM
64#include <client.h>
65#endif
66
67/* On some systems, e.g. DGUX, inet_addr returns a 'struct in_addr'. */
68#ifdef HAVE_BROKEN_INET_ADDR
69#define IN_ADDR struct in_addr
70#define NUMERIC_ADDR_ERROR (numeric_addr.s_addr == -1)
71#else
72#define IN_ADDR unsigned long
73#define NUMERIC_ADDR_ERROR (numeric_addr == -1)
74#endif
75
76#if defined(BSD_SYSTEM) || defined(STRIDE)
77#include <sys/ioctl.h>
78#if !defined (O_NDELAY) && defined (HAVE_PTYS) && !defined(USG5)
79#include <fcntl.h>
80#endif /* HAVE_PTYS and no O_NDELAY */
81#endif /* BSD_SYSTEM || STRIDE */
82
83#ifdef BROKEN_O_NONBLOCK
84#undef O_NONBLOCK
85#endif /* BROKEN_O_NONBLOCK */
86
87#ifdef NEED_BSDTTY
88#include <bsdtty.h>
89#endif
90
91#ifdef IRIS
92#include <sys/sysmacros.h> /* for "minor" */
93#endif /* not IRIS */
94
95#include "systime.h"
96#include "systty.h"
97
98#include "lisp.h"
99#include "window.h"
100#include "buffer.h"
101#include "charset.h"
102#include "coding.h"
103#include "process.h"
104#include "termhooks.h"
105#include "termopts.h"
106#include "commands.h"
107#include "frame.h"
108#include "blockinput.h"
109#include "keyboard.h"
110#include "dispextern.h"
111#include "composite.h"
112#include "atimer.h"
113
114#define max(a, b) ((a) > (b) ? (a) : (b))
115
116Lisp_Object Qprocessp;
117Lisp_Object Qrun, Qstop, Qsignal, Qopen, Qclosed;
118Lisp_Object Qlast_nonmenu_event;
119/* Qexit is declared and initialized in eval.c. */
120
121/* a process object is a network connection when its childp field is neither
122 Qt nor Qnil but is instead a cons cell (HOSTNAME PORTNUM). */
123
124#ifdef HAVE_SOCKETS
125#define NETCONN_P(p) (GC_CONSP (XPROCESS (p)->childp))
126#else
127#define NETCONN_P(p) 0
128#endif /* HAVE_SOCKETS */
129
130/* Define first descriptor number available for subprocesses. */
131#ifdef VMS
132#define FIRST_PROC_DESC 1
133#else /* Not VMS */
134#define FIRST_PROC_DESC 3
135#endif
136
137/* Define SIGCHLD as an alias for SIGCLD. There are many conditionals
138 testing SIGCHLD. */
139
140#if !defined (SIGCHLD) && defined (SIGCLD)
141#define SIGCHLD SIGCLD
142#endif /* SIGCLD */
143
144#include "syssignal.h"
145
146#include "syswait.h"
147
148extern void set_waiting_for_input P_ ((EMACS_TIME *));
149
150extern int errno;
151#ifdef VMS
152extern char *sys_errlist[];
153#endif
154
155#ifndef HAVE_H_ERRNO
156extern int h_errno;
157#endif
158
159/* t means use pty, nil means use a pipe,
160 maybe other values to come. */
161static Lisp_Object Vprocess_connection_type;
162
163#ifdef SKTPAIR
164#ifndef HAVE_SOCKETS
165#include <sys/socket.h>
166#endif
167#endif /* SKTPAIR */
168
169/* These next two vars are non-static since sysdep.c uses them in the
170 emulation of `select'. */
171/* Number of events of change of status of a process. */
172int process_tick;
173/* Number of events for which the user or sentinel has been notified. */
174int update_tick;
175
176#include "sysselect.h"
177
178extern int keyboard_bit_set P_ ((SELECT_TYPE *));
179
180/* If we support a window system, turn on the code to poll periodically
181 to detect C-g. It isn't actually used when doing interrupt input. */
182#ifdef HAVE_WINDOW_SYSTEM
183#define POLL_FOR_INPUT
184#endif
185
186/* Mask of bits indicating the descriptors that we wait for input on. */
187
188static SELECT_TYPE input_wait_mask;
189
190/* Mask that excludes keyboard input descriptor (s). */
191
192static SELECT_TYPE non_keyboard_wait_mask;
193
194/* Mask that excludes process input descriptor (s). */
195
196static SELECT_TYPE non_process_wait_mask;
197
198/* The largest descriptor currently in use for a process object. */
199static int max_process_desc;
200
201/* The largest descriptor currently in use for keyboard input. */
202static int max_keyboard_desc;
203
204/* Nonzero means delete a process right away if it exits. */
205static int delete_exited_processes;
206
207/* Indexed by descriptor, gives the process (if any) for that descriptor */
208Lisp_Object chan_process[MAXDESC];
209
210/* Alist of elements (NAME . PROCESS) */
211Lisp_Object Vprocess_alist;
212
213/* Buffered-ahead input char from process, indexed by channel.
214 -1 means empty (no char is buffered).
215 Used on sys V where the only way to tell if there is any
216 output from the process is to read at least one char.
217 Always -1 on systems that support FIONREAD. */
218
219/* Don't make static; need to access externally. */
220int proc_buffered_char[MAXDESC];
221
222/* Table of `struct coding-system' for each process. */
223static struct coding_system *proc_decode_coding_system[MAXDESC];
224static struct coding_system *proc_encode_coding_system[MAXDESC];
225
226static Lisp_Object get_process ();
227
228extern EMACS_TIME timer_check ();
229extern int timers_run;
230
231/* Maximum number of bytes to send to a pty without an eof. */
232static int pty_max_bytes;
233
234extern Lisp_Object Vfile_name_coding_system, Vdefault_file_name_coding_system;
235
236#ifdef HAVE_PTYS
237/* The file name of the pty opened by allocate_pty. */
238
239static char pty_name[24];
240#endif
241
242/* Compute the Lisp form of the process status, p->status, from
243 the numeric status that was returned by `wait'. */
244
245Lisp_Object status_convert ();
246
247void
248update_status (p)
249 struct Lisp_Process *p;
250{
251 union { int i; WAITTYPE wt; } u;
252 u.i = XFASTINT (p->raw_status_low) + (XFASTINT (p->raw_status_high) << 16);
253 p->status = status_convert (u.wt);
254 p->raw_status_low = Qnil;
255 p->raw_status_high = Qnil;
256}
257
258/* Convert a process status word in Unix format to
259 the list that we use internally. */
260
261Lisp_Object
262status_convert (w)
263 WAITTYPE w;
264{
265 if (WIFSTOPPED (w))
266 return Fcons (Qstop, Fcons (make_number (WSTOPSIG (w)), Qnil));
267 else if (WIFEXITED (w))
268 return Fcons (Qexit, Fcons (make_number (WRETCODE (w)),
269 WCOREDUMP (w) ? Qt : Qnil));
270 else if (WIFSIGNALED (w))
271 return Fcons (Qsignal, Fcons (make_number (WTERMSIG (w)),
272 WCOREDUMP (w) ? Qt : Qnil));
273 else
274 return Qrun;
275}
276
277/* Given a status-list, extract the three pieces of information
278 and store them individually through the three pointers. */
279
280void
281decode_status (l, symbol, code, coredump)
282 Lisp_Object l;
283 Lisp_Object *symbol;
284 int *code;
285 int *coredump;
286{
287 Lisp_Object tem;
288
289 if (SYMBOLP (l))
290 {
291 *symbol = l;
292 *code = 0;
293 *coredump = 0;
294 }
295 else
296 {
297 *symbol = XCAR (l);
298 tem = XCDR (l);
299 *code = XFASTINT (XCAR (tem));
300 tem = XCDR (tem);
301 *coredump = !NILP (tem);
302 }
303}
304
305/* Return a string describing a process status list. */
306
307Lisp_Object
308status_message (status)
309 Lisp_Object status;
310{
311 Lisp_Object symbol;
312 int code, coredump;
313 Lisp_Object string, string2;
314
315 decode_status (status, &symbol, &code, &coredump);
316
317 if (EQ (symbol, Qsignal) || EQ (symbol, Qstop))
318 {
319 char *signame;
320 synchronize_system_messages_locale ();
321 signame = strsignal (code);
322 if (signame == 0)
323 signame = "unknown";
324 string = build_string (signame);
325 string2 = build_string (coredump ? " (core dumped)\n" : "\n");
326 XSTRING (string)->data[0] = DOWNCASE (XSTRING (string)->data[0]);
327 return concat2 (string, string2);
328 }
329 else if (EQ (symbol, Qexit))
330 {
331 if (code == 0)
332 return build_string ("finished\n");
333 string = Fnumber_to_string (make_number (code));
334 string2 = build_string (coredump ? " (core dumped)\n" : "\n");
335 return concat2 (build_string ("exited abnormally with code "),
336 concat2 (string, string2));
337 }
338 else
339 return Fcopy_sequence (Fsymbol_name (symbol));
340}
341
342#ifdef HAVE_PTYS
343
344/* Open an available pty, returning a file descriptor.
345 Return -1 on failure.
346 The file name of the terminal corresponding to the pty
347 is left in the variable pty_name. */
348
349int
350allocate_pty ()
351{
352 struct stat stb;
353 register int c, i;
354 int fd;
355
356 /* Some systems name their pseudoterminals so that there are gaps in
357 the usual sequence - for example, on HP9000/S700 systems, there
358 are no pseudoterminals with names ending in 'f'. So we wait for
359 three failures in a row before deciding that we've reached the
360 end of the ptys. */
361 int failed_count = 0;
362
363#ifdef PTY_ITERATION
364 PTY_ITERATION
365#else
366 for (c = FIRST_PTY_LETTER; c <= 'z'; c++)
367 for (i = 0; i < 16; i++)
368#endif
369 {
370#ifdef PTY_NAME_SPRINTF
371 PTY_NAME_SPRINTF
372#else
373 sprintf (pty_name, "/dev/pty%c%x", c, i);
374#endif /* no PTY_NAME_SPRINTF */
375
376#ifdef PTY_OPEN
377 PTY_OPEN;
378#else /* no PTY_OPEN */
379#ifdef IRIS
380 /* Unusual IRIS code */
381 *ptyv = emacs_open ("/dev/ptc", O_RDWR | O_NDELAY, 0);
382 if (fd < 0)
383 return -1;
384 if (fstat (fd, &stb) < 0)
385 return -1;
386#else /* not IRIS */
387 if (stat (pty_name, &stb) < 0)
388 {
389 failed_count++;
390 if (failed_count >= 3)
391 return -1;
392 }
393 else
394 failed_count = 0;
395#ifdef O_NONBLOCK
396 fd = emacs_open (pty_name, O_RDWR | O_NONBLOCK, 0);
397#else
398 fd = emacs_open (pty_name, O_RDWR | O_NDELAY, 0);
399#endif
400#endif /* not IRIS */
401#endif /* no PTY_OPEN */
402
403 if (fd >= 0)
404 {
405 /* check to make certain that both sides are available
406 this avoids a nasty yet stupid bug in rlogins */
407#ifdef PTY_TTY_NAME_SPRINTF
408 PTY_TTY_NAME_SPRINTF
409#else
410 sprintf (pty_name, "/dev/tty%c%x", c, i);
411#endif /* no PTY_TTY_NAME_SPRINTF */
412#ifndef UNIPLUS
413 if (access (pty_name, 6) != 0)
414 {
415 emacs_close (fd);
416#if !defined(IRIS) && !defined(__sgi)
417 continue;
418#else
419 return -1;
420#endif /* IRIS */
421 }
422#endif /* not UNIPLUS */
423 setup_pty (fd);
424 return fd;
425 }
426 }
427 return -1;
428}
429#endif /* HAVE_PTYS */
430
431Lisp_Object
432make_process (name)
433 Lisp_Object name;
434{
435 struct Lisp_Vector *vec;
436 register Lisp_Object val, tem, name1;
437 register struct Lisp_Process *p;
438 char suffix[10];
439 register int i;
440
441 vec = allocate_vectorlike ((EMACS_INT) VECSIZE (struct Lisp_Process));
442 for (i = 0; i < VECSIZE (struct Lisp_Process); i++)
443 vec->contents[i] = Qnil;
444 vec->size = VECSIZE (struct Lisp_Process);
445 p = (struct Lisp_Process *)vec;
446
447 XSETINT (p->infd, -1);
448 XSETINT (p->outfd, -1);
449 XSETFASTINT (p->pid, 0);
450 XSETFASTINT (p->tick, 0);
451 XSETFASTINT (p->update_tick, 0);
452 p->raw_status_low = Qnil;
453 p->raw_status_high = Qnil;
454 p->status = Qrun;
455 p->mark = Fmake_marker ();
456
457 /* If name is already in use, modify it until it is unused. */
458
459 name1 = name;
460 for (i = 1; ; i++)
461 {
462 tem = Fget_process (name1);
463 if (NILP (tem)) break;
464 sprintf (suffix, "<%d>", i);
465 name1 = concat2 (name, build_string (suffix));
466 }
467 name = name1;
468 p->name = name;
469 XSETPROCESS (val, p);
470 Vprocess_alist = Fcons (Fcons (name, val), Vprocess_alist);
471 return val;
472}
473
474void
475remove_process (proc)
476 register Lisp_Object proc;
477{
478 register Lisp_Object pair;
479
480 pair = Frassq (proc, Vprocess_alist);
481 Vprocess_alist = Fdelq (pair, Vprocess_alist);
482
483 deactivate_process (proc);
484}
485
486DEFUN ("processp", Fprocessp, Sprocessp, 1, 1, 0,
487 "Return t if OBJECT is a process.")
488 (object)
489 Lisp_Object object;
490{
491 return PROCESSP (object) ? Qt : Qnil;
492}
493
494DEFUN ("get-process", Fget_process, Sget_process, 1, 1, 0,
495 "Return the process named NAME, or nil if there is none.")
496 (name)
497 register Lisp_Object name;
498{
499 if (PROCESSP (name))
500 return name;
501 CHECK_STRING (name, 0);
502 return Fcdr (Fassoc (name, Vprocess_alist));
503}
504
505DEFUN ("get-buffer-process", Fget_buffer_process, Sget_buffer_process, 1, 1, 0,
506 "Return the (or a) process associated with BUFFER.\n\
507BUFFER may be a buffer or the name of one.")
508 (buffer)
509 register Lisp_Object buffer;
510{
511 register Lisp_Object buf, tail, proc;
512
513 if (NILP (buffer)) return Qnil;
514 buf = Fget_buffer (buffer);
515 if (NILP (buf)) return Qnil;
516
517 for (tail = Vprocess_alist; !NILP (tail); tail = Fcdr (tail))
518 {
519 proc = Fcdr (Fcar (tail));
520 if (PROCESSP (proc) && EQ (XPROCESS (proc)->buffer, buf))
521 return proc;
522 }
523 return Qnil;
524}
525
526/* This is how commands for the user decode process arguments. It
527 accepts a process, a process name, a buffer, a buffer name, or nil.
528 Buffers denote the first process in the buffer, and nil denotes the
529 current buffer. */
530
531static Lisp_Object
532get_process (name)
533 register Lisp_Object name;
534{
535 register Lisp_Object proc, obj;
536 if (STRINGP (name))
537 {
538 obj = Fget_process (name);
539 if (NILP (obj))
540 obj = Fget_buffer (name);
541 if (NILP (obj))
542 error ("Process %s does not exist", XSTRING (name)->data);
543 }
544 else if (NILP (name))
545 obj = Fcurrent_buffer ();
546 else
547 obj = name;
548
549 /* Now obj should be either a buffer object or a process object.
550 */
551 if (BUFFERP (obj))
552 {
553 proc = Fget_buffer_process (obj);
554 if (NILP (proc))
555 error ("Buffer %s has no process", XSTRING (XBUFFER (obj)->name)->data);
556 }
557 else
558 {
559 CHECK_PROCESS (obj, 0);
560 proc = obj;
561 }
562 return proc;
563}
564
565DEFUN ("delete-process", Fdelete_process, Sdelete_process, 1, 1, 0,
566 "Delete PROCESS: kill it and forget about it immediately.\n\
567PROCESS may be a process, a buffer, the name of a process or buffer, or\n\
568nil, indicating the current buffer's process.")
569 (process)
570 register Lisp_Object process;
571{
572 process = get_process (process);
573 XPROCESS (process)->raw_status_low = Qnil;
574 XPROCESS (process)->raw_status_high = Qnil;
575 if (NETCONN_P (process))
576 {
577 XPROCESS (process)->status = Fcons (Qexit, Fcons (make_number (0), Qnil));
578 XSETINT (XPROCESS (process)->tick, ++process_tick);
579 }
580 else if (XINT (XPROCESS (process)->infd) >= 0)
581 {
582 Fkill_process (process, Qnil);
583 /* Do this now, since remove_process will make sigchld_handler do nothing. */
584 XPROCESS (process)->status
585 = Fcons (Qsignal, Fcons (make_number (SIGKILL), Qnil));
586 XSETINT (XPROCESS (process)->tick, ++process_tick);
587 status_notify ();
588 }
589 remove_process (process);
590 return Qnil;
591}
592
593DEFUN ("process-status", Fprocess_status, Sprocess_status, 1, 1, 0,
594 "Return the status of PROCESS.\n\
595The returned value is one of the following symbols:\n\
596run -- for a process that is running.\n\
597stop -- for a process stopped but continuable.\n\
598exit -- for a process that has exited.\n\
599signal -- for a process that has got a fatal signal.\n\
600open -- for a network stream connection that is open.\n\
601closed -- for a network stream connection that is closed.\n\
602nil -- if arg is a process name and no such process exists.\n\
603PROCESS may be a process, a buffer, the name of a process, or\n\
604nil, indicating the current buffer's process.")
605 (process)
606 register Lisp_Object process;
607{
608 register struct Lisp_Process *p;
609 register Lisp_Object status;
610
611 if (STRINGP (process))
612 process = Fget_process (process);
613 else
614 process = get_process (process);
615
616 if (NILP (process))
617 return process;
618
619 p = XPROCESS (process);
620 if (!NILP (p->raw_status_low))
621 update_status (p);
622 status = p->status;
623 if (CONSP (status))
624 status = XCAR (status);
625 if (NETCONN_P (process))
626 {
627 if (EQ (status, Qrun))
628 status = Qopen;
629 else if (EQ (status, Qexit))
630 status = Qclosed;
631 }
632 return status;
633}
634
635DEFUN ("process-exit-status", Fprocess_exit_status, Sprocess_exit_status,
636 1, 1, 0,
637 "Return the exit status of PROCESS or the signal number that killed it.\n\
638If PROCESS has not yet exited or died, return 0.")
639 (process)
640 register Lisp_Object process;
641{
642 CHECK_PROCESS (process, 0);
643 if (!NILP (XPROCESS (process)->raw_status_low))
644 update_status (XPROCESS (process));
645 if (CONSP (XPROCESS (process)->status))
646 return XCAR (XCDR (XPROCESS (process)->status));
647 return make_number (0);
648}
649
650DEFUN ("process-id", Fprocess_id, Sprocess_id, 1, 1, 0,
651 "Return the process id of PROCESS.\n\
652This is the pid of the Unix process which PROCESS uses or talks to.\n\
653For a network connection, this value is nil.")
654 (process)
655 register Lisp_Object process;
656{
657 CHECK_PROCESS (process, 0);
658 return XPROCESS (process)->pid;
659}
660
661DEFUN ("process-name", Fprocess_name, Sprocess_name, 1, 1, 0,
662 "Return the name of PROCESS, as a string.\n\
663This is the name of the program invoked in PROCESS,\n\
664possibly modified to make it unique among process names.")
665 (process)
666 register Lisp_Object process;
667{
668 CHECK_PROCESS (process, 0);
669 return XPROCESS (process)->name;
670}
671
672DEFUN ("process-command", Fprocess_command, Sprocess_command, 1, 1, 0,
673 "Return the command that was executed to start PROCESS.\n\
674This is a list of strings, the first string being the program executed\n\
675and the rest of the strings being the arguments given to it.\n\
676For a non-child channel, this is nil.")
677 (process)
678 register Lisp_Object process;
679{
680 CHECK_PROCESS (process, 0);
681 return XPROCESS (process)->command;
682}
683
684DEFUN ("process-tty-name", Fprocess_tty_name, Sprocess_tty_name, 1, 1, 0,
685 "Return the name of the terminal PROCESS uses, or nil if none.\n\
686This is the terminal that the process itself reads and writes on,\n\
687not the name of the pty that Emacs uses to talk with that terminal.")
688 (process)
689 register Lisp_Object process;
690{
691 CHECK_PROCESS (process, 0);
692 return XPROCESS (process)->tty_name;
693}
694
695DEFUN ("set-process-buffer", Fset_process_buffer, Sset_process_buffer,
696 2, 2, 0,
697 "Set buffer associated with PROCESS to BUFFER (a buffer, or nil).")
698 (process, buffer)
699 register Lisp_Object process, buffer;
700{
701 CHECK_PROCESS (process, 0);
702 if (!NILP (buffer))
703 CHECK_BUFFER (buffer, 1);
704 XPROCESS (process)->buffer = buffer;
705 return buffer;
706}
707
708DEFUN ("process-buffer", Fprocess_buffer, Sprocess_buffer,
709 1, 1, 0,
710 "Return the buffer PROCESS is associated with.\n\
711Output from PROCESS is inserted in this buffer unless PROCESS has a filter.")
712 (process)
713 register Lisp_Object process;
714{
715 CHECK_PROCESS (process, 0);
716 return XPROCESS (process)->buffer;
717}
718
719DEFUN ("process-mark", Fprocess_mark, Sprocess_mark,
720 1, 1, 0,
721 "Return the marker for the end of the last output from PROCESS.")
722 (process)
723 register Lisp_Object process;
724{
725 CHECK_PROCESS (process, 0);
726 return XPROCESS (process)->mark;
727}
728
729DEFUN ("set-process-filter", Fset_process_filter, Sset_process_filter,
730 2, 2, 0,
731 "Give PROCESS the filter function FILTER; nil means no filter.\n\
732t means stop accepting output from the process.\n\
733When a process has a filter, each time it does output\n\
734the entire string of output is passed to the filter.\n\
735The filter gets two arguments: the process and the string of output.\n\
736If the process has a filter, its buffer is not used for output.")
737 (process, filter)
738 register Lisp_Object process, filter;
739{
740 CHECK_PROCESS (process, 0);
741 if (EQ (filter, Qt))
742 {
743 FD_CLR (XINT (XPROCESS (process)->infd), &input_wait_mask);
744 FD_CLR (XINT (XPROCESS (process)->infd), &non_keyboard_wait_mask);
745 }
746 else if (EQ (XPROCESS (process)->filter, Qt))
747 {
748 FD_SET (XINT (XPROCESS (process)->infd), &input_wait_mask);
749 FD_SET (XINT (XPROCESS (process)->infd), &non_keyboard_wait_mask);
750 }
751 XPROCESS (process)->filter = filter;
752 return filter;
753}
754
755DEFUN ("process-filter", Fprocess_filter, Sprocess_filter,
756 1, 1, 0,
757 "Returns the filter function of PROCESS; nil if none.\n\
758See `set-process-filter' for more info on filter functions.")
759 (process)
760 register Lisp_Object process;
761{
762 CHECK_PROCESS (process, 0);
763 return XPROCESS (process)->filter;
764}
765
766DEFUN ("set-process-sentinel", Fset_process_sentinel, Sset_process_sentinel,
767 2, 2, 0,
768 "Give PROCESS the sentinel SENTINEL; nil for none.\n\
769The sentinel is called as a function when the process changes state.\n\
770It gets two arguments: the process, and a string describing the change.")
771 (process, sentinel)
772 register Lisp_Object process, sentinel;
773{
774 CHECK_PROCESS (process, 0);
775 XPROCESS (process)->sentinel = sentinel;
776 return sentinel;
777}
778
779DEFUN ("process-sentinel", Fprocess_sentinel, Sprocess_sentinel,
780 1, 1, 0,
781 "Return the sentinel of PROCESS; nil if none.\n\
782See `set-process-sentinel' for more info on sentinels.")
783 (process)
784 register Lisp_Object process;
785{
786 CHECK_PROCESS (process, 0);
787 return XPROCESS (process)->sentinel;
788}
789
790DEFUN ("set-process-window-size", Fset_process_window_size,
791 Sset_process_window_size, 3, 3, 0,
792 "Tell PROCESS that it has logical window size HEIGHT and WIDTH.")
793 (process, height, width)
794 register Lisp_Object process, height, width;
795{
796 CHECK_PROCESS (process, 0);
797 CHECK_NATNUM (height, 0);
798 CHECK_NATNUM (width, 0);
799 if (set_window_size (XINT (XPROCESS (process)->infd),
800 XINT (height), XINT (width)) <= 0)
801 return Qnil;
802 else
803 return Qt;
804}
805
806DEFUN ("set-process-inherit-coding-system-flag",
807 Fset_process_inherit_coding_system_flag,
808 Sset_process_inherit_coding_system_flag, 2, 2, 0,
809 "Determine whether buffer of PROCESS will inherit coding-system.\n\
810If the second argument FLAG is non-nil, then the variable\n\
811`buffer-file-coding-system' of the buffer associated with PROCESS\n\
812will be bound to the value of the coding system used to decode\n\
813the process output.\n\
814\n\
815This is useful when the coding system specified for the process buffer\n\
816leaves either the character code conversion or the end-of-line conversion\n\
817unspecified, or if the coding system used to decode the process output\n\
818is more appropriate for saving the process buffer.\n\
819\n\
820Binding the variable `inherit-process-coding-system' to non-nil before\n\
821starting the process is an alternative way of setting the inherit flag\n\
822for the process which will run.")
823 (process, flag)
824 register Lisp_Object process, flag;
825{
826 CHECK_PROCESS (process, 0);
827 XPROCESS (process)->inherit_coding_system_flag = flag;
828 return flag;
829}
830
831DEFUN ("process-inherit-coding-system-flag",
832 Fprocess_inherit_coding_system_flag, Sprocess_inherit_coding_system_flag,
833 1, 1, 0,
834 "Return the value of inherit-coding-system flag for PROCESS.\n\
835If this flag is t, `buffer-file-coding-system' of the buffer\n\
836associated with PROCESS will inherit the coding system used to decode\n\
837the process output.")
838 (process)
839 register Lisp_Object process;
840{
841 CHECK_PROCESS (process, 0);
842 return XPROCESS (process)->inherit_coding_system_flag;
843}
844
845DEFUN ("process-kill-without-query", Fprocess_kill_without_query,
846 Sprocess_kill_without_query, 1, 2, 0,
847 "Say no query needed if PROCESS is running when Emacs is exited.\n\
848Optional second argument if non-nil says to require a query.\n\
849Value is t if a query was formerly required.")
850 (process, value)
851 register Lisp_Object process, value;
852{
853 Lisp_Object tem;
854
855 CHECK_PROCESS (process, 0);
856 tem = XPROCESS (process)->kill_without_query;
857 XPROCESS (process)->kill_without_query = Fnull (value);
858
859 return Fnull (tem);
860}
861
862DEFUN ("process-contact", Fprocess_contact, Sprocess_contact,
863 1, 1, 0,
864 "Return the contact info of PROCESS; t for a real child.\n\
865For a net connection, the value is a cons cell of the form (HOST SERVICE).")
866 (process)
867 register Lisp_Object process;
868{
869 CHECK_PROCESS (process, 0);
870 return XPROCESS (process)->childp;
871}
872
873#if 0 /* Turned off because we don't currently record this info
874 in the process. Perhaps add it. */
875DEFUN ("process-connection", Fprocess_connection, Sprocess_connection, 1, 1, 0,
876 "Return the connection type of PROCESS.\n\
877The value is nil for a pipe, t or `pty' for a pty, or `stream' for\n\
878a socket connection.")
879 (process)
880 Lisp_Object process;
881{
882 return XPROCESS (process)->type;
883}
884#endif
885
886Lisp_Object
887list_processes_1 ()
888{
889 register Lisp_Object tail, tem;
890 Lisp_Object proc, minspace, tem1;
891 register struct Lisp_Process *p;
892 char tembuf[80];
893
894 XSETFASTINT (minspace, 1);
895
896 set_buffer_internal (XBUFFER (Vstandard_output));
897 Fbuffer_disable_undo (Vstandard_output);
898
899 current_buffer->truncate_lines = Qt;
900
901 write_string ("\
902Proc Status Buffer Tty Command\n\
903---- ------ ------ --- -------\n", -1);
904
905 for (tail = Vprocess_alist; !NILP (tail); tail = Fcdr (tail))
906 {
907 Lisp_Object symbol;
908
909 proc = Fcdr (Fcar (tail));
910 p = XPROCESS (proc);
911 if (NILP (p->childp))
912 continue;
913
914 Finsert (1, &p->name);
915 Findent_to (make_number (13), minspace);
916
917 if (!NILP (p->raw_status_low))
918 update_status (p);
919 symbol = p->status;
920 if (CONSP (p->status))
921 symbol = XCAR (p->status);
922
923
924 if (EQ (symbol, Qsignal))
925 {
926 Lisp_Object tem;
927 tem = Fcar (Fcdr (p->status));
928#ifdef VMS
929 if (XINT (tem) < NSIG)
930 write_string (sys_errlist [XINT (tem)], -1);
931 else
932#endif
933 Fprinc (symbol, Qnil);
934 }
935 else if (NETCONN_P (proc))
936 {
937 if (EQ (symbol, Qrun))
938 write_string ("open", -1);
939 else if (EQ (symbol, Qexit))
940 write_string ("closed", -1);
941 else
942 Fprinc (symbol, Qnil);
943 }
944 else
945 Fprinc (symbol, Qnil);
946
947 if (EQ (symbol, Qexit))
948 {
949 Lisp_Object tem;
950 tem = Fcar (Fcdr (p->status));
951 if (XFASTINT (tem))
952 {
953 sprintf (tembuf, " %d", (int) XFASTINT (tem));
954 write_string (tembuf, -1);
955 }
956 }
957
958 if (EQ (symbol, Qsignal) || EQ (symbol, Qexit))
959 remove_process (proc);
960
961 Findent_to (make_number (22), minspace);
962 if (NILP (p->buffer))
963 insert_string ("(none)");
964 else if (NILP (XBUFFER (p->buffer)->name))
965 insert_string ("(Killed)");
966 else
967 Finsert (1, &XBUFFER (p->buffer)->name);
968
969 Findent_to (make_number (37), minspace);
970
971 if (STRINGP (p->tty_name))
972 Finsert (1, &p->tty_name);
973 else
974 insert_string ("(none)");
975
976 Findent_to (make_number (49), minspace);
977
978 if (NETCONN_P (proc))
979 {
980 sprintf (tembuf, "(network stream connection to %s)\n",
981 XSTRING (XCAR (p->childp))->data);
982 insert_string (tembuf);
983 }
984 else
985 {
986 tem = p->command;
987 while (1)
988 {
989 tem1 = Fcar (tem);
990 Finsert (1, &tem1);
991 tem = Fcdr (tem);
992 if (NILP (tem))
993 break;
994 insert_string (" ");
995 }
996 insert_string ("\n");
997 }
998 }
999 return Qnil;
1000}
1001
1002DEFUN ("list-processes", Flist_processes, Slist_processes, 0, 0, "",
1003 "Display a list of all processes.\n\
1004Any process listed as exited or signaled is actually eliminated\n\
1005after the listing is made.")
1006 ()
1007{
1008 internal_with_output_to_temp_buffer ("*Process List*",
1009 list_processes_1, Qnil);
1010 return Qnil;
1011}
1012
1013DEFUN ("process-list", Fprocess_list, Sprocess_list, 0, 0, 0,
1014 "Return a list of all processes.")
1015 ()
1016{
1017 return Fmapcar (Qcdr, Vprocess_alist);
1018}
1019
1020/* Starting asynchronous inferior processes. */
1021
1022static Lisp_Object start_process_unwind ();
1023
1024DEFUN ("start-process", Fstart_process, Sstart_process, 3, MANY, 0,
1025 "Start a program in a subprocess. Return the process object for it.\n\
1026NAME is name for process. It is modified if necessary to make it unique.\n\
1027BUFFER is the buffer or (buffer-name) to associate with the process.\n\
1028 Process output goes at end of that buffer, unless you specify\n\
1029 an output stream or filter function to handle the output.\n\
1030 BUFFER may be also nil, meaning that this process is not associated\n\
1031 with any buffer.\n\
1032Third arg is program file name. It is searched for in PATH.\n\
1033Remaining arguments are strings to give program as arguments.")
1034 (nargs, args)
1035 int nargs;
1036 register Lisp_Object *args;
1037{
1038 Lisp_Object buffer, name, program, proc, current_dir, tem;
1039#ifdef VMS
1040 register unsigned char *new_argv;
1041 int len;
1042#else
1043 register unsigned char **new_argv;
1044#endif
1045 register int i;
1046 int count = specpdl_ptr - specpdl;
1047
1048 buffer = args[1];
1049 if (!NILP (buffer))
1050 buffer = Fget_buffer_create (buffer);
1051
1052 /* Make sure that the child will be able to chdir to the current
1053 buffer's current directory, or its unhandled equivalent. We
1054 can't just have the child check for an error when it does the
1055 chdir, since it's in a vfork.
1056
1057 We have to GCPRO around this because Fexpand_file_name and
1058 Funhandled_file_name_directory might call a file name handling
1059 function. The argument list is protected by the caller, so all
1060 we really have to worry about is buffer. */
1061 {
1062 struct gcpro gcpro1, gcpro2;
1063
1064 current_dir = current_buffer->directory;
1065
1066 GCPRO2 (buffer, current_dir);
1067
1068 current_dir
1069 = expand_and_dir_to_file (Funhandled_file_name_directory (current_dir),
1070 Qnil);
1071 if (NILP (Ffile_accessible_directory_p (current_dir)))
1072 report_file_error ("Setting current directory",
1073 Fcons (current_buffer->directory, Qnil));
1074
1075 UNGCPRO;
1076 }
1077
1078 name = args[0];
1079 CHECK_STRING (name, 0);
1080
1081 program = args[2];
1082
1083 CHECK_STRING (program, 2);
1084
1085#ifdef VMS
1086 /* Make a one member argv with all args concatenated
1087 together separated by a blank. */
1088 len = STRING_BYTES (XSTRING (program)) + 2;
1089 for (i = 3; i < nargs; i++)
1090 {
1091 tem = args[i];
1092 CHECK_STRING (tem, i);
1093 len += STRING_BYTES (XSTRING (tem)) + 1; /* count the blank */
1094 }
1095 new_argv = (unsigned char *) alloca (len);
1096 strcpy (new_argv, XSTRING (program)->data);
1097 for (i = 3; i < nargs; i++)
1098 {
1099 tem = args[i];
1100 CHECK_STRING (tem, i);
1101 strcat (new_argv, " ");
1102 strcat (new_argv, XSTRING (tem)->data);
1103 }
1104 /* Need to add code here to check for program existence on VMS */
1105
1106#else /* not VMS */
1107 new_argv = (unsigned char **) alloca ((nargs - 1) * sizeof (char *));
1108
1109 /* If program file name is not absolute, search our path for it */
1110 if (!IS_DIRECTORY_SEP (XSTRING (program)->data[0])
1111 && !(XSTRING (program)->size > 1
1112 && IS_DEVICE_SEP (XSTRING (program)->data[1])))
1113 {
1114 struct gcpro gcpro1, gcpro2, gcpro3, gcpro4;
1115
1116 tem = Qnil;
1117 GCPRO4 (name, program, buffer, current_dir);
1118 openp (Vexec_path, program, EXEC_SUFFIXES, &tem, 1);
1119 UNGCPRO;
1120 if (NILP (tem))
1121 report_file_error ("Searching for program", Fcons (program, Qnil));
1122 tem = Fexpand_file_name (tem, Qnil);
1123 new_argv[0] = XSTRING (tem)->data;
1124 }
1125 else
1126 {
1127 if (!NILP (Ffile_directory_p (program)))
1128 error ("Specified program for new process is a directory");
1129
1130 new_argv[0] = XSTRING (program)->data;
1131 }
1132
1133 for (i = 3; i < nargs; i++)
1134 {
1135 tem = args[i];
1136 CHECK_STRING (tem, i);
1137 new_argv[i - 2] = XSTRING (tem)->data;
1138 }
1139 new_argv[i - 2] = 0;
1140#endif /* not VMS */
1141
1142 proc = make_process (name);
1143 /* If an error occurs and we can't start the process, we want to
1144 remove it from the process list. This means that each error
1145 check in create_process doesn't need to call remove_process
1146 itself; it's all taken care of here. */
1147 record_unwind_protect (start_process_unwind, proc);
1148
1149 XPROCESS (proc)->childp = Qt;
1150 XPROCESS (proc)->command_channel_p = Qnil;
1151 XPROCESS (proc)->buffer = buffer;
1152 XPROCESS (proc)->sentinel = Qnil;
1153 XPROCESS (proc)->filter = Qnil;
1154 XPROCESS (proc)->command = Flist (nargs - 2, args + 2);
1155
1156 /* Make the process marker point into the process buffer (if any). */
1157 if (!NILP (buffer))
1158 set_marker_both (XPROCESS (proc)->mark, buffer,
1159 BUF_ZV (XBUFFER (buffer)),
1160 BUF_ZV_BYTE (XBUFFER (buffer)));
1161
1162 {
1163 /* Decide coding systems for communicating with the process. Here
1164 we don't setup the structure coding_system nor pay attention to
1165 unibyte mode. They are done in create_process. */
1166
1167 /* Qt denotes we have not yet called Ffind_operation_coding_system. */
1168 Lisp_Object coding_systems = Qt;
1169 Lisp_Object val, *args2;
1170 struct gcpro gcpro1;
1171
1172 val = Vcoding_system_for_read;
1173 if (NILP (val))
1174 {
1175 args2 = (Lisp_Object *) alloca ((nargs + 1) * sizeof *args2);
1176 args2[0] = Qstart_process;
1177 for (i = 0; i < nargs; i++) args2[i + 1] = args[i];
1178 GCPRO1 (proc);
1179 coding_systems = Ffind_operation_coding_system (nargs + 1, args2);
1180 UNGCPRO;
1181 if (CONSP (coding_systems))
1182 val = XCAR (coding_systems);
1183 else if (CONSP (Vdefault_process_coding_system))
1184 val = XCAR (Vdefault_process_coding_system);
1185 }
1186 XPROCESS (proc)->decode_coding_system = val;
1187
1188 val = Vcoding_system_for_write;
1189 if (NILP (val))
1190 {
1191 if (EQ (coding_systems, Qt))
1192 {
1193 args2 = (Lisp_Object *) alloca ((nargs + 1) * sizeof args2);
1194 args2[0] = Qstart_process;
1195 for (i = 0; i < nargs; i++) args2[i + 1] = args[i];
1196 GCPRO1 (proc);
1197 coding_systems = Ffind_operation_coding_system (nargs + 1, args2);
1198 UNGCPRO;
1199 }
1200 if (CONSP (coding_systems))
1201 val = XCDR (coding_systems);
1202 else if (CONSP (Vdefault_process_coding_system))
1203 val = XCDR (Vdefault_process_coding_system);
1204 }
1205 XPROCESS (proc)->encode_coding_system = val;
1206 }
1207
1208 XPROCESS (proc)->decoding_buf = make_uninit_string (0);
1209 XPROCESS (proc)->decoding_carryover = make_number (0);
1210 XPROCESS (proc)->encoding_buf = make_uninit_string (0);
1211 XPROCESS (proc)->encoding_carryover = make_number (0);
1212
1213 XPROCESS (proc)->inherit_coding_system_flag
1214 = (NILP (buffer) || !inherit_process_coding_system
1215 ? Qnil : Qt);
1216
1217 create_process (proc, (char **) new_argv, current_dir);
1218
1219 return unbind_to (count, proc);
1220}
1221
1222/* This function is the unwind_protect form for Fstart_process. If
1223 PROC doesn't have its pid set, then we know someone has signaled
1224 an error and the process wasn't started successfully, so we should
1225 remove it from the process list. */
1226static Lisp_Object
1227start_process_unwind (proc)
1228 Lisp_Object proc;
1229{
1230 if (!PROCESSP (proc))
1231 abort ();
1232
1233 /* Was PROC started successfully? */
1234 if (XINT (XPROCESS (proc)->pid) <= 0)
1235 remove_process (proc);
1236
1237 return Qnil;
1238}
1239
1240void
1241create_process_1 (timer)
1242 struct atimer *timer;
1243{
1244 /* Nothing to do. */
1245}
1246
1247
1248#if 0 /* This doesn't work; see the note before sigchld_handler. */
1249#ifdef USG
1250#ifdef SIGCHLD
1251/* Mimic blocking of signals on system V, which doesn't really have it. */
1252
1253/* Nonzero means we got a SIGCHLD when it was supposed to be blocked. */
1254int sigchld_deferred;
1255
1256SIGTYPE
1257create_process_sigchld ()
1258{
1259 signal (SIGCHLD, create_process_sigchld);
1260
1261 sigchld_deferred = 1;
1262}
1263#endif
1264#endif
1265#endif
1266
1267#ifndef VMS /* VMS version of this function is in vmsproc.c. */
1268void
1269create_process (process, new_argv, current_dir)
1270 Lisp_Object process;
1271 char **new_argv;
1272 Lisp_Object current_dir;
1273{
1274 int pid, inchannel, outchannel;
1275 int sv[2];
1276#ifdef POSIX_SIGNALS
1277 sigset_t procmask;
1278 sigset_t blocked;
1279 struct sigaction sigint_action;
1280 struct sigaction sigquit_action;
1281#ifdef AIX
1282 struct sigaction sighup_action;
1283#endif
1284#else /* !POSIX_SIGNALS */
1285#if 0
1286#ifdef SIGCHLD
1287 SIGTYPE (*sigchld)();
1288#endif
1289#endif /* 0 */
1290#endif /* !POSIX_SIGNALS */
1291 /* Use volatile to protect variables from being clobbered by longjmp. */
1292 volatile int forkin, forkout;
1293 volatile int pty_flag = 0;
1294 extern char **environ;
1295 Lisp_Object buffer = XPROCESS (process)->buffer;
1296
1297 inchannel = outchannel = -1;
1298
1299#ifdef HAVE_PTYS
1300 if (!NILP (Vprocess_connection_type))
1301 outchannel = inchannel = allocate_pty ();
1302
1303 if (inchannel >= 0)
1304 {
1305#ifndef USG
1306 /* On USG systems it does not work to open the pty's tty here
1307 and then close and reopen it in the child. */
1308#ifdef O_NOCTTY
1309 /* Don't let this terminal become our controlling terminal
1310 (in case we don't have one). */
1311 forkout = forkin = emacs_open (pty_name, O_RDWR | O_NOCTTY, 0);
1312#else
1313 forkout = forkin = emacs_open (pty_name, O_RDWR, 0);
1314#endif
1315 if (forkin < 0)
1316 report_file_error ("Opening pty", Qnil);
1317#else
1318 forkin = forkout = -1;
1319#endif /* not USG */
1320 pty_flag = 1;
1321 }
1322 else
1323#endif /* HAVE_PTYS */
1324#ifdef SKTPAIR
1325 {
1326 if (socketpair (AF_UNIX, SOCK_STREAM, 0, sv) < 0)
1327 report_file_error ("Opening socketpair", Qnil);
1328 outchannel = inchannel = sv[0];
1329 forkout = forkin = sv[1];
1330 }
1331#else /* not SKTPAIR */
1332 {
1333 int tem;
1334 tem = pipe (sv);
1335 if (tem < 0)
1336 report_file_error ("Creating pipe", Qnil);
1337 inchannel = sv[0];
1338 forkout = sv[1];
1339 tem = pipe (sv);
1340 if (tem < 0)
1341 {
1342 emacs_close (inchannel);
1343 emacs_close (forkout);
1344 report_file_error ("Creating pipe", Qnil);
1345 }
1346 outchannel = sv[1];
1347 forkin = sv[0];
1348 }
1349#endif /* not SKTPAIR */
1350
1351#if 0
1352 /* Replaced by close_process_descs */
1353 set_exclusive_use (inchannel);
1354 set_exclusive_use (outchannel);
1355#endif
1356
1357/* Stride people say it's a mystery why this is needed
1358 as well as the O_NDELAY, but that it fails without this. */
1359#if defined (STRIDE) || (defined (pfa) && defined (HAVE_PTYS))
1360 {
1361 int one = 1;
1362 ioctl (inchannel, FIONBIO, &one);
1363 }
1364#endif
1365
1366#ifdef O_NONBLOCK
1367 fcntl (inchannel, F_SETFL, O_NONBLOCK);
1368 fcntl (outchannel, F_SETFL, O_NONBLOCK);
1369#else
1370#ifdef O_NDELAY
1371 fcntl (inchannel, F_SETFL, O_NDELAY);
1372 fcntl (outchannel, F_SETFL, O_NDELAY);
1373#endif
1374#endif
1375
1376 /* Record this as an active process, with its channels.
1377 As a result, child_setup will close Emacs's side of the pipes. */
1378 chan_process[inchannel] = process;
1379 XSETINT (XPROCESS (process)->infd, inchannel);
1380 XSETINT (XPROCESS (process)->outfd, outchannel);
1381 /* Record the tty descriptor used in the subprocess. */
1382 if (forkin < 0)
1383 XPROCESS (process)->subtty = Qnil;
1384 else
1385 XSETFASTINT (XPROCESS (process)->subtty, forkin);
1386 XPROCESS (process)->pty_flag = (pty_flag ? Qt : Qnil);
1387 XPROCESS (process)->status = Qrun;
1388 if (!proc_decode_coding_system[inchannel])
1389 proc_decode_coding_system[inchannel]
1390 = (struct coding_system *) xmalloc (sizeof (struct coding_system));
1391 setup_coding_system (XPROCESS (process)->decode_coding_system,
1392 proc_decode_coding_system[inchannel]);
1393 if (!proc_encode_coding_system[outchannel])
1394 proc_encode_coding_system[outchannel]
1395 = (struct coding_system *) xmalloc (sizeof (struct coding_system));
1396 setup_coding_system (XPROCESS (process)->encode_coding_system,
1397 proc_encode_coding_system[outchannel]);
1398
1399 if ((!NILP (buffer) && NILP (XBUFFER (buffer)->enable_multibyte_characters))
1400 || (NILP (buffer) && NILP (buffer_defaults.enable_multibyte_characters)))
1401 {
1402 /* In unibyte mode, character code conversion should not take
1403 place but EOL conversion should. So, setup raw-text or one
1404 of the subsidiary according to the information just setup. */
1405 if (!NILP (XPROCESS (process)->decode_coding_system))
1406 setup_raw_text_coding_system (proc_decode_coding_system[inchannel]);
1407 if (!NILP (XPROCESS (process)->encode_coding_system))
1408 setup_raw_text_coding_system (proc_encode_coding_system[outchannel]);
1409 }
1410
1411 if (CODING_REQUIRE_ENCODING (proc_encode_coding_system[outchannel]))
1412 {
1413 /* Here we encode arguments by the coding system used for
1414 sending data to the process. We don't support using
1415 different coding systems for encoding arguments and for
1416 encoding data sent to the process. */
1417 struct gcpro gcpro1;
1418 int i = 1;
1419 struct coding_system *coding = proc_encode_coding_system[outchannel];
1420
1421 coding->mode |= CODING_MODE_LAST_BLOCK;
1422 GCPRO1 (process);
1423 while (new_argv[i] != 0)
1424 {
1425 int len = strlen (new_argv[i]);
1426 int size = encoding_buffer_size (coding, len);
1427 unsigned char *buf = (unsigned char *) alloca (size);
1428
1429 encode_coding (coding, (unsigned char *)new_argv[i], buf, len, size);
1430 buf[coding->produced] = 0;
1431 /* We don't have to free new_argv[i] because it points to a
1432 Lisp string given as an argument to `start-process'. */
1433 new_argv[i++] = (char *) buf;
1434 }
1435 UNGCPRO;
1436 coding->mode &= ~CODING_MODE_LAST_BLOCK;
1437 }
1438
1439 /* Delay interrupts until we have a chance to store
1440 the new fork's pid in its process structure */
1441#ifdef POSIX_SIGNALS
1442 sigemptyset (&blocked);
1443#ifdef SIGCHLD
1444 sigaddset (&blocked, SIGCHLD);
1445#endif
1446#ifdef HAVE_VFORK
1447 /* On many hosts (e.g. Solaris 2.4), if a vforked child calls `signal',
1448 this sets the parent's signal handlers as well as the child's.
1449 So delay all interrupts whose handlers the child might munge,
1450 and record the current handlers so they can be restored later. */
1451 sigaddset (&blocked, SIGINT ); sigaction (SIGINT , 0, &sigint_action );
1452 sigaddset (&blocked, SIGQUIT); sigaction (SIGQUIT, 0, &sigquit_action);
1453#ifdef AIX
1454 sigaddset (&blocked, SIGHUP ); sigaction (SIGHUP , 0, &sighup_action );
1455#endif
1456#endif /* HAVE_VFORK */
1457 sigprocmask (SIG_BLOCK, &blocked, &procmask);
1458#else /* !POSIX_SIGNALS */
1459#ifdef SIGCHLD
1460#ifdef BSD4_1
1461 sighold (SIGCHLD);
1462#else /* not BSD4_1 */
1463#if defined (BSD_SYSTEM) || defined (UNIPLUS) || defined (HPUX)
1464 sigsetmask (sigmask (SIGCHLD));
1465#else /* ordinary USG */
1466#if 0
1467 sigchld_deferred = 0;
1468 sigchld = signal (SIGCHLD, create_process_sigchld);
1469#endif
1470#endif /* ordinary USG */
1471#endif /* not BSD4_1 */
1472#endif /* SIGCHLD */
1473#endif /* !POSIX_SIGNALS */
1474
1475 FD_SET (inchannel, &input_wait_mask);
1476 FD_SET (inchannel, &non_keyboard_wait_mask);
1477 if (inchannel > max_process_desc)
1478 max_process_desc = inchannel;
1479
1480 /* Until we store the proper pid, enable sigchld_handler
1481 to recognize an unknown pid as standing for this process.
1482 It is very important not to let this `marker' value stay
1483 in the table after this function has returned; if it does
1484 it might cause call-process to hang and subsequent asynchronous
1485 processes to get their return values scrambled. */
1486 XSETINT (XPROCESS (process)->pid, -1);
1487
1488 BLOCK_INPUT;
1489
1490 {
1491 /* child_setup must clobber environ on systems with true vfork.
1492 Protect it from permanent change. */
1493 char **save_environ = environ;
1494
1495 current_dir = ENCODE_FILE (current_dir);
1496
1497#ifndef WINDOWSNT
1498 pid = vfork ();
1499 if (pid == 0)
1500#endif /* not WINDOWSNT */
1501 {
1502 int xforkin = forkin;
1503 int xforkout = forkout;
1504
1505#if 0 /* This was probably a mistake--it duplicates code later on,
1506 but fails to handle all the cases. */
1507 /* Make sure SIGCHLD is not blocked in the child. */
1508 sigsetmask (SIGEMPTYMASK);
1509#endif
1510
1511 /* Make the pty be the controlling terminal of the process. */
1512#ifdef HAVE_PTYS
1513 /* First, disconnect its current controlling terminal. */
1514#ifdef HAVE_SETSID
1515 /* We tried doing setsid only if pty_flag, but it caused
1516 process_set_signal to fail on SGI when using a pipe. */
1517 setsid ();
1518 /* Make the pty's terminal the controlling terminal. */
1519 if (pty_flag)
1520 {
1521#ifdef TIOCSCTTY
1522 /* We ignore the return value
1523 because faith@cs.unc.edu says that is necessary on Linux. */
1524 ioctl (xforkin, TIOCSCTTY, 0);
1525#endif
1526 }
1527#else /* not HAVE_SETSID */
1528#ifdef USG
1529 /* It's very important to call setpgrp here and no time
1530 afterwards. Otherwise, we lose our controlling tty which
1531 is set when we open the pty. */
1532 setpgrp ();
1533#endif /* USG */
1534#endif /* not HAVE_SETSID */
1535#if defined (HAVE_TERMIOS) && defined (LDISC1)
1536 if (pty_flag && xforkin >= 0)
1537 {
1538 struct termios t;
1539 tcgetattr (xforkin, &t);
1540 t.c_lflag = LDISC1;
1541 if (tcsetattr (xforkin, TCSANOW, &t) < 0)
1542 emacs_write (1, "create_process/tcsetattr LDISC1 failed\n", 39);
1543 }
1544#else
1545#if defined (NTTYDISC) && defined (TIOCSETD)
1546 if (pty_flag && xforkin >= 0)
1547 {
1548 /* Use new line discipline. */
1549 int ldisc = NTTYDISC;
1550 ioctl (xforkin, TIOCSETD, &ldisc);
1551 }
1552#endif
1553#endif
1554#ifdef TIOCNOTTY
1555 /* In 4.3BSD, the TIOCSPGRP bug has been fixed, and now you
1556 can do TIOCSPGRP only to the process's controlling tty. */
1557 if (pty_flag)
1558 {
1559 /* I wonder: would just ioctl (0, TIOCNOTTY, 0) work here?
1560 I can't test it since I don't have 4.3. */
1561 int j = emacs_open ("/dev/tty", O_RDWR, 0);
1562 ioctl (j, TIOCNOTTY, 0);
1563 emacs_close (j);
1564#ifndef USG
1565 /* In order to get a controlling terminal on some versions
1566 of BSD, it is necessary to put the process in pgrp 0
1567 before it opens the terminal. */
1568#ifdef HAVE_SETPGID
1569 setpgid (0, 0);
1570#else
1571 setpgrp (0, 0);
1572#endif
1573#endif
1574 }
1575#endif /* TIOCNOTTY */
1576
1577#if !defined (RTU) && !defined (UNIPLUS) && !defined (DONT_REOPEN_PTY)
1578/*** There is a suggestion that this ought to be a
1579 conditional on TIOCSPGRP,
1580 or !(defined (HAVE_SETSID) && defined (TIOCSCTTY)).
1581 Trying the latter gave the wrong results on Debian GNU/Linux 1.1;
1582 that system does seem to need this code, even though
1583 both HAVE_SETSID and TIOCSCTTY are defined. */
1584 /* Now close the pty (if we had it open) and reopen it.
1585 This makes the pty the controlling terminal of the subprocess. */
1586 if (pty_flag)
1587 {
1588#ifdef SET_CHILD_PTY_PGRP
1589 int pgrp = getpid ();
1590#endif
1591
1592 /* I wonder if emacs_close (emacs_open (pty_name, ...))
1593 would work? */
1594 if (xforkin >= 0)
1595 emacs_close (xforkin);
1596 xforkout = xforkin = emacs_open (pty_name, O_RDWR, 0);
1597
1598 if (xforkin < 0)
1599 {
1600 emacs_write (1, "Couldn't open the pty terminal ", 31);
1601 emacs_write (1, pty_name, strlen (pty_name));
1602 emacs_write (1, "\n", 1);
1603 _exit (1);
1604 }
1605
1606#ifdef SET_CHILD_PTY_PGRP
1607 ioctl (xforkin, TIOCSPGRP, &pgrp);
1608 ioctl (xforkout, TIOCSPGRP, &pgrp);
1609#endif
1610 }
1611#endif /* not UNIPLUS and not RTU and not DONT_REOPEN_PTY */
1612
1613#ifdef SETUP_SLAVE_PTY
1614 if (pty_flag)
1615 {
1616 SETUP_SLAVE_PTY;
1617 }
1618#endif /* SETUP_SLAVE_PTY */
1619#ifdef AIX
1620 /* On AIX, we've disabled SIGHUP above once we start a child on a pty.
1621 Now reenable it in the child, so it will die when we want it to. */
1622 if (pty_flag)
1623 signal (SIGHUP, SIG_DFL);
1624#endif
1625#endif /* HAVE_PTYS */
1626
1627 signal (SIGINT, SIG_DFL);
1628 signal (SIGQUIT, SIG_DFL);
1629
1630 /* Stop blocking signals in the child. */
1631#ifdef POSIX_SIGNALS
1632 sigprocmask (SIG_SETMASK, &procmask, 0);
1633#else /* !POSIX_SIGNALS */
1634#ifdef SIGCHLD
1635#ifdef BSD4_1
1636 sigrelse (SIGCHLD);
1637#else /* not BSD4_1 */
1638#if defined (BSD_SYSTEM) || defined (UNIPLUS) || defined (HPUX)
1639 sigsetmask (SIGEMPTYMASK);
1640#else /* ordinary USG */
1641#if 0
1642 signal (SIGCHLD, sigchld);
1643#endif
1644#endif /* ordinary USG */
1645#endif /* not BSD4_1 */
1646#endif /* SIGCHLD */
1647#endif /* !POSIX_SIGNALS */
1648
1649 if (pty_flag)
1650 child_setup_tty (xforkout);
1651#ifdef WINDOWSNT
1652 pid = child_setup (xforkin, xforkout, xforkout,
1653 new_argv, 1, current_dir);
1654#else /* not WINDOWSNT */
1655 child_setup (xforkin, xforkout, xforkout,
1656 new_argv, 1, current_dir);
1657#endif /* not WINDOWSNT */
1658 }
1659 environ = save_environ;
1660 }
1661
1662 UNBLOCK_INPUT;
1663
1664 /* This runs in the Emacs process. */
1665 if (pid < 0)
1666 {
1667 if (forkin >= 0)
1668 emacs_close (forkin);
1669 if (forkin != forkout && forkout >= 0)
1670 emacs_close (forkout);
1671 }
1672 else
1673 {
1674 /* vfork succeeded. */
1675 XSETFASTINT (XPROCESS (process)->pid, pid);
1676
1677#ifdef WINDOWSNT
1678 register_child (pid, inchannel);
1679#endif /* WINDOWSNT */
1680
1681 /* If the subfork execv fails, and it exits,
1682 this close hangs. I don't know why.
1683 So have an interrupt jar it loose. */
1684 {
1685 struct atimer *timer;
1686 EMACS_TIME offset;
1687
1688 stop_polling ();
1689 EMACS_SET_SECS_USECS (offset, 1, 0);
1690 timer = start_atimer (ATIMER_RELATIVE, offset, create_process_1, 0);
1691
1692 XPROCESS (process)->subtty = Qnil;
1693 if (forkin >= 0)
1694 emacs_close (forkin);
1695
1696 cancel_atimer (timer);
1697 start_polling ();
1698 }
1699
1700 if (forkin != forkout && forkout >= 0)
1701 emacs_close (forkout);
1702
1703#ifdef HAVE_PTYS
1704 if (pty_flag)
1705 XPROCESS (process)->tty_name = build_string (pty_name);
1706 else
1707#endif
1708 XPROCESS (process)->tty_name = Qnil;
1709 }
1710
1711 /* Restore the signal state whether vfork succeeded or not.
1712 (We will signal an error, below, if it failed.) */
1713#ifdef POSIX_SIGNALS
1714#ifdef HAVE_VFORK
1715 /* Restore the parent's signal handlers. */
1716 sigaction (SIGINT, &sigint_action, 0);
1717 sigaction (SIGQUIT, &sigquit_action, 0);
1718#ifdef AIX
1719 sigaction (SIGHUP, &sighup_action, 0);
1720#endif
1721#endif /* HAVE_VFORK */
1722 /* Stop blocking signals in the parent. */
1723 sigprocmask (SIG_SETMASK, &procmask, 0);
1724#else /* !POSIX_SIGNALS */
1725#ifdef SIGCHLD
1726#ifdef BSD4_1
1727 sigrelse (SIGCHLD);
1728#else /* not BSD4_1 */
1729#if defined (BSD_SYSTEM) || defined (UNIPLUS) || defined (HPUX)
1730 sigsetmask (SIGEMPTYMASK);
1731#else /* ordinary USG */
1732#if 0
1733 signal (SIGCHLD, sigchld);
1734 /* Now really handle any of these signals
1735 that came in during this function. */
1736 if (sigchld_deferred)
1737 kill (getpid (), SIGCHLD);
1738#endif
1739#endif /* ordinary USG */
1740#endif /* not BSD4_1 */
1741#endif /* SIGCHLD */
1742#endif /* !POSIX_SIGNALS */
1743
1744 /* Now generate the error if vfork failed. */
1745 if (pid < 0)
1746 report_file_error ("Doing vfork", Qnil);
1747}
1748#endif /* not VMS */
1749
1750#ifdef HAVE_SOCKETS
1751
1752/* open a TCP network connection to a given HOST/SERVICE. Treated
1753 exactly like a normal process when reading and writing. Only
1754 differences are in status display and process deletion. A network
1755 connection has no PID; you cannot signal it. All you can do is
1756 deactivate and close it via delete-process */
1757
1758DEFUN ("open-network-stream", Fopen_network_stream, Sopen_network_stream,
1759 4, 4, 0,
1760 "Open a TCP connection for a service to a host.\n\
1761Returns a subprocess-object to represent the connection.\n\
1762Input and output work as for subprocesses; `delete-process' closes it.\n\
1763Args are NAME BUFFER HOST SERVICE.\n\
1764NAME is name for process. It is modified if necessary to make it unique.\n\
1765BUFFER is the buffer (or buffer-name) to associate with the process.\n\
1766 Process output goes at end of that buffer, unless you specify\n\
1767 an output stream or filter function to handle the output.\n\
1768 BUFFER may be also nil, meaning that this process is not associated\n\
1769 with any buffer\n\
1770Third arg is name of the host to connect to, or its IP address.\n\
1771Fourth arg SERVICE is name of the service desired, or an integer\n\
1772 specifying a port number to connect to.")
1773 (name, buffer, host, service)
1774 Lisp_Object name, buffer, host, service;
1775{
1776 Lisp_Object proc;
1777#ifndef HAVE_GETADDRINFO
1778 struct sockaddr_in address;
1779 struct servent *svc_info;
1780 struct hostent *host_info_ptr, host_info;
1781 char *(addr_list[2]);
1782 IN_ADDR numeric_addr;
1783 int port;
1784#else /* HAVE_GETADDRINFO */
1785 struct addrinfo hints, *res, *lres;
1786 int ret = 0;
1787 int xerrno = 0;
1788 char *portstring, portbuf[128];
1789#endif /* HAVE_GETADDRINFO */
1790 int s = -1, outch, inch;
1791 struct gcpro gcpro1, gcpro2, gcpro3, gcpro4;
1792 int retry = 0;
1793 int count = specpdl_ptr - specpdl;
1794 int count1;
1795
1796#ifdef WINDOWSNT
1797 /* Ensure socket support is loaded if available. */
1798 init_winsock (TRUE);
1799#endif
1800
1801 GCPRO4 (name, buffer, host, service);
1802 CHECK_STRING (name, 0);
1803 CHECK_STRING (host, 0);
1804
1805#ifdef HAVE_GETADDRINFO
1806 /*
1807 * SERVICE can either be a string or int.
1808 * Convert to a C string for later use by getaddrinfo.
1809 */
1810 if (INTEGERP (service))
1811 {
1812 sprintf (portbuf, "%d", XINT (service));
1813 portstring = portbuf;
1814 }
1815 else
1816 {
1817 CHECK_STRING (service, 0);
1818 portstring = XSTRING (service)->data;
1819 }
1820#else /* ! HAVE_GETADDRINFO */
1821 if (INTEGERP (service))
1822 port = htons ((unsigned short) XINT (service));
1823 else
1824 {
1825 CHECK_STRING (service, 0);
1826 svc_info = getservbyname (XSTRING (service)->data, "tcp");
1827 if (svc_info == 0)
1828 error ("Unknown service \"%s\"", XSTRING (service)->data);
1829 port = svc_info->s_port;
1830 }
1831#endif /* ! HAVE_GETADDRINFO */
1832
1833
1834 /* Slow down polling to every ten seconds.
1835 Some kernels have a bug which causes retrying connect to fail
1836 after a connect. Polling can interfere with gethostbyname too. */
1837#ifdef POLL_FOR_INPUT
1838 bind_polling_period (10);
1839#endif
1840
1841#ifndef TERM
1842#ifdef HAVE_GETADDRINFO
1843 {
1844 immediate_quit = 1;
1845 QUIT;
1846 memset (&hints, 0, sizeof (hints));
1847 hints.ai_flags = 0;
1848 hints.ai_family = AF_UNSPEC;
1849 hints.ai_socktype = SOCK_STREAM;
1850 hints.ai_protocol = 0;
1851 ret = getaddrinfo (XSTRING (host)->data, portstring, &hints, &res);
1852 if (ret)
1853 {
1854 error ("%s/%s %s", XSTRING (host)->data, portstring,
1855 strerror (ret));
1856 }
1857 immediate_quit = 0;
1858 }
1859
1860 s = -1;
1861 count1 = specpdl_ptr - specpdl;
1862 record_unwind_protect (close_file_unwind, make_number (s));
1863
1864 for (lres = res; lres; lres = lres->ai_next)
1865 {
1866 s = socket (lres->ai_family, lres->ai_socktype, lres->ai_protocol);
1867 if (s < 0)
1868 continue;
1869
1870 /* Kernel bugs (on Ultrix at least) cause lossage (not just EINTR)
1871 when connect is interrupted. So let's not let it get interrupted.
1872 Note we do not turn off polling, because polling is only used
1873 when not interrupt_input, and thus not normally used on the systems
1874 which have this bug. On systems which use polling, there's no way
1875 to quit if polling is turned off. */
1876 if (interrupt_input)
1877 unrequest_sigio ();
1878
1879 immediate_quit = 1;
1880 QUIT;
1881
1882 ret = connect (s, lres->ai_addr, lres->ai_addrlen);
1883 if (ret == 0)
1884 break;
1885 emacs_close (s);
1886 s = -1;
1887 }
1888
1889 freeaddrinfo (res);
1890 if (s < 0)
1891 {
1892 if (interrupt_input)
1893 request_sigio ();
1894
1895 errno = xerrno;
1896 report_file_error ("connection failed",
1897 Fcons (host, Fcons (name, Qnil)));
1898 }
1899#else /* ! HAVE_GETADDRINFO */
1900
1901 while (1)
1902 {
1903#if 0
1904#ifdef TRY_AGAIN
1905 h_errno = 0;
1906#endif
1907#endif
1908 immediate_quit = 1;
1909 QUIT;
1910 host_info_ptr = gethostbyname (XSTRING (host)->data);
1911 immediate_quit = 0;
1912#if 0
1913#ifdef TRY_AGAIN
1914 if (! (host_info_ptr == 0 && h_errno == TRY_AGAIN))
1915#endif
1916#endif
1917 break;
1918 Fsleep_for (make_number (1), Qnil);
1919 }
1920 if (host_info_ptr == 0)
1921 /* Attempt to interpret host as numeric inet address */
1922 {
1923 numeric_addr = inet_addr ((char *) XSTRING (host)->data);
1924 if (NUMERIC_ADDR_ERROR)
1925 error ("Unknown host \"%s\"", XSTRING (host)->data);
1926
1927 host_info_ptr = &host_info;
1928 host_info.h_name = 0;
1929 host_info.h_aliases = 0;
1930 host_info.h_addrtype = AF_INET;
1931#ifdef h_addr
1932 /* Older machines have only one address slot called h_addr.
1933 Newer machines have h_addr_list, but #define h_addr to
1934 be its first element. */
1935 host_info.h_addr_list = &(addr_list[0]);
1936#endif
1937 host_info.h_addr = (char*)(&numeric_addr);
1938 addr_list[1] = 0;
1939 /* numeric_addr isn't null-terminated; it has fixed length. */
1940 host_info.h_length = sizeof (numeric_addr);
1941 }
1942
1943 bzero (&address, sizeof address);
1944 bcopy (host_info_ptr->h_addr, (char *) &address.sin_addr,
1945 host_info_ptr->h_length);
1946 address.sin_family = host_info_ptr->h_addrtype;
1947 address.sin_port = port;
1948
1949 s = socket (host_info_ptr->h_addrtype, SOCK_STREAM, 0);
1950 if (s < 0)
1951 report_file_error ("error creating socket", Fcons (name, Qnil));
1952
1953 count1 = specpdl_ptr - specpdl;
1954 record_unwind_protect (close_file_unwind, make_number (s));
1955
1956 /* Kernel bugs (on Ultrix at least) cause lossage (not just EINTR)
1957 when connect is interrupted. So let's not let it get interrupted.
1958 Note we do not turn off polling, because polling is only used
1959 when not interrupt_input, and thus not normally used on the systems
1960 which have this bug. On systems which use polling, there's no way
1961 to quit if polling is turned off. */
1962 if (interrupt_input)
1963 unrequest_sigio ();
1964
1965 loop:
1966
1967 immediate_quit = 1;
1968 QUIT;
1969
1970 if (connect (s, (struct sockaddr *) &address, sizeof address) == -1
1971 && errno != EISCONN)
1972 {
1973 int xerrno = errno;
1974
1975 immediate_quit = 0;
1976
1977 if (errno == EINTR)
1978 goto loop;
1979 if (errno == EADDRINUSE && retry < 20)
1980 {
1981 /* A delay here is needed on some FreeBSD systems,
1982 and it is harmless, since this retrying takes time anyway
1983 and should be infrequent. */
1984 Fsleep_for (make_number (1), Qnil);
1985 retry++;
1986 goto loop;
1987 }
1988
1989 /* Discard the unwind protect. */
1990 specpdl_ptr = specpdl + count1;
1991
1992 emacs_close (s);
1993
1994 if (interrupt_input)
1995 request_sigio ();
1996
1997 errno = xerrno;
1998 report_file_error ("connection failed",
1999 Fcons (host, Fcons (name, Qnil)));
2000 }
2001#endif /* ! HAVE_GETADDRINFO */
2002
2003 immediate_quit = 0;
2004
2005 /* Discard the unwind protect. */
2006 specpdl_ptr = specpdl + count1;
2007
2008#ifdef POLL_FOR_INPUT
2009 unbind_to (count, Qnil);
2010#endif
2011
2012 if (interrupt_input)
2013 request_sigio ();
2014
2015#else /* TERM */
2016 s = connect_server (0);
2017 if (s < 0)
2018 report_file_error ("error creating socket", Fcons (name, Qnil));
2019 send_command (s, C_PORT, 0, "%s:%d", XSTRING (host)->data, ntohs (port));
2020 send_command (s, C_DUMB, 1, 0);
2021#endif /* TERM */
2022
2023 inch = s;
2024 outch = s;
2025
2026 if (!NILP (buffer))
2027 buffer = Fget_buffer_create (buffer);
2028 proc = make_process (name);
2029
2030 chan_process[inch] = proc;
2031
2032#ifdef O_NONBLOCK
2033 fcntl (inch, F_SETFL, O_NONBLOCK);
2034#else
2035#ifdef O_NDELAY
2036 fcntl (inch, F_SETFL, O_NDELAY);
2037#endif
2038#endif
2039
2040 XPROCESS (proc)->childp = Fcons (host, Fcons (service, Qnil));
2041 XPROCESS (proc)->command_channel_p = Qnil;
2042 XPROCESS (proc)->buffer = buffer;
2043 XPROCESS (proc)->sentinel = Qnil;
2044 XPROCESS (proc)->filter = Qnil;
2045 XPROCESS (proc)->command = Qnil;
2046 XPROCESS (proc)->pid = Qnil;
2047 XSETINT (XPROCESS (proc)->infd, inch);
2048 XSETINT (XPROCESS (proc)->outfd, outch);
2049 XPROCESS (proc)->status = Qrun;
2050 FD_SET (inch, &input_wait_mask);
2051 FD_SET (inch, &non_keyboard_wait_mask);
2052 if (inch > max_process_desc)
2053 max_process_desc = inch;
2054
2055 {
2056 /* Setup coding systems for communicating with the network stream. */
2057 struct gcpro gcpro1;
2058 /* Qt denotes we have not yet called Ffind_operation_coding_system. */
2059 Lisp_Object coding_systems = Qt;
2060 Lisp_Object args[5], val;
2061
2062 if (!NILP (Vcoding_system_for_read))
2063 val = Vcoding_system_for_read;
2064 else if ((!NILP (buffer) && NILP (XBUFFER (buffer)->enable_multibyte_characters))
2065 || (NILP (buffer) && NILP (buffer_defaults.enable_multibyte_characters)))
2066 /* We dare not decode end-of-line format by setting VAL to
2067 Qraw_text, because the existing Emacs Lisp libraries
2068 assume that they receive bare code including a sequene of
2069 CR LF. */
2070 val = Qnil;
2071 else
2072 {
2073 args[0] = Qopen_network_stream, args[1] = name,
2074 args[2] = buffer, args[3] = host, args[4] = service;
2075 GCPRO1 (proc);
2076 coding_systems = Ffind_operation_coding_system (5, args);
2077 UNGCPRO;
2078 if (CONSP (coding_systems))
2079 val = XCAR (coding_systems);
2080 else if (CONSP (Vdefault_process_coding_system))
2081 val = XCAR (Vdefault_process_coding_system);
2082 else
2083 val = Qnil;
2084 }
2085 XPROCESS (proc)->decode_coding_system = val;
2086
2087 if (!NILP (Vcoding_system_for_write))
2088 val = Vcoding_system_for_write;
2089 else if (NILP (current_buffer->enable_multibyte_characters))
2090 val = Qnil;
2091 else
2092 {
2093 if (EQ (coding_systems, Qt))
2094 {
2095 args[0] = Qopen_network_stream, args[1] = name,
2096 args[2] = buffer, args[3] = host, args[4] = service;
2097 GCPRO1 (proc);
2098 coding_systems = Ffind_operation_coding_system (5, args);
2099 UNGCPRO;
2100 }
2101 if (CONSP (coding_systems))
2102 val = XCDR (coding_systems);
2103 else if (CONSP (Vdefault_process_coding_system))
2104 val = XCDR (Vdefault_process_coding_system);
2105 else
2106 val = Qnil;
2107 }
2108 XPROCESS (proc)->encode_coding_system = val;
2109 }
2110
2111 if (!proc_decode_coding_system[inch])
2112 proc_decode_coding_system[inch]
2113 = (struct coding_system *) xmalloc (sizeof (struct coding_system));
2114 setup_coding_system (XPROCESS (proc)->decode_coding_system,
2115 proc_decode_coding_system[inch]);
2116 if (!proc_encode_coding_system[outch])
2117 proc_encode_coding_system[outch]
2118 = (struct coding_system *) xmalloc (sizeof (struct coding_system));
2119 setup_coding_system (XPROCESS (proc)->encode_coding_system,
2120 proc_encode_coding_system[outch]);
2121
2122 XPROCESS (proc)->decoding_buf = make_uninit_string (0);
2123 XPROCESS (proc)->decoding_carryover = make_number (0);
2124 XPROCESS (proc)->encoding_buf = make_uninit_string (0);
2125 XPROCESS (proc)->encoding_carryover = make_number (0);
2126
2127 XPROCESS (proc)->inherit_coding_system_flag
2128 = (NILP (buffer) || !inherit_process_coding_system
2129 ? Qnil : Qt);
2130
2131 UNGCPRO;
2132 return proc;
2133}
2134#endif /* HAVE_SOCKETS */
2135
2136void
2137deactivate_process (proc)
2138 Lisp_Object proc;
2139{
2140 register int inchannel, outchannel;
2141 register struct Lisp_Process *p = XPROCESS (proc);
2142
2143 inchannel = XINT (p->infd);
2144 outchannel = XINT (p->outfd);
2145
2146 if (inchannel >= 0)
2147 {
2148 /* Beware SIGCHLD hereabouts. */
2149 flush_pending_output (inchannel);
2150#ifdef VMS
2151 {
2152 VMS_PROC_STUFF *get_vms_process_pointer (), *vs;
2153 sys$dassgn (outchannel);
2154 vs = get_vms_process_pointer (p->pid);
2155 if (vs)
2156 give_back_vms_process_stuff (vs);
2157 }
2158#else
2159 emacs_close (inchannel);
2160 if (outchannel >= 0 && outchannel != inchannel)
2161 emacs_close (outchannel);
2162#endif
2163
2164 XSETINT (p->infd, -1);
2165 XSETINT (p->outfd, -1);
2166 chan_process[inchannel] = Qnil;
2167 FD_CLR (inchannel, &input_wait_mask);
2168 FD_CLR (inchannel, &non_keyboard_wait_mask);
2169 if (inchannel == max_process_desc)
2170 {
2171 int i;
2172 /* We just closed the highest-numbered process input descriptor,
2173 so recompute the highest-numbered one now. */
2174 max_process_desc = 0;
2175 for (i = 0; i < MAXDESC; i++)
2176 if (!NILP (chan_process[i]))
2177 max_process_desc = i;
2178 }
2179 }
2180}
2181
2182/* Close all descriptors currently in use for communication
2183 with subprocess. This is used in a newly-forked subprocess
2184 to get rid of irrelevant descriptors. */
2185
2186void
2187close_process_descs ()
2188{
2189#ifndef WINDOWSNT
2190 int i;
2191 for (i = 0; i < MAXDESC; i++)
2192 {
2193 Lisp_Object process;
2194 process = chan_process[i];
2195 if (!NILP (process))
2196 {
2197 int in = XINT (XPROCESS (process)->infd);
2198 int out = XINT (XPROCESS (process)->outfd);
2199 if (in >= 0)
2200 emacs_close (in);
2201 if (out >= 0 && in != out)
2202 emacs_close (out);
2203 }
2204 }
2205#endif
2206}
2207
2208DEFUN ("accept-process-output", Faccept_process_output, Saccept_process_output,
2209 0, 3, 0,
2210 "Allow any pending output from subprocesses to be read by Emacs.\n\
2211It is read into the process' buffers or given to their filter functions.\n\
2212Non-nil arg PROCESS means do not return until some output has been received\n\
2213from PROCESS.\n\
2214Non-nil second arg TIMEOUT and third arg TIMEOUT-MSECS are number of\n\
2215seconds and microseconds to wait; return after that much time whether\n\
2216or not there is input.\n\
2217Return non-nil iff we received any output before the timeout expired.")
2218 (process, timeout, timeout_msecs)
2219 register Lisp_Object process, timeout, timeout_msecs;
2220{
2221 int seconds;
2222 int useconds;
2223
2224 if (! NILP (process))
2225 CHECK_PROCESS (process, 0);
2226
2227 if (! NILP (timeout_msecs))
2228 {
2229 CHECK_NUMBER (timeout_msecs, 2);
2230 useconds = XINT (timeout_msecs);
2231 if (!INTEGERP (timeout))
2232 XSETINT (timeout, 0);
2233
2234 {
2235 int carry = useconds / 1000000;
2236
2237 XSETINT (timeout, XINT (timeout) + carry);
2238 useconds -= carry * 1000000;
2239
2240 /* I think this clause is necessary because C doesn't
2241 guarantee a particular rounding direction for negative
2242 integers. */
2243 if (useconds < 0)
2244 {
2245 XSETINT (timeout, XINT (timeout) - 1);
2246 useconds += 1000000;
2247 }
2248 }
2249 }
2250 else
2251 useconds = 0;
2252
2253 if (! NILP (timeout))
2254 {
2255 CHECK_NUMBER (timeout, 1);
2256 seconds = XINT (timeout);
2257 if (seconds < 0 || (seconds == 0 && useconds == 0))
2258 seconds = -1;
2259 }
2260 else
2261 {
2262 if (NILP (process))
2263 seconds = -1;
2264 else
2265 seconds = 0;
2266 }
2267
2268 if (NILP (process))
2269 XSETFASTINT (process, 0);
2270
2271 return
2272 (wait_reading_process_input (seconds, useconds, process, 0)
2273 ? Qt : Qnil);
2274}
2275
2276/* This variable is different from waiting_for_input in keyboard.c.
2277 It is used to communicate to a lisp process-filter/sentinel (via the
2278 function Fwaiting_for_user_input_p below) whether emacs was waiting
2279 for user-input when that process-filter was called.
2280 waiting_for_input cannot be used as that is by definition 0 when
2281 lisp code is being evalled.
2282 This is also used in record_asynch_buffer_change.
2283 For that purpose, this must be 0
2284 when not inside wait_reading_process_input. */
2285static int waiting_for_user_input_p;
2286
2287/* This is here so breakpoints can be put on it. */
2288static void
2289wait_reading_process_input_1 ()
2290{
2291}
2292
2293/* Read and dispose of subprocess output while waiting for timeout to
2294 elapse and/or keyboard input to be available.
2295
2296 TIME_LIMIT is:
2297 timeout in seconds, or
2298 zero for no limit, or
2299 -1 means gobble data immediately available but don't wait for any.
2300
2301 MICROSECS is:
2302 an additional duration to wait, measured in microseconds.
2303 If this is nonzero and time_limit is 0, then the timeout
2304 consists of MICROSECS only.
2305
2306 READ_KBD is a lisp value:
2307 0 to ignore keyboard input, or
2308 1 to return when input is available, or
2309 -1 meaning caller will actually read the input, so don't throw to
2310 the quit handler, or
2311 a cons cell, meaning wait until its car is non-nil
2312 (and gobble terminal input into the buffer if any arrives), or
2313 a process object, meaning wait until something arrives from that
2314 process. The return value is true iff we read some input from
2315 that process.
2316
2317 DO_DISPLAY != 0 means redisplay should be done to show subprocess
2318 output that arrives.
2319
2320 If READ_KBD is a pointer to a struct Lisp_Process, then the
2321 function returns true iff we received input from that process
2322 before the timeout elapsed.
2323 Otherwise, return true iff we received input from any process. */
2324
2325int
2326wait_reading_process_input (time_limit, microsecs, read_kbd, do_display)
2327 int time_limit, microsecs;
2328 Lisp_Object read_kbd;
2329 int do_display;
2330{
2331 register int channel, nfds;
2332 static SELECT_TYPE Available;
2333 int xerrno;
2334 Lisp_Object proc;
2335 EMACS_TIME timeout, end_time;
2336 SELECT_TYPE Atemp;
2337 int wait_channel = -1;
2338 struct Lisp_Process *wait_proc = 0;
2339 int got_some_input = 0;
2340 Lisp_Object *wait_for_cell = 0;
2341
2342 FD_ZERO (&Available);
2343
2344 /* If read_kbd is a process to watch, set wait_proc and wait_channel
2345 accordingly. */
2346 if (PROCESSP (read_kbd))
2347 {
2348 wait_proc = XPROCESS (read_kbd);
2349 wait_channel = XINT (wait_proc->infd);
2350 XSETFASTINT (read_kbd, 0);
2351 }
2352
2353 /* If waiting for non-nil in a cell, record where. */
2354 if (CONSP (read_kbd))
2355 {
2356 wait_for_cell = &XCAR (read_kbd);
2357 XSETFASTINT (read_kbd, 0);
2358 }
2359
2360 waiting_for_user_input_p = XINT (read_kbd);
2361
2362 /* Since we may need to wait several times,
2363 compute the absolute time to return at. */
2364 if (time_limit || microsecs)
2365 {
2366 EMACS_GET_TIME (end_time);
2367 EMACS_SET_SECS_USECS (timeout, time_limit, microsecs);
2368 EMACS_ADD_TIME (end_time, end_time, timeout);
2369 }
2370#ifdef hpux
2371 /* AlainF 5-Jul-1996
2372 HP-UX 10.10 seem to have problems with signals coming in
2373 Causes "poll: interrupted system call" messages when Emacs is run
2374 in an X window
2375 Turn off periodic alarms (in case they are in use) */
2376 turn_on_atimers (0);
2377#endif
2378
2379 while (1)
2380 {
2381 int timeout_reduced_for_timers = 0;
2382
2383#ifdef HAVE_X_WINDOWS
2384 if (display_busy_cursor_p)
2385 Fx_hide_busy_cursor (Qnil);
2386#endif
2387
2388 /* If calling from keyboard input, do not quit
2389 since we want to return C-g as an input character.
2390 Otherwise, do pending quit if requested. */
2391 if (XINT (read_kbd) >= 0)
2392 QUIT;
2393
2394 /* Exit now if the cell we're waiting for became non-nil. */
2395 if (wait_for_cell && ! NILP (*wait_for_cell))
2396 break;
2397
2398 /* Compute time from now till when time limit is up */
2399 /* Exit if already run out */
2400 if (time_limit == -1)
2401 {
2402 /* -1 specified for timeout means
2403 gobble output available now
2404 but don't wait at all. */
2405
2406 EMACS_SET_SECS_USECS (timeout, 0, 0);
2407 }
2408 else if (time_limit || microsecs)
2409 {
2410 EMACS_GET_TIME (timeout);
2411 EMACS_SUB_TIME (timeout, end_time, timeout);
2412 if (EMACS_TIME_NEG_P (timeout))
2413 break;
2414 }
2415 else
2416 {
2417 EMACS_SET_SECS_USECS (timeout, 100000, 0);
2418 }
2419
2420 /* Normally we run timers here.
2421 But not if wait_for_cell; in those cases,
2422 the wait is supposed to be short,
2423 and those callers cannot handle running arbitrary Lisp code here. */
2424 if (! wait_for_cell)
2425 {
2426 EMACS_TIME timer_delay;
2427 int old_timers_run;
2428
2429 retry:
2430 old_timers_run = timers_run;
2431 timer_delay = timer_check (1);
2432 if (timers_run != old_timers_run && do_display)
2433 {
2434 redisplay_preserve_echo_area ();
2435 /* We must retry, since a timer may have requeued itself
2436 and that could alter the time_delay. */
2437 goto retry;
2438 }
2439
2440 /* If there is unread keyboard input, also return. */
2441 if (XINT (read_kbd) != 0
2442 && requeued_events_pending_p ())
2443 break;
2444
2445 if (! EMACS_TIME_NEG_P (timer_delay) && time_limit != -1)
2446 {
2447 EMACS_TIME difference;
2448 EMACS_SUB_TIME (difference, timer_delay, timeout);
2449 if (EMACS_TIME_NEG_P (difference))
2450 {
2451 timeout = timer_delay;
2452 timeout_reduced_for_timers = 1;
2453 }
2454 }
2455 /* If time_limit is -1, we are not going to wait at all. */
2456 else if (time_limit != -1)
2457 {
2458 /* This is so a breakpoint can be put here. */
2459 wait_reading_process_input_1 ();
2460 }
2461 }
2462
2463 /* Cause C-g and alarm signals to take immediate action,
2464 and cause input available signals to zero out timeout.
2465
2466 It is important that we do this before checking for process
2467 activity. If we get a SIGCHLD after the explicit checks for
2468 process activity, timeout is the only way we will know. */
2469 if (XINT (read_kbd) < 0)
2470 set_waiting_for_input (&timeout);
2471
2472 /* If status of something has changed, and no input is
2473 available, notify the user of the change right away. After
2474 this explicit check, we'll let the SIGCHLD handler zap
2475 timeout to get our attention. */
2476 if (update_tick != process_tick && do_display)
2477 {
2478 Atemp = input_wait_mask;
2479 EMACS_SET_SECS_USECS (timeout, 0, 0);
2480 if ((select (max (max_process_desc, max_keyboard_desc) + 1,
2481 &Atemp, (SELECT_TYPE *)0, (SELECT_TYPE *)0,
2482 &timeout)
2483 <= 0))
2484 {
2485 /* It's okay for us to do this and then continue with
2486 the loop, since timeout has already been zeroed out. */
2487 clear_waiting_for_input ();
2488 status_notify ();
2489 }
2490 }
2491
2492 /* Don't wait for output from a non-running process. */
2493 if (wait_proc != 0 && !NILP (wait_proc->raw_status_low))
2494 update_status (wait_proc);
2495 if (wait_proc != 0
2496 && ! EQ (wait_proc->status, Qrun))
2497 {
2498 int nread, total_nread = 0;
2499
2500 clear_waiting_for_input ();
2501 XSETPROCESS (proc, wait_proc);
2502
2503 /* Read data from the process, until we exhaust it. */
2504 while (XINT (wait_proc->infd) >= 0)
2505 {
2506 nread = read_process_output (proc, XINT (wait_proc->infd));
2507
2508 if (nread == 0)
2509 break;
2510
2511 if (0 < nread)
2512 total_nread += nread;
2513#ifdef EIO
2514 else if (nread == -1 && EIO == errno)
2515 break;
2516#endif
2517#ifdef EAGAIN
2518 else if (nread == -1 && EAGAIN == errno)
2519 break;
2520#endif
2521#ifdef EWOULDBLOCK
2522 else if (nread == -1 && EWOULDBLOCK == errno)
2523 break;
2524#endif
2525 }
2526 if (total_nread > 0 && do_display)
2527 redisplay_preserve_echo_area ();
2528
2529 break;
2530 }
2531
2532 /* Wait till there is something to do */
2533
2534 if (wait_for_cell)
2535 Available = non_process_wait_mask;
2536 else if (! XINT (read_kbd))
2537 Available = non_keyboard_wait_mask;
2538 else
2539 Available = input_wait_mask;
2540
2541 /* If frame size has changed or the window is newly mapped,
2542 redisplay now, before we start to wait. There is a race
2543 condition here; if a SIGIO arrives between now and the select
2544 and indicates that a frame is trashed, the select may block
2545 displaying a trashed screen. */
2546 if (frame_garbaged && do_display)
2547 {
2548 clear_waiting_for_input ();
2549 redisplay_preserve_echo_area ();
2550 if (XINT (read_kbd) < 0)
2551 set_waiting_for_input (&timeout);
2552 }
2553
2554 if (XINT (read_kbd) && detect_input_pending ())
2555 {
2556 nfds = 0;
2557 FD_ZERO (&Available);
2558 }
2559 else
2560 nfds = select (max (max_process_desc, max_keyboard_desc) + 1,
2561 &Available, (SELECT_TYPE *)0, (SELECT_TYPE *)0,
2562 &timeout);
2563
2564 xerrno = errno;
2565
2566 /* Make C-g and alarm signals set flags again */
2567 clear_waiting_for_input ();
2568
2569 /* If we woke up due to SIGWINCH, actually change size now. */
2570 do_pending_window_change (0);
2571
2572 if (time_limit && nfds == 0 && ! timeout_reduced_for_timers)
2573 /* We wanted the full specified time, so return now. */
2574 break;
2575 if (nfds < 0)
2576 {
2577 if (xerrno == EINTR)
2578 FD_ZERO (&Available);
2579#ifdef ultrix
2580 /* Ultrix select seems to return ENOMEM when it is
2581 interrupted. Treat it just like EINTR. Bleah. Note
2582 that we want to test for the "ultrix" CPP symbol, not
2583 "__ultrix__"; the latter is only defined under GCC, but
2584 not by DEC's bundled CC. -JimB */
2585 else if (xerrno == ENOMEM)
2586 FD_ZERO (&Available);
2587#endif
2588#ifdef ALLIANT
2589 /* This happens for no known reason on ALLIANT.
2590 I am guessing that this is the right response. -- RMS. */
2591 else if (xerrno == EFAULT)
2592 FD_ZERO (&Available);
2593#endif
2594 else if (xerrno == EBADF)
2595 {
2596#ifdef AIX
2597 /* AIX doesn't handle PTY closure the same way BSD does. On AIX,
2598 the child's closure of the pts gives the parent a SIGHUP, and
2599 the ptc file descriptor is automatically closed,
2600 yielding EBADF here or at select() call above.
2601 So, SIGHUP is ignored (see def of PTY_TTY_NAME_SPRINTF
2602 in m/ibmrt-aix.h), and here we just ignore the select error.
2603 Cleanup occurs c/o status_notify after SIGCLD. */
2604 FD_ZERO (&Available); /* Cannot depend on values returned */
2605#else
2606 abort ();
2607#endif
2608 }
2609 else
2610 error ("select error: %s", emacs_strerror (xerrno));
2611 }
2612#if defined(sun) && !defined(USG5_4)
2613 else if (nfds > 0 && keyboard_bit_set (&Available)
2614 && interrupt_input)
2615 /* System sometimes fails to deliver SIGIO.
2616
2617 David J. Mackenzie says that Emacs doesn't compile under
2618 Solaris if this code is enabled, thus the USG5_4 in the CPP
2619 conditional. "I haven't noticed any ill effects so far.
2620 If you find a Solaris expert somewhere, they might know
2621 better." */
2622 kill (getpid (), SIGIO);
2623#endif
2624
2625#if 0 /* When polling is used, interrupt_input is 0,
2626 so get_input_pending should read the input.
2627 So this should not be needed. */
2628 /* If we are using polling for input,
2629 and we see input available, make it get read now.
2630 Otherwise it might not actually get read for a second.
2631 And on hpux, since we turn off polling in wait_reading_process_input,
2632 it might never get read at all if we don't spend much time
2633 outside of wait_reading_process_input. */
2634 if (XINT (read_kbd) && interrupt_input
2635 && keyboard_bit_set (&Available)
2636 && input_polling_used ())
2637 kill (getpid (), SIGALRM);
2638#endif
2639
2640 /* Check for keyboard input */
2641 /* If there is any, return immediately
2642 to give it higher priority than subprocesses */
2643
2644 if (XINT (read_kbd) != 0
2645 && detect_input_pending_run_timers (do_display))
2646 {
2647 swallow_events (do_display);
2648 if (detect_input_pending_run_timers (do_display))
2649 break;
2650 }
2651
2652 /* If there is unread keyboard input, also return. */
2653 if (XINT (read_kbd) != 0
2654 && requeued_events_pending_p ())
2655 break;
2656
2657 /* If we are not checking for keyboard input now,
2658 do process events (but don't run any timers).
2659 This is so that X events will be processed.
2660 Otherwise they may have to wait until polling takes place.
2661 That would causes delays in pasting selections, for example.
2662
2663 (We used to do this only if wait_for_cell.) */
2664 if (XINT (read_kbd) == 0 && detect_input_pending ())
2665 {
2666 swallow_events (do_display);
2667#if 0 /* Exiting when read_kbd doesn't request that seems wrong, though. */
2668 if (detect_input_pending ())
2669 break;
2670#endif
2671 }
2672
2673 /* Exit now if the cell we're waiting for became non-nil. */
2674 if (wait_for_cell && ! NILP (*wait_for_cell))
2675 break;
2676
2677#ifdef SIGIO
2678 /* If we think we have keyboard input waiting, but didn't get SIGIO,
2679 go read it. This can happen with X on BSD after logging out.
2680 In that case, there really is no input and no SIGIO,
2681 but select says there is input. */
2682
2683 if (XINT (read_kbd) && interrupt_input
2684 && keyboard_bit_set (&Available))
2685 kill (getpid (), SIGIO);
2686#endif
2687
2688 if (! wait_proc)
2689 got_some_input |= nfds > 0;
2690
2691 /* If checking input just got us a size-change event from X,
2692 obey it now if we should. */
2693 if (XINT (read_kbd) || wait_for_cell)
2694 do_pending_window_change (0);
2695
2696 /* Check for data from a process. */
2697 /* Really FIRST_PROC_DESC should be 0 on Unix,
2698 but this is safer in the short run. */
2699 for (channel = 0; channel <= max_process_desc; channel++)
2700 {
2701 if (FD_ISSET (channel, &Available)
2702 && FD_ISSET (channel, &non_keyboard_wait_mask))
2703 {
2704 int nread;
2705
2706 /* If waiting for this channel, arrange to return as
2707 soon as no more input to be processed. No more
2708 waiting. */
2709 if (wait_channel == channel)
2710 {
2711 wait_channel = -1;
2712 time_limit = -1;
2713 got_some_input = 1;
2714 }
2715 proc = chan_process[channel];
2716 if (NILP (proc))
2717 continue;
2718
2719 /* Read data from the process, starting with our
2720 buffered-ahead character if we have one. */
2721
2722 nread = read_process_output (proc, channel);
2723 if (nread > 0)
2724 {
2725 /* Since read_process_output can run a filter,
2726 which can call accept-process-output,
2727 don't try to read from any other processes
2728 before doing the select again. */
2729 FD_ZERO (&Available);
2730
2731 if (do_display)
2732 redisplay_preserve_echo_area ();
2733 }
2734#ifdef EWOULDBLOCK
2735 else if (nread == -1 && errno == EWOULDBLOCK)
2736 ;
2737#endif
2738 /* ISC 4.1 defines both EWOULDBLOCK and O_NONBLOCK,
2739 and Emacs uses O_NONBLOCK, so what we get is EAGAIN. */
2740#ifdef O_NONBLOCK
2741 else if (nread == -1 && errno == EAGAIN)
2742 ;
2743#else
2744#ifdef O_NDELAY
2745 else if (nread == -1 && errno == EAGAIN)
2746 ;
2747 /* Note that we cannot distinguish between no input
2748 available now and a closed pipe.
2749 With luck, a closed pipe will be accompanied by
2750 subprocess termination and SIGCHLD. */
2751 else if (nread == 0 && !NETCONN_P (proc))
2752 ;
2753#endif /* O_NDELAY */
2754#endif /* O_NONBLOCK */
2755#ifdef HAVE_PTYS
2756 /* On some OSs with ptys, when the process on one end of
2757 a pty exits, the other end gets an error reading with
2758 errno = EIO instead of getting an EOF (0 bytes read).
2759 Therefore, if we get an error reading and errno =
2760 EIO, just continue, because the child process has
2761 exited and should clean itself up soon (e.g. when we
2762 get a SIGCHLD).
2763
2764 However, it has been known to happen that the SIGCHLD
2765 got lost. So raise the signl again just in case.
2766 It can't hurt. */
2767 else if (nread == -1 && errno == EIO)
2768 kill (getpid (), SIGCHLD);
2769#endif /* HAVE_PTYS */
2770 /* If we can detect process termination, don't consider the process
2771 gone just because its pipe is closed. */
2772#ifdef SIGCHLD
2773 else if (nread == 0 && !NETCONN_P (proc))
2774 ;
2775#endif
2776 else
2777 {
2778 /* Preserve status of processes already terminated. */
2779 XSETINT (XPROCESS (proc)->tick, ++process_tick);
2780 deactivate_process (proc);
2781 if (!NILP (XPROCESS (proc)->raw_status_low))
2782 update_status (XPROCESS (proc));
2783 if (EQ (XPROCESS (proc)->status, Qrun))
2784 XPROCESS (proc)->status
2785 = Fcons (Qexit, Fcons (make_number (256), Qnil));
2786 }
2787 }
2788 } /* end for each file descriptor */
2789 } /* end while exit conditions not met */
2790
2791 waiting_for_user_input_p = 0;
2792
2793 /* If calling from keyboard input, do not quit
2794 since we want to return C-g as an input character.
2795 Otherwise, do pending quit if requested. */
2796 if (XINT (read_kbd) >= 0)
2797 {
2798 /* Prevent input_pending from remaining set if we quit. */
2799 clear_input_pending ();
2800 QUIT;
2801 }
2802#ifdef hpux
2803 /* AlainF 5-Jul-1996
2804 HP-UX 10.10 seems to have problems with signals coming in
2805 Causes "poll: interrupted system call" messages when Emacs is run
2806 in an X window
2807 Turn periodic alarms back on */
2808 start_polling ();
2809#endif
2810
2811#ifdef HAVE_X_WINDOWS
2812 if (display_busy_cursor_p)
2813 if (!inhibit_busy_cursor)
2814 Fx_show_busy_cursor ();
2815#endif
2816
2817 return got_some_input;
2818}
2819
2820/* Given a list (FUNCTION ARGS...), apply FUNCTION to the ARGS. */
2821
2822static Lisp_Object
2823read_process_output_call (fun_and_args)
2824 Lisp_Object fun_and_args;
2825{
2826 return apply1 (XCAR (fun_and_args), XCDR (fun_and_args));
2827}
2828
2829static Lisp_Object
2830read_process_output_error_handler (error)
2831 Lisp_Object error;
2832{
2833 cmd_error_internal (error, "error in process filter: ");
2834 Vinhibit_quit = Qt;
2835 update_echo_area ();
2836 Fsleep_for (make_number (2), Qnil);
2837}
2838
2839/* Read pending output from the process channel,
2840 starting with our buffered-ahead character if we have one.
2841 Yield number of decoded characters read.
2842
2843 This function reads at most 1024 characters.
2844 If you want to read all available subprocess output,
2845 you must call it repeatedly until it returns zero.
2846
2847 The characters read are decoded according to PROC's coding-system
2848 for decoding. */
2849
2850int
2851read_process_output (proc, channel)
2852 Lisp_Object proc;
2853 register int channel;
2854{
2855 register int nchars, nbytes;
2856 char *chars;
2857#ifdef VMS
2858 int chars_allocated = 0; /* If 1, `chars' should be freed later. */
2859#else
2860 char buf[1024];
2861#endif
2862 register Lisp_Object outstream;
2863 register struct buffer *old = current_buffer;
2864 register struct Lisp_Process *p = XPROCESS (proc);
2865 register int opoint;
2866 struct coding_system *coding = proc_decode_coding_system[channel];
2867 int chars_in_decoding_buf = 0; /* If 1, `chars' points
2868 XSTRING (p->decoding_buf)->data. */
2869 int carryover = XINT (p->decoding_carryover);
2870
2871#ifdef VMS
2872 VMS_PROC_STUFF *vs, *get_vms_process_pointer();
2873
2874 vs = get_vms_process_pointer (p->pid);
2875 if (vs)
2876 {
2877 if (!vs->iosb[0])
2878 return (0); /* Really weird if it does this */
2879 if (!(vs->iosb[0] & 1))
2880 return -1; /* I/O error */
2881 }
2882 else
2883 error ("Could not get VMS process pointer");
2884 chars = vs->inputBuffer;
2885 nbytes = clean_vms_buffer (chars, vs->iosb[1]);
2886 if (nbytes <= 0)
2887 {
2888 start_vms_process_read (vs); /* Crank up the next read on the process */
2889 return 1; /* Nothing worth printing, say we got 1 */
2890 }
2891 if (carryover > 0)
2892 {
2893 /* The data carried over in the previous decoding (which are at
2894 the tail of decoding buffer) should be prepended to the new
2895 data read to decode all together. */
2896 char *buf = (char *) xmalloc (nbytes + carryover);
2897
2898 bcopy (XSTRING (p->decoding_buf)->data
2899 + STRING_BYTES (XSTRING (p->decoding_buf)) - carryover,
2900 buf, carryover);
2901 bcopy (chars, buf + carryover, nbytes);
2902 chars = buf;
2903 chars_allocated = 1;
2904 }
2905#else /* not VMS */
2906
2907 if (carryover)
2908 /* See the comment above. */
2909 bcopy (XSTRING (p->decoding_buf)->data
2910 + STRING_BYTES (XSTRING (p->decoding_buf)) - carryover,
2911 buf, carryover);
2912
2913 if (proc_buffered_char[channel] < 0)
2914 nbytes = emacs_read (channel, buf + carryover, (sizeof buf) - carryover);
2915 else
2916 {
2917 buf[carryover] = proc_buffered_char[channel];
2918 proc_buffered_char[channel] = -1;
2919 nbytes = emacs_read (channel, buf + carryover + 1,
2920 (sizeof buf) - carryover - 1);
2921 if (nbytes < 0)
2922 nbytes = 1;
2923 else
2924 nbytes = nbytes + 1;
2925 }
2926 chars = buf;
2927#endif /* not VMS */
2928
2929 XSETINT (p->decoding_carryover, 0);
2930
2931 /* At this point, NBYTES holds number of characters just received
2932 (including the one in proc_buffered_char[channel]). */
2933 if (nbytes <= 0)
2934 {
2935 if (nbytes < 0 || coding->mode & CODING_MODE_LAST_BLOCK)
2936 return nbytes;
2937 coding->mode |= CODING_MODE_LAST_BLOCK;
2938 }
2939
2940 /* Now set NBYTES how many bytes we must decode. */
2941 nbytes += carryover;
2942 nchars = nbytes;
2943
2944 if (CODING_MAY_REQUIRE_DECODING (coding))
2945 {
2946 int require = decoding_buffer_size (coding, nbytes);
2947 int result;
2948
2949 if (STRING_BYTES (XSTRING (p->decoding_buf)) < require)
2950 p->decoding_buf = make_uninit_string (require);
2951 result = decode_coding (coding, chars, XSTRING (p->decoding_buf)->data,
2952 nbytes, STRING_BYTES (XSTRING (p->decoding_buf)));
2953 carryover = nbytes - coding->consumed;
2954 if (carryover > 0)
2955 {
2956 /* Copy the carryover bytes to the end of p->decoding_buf, to
2957 be processed on the next read. Since decoding_buffer_size
2958 asks for an extra amount of space beyond the maximum
2959 expected for the output, there should always be sufficient
2960 space for the carryover (which is by definition a sequence
2961 of bytes that was not long enough to be decoded, and thus
2962 has a bounded length). */
2963 if (STRING_BYTES (XSTRING (p->decoding_buf))
2964 < coding->produced + carryover)
2965 abort ();
2966 bcopy (chars + coding->consumed,
2967 XSTRING (p->decoding_buf)->data
2968 + STRING_BYTES (XSTRING (p->decoding_buf)) - carryover,
2969 carryover);
2970 XSETINT (p->decoding_carryover, carryover);
2971 }
2972
2973 /* A new coding system might be found by `decode_coding'. */
2974 if (!EQ (p->decode_coding_system, coding->symbol))
2975 {
2976 p->decode_coding_system = coding->symbol;
2977
2978 /* Don't call setup_coding_system for
2979 proc_decode_coding_system[channel] here. It is done in
2980 detect_coding called via decode_coding above. */
2981
2982 /* If a coding system for encoding is not yet decided, we set
2983 it as the same as coding-system for decoding.
2984
2985 But, before doing that we must check if
2986 proc_encode_coding_system[p->outfd] surely points to a
2987 valid memory because p->outfd will be changed once EOF is
2988 sent to the process. */
2989 if (NILP (p->encode_coding_system)
2990 && proc_encode_coding_system[XINT (p->outfd)])
2991 {
2992 p->encode_coding_system = coding->symbol;
2993 setup_coding_system (coding->symbol,
2994 proc_encode_coding_system[XINT (p->outfd)]);
2995 }
2996 }
2997
2998#ifdef VMS
2999 /* Now we don't need the contents of `chars'. */
3000 if (chars_allocated)
3001 free (chars);
3002#endif
3003 if (coding->produced == 0)
3004 return 0;
3005 chars = (char *) XSTRING (p->decoding_buf)->data;
3006 nbytes = coding->produced;
3007 nchars = (coding->fake_multibyte
3008 ? multibyte_chars_in_text (chars, nbytes)
3009 : coding->produced_char);
3010 chars_in_decoding_buf = 1;
3011 }
3012 else
3013 {
3014#ifdef VMS
3015 if (chars_allocated)
3016 {
3017 /* Although we don't have to decode the received data, we
3018 must move it to an area which we don't have to free. */
3019 if (! STRINGP (p->decoding_buf)
3020 || STRING_BYTES (XSTRING (p->decoding_buf)) < nbytes)
3021 p->decoding_buf = make_uninit_string (nbytes);
3022 bcopy (chars, XSTRING (p->decoding_buf)->data, nbytes);
3023 free (chars);
3024 chars = XSTRING (p->decoding_buf)->data;
3025 chars_in_decoding_buf = 1;
3026 }
3027#endif
3028 nchars = multibyte_chars_in_text (chars, nbytes);
3029 }
3030
3031 Vlast_coding_system_used = coding->symbol;
3032
3033 /* If the caller required, let the process associated buffer
3034 inherit the coding-system used to decode the process output. */
3035 if (! NILP (p->inherit_coding_system_flag)
3036 && !NILP (p->buffer) && !NILP (XBUFFER (p->buffer)->name))
3037 {
3038 struct buffer *prev_buf = current_buffer;
3039
3040 Fset_buffer (p->buffer);
3041 call1 (intern ("after-insert-file-set-buffer-file-coding-system"),
3042 make_number (nbytes));
3043 set_buffer_internal (prev_buf);
3044 }
3045
3046 /* Read and dispose of the process output. */
3047 outstream = p->filter;
3048 if (!NILP (outstream))
3049 {
3050 /* We inhibit quit here instead of just catching it so that
3051 hitting ^G when a filter happens to be running won't screw
3052 it up. */
3053 int count = specpdl_ptr - specpdl;
3054 Lisp_Object odeactivate;
3055 Lisp_Object obuffer, okeymap;
3056 Lisp_Object text;
3057 int outer_running_asynch_code = running_asynch_code;
3058 int waiting = waiting_for_user_input_p;
3059
3060 /* No need to gcpro these, because all we do with them later
3061 is test them for EQness, and none of them should be a string. */
3062 odeactivate = Vdeactivate_mark;
3063 XSETBUFFER (obuffer, current_buffer);
3064 okeymap = current_buffer->keymap;
3065
3066 specbind (Qinhibit_quit, Qt);
3067 specbind (Qlast_nonmenu_event, Qt);
3068
3069 /* In case we get recursively called,
3070 and we already saved the match data nonrecursively,
3071 save the same match data in safely recursive fashion. */
3072 if (outer_running_asynch_code)
3073 {
3074 Lisp_Object tem;
3075 /* Don't clobber the CURRENT match data, either! */
3076 tem = Fmatch_data (Qnil, Qnil);
3077 restore_match_data ();
3078 record_unwind_protect (Fset_match_data, Fmatch_data (Qnil, Qnil));
3079 Fset_match_data (tem);
3080 }
3081
3082 /* For speed, if a search happens within this code,
3083 save the match data in a special nonrecursive fashion. */
3084 running_asynch_code = 1;
3085
3086 /* The multibyteness of a string given to the filter is decided
3087 by which coding system we used for decoding. */
3088 if (coding->type == coding_type_no_conversion
3089 || coding->type == coding_type_raw_text)
3090 text = make_unibyte_string (chars, nbytes);
3091 else
3092 text = make_multibyte_string (chars, nchars, nbytes);
3093
3094 internal_condition_case_1 (read_process_output_call,
3095 Fcons (outstream,
3096 Fcons (proc, Fcons (text, Qnil))),
3097 !NILP (Vdebug_on_error) ? Qnil : Qerror,
3098 read_process_output_error_handler);
3099
3100 /* If we saved the match data nonrecursively, restore it now. */
3101 restore_match_data ();
3102 running_asynch_code = outer_running_asynch_code;
3103
3104 /* Handling the process output should not deactivate the mark. */
3105 Vdeactivate_mark = odeactivate;
3106
3107 /* Restore waiting_for_user_input_p as it was
3108 when we were called, in case the filter clobbered it. */
3109 waiting_for_user_input_p = waiting;
3110
3111#if 0 /* Call record_asynch_buffer_change unconditionally,
3112 because we might have changed minor modes or other things
3113 that affect key bindings. */
3114 if (! EQ (Fcurrent_buffer (), obuffer)
3115 || ! EQ (current_buffer->keymap, okeymap))
3116#endif
3117 /* But do it only if the caller is actually going to read events.
3118 Otherwise there's no need to make him wake up, and it could
3119 cause trouble (for example it would make Fsit_for return). */
3120 if (waiting_for_user_input_p == -1)
3121 record_asynch_buffer_change ();
3122
3123#ifdef VMS
3124 start_vms_process_read (vs);
3125#endif
3126 unbind_to (count, Qnil);
3127 return nchars;
3128 }
3129
3130 /* If no filter, write into buffer if it isn't dead. */
3131 if (!NILP (p->buffer) && !NILP (XBUFFER (p->buffer)->name))
3132 {
3133 Lisp_Object old_read_only;
3134 int old_begv, old_zv;
3135 int old_begv_byte, old_zv_byte;
3136 Lisp_Object odeactivate;
3137 int before, before_byte;
3138 int opoint_byte;
3139
3140 odeactivate = Vdeactivate_mark;
3141
3142 Fset_buffer (p->buffer);
3143 opoint = PT;
3144 opoint_byte = PT_BYTE;
3145 old_read_only = current_buffer->read_only;
3146 old_begv = BEGV;
3147 old_zv = ZV;
3148 old_begv_byte = BEGV_BYTE;
3149 old_zv_byte = ZV_BYTE;
3150
3151 current_buffer->read_only = Qnil;
3152
3153 /* Insert new output into buffer
3154 at the current end-of-output marker,
3155 thus preserving logical ordering of input and output. */
3156 if (XMARKER (p->mark)->buffer)
3157 SET_PT_BOTH (clip_to_bounds (BEGV, marker_position (p->mark), ZV),
3158 clip_to_bounds (BEGV_BYTE, marker_byte_position (p->mark),
3159 ZV_BYTE));
3160 else
3161 SET_PT_BOTH (ZV, ZV_BYTE);
3162 before = PT;
3163 before_byte = PT_BYTE;
3164
3165 /* If the output marker is outside of the visible region, save
3166 the restriction and widen. */
3167 if (! (BEGV <= PT && PT <= ZV))
3168 Fwiden ();
3169
3170 if (NILP (current_buffer->enable_multibyte_characters))
3171 nchars = nbytes;
3172
3173 /* Insert before markers in case we are inserting where
3174 the buffer's mark is, and the user's next command is Meta-y. */
3175 if (chars_in_decoding_buf)
3176 {
3177 /* Since multibyteness of p->docoding_buf is corrupted, we
3178 can't use insert_from_string_before_markers. */
3179 char *temp_buf;
3180
3181 temp_buf = (char *) alloca (nbytes);
3182 bcopy (XSTRING (p->decoding_buf)->data, temp_buf, nbytes);
3183 insert_before_markers (temp_buf, nbytes);
3184 }
3185 else
3186 {
3187 insert_1_both (chars, nchars, nbytes, 0, 1, 1);
3188 signal_after_change (before, 0, PT - before);
3189 update_compositions (before, PT, CHECK_BORDER);
3190 }
3191 set_marker_both (p->mark, p->buffer, PT, PT_BYTE);
3192
3193 update_mode_lines++;
3194
3195 /* Make sure opoint and the old restrictions
3196 float ahead of any new text just as point would. */
3197 if (opoint >= before)
3198 {
3199 opoint += PT - before;
3200 opoint_byte += PT_BYTE - before_byte;
3201 }
3202 if (old_begv > before)
3203 {
3204 old_begv += PT - before;
3205 old_begv_byte += PT_BYTE - before_byte;
3206 }
3207 if (old_zv >= before)
3208 {
3209 old_zv += PT - before;
3210 old_zv_byte += PT_BYTE - before_byte;
3211 }
3212
3213 /* If the restriction isn't what it should be, set it. */
3214 if (old_begv != BEGV || old_zv != ZV)
3215 Fnarrow_to_region (make_number (old_begv), make_number (old_zv));
3216
3217 /* Handling the process output should not deactivate the mark. */
3218 Vdeactivate_mark = odeactivate;
3219
3220 current_buffer->read_only = old_read_only;
3221 SET_PT_BOTH (opoint, opoint_byte);
3222 set_buffer_internal (old);
3223 }
3224#ifdef VMS
3225 start_vms_process_read (vs);
3226#endif
3227 return nbytes;
3228}
3229
3230DEFUN ("waiting-for-user-input-p", Fwaiting_for_user_input_p, Swaiting_for_user_input_p,
3231 0, 0, 0,
3232 "Returns non-nil if emacs is waiting for input from the user.\n\
3233This is intended for use by asynchronous process output filters and sentinels.")
3234 ()
3235{
3236 return (waiting_for_user_input_p ? Qt : Qnil);
3237}
3238
3239/* Sending data to subprocess */
3240
3241jmp_buf send_process_frame;
3242
3243SIGTYPE
3244send_process_trap ()
3245{
3246#ifdef BSD4_1
3247 sigrelse (SIGPIPE);
3248 sigrelse (SIGALRM);
3249#endif /* BSD4_1 */
3250 longjmp (send_process_frame, 1);
3251}
3252
3253/* Send some data to process PROC.
3254 BUF is the beginning of the data; LEN is the number of characters.
3255 OBJECT is the Lisp object that the data comes from.
3256
3257 The data is encoded by PROC's coding-system for encoding before it
3258 is sent. But if the data ends at the middle of multi-byte
3259 representation, that incomplete sequence of bytes are sent without
3260 being encoded. Should we store them in a buffer to prepend them to
3261 the data send later? */
3262
3263void
3264send_process (proc, buf, len, object)
3265 volatile Lisp_Object proc;
3266 unsigned char *buf;
3267 int len;
3268 Lisp_Object object;
3269{
3270 /* Use volatile to protect variables from being clobbered by longjmp. */
3271 int rv;
3272 volatile unsigned char *procname = XSTRING (XPROCESS (proc)->name)->data;
3273 struct coding_system *coding;
3274 struct gcpro gcpro1;
3275 int carryover = XINT (XPROCESS (proc)->encoding_carryover);
3276
3277 GCPRO1 (object);
3278
3279#ifdef VMS
3280 struct Lisp_Process *p = XPROCESS (proc);
3281 VMS_PROC_STUFF *vs, *get_vms_process_pointer();
3282#endif /* VMS */
3283
3284 if (! NILP (XPROCESS (proc)->raw_status_low))
3285 update_status (XPROCESS (proc));
3286 if (! EQ (XPROCESS (proc)->status, Qrun))
3287 error ("Process %s not running", procname);
3288 if (XINT (XPROCESS (proc)->outfd) < 0)
3289 error ("Output file descriptor of %s is closed", procname);
3290
3291 coding = proc_encode_coding_system[XINT (XPROCESS (proc)->outfd)];
3292 Vlast_coding_system_used = coding->symbol;
3293
3294 if (CODING_REQUIRE_ENCODING (coding))
3295 {
3296 int require = encoding_buffer_size (coding, len);
3297 int offset;
3298 unsigned char *temp_buf = NULL;
3299
3300 /* Remember the offset of data because a string or a buffer may
3301 be relocated. Setting OFFSET to -1 means we don't have to
3302 care about relocation. */
3303 offset = (BUFFERP (object)
3304 ? BUF_PTR_BYTE_POS (XBUFFER (object), buf)
3305 : (STRINGP (object)
3306 ? buf - XSTRING (object)->data
3307 : -1));
3308
3309 if (carryover > 0)
3310 {
3311 temp_buf = (unsigned char *) xmalloc (len + carryover);
3312
3313 if (offset >= 0)
3314 {
3315 if (BUFFERP (object))
3316 buf = BUF_BYTE_ADDRESS (XBUFFER (object), offset);
3317 else if (STRINGP (object))
3318 buf = offset + XSTRING (object)->data;
3319 /* Now we don't have to care about relocation. */
3320 offset = -1;
3321 }
3322 bcopy ((XSTRING (XPROCESS (proc)->encoding_buf)->data
3323 + STRING_BYTES (XSTRING (XPROCESS (proc)->encoding_buf))
3324 - carryover),
3325 temp_buf,
3326 carryover);
3327 bcopy (buf, temp_buf + carryover, len);
3328 buf = temp_buf;
3329 }
3330
3331 if (STRING_BYTES (XSTRING (XPROCESS (proc)->encoding_buf)) < require)
3332 {
3333 XPROCESS (proc)->encoding_buf = make_uninit_string (require);
3334
3335 if (offset >= 0)
3336 {
3337 if (BUFFERP (object))
3338 buf = BUF_BYTE_ADDRESS (XBUFFER (object), offset);
3339 else if (STRINGP (object))
3340 buf = offset + XSTRING (object)->data;
3341 }
3342 }
3343 object = XPROCESS (proc)->encoding_buf;
3344 encode_coding (coding, buf, XSTRING (object)->data,
3345 len, STRING_BYTES (XSTRING (object)));
3346 len = coding->produced;
3347 buf = XSTRING (object)->data;
3348 if (temp_buf)
3349 xfree (temp_buf);
3350 }
3351
3352#ifdef VMS
3353 vs = get_vms_process_pointer (p->pid);
3354 if (vs == 0)
3355 error ("Could not find this process: %x", p->pid);
3356 else if (write_to_vms_process (vs, buf, len))
3357 ;
3358#else
3359
3360 if (pty_max_bytes == 0)
3361 {
3362#if defined (HAVE_FPATHCONF) && defined (_PC_MAX_CANON)
3363 pty_max_bytes = fpathconf (XFASTINT (XPROCESS (proc)->outfd),
3364 _PC_MAX_CANON);
3365 if (pty_max_bytes < 0)
3366 pty_max_bytes = 250;
3367#else
3368 pty_max_bytes = 250;
3369#endif
3370 /* Deduct one, to leave space for the eof. */
3371 pty_max_bytes--;
3372 }
3373
3374 if (!setjmp (send_process_frame))
3375 while (len > 0)
3376 {
3377 int this = len;
3378 SIGTYPE (*old_sigpipe)();
3379
3380 /* Decide how much data we can send in one batch.
3381 Long lines need to be split into multiple batches. */
3382 if (!NILP (XPROCESS (proc)->pty_flag))
3383 {
3384 /* Starting this at zero is always correct when not the first iteration
3385 because the previous iteration ended by sending C-d.
3386 It may not be correct for the first iteration
3387 if a partial line was sent in a separate send_process call.
3388 If that proves worth handling, we need to save linepos
3389 in the process object. */
3390 int linepos = 0;
3391 unsigned char *ptr = buf;
3392 unsigned char *end = buf + len;
3393
3394 /* Scan through this text for a line that is too long. */
3395 while (ptr != end && linepos < pty_max_bytes)
3396 {
3397 if (*ptr == '\n')
3398 linepos = 0;
3399 else
3400 linepos++;
3401 ptr++;
3402 }
3403 /* If we found one, break the line there
3404 and put in a C-d to force the buffer through. */
3405 this = ptr - buf;
3406 }
3407
3408 /* Send this batch, using one or more write calls. */
3409 while (this > 0)
3410 {
3411 old_sigpipe = (SIGTYPE (*) ()) signal (SIGPIPE, send_process_trap);
3412 rv = emacs_write (XINT (XPROCESS (proc)->outfd), buf, this);
3413 signal (SIGPIPE, old_sigpipe);
3414
3415 if (rv < 0)
3416 {
3417 if (0
3418#ifdef EWOULDBLOCK
3419 || errno == EWOULDBLOCK
3420#endif
3421#ifdef EAGAIN
3422 || errno == EAGAIN
3423#endif
3424 )
3425 /* Buffer is full. Wait, accepting input;
3426 that may allow the program
3427 to finish doing output and read more. */
3428 {
3429 Lisp_Object zero;
3430 int offset;
3431
3432 /* Running filters might relocate buffers or strings.
3433 Arrange to relocate BUF. */
3434 if (BUFFERP (object))
3435 offset = BUF_PTR_BYTE_POS (XBUFFER (object), buf);
3436 else if (STRINGP (object))
3437 offset = buf - XSTRING (object)->data;
3438
3439 XSETFASTINT (zero, 0);
3440#ifdef EMACS_HAS_USECS
3441 wait_reading_process_input (0, 20000, zero, 0);
3442#else
3443 wait_reading_process_input (1, 0, zero, 0);
3444#endif
3445
3446 if (BUFFERP (object))
3447 buf = BUF_BYTE_ADDRESS (XBUFFER (object), offset);
3448 else if (STRINGP (object))
3449 buf = offset + XSTRING (object)->data;
3450
3451 rv = 0;
3452 }
3453 else
3454 /* This is a real error. */
3455 report_file_error ("writing to process", Fcons (proc, Qnil));
3456 }
3457 buf += rv;
3458 len -= rv;
3459 this -= rv;
3460 }
3461
3462 /* If we sent just part of the string, put in an EOF
3463 to force it through, before we send the rest. */
3464 if (len > 0)
3465 Fprocess_send_eof (proc);
3466 }
3467#endif
3468 else
3469 {
3470 XPROCESS (proc)->raw_status_low = Qnil;
3471 XPROCESS (proc)->raw_status_high = Qnil;
3472 XPROCESS (proc)->status = Fcons (Qexit, Fcons (make_number (256), Qnil));
3473 XSETINT (XPROCESS (proc)->tick, ++process_tick);
3474 deactivate_process (proc);
3475#ifdef VMS
3476 error ("Error writing to process %s; closed it", procname);
3477#else
3478 error ("SIGPIPE raised on process %s; closed it", procname);
3479#endif
3480 }
3481
3482 UNGCPRO;
3483}
3484
3485DEFUN ("process-send-region", Fprocess_send_region, Sprocess_send_region,
3486 3, 3, 0,
3487 "Send current contents of region as input to PROCESS.\n\
3488PROCESS may be a process, a buffer, the name of a process or buffer, or\n\
3489nil, indicating the current buffer's process.\n\
3490Called from program, takes three arguments, PROCESS, START and END.\n\
3491If the region is more than 500 characters long,\n\
3492it is sent in several bunches. This may happen even for shorter regions.\n\
3493Output from processes can arrive in between bunches.")
3494 (process, start, end)
3495 Lisp_Object process, start, end;
3496{
3497 Lisp_Object proc;
3498 int start1, end1;
3499
3500 proc = get_process (process);
3501 validate_region (&start, &end);
3502
3503 if (XINT (start) < GPT && XINT (end) > GPT)
3504 move_gap (XINT (start));
3505
3506 start1 = CHAR_TO_BYTE (XINT (start));
3507 end1 = CHAR_TO_BYTE (XINT (end));
3508 send_process (proc, BYTE_POS_ADDR (start1), end1 - start1,
3509 Fcurrent_buffer ());
3510
3511 return Qnil;
3512}
3513
3514DEFUN ("process-send-string", Fprocess_send_string, Sprocess_send_string,
3515 2, 2, 0,
3516 "Send PROCESS the contents of STRING as input.\n\
3517PROCESS may be a process, a buffer, the name of a process or buffer, or\n\
3518nil, indicating the current buffer's process.\n\
3519If STRING is more than 500 characters long,\n\
3520it is sent in several bunches. This may happen even for shorter strings.\n\
3521Output from processes can arrive in between bunches.")
3522 (process, string)
3523 Lisp_Object process, string;
3524{
3525 Lisp_Object proc;
3526 CHECK_STRING (string, 1);
3527 proc = get_process (process);
3528 send_process (proc, XSTRING (string)->data,
3529 STRING_BYTES (XSTRING (string)), string);
3530 return Qnil;
3531}
3532
3533DEFUN ("process-running-child-p", Fprocess_running_child_p,
3534 Sprocess_running_child_p, 0, 1, 0,
3535 "Return t if PROCESS has given the terminal to a child.\n\
3536If the operating system does not make it possible to find out,\n\
3537return t unconditionally.")
3538 (process)
3539 Lisp_Object process;
3540{
3541 /* Initialize in case ioctl doesn't exist or gives an error,
3542 in a way that will cause returning t. */
3543 int gid = 0;
3544 Lisp_Object proc;
3545 struct Lisp_Process *p;
3546
3547 proc = get_process (process);
3548 p = XPROCESS (proc);
3549
3550 if (!EQ (p->childp, Qt))
3551 error ("Process %s is not a subprocess",
3552 XSTRING (p->name)->data);
3553 if (XINT (p->infd) < 0)
3554 error ("Process %s is not active",
3555 XSTRING (p->name)->data);
3556
3557#ifdef TIOCGPGRP
3558 if (!NILP (p->subtty))
3559 ioctl (XFASTINT (p->subtty), TIOCGPGRP, &gid);
3560 else
3561 ioctl (XINT (p->infd), TIOCGPGRP, &gid);
3562#endif /* defined (TIOCGPGRP ) */
3563
3564 if (gid == XFASTINT (p->pid))
3565 return Qnil;
3566 return Qt;
3567}
3568
3569/* send a signal number SIGNO to PROCESS.
3570 If CURRENT_GROUP is t, that means send to the process group
3571 that currently owns the terminal being used to communicate with PROCESS.
3572 This is used for various commands in shell mode.
3573 If CURRENT_GROUP is lambda, that means send to the process group
3574 that currently owns the terminal, but only if it is NOT the shell itself.
3575
3576 If NOMSG is zero, insert signal-announcements into process's buffers
3577 right away.
3578
3579 If we can, we try to signal PROCESS by sending control characters
3580 down the pty. This allows us to signal inferiors who have changed
3581 their uid, for which killpg would return an EPERM error. */
3582
3583static void
3584process_send_signal (process, signo, current_group, nomsg)
3585 Lisp_Object process;
3586 int signo;
3587 Lisp_Object current_group;
3588 int nomsg;
3589{
3590 Lisp_Object proc;
3591 register struct Lisp_Process *p;
3592 int gid;
3593 int no_pgrp = 0;
3594
3595 proc = get_process (process);
3596 p = XPROCESS (proc);
3597
3598 if (!EQ (p->childp, Qt))
3599 error ("Process %s is not a subprocess",
3600 XSTRING (p->name)->data);
3601 if (XINT (p->infd) < 0)
3602 error ("Process %s is not active",
3603 XSTRING (p->name)->data);
3604
3605 if (NILP (p->pty_flag))
3606 current_group = Qnil;
3607
3608 /* If we are using pgrps, get a pgrp number and make it negative. */
3609 if (!NILP (current_group))
3610 {
3611#ifdef SIGNALS_VIA_CHARACTERS
3612 /* If possible, send signals to the entire pgrp
3613 by sending an input character to it. */
3614
3615 /* TERMIOS is the latest and bestest, and seems most likely to
3616 work. If the system has it, use it. */
3617#ifdef HAVE_TERMIOS
3618 struct termios t;
3619
3620 switch (signo)
3621 {
3622 case SIGINT:
3623 tcgetattr (XINT (p->infd), &t);
3624 send_process (proc, &t.c_cc[VINTR], 1, Qnil);
3625 return;
3626
3627 case SIGQUIT:
3628 tcgetattr (XINT (p->infd), &t);
3629 send_process (proc, &t.c_cc[VQUIT], 1, Qnil);
3630 return;
3631
3632 case SIGTSTP:
3633 tcgetattr (XINT (p->infd), &t);
3634#if defined (VSWTCH) && !defined (PREFER_VSUSP)
3635 send_process (proc, &t.c_cc[VSWTCH], 1, Qnil);
3636#else
3637 send_process (proc, &t.c_cc[VSUSP], 1, Qnil);
3638#endif
3639 return;
3640 }
3641
3642#else /* ! HAVE_TERMIOS */
3643
3644 /* On Berkeley descendants, the following IOCTL's retrieve the
3645 current control characters. */
3646#if defined (TIOCGLTC) && defined (TIOCGETC)
3647
3648 struct tchars c;
3649 struct ltchars lc;
3650
3651 switch (signo)
3652 {
3653 case SIGINT:
3654 ioctl (XINT (p->infd), TIOCGETC, &c);
3655 send_process (proc, &c.t_intrc, 1, Qnil);
3656 return;
3657 case SIGQUIT:
3658 ioctl (XINT (p->infd), TIOCGETC, &c);
3659 send_process (proc, &c.t_quitc, 1, Qnil);
3660 return;
3661#ifdef SIGTSTP
3662 case SIGTSTP:
3663 ioctl (XINT (p->infd), TIOCGLTC, &lc);
3664 send_process (proc, &lc.t_suspc, 1, Qnil);
3665 return;
3666#endif /* ! defined (SIGTSTP) */
3667 }
3668
3669#else /* ! defined (TIOCGLTC) && defined (TIOCGETC) */
3670
3671 /* On SYSV descendants, the TCGETA ioctl retrieves the current control
3672 characters. */
3673#ifdef TCGETA
3674 struct termio t;
3675 switch (signo)
3676 {
3677 case SIGINT:
3678 ioctl (XINT (p->infd), TCGETA, &t);
3679 send_process (proc, &t.c_cc[VINTR], 1, Qnil);
3680 return;
3681 case SIGQUIT:
3682 ioctl (XINT (p->infd), TCGETA, &t);
3683 send_process (proc, &t.c_cc[VQUIT], 1, Qnil);
3684 return;
3685#ifdef SIGTSTP
3686 case SIGTSTP:
3687 ioctl (XINT (p->infd), TCGETA, &t);
3688 send_process (proc, &t.c_cc[VSWTCH], 1, Qnil);
3689 return;
3690#endif /* ! defined (SIGTSTP) */
3691 }
3692#else /* ! defined (TCGETA) */
3693 Your configuration files are messed up.
3694 /* If your system configuration files define SIGNALS_VIA_CHARACTERS,
3695 you'd better be using one of the alternatives above! */
3696#endif /* ! defined (TCGETA) */
3697#endif /* ! defined (TIOCGLTC) && defined (TIOCGETC) */
3698#endif /* ! defined HAVE_TERMIOS */
3699#endif /* ! defined (SIGNALS_VIA_CHARACTERS) */
3700
3701#ifdef TIOCGPGRP
3702 /* Get the pgrp using the tty itself, if we have that.
3703 Otherwise, use the pty to get the pgrp.
3704 On pfa systems, saka@pfu.fujitsu.co.JP writes:
3705 "TIOCGPGRP symbol defined in sys/ioctl.h at E50.
3706 But, TIOCGPGRP does not work on E50 ;-P works fine on E60"
3707 His patch indicates that if TIOCGPGRP returns an error, then
3708 we should just assume that p->pid is also the process group id. */
3709 {
3710 int err;
3711
3712 if (!NILP (p->subtty))
3713 err = ioctl (XFASTINT (p->subtty), TIOCGPGRP, &gid);
3714 else
3715 err = ioctl (XINT (p->infd), TIOCGPGRP, &gid);
3716
3717#ifdef pfa
3718 if (err == -1)
3719 gid = - XFASTINT (p->pid);
3720#endif /* ! defined (pfa) */
3721 }
3722 if (gid == -1)
3723 no_pgrp = 1;
3724 else
3725 gid = - gid;
3726#else /* ! defined (TIOCGPGRP ) */
3727 /* Can't select pgrps on this system, so we know that
3728 the child itself heads the pgrp. */
3729 gid = - XFASTINT (p->pid);
3730#endif /* ! defined (TIOCGPGRP ) */
3731
3732 /* If current_group is lambda, and the shell owns the terminal,
3733 don't send any signal. */
3734 if (EQ (current_group, Qlambda) && gid == - XFASTINT (p->pid))
3735 return;
3736 }
3737 else
3738 gid = - XFASTINT (p->pid);
3739
3740 switch (signo)
3741 {
3742#ifdef SIGCONT
3743 case SIGCONT:
3744 p->raw_status_low = Qnil;
3745 p->raw_status_high = Qnil;
3746 p->status = Qrun;
3747 XSETINT (p->tick, ++process_tick);
3748 if (!nomsg)
3749 status_notify ();
3750 break;
3751#endif /* ! defined (SIGCONT) */
3752 case SIGINT:
3753#ifdef VMS
3754 send_process (proc, "\003", 1, Qnil); /* ^C */
3755 goto whoosh;
3756#endif
3757 case SIGQUIT:
3758#ifdef VMS
3759 send_process (proc, "\031", 1, Qnil); /* ^Y */
3760 goto whoosh;
3761#endif
3762 case SIGKILL:
3763#ifdef VMS
3764 sys$forcex (&(XFASTINT (p->pid)), 0, 1);
3765 whoosh:
3766#endif
3767 flush_pending_output (XINT (p->infd));
3768 break;
3769 }
3770
3771 /* If we don't have process groups, send the signal to the immediate
3772 subprocess. That isn't really right, but it's better than any
3773 obvious alternative. */
3774 if (no_pgrp)
3775 {
3776 kill (XFASTINT (p->pid), signo);
3777 return;
3778 }
3779
3780 /* gid may be a pid, or minus a pgrp's number */
3781#ifdef TIOCSIGSEND
3782 if (!NILP (current_group))
3783 ioctl (XINT (p->infd), TIOCSIGSEND, signo);
3784 else
3785 {
3786 gid = - XFASTINT (p->pid);
3787 kill (gid, signo);
3788 }
3789#else /* ! defined (TIOCSIGSEND) */
3790 EMACS_KILLPG (-gid, signo);
3791#endif /* ! defined (TIOCSIGSEND) */
3792}
3793
3794DEFUN ("interrupt-process", Finterrupt_process, Sinterrupt_process, 0, 2, 0,
3795 "Interrupt process PROCESS.\n\
3796PROCESS may be a process, a buffer, or the name of a process or buffer.\n\
3797nil or no arg means current buffer's process.\n\
3798Second arg CURRENT-GROUP non-nil means send signal to\n\
3799the current process-group of the process's controlling terminal\n\
3800rather than to the process's own process group.\n\
3801If the process is a shell, this means interrupt current subjob\n\
3802rather than the shell.\n\
3803\n\
3804If CURRENT-GROUP is `lambda', and if the shell owns the terminal,\n\
3805don't send the signal.")
3806 (process, current_group)
3807 Lisp_Object process, current_group;
3808{
3809 process_send_signal (process, SIGINT, current_group, 0);
3810 return process;
3811}
3812
3813DEFUN ("kill-process", Fkill_process, Skill_process, 0, 2, 0,
3814 "Kill process PROCESS. May be process or name of one.\n\
3815See function `interrupt-process' for more details on usage.")
3816 (process, current_group)
3817 Lisp_Object process, current_group;
3818{
3819 process_send_signal (process, SIGKILL, current_group, 0);
3820 return process;
3821}
3822
3823DEFUN ("quit-process", Fquit_process, Squit_process, 0, 2, 0,
3824 "Send QUIT signal to process PROCESS. May be process or name of one.\n\
3825See function `interrupt-process' for more details on usage.")
3826 (process, current_group)
3827 Lisp_Object process, current_group;
3828{
3829 process_send_signal (process, SIGQUIT, current_group, 0);
3830 return process;
3831}
3832
3833DEFUN ("stop-process", Fstop_process, Sstop_process, 0, 2, 0,
3834 "Stop process PROCESS. May be process or name of one.\n\
3835See function `interrupt-process' for more details on usage.")
3836 (process, current_group)
3837 Lisp_Object process, current_group;
3838{
3839#ifndef SIGTSTP
3840 error ("no SIGTSTP support");
3841#else
3842 process_send_signal (process, SIGTSTP, current_group, 0);
3843#endif
3844 return process;
3845}
3846
3847DEFUN ("continue-process", Fcontinue_process, Scontinue_process, 0, 2, 0,
3848 "Continue process PROCESS. May be process or name of one.\n\
3849See function `interrupt-process' for more details on usage.")
3850 (process, current_group)
3851 Lisp_Object process, current_group;
3852{
3853#ifdef SIGCONT
3854 process_send_signal (process, SIGCONT, current_group, 0);
3855#else
3856 error ("no SIGCONT support");
3857#endif
3858 return process;
3859}
3860
3861DEFUN ("signal-process", Fsignal_process, Ssignal_process,
3862 2, 2, "nProcess number: \nnSignal code: ",
3863 "Send the process with process id PID the signal with code SIGCODE.\n\
3864PID must be an integer. The process need not be a child of this Emacs.\n\
3865SIGCODE may be an integer, or a symbol whose name is a signal name.")
3866 (pid, sigcode)
3867 Lisp_Object pid, sigcode;
3868{
3869 CHECK_NUMBER (pid, 0);
3870
3871#define handle_signal(NAME, VALUE) \
3872 else if (!strcmp (name, NAME)) \
3873 XSETINT (sigcode, VALUE)
3874
3875 if (INTEGERP (sigcode))
3876 ;
3877 else
3878 {
3879 unsigned char *name;
3880
3881 CHECK_SYMBOL (sigcode, 1);
3882 name = XSYMBOL (sigcode)->name->data;
3883
3884 if (0)
3885 ;
3886#ifdef SIGHUP
3887 handle_signal ("SIGHUP", SIGHUP);
3888#endif
3889#ifdef SIGINT
3890 handle_signal ("SIGINT", SIGINT);
3891#endif
3892#ifdef SIGQUIT
3893 handle_signal ("SIGQUIT", SIGQUIT);
3894#endif
3895#ifdef SIGILL
3896 handle_signal ("SIGILL", SIGILL);
3897#endif
3898#ifdef SIGABRT
3899 handle_signal ("SIGABRT", SIGABRT);
3900#endif
3901#ifdef SIGEMT
3902 handle_signal ("SIGEMT", SIGEMT);
3903#endif
3904#ifdef SIGKILL
3905 handle_signal ("SIGKILL", SIGKILL);
3906#endif
3907#ifdef SIGFPE
3908 handle_signal ("SIGFPE", SIGFPE);
3909#endif
3910#ifdef SIGBUS
3911 handle_signal ("SIGBUS", SIGBUS);
3912#endif
3913#ifdef SIGSEGV
3914 handle_signal ("SIGSEGV", SIGSEGV);
3915#endif
3916#ifdef SIGSYS
3917 handle_signal ("SIGSYS", SIGSYS);
3918#endif
3919#ifdef SIGPIPE
3920 handle_signal ("SIGPIPE", SIGPIPE);
3921#endif
3922#ifdef SIGALRM
3923 handle_signal ("SIGALRM", SIGALRM);
3924#endif
3925#ifdef SIGTERM
3926 handle_signal ("SIGTERM", SIGTERM);
3927#endif
3928#ifdef SIGURG
3929 handle_signal ("SIGURG", SIGURG);
3930#endif
3931#ifdef SIGSTOP
3932 handle_signal ("SIGSTOP", SIGSTOP);
3933#endif
3934#ifdef SIGTSTP
3935 handle_signal ("SIGTSTP", SIGTSTP);
3936#endif
3937#ifdef SIGCONT
3938 handle_signal ("SIGCONT", SIGCONT);
3939#endif
3940#ifdef SIGCHLD
3941 handle_signal ("SIGCHLD", SIGCHLD);
3942#endif
3943#ifdef SIGTTIN
3944 handle_signal ("SIGTTIN", SIGTTIN);
3945#endif
3946#ifdef SIGTTOU
3947 handle_signal ("SIGTTOU", SIGTTOU);
3948#endif
3949#ifdef SIGIO
3950 handle_signal ("SIGIO", SIGIO);
3951#endif
3952#ifdef SIGXCPU
3953 handle_signal ("SIGXCPU", SIGXCPU);
3954#endif
3955#ifdef SIGXFSZ
3956 handle_signal ("SIGXFSZ", SIGXFSZ);
3957#endif
3958#ifdef SIGVTALRM
3959 handle_signal ("SIGVTALRM", SIGVTALRM);
3960#endif
3961#ifdef SIGPROF
3962 handle_signal ("SIGPROF", SIGPROF);
3963#endif
3964#ifdef SIGWINCH
3965 handle_signal ("SIGWINCH", SIGWINCH);
3966#endif
3967#ifdef SIGINFO
3968 handle_signal ("SIGINFO", SIGINFO);
3969#endif
3970#ifdef SIGUSR1
3971 handle_signal ("SIGUSR1", SIGUSR1);
3972#endif
3973#ifdef SIGUSR2
3974 handle_signal ("SIGUSR2", SIGUSR2);
3975#endif
3976 else
3977 error ("Undefined signal name %s", name);
3978 }
3979
3980#undef handle_signal
3981
3982 return make_number (kill (XINT (pid), XINT (sigcode)));
3983}
3984
3985DEFUN ("process-send-eof", Fprocess_send_eof, Sprocess_send_eof, 0, 1, 0,
3986 "Make PROCESS see end-of-file in its input.\n\
3987EOF comes after any text already sent to it.\n\
3988PROCESS may be a process, a buffer, the name of a process or buffer, or\n\
3989nil, indicating the current buffer's process.\n\
3990If PROCESS is a network connection, or is a process communicating\n\
3991through a pipe (as opposed to a pty), then you cannot send any more\n\
3992text to PROCESS after you call this function.")
3993 (process)
3994 Lisp_Object process;
3995{
3996 Lisp_Object proc;
3997 struct coding_system *coding;
3998
3999 proc = get_process (process);
4000 coding = proc_encode_coding_system[XINT (XPROCESS (proc)->outfd)];
4001
4002 /* Make sure the process is really alive. */
4003 if (! NILP (XPROCESS (proc)->raw_status_low))
4004 update_status (XPROCESS (proc));
4005 if (! EQ (XPROCESS (proc)->status, Qrun))
4006 error ("Process %s not running", XSTRING (XPROCESS (proc)->name)->data);
4007
4008 if (CODING_REQUIRE_FLUSHING (coding))
4009 {
4010 coding->mode |= CODING_MODE_LAST_BLOCK;
4011 send_process (proc, "", 0, Qnil);
4012 }
4013
4014#ifdef VMS
4015 send_process (proc, "\032", 1, Qnil); /* ^z */
4016#else
4017 if (!NILP (XPROCESS (proc)->pty_flag))
4018 send_process (proc, "\004", 1, Qnil);
4019 else
4020 {
4021 int old_outfd, new_outfd;
4022
4023#ifdef HAVE_SHUTDOWN
4024 /* If this is a network connection, or socketpair is used
4025 for communication with the subprocess, call shutdown to cause EOF.
4026 (In some old system, shutdown to socketpair doesn't work.
4027 Then we just can't win.) */
4028 if (NILP (XPROCESS (proc)->pid)
4029 || XINT (XPROCESS (proc)->outfd) == XINT (XPROCESS (proc)->infd))
4030 shutdown (XINT (XPROCESS (proc)->outfd), 1);
4031 /* In case of socketpair, outfd == infd, so don't close it. */
4032 if (XINT (XPROCESS (proc)->outfd) != XINT (XPROCESS (proc)->infd))
4033 emacs_close (XINT (XPROCESS (proc)->outfd));
4034#else /* not HAVE_SHUTDOWN */
4035 emacs_close (XINT (XPROCESS (proc)->outfd));
4036#endif /* not HAVE_SHUTDOWN */
4037 new_outfd = emacs_open (NULL_DEVICE, O_WRONLY, 0);
4038 old_outfd = XINT (XPROCESS (proc)->outfd);
4039
4040 if (!proc_encode_coding_system[new_outfd])
4041 proc_encode_coding_system[new_outfd]
4042 = (struct coding_system *) xmalloc (sizeof (struct coding_system));
4043 bcopy (proc_encode_coding_system[old_outfd],
4044 proc_encode_coding_system[new_outfd],
4045 sizeof (struct coding_system));
4046 bzero (proc_encode_coding_system[old_outfd],
4047 sizeof (struct coding_system));
4048
4049 XSETINT (XPROCESS (proc)->outfd, new_outfd);
4050 }
4051#endif /* VMS */
4052 return process;
4053}
4054
4055/* Kill all processes associated with `buffer'.
4056 If `buffer' is nil, kill all processes */
4057
4058void
4059kill_buffer_processes (buffer)
4060 Lisp_Object buffer;
4061{
4062 Lisp_Object tail, proc;
4063
4064 for (tail = Vprocess_alist; GC_CONSP (tail); tail = XCDR (tail))
4065 {
4066 proc = XCDR (XCAR (tail));
4067 if (GC_PROCESSP (proc)
4068 && (NILP (buffer) || EQ (XPROCESS (proc)->buffer, buffer)))
4069 {
4070 if (NETCONN_P (proc))
4071 Fdelete_process (proc);
4072 else if (XINT (XPROCESS (proc)->infd) >= 0)
4073 process_send_signal (proc, SIGHUP, Qnil, 1);
4074 }
4075 }
4076}
4077
4078/* On receipt of a signal that a child status has changed,
4079 loop asking about children with changed statuses until
4080 the system says there are no more.
4081 All we do is change the status;
4082 we do not run sentinels or print notifications.
4083 That is saved for the next time keyboard input is done,
4084 in order to avoid timing errors. */
4085
4086/** WARNING: this can be called during garbage collection.
4087 Therefore, it must not be fooled by the presence of mark bits in
4088 Lisp objects. */
4089
4090/** USG WARNING: Although it is not obvious from the documentation
4091 in signal(2), on a USG system the SIGCLD handler MUST NOT call
4092 signal() before executing at least one wait(), otherwise the handler
4093 will be called again, resulting in an infinite loop. The relevant
4094 portion of the documentation reads "SIGCLD signals will be queued
4095 and the signal-catching function will be continually reentered until
4096 the queue is empty". Invoking signal() causes the kernel to reexamine
4097 the SIGCLD queue. Fred Fish, UniSoft Systems Inc. */
4098
4099SIGTYPE
4100sigchld_handler (signo)
4101 int signo;
4102{
4103 int old_errno = errno;
4104 Lisp_Object proc;
4105 register struct Lisp_Process *p;
4106 extern EMACS_TIME *input_available_clear_time;
4107
4108#ifdef BSD4_1
4109 extern int sigheld;
4110 sigheld |= sigbit (SIGCHLD);
4111#endif
4112
4113 while (1)
4114 {
4115 register int pid;
4116 WAITTYPE w;
4117 Lisp_Object tail;
4118
4119#ifdef WNOHANG
4120#ifndef WUNTRACED
4121#define WUNTRACED 0
4122#endif /* no WUNTRACED */
4123 /* Keep trying to get a status until we get a definitive result. */
4124 do
4125 {
4126 errno = 0;
4127 pid = wait3 (&w, WNOHANG | WUNTRACED, 0);
4128 }
4129 while (pid <= 0 && errno == EINTR);
4130
4131 if (pid <= 0)
4132 {
4133 /* A real failure. We have done all our job, so return. */
4134
4135 /* USG systems forget handlers when they are used;
4136 must reestablish each time */
4137#if defined (USG) && !defined (POSIX_SIGNALS)
4138 signal (signo, sigchld_handler); /* WARNING - must come after wait3() */
4139#endif
4140#ifdef BSD4_1
4141 sigheld &= ~sigbit (SIGCHLD);
4142 sigrelse (SIGCHLD);
4143#endif
4144 errno = old_errno;
4145 return;
4146 }
4147#else
4148 pid = wait (&w);
4149#endif /* no WNOHANG */
4150
4151 /* Find the process that signaled us, and record its status. */
4152
4153 p = 0;
4154 for (tail = Vprocess_alist; CONSP (tail); tail = XCDR (tail))
4155 {
4156 proc = XCDR (XCAR (tail));
4157 p = XPROCESS (proc);
4158 if (EQ (p->childp, Qt) && XFASTINT (p->pid) == pid)
4159 break;
4160 p = 0;
4161 }
4162
4163 /* Look for an asynchronous process whose pid hasn't been filled
4164 in yet. */
4165 if (p == 0)
4166 for (tail = Vprocess_alist; CONSP (tail); tail = XCDR (tail))
4167 {
4168 proc = XCDR (XCAR (tail));
4169 p = XPROCESS (proc);
4170 if (INTEGERP (p->pid) && XINT (p->pid) == -1)
4171 break;
4172 p = 0;
4173 }
4174
4175 /* Change the status of the process that was found. */
4176 if (p != 0)
4177 {
4178 union { int i; WAITTYPE wt; } u;
4179 int clear_desc_flag = 0;
4180
4181 XSETINT (p->tick, ++process_tick);
4182 u.wt = w;
4183 XSETINT (p->raw_status_low, u.i & 0xffff);
4184 XSETINT (p->raw_status_high, u.i >> 16);
4185
4186 /* If process has terminated, stop waiting for its output. */
4187 if ((WIFSIGNALED (w) || WIFEXITED (w))
4188 && XINT (p->infd) >= 0)
4189 clear_desc_flag = 1;
4190
4191 /* We use clear_desc_flag to avoid a compiler bug in Microsoft C. */
4192 if (clear_desc_flag)
4193 {
4194 FD_CLR (XINT (p->infd), &input_wait_mask);
4195 FD_CLR (XINT (p->infd), &non_keyboard_wait_mask);
4196 }
4197
4198 /* Tell wait_reading_process_input that it needs to wake up and
4199 look around. */
4200 if (input_available_clear_time)
4201 EMACS_SET_SECS_USECS (*input_available_clear_time, 0, 0);
4202 }
4203
4204 /* There was no asynchronous process found for that id. Check
4205 if we have a synchronous process. */
4206 else
4207 {
4208 synch_process_alive = 0;
4209
4210 /* Report the status of the synchronous process. */
4211 if (WIFEXITED (w))
4212 synch_process_retcode = WRETCODE (w);
4213 else if (WIFSIGNALED (w))
4214 {
4215 int code = WTERMSIG (w);
4216 char *signame;
4217
4218 synchronize_system_messages_locale ();
4219 signame = strsignal (code);
4220
4221 if (signame == 0)
4222 signame = "unknown";
4223
4224 synch_process_death = signame;
4225 }
4226
4227 /* Tell wait_reading_process_input that it needs to wake up and
4228 look around. */
4229 if (input_available_clear_time)
4230 EMACS_SET_SECS_USECS (*input_available_clear_time, 0, 0);
4231 }
4232
4233 /* On some systems, we must return right away.
4234 If any more processes want to signal us, we will
4235 get another signal.
4236 Otherwise (on systems that have WNOHANG), loop around
4237 to use up all the processes that have something to tell us. */
4238#if defined (USG) && ! (defined (HPUX) && defined (WNOHANG)) || defined (WINDOWSNT)
4239#if defined (USG) && ! defined (POSIX_SIGNALS)
4240 signal (signo, sigchld_handler);
4241#endif
4242 errno = old_errno;
4243 return;
4244#endif /* USG, but not HPUX with WNOHANG */
4245 }
4246}
4247
4248
4249static Lisp_Object
4250exec_sentinel_unwind (data)
4251 Lisp_Object data;
4252{
4253 XPROCESS (XCAR (data))->sentinel = XCDR (data);
4254 return Qnil;
4255}
4256
4257static Lisp_Object
4258exec_sentinel_error_handler (error)
4259 Lisp_Object error;
4260{
4261 cmd_error_internal (error, "error in process sentinel: ");
4262 Vinhibit_quit = Qt;
4263 update_echo_area ();
4264 Fsleep_for (make_number (2), Qnil);
4265}
4266
4267static void
4268exec_sentinel (proc, reason)
4269 Lisp_Object proc, reason;
4270{
4271 Lisp_Object sentinel, obuffer, odeactivate, okeymap;
4272 register struct Lisp_Process *p = XPROCESS (proc);
4273 int count = specpdl_ptr - specpdl;
4274 int outer_running_asynch_code = running_asynch_code;
4275 int waiting = waiting_for_user_input_p;
4276
4277 /* No need to gcpro these, because all we do with them later
4278 is test them for EQness, and none of them should be a string. */
4279 odeactivate = Vdeactivate_mark;
4280 XSETBUFFER (obuffer, current_buffer);
4281 okeymap = current_buffer->keymap;
4282
4283 sentinel = p->sentinel;
4284 if (NILP (sentinel))
4285 return;
4286
4287 /* Zilch the sentinel while it's running, to avoid recursive invocations;
4288 assure that it gets restored no matter how the sentinel exits. */
4289 p->sentinel = Qnil;
4290 record_unwind_protect (exec_sentinel_unwind, Fcons (proc, sentinel));
4291 /* Inhibit quit so that random quits don't screw up a running filter. */
4292 specbind (Qinhibit_quit, Qt);
4293 specbind (Qlast_nonmenu_event, Qt);
4294
4295 /* In case we get recursively called,
4296 and we already saved the match data nonrecursively,
4297 save the same match data in safely recursive fashion. */
4298 if (outer_running_asynch_code)
4299 {
4300 Lisp_Object tem;
4301 tem = Fmatch_data (Qnil, Qnil);
4302 restore_match_data ();
4303 record_unwind_protect (Fset_match_data, Fmatch_data (Qnil, Qnil));
4304 Fset_match_data (tem);
4305 }
4306
4307 /* For speed, if a search happens within this code,
4308 save the match data in a special nonrecursive fashion. */
4309 running_asynch_code = 1;
4310
4311 internal_condition_case_1 (read_process_output_call,
4312 Fcons (sentinel,
4313 Fcons (proc, Fcons (reason, Qnil))),
4314 !NILP (Vdebug_on_error) ? Qnil : Qerror,
4315 exec_sentinel_error_handler);
4316
4317 /* If we saved the match data nonrecursively, restore it now. */
4318 restore_match_data ();
4319 running_asynch_code = outer_running_asynch_code;
4320
4321 Vdeactivate_mark = odeactivate;
4322
4323 /* Restore waiting_for_user_input_p as it was
4324 when we were called, in case the filter clobbered it. */
4325 waiting_for_user_input_p = waiting;
4326
4327#if 0
4328 if (! EQ (Fcurrent_buffer (), obuffer)
4329 || ! EQ (current_buffer->keymap, okeymap))
4330#endif
4331 /* But do it only if the caller is actually going to read events.
4332 Otherwise there's no need to make him wake up, and it could
4333 cause trouble (for example it would make Fsit_for return). */
4334 if (waiting_for_user_input_p == -1)
4335 record_asynch_buffer_change ();
4336
4337 unbind_to (count, Qnil);
4338}
4339
4340/* Report all recent events of a change in process status
4341 (either run the sentinel or output a message).
4342 This is done while Emacs is waiting for keyboard input. */
4343
4344void
4345status_notify ()
4346{
4347 register Lisp_Object proc, buffer;
4348 Lisp_Object tail, msg;
4349 struct gcpro gcpro1, gcpro2;
4350
4351 tail = Qnil;
4352 msg = Qnil;
4353 /* We need to gcpro tail; if read_process_output calls a filter
4354 which deletes a process and removes the cons to which tail points
4355 from Vprocess_alist, and then causes a GC, tail is an unprotected
4356 reference. */
4357 GCPRO2 (tail, msg);
4358
4359 /* Set this now, so that if new processes are created by sentinels
4360 that we run, we get called again to handle their status changes. */
4361 update_tick = process_tick;
4362
4363 for (tail = Vprocess_alist; !NILP (tail); tail = Fcdr (tail))
4364 {
4365 Lisp_Object symbol;
4366 register struct Lisp_Process *p;
4367
4368 proc = Fcdr (Fcar (tail));
4369 p = XPROCESS (proc);
4370
4371 if (XINT (p->tick) != XINT (p->update_tick))
4372 {
4373 XSETINT (p->update_tick, XINT (p->tick));
4374
4375 /* If process is still active, read any output that remains. */
4376 while (! EQ (p->filter, Qt)
4377 && XINT (p->infd) >= 0
4378 && read_process_output (proc, XINT (p->infd)) > 0);
4379
4380 buffer = p->buffer;
4381
4382 /* Get the text to use for the message. */
4383 if (!NILP (p->raw_status_low))
4384 update_status (p);
4385 msg = status_message (p->status);
4386
4387 /* If process is terminated, deactivate it or delete it. */
4388 symbol = p->status;
4389 if (CONSP (p->status))
4390 symbol = XCAR (p->status);
4391
4392 if (EQ (symbol, Qsignal) || EQ (symbol, Qexit)
4393 || EQ (symbol, Qclosed))
4394 {
4395 if (delete_exited_processes)
4396 remove_process (proc);
4397 else
4398 deactivate_process (proc);
4399 }
4400
4401 /* The actions above may have further incremented p->tick.
4402 So set p->update_tick again
4403 so that an error in the sentinel will not cause
4404 this code to be run again. */
4405 XSETINT (p->update_tick, XINT (p->tick));
4406 /* Now output the message suitably. */
4407 if (!NILP (p->sentinel))
4408 exec_sentinel (proc, msg);
4409 /* Don't bother with a message in the buffer
4410 when a process becomes runnable. */
4411 else if (!EQ (symbol, Qrun) && !NILP (buffer))
4412 {
4413 Lisp_Object ro, tem;
4414 struct buffer *old = current_buffer;
4415 int opoint, opoint_byte;
4416 int before, before_byte;
4417
4418 ro = XBUFFER (buffer)->read_only;
4419
4420 /* Avoid error if buffer is deleted
4421 (probably that's why the process is dead, too) */
4422 if (NILP (XBUFFER (buffer)->name))
4423 continue;
4424 Fset_buffer (buffer);
4425
4426 opoint = PT;
4427 opoint_byte = PT_BYTE;
4428 /* Insert new output into buffer
4429 at the current end-of-output marker,
4430 thus preserving logical ordering of input and output. */
4431 if (XMARKER (p->mark)->buffer)
4432 Fgoto_char (p->mark);
4433 else
4434 SET_PT_BOTH (ZV, ZV_BYTE);
4435
4436 before = PT;
4437 before_byte = PT_BYTE;
4438
4439 tem = current_buffer->read_only;
4440 current_buffer->read_only = Qnil;
4441 insert_string ("\nProcess ");
4442 Finsert (1, &p->name);
4443 insert_string (" ");
4444 Finsert (1, &msg);
4445 current_buffer->read_only = tem;
4446 set_marker_both (p->mark, p->buffer, PT, PT_BYTE);
4447
4448 if (opoint >= before)
4449 SET_PT_BOTH (opoint + (PT - before),
4450 opoint_byte + (PT_BYTE - before_byte));
4451 else
4452 SET_PT_BOTH (opoint, opoint_byte);
4453
4454 set_buffer_internal (old);
4455 }
4456 }
4457 } /* end for */
4458
4459 update_mode_lines++; /* in case buffers use %s in mode-line-format */
4460 redisplay_preserve_echo_area ();
4461
4462 UNGCPRO;
4463}
4464
4465
4466DEFUN ("set-process-coding-system", Fset_process_coding_system,
4467 Sset_process_coding_system, 1, 3, 0,
4468 "Set coding systems of PROCESS to DECODING and ENCODING.\n\
4469DECODING will be used to decode subprocess output and ENCODING to\n\
4470encode subprocess input.")
4471 (proc, decoding, encoding)
4472 register Lisp_Object proc, decoding, encoding;
4473{
4474 register struct Lisp_Process *p;
4475
4476 CHECK_PROCESS (proc, 0);
4477 p = XPROCESS (proc);
4478 if (XINT (p->infd) < 0)
4479 error ("Input file descriptor of %s closed", XSTRING (p->name)->data);
4480 if (XINT (p->outfd) < 0)
4481 error ("Output file descriptor of %s closed", XSTRING (p->name)->data);
4482
4483 p->decode_coding_system = Fcheck_coding_system (decoding);
4484 p->encode_coding_system = Fcheck_coding_system (encoding);
4485 setup_coding_system (decoding,
4486 proc_decode_coding_system[XINT (p->infd)]);
4487 setup_coding_system (encoding,
4488 proc_encode_coding_system[XINT (p->outfd)]);
4489
4490 return Qnil;
4491}
4492
4493DEFUN ("process-coding-system",
4494 Fprocess_coding_system, Sprocess_coding_system, 1, 1, 0,
4495 "Return a cons of coding systems for decoding and encoding of PROCESS.")
4496 (proc)
4497 register Lisp_Object proc;
4498{
4499 CHECK_PROCESS (proc, 0);
4500 return Fcons (XPROCESS (proc)->decode_coding_system,
4501 XPROCESS (proc)->encode_coding_system);
4502}
4503
4504/* The first time this is called, assume keyboard input comes from DESC
4505 instead of from where we used to expect it.
4506 Subsequent calls mean assume input keyboard can come from DESC
4507 in addition to other places. */
4508
4509static int add_keyboard_wait_descriptor_called_flag;
4510
4511void
4512add_keyboard_wait_descriptor (desc)
4513 int desc;
4514{
4515 if (! add_keyboard_wait_descriptor_called_flag)
4516 FD_CLR (0, &input_wait_mask);
4517 add_keyboard_wait_descriptor_called_flag = 1;
4518 FD_SET (desc, &input_wait_mask);
4519 FD_SET (desc, &non_process_wait_mask);
4520 if (desc > max_keyboard_desc)
4521 max_keyboard_desc = desc;
4522}
4523
4524/* From now on, do not expect DESC to give keyboard input. */
4525
4526void
4527delete_keyboard_wait_descriptor (desc)
4528 int desc;
4529{
4530 int fd;
4531 int lim = max_keyboard_desc;
4532
4533 FD_CLR (desc, &input_wait_mask);
4534 FD_CLR (desc, &non_process_wait_mask);
4535
4536 if (desc == max_keyboard_desc)
4537 for (fd = 0; fd < lim; fd++)
4538 if (FD_ISSET (fd, &input_wait_mask)
4539 && !FD_ISSET (fd, &non_keyboard_wait_mask))
4540 max_keyboard_desc = fd;
4541}
4542
4543/* Return nonzero if *MASK has a bit set
4544 that corresponds to one of the keyboard input descriptors. */
4545
4546int
4547keyboard_bit_set (mask)
4548 SELECT_TYPE *mask;
4549{
4550 int fd;
4551
4552 for (fd = 0; fd <= max_keyboard_desc; fd++)
4553 if (FD_ISSET (fd, mask) && FD_ISSET (fd, &input_wait_mask)
4554 && !FD_ISSET (fd, &non_keyboard_wait_mask))
4555 return 1;
4556
4557 return 0;
4558}
4559
4560void
4561init_process ()
4562{
4563 register int i;
4564
4565#ifdef SIGCHLD
4566#ifndef CANNOT_DUMP
4567 if (! noninteractive || initialized)
4568#endif
4569 signal (SIGCHLD, sigchld_handler);
4570#endif
4571
4572 FD_ZERO (&input_wait_mask);
4573 FD_ZERO (&non_keyboard_wait_mask);
4574 FD_ZERO (&non_process_wait_mask);
4575 max_process_desc = 0;
4576
4577 FD_SET (0, &input_wait_mask);
4578
4579 Vprocess_alist = Qnil;
4580 for (i = 0; i < MAXDESC; i++)
4581 {
4582 chan_process[i] = Qnil;
4583 proc_buffered_char[i] = -1;
4584 }
4585 bzero (proc_decode_coding_system, sizeof proc_decode_coding_system);
4586 bzero (proc_encode_coding_system, sizeof proc_encode_coding_system);
4587
4588 Vdefault_process_coding_system
4589 = (NILP (buffer_defaults.enable_multibyte_characters)
4590 ? Fcons (Qraw_text, Qnil)
4591 : Fcons (Qemacs_mule, Qnil));
4592}
4593
4594void
4595syms_of_process ()
4596{
4597 Qprocessp = intern ("processp");
4598 staticpro (&Qprocessp);
4599 Qrun = intern ("run");
4600 staticpro (&Qrun);
4601 Qstop = intern ("stop");
4602 staticpro (&Qstop);
4603 Qsignal = intern ("signal");
4604 staticpro (&Qsignal);
4605
4606 /* Qexit is already staticpro'd by syms_of_eval; don't staticpro it
4607 here again.
4608
4609 Qexit = intern ("exit");
4610 staticpro (&Qexit); */
4611
4612 Qopen = intern ("open");
4613 staticpro (&Qopen);
4614 Qclosed = intern ("closed");
4615 staticpro (&Qclosed);
4616
4617 Qlast_nonmenu_event = intern ("last-nonmenu-event");
4618 staticpro (&Qlast_nonmenu_event);
4619
4620 staticpro (&Vprocess_alist);
4621
4622 DEFVAR_BOOL ("delete-exited-processes", &delete_exited_processes,
4623 "*Non-nil means delete processes immediately when they exit.\n\
4624nil means don't delete them until `list-processes' is run.");
4625
4626 delete_exited_processes = 1;
4627
4628 DEFVAR_LISP ("process-connection-type", &Vprocess_connection_type,
4629 "Control type of device used to communicate with subprocesses.\n\
4630Values are nil to use a pipe, or t or `pty' to use a pty.\n\
4631The value has no effect if the system has no ptys or if all ptys are busy:\n\
4632then a pipe is used in any case.\n\
4633The value takes effect when `start-process' is called.");
4634 Vprocess_connection_type = Qt;
4635
4636 defsubr (&Sprocessp);
4637 defsubr (&Sget_process);
4638 defsubr (&Sget_buffer_process);
4639 defsubr (&Sdelete_process);
4640 defsubr (&Sprocess_status);
4641 defsubr (&Sprocess_exit_status);
4642 defsubr (&Sprocess_id);
4643 defsubr (&Sprocess_name);
4644 defsubr (&Sprocess_tty_name);
4645 defsubr (&Sprocess_command);
4646 defsubr (&Sset_process_buffer);
4647 defsubr (&Sprocess_buffer);
4648 defsubr (&Sprocess_mark);
4649 defsubr (&Sset_process_filter);
4650 defsubr (&Sprocess_filter);
4651 defsubr (&Sset_process_sentinel);
4652 defsubr (&Sprocess_sentinel);
4653 defsubr (&Sset_process_window_size);
4654 defsubr (&Sset_process_inherit_coding_system_flag);
4655 defsubr (&Sprocess_inherit_coding_system_flag);
4656 defsubr (&Sprocess_kill_without_query);
4657 defsubr (&Sprocess_contact);
4658 defsubr (&Slist_processes);
4659 defsubr (&Sprocess_list);
4660 defsubr (&Sstart_process);
4661#ifdef HAVE_SOCKETS
4662 defsubr (&Sopen_network_stream);
4663#endif /* HAVE_SOCKETS */
4664 defsubr (&Saccept_process_output);
4665 defsubr (&Sprocess_send_region);
4666 defsubr (&Sprocess_send_string);
4667 defsubr (&Sinterrupt_process);
4668 defsubr (&Skill_process);
4669 defsubr (&Squit_process);
4670 defsubr (&Sstop_process);
4671 defsubr (&Scontinue_process);
4672 defsubr (&Sprocess_running_child_p);
4673 defsubr (&Sprocess_send_eof);
4674 defsubr (&Ssignal_process);
4675 defsubr (&Swaiting_for_user_input_p);
4676/* defsubr (&Sprocess_connection); */
4677 defsubr (&Sset_process_coding_system);
4678 defsubr (&Sprocess_coding_system);
4679}
4680
4681
4682#else /* not subprocesses */
4683
4684#include <sys/types.h>
4685#include <errno.h>
4686
4687#include "lisp.h"
4688#include "systime.h"
4689#include "charset.h"
4690#include "coding.h"
4691#include "termopts.h"
4692#include "sysselect.h"
4693
4694extern int frame_garbaged;
4695
4696extern EMACS_TIME timer_check ();
4697extern int timers_run;
4698
4699/* As described above, except assuming that there are no subprocesses:
4700
4701 Wait for timeout to elapse and/or keyboard input to be available.
4702
4703 time_limit is:
4704 timeout in seconds, or
4705 zero for no limit, or
4706 -1 means gobble data immediately available but don't wait for any.
4707
4708 read_kbd is a Lisp_Object:
4709 0 to ignore keyboard input, or
4710 1 to return when input is available, or
4711 -1 means caller will actually read the input, so don't throw to
4712 the quit handler.
4713 a cons cell, meaning wait until its car is non-nil
4714 (and gobble terminal input into the buffer if any arrives), or
4715 We know that read_kbd will never be a Lisp_Process, since
4716 `subprocesses' isn't defined.
4717
4718 do_display != 0 means redisplay should be done to show subprocess
4719 output that arrives.
4720
4721 Return true iff we received input from any process. */
4722
4723int
4724wait_reading_process_input (time_limit, microsecs, read_kbd, do_display)
4725 int time_limit, microsecs;
4726 Lisp_Object read_kbd;
4727 int do_display;
4728{
4729 register int nfds;
4730 EMACS_TIME end_time, timeout;
4731 SELECT_TYPE waitchannels;
4732 int xerrno;
4733 Lisp_Object *wait_for_cell = 0;
4734
4735 /* If waiting for non-nil in a cell, record where. */
4736 if (CONSP (read_kbd))
4737 {
4738 wait_for_cell = &XCAR (read_kbd);
4739 XSETFASTINT (read_kbd, 0);
4740 }
4741
4742 /* What does time_limit really mean? */
4743 if (time_limit || microsecs)
4744 {
4745 EMACS_GET_TIME (end_time);
4746 EMACS_SET_SECS_USECS (timeout, time_limit, microsecs);
4747 EMACS_ADD_TIME (end_time, end_time, timeout);
4748 }
4749
4750 /* Turn off periodic alarms (in case they are in use)
4751 because the select emulator uses alarms. */
4752 turn_on_atimers (0);
4753
4754 while (1)
4755 {
4756 int timeout_reduced_for_timers = 0;
4757
4758 /* If calling from keyboard input, do not quit
4759 since we want to return C-g as an input character.
4760 Otherwise, do pending quit if requested. */
4761 if (XINT (read_kbd) >= 0)
4762 QUIT;
4763
4764 /* Exit now if the cell we're waiting for became non-nil. */
4765 if (wait_for_cell && ! NILP (*wait_for_cell))
4766 break;
4767
4768 /* Compute time from now till when time limit is up */
4769 /* Exit if already run out */
4770 if (time_limit == -1)
4771 {
4772 /* -1 specified for timeout means
4773 gobble output available now
4774 but don't wait at all. */
4775
4776 EMACS_SET_SECS_USECS (timeout, 0, 0);
4777 }
4778 else if (time_limit || microsecs)
4779 {
4780 EMACS_GET_TIME (timeout);
4781 EMACS_SUB_TIME (timeout, end_time, timeout);
4782 if (EMACS_TIME_NEG_P (timeout))
4783 break;
4784 }
4785 else
4786 {
4787 EMACS_SET_SECS_USECS (timeout, 100000, 0);
4788 }
4789
4790 /* If our caller will not immediately handle keyboard events,
4791 run timer events directly.
4792 (Callers that will immediately read keyboard events
4793 call timer_delay on their own.) */
4794 if (! wait_for_cell)
4795 {
4796 EMACS_TIME timer_delay;
4797 int old_timers_run;
4798
4799 retry:
4800 old_timers_run = timers_run;
4801 timer_delay = timer_check (1);
4802 if (timers_run != old_timers_run && do_display)
4803 {
4804 redisplay_preserve_echo_area ();
4805 /* We must retry, since a timer may have requeued itself
4806 and that could alter the time delay. */
4807 goto retry;
4808 }
4809
4810 /* If there is unread keyboard input, also return. */
4811 if (XINT (read_kbd) != 0
4812 && requeued_events_pending_p ())
4813 break;
4814
4815 if (! EMACS_TIME_NEG_P (timer_delay) && time_limit != -1)
4816 {
4817 EMACS_TIME difference;
4818 EMACS_SUB_TIME (difference, timer_delay, timeout);
4819 if (EMACS_TIME_NEG_P (difference))
4820 {
4821 timeout = timer_delay;
4822 timeout_reduced_for_timers = 1;
4823 }
4824 }
4825 }
4826
4827 /* Cause C-g and alarm signals to take immediate action,
4828 and cause input available signals to zero out timeout. */
4829 if (XINT (read_kbd) < 0)
4830 set_waiting_for_input (&timeout);
4831
4832 /* Wait till there is something to do. */
4833
4834 if (! XINT (read_kbd) && wait_for_cell == 0)
4835 FD_ZERO (&waitchannels);
4836 else
4837 FD_SET (0, &waitchannels);
4838
4839 /* If a frame has been newly mapped and needs updating,
4840 reprocess its display stuff. */
4841 if (frame_garbaged && do_display)
4842 {
4843 clear_waiting_for_input ();
4844 redisplay_preserve_echo_area ();
4845 if (XINT (read_kbd) < 0)
4846 set_waiting_for_input (&timeout);
4847 }
4848
4849 if (XINT (read_kbd) && detect_input_pending ())
4850 {
4851 nfds = 0;
4852 FD_ZERO (&waitchannels);
4853 }
4854 else
4855 nfds = select (1, &waitchannels, (SELECT_TYPE *)0, (SELECT_TYPE *)0,
4856 &timeout);
4857
4858 xerrno = errno;
4859
4860 /* Make C-g and alarm signals set flags again */
4861 clear_waiting_for_input ();
4862
4863 /* If we woke up due to SIGWINCH, actually change size now. */
4864 do_pending_window_change (0);
4865
4866 if (time_limit && nfds == 0 && ! timeout_reduced_for_timers)
4867 /* We waited the full specified time, so return now. */
4868 break;
4869
4870 if (nfds == -1)
4871 {
4872 /* If the system call was interrupted, then go around the
4873 loop again. */
4874 if (xerrno == EINTR)
4875 FD_ZERO (&waitchannels);
4876 else
4877 error ("select error: %s", emacs_strerror (xerrno));
4878 }
4879#ifdef sun
4880 else if (nfds > 0 && (waitchannels & 1) && interrupt_input)
4881 /* System sometimes fails to deliver SIGIO. */
4882 kill (getpid (), SIGIO);
4883#endif
4884#ifdef SIGIO
4885 if (XINT (read_kbd) && interrupt_input && (waitchannels & 1))
4886 kill (getpid (), SIGIO);
4887#endif
4888
4889 /* Check for keyboard input */
4890
4891 if ((XINT (read_kbd) != 0)
4892 && detect_input_pending_run_timers (do_display))
4893 {
4894 swallow_events (do_display);
4895 if (detect_input_pending_run_timers (do_display))
4896 break;
4897 }
4898
4899 /* If there is unread keyboard input, also return. */
4900 if (XINT (read_kbd) != 0
4901 && requeued_events_pending_p ())
4902 break;
4903
4904 /* If wait_for_cell. check for keyboard input
4905 but don't run any timers.
4906 ??? (It seems wrong to me to check for keyboard
4907 input at all when wait_for_cell, but the code
4908 has been this way since July 1994.
4909 Try changing this after version 19.31.) */
4910 if (wait_for_cell
4911 && detect_input_pending ())
4912 {
4913 swallow_events (do_display);
4914 if (detect_input_pending ())
4915 break;
4916 }
4917
4918 /* Exit now if the cell we're waiting for became non-nil. */
4919 if (wait_for_cell && ! NILP (*wait_for_cell))
4920 break;
4921 }
4922
4923 start_polling ();
4924
4925 return 0;
4926}
4927
4928
4929DEFUN ("get-buffer-process", Fget_buffer_process, Sget_buffer_process, 1, 1, 0,
4930 /* Don't confuse make-docfile by having two doc strings for this function.
4931 make-docfile does not pay attention to #if, for good reason! */
4932 0)
4933 (name)
4934 register Lisp_Object name;
4935{
4936 return Qnil;
4937}
4938
4939DEFUN ("process-inherit-coding-system-flag",
4940 Fprocess_inherit_coding_system_flag, Sprocess_inherit_coding_system_flag,
4941 1, 1, 0,
4942 /* Don't confuse make-docfile by having two doc strings for this function.
4943 make-docfile does not pay attention to #if, for good reason! */
4944 0)
4945 (process)
4946 register Lisp_Object process;
4947{
4948 /* Ignore the argument and return the value of
4949 inherit-process-coding-system. */
4950 return inherit_process_coding_system ? Qt : Qnil;
4951}
4952
4953/* Kill all processes associated with `buffer'.
4954 If `buffer' is nil, kill all processes.
4955 Since we have no subprocesses, this does nothing. */
4956
4957void
4958kill_buffer_processes (buffer)
4959 Lisp_Object buffer;
4960{
4961}
4962
4963void
4964init_process ()
4965{
4966}
4967
4968void
4969syms_of_process ()
4970{
4971 defsubr (&Sget_buffer_process);
4972 defsubr (&Sprocess_inherit_coding_system_flag);
4973}
4974
4975
4976#endif /* not subprocesses */