Labeling system global variables with underscore.
authorChao Huang <chuang10@uiuc.edu>
Fri, 12 Sep 2003 15:23:58 +0000 (15:23 +0000)
committerChao Huang <chuang10@uiuc.edu>
Fri, 12 Sep 2003 15:23:58 +0000 (15:23 +0000)
31 files changed:
src/arch/util/immediate.c
src/arch/util/machine-smp.c
src/arch/vmi/machine.c
src/ck-core/ckarray.C
src/ck-core/ckcallback.C
src/ck-core/ckcallback.ci
src/ck-core/cklocation.C
src/ck-core/cklocation.ci
src/ck-core/cklocation.h
src/ck-core/init.C
src/ck-core/init.h
src/ck-core/waitqd.C
src/ck-core/waitqd.ci
src/ck-ldb/BaseLB.C
src/ck-ldb/CentralLB.C
src/ck-ldb/Comm1LB.C
src/ck-ldb/CommLB.C
src/ck-ldb/LBDBManager.C
src/ck-ldb/LBDatabase.C
src/ck-ldb/LBDatabase.ci
src/ck-ldb/LBDatabase.h
src/ck-ldb/NborBaseLB.C
src/ck-ldb/ObjGraph.C
src/ck-ldb/lbdb.h
src/conv-core/convcore.c
src/conv-core/converse.h
src/conv-core/quiescence.c
src/conv-core/random.c
src/util/ckstandalone.C
src/util/sockRoutines.c
src/util/sockRoutines.h

index 4c7a9b7563258e13bffa15f2b92cddec8189a785..15b7b6f3e5d3f16fd3c69895112ff509cc2851d6 100644 (file)
@@ -3,7 +3,7 @@
 */
 
 
-int immRunning=0; /* if set, somebody's inside an immediate message */
+int _immRunning=0; /* if set, somebody's inside an immediate message */
 
 #if CMK_IMMEDIATE_MSG
 
