summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--remote-cstms.c206
1 files changed, 206 insertions, 0 deletions
diff --git a/remote-cstms.c b/remote-cstms.c
new file mode 100644
index 0000000..b940439
--- /dev/null
+++ b/remote-cstms.c
@@ -0,0 +1,206 @@
+/* This file implements an interface to the Customs daemon to do
+ remote execution of commands under GNU make.
+ THIS CODE IS NOT SUPPORTED BY THE GNU PROJECT.
+ Please do not send bug reports or questions about it to
+ the Make maintainers.
+
+Copyright (C) 1988, 1989 Free Software Foundation, Inc.
+This file is part of GNU Make.
+
+GNU Make 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, or (at your option)
+any later version.
+
+GNU Make is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY 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
+along with GNU Make; see the file COPYING. If not, write to
+the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA. */
+
+#include "make.h"
+#include "commands.h"
+#include "customs.h"
+#include <sys/time.h>
+
+
+char *remote_description = "Customs";
+
+
+/* ExportPermit gotten by start_remote_job_p, and used by start_remote_job. */
+static ExportPermit permit;
+
+/* Return nonzero if the next job should be done remotely. */
+
+int
+start_remote_job_p ()
+{
+ if (Customs_Host (EXPORT_SAME, &permit) != RPC_SUCCESS)
+ return 0;
+
+ return !CUSTOMS_FAIL (&permit.addr);
+}
+
+/* Start a remote job running the command in ARGV.
+ It gets standard input from STDIN_FD. On failure,
+ return nonzero. On success, return zero, and set
+ *USED_STDIN to nonzero if it will actually use STDIN_FD,
+ zero if not, set *ID_PTR to a unique identification, and
+ set *IS_REMOTE to zero if the job is local, nonzero if it
+ is remote (meaning *ID_PTR is a process ID). */
+
+int
+start_remote_job (argv, stdin_fd, is_remote, id_ptr, used_stdin)
+ char **argv;
+ int stdin_fd;
+ int *is_remote;
+ int *id_ptr;
+ int *used_stdin;
+{
+ extern char **environ;
+ extern int vfork (), execve ();
+ PATH_VAR (cwd);
+ char waybill[MAX_DATA_SIZE], msg[128];
+ struct timeval timeout;
+ struct sockaddr_in sin;
+ int len;
+ int retsock, retport, sock;
+ Rpc_Stat status;
+ int pid;
+
+ /* Find the current directory. */
+ if (getwd (cwd) == 0)
+ {
+ error ("exporting: getwd: %s", cwd);
+ return 1;
+ }
+
+ /* Create the return socket. */
+ retsock = Rpc_UdpCreate (True, 0);
+ if (retsock < 0)
+ {
+ error ("exporting: Couldn't create return socket.");
+ return 1;
+ }
+
+ /* Get the return socket's port number. */
+ len = sizeof(sin);
+ if (getsockname (retsock, (struct sockaddr *) &sin, &len) < 0)
+ {
+ (void) close (retsock);
+ perror_with_name ("exporting: ", "getsockname");
+ return 1;
+ }
+ retport = sin.sin_port;
+
+ /* Create the TCP socket for talking to the remote child. */
+ sock = Rpc_TcpCreate (False, 0);
+
+ /* Create a WayBill to give to the server. */
+ len = Customs_MakeWayBill (&permit, cwd, argv[0], argv,
+ environ, retport, waybill);
+
+ /* Send the request to the server, timing out in 20 seconds. */
+ timeout.tv_usec = 0;
+ timeout.tv_sec = 20;
+ sin.sin_family = AF_INET;
+ sin.sin_port = htons (Customs_Port ());
+ sin.sin_addr = permit.addr;
+ status = Rpc_Call (sock, &sin, (Rpc_Proc) CUSTOMS_IMPORT,
+ len, (Rpc_Opaque) waybill,
+ sizeof(msg), (Rpc_Opaque) msg,
+ 1, &timeout);
+ if (status != RPC_SUCCESS)
+ {
+ (void) close (retsock);
+ (void) close (sock);
+ error ("exporting: %s", Rpc_ErrorMessage (status));
+ return 1;
+ }
+ else if (msg[0] != 'O' || msg[1] != 'k' || msg[2] != '\0')
+ {
+ (void) close (retsock);
+ (void) close (sock);
+ error ("CUSTOMS_IMPORT: %s", msg);
+ return 1;
+ }
+
+ fflush (stdout);
+ fflush (stderr);
+
+ pid = vfork ();
+ if (pid < 0)
+ {
+ /* The fork failed! */
+ perror_with_name ("vfork", "");
+ return 1;
+ }
+ else if (pid == 0)
+ {
+ /* Child side. Run `export' to handle the connection. */
+ static char sock_buf[20], retsock_buf[20], id_buf[20];
+ static char *new_argv[6] =
+ { "export", "-id", sock_buf, retsock_buf, id_buf, 0 };
+
+ /* Set up the arguments. */
+ (void) sprintf (sock_buf, "%d", sock);
+ (void) sprintf (retsock_buf, "%d", retsock);
+ (void) sprintf (id_buf, "%x", permit.id);
+
+ /* Run the command. */
+ (void) execvp (new_argv[0], new_argv);
+ perror_with_name ("execvp: ", new_argv[0]);
+ _exit (127);
+ }
+
+ /* Parent side. Return the `export' process's ID. */
+ (void) close (retsock);
+ (void) close (sock);
+ *is_remote = 0;
+ *id_ptr = pid;
+ return 0;
+}
+
+/* Get the status of a dead remote child. Block waiting for one to die
+ if BLOCK is nonzero. Set *EXIT_CODE_PTR to the exit status, *SIGNAL_PTR
+ to the termination signal or zero if it exited normally, and *COREDUMP_PTR
+ nonzero if it dumped core. Return the ID of the child that died,
+ 0 if we would have to block and !BLOCK, or < 0 if there were none. */
+
+int
+remote_status (exit_code_ptr, signal_ptr, coredump_ptr, block)
+ int *exit_code_ptr, *signal_ptr, *coredump_ptr;
+ int block;
+{
+ return -1;
+}
+
+/* Block asynchronous notification of remote child death.
+ If this notification is done by raising the child termination
+ signal, do not block that signal. */
+void
+block_remote_children ()
+{
+ return;
+}
+
+/* Restore asynchronous notification of remote child death.
+ If this is done by raising the child termination signal,
+ do not unblock that signal. */
+void
+unblock_remote_children ()
+{
+ return;
+}
+
+/* Send signal SIG to child ID. Return 0 if successful, -1 if not. */
+int
+remote_kill (id, sig)
+ int id;
+ int sig;
+{
+ return -1;
+}