changes for pxshm and persistent
authorGengbin Zheng <gzheng@illinois.edu>
Mon, 12 Sep 2011 04:20:06 +0000 (21:20 -0700)
committerGengbin Zheng <gzheng@illinois.edu>
Mon, 12 Sep 2011 04:20:06 +0000 (21:20 -0700)
src/arch/gemini_gni/machine.c

index d485d3783a3d1ee891a5cc2a7e691f75c77455ca..5cf794ec1bf7b2e9b97ce9cd4f3b4325aea0eef7 100644 (file)
@@ -56,6 +56,10 @@ int         lrts_local_done_msg = 0;
 
 #include "pcqueue.h"
 
+#if CMK_PERSISTENT_COMM
+#include "machine-persistent.h"
+#endif
+
 //#define  USE_ONESIDED 1
 #ifdef USE_ONESIDED
 //onesided implementation is wrong, since no place to restore omdh
@@ -345,10 +349,6 @@ static MSG_LIST *buffered_fma_tail = 0;
 
 #include "mempool.c"
 
-#if CMK_PERSISTENT_COMM
-#include "machine-persistent.c"
-#endif
-
 /* get the upper bound of log 2 */
 int mylog2(int size)
 {
@@ -728,9 +728,14 @@ static int send_large_messages(int destNode, int size, char *msg)
 #endif
 }
 
-static CmiCommHandle LrtsSendFunc(int destNode, int size, char *msg, int mode)
+void LrtsPrepareEnvelope(char *msg, int size)
 {
     CmiSetMsgSize(msg, size);
+}
+
+static CmiCommHandle LrtsSendFunc(int destNode, int size, char *msg, int mode)
+{
+    LrtsPrepareEnvelope(msg, size);
 
     if(size <= SMSG_MAX_MSG)
     {
@@ -1706,4 +1711,8 @@ int CmiBarrier()
 }
 
 
+#if CMK_PERSISTENT_COMM
+#include "machine-persistent.c"
+#endif
+