428
+ − 1 /* Code shared between all event loops that use select() and have a
+ − 2 different input descriptor for each device.
+ − 3 Copyright (C) 1991, 1992, 1993, 1994, 1995 Free Software Foundation, Inc.
+ − 4 Copyright (C) 1995 Board of Trustees, University of Illinois.
+ − 5 Copyright (C) 1995 Sun Microsystems, Inc.
801
+ − 6 Copyright (C) 1995, 1996, 2001, 2002 Ben Wing.
428
+ − 7
+ − 8 This file is part of XEmacs.
+ − 9
+ − 10 XEmacs is free software; you can redistribute it and/or modify it
+ − 11 under the terms of the GNU General Public License as published by the
+ − 12 Free Software Foundation; either version 2, or (at your option) any
+ − 13 later version.
+ − 14
+ − 15 XEmacs is distributed in the hope that it will be useful, but WITHOUT
+ − 16 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ − 17 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
+ − 18 for more details.
+ − 19
+ − 20 You should have received a copy of the GNU General Public License
+ − 21 along with XEmacs; see the file COPYING. If not, write to
+ − 22 the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ − 23 Boston, MA 02111-1307, USA. */
+ − 24
+ − 25 /* Synched up with: Not in FSF. */
+ − 26
+ − 27 /* This file has been Mule-ized. */
+ − 28
+ − 29 #include <config.h>
+ − 30 #include "lisp.h"
+ − 31
+ − 32 #include "console-stream.h"
+ − 33 #include "console-tty.h"
+ − 34 #include "device.h"
+ − 35 #include "events.h"
+ − 36 #include "lstream.h"
+ − 37 #include "process.h"
+ − 38
+ − 39 #include "sysdep.h"
+ − 40 #include "sysfile.h"
+ − 41 #include "sysproc.h" /* select stuff */
+ − 42 #include "systime.h"
+ − 43
+ − 44 /* Mask of bits indicating the descriptors that we wait for input on.
+ − 45 These work as follows:
+ − 46
+ − 47 input_wait_mask == mask of all file descriptors we select() on,
+ − 48 including TTY/stream console descriptors,
+ − 49 process descriptors, and the signal event pipe.
+ − 50 Only used in event-tty.c; event-Xt.c uses
+ − 51 XtAppAddInput(), and the call to select() is down in
+ − 52 the guts of Xt.
+ − 53
+ − 54 non_fake_input_wait_mask == same as input_wait_mask but minus the
+ − 55 signal event pipe. Also only used in
+ − 56 event-tty.c.
+ − 57
+ − 58 process_only_mask == only the process descriptors.
+ − 59
+ − 60 tty_only_mask == only the TTY/stream console descriptors.
+ − 61 */
+ − 62 SELECT_TYPE input_wait_mask, non_fake_input_wait_mask;
+ − 63 SELECT_TYPE process_only_mask, tty_only_mask;
+ − 64
+ − 65 /* This is used to terminate the select(), when an event came in
+ − 66 through a signal (e.g. window-change or C-g on controlling TTY). */
+ − 67 int signal_event_pipe[2];
+ − 68
+ − 69 int signal_event_pipe_initialized;
+ − 70
+ − 71 int fake_event_occurred;
+ − 72
+ − 73 int
771
+ − 74 read_event_from_tty_or_stream_desc (Lisp_Event *event, struct console *con)
428
+ − 75 {
771
+ − 76 Emchar ch;
793
+ − 77 Lisp_Object console = wrap_console (con);
428
+ − 78
771
+ − 79 if (CONSOLE_TTY_P (con))
+ − 80 ch = Lstream_get_emchar (XLSTREAM (CONSOLE_TTY_DATA (con)->instream));
+ − 81 else
+ − 82 {
+ − 83 /* #### Definitely something strange here. We should be setting
+ − 84 the stdio handle unbuffered and reading from it instead of mixing
+ − 85 stdio and raw io calls. */
+ − 86 int nread = retry_read (fileno (CONSOLE_STREAM_DATA (con)->in), &ch, 1);
+ − 87 if (nread <= 0)
+ − 88 ch = -1;
+ − 89 }
+ − 90
+ − 91 if (ch < 0)
428
+ − 92 {
+ − 93 /* deleting the console might not be safe right now ... */
+ − 94 enqueue_magic_eval_event (io_error_delete_console, console);
+ − 95 /* but we definitely need to unselect it to avoid infinite
+ − 96 loops reading EOF's */
+ − 97 Fconsole_disable_input (console);
+ − 98 }
+ − 99 else
+ − 100 {
+ − 101 character_to_event (ch, event, con, 1, 1);
+ − 102 event->channel = console;
+ − 103 return 1;
+ − 104 }
+ − 105 return 0;
+ − 106 }
+ − 107
+ − 108 void
+ − 109 signal_fake_event (void)
+ − 110 {
+ − 111 char byte = 0;
+ − 112 /* We do the write always. Formerly I tried to "optimize" this
+ − 113 by setting a flag indicating whether we're blocking and only
+ − 114 doing the write in that case, but there is a race condition
+ − 115 if the signal occurs after we've checked for the signal
+ − 116 occurrence (which could occur in many places throughout
+ − 117 an iteration of the command loop, e.g. in status_notify()),
+ − 118 but before we set the blocking flag.
+ − 119
771
+ − 120 This should be OK as long as write() is reentrant, which I'm fairly
+ − 121 sure it is since it's a system call. */
428
+ − 122
+ − 123 if (signal_event_pipe_initialized)
+ − 124 /* In case a signal comes through while we're dumping */
+ − 125 {
+ − 126 int old_errno = errno;
771
+ − 127 retry_write (signal_event_pipe[1], &byte, 1);
428
+ − 128 errno = old_errno;
+ − 129 }
+ − 130 }
+ − 131
+ − 132 void
+ − 133 drain_signal_event_pipe (void)
+ − 134 {
+ − 135 char chars[128];
+ − 136 /* The input end of the pipe has been set to non-blocking. */
771
+ − 137 while (retry_read (signal_event_pipe[0], chars, sizeof (chars)) > 0)
428
+ − 138 ;
+ − 139 }
+ − 140
+ − 141 int
+ − 142 event_stream_unixoid_select_console (struct console *con)
+ − 143 {
+ − 144 int infd;
+ − 145
+ − 146 if (CONSOLE_STREAM_P (con))
+ − 147 infd = fileno (CONSOLE_STREAM_DATA (con)->in);
+ − 148 else
+ − 149 {
+ − 150 assert (CONSOLE_TTY_P (con));
+ − 151 infd = CONSOLE_TTY_DATA (con)->infd;
+ − 152 }
+ − 153
+ − 154 assert (infd >= 0);
+ − 155
+ − 156 FD_SET (infd, &input_wait_mask);
+ − 157 FD_SET (infd, &non_fake_input_wait_mask);
+ − 158 FD_SET (infd, &tty_only_mask);
+ − 159 return infd;
+ − 160 }
+ − 161
+ − 162 int
+ − 163 event_stream_unixoid_unselect_console (struct console *con)
+ − 164 {
+ − 165 int infd;
+ − 166
+ − 167 if (CONSOLE_STREAM_P (con))
+ − 168 infd = fileno (CONSOLE_STREAM_DATA (con)->in);
+ − 169 else
+ − 170 {
+ − 171 assert (CONSOLE_TTY_P (con));
+ − 172 infd = CONSOLE_TTY_DATA (con)->infd;
+ − 173 }
+ − 174
+ − 175 assert (infd >= 0);
+ − 176
+ − 177 FD_CLR (infd, &input_wait_mask);
+ − 178 FD_CLR (infd, &non_fake_input_wait_mask);
+ − 179 FD_CLR (infd, &tty_only_mask);
+ − 180 return infd;
+ − 181 }
+ − 182
+ − 183 static int
440
+ − 184 get_process_infd (Lisp_Process *p)
428
+ − 185 {
+ − 186 Lisp_Object instr, outstr;
+ − 187 get_process_streams (p, &instr, &outstr);
+ − 188 assert (!NILP (instr));
+ − 189 return filedesc_stream_fd (XLSTREAM (instr));
+ − 190 }
+ − 191
+ − 192 int
440
+ − 193 event_stream_unixoid_select_process (Lisp_Process *proc)
428
+ − 194 {
+ − 195 int infd = get_process_infd (proc);
+ − 196
+ − 197 FD_SET (infd, &input_wait_mask);
+ − 198 FD_SET (infd, &non_fake_input_wait_mask);
+ − 199 FD_SET (infd, &process_only_mask);
+ − 200 return infd;
+ − 201 }
+ − 202
+ − 203 int
440
+ − 204 event_stream_unixoid_unselect_process (Lisp_Process *proc)
428
+ − 205 {
+ − 206 int infd = get_process_infd (proc);
+ − 207
+ − 208 FD_CLR (infd, &input_wait_mask);
+ − 209 FD_CLR (infd, &non_fake_input_wait_mask);
+ − 210 FD_CLR (infd, &process_only_mask);
+ − 211 return infd;
+ − 212 }
+ − 213
+ − 214 int
+ − 215 poll_fds_for_input (SELECT_TYPE mask)
+ − 216 {
+ − 217 EMACS_TIME sometime;
+ − 218 EMACS_SELECT_TIME select_time;
+ − 219 SELECT_TYPE temp_mask;
+ − 220 int retval;
+ − 221
+ − 222 while (1)
+ − 223 {
+ − 224 EMACS_SET_SECS_USECS (sometime, 0, 0);
+ − 225 EMACS_TIME_TO_SELECT_TIME (sometime, select_time);
+ − 226 temp_mask = mask;
+ − 227 /* To effect a poll, tell select() to block for zero seconds. */
+ − 228 retval = select (MAXDESC, &temp_mask, 0, 0, &select_time);
+ − 229 if (retval >= 0)
+ − 230 return retval;
+ − 231 if (errno != EINTR)
+ − 232 {
+ − 233 /* Something went seriously wrong; don't abort since maybe
+ − 234 the TTY just died at the wrong time. */
442
+ − 235 stderr_out ("xemacs: select failed: errno = %d\n", errno);
428
+ − 236 return 0;
+ − 237 }
+ − 238 /* else, we got interrupted by a signal, so try again. */
+ − 239 }
+ − 240
801
+ − 241 RETURN_NOT_REACHED (0)
428
+ − 242 }
+ − 243
+ − 244 /****************************************************************************/
+ − 245 /* Unixoid (file descriptors based) process I/O streams routines */
+ − 246 /****************************************************************************/
+ − 247
+ − 248 USID
+ − 249 event_stream_unixoid_create_stream_pair (void* inhandle, void* outhandle,
+ − 250 Lisp_Object* instream,
+ − 251 Lisp_Object* outstream,
+ − 252 int flags)
+ − 253 {
+ − 254 int infd, outfd;
+ − 255 /* Decode inhandle and outhandle. Their meaning depends on
+ − 256 the process implementation being used. */
+ − 257 #if defined (HAVE_WIN32_PROCESSES)
+ − 258 /* We're passed in Windows handles. Open new fds for them */
+ − 259 if ((HANDLE)inhandle != INVALID_HANDLE_VALUE)
+ − 260 {
+ − 261 infd = open_osfhandle ((HANDLE)inhandle, 0);
+ − 262 if (infd < 0)
+ − 263 return USID_ERROR;
+ − 264 }
+ − 265 else
+ − 266 infd = -1;
+ − 267
+ − 268 if ((HANDLE)outhandle != INVALID_HANDLE_VALUE)
+ − 269 {
+ − 270 outfd = open_osfhandle ((HANDLE)outhandle, 0);
+ − 271 if (outfd < 0)
+ − 272 {
+ − 273 if (infd >= 0)
771
+ − 274 retry_close (infd);
428
+ − 275 return USID_ERROR;
+ − 276 }
+ − 277 }
+ − 278 else
+ − 279 outfd = -1;
+ − 280
+ − 281 flags = 0;
+ − 282 #elif defined (HAVE_UNIX_PROCESSES)
+ − 283 /* We are passed plain old file descs */
+ − 284 infd = (int)inhandle;
+ − 285 outfd = (int)outhandle;
+ − 286 #else
+ − 287 # error Which processes do you have?
+ − 288 #endif
+ − 289
+ − 290 *instream = (infd >= 0
+ − 291 ? make_filedesc_input_stream (infd, 0, -1, 0)
+ − 292 : Qnil);
+ − 293
+ − 294 *outstream = (outfd >= 0
+ − 295 ? make_filedesc_output_stream (outfd, 0, -1, LSTR_BLOCKED_OK)
+ − 296 : Qnil);
+ − 297
535
+ − 298 #if defined(HAVE_UNIX_PROCESSES)
428
+ − 299 /* FLAGS is process->pty_flag for UNIX_PROCESSES */
+ − 300 if ((flags & STREAM_PTY_FLUSHING) && outfd >= 0)
+ − 301 {
665
+ − 302 Intbyte eof_char = get_eof_char (outfd);
428
+ − 303 int pty_max_bytes = get_pty_max_bytes (outfd);
+ − 304 filedesc_stream_set_pty_flushing (XLSTREAM(*outstream), pty_max_bytes, eof_char);
+ − 305 }
+ − 306 #endif
+ − 307
+ − 308 return FD_TO_USID (infd);
+ − 309 }
+ − 310
+ − 311 USID
+ − 312 event_stream_unixoid_delete_stream_pair (Lisp_Object instream,
+ − 313 Lisp_Object outstream)
+ − 314 {
+ − 315 int in = (NILP(instream) ? -1
+ − 316 : filedesc_stream_fd (XLSTREAM (instream)));
+ − 317 int out = (NILP(outstream) ? -1
+ − 318 : filedesc_stream_fd (XLSTREAM (outstream)));
+ − 319
+ − 320 if (in >= 0)
771
+ − 321 retry_close (in);
428
+ − 322 if (out != in && out >= 0)
771
+ − 323 retry_close (out);
428
+ − 324
+ − 325 return FD_TO_USID (in);
+ − 326 }
+ − 327
+ − 328
+ − 329 void
+ − 330 init_event_unixoid (void)
+ − 331 {
+ − 332 /* Do this first; the init_event_*_late() functions
+ − 333 pay attention to it. */
+ − 334 if (pipe (signal_event_pipe) < 0)
+ − 335 {
+ − 336 perror ("XEmacs: can't open pipe");
+ − 337 exit (-1);
+ − 338 }
+ − 339 signal_event_pipe_initialized = 1;
+ − 340
+ − 341 /* Set it non-blocking so we can drain its output. */
+ − 342 set_descriptor_non_blocking (signal_event_pipe[0]);
+ − 343
+ − 344 /* Also set the write descriptor non-blocking so we don't
+ − 345 hang in case a long time passes between times when
+ − 346 we drain the pipe. */
+ − 347 set_descriptor_non_blocking (signal_event_pipe[1]);
+ − 348
+ − 349 /* WARNING: In order for the signal-event pipe to work correctly
+ − 350 and not cause lockups, the following need to be followed:
+ − 351
+ − 352 1) event_pending_p() must ignore input on the signal-event pipe.
+ − 353 2) As soon as next_event() notices input on the signal-event
+ − 354 pipe, it must drain it. */
+ − 355 FD_ZERO (&input_wait_mask);
+ − 356 FD_ZERO (&non_fake_input_wait_mask);
+ − 357 FD_ZERO (&process_only_mask);
+ − 358 FD_ZERO (&tty_only_mask);
+ − 359
+ − 360 FD_SET (signal_event_pipe[0], &input_wait_mask);
+ − 361 }
