Bug fix in termination.
authorGreg Koenig <koenig@uiuc.edu>
Thu, 14 Aug 2003 01:16:26 +0000 (01:16 +0000)
committerGreg Koenig <koenig@uiuc.edu>
Thu, 14 Aug 2003 01:16:26 +0000 (01:16 +0000)
src/arch/vmi-linux/conv-mach.h
src/arch/vmi-linux/conv-mach.sh
src/arch/vmi/conv-common.h
src/arch/vmi/machine.c
src/arch/vmi/machine.h

index 068cd202d987aa5e08a173584306f8cff7d46dd8..5ae3dae99b427b0f5546a2214705a2d8967c4dab 100644 (file)
@@ -1,21 +1,20 @@
 #ifndef _CONV_MACH_H
 #define _CONV_MACH_H
 
-#define CMK_IA64                                           1
-
 #define CMK_ASYNC_NOT_NEEDED                               0
 #define CMK_ASYNC_USE_FIOASYNC_AND_FIOSETOWN               0
 #define CMK_ASYNC_USE_FIOASYNC_AND_SIOCSPGRP               0
 #define CMK_ASYNC_USE_FIOSSAIOSTAT_AND_FIOSSAIOOWN         0
 #define CMK_ASYNC_USE_F_SETFL_AND_F_SETOWN                 1
 
-#define CMK_GETPAGESIZE_AVAILABLE                          1
+//#define CMK_GETPAGESIZE_AVAILABLE                          1
+#define CMK_GETPAGESIZE_AVAILABLE                          0 
 
 #define CMK_MALLOC_USE_GNU_MALLOC                          0
 #define CMK_MALLOC_USE_OS_BUILTIN                          1
 #define CMK_MALLOC_USE_GNUOLD_MALLOC                       0
 
-#define CMK_MEMORY_PAGESIZE                                16384
+#define CMK_MEMORY_PAGESIZE                                8192
 #define CMK_MEMORY_PROTECTABLE                             1
 
 #define CMK_NODE_QUEUE_AVAILABLE                           0
 #define CMK_THREADS_ARE_WIN32_FIBERS                       0
 
 #define CMK_SIGNAL_NOT_NEEDED                              0
-#define CMK_SIGNAL_USE_SIGACTION                           0
-#define CMK_SIGNAL_USE_SIGACTION_WITH_RESTART              1
+//#define CMK_SIGNAL_USE_SIGACTION                           0
+//#define CMK_SIGNAL_USE_SIGACTION_WITH_RESTART              1
+#define CMK_SIGNAL_USE_SIGACTION                           1 
+#define CMK_SIGNAL_USE_SIGACTION_WITH_RESTART              0 
 
 #define CMK_THREADS_REQUIRE_NO_CPV                         0
 #define CMK_THREADS_COPY_STACK                             0
 
-#define CMK_TIMER_USE_RDTSC                                1
-#define CMK_TIMER_USE_GETRUSAGE                            0
+//#define CMK_TIMER_USE_RDTSC                                1
+//#define CMK_TIMER_USE_GETRUSAGE                            0
+#define CMK_TIMER_USE_RDTSC                                0 
+#define CMK_TIMER_USE_GETRUSAGE                            1 
 #define CMK_TIMER_USE_SPECIAL                              0
 #define CMK_TIMER_USE_TIMES                                0
 
 #define CMK_TYPEDEF_FLOAT4 float
 #define CMK_TYPEDEF_FLOAT8 double
 
-#define CMK_NETPOLL                                        1
+//#define CMK_NETPOLL                                        1
+#define CMK_NETPOLL                                        0 
 
-#define CMK_WHEN_PROCESSOR_IDLE_BUSYWAIT                   1
-#define CMK_WHEN_PROCESSOR_IDLE_USLEEP                     0
+//#define CMK_WHEN_PROCESSOR_IDLE_BUSYWAIT                   1
+//#define CMK_WHEN_PROCESSOR_IDLE_USLEEP                     0
+#define CMK_WHEN_PROCESSOR_IDLE_BUSYWAIT                   0 
+#define CMK_WHEN_PROCESSOR_IDLE_USLEEP                     1 
 
 #define CMK_DEBUG_MODE                                    0 
-#define CMK_WEB_MODE                                       1
+//#define CMK_WEB_MODE                                       1
+#define CMK_WEB_MODE                                       0
 
 #define CMK_LBDB_ON                                       1
 
index 6837c5cfae95b0b32cff58833bfffa05fbe479b8..c9884540a26ce403884f081f1bed48df7e6e37be 100644 (file)
@@ -1,9 +1,9 @@
 VMI_INCDIR="-I/home/koenig/THESIS/VMI20-install/include" 
 VMI_LIBDIR="-L/home/koenig/THESIS/VMI20-install/lib"
 CMK_CPP_CHARM="/lib/cpp -P"
