From: Sebastian Hammer <quinn@indexdata.com>
Date: Mon, 15 May 1995 12:12:22 +0000 (+0000)
Subject: Request queue.
X-Git-Tag: YAZ.1.8~1045
X-Git-Url: http://jsfdemo.indexdata.com/?a=commitdiff_plain;h=eba5a38ad752c24f77110eb02e96e3895bd0fb3b;p=yaz-moved-to-github.git

Request queue.
---

diff --git a/server/requestq.c b/server/requestq.c
new file mode 100644
index 0000000..cfae569
--- /dev/null
+++ b/server/requestq.c
@@ -0,0 +1,87 @@
+/*
+ * Copyright (C) 1994, Index Data.
+ * See the file LICENSE for details.
+ * Sebastian Hammer, Adam Dickmeiss
+ *
+ * $Log: requestq.c,v $
+ * Revision 1.1  1995-05-15 12:12:22  quinn
+ * Request queue.
+ *
+ *
+ */
+
+/*
+ * Simple queue management.
+ *
+ * We also use the request-freelist to store encoding buffers, rather than
+ * freeing and malloc'ing them on each cycle.
+ */
+
+#include <stdlib.h>
+
+#include <dmalloc.h>
+#include <session.h>
+
+static request *request_list = 0;  /* global freelist for requests */
+
+void request_enq(request_q *q, request *r)
+{
+    if (q->tail)
+    	q->tail->next = r;
+    else
+    	q->head = r;
+    q->tail = r;
+    q->num++;
+}
+
+request *request_head(request_q *q)
+{
+    return q->head;
+}
+
+request *request_deq(request_q *q)
+{
+    request *r = q->head;
+
+    if (!r)
+    	return 0;
+    q->head = q->head->next;
+    if (!q->head)
+    	q->tail = 0;
+    q->num--;
+    return r;
+}
+
+void request_initq(request_q *q)
+{
+    q->head = q->tail = 0;
+    q->num = 0;
+}
+
+request *request_get(void)
+{
+    request *r = request_list;
+
+    if (r)
+    	request_list = r->next;
+    else
+    {
+    	if (!(r = malloc(sizeof(*r))))
+	    abort();
+	r->response = 0;
+	r->size_response = 0;
+    }
+    r->len_refid = 0;
+    r->request = 0;
+    r->request_mem = 0;
+    r->len_response = 0;
+    r->state = REQUEST_IDLE;
+    r->next = 0;
+    return r;
+}
+
+void request_release(request *r)
+{
+    r->next = request_list;
+    request_list = r;
+}