summaryrefslogtreecommitdiff
path: root/pflocal/connq.c
diff options
context:
space:
mode:
authorMiles Bader <miles@gnu.org>1995-07-22 00:35:43 +0000
committerMiles Bader <miles@gnu.org>1995-07-22 00:35:43 +0000
commitb5abf101421ffeafe6e5408ff86dc601f0c94fe5 (patch)
tree94212e26fa996c23d163cb48668945f7c91bb8aa /pflocal/connq.c
parent091a9dd71ff33796fa72a1b139e5ec637045b32d (diff)
entered into RCS
Diffstat (limited to 'pflocal/connq.c')
-rw-r--r--pflocal/connq.c30
1 files changed, 30 insertions, 0 deletions
diff --git a/pflocal/connq.c b/pflocal/connq.c
index b94c69f8..572c7ccf 100644
--- a/pflocal/connq.c
+++ b/pflocal/connq.c
@@ -22,6 +22,8 @@
#include "connq.h"
+#include "debug.h"
+
/* A queue for queueing incoming connections. */
struct connq
{
@@ -121,21 +123,28 @@ error_t
connq_listen (struct connq *cq, int noblock,
struct connq_request **req, struct sock **sock)
{
+debug (cq, "in");
+debug (cq, "lock");
mutex_lock (&cq->lock);
if (noblock && cq->head == cq->tail)
+{debug (cq, "ewouldblock");
return EWOULDBLOCK;
+}
cq->num_listeners++;
while (cq->head == cq->tail)
+{debug (cq, "wait listeners");
condition_wait (&cq->listeners, &cq->lock);
+}
if (req != NULL)
/* Dequeue the next request, if desired. */
{
*req = cq->queue[cq->tail];
cq->tail = qnext (cq, cq->tail);
+debug (*req, "(req) lock");
mutex_lock (&(*req)->lock);
if (sock != NULL)
*sock = (*req)->sock;
@@ -143,8 +152,10 @@ connq_listen (struct connq *cq, int noblock,
cq->num_listeners--;
+debug (cq, "unlock");
mutex_unlock (&cq->lock);
+debug (cq, "out");
return 0;
}
@@ -153,10 +164,13 @@ connq_listen (struct connq *cq, int noblock,
void
connq_request_complete (struct connq_request *req, error_t err)
{
+debug (req, "lock");
mutex_lock (&req->lock);
req->err = err;
req->completed = 1;
+debug (req, "signal, err: %d", err);
condition_signal (&req->signal);
+debug (req, "unlock");
mutex_unlock (&req->lock);
}
@@ -170,10 +184,16 @@ connq_connect (struct connq *cq, int noblock, struct sock *sock)
struct connq_request req;
unsigned next;
+debug (cq, "in");
+debug (cq, "lock");
mutex_lock (&cq->lock);
if ((noblock || cq->noqueue) && cq->num_listeners == 0)
+{debug (cq, "unlock");
+ mutex_unlock (&cq->lock);
+debug (cq, "ewouldblock");
return EWOULDBLOCK;
+}
next = qnext (cq, cq->head);
if (next == cq->tail)
@@ -185,16 +205,22 @@ connq_connect (struct connq *cq, int noblock, struct sock *sock)
/* Hold REQ.LOCK before we signal the condition so that we're sure to be
woken up. */
+debug (&req, "(req) lock");
mutex_lock (&req.lock);
+debug (cq, "signal listeners");
condition_signal (&cq->listeners);
+debug (cq, "unlock");
mutex_unlock (&cq->lock);
while (!req.completed)
+{debug (&req, "(req) wait");
condition_wait (&req.signal, &req.lock);
+}
err = req.err;
+debug (&req, "(req) unlock");
mutex_unlock (&req.lock);
}
@@ -206,6 +232,8 @@ connq_connect (struct connq *cq, int noblock, struct sock *sock)
error_t
connq_set_length (struct connq *cq, int length)
{
+debug (cq, "in: %d", length);
+debug (cq, "lock");
mutex_lock (&cq->lock);
if (length > cq->length)
@@ -232,7 +260,9 @@ connq_set_length (struct connq *cq, int length)
cq->noqueue = 0; /* Turn on queueing. */
+debug (cq, "unlock");
mutex_unlock (&cq->lock);
+debug (cq, "out");
return 0;
}