more changes

diff --git a/Robust/src/Runtime/multicoregarbage.c b/Robust/src/Runtime/multicoregarbage.c
index 50836edb54dfe52301b7232a16975a0bd3994602..e72f6bf88a4fafcfd919172d3daab996f421b816 100644 (file)
--- a/Robust/src/Runtime/multicoregarbage.c
+++ b/Robust/src/Runtime/multicoregarbage.c
@@ -134,7 +134,7 @@ void gc() {
                gcphase = 0;
                for(i = 1; i < NUMCORES - 1; i++) {
                        // send GC start messages to all cores
-                       send_msg_1(true, i, 0x11);
+                       send_msg_1(i, 0x11);
                }
                bool isfirst = true;
                lObjList.head = NULL;
@@ -186,7 +186,7 @@ void gc() {
                                                        for(i = 1; i < NUMCORES; ++i) { 
                                                                gccorestatus[i] = 1;
                                                                // send mark phase finish confirm request msg to core i
-                                                               send_msg_1(true, i, 0x18);
+                                                               send_msg_1(i, 0x18);
                                                        }
                                                } else {
                                                        // all the core status info are the latest
@@ -204,7 +204,7 @@ void gc() {
                // send msgs to all cores requiring large objs info
                gcnumconfirm = NUMCORES - 1;
                for(i = 1; i < NUMCORES; ++i) {
-                       send_msg_1(true, i, 0x1e);
+                       send_msg_1(i, 0x1e);
                }       
                while(gcnumconfirm != 0) {} // wait for responses
                // TODO compute load balance
@@ -238,7 +238,7 @@ void gc() {
                gcphase = 2;
                for(i = 1; i < NUMCORES; ++i) {
                        // send start flush messages to all cores
-                       send_msg_1(true, i, 0x13);
+                       send_msg_1(i, 0x13);
                }
 
                // flush phase
@@ -261,7 +261,7 @@ void gc() {
                gcphase = 3;
                for(i = 1; i < NUMCORES; ++i) {
                        // send gc finish messages to all cores
-                       send_msg_1(true, i, 0x17);
+                       send_msg_1(i, 0x17);
                }
 
                // change to UDN0
@@ -378,7 +378,7 @@ void mark(bool isfirst) {
                                                addNewItem(gctomark, objptr);  
                                        } else {
                                                // send a msg to host informing that objptr is active
-                                               send_msg_2(true, host, 0x1a, objptr);
+                                               send_msg_2(host, 0x1a, objptr);
                                                gcself_numsendobjs++;
                                        }
                                }
@@ -394,7 +394,7 @@ void mark(bool isfirst) {
                                                addNewItem(gctomark, objptr);  
                                        } else {
                                                // send a msg to host informing that objptr is active
-                                               send_msg_2(true, host, 0x1a, objptr);
+                                               send_msg_2(host, 0x1a, objptr);
                                                gcself_numsendobjs++;
                                        }
                                }
@@ -402,7 +402,7 @@ void mark(bool isfirst) {
                } // while(!isEmpty(gctomark))
                gcbusystatus = false;
                // send mark finish msg to core coordinator
-               send_msg_4(true, STARTUPCORE, 0x14, BAMBOO_NUM_OF_CORE, gcself_numsendobjs, gcself_numreceiveobjs); 
+               send_msg_4(STARTUPCORE, 0x14, BAMBOO_NUM_OF_CORE, gcself_numsendobjs, gcself_numreceiveobjs); 
 
                if(BAMBOO_NUM_OF_CORE == 0) {
                        return;
@@ -457,7 +457,7 @@ void compact() {
                if(cinstruction->incomingobjs != NULL) {
                        for(int j = 0; j < cinstruction->incomingobjs->length; j++) {
                                // send messages to corresponding cores to start moving
-                               send_msg_2(true, cinstruction->incomingobjs->dsts[j], 0x1b, BAMBOO_NUM_OF_CORE);
+                               send_msg_2(cinstruction->incomingobjs->dsts[j], 0x1b, BAMBOO_NUM_OF_CORE);
                        }
                }
        } else {
@@ -521,7 +521,7 @@ void compact() {
                }while(cinstruction->largeobjs != NULL);
        }
        // send compact finish message to core coordinator
-       send_msg_2(true, STARTUPCORE, 0x15, BAMBOO_NUM_OF_CORE);
+       send_msg_2(STARTUPCORE, 0x15, BAMBOO_NUM_OF_CORE);
        
 } // compact()
 
@@ -550,7 +550,7 @@ void flush() {
                                        obj2map = (int)objptr;
                                        ismapped = false;
                                        mappedobj = NULL;
-                                       send_msg_3(true, hostcore(objptr), 0x1c, (int)objptr, BAMBOO_NUM_OF_CORE);
+                                       send_msg_3(hostcore(objptr), 0x1c, (int)objptr, BAMBOO_NUM_OF_CORE);
                                        while(!ismapped) {}
                                        dstptr = mappedobj;
                                }
@@ -569,7 +569,7 @@ void flush() {
                                        obj2map = (int)objptr;
                                        ismapped = false;
                                        mappedobj = NULL;
-                                       send_msg_3(true, hostcore(objptr), 0x1c, (int)objptr, BAMBOO_NUM_OF_CORE);
+                                       send_msg_3(hostcore(objptr), 0x1c, (int)objptr, BAMBOO_NUM_OF_CORE);
                                        while(!ismapped) {}
                                        dstptr = mappedobj;
                                }
@@ -579,7 +579,7 @@ void flush() {
                moi = moi->next;
        } // while(moi != NULL)
        // send flush finish message to core coordinator
-       send_msg_2(true, STARTUPCORE, 0x16, BAMBOO_NUM_OF_CORE);
+       send_msg_2(STARTUPCORE, 0x16, BAMBOO_NUM_OF_CORE);
        
 } // flush()
 
@@ -822,9 +822,9 @@ gcmsg:
       } else {
                  // send response msg
                  if(gcisMsgSending) {
-                         cache_msg_5(true, STARTUPCORE, 0x19, BAMBOO_NUM_OF_CORE, gcbusystatus, gcself_numsendobjs, gcself_numreceiveobjs);
+                         cache_msg_5(STARTUPCORE, 0x19, BAMBOO_NUM_OF_CORE, gcbusystatus, gcself_numsendobjs, gcself_numreceiveobjs);
                  } else {
-                         send_msg_5(true, STARTUPCORE, 0x19, BAMBOO_NUM_OF_CORE, gcbusystatus, gcself_numsendobjs, gcself_numreceiveobjs);
+                         send_msg_5(STARTUPCORE, 0x19, BAMBOO_NUM_OF_CORE, gcbusystatus, gcself_numsendobjs, gcself_numreceiveobjs);
                  }
       }
          break;
@@ -873,9 +873,9 @@ gcmsg:
                } else {
                        // send back the mapping info
                        if(gcisMsgSending) {
-                               cache_msg_3(true, gcmsgdata[2], 0x1d, data1, dstptr);
+                               cache_msg_3(gcmsgdata[2], 0x1d, data1, dstptr);
                        } else {
-                               send_msg_3(true, gcmsgdata[2], 0x1d, data1, dstptr);
+                               send_msg_3(gcmsgdata[2], 0x1d, data1, dstptr);
                        }
                }
                break;

