Changeset 455:7250e91f0662 in freeDiameter

Timestamp:

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

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Phase:

public

Message:

Some additional flush enforcement to attempt to avoid some possible problems

Location:

freeDiameter

Files:

• cnxctx.c (modified) (3 diffs)
• p_out.c (modified) (2 diffs)
• routing_dispatch.c (modified) (2 diffs)
• sctps.c (modified) (1 diff)

freeDiameter/cnxctx.c

@@ -691 +691 @@
                 
                 /* We have received a complete message, pass it to the daemon */
+                fd_cpu_flush_cache();
                 CHECK_FCT_DO( fd_event_send( Target_Queue(conn), FDEVP_CNX_MSG_RECV, length, newmsg), /* continue or destroy everything? */);
                 
@@ -741 +742 @@
                 }
                 
+                fd_cpu_flush_cache();
                 CHECK_FCT_DO( fd_event_send( Target_Queue(conn), event, bufsz, buf), goto fatal );
                 
@@ -925 +927 @@
                 
                 /* We have received a complete message, pass it to the daemon */
+                fd_cpu_flush_cache();
                 CHECK_FCT_DO( ret = fd_event_send( Target_Queue(conn), FDEVP_CNX_MSG_RECV, length, newmsg), 
                         { 

freeDiameter/p_out.c

@@ -122 +122 @@
                 CHECK_FCT_DO( do_send(&msg, 0, peer->p_cnxctx, &peer->p_hbh, &peer->p_sr),
                         {
-                                fd_log_debug("An error occurred while sending this message, it is lost:\n");
-                                fd_msg_dump_walk(NONE, msg);
-                                fd_msg_free(msg);
+                                if (msg) {
+                                        fd_log_debug("An error occurred while sending this message, it was lost:\n");
+                                        fd_msg_dump_walk(NONE, msg);
+                                        fd_msg_free(msg);
+                                }
                         } );
                         
@@ -161 +163 @@
                 CHECK_FCT_DO( do_send(msg, flags, cnx, hbh, peer ? &peer->p_sr : NULL),
                         {
-                                fd_log_debug("An error occurred while sending this message, it is lost:\n");
-                                fd_msg_dump_walk(NONE, *msg);
-                                fd_msg_free(*msg);
-                                *msg = NULL;
+                                if (msg) {
+                                        fd_log_debug("An error occurred while sending this message, it was lost:\n");
+                                        fd_msg_dump_walk(NONE, *msg);
+                                        fd_msg_free(*msg);
+                                        *msg = NULL;
+                                }
                         } );
         }

freeDiameter/routing_dispatch.c

@@ -998 +998 @@
         /* Mark the thread running */
         *(enum thread_state *)arg = RUNNING;
+        fd_cpu_flush_cache();
         
         do {
@@ -1124 +1125 @@
 
         /* Wait for a second for the thread to complete, by monitoring my_state */
+        fd_cpu_flush_cache();
         if (*st != TERMINATED) {
                 TRACE_DEBUG(INFO, "Waiting for the %s thread to have a chance to terminate", th_name);

freeDiameter/sctps.c

@@ -102 +102 @@
                         case FDEVP_CNX_EP_CHANGE:
                                 /* Send this event to the target queue */
+                                fd_cpu_flush_cache();
                                 CHECK_FCT_DO( fd_event_send( Target_Queue(conn), event, bufsz, buf), goto fatal );
                                 break;