Changeset 454:f1484823cb4a in freeDiameter for freeDiameter/p_psm.c

Timestamp:

Jul 29, 2010, 4:11:12 PM (14 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Small hack which might spear some concurrency problems and is quite harmless

File:

• freeDiameter/p_psm.c (modified) (7 diffs)

freeDiameter/p_psm.c

@@ -184 +184 @@
         TRACE_ENTRY("%p %d(%s)", peer, new_state, STATE_STR(new_state));
         CHECK_PARAMS( CHECK_PEER(peer) );
+        fd_cpu_flush_cache();
         old = peer->p_hdr.info.runtime.pir_state;
         if (old == new_state)
@@ -194 +195 @@
         
         peer->p_hdr.info.runtime.pir_state = new_state;
+        fd_cpu_flush_cache();
         
         if (old == STATE_OPEN) {
@@ -251 +253 @@
 {
         /* Move to CLOSED state: failover messages, stop OUT thread, unlink peer from active list */
+        fd_cpu_flush_cache();
         if (peer->p_hdr.info.runtime.pir_state != STATE_ZOMBIE) {
                 CHECK_FCT_DO( fd_psm_change_state(peer, STATE_CLOSED), /* continue */ );
@@ -281 +284 @@
         CHECK_PARAMS_DO( CHECK_PEER(peer), return );
         peer->p_hdr.info.runtime.pir_state = STATE_ZOMBIE;
+        fd_cpu_flush_cache();
         return;
 }
@@ -306 +310 @@
         /* The state machine starts in CLOSED state */
         peer->p_hdr.info.runtime.pir_state = STATE_CLOSED;
-        
+
         /* Wait that the PSM are authorized to start in the daemon */
         CHECK_FCT_DO( fd_psm_waitstart(), goto psm_end );
@@ -709 +713 @@
                         peer->p_hdr.info.pi_diamid);
         pthread_cleanup_pop(1); /* set STATE_ZOMBIE */
+        fd_cpu_flush_cache();
         peer->p_psm = (pthread_t)NULL;
         pthread_detach(pthread_self());
@@ -742 +747 @@
         CHECK_PARAMS( CHECK_PEER(peer) );
         
+        fd_cpu_flush_cache();
         if (peer->p_hdr.info.runtime.pir_state != STATE_ZOMBIE) {
                 CHECK_FCT( fd_event_send(peer->p_events, FDEVP_TERMINATE, 0, reason) );