diff --git a/Robust/src/Runtime/multicoretask.c b/Robust/src/Runtime/multicoretask.c
index fc5da71de4994b0581cce207dd5ae46111372234..2a9bfce5cac72a6091c381bccf9d620f3a179326 100644 (file)
--- a/Robust/src/Runtime/multicoretask.c
+++ b/Robust/src/Runtime/multicoretask.c
@@ -378,7 +378,7 @@ objqueuebreak:
                                                                  for(i = 1; i < NUMCORES; ++i) {       
                                                                          corestatus[i] = 1;
                                                                          // send status confirm msg to core i
-                                                                         send_msg_1(false, i, 0xc);
+                                                                         send_msg_1(i, 0xc);
                                                                  }
                                                                  waitconfirm = true;
                                                                  numconfirm = NUMCORES - 1;
@@ -406,7 +406,7 @@ objqueuebreak:
 #endif
                                                                  for(i = 1; i < NUMCORES; ++i) {
                                                                          // send profile request msg to core i
-                                                                         send_msg_2(false, i, 6, totalexetime);
+                                                                         send_msg_2(i, 6, totalexetime);
                                                                  }
                                                                  // pour profiling data on startup core
                                                                  outputProfileData();
@@ -490,7 +490,7 @@ objqueuebreak:
                                                          BAMBOO_DEBUGPRINT(0xee0b);
 #endif
                                                          // send stall msg
