X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=src%2Fsel.c;fp=src%2Fsel.c;h=2d8972f23ca02b7da2759797566b8304d5e62aad;hb=8804833a62667fe6a33655351790b241256e5980;hp=0000000000000000000000000000000000000000;hpb=a6d0720c825ae5d7233025c96e0f04ac48d5b811;p=spider.git

diff --git a/src/sel.c b/src/sel.c
new file mode 100755
index 00000000..2d8972f2
--- /dev/null
+++ b/src/sel.c
@@ -0,0 +1,214 @@
+/*
+ * sel.c
+ * 
+ * util routines for do the various select activities
+ * 
+ * Copyright 1996 (c) D-J Koopman
+ * 
+ * $Header$
+ */
+ 
+
+static char rcsid[] = "$Id$";
+
+#include <sys/time.h>
+#include <sys/types.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <time.h>
+#include <string.h>
+#include <errno.h>
+
+#include "chain.h"
+#include "sel.h"
+
+sel_t *sel;							   /* the array of selectors */
+int sel_max;						   /* the maximum no of selectors */
+int sel_top;						   /* the last selector in use */
+int sel_inuse;						   /* the no of selectors in use */
+time_t sel_systime;					   /* the unix time now */
+struct timeval sel_tv;				   /* the current timeout for select */
+
+/*
+ * initialise the selector system, no is the no of slots to reserve
+ */
+
+void sel_init(int no, long sec, long usec)
+{
+	sel = malloc(sizeof(sel_t) * no);
+	if (!sel)
+		die("no room in sel_init");
+	memset(sel, 0, sizeof(sel_t) * no);
+	sel_max = no;
+	sel_inuse = sel_top = 0;
+	if (sec == 0 && usec == 0) 
+		usec = 10000;
+	sel_tv.tv_sec = sec;
+	sel_tv.tv_usec = usec;
+}
+
+/*
+ * open and initialise a selector slot, you are expected to deal with the
+ * actual opening and setting up of the device itself
+ */
+
+sel_t *sel_open(int cnum, void *fcb, char *name, int (*handler)(), int sort, int flags)
+{
+	int i;
+	sel_t *sp;
+	
+	/* get a free slot */
+	for (i = 0; i < sel_max; ++i) {
+		sp = &sel[i];
+		if (sp->sort == 0)
+			break;
+	}
+	if (i >= sel_max)
+		die("there are no more sel slots available (max %d)", sel_max);
+	
+	/* fill in the blanks */
+	sp->cnum = cnum;
+	sp->fcb = fcb;
+	sp->name = strdup(name);
+	sp->handler = handler;
+	sp->sort = sort;
+	sp->flags = flags;
+	sp->msgbase = chain_new();
+	sp->err = 0;
+	++sel_inuse;
+	if (sel_top < (sp - sel) + 1)
+		sel_top = (sp - sel) + 1;
+	return sp;
+}
+
+/*
+ * close (and thus clear down) a slot, it is assumed that you have done whatever
+ * you need to do to close the actual device already
+ */
+
+void sel_close(sel_t *sp)
+{
+	if (sp->sort) {
+		chain_flush(sp->msgbase);
+		free(sp->msgbase);
+		free(sp->name);
+		memset(sp, 0, sizeof(sel_t));
+		if (sel_top == (sp - sel) + 1)
+			--sel_top;
+		--sel_inuse;
+	}
+}
+
+/*
+ * this actually runs the (de)multiplexor, it simply listens to the various cnums 
+ * presents the events to the handler which has to deal with them
+ */
+
+void sel_run()
+{
+	int i, r, max = 0;
+	struct timeval tv;
+	fd_set infd;
+	fd_set outfd;
+	fd_set errfd;
+	sel_t *sp;
+	
+	/* first set up the parameters for the select according to the slots registered */
+	FD_ZERO(&infd);
+	FD_ZERO(&outfd);
+	FD_ZERO(&errfd);
+	tv = sel_tv;
+	
+	for (i = 0; i < sel_top; ++i) {
+		sp = &sel[i];
+		if (sp->sort && !sp->err) {
+			if (sp->flags & SEL_INPUT)
+				FD_SET(sp->cnum, &infd);
+			if (sp->flags & SEL_OUTPUT)
+				FD_SET(sp->cnum, &outfd);
+			if (sp->flags & SEL_ERROR)
+				FD_SET(sp->cnum, &errfd);
+			if (sp->cnum > max)
+				max = sp->cnum;
+		}
+	}
+	
+	/* now do the select */
+	r = select(max + 1, &infd, &outfd, &errfd, &tv);
+
+	if (r < 0) {
+		if (errno != EINTR)
+			die("Error during select (%d)", errno);
+		return;
+	}
+
+	/* if there is anything to do, pass it on to the appropriate handler */
+	if (r > 0) {
+		int in, out, err;
+		int hr;
+		
+		for (i = 0; i < sel_top; ++i) {
+			sp = &sel[i];
+			if (sp->sort) {
+				in = FD_ISSET(sp->cnum, &infd);
+				out = FD_ISSET(sp->cnum, &outfd);
+				err = FD_ISSET(sp->cnum, &errfd);
+				if (in || out || err) {
+					hr = (sp->handler)(sp, in, out, err);
+					
+					/* if this is positive, close this selector */
+					if (hr)
+						sel_close(sp);
+					else {
+						FD_CLR(sp->cnum, &infd);
+						FD_CLR(sp->cnum, &outfd);
+						FD_CLR(sp->cnum, &errfd);
+					}
+				}
+			}
+		}
+	}
+	
+	time(&sel_systime);				   /* note the time, for general purpuse use */
+}
+
+/*
+ * get/set error flag - -1 simply gets the flag, 0 or 1 sets the flag
+ * 
+ * in all cases the old setting of the flag is returned
+ */
+
+int sel_error(sel_t *sp, int err)
+{
+	int r = sp->err;
+	if (err >= 0)
+		sp->err = err;
+	return err;
+}
+
+/*
+ * $Log$
+ * Revision 1.1  2000-03-26 00:03:30  djk
+ * first cut of client
+ *
+ * Revision 1.3  1998/01/02 19:39:59  djk
+ * made various changes to cope with glibc
+ * fixed problem with extended status in etsi_router
+ *
+ * Revision 1.2  1997/06/18 18:44:31  djk
+ * A working hayes implementation!
+ *
+ * Revision 1.1  1997/01/28 16:14:38  djk
+ * moved these into lib as general routines to use with sel
+ *
+ * Revision 1.3  1997/01/15 21:23:26  djk
+ * fixed a few minor svlp problems and added the router logging system
+ *
+ * Revision 1.2  1997/01/13 23:34:56  djk
+ * The first working test version of smsd
+ *
+ * Revision 1.1  1997/01/03 23:44:31  djk
+ * initial workings
+ *
+ *
+ */