Changeset 938:4158151cc694 in freeDiameter

Timestamp:

Mar 12, 2013, 11:27:30 PM (11 years ago)

Author:

Sebastien Decugis <sdecugis@freediameter.net>

Branch:

default

Phase:

public

Message:

Add counter for number of requests pending answers

Location:

libfdcore

Files:

• fdcore-internal.h (modified) (1 diff)
• p_sr.c (modified) (3 diffs)

libfdcore/fdcore-internal.h

@@ -126 +126 @@
         struct fd_list  srs; /* requests ordered by hop-by-hop id */
         struct fd_list  exp; /* requests that have a timeout set, ordered by timeout */
+        int             cnt; /* number of requests in the srs list */
         pthread_mutex_t mtx; /* mutex to protect these lists */
         pthread_cond_t  cnd; /* cond var used by the thread that handles timeouts */

libfdcore/p_sr.c

@@ -226 +226 @@
         *req = NULL;
         fd_list_insert_before(next, &sr->chain);
+        srlist->cnt++;
         srl_dump("Saved new request, ", &srlist->srs);
         
@@ -281 +282 @@
                 /* Unlink */
                 fd_list_unlink(&sr->chain);
+                srlist->cnt--;
                 fd_list_unlink(&sr->expire);
                 *req = sr->req;
@@ -300 +302 @@
                 struct sentreq * sr = (struct sentreq *)(srlist->srs.next);
                 fd_list_unlink(&sr->chain);
+                srlist->cnt--;
                 fd_list_unlink(&sr->expire);
                 if (fd_msg_is_routable(sr->req)) {