Initial import

1 files changed, 50 insertions, 0 deletions

diff --git a/server/.svn/text-base/fqm.h.svn-base b/server/.svn/text-base/fqm.h.svn-base
new file mode 100644
index 0000000..c3c27df
--- /dev/null
+++ b/server/.svn/text-base/fqm.h.svn-base
@@ -0,0 +1,50 @@
+/* $Id: fqm.h,v 1.9 2000/11/08 19:50:24 shmit Exp $ */
+
+#ifndef FQM_H
+#define FQM_H
+
+#include "thread.h"
+
+#define REQHANDLER(func) int func(struct _request_t *req, reqthread_t *self)
+
+enum _status_t { IDLE, BUSY, NOALLOC };
+typedef enum _status_t status_t;
+
+struct _reqthread_t {
+	struct _fqm_t *fqm;
+	thread_t *tid;
+	void *arg;
+	int dieflag;
+	status_t status;
+};
+typedef struct _reqthread_t reqthread_t;
+
+struct _request_t {
+	REQHANDLER((*req_handler));
+	char *req;
+	int sock;
+	short reqid;
+	struct _request_t *next;
+};
+typedef struct _request_t request_t;
+
+struct _fqm_t {
+	cond_t *q_cond;
+	cond_t *t_cond;
+	request_t *sreq, *ereq;
+	reqthread_t **tids;
+	int maxitems;
+	int nitems;
+};
+typedef struct _fqm_t fqm_t;
+
+request_t *req_new(int sock, short reqid, REQHANDLER((*req_handler)),
+		   const char *reqstr, int reqlen);
+void req_delete(request_t *req);
+
+fqm_t *fqm_new(int maxitems);
+void fqm_delete(fqm_t *fqm);
+int fqm_changemaxitems(fqm_t *fqm, int maxitems);
+int fqm_push(fqm_t *fqm, request_t *req);
+
+#endif