comparison src/process.c @ 90851:31beec9ee600

Merge from emacs--devo--0 Patches applied: * emacs--devo--0 (patch 751-770) - Update from CVS - Merge from emacs--rel--22 - Update from CVS: lisp/textmodes/sgml-mode.el: Revert last change. - Merge from gnus--rel--5.10 * emacs--rel--22 (patch 18-25) * gnus--rel--5.10 (patch 222-223) - Update from CVS Revision: [e-mail]/emacs--unicode--0--patch-208

90850:7d184cd91770


/* Mask of bits indicating the descriptors that we wait for input on.  */

static SELECT_TYPE input_wait_mask;

/* Mask that excludes keyboard input descriptor (s).  */

static SELECT_TYPE non_keyboard_wait_mask;

/* Mask that excludes process input descriptor (s).  */

static SELECT_TYPE non_process_wait_mask;

#ifdef NON_BLOCKING_CONNECT
/* Mask of bits indicating the descriptors that we wait for connect to
   complete on.  Once they complete, they are removed from this mask
   and added to the input_wait_mask and non_keyboard_wait_mask.  */

/* The largest descriptor currently in use for a process object.  */
static int max_process_desc;

/* The largest descriptor currently in use for keyboard input.  */
static int max_keyboard_desc;

/* Nonzero means delete a process right away if it exits.  */
static int delete_exited_processes;

/* Indexed by descriptor, gives the process (if any) for that descriptor */

          FD_CLR (0, &Atemp);
#endif
	  IF_NON_BLOCKING_CONNECT (Ctemp = connect_wait_mask);

	  EMACS_SET_SECS_USECS (timeout, 0, 0);
	  if ((select (max (max_process_desc, max_keyboard_desc) + 1,
		       &Atemp,
#ifdef NON_BLOCKING_CONNECT
		       (num_pending_connects > 0 ? &Ctemp : (SELECT_TYPE *)0),
#else
		       (SELECT_TYPE *)0,

	      EMACS_SET_SECS_USECS (timeout, 0, usecs);
	      process_output_skip = 0;
	    }
#endif

	  nfds = select (max (max_process_desc, max_keyboard_desc) + 1,
			 &Available,
#ifdef NON_BLOCKING_CONNECT
			 (check_connect ? &Connecting : (SELECT_TYPE *)0),
#else
			 (SELECT_TYPE *)0,

  FD_SET (desc, &non_process_wait_mask);
  if (desc > max_keyboard_desc)
    max_keyboard_desc = desc;
}

/* From now on, do not expect DESC to give keyboard input.  */

void
delete_keyboard_wait_descriptor (desc)
     int desc;

  FD_CLR (desc, &non_process_wait_mask);

  if (desc == max_keyboard_desc)
    for (fd = 0; fd < lim; fd++)
      if (FD_ISSET (fd, &input_wait_mask)
	  && !FD_ISSET (fd, &non_keyboard_wait_mask))
	max_keyboard_desc = fd;
}

/* Return nonzero if *MASK has a bit set
   that corresponds to one of the keyboard input descriptors.  */

90851:31beec9ee600


/* Mask of bits indicating the descriptors that we wait for input on.  */

static SELECT_TYPE input_wait_mask;

/* Mask that excludes keyboard input descriptor(s).  */

static SELECT_TYPE non_keyboard_wait_mask;

/* Mask that excludes process input descriptor(s).  */

static SELECT_TYPE non_process_wait_mask;

/* Mask for the gpm mouse input descriptor.  */

static SELECT_TYPE gpm_wait_mask;

#ifdef NON_BLOCKING_CONNECT
/* Mask of bits indicating the descriptors that we wait for connect to
   complete on.  Once they complete, they are removed from this mask
   and added to the input_wait_mask and non_keyboard_wait_mask.  */

/* The largest descriptor currently in use for a process object.  */
static int max_process_desc;

/* The largest descriptor currently in use for keyboard input.  */
static int max_keyboard_desc;

/* The largest descriptor currently in use for gpm mouse input.  */
static int max_gpm_desc;

/* Nonzero means delete a process right away if it exits.  */
static int delete_exited_processes;

/* Indexed by descriptor, gives the process (if any) for that descriptor */

          FD_CLR (0, &Atemp);
#endif
	  IF_NON_BLOCKING_CONNECT (Ctemp = connect_wait_mask);

	  EMACS_SET_SECS_USECS (timeout, 0, 0);
	  if ((select (max (max (max_process_desc, max_keyboard_desc),
			      max_gpm_desc) + 1,
		       &Atemp,
#ifdef NON_BLOCKING_CONNECT
		       (num_pending_connects > 0 ? &Ctemp : (SELECT_TYPE *)0),
#else
		       (SELECT_TYPE *)0,

	      EMACS_SET_SECS_USECS (timeout, 0, usecs);
	      process_output_skip = 0;
	    }
#endif

	  nfds = select (max (max (max_process_desc, max_keyboard_desc),
			      max_gpm_desc) + 1,
			 &Available,
#ifdef NON_BLOCKING_CONNECT
			 (check_connect ? &Connecting : (SELECT_TYPE *)0),
#else
			 (SELECT_TYPE *)0,

  FD_SET (desc, &non_process_wait_mask);
  if (desc > max_keyboard_desc)
    max_keyboard_desc = desc;
}

static int add_gpm_wait_descriptor_called_flag;

void
add_gpm_wait_descriptor (desc)
     int desc;
{
  if (! add_gpm_wait_descriptor_called_flag)
    FD_CLR (0, &input_wait_mask);
  add_gpm_wait_descriptor_called_flag = 1;
  FD_SET (desc, &input_wait_mask);
  FD_SET (desc, &gpm_wait_mask);
  if (desc > max_gpm_desc)
    max_gpm_desc = desc;
}

/* From now on, do not expect DESC to give keyboard input.  */

void
delete_keyboard_wait_descriptor (desc)
     int desc;

  FD_CLR (desc, &non_process_wait_mask);

  if (desc == max_keyboard_desc)
    for (fd = 0; fd < lim; fd++)
      if (FD_ISSET (fd, &input_wait_mask)
	  && !FD_ISSET (fd, &non_keyboard_wait_mask)
	  && !FD_ISSET (fd, &gpm_wait_mask))
	max_keyboard_desc = fd;
}

void
delete_gpm_wait_descriptor (desc)
     int desc;
{
  int fd;
  int lim = max_gpm_desc;

  FD_CLR (desc, &input_wait_mask);
  FD_CLR (desc, &non_process_wait_mask);

  if (desc == max_gpm_desc)
    for (fd = 0; fd < lim; fd++)
      if (FD_ISSET (fd, &input_wait_mask)
	  && !FD_ISSET (fd, &non_keyboard_wait_mask)
	  && !FD_ISSET (fd, &non_process_wait_mask))
	max_gpm_desc = fd;
}

/* Return nonzero if *MASK has a bit set
   that corresponds to one of the keyboard input descriptors.  */