diff options
| -rw-r--r-- | server/class.c | 186 | ||||
| -rw-r--r-- | server/common.c | 27 | ||||
| -rw-r--r-- | server/zserver.h | 24 |
3 files changed, 237 insertions, 0 deletions
diff --git a/server/class.c b/server/class.c new file mode 100644 index 0000000..43246ce --- /dev/null +++ b/server/class.c @@ -0,0 +1,186 @@ +/* Copyright (c) 1987 Massachusetts Institute of Technology */ + +/* + * $Source$ + * $Header$ + */ + +#ifndef lint +static char *rcsid_cm_c = "$Header$"; +#endif lint + +#include <zephyr/mit-copyright.h> +#include <zephyr/zephyr.h> +#include "zserver.h" + +/* + * Class manager subsystem. + * external functions are: + * Code_t cm_register(client, class) + * Code_t cm_deregister(client, class) + * struct qelem *cm_lookup(class) + * ZClientDesc_t *client; + * char *class; + */ + +/* Private variables */ +typedef struct _ZClientList_t { + struct _ZClientList_t *q_forw; + struct _ZClientList_t *q_back; + ZClientDesc_t *client; +} ZClientList_t; + +typedef struct _ZClass_t { + struct _ZClass_t *q_forw; + struct _ZClass_t *q_back; + char *classname; + ZClientList_t *clientlist; +} ZClass_t; + + +#define NULLZCT ((ZClass_t *) 0) +#define NULLZCDT ((ZClientDesc_t *) 0) +#define NULLZCLT ((ZClientList_t *) 0) + +#define EMPTY_CLASS 2000 + +#define HSHSIZ 8192 +#define HSHMUL 243 + +static ZClass_t *class_bucket[511]; + +/* private routines */ +static ZClass_t *class_alloc(class) +char *class; +{ + register ZClass_t *ptr; + if ((ptr = (ZClass_t *) malloc(sizeof(ZClass_t))) == NULLZCT) + return(NULLZCT); + + if ((ptr->classname = strsave(class)) == NULL) { + free((char *) ptr); + return(NULLZCT); + } + return(ptr); +} + +static ZClientList_t *client_alloc(client) +ZClientDesc_t *client; +{ + register ZClientList_t *ptr; + if ((ptr = (ZClientList_t *) malloc(sizeof(ZClientList_t))) == NULLZCLT) + return(NULLZCLT); + + ptr->client = client; + return(ptr); +} + +static Code_t insert_client(ptr, client) +ZClass_t *ptr; +ZClientDesc_t *client; +{ + register ZClientList_t *listp; + + if ((listp = client_alloc(client)) == NULLZCLT) + return(ZERR_UNIX); + if (ptr->clientlist == NULLZCLT) + ptr->clientlist = listp; + else + insque(listp, ptr->clientlist); + return(ZERR_NONE); +} + +static Code_t remove_client(ptr, client) +ZClass_t *ptr; +ZClientDesc_t *client; +{ + register ZClientList_t *listp = ptr->clientlist; + register ZClientList_t *listp2; + + if (listp->client == client) { /* found him */ + if (listp->q_forw = listp) { /* this is the only elem on this queue */ + ptr->clientlist = NULLZCLT; + free(listp); + return(EMPTY_CLASS); + } + /* ok, remove him, being careful to reset the pointer to the queue */ + ptr->clientlist = listp->q_forw; + remque(listp); + free(listp); + return(ZERR_NONE); + } else { + for (listp2 = listp->q_forw; listp2 != listp; listp2 = listp2->q_forw) + /* walk down list, looking for him */ + if (listp2->client == client) { + reqmue(listp); + free(listp); + return(ZERR_NONE); + } + return(ZERR_S_BADASSOC); + } +} + +/* */ +/* public routines */ +Code_t cm_register(client, class) +ZClientDesc_t *client; +char *class; +{ + register ZClass_t *ptr, *ptr2; + int hashval = hash(class); + + if ((ptr = class_bucket[hashval]) == NULLZCT) { + /* not registered */ + + if ((ptr = class_alloc(class)) == NULLZCT) + return(ZERR_UNIX); + + class_bucket[hashval] = ptr; + return(insert_client(ptr, client)); + + } else if (!strcmp(ptr->classname, class)) /* match! */ + return(insert_client(ptr, client)); + else { + for (ptr2 = ptr->q_forw; ptr2 != ptr; ptr2 = ptr2->q_forw) { + /* walk down the list, looking for a match */ + if (!strcmp(ptr2->classname, class)) + return(insert_client(ptr2, client)); + } + if (ptr2 = ptr) { /* fell off the end, no match */ + if ((ptr2 = class_alloc(class)) == NULLZCT) + return(ZERR_UNIX); + insque(ptr2, ptr); /* insert new class into hash bucket */ + return(insert_client(ptr2, client)); + } + } +} + +Code_t cm_deregister(client, class) +ZClientDesc_t *client; +char *class; +{ + register ZClass_t *ptr, *ptr2; + int retval = -1; + int hashval = hash(class); + + if ((ptr = class_bucket[hashval]) == NULLZCT) + /* no such class to deregister */ + return(ZERR_S_BADASSOC); + if (!strcmp(ptr->classname, class)) { /* match! */ + retval = remove_client(ptr, client); + /* handle retval here*/ + ptr2 = ptr; + } + else { + for (ptr2 = ptr->q_forw; ptr2 != ptr; ptr2 = ptr2->q_forw) { + /* walk down the list, looking for a match */ + if (!strcmp(ptr2->classname, class)) { + retval = remove_client(ptr2, client); + /* handle it here too */ + break; + } + } + /* fell off, error */ + return(ZERR_S_BADASSOC); + } +} diff --git a/server/common.c b/server/common.c new file mode 100644 index 0000000..2a99cf6 --- /dev/null +++ b/server/common.c @@ -0,0 +1,27 @@ +/* + * $Source$ + * $Header$ + */ + +#ifndef lint +static char *rcsid_common_c = "$Header$"; +#endif lint + +/* common routines */ + +#include <zephyr/mit-copyright.h> +#include <stdio.h> + +char * +strsave(sp) char *sp; +{ + register char *ret; + + if((ret = (char *) malloc(strlen(sp)+1)) == NULL) { + error("out of memory in strsave()\n"); + return(NULL); + } + strcpy(ret,sp); + return(ret); +} + diff --git a/server/zserver.h b/server/zserver.h new file mode 100644 index 0000000..d8ad9e9 --- /dev/null +++ b/server/zserver.h @@ -0,0 +1,24 @@ +/* Coypright 1987, Massachusetts Institute of Technology */ +/* + * $Source$ + * $Header$ + */ + +/* definitions for the Zephyr server */ + +typedef struct _ZClientDesc_t { + struct _ZClientDesc_t *q_forw; + struct _ZClientDesc_t *q_back; +} ZClientDesc_t; + +typedef struct _ZEntity_t { + char *filler; /* fill this in later */ +} ZEntity_t; + +/* Function declarations */ + +extern char *strsave(); + +/* server internal error codes */ +#define ZERR_S_FIRST 2000 +#define ZERR_S_BADASSOC 2000 /* client not associated with class */ |