Changeset 1010:357c2f892d24 in freeDiameter for libfdcore/p_out.c

Timestamp:

Mar 26, 2013, 12:39:32 AM (11 years ago)

Author:

Sebastien Decugis <sdecugis@freediameter.net>

Branch:

default

Phase:

public

Message:

Implement a new counter on pending answers to send back to a peer.
Function fd_peer_get_load_pending updated to retrieve this counter as well.
When a peer has answers pending, the connection is not immediately teared down
upon DPR/DPA exchange, but a GRACE_TIMEOUT delay (default 1 sec) is granted.

File:

• libfdcore/p_out.c (modified) (1 diff)

libfdcore/p_out.c

@@ -173 +173 @@
 int fd_out_send(struct msg ** msg, struct cnxctx * cnx, struct fd_peer * peer, uint32_t flags)
 {
+        struct msg_hdr * hdr;
+        
         TRACE_ENTRY("%p %p %p %x", msg, cnx, peer, flags);
         CHECK_PARAMS( msg && *msg && (cnx || (peer && peer->p_cnxctx)));
+        
+        if (peer) {
+                CHECK_FCT( fd_msg_hdr(*msg, &hdr) );
+                if (!(hdr->msg_flags & CMD_FLAG_REQUEST)) {
+                        /* Update the count of pending answers to send */
+                        CHECK_POSIX( pthread_mutex_lock(&peer->p_state_mtx) );
+                        peer->p_reqin_count--;
+                        CHECK_POSIX( pthread_mutex_unlock(&peer->p_state_mtx) );                        
+                }
+        }
         
         if (fd_peer_getstate(peer) == STATE_OPEN) {