X-Git-Url: http://git.ipfire.org/?a=blobdiff_plain;f=gdb%2Fser-pipe.c;h=5fa897f2d909e958771af31dd726e9badc290be0;hb=a9762ec78a53fbe9209fe1654db42df0cd328d50;hp=0c36a31e07ae27c41d9fa45c6c8fb54d41c3d9dd;hpb=d4f3574e777abfa65c9ba134e582228f3f32a8d6;p=thirdparty%2Fbinutils-gdb.git diff --git a/gdb/ser-pipe.c b/gdb/ser-pipe.c index 0c36a31e07a..5fa897f2d90 100644 --- a/gdb/ser-pipe.c +++ b/gdb/ser-pipe.c @@ -1,5 +1,5 @@ /* Serial interface for a pipe to a separate program - Copyright 1999 Free Software Foundation, Inc. + Copyright (C) 1999, 2000, 2001, 2007 Free Software Foundation, Inc. Contributed by Cygnus Solutions. @@ -7,7 +7,7 @@ This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by - the Free Software Foundation; either version 2 of the License, or + the Free Software Foundation; either version 3 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, @@ -16,46 +16,27 @@ GNU General Public License for more details. You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 59 Temple Place - Suite 330, - Boston, MA 02111-1307, USA. */ + along with this program. If not, see . */ #include "defs.h" #include "serial.h" +#include "ser-base.h" +#include "ser-unix.h" + +#include "gdb_vfork.h" + #include -#ifdef HAVE_SYS_WAIT_H -#include -#endif #include #include #include - -#include "signals.h" #include "gdb_string.h" -extern int (*ui_loop_hook) PARAMS ((int)); +#include -static int pipe_open PARAMS ((serial_t scb, const char *name)); -static void pipe_raw PARAMS ((serial_t scb)); -static int wait_for PARAMS ((serial_t scb, int timeout)); -static int pipe_readchar PARAMS ((serial_t scb, int timeout)); -static int pipe_setbaudrate PARAMS ((serial_t scb, int rate)); -static int pipe_setstopbits PARAMS ((serial_t scb, int num)); -static int pipe_write PARAMS ((serial_t scb, const char *str, int len)); -/* FIXME: static void pipe_restore PARAMS ((serial_t scb)); */ -static void pipe_close PARAMS ((serial_t scb)); -static serial_ttystate pipe_get_tty_state PARAMS ((serial_t scb)); -static int pipe_set_tty_state PARAMS ((serial_t scb, serial_ttystate state)); -static int pipe_return_0 PARAMS ((serial_t)); -static int pipe_noflush_set_tty_state PARAMS ((serial_t, serial_ttystate, - serial_ttystate)); -static void pipe_print_tty_state PARAMS ((serial_t, serial_ttystate)); - -extern void _initialize_ser_pipe PARAMS ((void)); - -#undef XMALLOC -#define XMALLOC(T) ((T*) xmalloc (sizeof (T))) +static int pipe_open (struct serial *scb, const char *name); +static void pipe_close (struct serial *scb); +extern void _initialize_ser_pipe (void); struct pipe_state { @@ -65,11 +46,9 @@ struct pipe_state /* Open up a raw pipe */ static int -pipe_open (scb, name) - serial_t scb; - const char *name; +pipe_open (struct serial *scb, const char *name) { -#if !defined(O_NONBLOCK) || !defined(F_GETFL) || !defined(F_SETFL) || !HAVE_SOCKETPAIR +#if !HAVE_SOCKETPAIR return -1; #else struct pipe_state *state; @@ -81,10 +60,17 @@ pipe_open (scb, name) * published in UNIX Review, Vol. 6, No. 8. */ int pdes[2]; + int err_pdes[2]; int pid; if (socketpair (AF_UNIX, SOCK_STREAM, 0, pdes) < 0) return -1; + if (socketpair (AF_UNIX, SOCK_STREAM, 0, err_pdes) < 0) + return -1; + /* Create the child process to run the command in. Note that the + apparent call to vfork() below *might* actually be a call to + fork() due to the fact that autoconf will ``#define vfork fork'' + on certain platforms. */ pid = vfork (); /* Error. */ @@ -92,9 +78,18 @@ pipe_open (scb, name) { close (pdes[0]); close (pdes[1]); + close (err_pdes[0]); + close (err_pdes[1]); return -1; } + if (fcntl (err_pdes[0], F_SETFL, O_NONBLOCK) == -1) + { + close (err_pdes[0]); + close (err_pdes[1]); + err_pdes[0] = err_pdes[1] = -1; + } + /* Child. */ if (pid == 0) { @@ -106,6 +101,13 @@ pipe_open (scb, name) close (pdes[1]); } dup2 (STDOUT_FILENO, STDIN_FILENO); + + if (err_pdes[0] != -1) + { + close (err_pdes[0]); + dup2 (err_pdes[1], STDERR_FILENO); + close (err_pdes[1]); + } #if 0 /* close any stray FD's - FIXME - how? */ /* POSIX.2 B.3.2.2 "popen() shall ensure that any streams @@ -114,7 +116,7 @@ pipe_open (scb, name) for (old = pidlist; old; old = old->next) close (fileno (old->fp)); /* don't allow a flush */ #endif - execl ("/bin/sh", "sh", "-c", name + 1, NULL); + execl ("/bin/sh", "sh", "-c", name, (char *) 0); _exit (127); } @@ -124,243 +126,17 @@ pipe_open (scb, name) state = XMALLOC (struct pipe_state); state->pid = pid; scb->fd = pdes[0]; + scb->error_fd = err_pdes[0]; scb->state = state; - /* Make it non-blocking */ - { - int flags = fcntl (scb->fd, F_GETFL, 0); - if (fcntl (scb->fd, F_SETFL, flags | O_NONBLOCK) < 0) - { - perror ("ser-pipe"); - pipe_close (scb); - return -1; - } - } - /* If we don't do this, GDB simply exits when the remote side dies. */ signal (SIGPIPE, SIG_IGN); return 0; #endif } -static serial_ttystate -pipe_get_tty_state (scb) - serial_t scb; -{ - /* return garbage */ - return xmalloc (sizeof (int)); -} - -static int -pipe_set_tty_state (scb, ttystate) - serial_t scb; - serial_ttystate ttystate; -{ - return 0; -} - -static int -pipe_return_0 (scb) - serial_t scb; -{ - return 0; -} - static void -pipe_raw (scb) - serial_t scb; -{ - return; /* Always in raw mode */ -} - -/* Wait for input on scb, with timeout seconds. Returns 0 on success, - otherwise SERIAL_TIMEOUT or SERIAL_ERROR. - - For termio{s}, we actually just setup VTIME if necessary, and let the - timeout occur in the read() in pipe_read(). - */ - -static int -wait_for (scb, timeout) - serial_t scb; - int timeout; -{ - int numfds; - struct timeval tv; - fd_set readfds, exceptfds; - - FD_ZERO (&readfds); - FD_ZERO (&exceptfds); - - tv.tv_sec = timeout; - tv.tv_usec = 0; - - FD_SET (scb->fd, &readfds); - FD_SET (scb->fd, &exceptfds); - - while (1) - { - if (timeout >= 0) - numfds = select (scb->fd + 1, &readfds, 0, &exceptfds, &tv); - else - numfds = select (scb->fd + 1, &readfds, 0, &exceptfds, 0); - - if (numfds <= 0) - { - if (numfds == 0) - return SERIAL_TIMEOUT; - else if (errno == EINTR) - continue; - else - return SERIAL_ERROR; /* Got an error from select or poll */ - } - - return 0; - } -} - -/* Read a character with user-specified timeout. TIMEOUT is number of seconds - to wait, or -1 to wait forever. Use timeout of 0 to effect a poll. Returns - char if successful. Returns -2 if timeout expired, EOF if line dropped - dead, or -3 for any other error (see errno in that case). */ - -static int -pipe_readchar (scb, timeout) - serial_t scb; - int timeout; -{ - int status; - int delta; - - if (scb->bufcnt-- > 0) - return *scb->bufp++; - - /* We have to be able to keep the GUI alive here, so we break the original - timeout into steps of 1 second, running the "keep the GUI alive" hook - each time through the loop. - - Also, timeout = 0 means to poll, so we just set the delta to 0, so we - will only go through the loop once. */ - - delta = (timeout == 0 ? 0 : 1); - while (1) - { - - /* N.B. The UI may destroy our world (for instance by calling - remote_stop,) in which case we want to get out of here as - quickly as possible. It is not safe to touch scb, since - someone else might have freed it. The ui_loop_hook signals that - we should exit by returning 1. */ - - if (ui_loop_hook) - { - if (ui_loop_hook (0)) - return SERIAL_TIMEOUT; - } - - status = wait_for (scb, delta); - timeout -= delta; - - /* If we got a character or an error back from wait_for, then we can - break from the loop before the timeout is completed. */ - - if (status != SERIAL_TIMEOUT) - { - break; - } - - /* If we have exhausted the original timeout, then generate - a SERIAL_TIMEOUT, and pass it out of the loop. */ - - else if (timeout == 0) - { - status = SERIAL_TIMEOUT; - break; - } - } - - if (status < 0) - return status; - - while (1) - { - scb->bufcnt = read (scb->fd, scb->buf, BUFSIZ); - if (scb->bufcnt != -1 || errno != EINTR) - break; - } - - if (scb->bufcnt <= 0) - { - if (scb->bufcnt == 0) - return SERIAL_TIMEOUT; /* 0 chars means timeout [may need to - distinguish between EOF & timeouts - someday] */ - else - return SERIAL_ERROR; /* Got an error from read */ - } - - scb->bufcnt--; - scb->bufp = scb->buf; - return *scb->bufp++; -} - -static int -pipe_noflush_set_tty_state (scb, new_ttystate, old_ttystate) - serial_t scb; - serial_ttystate new_ttystate; - serial_ttystate old_ttystate; -{ - return 0; -} - -static void -pipe_print_tty_state (scb, ttystate) - serial_t scb; - serial_ttystate ttystate; -{ - /* Nothing to print. */ - return; -} - -static int -pipe_setbaudrate (scb, rate) - serial_t scb; - int rate; -{ - return 0; /* Never fails! */ -} - -static int -pipe_setstopbits (scb, num) - serial_t scb; - int num; -{ - return 0; /* Never fails! */ -} - -static int -pipe_write (scb, str, len) - serial_t scb; - const char *str; - int len; -{ - int cc; - - while (len > 0) - { - cc = write (scb->fd, str, len); - - if (cc < 0) - return 1; - len -= cc; - str += cc; - } - return 0; -} - -static void -pipe_close (scb) - serial_t scb; +pipe_close (struct serial *scb) { struct pipe_state *state = scb->state; if (state != NULL) @@ -368,36 +144,39 @@ pipe_close (scb) int pid = state->pid; close (scb->fd); scb->fd = -1; - free (state); + xfree (state); scb->state = NULL; kill (pid, SIGTERM); /* Might be useful to check that the child does die. */ } } -static struct serial_ops pipe_ops = -{ - "pipe", - 0, - pipe_open, - pipe_close, - pipe_readchar, - pipe_write, - pipe_return_0, /* flush output */ - pipe_return_0, /* flush input */ - pipe_return_0, /* send break */ - pipe_raw, - pipe_get_tty_state, - pipe_set_tty_state, - pipe_print_tty_state, - pipe_noflush_set_tty_state, - pipe_setbaudrate, - pipe_setstopbits, - pipe_return_0, /* wait for output to drain */ -}; +static struct serial_ops pipe_ops; void -_initialize_ser_pipe () +_initialize_ser_pipe (void) { - serial_add_interface (&pipe_ops); + struct serial_ops *ops = XMALLOC (struct serial_ops); + memset (ops, 0, sizeof (struct serial_ops)); + ops->name = "pipe"; + ops->next = 0; + ops->open = pipe_open; + ops->close = pipe_close; + ops->readchar = ser_base_readchar; + ops->write = ser_base_write; + ops->flush_output = ser_base_flush_output; + ops->flush_input = ser_base_flush_input; + ops->send_break = ser_base_send_break; + ops->go_raw = ser_base_raw; + ops->get_tty_state = ser_base_get_tty_state; + ops->set_tty_state = ser_base_set_tty_state; + ops->print_tty_state = ser_base_print_tty_state; + ops->noflush_set_tty_state = ser_base_noflush_set_tty_state; + ops->setbaudrate = ser_base_setbaudrate; + ops->setstopbits = ser_base_setstopbits; + ops->drain_output = ser_base_drain_output; + ops->async = ser_base_async; + ops->read_prim = ser_unix_read_prim; + ops->write_prim = ser_unix_write_prim; + serial_add_interface (ops); }