comparison src/process.c @ 7044:7032d07f5ad9

(max_process_desc): New variable. (wait_reading_process_output): Don't look for process output beyond that many bits. (create_process, Fopen_network_stream, deactivate_process): Update it. (init_process): Initialize it.

7043:acf840ff5c1c

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

static SELECT_TYPE input_wait_mask;

/* Descriptor to use for keyboard input.  */
static int keyboard_descriptor;

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

    report_file_error ("Doing vfork", Qnil);
  
  XFASTINT (XPROCESS (process)->pid) = pid;

  FD_SET (inchannel, &input_wait_mask);

  /* If the subfork execv fails, and it exits,
     this close hangs.  I don't know why.
     So have an interrupt jar it loose.  */
  stop_polling ();

  XPROCESS (proc)->pid = Qnil;
  XSET (XPROCESS (proc)->infd, Lisp_Int, s);
  XSET (XPROCESS (proc)->outfd, Lisp_Int, outch);
  XPROCESS (proc)->status = Qrun;
  FD_SET (inch, &input_wait_mask);

  UNGCPRO;
  return proc;
}
#endif	/* HAVE_SOCKETS */

      XSET (p->infd, Lisp_Int, -1);
      XSET (p->outfd, Lisp_Int, -1);
      chan_process[inchannel] = Qnil;
      FD_CLR (inchannel, &input_wait_mask);
    }
}

/* Close all descriptors currently in use for communication
   with subprocess.  This is used in a newly-forked subprocess

      /* Check for data from a process.  */
      /* Really FIRST_PROC_DESC should be 0 on Unix,
	 but this is safer in the short run.  */
      for (channel = keyboard_descriptor == 0 ? FIRST_PROC_DESC : 0;
	   channel < MAXDESC; channel++)
	{
	  if (FD_ISSET (channel, &Available))
	    {
	      int nread;

#endif
    signal (SIGCHLD, sigchld_handler);
#endif

  FD_ZERO (&input_wait_mask);

  keyboard_descriptor = 0;
  FD_SET (keyboard_descriptor, &input_wait_mask);

  Vprocess_alist = Qnil;

7044:7032d07f5ad9

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

static SELECT_TYPE input_wait_mask;

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

/* Descriptor to use for keyboard input.  */
static int keyboard_descriptor;

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

    report_file_error ("Doing vfork", Qnil);
  
  XFASTINT (XPROCESS (process)->pid) = pid;

  FD_SET (inchannel, &input_wait_mask);
  if (inchannel > max_process_desc)
    max_process_desc = inchannel;

  /* If the subfork execv fails, and it exits,
     this close hangs.  I don't know why.
     So have an interrupt jar it loose.  */
  stop_polling ();

  XPROCESS (proc)->pid = Qnil;
  XSET (XPROCESS (proc)->infd, Lisp_Int, s);
  XSET (XPROCESS (proc)->outfd, Lisp_Int, outch);
  XPROCESS (proc)->status = Qrun;
  FD_SET (inch, &input_wait_mask);
  if (inch > max_process_desc)
    max_process_desc = inch;

  UNGCPRO;
  return proc;
}
#endif	/* HAVE_SOCKETS */

      XSET (p->infd, Lisp_Int, -1);
      XSET (p->outfd, Lisp_Int, -1);
      chan_process[inchannel] = Qnil;
      FD_CLR (inchannel, &input_wait_mask);
      if (inchannel == max_process_desc)
	{
	  int i;
	  /* We just closed the highest-numbered process input descriptor,
	     so recompute the highest-numbered one now.  */
	  max_process_desc = 0;
	  for (i = 0; i < MAXDESC; i++)
	    if (!NILP (chan_process[i]))
	      max_process_desc = i;
	}
    }
}

/* Close all descriptors currently in use for communication
   with subprocess.  This is used in a newly-forked subprocess

      /* Check for data from a process.  */
      /* Really FIRST_PROC_DESC should be 0 on Unix,
	 but this is safer in the short run.  */
      for (channel = keyboard_descriptor == 0 ? FIRST_PROC_DESC : 0;
	   channel <= max_process_desc; channel++)
	{
	  if (FD_ISSET (channel, &Available))
	    {
	      int nread;

#endif
    signal (SIGCHLD, sigchld_handler);
#endif

  FD_ZERO (&input_wait_mask);
  max_process_desc = 0;

  keyboard_descriptor = 0;
  FD_SET (keyboard_descriptor, &input_wait_mask);

  Vprocess_alist = Qnil;