summaryrefslogtreecommitdiff
path: root/common.c
diff options
context:
space:
mode:
Diffstat (limited to 'common.c')
-rw-r--r--common.c276
1 files changed, 276 insertions, 0 deletions
diff --git a/common.c b/common.c
new file mode 100644
index 0000000..7ce37a5
--- /dev/null
+++ b/common.c
@@ -0,0 +1,276 @@
+/* ************************************************************ *\
+ * *
+ * Common support routines for sockets *
+ * *
+ * James L. Peterson *
+ * Copyright (C) 1987 MCC
+ *
+ * Permission to use, copy, modify, distribute, and sell this software and its
+ * documentation for any purpose is hereby granted without fee, provided that
+ * the above copyright notice appear in all copies and that both that
+ * copyright notice and this permission notice appear in supporting
+ * documentation, and that the name of MCC not be used in
+ * advertising or publicity pertaining to distribution of the software without
+ * specific, written prior permission. MCC makes no
+ * representations about the suitability of this software for any purpose. It
+ * is provided "as is" without express or implied warranty.
+ *
+ * MCC DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE,
+ * INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO
+ * EVENT SHALL MCC BE LIABLE FOR ANY SPECIAL, INDIRECT OR
+ * CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE,
+ * DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
+ * TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+ * PERFORMANCE OF THIS SOFTWARE.
+ * *
+ \* *********************************************************** */
+
+#include "scope.h"
+
+/* ********************************************** */
+/* */
+/* Debugging support routines */
+/* */
+/* ********************************************** */
+
+enterprocedure(s)
+ char *s;
+{
+ debug(2,(stderr, "-> %s\n", s));
+}
+
+warn(s)
+ char *s;
+{
+ fprintf(stderr, "####### %s\n", s);
+}
+
+panic(s)
+ char *s;
+{
+ fprintf(stderr, "%s\n", s);
+ exit(1);
+}
+
+/* ********************************************** */
+/* */
+/* Debugging forms of memory management */
+/* */
+/* ********************************************** */
+
+extern char *malloc();
+
+char *Malloc (n)
+ long n;
+{
+ char *p;
+ p = (char *)malloc((unsigned int)n);
+ debug(64,(stderr, "%x = malloc(%d)\n", p, n));
+ if (p == NULL)
+ panic("no more malloc space");
+ return(p);
+}
+
+Free(p)
+ char *p;
+{
+ debug(64,(stderr, "%x = free\n", p));
+ free(p);
+}
+
+
+
+/* ************************************************************ */
+/* */
+/* Signal Handling support */
+/* */
+/* ************************************************************ */
+
+#include <signal.h>
+
+#ifdef SIGURG
+void SignalURG(int dummy)
+{
+ debug(1,(stderr, "==> SIGURG received\n"));
+}
+#endif /* #ifdef SIGURG */
+
+#ifdef SIGPIPE
+void SignalPIPE(int dummy)
+{
+ debug(1,(stderr, "==> SIGPIPE received\n"));
+}
+#endif /* #ifdef SIGPIPE */
+
+#ifdef SIGINT
+void SignalINT(int dummy)
+{
+ debug(1,(stderr, "==> SIGINT received\n"));
+ exit(1);
+#endif /* #ifdef SIGINT */
+}
+
+#ifdef SIGQUIT
+void SignalQUIT(int dummy)
+{
+ debug(1,(stderr, "==> SIGQUIT received\n"));
+ exit(1);
+#endif /* #ifdef SIGQUIT */
+}
+
+#ifdef SIGTERM
+void SignalTERM(int dummy)
+{
+ debug(1,(stderr, "==> SIGTERM received\n"));
+ exit(1);
+#endif /* #ifdef SIGTERM */
+}
+
+#ifdef SIGTSTP
+void SignalTSTP(int dummy)
+{
+ debug(1,(stderr, "==> SIGTSTP received\n"));
+}
+#endif /* #ifdef SIGTSTP */
+
+#ifdef SIGCONT
+void SignalCONT(int dummy)
+{
+ debug(1,(stderr, "==> SIGCONT received\n"));
+}
+#endif /* #ifdef SIGCONT */
+
+SetSignalHandling()
+{
+ enterprocedure("SetSignalHandling");
+#ifdef SIGURG
+ (void)signal(SIGURG, SignalURG);
+#endif /* #ifdef SIGURG */
+#ifdef SIGPIPE
+ (void)signal(SIGPIPE, SignalPIPE);
+#endif /* #ifdef SIGPIPE */
+#ifdef SIGINT
+ (void)signal(SIGINT, SignalINT);
+#endif /* #ifdef SIGINT */
+#ifdef SIGQUIT
+ (void)signal(SIGQUIT, SignalQUIT);
+#endif /* #ifdef SIGQUIT */
+#ifdef SIGTERM
+ (void)signal(SIGTERM, SignalTERM);
+#endif /* #ifdef SIGTERM */
+#ifdef SIGTSTP
+ (void)signal(SIGTSTP, SignalTSTP);
+#endif /* #ifdef SIGTSTP */
+#ifdef SIGCONT
+ (void)signal(SIGCONT, SignalCONT);
+#endif /* #ifdef SIGCONT */
+}
+
+
+
+/* ************************************************************ */
+/* */
+/* Create a socket for a service to listen for clients */
+/* */
+/* ************************************************************ */
+
+#include <sys/types.h> /* needed by sys/socket.h and netinet/in.h */
+#include <sys/uio.h> /* for struct iovec, used by socket.h */
+#include <sys/socket.h> /* for AF_INET, SOCK_STREAM, ... */
+#include <sys/ioctl.h> /* for FIONCLEX, FIONBIO, ... */
+#include <netinet/in.h> /* struct sockaddr_in */
+#include <netdb.h> /* struct servent * and struct hostent * */
+
+static int ON = 1 /* used in ioctl */ ;
+#define BACKLOG 5
+
+/* for use in the UsingFD call -- defined later */
+extern int NewConnection ();
+
+
+SetUpConnectionSocket(port)
+ int port;
+{
+ FD ConnectionSocket;
+ struct sockaddr_in sin;
+#ifndef SO_DONTLINGER
+ struct linger linger;
+#endif /* #ifndef SO_DONTLINGER */
+
+ enterprocedure("SetUpConnectionSocket");
+
+ /* create the connection socket and set its parameters of use */
+ ConnectionSocket = socket(AF_INET, SOCK_STREAM, 0);
+ if (ConnectionSocket < 0)
+ {
+ perror("socket");
+ exit(-1);
+ }
+ (void)setsockopt(ConnectionSocket, SOL_SOCKET, SO_REUSEADDR, (char *)NULL, 0);
+#ifdef SO_USELOOPBACK
+ (void)setsockopt(ConnectionSocket, SOL_SOCKET, SO_USELOOPBACK, (char *)NULL, 0);
+#endif /* #ifdef SO_USELOOPBACK */
+#ifdef SO_DONTLINGER
+ (void)setsockopt(ConnectionSocket, SOL_SOCKET, SO_DONTLINGER, (char *)NULL, 0);
+#else /* #ifdef SO_DONTLINGER */
+ linger.l_onoff = 0;
+ linger.l_linger = 0;
+ (void)setsockopt(ConnectionSocket, SOL_SOCKET, SO_LINGER, (char *)&linger, sizeof linger);
+#endif /* #ifdef SO_DONTLINGER */
+
+ /* define the name and port to be used with the connection socket */
+ bzero((char *)&sin, sizeof(sin));
+ sin.sin_family = AF_INET;
+
+ /* the address of the socket is composed of two parts: the host machine and
+ the port number. We need the host machine address for the current host
+ */
+ {
+ /* define the host part of the address */
+ char MyHostName[256];
+ struct hostent *hp;
+
+ (void) gethostname(MyHostName, sizeof(MyHostName));
+ ScopeHost = (char *) Malloc((long)(1+strlen(MyHostName)));
+ (void)strcpy(ScopeHost, MyHostName);
+ hp = gethostbyname(MyHostName);
+ if (hp == NULL)
+ panic("No address for our host");
+ bcopy((char *)hp->h_addr, (char*)&sin.sin_addr, hp->h_length);
+ }
+ /* new code -- INADDR_ANY should be better than using the name of the
+ host machine. The host machine may have several different network
+ addresses. INADDR_ANY should work with all of them at once. */
+ sin.sin_addr.s_addr = INADDR_ANY;
+
+ sin.sin_port = htons(port);
+ ScopePort = port;
+
+ /* bind the name and port number to the connection socket */
+ if (bind(ConnectionSocket, (struct sockaddr *)&sin, sizeof(sin)) < 0)
+ {
+ perror("bind");
+ exit(-1);
+ }
+
+ debug(4,(stderr, "Socket is FD %d for %s,%d\n",
+ ConnectionSocket, ScopeHost, ScopePort));
+
+ /* now activate the named connection socket to get messages */
+ if (listen(ConnectionSocket, BACKLOG) < 0)
+ {
+ perror("listen");
+ exit(-1);
+ };
+
+ /* a few more parameter settings */
+#ifdef FIOCLEX
+ (void)ioctl(ConnectionSocket, FIOCLEX, 0);
+#endif /* #ifdef FIOCLEX */
+ (void)ioctl(ConnectionSocket, FIONBIO, &ON);
+
+ debug(4,(stderr, "Listening on FD %d\n", ConnectionSocket));
+ UsingFD(ConnectionSocket, NewConnection);
+}
+
+
generated by cgit v1.2.1 (git 2.18.0) at 2024-05-11 16:53:00 +0000