Changeset 229:965f5971dc23 in freeDiameter for freeDiameter/p_dp.c

Timestamp:

Mar 2, 2010, 3:55:26 PM (14 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Broadcast CEA over all streams to avoid possible race condition

File:

• freeDiameter/p_dp.c (modified) (4 diffs)

freeDiameter/p_dp.c

@@ -87 +87 @@
                                 if (dictobj) {
                                         CHECK_FCT( fd_dict_getval( dictobj, &er.search ) );
-                                        fd_log_debug("Peer '%s' sent a DPR with cause: %s\n", peer->p_hdr.info.pi_diamid, er.search.enum_name);
+                                        TRACE_DEBUG(INFO, "Peer '%s' sent a DPR with cause: %s\n", peer->p_hdr.info.pi_diamid, er.search.enum_name);
                                 } else {
-                                        fd_log_debug("Peer '%s' sent a DPR with unknown cause: %u\n", peer->p_hdr.info.pi_diamid, peer->p_hdr.info.runtime.pir_lastDC);
+                                        TRACE_DEBUG(INFO, "Peer '%s' sent a DPR with unknown cause: %u\n", peer->p_hdr.info.pi_diamid, peer->p_hdr.info.runtime.pir_lastDC);
                                 }
                         } else {
-                                fd_log_debug("Peer '%s' sent a DPR without Disconnect-Cause AVP\n", peer->p_hdr.info.pi_diamid);
+                                TRACE_DEBUG(INFO, "Peer '%s' sent a DPR without Disconnect-Cause AVP\n", peer->p_hdr.info.pi_diamid);
                         }
                 }
@@ -104 +104 @@
                 
                 /* Now send the DPA */
-                CHECK_FCT( fd_out_send( msg, NULL, peer) );
+                CHECK_FCT( fd_out_send( msg, NULL, peer, FD_CNX_ORDERED) );
                 
                 /* Move to CLOSED state */
@@ -115 +115 @@
                 /* We received a DPA */
                 if (peer->p_hdr.info.runtime.pir_state != STATE_CLOSING) {
-                        TRACE_DEBUG(INFO, "Ignore DPA received in state %s", STATE_STR(peer->p_hdr.info.runtime.pir_state));
+                        TRACE_DEBUG(INFO, "Ignoring DPA received in state %s", STATE_STR(peer->p_hdr.info.runtime.pir_state));
                 }
                         
@@ -168 +168 @@
         
         /* Now send the DPR message */
-        CHECK_FCT_DO( fd_out_send(&msg, NULL, peer), /* ignore since we are on timeout anyway */ );
+        CHECK_FCT_DO( fd_out_send(&msg, NULL, peer, FD_CNX_ORDERED), /* ignore since we are on timeout anyway */ );
         
         return 0;