@@ -22,7 +22,7 @@ void CmiPushImmediateMsg(void *msg)
 {
   MACHSTATE(4,"pushing immediate message {");
   /* This lock check needs portable access to comm_flag, which is tough:
-     MACHLOCK_ASSERT(immRunning||comm_flag,"CmiPushImmediateMsg");
+     MACHLOCK_ASSERT(_immRunning||comm_flag,"CmiPushImmediateMsg");
   */
   
   CmiLock(CsvAccess(NodeState).immSendLock);
@@ -40,7 +40,7 @@ SMP: This routine must be called holding immRecvLock
 */
 void CmiDelayImmediate(void)
 {
-  MACHLOCK_ASSERT(immRunning,"CmiDelayImmediate");
+  MACHLOCK_ASSERT(_immRunning,"CmiDelayImmediate");
 
   CQdCreate(CpvAccess(cQdState),1);
   MACHSTATE(5,"Actually delaying an immediate message");
@@ -61,7 +61,7 @@ static void CmiHandleImmediateMessage(void *msg) {
   CmiHandlerInfo *h=&CpvAccess(CmiHandlerTable)[handlerNo];
   CmiAssert(h && h->hdlr);
 
-  MACHLOCK_ASSERT(immRunning,"CmiHandleImmediateMessage");
+  MACHLOCK_ASSERT(_immRunning,"CmiHandleImmediateMessage");
   CQdProcess(CpvAccess(cQdState),1);
   (h->hdlr)(msg,h->userPtr);
 }
@@ -84,8 +84,8 @@ void CmiHandleImmediate()
    /* Make sure only one thread is running immediate messages: */
    CmiLock(CsvAccess(NodeState).immRecvLock);
 
-   MACHLOCK_ASSERT(!immRunning,"CmiHandleImmediate");
-   immRunning=1; /* prevents SIGIO reentrancy, and allows different send */
+   MACHLOCK_ASSERT(!_immRunning,"CmiHandleImmediate");
+   _immRunning=1; /* prevents SIGIO reentrancy, and allows different send */
    MACHSTATE(2,"Entered handleImmediate {")
 
    /* Handle all pending immediate messages */
@@ -102,7 +102,7 @@ void CmiHandleImmediate()
        CmiPushImmediateMsg(msg);
    
    MACHSTATE(2,"} exiting handleImmediate")
-   immRunning = 0;
+   _immRunning = 0;
    
    CmiUnlock(CsvAccess(NodeState).immRecvLock);
 }
index bc6427a90f28f6ee01cae1ad239b9d6860c139d3..fdb66102b0efb5d4bc40ad9576e67c5c24246989 100644 (file)
@@ -155,7 +155,7 @@ static DWORD WINAPI call_startfn(LPVOID vindex)
 
   ConverseRunPE(0);
 #if 0
-  if (index<Cmi_mynodesize)
+  if (index<_Cmi_mynodesize)
          ConverseRunPE(0); /*Regular worker thread*/
   else { /*Communication thread*/
          CommunicationServerInit();
@@ -208,15 +208,15 @@ static void CmiStartThreads(char **argv)
   if(Cmi_state_key == 0xFFFFFFFF) PerrorExit("TlsAlloc main");
   
   Cmi_state_vector =
-    (CmiState)calloc(Cmi_mynodesize+1, sizeof(struct CmiStateStruct));
+    (CmiState)calloc(_Cmi_mynodesize+1, sizeof(struct CmiStateStruct));
   
-  for (i=0; i<Cmi_mynodesize; i++)
+  for (i=0; i<_Cmi_mynodesize; i++)
     CmiStateInit(i+Cmi_nodestart, i, CmiGetStateN(i));
   /*Create a fake state structure for the comm. thread*/
-/*  CmiStateInit(-1,Cmi_mynodesize,CmiGetStateN(Cmi_mynodesize)); */
-  CmiStateInit(Cmi_mynode+CmiNumPes(),Cmi_mynodesize,CmiGetStateN(Cmi_mynodesize));
+/*  CmiStateInit(-1,_Cmi_mynodesize,CmiGetStateN(_Cmi_mynodesize)); */
+  CmiStateInit(_Cmi_mynode+CmiNumPes(),_Cmi_mynodesize,CmiGetStateN(_Cmi_mynodesize));
   
-  for (i=1; i<=Cmi_mynodesize; i++) {
+  for (i=1; i<=_Cmi_mynodesize; i++) {
     if((thr = CreateThread(NULL, 0, call_startfn, (LPVOID)i, 0, &threadID)) 
        == NULL) PerrorExit("CreateThread");
     CloseHandle(thr);
@@ -337,7 +337,7 @@ static void *call_startfn(void *vindex)
 
   ConverseRunPE(0);
 #if 0
-  if (index<Cmi_mynodesize) 
+  if (index<_Cmi_mynodesize) 
          ConverseRunPE(0); /*Regular worker thread*/
   else 
   { /*Communication thread*/
@@ -360,14 +360,14 @@ static void CmiStartThreads(char **argv)
 
   pthread_key_create(&Cmi_state_key, 0);
   Cmi_state_vector =
-    (CmiState)calloc(Cmi_mynodesize+1, sizeof(struct CmiStateStruct));
-  for (i=0; i<Cmi_mynodesize; i++)
+    (CmiState)calloc(_Cmi_mynodesize+1, sizeof(struct CmiStateStruct));
+  for (i=0; i<_Cmi_mynodesize; i++)
     CmiStateInit(i+Cmi_nodestart, i, CmiGetStateN(i));
   /*Create a fake state structure for the comm. thread*/
-/*  CmiStateInit(-1,Cmi_mynodesize,CmiGetStateN(Cmi_mynodesize)); */
-  CmiStateInit(Cmi_mynode+CmiNumPes(),Cmi_mynodesize,CmiGetStateN(Cmi_mynodesize));
+/*  CmiStateInit(-1,_Cmi_mynodesize,CmiGetStateN(_Cmi_mynodesize)); */
+  CmiStateInit(_Cmi_mynode+CmiNumPes(),_Cmi_mynodesize,CmiGetStateN(_Cmi_mynodesize));
 
-  for (i=1; i<=Cmi_mynodesize; i++) {
+  for (i=1; i<=_Cmi_mynodesize; i++) {
     pthread_attr_init(&attr);
     pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);
     ok = pthread_create(&pid, &attr, call_startfn, (void *)i);
@@ -517,7 +517,7 @@ void CmiStateInit(int pe, int rank, CmiState state)
   MACHSTATE(4,"StateInit")
   state->pe = pe;
   state->rank = rank;
-  if (rank==Cmi_mynodesize) return; /* Communications thread */
+  if (rank==_Cmi_mynodesize) return; /* Communications thread */
   state->recv = PCQueueCreate();
   state->localqueue = CdsFifo_Create();
   CmiIdleLock_init(&state->idle);
index 54543c29c58ca4e7ec3598c4b77e50a8d2e6e8e7..3d622aa7c89d057c8cf3180bf3f30ad4b436a208 100644 (file)
@@ -52,10 +52,10 @@ extern VMIStreamRecv recvFn;
   The following two globals hold this process's rank in the computation
   and the count of the total number of processes in the computation.
 */
-int Cmi_mype;
-int Cmi_numpes;
+int _Cmi_mype;
+int _Cmi_numpe;
 
-int Cmi_myrank = 0;
+int _Cmi_myrank = 0;
 
 /* This is the global variable for CMI_VMI_VERYSHORT_MESSAGE_BOUNDARY. */
 int CMI_VMI_VeryShort_Message_Boundary;
@@ -1038,7 +1038,7 @@ BOOLEAN CMI_VMI_Open_Connections (PUCHAR synckey)
 
   /* Set up the connection message field. */
   connmsgdata = (CMI_VMI_Connect_Message_T *) VMI_BUFFER_ADDRESS (connmsgbuf);
-  connmsgdata->rank = htonl (Cmi_mype);
+  connmsgdata->rank = htonl (_Cmi_mype);
 
   CMI_VMI_OAccept = 0;
   CMI_VMI_OReject = 0;
@@ -1058,7 +1058,7 @@ BOOLEAN CMI_VMI_Open_Connections (PUCHAR synckey)
     Here we initiate a connection to each process with a rank lower than
     this process's rank.
   */
-  for (i = 0; i < Cmi_mype; i++) {
+  for (i = 0; i < _Cmi_mype; i++) {
     /* Get a pointer to the process to make things easier. */
     proc = &CMI_VMI_Procs[i];
 
@@ -1134,7 +1134,7 @@ BOOLEAN CMI_VMI_Open_Connections (PUCHAR synckey)
   }
 
   /* Set the connection state to ourself to "connected". */
-  (&CMI_VMI_Procs[Cmi_mype])->state = CMI_VMI_CONNECTION_CONNECTED;
+  (&CMI_VMI_Procs[_Cmi_mype])->state = CMI_VMI_CONNECTION_CONNECTED;
 
   /*
     **********
@@ -1146,9 +1146,9 @@ BOOLEAN CMI_VMI_Open_Connections (PUCHAR synckey)
   */
 
   /* Calculate how many pprocesses are supposed to connect to us. */
-  CMI_VMI_IExpect = ((Cmi_numpes - Cmi_mype) - 1);
+  CMI_VMI_IExpect = ((_Cmi_numpes - _Cmi_mype) - 1);
 
-  DEBUG_PRINT ("This process's rank is %d.\n", Cmi_mype);
+  DEBUG_PRINT ("This process's rank is %d.\n", _Cmi_mype);
   DEBUG_PRINT ("Issued %d connection requests.\n", CMI_VMI_OIssue);
   DEBUG_PRINT ("Expecting %d connections to arrive.\n", CMI_VMI_IExpect);
 
@@ -1189,7 +1189,7 @@ BOOLEAN CMI_VMI_Open_Connections (PUCHAR synckey)
     return FALSE;
   }
 
-  DEBUG_PRINT ("All connections complete for process %d.\n", Cmi_mype);
+  DEBUG_PRINT ("All connections complete for process %d.\n", _Cmi_mype);
 
   free (remotekey);
   VMI_Buffer_Deallocate (connmsgbuf);
@@ -1316,20 +1316,20 @@ int CMI_VMI_Spanning_Children_Count (char *msg)
 
   startrank = CMI_BROADCAST_ROOT (msg) - 1;
   for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-    destrank = Cmi_mype - startrank;
+    destrank = _Cmi_mype - startrank;
 
     if (destrank < 0) {
-      destrank += Cmi_numpes;
+      destrank += _Cmi_numpes;
     }
 
     destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-    if (destrank > (Cmi_numpes - 1)) {
+    if (destrank > (_Cmi_numpes - 1)) {
       break;
     }
 
     destrank += startrank;
-    destrank %= Cmi_numpes;
+    destrank %= _Cmi_numpes;
 
     childcount++;
   }
@@ -1400,20 +1400,20 @@ void CMI_VMI_Send_Spanning_Children (int msgsize, char *msg)
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send ((&CMI_VMI_Procs[destrank])->connection,
            bufHandles, addrs, sz, 2, CMI_VMI_Stream_Completion_Handler,
@@ -1457,20 +1457,20 @@ void CMI_VMI_Send_Spanning_Children (int msgsize, char *msg)
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[destrank])->connection,
           addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
@@ -1577,11 +1577,11 @@ void ConverseInit (int argc, char **argv, CmiStartFn startFn,
   if (!a) {
     CmiAbort ("Environment variable VMI_PROCS not set.");
   }
-  Cmi_numpes = atoi (a);
+  _Cmi_numpes = atoi (a);
 
   CMI_VMI_Procs = (CMI_VMI_Process_Info_T *)
-       malloc (Cmi_numpes * sizeof (CMI_VMI_Process_Info_T));
-  for (i = 0; i < Cmi_numpes; i++) {
+       malloc (_Cmi_numpes * sizeof (CMI_VMI_Process_Info_T));
+  for (i = 0; i < _Cmi_numpes; i++) {
     (&CMI_VMI_Procs[i])->state = CMI_VMI_CONNECTION_DISCONNECTED;
   }
 
@@ -1607,12 +1607,12 @@ void ConverseInit (int argc, char **argv, CmiStartFn startFn,
   DEBUG_PRINT ("The initial synchronization key is %s.\n", synckey);
 
   /* Register with the CRM. */
-  if ((Cmi_mype = CMI_VMI_CRM_Register (synckey, Cmi_numpes, TRUE)) < 0) {
+  if ((_Cmi_mype = CMI_VMI_CRM_Register (synckey, _Cmi_numpes, TRUE)) < 0) {
     CmiAbort ("Unable to synchronize with the CRM.");
   }
 
   DEBUG_PRINT ("This process's rank is %d of %d total processes.\n",
-              Cmi_mype, Cmi_numpes);
+              _Cmi_mype, _Cmi_numpes);
 
   /*
     **********
@@ -1671,7 +1671,7 @@ void ConverseInit (int argc, char **argv, CmiStartFn startFn,
     CmiAbort ("Unable to allocate memory for VMI_KEY environment variable.");
   }
 
-  sprintf (vmikey, "VMI_KEY=%s:%d\0", synckey, Cmi_mype);
+  sprintf (vmikey, "VMI_KEY=%s:%d\0", synckey, _Cmi_mype);
 
   if (putenv (vmikey) == -1) {
     CmiAbort ("Unable to set VMI_KEY environment variable.");
@@ -1716,7 +1716,7 @@ void ConverseInit (int argc, char **argv, CmiStartFn startFn,
        &CMI_VMI_Handle_Pool);
   CMI_VMI_CHECK_SUCCESS (status, "VMI_Pool_Create_Buffer_Pool()");
 
-  status = VMI_Pool_Create_Buffer_Pool (Cmi_numpes * sizeof (int),
+  status = VMI_Pool_Create_Buffer_Pool (_Cmi_numpes * sizeof (int),
        sizeof (PVOID), CMI_VMI_RDMA_BYTES_SENT_POOL_PREALLOCATE,
        CMI_VMI_RDMA_BYTES_SENT_POOL_GROW, VMI_POOL_CLEARONCE,
        &CMI_VMI_RDMABytesSent_Pool);
@@ -1809,7 +1809,7 @@ void ConverseInit (int argc, char **argv, CmiStartFn startFn,
   sprintf (initkey, "%s:Initialized", synckey);
 
   /* Re-register with the CRM. */
-  if (CMI_VMI_CRM_Register (initkey, Cmi_numpes, FALSE) < -1) {
+  if (CMI_VMI_CRM_Register (initkey, _Cmi_numpes, FALSE) < -1) {
     CmiAbort ("Unable to re-synchronize with all processes.");
   }
 
@@ -1881,7 +1881,7 @@ void ConverseExit ()
     Issue a disconnect request to each process with a rank lower than
     this process's rank.
   */
-  for (i = 0; i < Cmi_mype; i++) {
+  for (i = 0; i < _Cmi_mype; i++) {
     // Do this first to avoid a race condition where the disconnect
     // completes and then we set the state flag here.
     (&CMI_VMI_Procs[i])->state = CMI_VMI_CONNECTION_DISCONNECTING;
@@ -1891,7 +1891,7 @@ void ConverseExit ()
     CMI_VMI_CHECK_SUCCESS (status, "VMI_Connection_Disconnect()");
   }
 
-  (&CMI_VMI_Procs[Cmi_mype])->state = CMI_VMI_CONNECTION_DISCONNECTED;
+  (&CMI_VMI_Procs[_Cmi_mype])->state = CMI_VMI_CONNECTION_DISCONNECTED;
 
   /* Complete all disconnect requests and accepts. */
   gettimeofday (&tp, NULL);
@@ -1907,7 +1907,7 @@ void ConverseExit ()
     nowtime = tp.tv_sec;
 
     pending = FALSE;
-    for (i = 0; i < Cmi_numpes; i++) {
+    for (i = 0; i < _Cmi_numpes; i++) {
       pending = pending ||
            ((&CMI_VMI_Procs[i])->state != CMI_VMI_CONNECTION_DISCONNECTED);
     }
@@ -2148,7 +2148,7 @@ void CmiSyncSendFn (int destrank, int msgsize, char *msg)
   CMI_SET_BROADCAST_ROOT (msg, 0);
 #endif
 
-  if (destrank == Cmi_mype) {
+  if (destrank == _Cmi_mype) {
     msgcopy = CmiAlloc (msgsize);
     memcpy (msgcopy, msg, msgsize);
     CdsFifo_Enqueue (CpvAccess (CmiLocalQueue), msgcopy);
@@ -2235,7 +2235,7 @@ CmiCommHandle CmiAsyncSendFn (int destrank, int msgsize, char *msg)
   CMI_SET_BROADCAST_ROOT (msg, 0);
 #endif
 
-  if (destrank == Cmi_mype) {
+  if (destrank == _Cmi_mype) {
     msgcopy = CmiAlloc (msgsize);
     memcpy (msgcopy, msg, msgsize);
     CdsFifo_Enqueue (CpvAccess (CmiLocalQueue), msgcopy);
@@ -2366,7 +2366,7 @@ void CmiFreeSendFn (int destrank, int msgsize, char *msg)
   CMI_SET_BROADCAST_ROOT (msg, 0);
 #endif
 
-  if (destrank == Cmi_mype) {
+  if (destrank == _Cmi_mype) {
     CdsFifo_Enqueue (CpvAccess (CmiLocalQueue), msg);
   } else if (msgsize < CMI_VMI_Short_Message_Boundary) {
     inlmsg.hdr.type = CMI_VMI_MESSAGE_TYPE_SHORT;
@@ -2482,7 +2482,7 @@ void CmiSyncBroadcastFn (int msgsize, char *msg)
     sz[1] = (ULONG) msgsize;
 
 #if CMK_BROADCAST_SPANNING_TREE
-    CMI_SET_BROADCAST_ROOT (msg, (Cmi_mype + 1));
+    CMI_SET_BROADCAST_ROOT (msg, (_Cmi_mype + 1));
 
     childcount = CMI_VMI_Spanning_Children_Count (msg);
 
@@ -2490,20 +2490,20 @@ void CmiSyncBroadcastFn (int msgsize, char *msg)
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send ((&CMI_VMI_Procs[destrank])->connection,
           bufHandles, addrs, sz, 2, CMI_VMI_Stream_Completion_Handler,
@@ -2511,16 +2511,16 @@ void CmiSyncBroadcastFn (int msgsize, char *msg)
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 #else   /* CMK_BROADCAST_SPANNING_TREE */
-    handle.refcount = Cmi_numpes;
+    handle.refcount = _Cmi_numpes;
 
-    for (i = 0; i < Cmi_mype; i++) {
+    for (i = 0; i < _Cmi_mype; i++) {
       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++) {
+    for (i = (_Cmi_mype + 1); i < _Cmi_numpes; i++) {
       status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
            addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
            TRUE);
@@ -2558,7 +2558,7 @@ void CmiSyncBroadcastFn (int msgsize, char *msg)
                     sizeof (CMI_VMI_Message_Body_Rendezvous_T));
 
 #if CMK_BROADCAST_SPANNING_TREE
-    CMI_SET_BROADCAST_ROOT (msg, (Cmi_mype + 1));
+    CMI_SET_BROADCAST_ROOT (msg, (_Cmi_mype + 1));
 
     childcount = CMI_VMI_Spanning_Children_Count (msg);
 
@@ -2566,20 +2566,20 @@ void CmiSyncBroadcastFn (int msgsize, char *msg)
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[destrank])->connection,
           addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
@@ -2587,16 +2587,16 @@ void CmiSyncBroadcastFn (int msgsize, char *msg)
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
 #else   /* CMK_BROADCAST_SPANNING_TREE */
-    handle.refcount = Cmi_numpes;
+    handle.refcount = _Cmi_numpes;
 
-    for (i = 0; i < Cmi_mype; i++) {
+    for (i = 0; i < _Cmi_mype; i++) {
       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++) {
+    for (i = (_Cmi_mype + 1); i < _Cmi_numpes; i++) {
       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));
@@ -2670,39 +2670,39 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
     sz[1] = msgsize;
 
 #if CMK_BROADCAST_SPANNING_TREE
-    CMI_SET_BROADCAST_ROOT (msg, (Cmi_mype + 1));
+    CMI_SET_BROADCAST_ROOT (msg, (_Cmi_mype + 1));
 
     childcount = CMI_VMI_Spanning_Children_Count (msg);
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[destrank])->connection,
            addrs, sz, 2, sizeof (CMI_VMI_Message_Header_T) + msgsize);
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
 #else   /* CMK_BROADCAST_SPANNING_TREE */
-    for (i = 0; i < Cmi_mype; i++) {
+    for (i = 0; i < _Cmi_mype; i++) {
       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++) {
+    for (i = (_Cmi_mype + 1); i < _Cmi_numpes; i++) {
       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()");
@@ -2745,7 +2745,7 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
     sz[1] = (ULONG) msgsize;
 
 #if CMK_BROADCAST_SPANNING_TREE
-    CMI_SET_BROADCAST_ROOT (msg, (Cmi_mype + 1));
+    CMI_SET_BROADCAST_ROOT (msg, (_Cmi_mype + 1));
 
     childcount = CMI_VMI_Spanning_Children_Count (msg);
 
@@ -2755,20 +2755,20 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send ((&CMI_VMI_Procs[destrank])->connection,
            bufHandles, addrs, sz, 2, CMI_VMI_Stream_Completion_Handler,
@@ -2776,18 +2776,18 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 #else   /* CMK_BROADCAST_SPANNING_TREE */
-    handle->refcount = (Cmi_numpes - 1);
-    commhandle->count = (Cmi_numpes - 1);
-    CMI_VMI_AsyncMsgCount += (Cmi_numpes - 1);
+    handle->refcount = (_Cmi_numpes - 1);
+    commhandle->count = (_Cmi_numpes - 1);
+    CMI_VMI_AsyncMsgCount += (_Cmi_numpes - 1);
 
-    for (i = 0; i < Cmi_mype; i++) {
+    for (i = 0; i < _Cmi_mype; i++) {
       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++) {
+    for (i = (_Cmi_mype + 1); i < _Cmi_numpes; i++) {
       status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
            addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
            TRUE);
@@ -2821,7 +2821,7 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
                     sizeof (CMI_VMI_Message_Body_Rendezvous_T));
 
 #if CMK_BROADCAST_SPANNING_TREE
-    CMI_SET_BROADCAST_ROOT (msg, (Cmi_mype + 1));
+    CMI_SET_BROADCAST_ROOT (msg, (_Cmi_mype + 1));
 
     childcount = CMI_VMI_Spanning_Children_Count (msg);
 
@@ -2831,20 +2831,20 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[destrank])->connection,
            addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
@@ -2852,18 +2852,18 @@ CmiCommHandle CmiAsyncBroadcastFn (int msgsize, char *msg)
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
 #else   /* CMK_BROADCAST_SPANNING_TREE */
-    handle->refcount = (Cmi_numpes - 1);
-    commhandle->count = (Cmi_numpes - 1);
-    CMI_VMI_AsyncMsgCount += (Cmi_numpes - 1);
+    handle->refcount = (_Cmi_numpes - 1);
+    commhandle->count = (_Cmi_numpes - 1);
+    CMI_VMI_AsyncMsgCount += (_Cmi_numpes - 1);
 
-    for (i = 0; i < Cmi_mype; i++) {
+    for (i = 0; i < _Cmi_mype; i++) {
       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++) {
+    for (i = (_Cmi_mype + 1); i < _Cmi_numpes; i++) {
       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));
@@ -2943,7 +2943,7 @@ void CmiFreeBroadcastFn (int msgsize, char *msg)
     sz[1] = (ULONG) msgsize;
 
 #if CMK_BROADCAST_SPANNING_TREE
-    CMI_SET_BROADCAST_ROOT (msg, (Cmi_mype + 1));
+    CMI_SET_BROADCAST_ROOT (msg, (_Cmi_mype + 1));
 
     childcount = CMI_VMI_Spanning_Children_Count (msg);
 
@@ -2951,20 +2951,20 @@ void CmiFreeBroadcastFn (int msgsize, char *msg)
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send ((&CMI_VMI_Procs[destrank])->connection,
            bufHandles, addrs, sz, 2, CMI_VMI_Stream_Completion_Handler,
@@ -2972,16 +2972,16 @@ void CmiFreeBroadcastFn (int msgsize, char *msg)
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send()");
     }
 #else   /* CMK_BROADCAST_SPANNING_TREE */
-    handle.refcount = Cmi_numpes;
+    handle.refcount = _Cmi_numpes;
 
-    for (i = 0; i < Cmi_mype; i++) {
+    for (i = 0; i < _Cmi_mype; i++) {
       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++) {
+    for (i = (_Cmi_mype + 1); i < _Cmi_numpes; i++) {
       status = VMI_Stream_Send ((&CMI_VMI_Procs[i])->connection, bufHandles,
            addrs, sz, 2, CMI_VMI_Stream_Completion_Handler, (PVOID) &handle,
            TRUE);
@@ -3019,7 +3019,7 @@ void CmiFreeBroadcastFn (int msgsize, char *msg)
                     sizeof (CMI_VMI_Message_Body_Rendezvous_T));
 
 #if CMK_BROADCAST_SPANNING_TREE
-    CMI_SET_BROADCAST_ROOT (msg, (Cmi_mype + 1));
+    CMI_SET_BROADCAST_ROOT (msg, (_Cmi_mype + 1));
 
     childcount = CMI_VMI_Spanning_Children_Count (msg);
 
@@ -3027,20 +3027,20 @@ void CmiFreeBroadcastFn (int msgsize, char *msg)
 
     startrank = CMI_BROADCAST_ROOT (msg) - 1;
     for (i = 1; i <= CMI_VMI_BROADCAST_SPANNING_FACTOR; i++) {
-      destrank = Cmi_mype - startrank;
+      destrank = _Cmi_mype - startrank;
 
       if (destrank < 0) {
-       destrank += Cmi_numpes;
+       destrank += _Cmi_numpes;
       }
 
       destrank = CMI_VMI_BROADCAST_SPANNING_FACTOR * destrank + i;
 
-      if (destrank > (Cmi_numpes - 1)) {
+      if (destrank > (_Cmi_numpes - 1)) {
        break;
       }
 
       destrank += startrank;
-      destrank %= Cmi_numpes;
+      destrank %= _Cmi_numpes;
 
       status = VMI_Stream_Send_Inline ((&CMI_VMI_Procs[destrank])->connection,
           addrs, sz, 1, sizeof (CMI_VMI_Message_Header_T) +
@@ -3048,16 +3048,16 @@ void CmiFreeBroadcastFn (int msgsize, char *msg)
       CMI_VMI_CHECK_SUCCESS (status, "VMI_Stream_Send_Inline()");
     }
 #else   /* CMK_BROADCAST_SPANNING_TREE */
-    handle.refcount = Cmi_numpes;
+    handle.refcount = _Cmi_numpes;
 
-    for (i = 0; i < Cmi_mype; i++) {
+    for (i = 0; i < _Cmi_mype; i++) {
       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++) {
+    for (i = (_Cmi_mype + 1); i < _Cmi_numpes; i++) {
       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));
index 90b6c8f872f977cfe0835f3a447e4175329bf921..ef187a6ee76ae4fd0e69a1b461d1cc596f4324ba 100644 (file)
@@ -301,10 +301,10 @@ CkArrayID CProxy_ArrayBase::ckCreateArray(CkArrayMessage *m,int ctor,
   if (opts.getLocationManager().isZero())
   { //Create a new location manager
 #if !CMK_LBDB_ON
-    CkGroupID lbdb;
+    CkGroupID _lbdb;
 #endif
     opts.setLocationManager(CProxy_CkLocMgr::ckNew(
-      opts.getMap(),lbdb,opts.getNumInitial()
+      opts.getMap(),_lbdb,opts.getNumInitial()
       ));
   }
   //Create the array manager
index f21a8f78fe75f8b5a4064de208cd9033a68534f9..df3e5a0f1584c4363337e5d80e356a9131f2ca02 100644 (file)
@@ -13,13 +13,13 @@ Initial version by Orion Sky Lawlor, olawlor@acm.org, 2/8/2002
 #include "ckcallback-ccs.h"
 #include "CkCallback.decl.h"
 
-/*readonly*/ CProxy_ckcallback_group ckcallbackgroup;
+/*readonly*/ CProxy_ckcallback_group _ckcallbackgroup;
 
 //This main chare is only used to create the callback forwarding group
 class ckcallback_main : public CBase_ckcallback_main {
 public:
        ckcallback_main(CkArgMsg *m) {
-               ckcallbackgroup=CProxy_ckcallback_group::ckNew();
+               _ckcallbackgroup=CProxy_ckcallback_group::ckNew();
                delete m;
        }
 };
@@ -112,7 +112,7 @@ void CkCallback::send(void *msg) const
                                CthAwaken(dest->d.thread.th);
                } 
                else //Forward message to processor where the thread actually lives
-                       ckcallbackgroup[d.thread.onPE].call(*this,(CkMessage *)msg);
+                       _ckcallbackgroup[d.thread.onPE].call(*this,(CkMessage *)msg);
                break;
        case call1Fn: //Call a C function pointer on the current processor
                (d.c1fn.fn)(msg);
@@ -121,7 +121,7 @@ void CkCallback::send(void *msg) const
                if (d.cfn.onPE==CkMyPe())
                        (d.cfn.fn)(d.cfn.param,msg);
                else
-                       ckcallbackgroup[d.cfn.onPE].call(*this,(CkMessage *)msg);
+                       _ckcallbackgroup[d.cfn.onPE].call(*this,(CkMessage *)msg);
                break;
        case sendChare: //Send message to a chare
                if (!msg) msg=CkAllocSysMsg();
@@ -187,7 +187,7 @@ void ckcallback_group::registerCcsCallback(const char *name,const CkCallback &cb
 
 // Broadcast this callback registration to all processors
 void CcsRegisterHandler(const char *ccs_handlername,const CkCallback &cb) {
-       ckcallbackgroup.registerCcsCallback(ccs_handlername,cb);
+       _ckcallbackgroup.registerCcsCallback(ccs_handlername,cb);
 }
 
 
index 23f558dfd1d2adb45889e629673a8de0aba555f1..b1ca83eeeca6cbd6b98c5ffafe31219bd7bbc9b9 100644 (file)
@@ -1,5 +1,5 @@
 module CkCallback {
-       readonly CProxy_ckcallback_group ckcallbackgroup;
+       readonly CProxy_ckcallback_group _ckcallbackgroup;
        message CkCcsRequestMsg {
                char data[];
        };
index a4d11bba947f5a1ef8cce5d507c2438d05ba3733..ae4e5cbe7c4dc5e06a17be2e2ed70fdcffba234c 100644 (file)
@@ -616,7 +616,7 @@ int CkLocRec::lookupProcessor(void) {return -1;}
 
 
 /*----------------- Local:
-Matches up the array index with the local index, and
+Matches up the array index with the local index, an
 interfaces with the load balancer on behalf of the
 represented array elements.
 */
@@ -1044,7 +1044,7 @@ CkPrintf("CkLocMgr::pup after puping lbdbID=%d\n",lbdbID.idx);
                map=(CkArrayMap *)CkLocalBranch(mapID);
                if (map==NULL) CkAbort("ERROR!  Local branch of array map is NULL!");
                mapHandle=map->registerArray(0,thisgroup);
-               // lbdb is the fixed global groupID
+               // _lbdb is the fixed global groupID
                initLB(lbdbID);
                doneInserting();
        }
index 5214044886109becfa348bb7c82b88a8092e37a4..8939715a3752417d8be4f536ec509fe88879e8d1 100644 (file)
@@ -6,7 +6,7 @@ module CkLocation {
   };
 
   group [migratable] CkLocMgr {
-       entry CkLocMgr(CkGroupID map,CkGroupID lbdb,int numInitial);
+       entry CkLocMgr(CkGroupID map,CkGroupID _lbdb,int numInitial);
        entry void deliverInline(CkMessage *m);
 //     entry [immediate] void deliverImmediate(CkMessage *m);
        entry void deliverImmediate(CkMessage *m);
index 08f2523f81359a11dcec3bf61878b35f6878a4ec..4004584436b7e9b7eb9d6d31d5ed40ccef63b4e7 100644 (file)
@@ -450,7 +450,7 @@ public:
 class CkLocMgr : public IrrGroup {
        CkMagicNumber<CkMigratable> magic; //To detect heap corruption
 public:
-       CkLocMgr(CkGroupID map,CkGroupID lbdb,int numInitial);
+       CkLocMgr(CkGroupID map,CkGroupID _lbdb,int numInitial);
        CkLocMgr(CkMigrateMessage *m);
        inline CmiBool isLocMgr(void) { return CmiTrue; }
        CkGroupID &getGroupID(void) {return thisgroup;}
index 322f0b2207f85c999808a0b53c87b23c884a0f32..c073680f6e23546f2b13e9b3aa5c665e134b3a3e 100644 (file)
@@ -453,17 +453,17 @@ void _CkExit(void)
 #endif
 }
 
-CkQ<CkExitFn> CkExitFnVec;
+CkQ<CkExitFn> _CkExitFnVec;
 
 // wrapper of CkExit
-// traverse CkExitFnVec to call registered user exit functions
+// traverse _CkExitFnVec to call registered user exit functions
 // CkExitFn will call CkExit() when finished to make sure other
 // registered functions get called.
 extern "C"
 void CkExit(void)
 {
-  if (!CkExitFnVec.isEmpty()) {
-    CkExitFn fn = CkExitFnVec.deq();
+  if (!_CkExitFnVec.isEmpty()) {
+    CkExitFn fn = _CkExitFnVec.deq();
     fn();
   }
   else
@@ -755,7 +755,7 @@ extern "C" void fmain_(int *argc,char _argv[][80],int length[])
 // see trace-summary for an example.
 void registerExitFn(CkExitFn fn)
 {
-  CkExitFnVec.enq(fn);
+  _CkExitFnVec.enq(fn);
 }
 
 /*@}*/
index 47d42f3beecdd1b721e2700723399e9d32aef0f7..d3bae477e87dd79d87ecb76aeff756bc559d63b2 100644 (file)
@@ -152,7 +152,7 @@ extern "C" void CkRegisterMainModule(void);
 
 typedef  void  (*CkExitFn) (void);
 
-extern CkQ<CkExitFn> CkExitFnVec;
+extern CkQ<CkExitFn> _CkExitFnVec;
 extern void registerExitFn(CkExitFn);
 
 /*@}*/
index 6260b5d495a8a0be46ca73e48f63024777a6b692..28ef47b05cb44c63b5a4953026ef601da510d4d6 100644 (file)
@@ -8,17 +8,17 @@
 #include "waitqd.h"
 
 /* readonly */ 
-CkChareID waitqd_qdhandle;
+CkChareID _waitqd_qdhandle;
 
 extern "C" void CkWaitQD(void) {
-  CProxy_waitqd_QDChare qdchareproxy(waitqd_qdhandle);
+  CProxy_waitqd_QDChare qdchareproxy(_waitqd_qdhandle);
   qdchareproxy.waitQD();
 }
   
 waitqd_QDChare::waitqd_QDChare(CkArgMsg *m) {
   waitStarted = 0;
   threadList = 0;
-  waitqd_qdhandle = thishandle;
+  _waitqd_qdhandle = thishandle;
   delete m;
 }
 
index 32d041435e0a962e59fedae35dd3e59d1f110922..93f8ed970dd948e8532242b61e24a2880b9b2da8 100644 (file)
@@ -14,7 +14,7 @@ module waitqd {
 
   extern module CkFutures;
 
-  readonly CkChareID waitqd_qdhandle; 
+  readonly CkChareID _waitqd_qdhandle; 
 
   mainchare waitqd_QDChare {
     entry waitqd_QDChare(CkArgMsg *m);
index db5f224cdf7e81e353d800dba82b893bd0f15d0d..8b82ccf3ab998beda46e48ae3cfc67033fe20ca9 100644 (file)
@@ -22,7 +22,7 @@ BaseLB::BaseLB(const CkLBOptions &opt) {
   if (CkpvAccess(numLoadBalancers) - CkpvAccess(hasNullLB) > 1)
     CmiAbort("Error: try to create more than one load balancer strategies!");
 */
-  theLbdb = CProxy_LBDatabase(lbdb).ckLocalBranch();
+  theLbdb = CProxy_LBDatabase(_lbdb).ckLocalBranch();
   lbname = "Unknown";
   // register this load balancer to LBDatabase at the sequence number
   theLbdb->addLoadbalancer(this, seqno);
index 4751a783ac287f7082c6a6abe12e16e2dfe9b765..e2ce116d2a106ccd73e4b0e475a18e5272cb4eb1 100644 (file)
@@ -211,7 +211,7 @@ void CentralLB::buildStats()
        statsMsgsList[pe]=0;
     }
     statsData->n_migrateobjs = nmigobj;
-    if (lb_debug) {
+    if (_lb_debug) {
       CmiPrintf("n_obj:%d migratable:%d ncom:%d\n", nobj, nmigobj, ncom);
     }
 }
@@ -238,7 +238,7 @@ void CentralLB::ReceiveStats(CkMarshalledCLBStatsMessage &msg)
     struct ProcStats &procStat = statsData->procs[pe];
     procStat.total_walltime = m->total_walltime;
     procStat.total_cputime = m->total_cputime;
-    if (lb_ignoreBgLoad) {
+    if (_lb_ignoreBgLoad) {
       procStat.idletime = 0.0;
       procStat.bg_walltime = 0.0;
       procStat.bg_cputime = 0.0;
@@ -260,7 +260,7 @@ void CentralLB::ReceiveStats(CkMarshalledCLBStatsMessage &msg)
 
   const int clients = CkNumPes();
   if (stats_msg_count == clients) {
-    if (lb_debug) 
+    if (_lb_debug) 
       CmiPrintf("[%s] Load balancing step %d starting at %f in PE%d\n",
                  lbName(), step(),start_lb_time, cur_ld_balancer);
 //    double strat_start_time = CmiWallTimer();
@@ -284,7 +284,7 @@ void CentralLB::ReceiveStats(CkMarshalledCLBStatsMessage &msg)
 
 //  calculate predicted load
 //  very time consuming though, so only happen when debugging is on
-    if (lb_debug) {
+    if (_lb_debug) {
       double minObjLoad, maxObjLoad;
       getPredictedLoad(statsData, clients, migrateMsg, migrateMsg->expectedLoad, minObjLoad, maxObjLoad, 1);
     }
@@ -409,7 +409,7 @@ void CentralLB::ReceiveMigration(LBMigrateMsg *m)
 
 void CentralLB::MigrationDone(int balancing)
 {
-  if (balancing && lb_debug && CkMyPe() == cur_ld_balancer) {
+  if (balancing && _lb_debug && CkMyPe() == cur_ld_balancer) {
     double end_lb_time = CmiWallTimer();
       CkPrintf("[%s] Load balancing step %d finished at %f\n",
                lbName(), step(),end_lb_time);
@@ -520,7 +520,7 @@ LBMigrateMsg * CentralLB::createMigrateMsg(LDStats* stats,int count)
     delete item;
     migrateInfo[i] = 0;
   }
-  if (lb_debug)
+  if (_lb_debug)
     CkPrintf("%s: %d objects migrating.\n", lbname, migrate_count);
   return msg;
 }
index fcf1b1ab58d9cd22447f28cfd50a72867b02b0ec..a325c835af289a374f8a840024c49458512c66dc 100644 (file)
@@ -196,7 +196,7 @@ void Comm1LB::work(CentralLB::LDStats* stats, int count)
        xcoord = stats->getHash(commData.sender); 
        ycoord = stats->getHash(commData.receiver.get_destObj());
        if((xcoord == -1)||(ycoord == -1))
-         if (lb_ignoreBgLoad) continue;
+         if (_lb_ignoreBgLoad) continue;
          else CkAbort("Error in search\n");
        add_graph(xcoord,ycoord,commData.bytes, commData.messages);     
       }
index 6cca0c728e5990640eba0a7c8b94b40e3e00b250..79e1fd3009b4c8d4365d4cb4ff9e6c8d48db82dd 100644 (file)
@@ -205,7 +205,7 @@ void CommLB::work(CentralLB::LDStats* _stats, int count)
                xcoord = stats->getHash(commData.sender);
                ycoord = stats->getHash(commData.receiver.get_destObj());
                if((xcoord == -1)||(ycoord == -1))
-                   if (lb_ignoreBgLoad) continue;
+                   if (_lb_ignoreBgLoad) continue;
                    else CkAbort("Error in search\n");
                add_graph(xcoord,ycoord,commData.bytes, commData.messages);
         }
index e211782c72a53560e609aced6b971f2250047f65..5bc8195a3451d8c740926b4b281a06ac993b6b7f 100644 (file)
@@ -61,7 +61,7 @@ LBDB::LBDB(): useBarrier(CmiTrue)
     commTable = new LBCommTable;
     obj_walltime = obj_cputime = 0;
     startLBFn_count = 0;
-    batsync.init(this, autoLbPeriod);          // original 1.0 second
+    batsync.init(this, _autoLbPeriod);         // original 1.0 second
 }
 
 LDOMHandle LBDB::AddOM(LDOMid _userID, void* _userData, 
@@ -191,7 +191,7 @@ int LBDB::ObjDataCount()
 {
   int nitems=0;
   int i;
-  if (lb_ignoreBgLoad) {
+  if (_lb_ignoreBgLoad) {
   for(i=0; i < objCount; i++)
     if (objs[i] && (objs[i])->data.migratable)
       nitems++;
@@ -206,7 +206,7 @@ int LBDB::ObjDataCount()
 
 void LBDB::GetObjData(LDObjData *dp)
 {
-  if (lb_ignoreBgLoad) {
+  if (_lb_ignoreBgLoad) {
   for(int i = 0; i < objs.length(); i++) {
     LBObj* obj = objs[i];
     if ( obj && obj->data.migratable)
index 348fdefb86c9ca0cf7509031ec0a08d837b84d0e..944dcc600fbab112caf95c58422e3f63def3503a 100644 (file)
 
 #include "NullLB.h"
 
-CkGroupID lbdb;
+CkGroupID _lbdb;
 
 CkpvDeclare(int, numLoadBalancers);  /**< num of lb created */
 CkpvDeclare(int, hasNullLB);         /**< true if NullLB is created */
 CkpvDeclare(int, lbdatabaseInited);  /**< true if lbdatabase is inited */
 
 // command line options
-double autoLbPeriod = 1.0;             // in seconds
-int lb_debug=0;
-int lb_ignoreBgLoad=0;
+double _autoLbPeriod = 1.0;            // in seconds
+int _lb_debug=0;
+int _lb_ignoreBgLoad=0;
 
 class LBDBResgistry {
 friend class LBDBInit;
@@ -105,7 +105,7 @@ static void createLoadBalancer(const char *lbname)
 LBDBInit::LBDBInit(CkArgMsg *m)
 {
 #if CMK_LBDB_ON
-  lbdb = CProxy_LBDatabase::ckNew();
+  _lbdb = CProxy_LBDatabase::ckNew();
 
   // runtime specified load balancer
   if (lbRegistry.runtime_lbs.size() > 0) {
@@ -129,7 +129,7 @@ LBDBInit::LBDBInit(CkArgMsg *m)
 
   if (LBSimulation::doSimulation) {
     CmiPrintf("Charm++> Entering Load Balancer Simulation Mode ... \n");
-    CProxy_LBDatabase(lbdb).ckLocalBranch()->StartLB();
+    CProxy_LBDatabase(_lbdb).ckLocalBranch()->StartLB();
   }
 #endif
   delete m;
@@ -154,7 +154,7 @@ void _loadbalancerInit()
 
   // set up init value for LBPeriod time in seconds
   // it can also be set calling LDSetLBPeriod()
-  CmiGetArgDoubleDesc(argv,"+LBPeriod", &autoLbPeriod,"specify the period for automatic load balancing in seconds (for non atSync mode)");
+  CmiGetArgDoubleDesc(argv,"+LBPeriod", &_autoLbPeriod,"specify the period for automatic load balancing in seconds (for non atSync mode)");
 
   /******************* SIMULATION *******************/
   // get the step number at which to dump the LB database
@@ -165,13 +165,13 @@ void _loadbalancerInit()
   LBSimulation::simProcs = 0;
   CmiGetArgIntDesc(argv, "+LBSimProcs", &LBSimulation::simProcs, "Number of target processors.");
 
-  lb_debug = CmiGetArgFlagDesc(argv, "+LBDebug", "Turn on LB debugging printouts");
-  lb_ignoreBgLoad = CmiGetArgFlagDesc(argv, "+LBObjOnly", "Load balancer only balance migratable object without considering the background load, etc");
+  _lb_debug = CmiGetArgFlagDesc(argv, "+LBDebug", "Turn on LB debugging printouts");
+  _lb_ignoreBgLoad = CmiGetArgFlagDesc(argv, "+LBObjOnly", "Load balancer only balance migratable object without considering the background load, etc");
   if (CkMyPe() == 0) {
-    if (lb_debug) {
-      CmiPrintf("LB> Load balancer running with verbose mode, period time: %gs.\n", autoLbPeriod);
+    if (_lb_debug) {
+      CmiPrintf("LB> Load balancer running with verbose mode, period time: %gs.\n", _autoLbPeriod);
     }
-    if (lb_ignoreBgLoad)
+    if (_lb_ignoreBgLoad)
       CmiPrintf("LB> Load balancer only balance migratable object.\n");
     if (LBSimulation::doSimulation)
       CmiPrintf("LB> Load balancer running in simulation mode.\n");
index 272fbe90b59364138d08f56fa017a776804c149c..ae884deb623bc0eb95e3742abd81d6c75443b8f6 100644 (file)
@@ -1,7 +1,7 @@
 module LBDatabase {
   extern module NullLB;
 
-  readonly CkGroupID lbdb;
+  readonly CkGroupID _lbdb;
 
   mainchare LBDBInit {
     entry LBDBInit(CkArgMsg *m);
index eb550fa183384456beb89227e3890fe72bc6baa5..3930b9dc5eac90255f01c31215b6c2a6e709b255 100644 (file)
@@ -28,7 +28,7 @@ PUPbytes(CkLBOptions);
                                                                                 
 #include "LBDatabase.decl.h"
 
-extern CkGroupID lbdb;
+extern CkGroupID _lbdb;
 
 class LBDB;
 
@@ -36,9 +36,9 @@ CkpvExtern(int, numLoadBalancers);
 CkpvExtern(int, hasNullLB);
 CkpvExtern(int, lbdatabaseInited);
 
-extern double autoLbPeriod;
-extern int lb_debug;
-extern int lb_ignoreBgLoad;
+extern double _autoLbPeriod;
+extern int _lb_debug;
+extern int _lb_ignoreBgLoad;
 
 typedef void (*LBCreateFn)();
 void LBDefaultCreate(LBCreateFn f);
@@ -63,7 +63,7 @@ public:
 private:
   void init();
 public:
-  inline static LBDatabase * Object() { return CkpvAccess(lbdatabaseInited)?(LBDatabase *)CkLocalBranch(lbdb):NULL; }
+  inline static LBDatabase * Object() { return CkpvAccess(lbdatabaseInited)?(LBDatabase *)CkLocalBranch(_lbdb):NULL; }
 #if CMK_LBDB_ON
   inline LBDB *getLBDB() {return (LBDB*)(myLDHandle.handle);}
 #endif
index 200971d8ba3f15435bcb4131ba1dab47c59b1728..30f015c801249001235440b0e8bfd9b342356c23 100644 (file)
@@ -112,7 +112,7 @@ void NborBaseLB::AtSync()
 
   if (CkMyPe() == 0) {
     start_lb_time = CmiWallTimer();
-    if (lb_debug)
+    if (_lb_debug)
       CkPrintf("Load balancing step %d starting at %f\n",
               step(),start_lb_time);
   }
@@ -272,7 +272,7 @@ void NborBaseLB::ReceiveStats(NLBStatsMsg *m)
     theLbdb->ClearLoads();
     if (CkMyPe() == 0) {
       double strat_end_time = CmiWallTimer();
-      if (lb_debug)
+      if (_lb_debug)
         CkPrintf("Strat elapsed time %f\n",strat_end_time-strat_start_time);
     }
   }
@@ -324,7 +324,7 @@ void NborBaseLB::MigrationDone()
 {
   if (CkMyPe() == 0 && start_lb_time != 0.0) {
     double end_lb_time = CmiWallTimer();
-    if (lb_debug)
+    if (_lb_debug)
       CkPrintf("Load balancing step %d finished at %f duration %f\n",
                step(),end_lb_time,end_lb_time - start_lb_time);
   }
index 62c1af5fcae1289fce05de68451f8c6879f075f2..3535f87864addf3fab03f409f7c866928c6e57f4 100644 (file)
@@ -100,14 +100,14 @@ ObjGraph::ObjGraph(int count, CentralLB::LDStats* _stats)
 
     Node* from_node = find_node(newedgedata.sender);
     if (from_node == 0) {
-      if (!lb_ignoreBgLoad) 
+      if (!_lb_ignoreBgLoad) 
        CkPrintf("ObjGraph::find_node: Didn't locate from node match!\n");
       continue;
     }
 
     Node* to_node = find_node(newedgedata.receiver.get_destObj());
     if (to_node == 0) {
-      if (!lb_ignoreBgLoad) 
+      if (!_lb_ignoreBgLoad) 
         CkPrintf("ObjGraph::find_node: Didn't locate to node match!\n");
       continue;
     }
index 5fddc88952eced42cfc87be479261e178daa1285..94f6bf5e609b12b67b8583c0160f8f95ce32d24e 100644 (file)
@@ -194,7 +194,7 @@ LDHandle LDCreate(void);
 #define LDCreate() 0
 #endif
 
-LDOMHandle LDRegisterOM(LDHandle lbdb, LDOMid userID, 
+LDOMHandle LDRegisterOM(LDHandle _lbdb, LDOMid userID, 
                        void *userptr, LDCallbacks cb);
 void * LDOMUserData(LDOMHandle &_h);
 void LDRegisteringObjects(LDOMHandle _h);
@@ -217,37 +217,37 @@ void LDMessage(LDObjHandle from,
 void LDEstObjLoad(LDObjHandle h, double load);
 void LDNonMigratable(const LDObjHandle &h);
 void LDMigratable(const LDObjHandle &h);
-void LDDumpDatabase(LDHandle lbdb);
+void LDDumpDatabase(LDHandle _lbdb);
 
 /*
  * Calls from load balancer to load database
  */  
 typedef void (*LDMigratedFn)(void* data, LDObjHandle handle);
-void LDNotifyMigrated(LDHandle lbdb, LDMigratedFn fn, void* data);
+void LDNotifyMigrated(LDHandle _lbdb, LDMigratedFn fn, void* data);
 
 typedef void (*LDStartLBFn)(void *user_ptr);
-void LDAddStartLBFn(LDHandle lbdb, LDStartLBFn fn, void* data);
-void LDRemoveStartLBFn(LDHandle lbdb, LDStartLBFn fn);
+void LDAddStartLBFn(LDHandle _lbdb, LDStartLBFn fn, void* data);
+void LDRemoveStartLBFn(LDHandle _lbdb, LDStartLBFn fn);
 void LDStartLB(LDHandle _db);
-void LDTurnManualLBOn(LDHandle lbdb);
-void LDTurnManualLBOff(LDHandle lbdb);
+void LDTurnManualLBOn(LDHandle _lbdb);
+void LDTurnManualLBOff(LDHandle _lbdb);
 
-void LDCollectStatsOn(LDHandle lbdb);
-void LDCollectStatsOff(LDHandle lbdb);
+void LDCollectStatsOn(LDHandle _lbdb);
+void LDCollectStatsOff(LDHandle _lbdb);
 void LDQueryEstLoad(LDHandle bdb);
 void LDQueryKnownObjLoad(LDObjHandle &h, double *cpuT, double *wallT);
 
-int LDGetObjDataSz(LDHandle lbdb);
-void LDGetObjData(LDHandle lbdb, LDObjData *data);
+int LDGetObjDataSz(LDHandle _lbdb);
+void LDGetObjData(LDHandle _lbdb, LDObjData *data);
 
-int LDGetCommDataSz(LDHandle lbdb);
-void LDGetCommData(LDHandle lbdb, LDCommData *data);
+int LDGetCommDataSz(LDHandle _lbdb);
+void LDGetCommData(LDHandle _lbdb, LDCommData *data);
 
-void LDBackgroundLoad(LDHandle lbdb, double *walltime, double *cputime);
-void LDIdleTime(LDHandle lbdb, double *walltime);
-void LDTotalTime(LDHandle lbdb, double *walltime, double *cputime);
+void LDBackgroundLoad(LDHandle _lbdb, double *walltime, double *cputime);
+void LDIdleTime(LDHandle _lbdb, double *walltime);
+void LDTotalTime(LDHandle _lbdb, double *walltime, double *cputime);
 
-void LDClearLoads(LDHandle lbdb);
+void LDClearLoads(LDHandle _lbdb);
 void LDMigrate(LDObjHandle h, int dest);
 void LDMigrated(LDObjHandle h);
 
@@ -265,16 +265,16 @@ typedef struct {
   int serial;
 } LDBarrierReceiver;
 
-LDBarrierClient LDAddLocalBarrierClient(LDHandle lbdb,LDResumeFn fn,
+LDBarrierClient LDAddLocalBarrierClient(LDHandle _lbdb,LDResumeFn fn,
                                        void* data);
-void LDRemoveLocalBarrierClient(LDHandle lbdb, LDBarrierClient h);
-LDBarrierReceiver LDAddLocalBarrierReceiver(LDHandle lbdb,LDBarrierFn fn,
+void LDRemoveLocalBarrierClient(LDHandle _lbdb, LDBarrierClient h);
+LDBarrierReceiver LDAddLocalBarrierReceiver(LDHandle _lbdb,LDBarrierFn fn,
                                            void* data);
-void LDRemoveLocalBarrierReceiver(LDHandle lbdb,LDBarrierReceiver h);
-void LDAtLocalBarrier(LDHandle lbdb, LDBarrierClient h);
+void LDRemoveLocalBarrierReceiver(LDHandle _lbdb,LDBarrierReceiver h);
+void LDAtLocalBarrier(LDHandle _lbdb, LDBarrierClient h);
 void LDLocalBarrierOn(LDHandle _db);
 void LDLocalBarrierOff(LDHandle _db);
-void LDResumeClients(LDHandle lbdb);
+void LDResumeClients(LDHandle _lbdb);
 int LDProcessorSpeed();
 CmiBool LDOMidEqual(const LDOMid &i1, const LDOMid &i2);
 CmiBool LDObjIDEqual(const LDObjid &i1, const LDObjid &i2);
index ea1d3e80b53583b187fceabb26c8a6524dc2ff50..2a8495aa3a923e8859a3067b7ad5d1f392dd46dd 100644 (file)
@@ -711,13 +711,13 @@ static double readMHz(void)
   return 0.0;
 }
 
-double cpu_speed_factor;
+double _cpu_speed_factor;
 CpvStaticDeclare(double, inittime_virtual);
 
 void CmiTimerInit()
 {
   struct rusage ru;
-  cpu_speed_factor = 1.0/(readMHz()*1.0e6); 
+  _cpu_speed_factor = 1.0/(readMHz()*1.0e6); 
   rdtsc(); rdtsc(); rdtsc(); rdtsc(); rdtsc();
   CpvInitialize(double, inittime_virtual);
   getrusage(0, &ru); 
index 5b9e087fde374912015fc6ee9a5e62539d31050d..6c60cfb29226b46ad24542c2c8ca322852f74e01 100644 (file)
@@ -60,16 +60,16 @@ extern "C" {
 
 #if CMK_SHARED_VARS_UNAVAILABLE /* Non-SMP version of shared vars. */
 
-extern int Cmi_mype;
-extern int Cmi_numpes;
-extern int Cmi_myrank; /* Normally zero; only 1 during SIGIO handling */
+extern int _Cmi_mype;
+extern int _Cmi_numpes;
+extern int _Cmi_myrank; /* Normally zero; only 1 during SIGIO handling */
 
-#define CmiMyPe()           Cmi_mype
+#define CmiMyPe()           _Cmi_mype
 #define CmiMyRank()         0
-#define CmiNumPes()         Cmi_numpes
+#define CmiNumPes()         _Cmi_numpes
 #define CmiMyNodeSize()     1
-#define CmiMyNode()         Cmi_mype
-#define CmiNumNodes()       Cmi_numpes
+#define CmiMyNode()         _Cmi_mype
+#define CmiNumNodes()       _Cmi_numpes
 #define CmiNodeFirst(node)  (node)
 #define CmiNodeSize(node)   1
 #define CmiNodeOf(pe)       (pe)
@@ -81,7 +81,7 @@ extern int Cmi_myrank; /* Normally zero; only 1 during SIGIO handling */
 #define CpvStaticDeclare(t,v) static t CMK_TAG(Cpv_,v)[2]
 #define CpvInitialize(t,v) do {} while(0)
 #define CpvInitialized(v) 1
-#define CpvAccess(v) CMK_TAG(Cpv_,v)[Cmi_myrank]
+#define CpvAccess(v) CMK_TAG(Cpv_,v)[_Cmi_myrank]
 #define CpvAccessOther(v, r) CMK_TAG(Cpv_,v)[r]
 
 extern void CmiMemLock();
@@ -108,17 +108,17 @@ typedef int CmiNodeLock;
 #define sched_yield() sleep(0)
 #endif
 
-extern int Cmi_numpes;
-extern int Cmi_mynodesize;
-extern int Cmi_mynode;
-extern int Cmi_numnodes;
+extern int _Cmi_numpes;
+extern int _Cmi_mynodesize;
+extern int _Cmi_mynode;
+extern int _Cmi_numnodes;
 
 extern int CmiMyPe();
 extern int CmiMyRank();
-#define CmiNumPes()         Cmi_numpes
-#define CmiMyNodeSize()     Cmi_mynodesize
-#define CmiMyNode()         Cmi_mynode
-#define CmiNumNodes()       Cmi_numnodes
+#define CmiNumPes()         _Cmi_numpes
+#define CmiMyNodeSize()     _Cmi_mynodesize
+#define CmiMyNode()         _Cmi_mynode
+#define CmiNumNodes()       _Cmi_numnodes
 extern int CmiNodeFirst(int node);
 extern int CmiNodeSize(int node);
 extern int CmiNodeOf(int pe);
@@ -149,17 +149,17 @@ extern CmiNodeLock CmiMemLock_lock;
 #include <spp_prog_model.h>
 #include <cps.h>
 
-extern int Cmi_numpes;
-extern int Cmi_mynodesize;
+extern int _Cmi_numpes;
+extern int _Cmi_mynodesize;
 
 #define CmiMyPe()           (my_thread())
 #define CmiMyRank()         (my_thread())
-#define CmiNumPes()         Cmi_numpes
-#define CmiMyNodeSize()     Cmi_numpes
+#define CmiNumPes()         _Cmi_numpes
+#define CmiMyNodeSize()     _Cmi_numpes
 #define CmiMyNode()         0
 #define CmiNumNodes()       1
 #define CmiNodeFirst(node)  0
-#define CmiNodeSize(node)   Cmi_numpes
+#define CmiNodeSize(node)   _Cmi_numpes
 #define CmiNodeOf(pe)       0
 #define CmiRankOf(pe)       (pe)
 
@@ -181,17 +181,17 @@ extern CmiNodeLock CmiCreateLock(void);
 
 #if CMK_SHARED_VARS_UNIPROCESSOR /*Used only by uth- and sim- versions*/
 
-extern int Cmi_mype;
-extern int Cmi_numpes;
+extern int _Cmi_mype;
+extern int _Cmi_numpes;
 
-#define CmiMyPe()              Cmi_mype
-#define CmiMyRank()            Cmi_mype
-#define CmiNumPes()            Cmi_numpes
-#define CmiMyNodeSize()        Cmi_numpes
+#define CmiMyPe()              _Cmi_mype
+#define CmiMyRank()            _Cmi_mype
+#define CmiNumPes()            _Cmi_numpes
+#define CmiMyNodeSize()        _Cmi_numpes
 #define CmiMyNode()            0
 #define CmiNumNodes()          1
 #define CmiNodeFirst(node)     0
-#define CmiNodeSize(node)      Cmi_numpes
+#define CmiNodeSize(node)      _Cmi_numpes
 #define CmiNodeOf(pe)          0
 #define CmiRankOf(pe)          (pe)
 
@@ -228,15 +228,15 @@ extern void         CmiDestroyLock(CmiNodeLock lock);
 #include <sched.h>
 
 extern int CmiMyPe();
-extern int Cmi_numpes;
+extern int _Cmi_numpes;
 
-#define CmiNumPes()            Cmi_numpes
+#define CmiNumPes()            _Cmi_numpes
 #define CmiMyRank()            CmiMyPe()
-#define CmiMyNodeSize()        Cmi_numpes
+#define CmiMyNodeSize()        _Cmi_numpes
 #define CmiMyNode()            0
 #define CmiNumNodes()          1
 #define CmiNodeFirst(node)     0
-#define CmiNodeSize(node)      Cmi_numpes
+#define CmiNodeSize(node)      _Cmi_numpes
 #define CmiNodeOf(pe)          0
 #define CmiRankOf(pe)          (pe)
 
@@ -260,17 +260,17 @@ extern void         CmiDestroyLock(CmiNodeLock lock);
 
 #include <windows.h>
 
-extern int Cmi_numpes;
-extern int Cmi_mynodesize;
-extern int Cmi_mynode;
-extern int Cmi_numnodes;
+extern int _Cmi_numpes;
+extern int _Cmi_mynodesize;
+extern int _Cmi_mynode;
+extern int _Cmi_numnodes;
 
 extern int CmiMyPe();
 extern int CmiMyRank();
-#define CmiNumPes()         Cmi_numpes
-#define CmiMyNodeSize()     Cmi_mynodesize
-#define CmiMyNode()         Cmi_mynode
-#define CmiNumNodes()       Cmi_numnodes
+#define CmiNumPes()         _Cmi_numpes
+#define CmiMyNodeSize()     _Cmi_mynodesize
+#define CmiMyNode()         _Cmi_mynode
+#define CmiNumNodes()       _Cmi_numnodes
 extern int CmiNodeFirst(int node);
 extern int CmiNodeSize(int node);
 extern int CmiNodeOf(int pe);
@@ -413,7 +413,7 @@ double   CmiCpuTimer(void);
 
 #if CMK_TIMER_USE_RDTSC
 
-extern double cpu_speed_factor;
+extern double _cpu_speed_factor;
 
 static __inline__ unsigned long long int rdtsc(void)
 {
@@ -426,7 +426,7 @@ static __inline__ unsigned long long int rdtsc(void)
         return x;
 }
 
-#define CmiWallTimer() ((double)rdtsc()*(cpu_speed_factor))
+#define CmiWallTimer() ((double)rdtsc()*(_cpu_speed_factor))
 #define CmiTimer CmiCpuTimer
 
 #else
@@ -992,13 +992,13 @@ void CmiDelayImmediate();
        CmiSetHandler(msg,CpvAccessOther(CmiImmediateMsgHandlerIdx,0)); \
      } while (0)
 /* 
-  for non smp and non intr based version, it returns immRunning
+  for non smp and non intr based version, it returns _immRunning
   for smp, this doesnot matter - CkMyPe() comparasion normaly fails and
            non threadsafe CqsEnqueueGeneral is avoided.
 */
 #if CMK_NET_VERSION && ! CMK_SMP
-extern int immRunning;
-#  define CmiImmIsRunning()        (immRunning)
+extern int _immRunning;
+#  define CmiImmIsRunning()        (_immRunning)
 #else
 #  define CmiImmIsRunning()        (0)
 #endif
index a3ae7a1ae0ad02956678e236f3b5d5d5a54792c7..faef1f5bbddc2b4b19bde181b9afe10b5879fbe8 100644 (file)
@@ -28,8 +28,8 @@ quiescence detection!
 #endif
 
 CpvDeclare(CQdState, cQdState);
-unsigned int CQdHandlerIdx;
-unsigned int CQdAnnounceHandlerIdx;
+unsigned int _CQdHandlerIdx;
+unsigned int _CQdAnnounceHandlerIdx;
 
 
 int  CQdMsgGetPhase(CQdMsg msg) 
@@ -72,7 +72,7 @@ void CQdProcess(CQdState state, int n)
 void CQdPropagate(CQdState state, CQdMsg msg) 
 {   
   int i;
-  CmiSetHandler(msg, CQdHandlerIdx);
+  CmiSetHandler(msg, _CQdHandlerIdx);
   for(i=0; i<state->nChildren; i++) {
     CQdCreate(state, -1);
     CmiSyncSend(state->children[i], sizeof(struct ConvQdMsg), (char *)msg);
@@ -235,7 +235,7 @@ static void CQdHandlePhase2(CQdState state, CQdMsg msg)
       if(CQdIsDirty(state)) 
        CQdBcastQD1(state, msg);
       else {
-       CmiSetHandler(msg, CQdAnnounceHandlerIdx);
+       CmiSetHandler(msg, _CQdAnnounceHandlerIdx);
        CQdCreate(state, 0-CmiNumPes());
        CmiSyncBroadcastAllAndFree(sizeof(struct ConvQdMsg), (char *) msg);
        CQdReset(state); 
@@ -296,8 +296,8 @@ void CQdCpvInit(void) {
 void CQdInit(void)
 {
   CQdCpvInit();
-  CQdHandlerIdx = CmiRegisterHandler((CmiHandler)CQdHandler);
-  CQdAnnounceHandlerIdx = 
+  _CQdHandlerIdx = CmiRegisterHandler((CmiHandler)CQdHandler);
+  _CQdAnnounceHandlerIdx = 
     CmiRegisterHandler((CmiHandler)CQdAnnounceHandler);
 }
 
@@ -306,7 +306,7 @@ void CmiStartQD(CQdVoidFn fn, void *arg)
   register CQdMsg msg = (CQdMsg) CmiAlloc(sizeof(struct ConvQdMsg)); 
   CQdRegisterCallback(fn, arg);
   CQdMsgSetPhase(msg, 0);  
-  CmiSetHandler(msg, CQdHandlerIdx);
+  CmiSetHandler(msg, _CQdHandlerIdx);
   CQdCreate(CpvAccess(cQdState), -1);
   CmiSyncSendAndFree(0, sizeof(struct ConvQdMsg), (char *)msg);
 }
index 026d151271fb4432060b457faa802ba8a4e4e5d4..0a29c2286ae22beadd7ec991ea4c265f76bc13fc 100644 (file)
@@ -37,9 +37,9 @@
 int MAX_STREAMS = (146138719);
 */
 
-extern unsigned int prime_list[];
+extern unsigned int _prime_list[];
 
-unsigned int PARAMLIST[3][2] = {{0x87b0b0fdU, 0x27bb2ee6U}, 
+unsigned int _PARAMLIST[3][2] = {{0x87b0b0fdU, 0x27bb2ee6U}, 
                                      {0xe78b6955U,0x2c6fe96eU},
                                      {0x31a53f85U,0x369dea0fU}};
 
@@ -77,11 +77,11 @@ void CrnInitStream(CrnStream *genptr, int seed, int type)
   int gennum = seed+CpvAccess(nstreams)*CmiNumPes();
   int i;
 
-  genptr->prime = prime_list[gennum%MAX_STREAMS];
-  genptr->multiplier[0] = (double) (PARAMLIST[type][0]&0x3fffff);
+  genptr->prime = _prime_list[gennum%MAX_STREAMS];
+  genptr->multiplier[0] = (double) (_PARAMLIST[type][0]&0x3fffff);
   genptr->multiplier[1] = (double) 
-    (PARAMLIST[type][0]>>22 | (PARAMLIST[type][1]&0xfff)<<10);
-  genptr->multiplier[2] = (double) (PARAMLIST[type][1]>>12);
+    (_PARAMLIST[type][0]>>22 | (_PARAMLIST[type][1]&0xfff)<<10);
+  genptr->multiplier[2] = (double) (_PARAMLIST[type][1]>>12);
   genptr->state[0] = (double) ((INIT_SEED0^gennum)&0x3fffff);
   genptr->state[1] = (double) 
     ((INIT_SEED0^gennum)>>22 | ((INIT_SEED1 ^ (unsigned)seed<<1)&0xfff)<<10);
@@ -142,7 +142,7 @@ double CrnDrand(void)
   return CrnDouble(&CpvAccess(_defaultStream));
 }
 
-unsigned int prime_list[MAX_STREAMS] = 
+unsigned int _prime_list[MAX_STREAMS] = 
 {
 3037000493U,
 3037000453U,
index e9604efb6465efbd80d99927c015b81e4e88d63b..6918a7258ca5f5b0fff21ee8d98e9d7965dd2ab0 100644 (file)
@@ -40,12 +40,12 @@ int CmiMyPe(void) {return 0;}
 #ifndef CmiMyRank
 int CmiMyRank(void) {return 0;}
 #endif
-int Cmi_mype=0;
-int Cmi_numpes=1;
-int Cmi_myrank=0;
-int Cmi_mynodesize=1;
-int Cmi_mynode=0;
-int Cmi_numnodes=1;
+int _Cmi_mype=0;
+int _Cmi_numpes=1;
+int _Cmi_myrank=0;
+int _Cmi_mynodesize=1;
+int _Cmi_mynode=0;
+int _Cmi_numnodes=1;
  */
 
 /* Mini-micro TCHARM */
index ee5757b571493b3de7bccbb3b46298ca4ede0523..b50e71833e75b827064959432d4f84f62b62bba1 100644 (file)
@@ -176,7 +176,7 @@ int skt_select1(SOCKET fd,int msec)
 
 
 /******* DNS *********/
-skt_ip_t skt_invalid_ip={{0}};
+skt_ip_t _skt_invalid_ip={{0}};
 
 skt_ip_t skt_my_ip(void)
 {
@@ -185,13 +185,13 @@ skt_ip_t skt_my_ip(void)
   if (gethostname(hostname, 999)==0)
       return skt_lookup_ip(hostname);
 
-  return skt_invalid_ip;
+  return _skt_invalid_ip;
 }
 
 static int skt_parse_dotted(const char *str,skt_ip_t *ret)
 {
   int i,v;
-  *ret=skt_invalid_ip;
+  *ret=_skt_invalid_ip;
   for (i=0;i<sizeof(skt_ip_t);i++) {
     if (1!=sscanf(str,"%d",&v)) return 0;
     if (v<0 || v>255) return 0;
@@ -209,13 +209,13 @@ static int skt_parse_dotted(const char *str,skt_ip_t *ret)
 
 skt_ip_t skt_lookup_ip(const char *name)
 {
-  skt_ip_t ret=skt_invalid_ip;
+  skt_ip_t ret=_skt_invalid_ip;
   /*First try to parse the name as dotted decimal*/
   if (skt_parse_dotted(name,&ret))
     return ret;
   else {/*Try a DNS lookup*/
     struct hostent *h = gethostbyname(name);
-    if (h==0) return skt_invalid_ip;
+    if (h==0) return _skt_invalid_ip;
     memcpy(&ret,h->h_addr_list[0],h->h_length);
     return ret;
   }
@@ -242,7 +242,7 @@ skt_ip_t skt_innode_lookup_ip(const char *name)
   struct sockaddr_in addr;
   int len = sizeof(struct sockaddr_in);
   if (-1 == bproc_nodeaddr(atoi(name), &addr, &len)) {
-    return skt_invalid_ip;
+    return _skt_invalid_ip;
   }
   else {
     skt_ip_t ret;
@@ -283,7 +283,7 @@ struct sockaddr_in skt_build_addr(skt_ip_t IP,int port)
 SOCKET skt_datagram(int *port, int bufsize)
 {  
   int connPort=(port==NULL)?0:*port;
-  struct sockaddr_in addr=skt_build_addr(skt_invalid_ip,connPort);
+  struct sockaddr_in addr=skt_build_addr(_skt_invalid_ip,connPort);
   socklen_t          len;
   SOCKET             ret;
   
@@ -323,7 +323,7 @@ SOCKET skt_server_ip(int *port,skt_ip_t *ip)
   socklen_t          len;
   int on = 1; /* for setsockopt */
   int connPort=(port==NULL)?0:*port;
-  struct sockaddr_in addr=skt_build_addr((ip==NULL)?skt_invalid_ip:*ip,connPort);
+  struct sockaddr_in addr=skt_build_addr((ip==NULL)?_skt_invalid_ip:*ip,connPort);
   
 retry:
   ret = socket(PF_INET, SOCK_STREAM, 0);
index 433e1c7bc533c90ca7a142d7322faa14dcefda58..76894d2c03cc605905867568970bb9a1b75c6fde 100644 (file)
@@ -54,7 +54,7 @@
  * SOCKET skt_server_ip(unsigned int *port,skt_ip_t *ip)
  *
  *   - create a TCP server socket on the given port and IP
- *     Use 0 for any port and skt_invalid_ip for any IP.  
+ *     Use 0 for any port and _skt_invalid_ip for any IP.  
  *     Performs the whole socket/bind/listen procedure.  
  *     Returns the actual port and IP address of the socket 
  *     and the file descriptor.
@@ -156,7 +156,7 @@ skt_abortFn skt_set_abort(skt_abortFn f);
 typedef struct { /*IPv4 IP address*/
        unsigned char data[4];
 } skt_ip_t;
-extern skt_ip_t skt_invalid_ip;
+extern skt_ip_t _skt_invalid_ip;
 skt_ip_t skt_my_ip(void);
 skt_ip_t skt_lookup_ip(const char *name);
 skt_ip_t skt_innode_my_ip(void);       /* inner node version */