-CMK_CPP_C="gcc3 -E $CMK_INCDIR $VMI_INCDIR "
-CMK_CC="gcc3 $CMK_INCDIR $VMI_INCDIR "
-CMK_CXX="g++3 $CMK_INCDIR $VMI_INCDIR "
+CMK_CPP_C="gcc -E $CMK_INCDIR $VMI_INCDIR "
+CMK_CC="gcc $CMK_INCDIR $VMI_INCDIR "
+CMK_CXX="g++ $CMK_INCDIR $VMI_INCDIR "
 CMK_CXXPP="$CMK_CC -x c++ -E "
 CMK_CF77="f77"
 CMK_CF90="f90"
@@ -11,7 +11,7 @@ CMK_LD="$CMK_CC -rdynamic -pthread $VMI_LIBDIR "
 CMK_LDXX="$CMK_CXX -rdynamic -pthread $VMI_LIBDIR"
 CMK_RANLIB='ranlib'
 CMK_LIBS='-lckqt -lvmi20 -lcurl -ldl -lexpat -lssl -lcrypto'
-CMK_QT='generic64'
+CMK_QT='generic'
 CMK_XIOPTS=''
 CMK_F90LIBS='-lvast90 -lg2c'
 CMK_MOD_EXT="vo"
index 472470daeea52074bd9a8d2bee7db152cb65851a..63f89cbc46ef413b4e33b88c9e614e0779791b30 100644 (file)
@@ -1,6 +1,7 @@
 #define CMK_NET_VERSION                                    0
 
-#define CMK_CCS_AVAILABLE                                  1
+//#define CMK_CCS_AVAILABLE                                  1
+#define CMK_CCS_AVAILABLE                                  0 
 
 #define CMK_CMIPRINTF_IS_A_BUILTIN                         0 
 #define CMK_CMIPRINTF_IS_JUST_PRINTF                       1 
@@ -8,19 +9,17 @@
 #define CMK_CMIDELIVERS_USE_COMMON_CODE                    1
 #define CMK_CMIDELIVERS_USE_SPECIAL_CODE                   0
 
-#define CMK_HANDLE_SIGUSR                                  1
-
 #define CMK_MULTICAST_GROUP_TYPE                struct { unsigned pe, id; }
 #define CMK_MULTICAST_DEF_USE_COMMON_CODE                  1
 #define CMK_MULTICAST_LIST_USE_COMMON_CODE                 1
 #define CMK_MULTICAST_GROUP_USE_COMMON_CODE                1
 
-/*
 #define CMK_MSG_HEADER_BASIC  { CmiUInt2 d0,d1,d2,d3,d4,d5,hdl,d7; }
 #define CMK_MSG_HEADER_EXT    { CmiUInt2 d0,d1,d2,d3,d4,d5,hdl,xhdl,info,d9,da,db; }
-*/
+/*
 #define CMK_MSG_HEADER_BASIC  CMK_MSG_HEADER_EXT
 #define CMK_MSG_HEADER_EXT    { CmiUInt2 rank,root,hdl,xhdl,info,d3; }
+*/
 #define CMK_MSG_HEADER_BLUEGENE    { CmiUInt2 d0,d1,d2,d3,d4,d5,hdl,xhdl,info,d9,da,db; int nd, n; double rt; CmiInt2 tID; CmiUInt2 hID; char t; int msgID; int srcPe;}
 
 #define CMK_REDUCTION_USES_COMMON_CODE                     1
 #define CMK_VECTOR_SEND_USES_COMMON_CODE                   1
 #define CMK_VECTOR_SEND_USES_SPECIAL_CODE                  0
 
-#define CMK_IMMEDIATE_MSG                                  1
+#define CMK_IMMEDIATE_MSG                                  0
 
-#define NODE_0_IS_CONVHOST                                 1
+//#define NODE_0_IS_CONVHOST                                 1
+#define NODE_0_IS_CONVHOST                                 0 
 
 #if 0
 
index afd28ce235f5791b970dc219751ed52c62c6b23e..84e7413484e1f7e0e390a143e808c490860912ae 100644 (file)
@@ -1726,7 +1726,7 @@ void ConverseExit ()
   DEBUG_PRINT ("ConverseExit() called.\n");
 
   /* Call VMI_Poll() to encourage the network to reach quiescence. */
