* *
* C Implementation File *
* *
- * $Revision$
- * *
- * Copyright (C) 2001-2002 Ada Core Technologies, Inc. *
+ * Copyright (C) 2001-2009, AdaCore *
* *
* GNAT is free software; you can redistribute it and/or modify it under *
* terms of the GNU General Public License as published by the Free Soft- *
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License *
* for more details. You should have received a copy of the GNU General *
* Public License distributed with GNAT; see file COPYING. If not, write *
- * to the Free Software Foundation, 59 Temple Place - Suite 330, Boston, *
- * MA 02111-1307, USA. *
+ * to the Free Software Foundation, 51 Franklin Street, Fifth Floor, *
+ * Boston, MA 02110-1301, USA. *
* *
* As a special exception, if you link this file with other files to *
* produce an executable, this file does not by itself cause the resulting *
* file might be covered by the GNU Public License. *
* *
* GNAT was originally developed by the GNAT team at New York University. *
- * It is now maintained by Ada Core Technologies Inc (http://www.gnat.com). *
+ * Extensive contributions were provided by Ada Core Technologies Inc. *
* *
****************************************************************************/
#include "system.h"
#endif
+#include <sys/types.h>
+
+#ifdef __MINGW32__
+#if OLD_MINGW
+#include <sys/wait.h>
+#endif
+#elif defined (__vxworks) && defined (__RTP__)
+#include <wait.h>
+#elif defined (__Lynx__)
+/* ??? See comment in adaint.c. */
+#define GCC_RESOURCE_H
+#include <sys/wait.h>
+#elif defined (__nucleus__)
+/* No wait.h available on Nucleus */
+#else
+#include <sys/wait.h>
+#endif
+
/* This file provides the low level functionalities needed to implement Expect
capabilities in GNAT.Expect.
Implementations for unix and windows systems is provided.
Dummy stubs are also provided for other systems. */
#ifdef _AIX
-/* Work around the fact that gcc/cpp does not define "unix" under AiX. */
-#define unix
+/* Work around the fact that gcc/cpp does not define "__unix__" under AiX. */
+#define __unix__
+#endif
+
+#ifdef __APPLE__
+/* Work around the fact that gcc/cpp does not define "__unix__" on Darwin. */
+#define __unix__
#endif
#ifdef _WIN32
#include <windows.h>
#include <process.h>
-
-/* ??? Provide a no-op for now */
+#include <signal.h>
+#include <io.h>
+#include "mingw32.h"
void
-kill ()
+__gnat_kill (int pid, int sig, int close)
{
+ HANDLE h = OpenProcess (PROCESS_ALL_ACCESS, FALSE, pid);
+ if (h == NULL)
+ return;
+ if (sig == 9)
+ {
+ TerminateProcess (h, 0);
+ __gnat_win32_remove_handle (NULL, pid);
+ }
+ else if (sig == SIGINT)
+ GenerateConsoleCtrlEvent (CTRL_C_EVENT, pid);
+ else if (sig == SIGBREAK)
+ GenerateConsoleCtrlEvent (CTRL_BREAK_EVENT, pid);
+ /* ??? The last two alternatives don't really work. SIGBREAK requires setting
+ up process groups at start time which we don't do; treating SIGINT is just
+ not possible apparently. So we really only support signal 9. Fortunately
+ that's all we use in GNAT.Expect */
+
+ CloseHandle (h);
+}
+
+int
+__gnat_waitpid (int pid)
+{
+ HANDLE h = OpenProcess (PROCESS_ALL_ACCESS, FALSE, pid);
+ DWORD exitcode = 1;
+ DWORD res;
+
+ if (h != NULL)
+ {
+ res = WaitForSingleObject (h, INFINITE);
+ GetExitCodeProcess (h, &exitcode);
+ CloseHandle (h);
+ }
+
+ __gnat_win32_remove_handle (NULL, pid);
+ return (int) exitcode;
}
int
-__gnat_expect_fork ()
+__gnat_expect_fork (void)
{
return 0;
}
void
-__gnat_expect_portable_execvp (pid, cmd, argv)
- int *pid;
- char *cmd;
- char *argv[];
+__gnat_expect_portable_execvp (int *pid, char *cmd, char *argv[])
{
- *pid = (int) spawnve (_P_NOWAIT, cmd, argv, NULL);
+ *pid = __gnat_portable_no_block_spawn (argv);
}
int
-__gnat_pipe (fd)
- int *fd;
+__gnat_pipe (int *fd)
{
HANDLE read, write;
CreatePipe (&read, &write, NULL, 0);
- fd[0]=_open_osfhandle (read, 0);
- fd[1]=_open_osfhandle (write, 0);
+ fd[0]=_open_osfhandle ((intptr_t)read, 0);
+ fd[1]=_open_osfhandle ((intptr_t)write, 0);
return 0; /* always success */
}
int
-__gnat_expect_poll (fd, num_fd, timeout, is_set)
- int *fd;
- int num_fd;
- int timeout;
- int *is_set;
+__gnat_expect_poll (int *fd, int num_fd, int timeout, int *is_set)
{
- int i, num;
+#define MAX_DELAY 100
+
+ int i, delay, infinite = 0;
DWORD avail;
HANDLE handles[num_fd];
is_set[i] = 0;
for (i = 0; i < num_fd; i++)
- handles[i] = (HANDLE) _get_osfhandle (fd[i]);
+ handles[i] = (HANDLE) _get_osfhandle (fd [i]);
+
+ /* Start with small delays, and then increase them, to avoid polling too
+ much when waiting a long time */
+ delay = 5;
- num = timeout / 50;
+ if (timeout < 0)
+ infinite = 1;
while (1)
{
for (i = 0; i < num_fd; i++)
- {
- if (!PeekNamedPipe (handles[i], NULL, 0, NULL, &avail, NULL))
- return -1;
+ {
+ if (!PeekNamedPipe (handles [i], NULL, 0, NULL, &avail, NULL))
+ return -1;
- if (avail > 0)
- {
- is_set[i] = 1;
- return 1;
- }
- }
+ if (avail > 0)
+ {
+ is_set[i] = 1;
+ return 1;
+ }
+ }
- if (timeout >= 0 && num == 0)
- return 0;
+ if (!infinite && timeout <= 0)
+ return 0;
- Sleep (50);
- num--;
+ Sleep (delay);
+ timeout -= delay;
+
+ if (delay < MAX_DELAY)
+ delay += 10;
}
}
#include <unixio.h>
#include <stdlib.h>
#include <string.h>
-#include <descrip.h>
+#include <vms/descrip.h>
#include <stdio.h>
-#include <stsdef.h>
-#include <iodef.h>
+#include <vms/stsdef.h>
+#include <vms/iodef.h>
+#include <signal.h>
+
+void
+__gnat_kill (int pid, int sig, int close)
+{
+ kill (pid, sig);
+}
+
+int
+__gnat_waitpid (int pid)
+{
+ int status = 0;
+
+ waitpid (pid, &status, 0);
+ status = WEXITSTATUS (status);
+
+ return status;
+}
int
-__gnat_pipe (fd)
- int *fd;
+__gnat_pipe (int *fd)
{
return pipe (fd);
}
int
-__gnat_expect_fork ()
+__gnat_expect_fork (void)
{
return -1;
}
void
-__gnat_expect_portable_execvp (pid, cmd, argv)
- int *pid;
- char *cmd;
- char *argv[];
+__gnat_expect_portable_execvp (int *pid, char *cmd, char *argv[])
{
- *pid = (int) getpid();
- /* Since cmd is fully qualified, it is incorrect to to call execvp */
+ *pid = (int) getpid ();
+ /* Since cmd is fully qualified, it is incorrect to call execvp */
execv (cmd, argv);
+ _exit (1);
}
int
-__gnat_expect_poll (fd, num_fd, timeout, is_set)
- int *fd;
- int num_fd;
- int timeout;
- int *is_set;
+__gnat_expect_poll (int *fd, int num_fd, int timeout, int *is_set)
{
int i, num, ready = 0;
unsigned int status;
mbxname.dsc$a_pointer = buf;
status = SYS$ASSIGN (&mbxname, &mbxchans[i], 0, 0, 0);
+
+ if ((status & 1) != 1)
+ {
+ ready = -1;
+ return ready;
+ }
}
}
(0, mbxchans[i], IO$_SENSEMODE|IO$M_READERCHECK,
&iosb, 0, 0, 0, 0, 0, 0, 0, 0);
+ if ((status & 1) != 1)
+ {
+ ready = -1;
+ goto deassign;
+ }
+
if (iosb.count > 0)
{
is_set[i] = 1;
}
}
- if (timeout >= 0 && num == 0)
+ if (timeout > 0 && num == 0)
{
ready = 0;
goto deassign;
return ready;
}
+#elif defined (__unix__) && !defined (__nucleus__)
-#elif defined (unix)
+#ifdef __hpux__
+#include <sys/ptyio.h>
+#endif
#include <sys/time.h>
#endif /* !_IBMR2 */
#endif /* !NO_FD_SET */
+void
+__gnat_kill (int pid, int sig, int close)
+{
+ kill (pid, sig);
+}
+
+int
+__gnat_waitpid (int pid)
+{
+ int status = 0;
+
+ waitpid (pid, &status, 0);
+ status = WEXITSTATUS (status);
+
+ return status;
+}
+
int
-__gnat_pipe (fd)
- int *fd;
+__gnat_pipe (int *fd)
{
return pipe (fd);
}
int
-__gnat_expect_fork ()
+__gnat_expect_fork (void)
{
return fork ();
}
void
-__gnat_expect_portable_execvp (pid, cmd, argv)
- int *pid;
- char *cmd;
- char *argv[];
+__gnat_expect_portable_execvp (int *pid, char *cmd, char *argv[])
{
- *pid = (int) getpid();
- execvp (cmd, argv);
+ *pid = (int) getpid ();
+ /* Since cmd is fully qualified, it is incorrect to call execvp */
+ execv (cmd, argv);
+ _exit (1);
}
int
-__gnat_expect_poll (fd, num_fd, timeout, is_set)
- int *fd;
- int num_fd;
- int timeout;
- int *is_set;
+__gnat_expect_poll (int *fd, int num_fd, int timeout, int *is_set)
{
struct timeval tv;
SELECT_MASK rset;
+ SELECT_MASK eset;
+
int max_fd = 0;
int ready;
int i;
-
- FD_ZERO (&rset);
-
- for (i = 0; i < num_fd; i++)
- {
- FD_SET (fd[i], &rset);
- if (fd[i] > max_fd)
- max_fd = fd[i];
- }
+ int received;
tv.tv_sec = timeout / 1000;
tv.tv_usec = (timeout % 1000) * 1000;
- ready = select (max_fd + 1, &rset, NULL, NULL, timeout == -1 ? NULL : &tv);
+ do {
+ FD_ZERO (&rset);
+ FD_ZERO (&eset);
- if (ready > 0)
for (i = 0; i < num_fd; i++)
- is_set[i] = (FD_ISSET (fd[i], &rset) ? 1 : 0);
+ {
+ FD_SET (fd[i], &rset);
+ FD_SET (fd[i], &eset);
+
+ if (fd[i] > max_fd)
+ max_fd = fd[i];
+ }
+
+ ready =
+ select (max_fd + 1, &rset, NULL, &eset, timeout == -1 ? NULL : &tv);
+
+ if (ready > 0)
+ {
+ received = 0;
+
+ for (i = 0; i < num_fd; i++)
+ {
+ if (FD_ISSET (fd[i], &rset))
+ {
+ is_set[i] = 1;
+ received = 1;
+ }
+ else
+ is_set[i] = 0;
+ }
+
+#ifdef __hpux__
+ for (i = 0; i < num_fd; i++)
+ {
+ if (FD_ISSET (fd[i], &eset))
+ {
+ struct request_info ei;
+
+ /* Only query and reset error state if no file descriptor
+ is ready to be read, otherwise we will be signalling a
+ died process too early */
+
+ if (!received)
+ {
+ ioctl (fd[i], TIOCREQCHECK, &ei);
+
+ if (ei.request == TIOCCLOSE)
+ {
+ ioctl (fd[i], TIOCREQSET, &ei);
+ return -1;
+ }
+
+ ioctl (fd[i], TIOCREQSET, &ei);
+ }
+ ready--;
+ }
+ }
+#endif
+ }
+ } while (timeout == -1 && ready == 0);
return ready;
}
#else
+void
+__gnat_kill (int pid, int sig, int close)
+{
+}
+
+int
+__gnat_waitpid (int pid, int sig)
+{
+ return 0;
+}
+
int
-__gnat_pipe (fd)
- int *fd;
+__gnat_pipe (int *fd)
{
return -1;
}
int
-__gnat_expect_fork ()
+__gnat_expect_fork (void)
{
return -1;
}
void
-__gnat_expect_portable_execvp (pid, cmd, argv)
- int *pid;
- char *cmd;
- char *argv[];
+__gnat_expect_portable_execvp (int *pid, char *cmd, char *argv[])
{
*pid = 0;
}
int
-__gnat_expect_poll (fd, num_fd, timeout, is_set)
- int *fd;
- int num_fd;
- int timeout;
- int *is_set;
+__gnat_expect_poll (int *fd, int num_fd, int timeout, int *is_set)
{
return -1;
}
OSDN Git Service
