From: jzhou Date: Fri, 31 Jul 2009 00:45:25 +0000 (+0000) Subject: more changes X-Git-Url: http://plrg.eecs.uci.edu/git/?a=commitdiff_plain;h=eb5aa5416aec663e616a459106540e441037d299;p=IRC.git more changes --- diff --git a/Robust/src/Runtime/multicoregarbage.c b/Robust/src/Runtime/multicoregarbage.c index 50836edb..e72f6bf8 100644 --- 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 fc5da71d..2a9bfce5 100644 --- 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;