-  for (i = 0; i < 10; i++) {
+  for (i = 0; i < 1000000; i++) {
     sched_yield ();
     status = VMI_Poll ();
     CMI_VMI_CHECK_SUCCESS (status, "VMI_Poll()");
@@ -1887,9 +1887,12 @@ void ConverseExit ()
   VMI_Cache_Stats();
 #endif
 
+  exit (0);
+#if 0
   /* Terminate VMI. */
   SET_VMI_SUCCESS (status);
   VMI_Terminate (status);
+#endif
 }
 
 
@@ -2354,14 +2357,16 @@ void CmiSyncBroadcastFn (int msgsize, char *msg)
     handle.refcount = Cmi_numpes;
 
     for (i = 0; i < Cmi_mype; i++) {
-      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->conn, bufHandles, addrs,
-          sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle, TRUE);
+      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
+           addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
+           TRUE);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 
     for (i = (Cmi_mype + 1); i < Cmi_numpes; i++) {
-      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->conn, bufHandles, addrs,
-          sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle, TRUE);
+      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
+           addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
+           TRUE);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 #endif   /* CMK_BROADCAST_SPANNING_TREE */
@@ -2428,14 +2433,14 @@ void CmiSyncBroadcastFn (int msgsize, char *msg)
     handle.refcount = Cmi_numpes;
 
     for (i = 0; i < Cmi_mype; i++) {
-      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->conn,
+      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->connection,
           addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
            sizeof (CMI_VMI_Message_Body_Rendezvous_T));
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
 
     for (i = (Cmi_mype + 1); i < Cmi_numpes; i++) {
-      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->conn,
+      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->connection,
           addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
            sizeof (CMI_VMI_Message_Body_Rendezvous_T));
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
@@ -2535,13 +2540,13 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
     }
 #else   /* CMK_BROADCAST_SPANNING_TREE */
     for (i = 0; i < Cmi_mype; i++) {
-      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->conn,
+      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->connection,
            addrs, sz, 2, sizeof (CMI_VMI_Message_Header_T) + msgsize);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
 
     for (i = (Cmi_mype + 1); i < Cmi_numpes; i++) {
-      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->conn,
+      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->connection,
            addrs, sz, 2, sizeof (CMI_VMI_Message_Header_T) + msgsize);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
@@ -2619,14 +2624,16 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
     CMI_VMI_AsyncMsgCount += (Cmi_numpes - 1);
 
     for (i = 0; i < Cmi_mype; i++) {
-      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->conn, bufHandles, addrs,
-          sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle, TRUE);
+      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
+           addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
+           TRUE);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 
     for (i = (Cmi_mype + 1); i < Cmi_numpes; i++) {
-      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->conn, bufHandles, addrs,
-          sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle, TRUE);
+      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
+           addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
+           TRUE);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 #endif   /* CMK_BROADCAST_SPANNING_TREE */
@@ -2693,14 +2700,14 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
     CMI_VMI_AsyncMsgCount += (Cmi_numpes - 1);
 
     for (i = 0; i < Cmi_mype; i++) {
-      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->conn,
+      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->connection,
            addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
            sizeof (CMI_VMI_Message_Body_Rendezvous_T));
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
 
     for (i = (Cmi_mype + 1); i < Cmi_numpes; i++) {
-      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->conn,
+      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->connection,
            addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
            sizeof (CMI_VMI_Message_Body_Rendezvous_T));
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
@@ -2811,14 +2818,16 @@ void CmiFreeBroadcastFn (int msgsize, char *msg)
     handle.refcount = Cmi_numpes;
 
     for (i = 0; i < Cmi_mype; i++) {
-      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->conn, bufHandles, addrs,
-          sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle, TRUE);
+      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
+           addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
+           TRUE);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 
     for (i = (Cmi_mype + 1); i < Cmi_numpes; i++) {
-      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->conn, bufHandles, addrs,
-          sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle, TRUE);
+      status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
+           addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
+           TRUE);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 #endif   /* CMK_BROADCAST_SPANNING_TREE */
@@ -2885,14 +2894,14 @@ void CmiFreeBroadcastFn (int msgsize, char *msg)
     handle.refcount = Cmi_numpes;
 
     for (i = 0; i < Cmi_mype; i++) {
-      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->conn,
+      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->connection,
           addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
            sizeof (CMI_VMI_Message_Body_Rendezvous_T));
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
 
     for (i = (Cmi_mype + 1); i < Cmi_numpes; i++) {
-      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->conn,
+      status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[i])->connection,
           addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
            sizeof (CMI_VMI_Message_Body_Rendezvous_T));
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
index 2c02e6bff9026634c4cf09262107ed91dea01414..ecdc58db97ddf64641028150bc97943508761a40 100644 (file)
@@ -26,7 +26,8 @@
 
 #define CMI_VMI_COLLECT_STATISTICS 0
 
-#define CMK_BROADCAST_SPANNING_TREE 1
+//#define CMK_BROADCAST_SPANNING_TREE 1
+#define CMK_BROADCAST_SPANNING_TREE 0