Changeset 939:1bc052ef961f in freeDiameter

Timestamp:

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

Author:

Sebastien Decugis <sdecugis@freediameter.net>

Branch:

default

Phase:

public

Message:

Add a function to access this counter

Files:

• include/freeDiameter/libfdcore.h (modified) (1 diff)
• libfdcore/peers.c (modified) (2 diffs)

include/freeDiameter/libfdcore.h

@@ -385 +385 @@
 int fd_peer_get_state(struct peer_hdr *peer);
 
+/* 
+ * FUNCTION:    fd_peer_get_load_pending
+ *
+ * PARAMETERS:
+ *  peer        : The peer which load to read
+ *
+ * DESCRIPTION: 
+ *   Returns the current number of requests sent to this peer
+ *  that have not been answered yet. This is an empirical indication
+ *  of the workload of this peer.
+ *
+ * RETURN VALUE:
+ *  0  : The load parameter has been updated. (it should have a positive value always)
+ * !0  : An error occurred
+ */
+int fd_peer_get_load_pending(struct peer_hdr *peer, int * load);
+
 /*
  * FUNCTION:    fd_peer_validate_register

libfdcore/peers.c

@@ -257 +257 @@
 }
 
+/* Return the value of srlist->cnt */
+int fd_peer_get_load_pending(struct peer_hdr *peer, int * load)
+{
+        struct fd_peer * p = (struct fd_peer *)peer;
+        TRACE_ENTRY("%p %p", peer, load);
+        CHECK_PARAMS(CHECK_PEER(peer) && load);
+        
+        CHECK_POSIX( pthread_mutex_lock(&p->p_sr.mtx) );
+        *load = p->p_sr.cnt;
+        CHECK_POSIX( pthread_mutex_unlock(&p->p_sr.mtx) );
+        
+        return 0;
+}
+
+
 /* Destroy a structure once cleanups have been performed (fd_psm_abord, ...) */
 int fd_peer_free(struct fd_peer ** ptr)
@@ -395 +410 @@
         }
 
-        fd_log_debug(">  %s\t%s", STATE_STR(fd_peer_getstate(peer)), peer->p_hdr.info.pi_diamid);
+        fd_log_debug(">  %s\t%s\t[%dsr]", STATE_STR(fd_peer_getstate(peer)), peer->p_hdr.info.pi_diamid, peer->p_sr.cnt);
         if (details > INFO) {
                 fd_log_debug("\t(rlm:%s)", peer->p_hdr.info.runtime.pir_realm ?: "<unknown>");