-                                                         send_msg_4(false, STARTUPCORE, 1, BAMBOO_NUM_OF_CORE, self_numsendobjs, self_numreceiveobjs);
+                                                         send_msg_4(STARTUPCORE, 1, BAMBOO_NUM_OF_CORE, self_numsendobjs, self_numreceiveobjs);
                                                          sendStall = true;
                                                          isfirst = true;
                                                          busystatus = false;
@@ -1277,9 +1277,9 @@ msg:
                  // for 32 bit machine, the size is always 4 words
                  int tmp = deny==1?4:3;
                  if(isMsgSending) {
-                         cache_msg_4(false, data4, tmp, data1, data2, data3);
+                         cache_msg_4(data4, tmp, data1, data2, data3);
                  } else {
-                         send_msg_4(false, data4, tmp, data1, data2, data3);
+                         send_msg_4(data4, tmp, data1, data2, data3);
                  }
          }
       break;
@@ -1365,9 +1365,9 @@ msg:
          totalexetime = data1;
          outputProfileData();
          if(isMsgSending) {
-                 cache_msg_2(false, STARTUPCORE, 7, BAMBOO_NUM_OF_CORE);
+                 cache_msg_2(STARTUPCORE, 7, BAMBOO_NUM_OF_CORE);
          } else {
-                 send_msg_2(false, STARTUPCORE, 7, BAMBOO_NUM_OF_CORE);
+                 send_msg_2(STARTUPCORE, 7, BAMBOO_NUM_OF_CORE);
          }
       break;
     }
@@ -1407,9 +1407,9 @@ msg:
                  // send response msg
                  // for 32 bit machine, the size is always 4 words
                  if(isMsgSending) {
-                         cache_msg_4(false, data4, deny==1?0xa:9, data1, data2, data3);
+                         cache_msg_4(data4, deny==1?0xa:9, data1, data2, data3);
                  } else {
-                         send_msg_4(false, data4, deny==1?0xa:9, data1, data2, data3);
+                         send_msg_4(data4, deny==1?0xa:9, data1, data2, data3);
                  }
          }
          break;
@@ -1493,9 +1493,9 @@ msg:
 #endif
 #endif
                  if(isMsgSending) {
-                         cache_msg_3(false, STARTUPCORE, 0xd, busystatus?1:0, BAMBOO_NUM_OF_CORE);
+                         cache_msg_3(STARTUPCORE, 0xd, busystatus?1:0, BAMBOO_NUM_OF_CORE);
                  } else {
-                         send_msg_3(false, STARTUPCORE, 0xd, busystatus?1:0, BAMBOO_NUM_OF_CORE);
+                         send_msg_3(STARTUPCORE, 0xd, busystatus?1:0, BAMBOO_NUM_OF_CORE);
                  }
       }
          break;
@@ -1556,9 +1556,9 @@ msg:
                  }
                  // send the start_va to request core
                 if(isMsgSending) {
-                         cache_msg_3(false, msgdata[2], 0x10, mem, msgdata[1]);
+                         cache_msg_3(msgdata[2], 0x10, mem, msgdata[1]);
                  } else {
-                         send_msg_3(false, msgdata[2], 0x10, mem, msgdata[1]);
+                         send_msg_3( msgdata[2], 0x10, mem, msgdata[1]);
                  } 
       }
          break;