Changeset 14:14cf6daf716d in freeDiameter for libfreeDiameter/fifo.c

Timestamp:

Oct 1, 2009, 6:24:07 PM (15 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Some progress on peers module

File:

• libfreeDiameter/fifo.c (modified) (3 diffs)

libfreeDiameter/fifo.c

@@ -65 +65 @@
         void            (*l_cb)(struct fifo *, void **);
         int             highest;/* The highest count value for which h_cb has been called */
+        int             highest_ever; /* The max count value this queue has reached (for tweaking) */
 };
 
@@ -118 +119 @@
         CHECK_POSIX_DO(  pthread_mutex_lock( &queue->mtx ), /* continue */  );
         fd_log_debug("   %d elements in queue / %d threads waiting\n", queue->count, queue->thrs);
-        fd_log_debug("   thresholds: %d / %d, cb: %p / %p (%p), highest: %d\n",
-                        queue->high, queue->low,
+        fd_log_debug("   thresholds: %d / %d (h:%d), cb: %p,%p (%p), highest: %d\n",
+                        queue->high, queue->low, queue->highest, 
                         queue->h_cb, queue->l_cb, queue->data,
-                        queue->highest);
+                        queue->highest_ever);
         
         if (dump_item) {
@@ -251 +252 @@
         fd_list_insert_before( &queue->list, new);
         queue->count++;
+        if (queue->highest_ever < queue->count)
+                queue->highest_ever = queue->count;
         if (queue->high && ((queue->count % queue->high) == 0)) {
                 call_cb = 1;