gcforwardobjtbl = allocateMGCHash_I(20, 3);
gcobj2map = 0;
gcmappedobj = 0;
- gcismapped = false;
+ //gcismapped = false;
gcnumlobjs = 0;
gcheaptop = 0;
gctopcore = 0;
gcblock2fill = 0;
gcsbstarttbl = BAMBOO_BASE_VA;
bamboo_smemtbl = (void *)gcsbstarttbl
- + (BAMBOO_SHARED_MEM_SIZE/BAMBOO_SMEM_SIZE)*sizeof(INTPTR);
+ + (BAMBOO_SHARED_MEM_SIZE/BAMBOO_SMEM_SIZE)*sizeof(INTPTR);
+ // for mapping info structures
+ gcrcoretbl = allocateRuntimeHash_I(20);
+ BAMBOO_MEMSET_WH(gcmappingtbl, 0,
+ sizeof(void *)*NUMCORESACTIVE*NUM_MAPPING);
#else
// create the lock table, lockresult table and obj queue
locktable.size = 20;
freeRuntimeHash(gcpointertbl);
//freeMGCHash(gcpointertbl);
freeMGCHash(gcforwardobjtbl);
+ // for mapping info structures
+ freeRuntimeHash(gcrcoretbl);
#else
freeRuntimeHash(lockRedirectTbl);
freeRuntimeHash(objRedirectLockTbl);
#ifdef MULTICORE_GC
case GCSTARTINIT:
case GCSTART:
+ case GCSTARTMAPINFO:
case GCSTARTFLUSH:
case GCFINISH:
case GCMARKCONFIRM:
#ifdef MULTICORE_GC
case GCSTARTCOMPACT:
case GCFINISHINIT:
+ case GCFINISHMAPINFO:
case GCFINISHFLUSH:
- case GCMARKEDOBJ:
#endif
{
msglength = 2;
case MEMREQUEST:
case MEMRESPONSE:
#ifdef MULTICORE_GC
+ case GCMARKEDOBJ:
case GCMAPREQUEST:
case GCMAPINFO:
case GCLOBJMAPPING:
gcphase = COMPACTPHASE;
}
+INLINE void processmsg_gcstartmapinfo_I() {
+ gcphase = MAPPHASE;
+}
+
INLINE void processmsg_gcstartflush_I() {
gcphase = FLUSHPHASE;
}
} // if(cnum < NUMCORES4GC)
}
+INLINE void processmsg_gcfinishmapinfo_I() {
+ int data1 = msgdata[msgdataindex];
+ MSG_INDEXINC_I();
+ // received a map phase finish msg
+ if(BAMBOO_NUM_OF_CORE != STARTUPCORE) {
+ // non startup core can not receive this msg
+ // return -1
+#ifndef CLOSE_PRINT
+ BAMBOO_DEBUGPRINT_REG(data1);
+#endif
+ BAMBOO_EXIT(0xb004);
+ }
+ // all cores should do flush
+ if(data1 < NUMCORES4GC) {
+ gccorestatus[data1] = 0;
+ }
+}
+
+
INLINE void processmsg_gcfinishflush_I() {
int data1 = msgdata[msgdataindex];
MSG_INDEXINC_I();
#ifndef CLOSE_PRINT
BAMBOO_DEBUGPRINT_REG(data1);
#endif
- BAMBOO_EXIT(0xb004);
+ BAMBOO_EXIT(0xb005);
}
// all cores should do flush
if(data1 < NUMCORESACTIVE) {
if((BAMBOO_NUM_OF_CORE == STARTUPCORE)
|| (BAMBOO_NUM_OF_CORE > NUMCORESACTIVE - 1)) {
// wrong core to receive such msg
- BAMBOO_EXIT(0xb005);
+ BAMBOO_EXIT(0xb006);
} else {
// send response msg, cahce the msg first
if(BAMBOO_CHECK_SEND_MODE()) {
#ifndef CLOSE_PRINT
BAMBOO_DEBUGPRINT_REG(data2);
#endif
- BAMBOO_EXIT(0xb006);
+ BAMBOO_EXIT(0xb007);
} else {
if(waitconfirm) {
numconfirm--;
INLINE void processmsg_gcmarkedobj_I() {
int data1 = msgdata[msgdataindex];
MSG_INDEXINC_I();
+ int data2 = msgdata[msgdataindex];
+ MSG_INDEXINC_I();
// received a markedObj msg
if(((int *)data1)[6] == INIT) {
// this is the first time that this object is discovered,
// set the flag as DISCOVERED
((int *)data1)[6] = DISCOVERED;
gc_enqueue_I(data1);
+ // insert the obj and request core info into mapping hashtable
+ /*struct requestcoreinfo * coreinfo =
+ (struct requestcoreinfo *)RUNMALLOC_I(sizeof(struct requestcoreinfo));
+ coreinfo->core = data2;
+ coreinfo->next = NULL;
+ struct nodemappinginfo * nodeinfo =
+ (struct nodemappinginfo *)RUNMALLOC_I(sizeof(struct nodemappinginfo));
+ nodeinfo->ptr = NULL;
+ nodeinfo->cores = coreinfo;
+ RuntimeHashadd_I(gcpointertbl, data1, (int)nodeinfo);*/
+ struct rcoreinfo * coreinfo =
+ (struct rcoreinfo *)RUNMALLOC_I(sizeof(struct rcoreinfo));
+ coreinfo->high = coreinfo->low = 0;
+ if(data2 > 31) {
+ coreinfo->high |= 1<<(data2-32);
+ } else {
+ coreinfo->low |= 1<<data2;
+ }
+ RuntimeHashadd_I(gcrcoretbl, data1, (int)coreinfo);
+ if(gcmappingtbl[data2][0] < NUM_MAPPING-1) {
+ int pos = ++gcmappingtbl[data2][0];
+ gcmappingtbl[data2][pos] = data1;
+ }
+ } else {
+ // record the request core
+ /*struct nodemappinginfo * nodeinfo = NULL;
+ RuntimeHashget(gcpointertbl, data1, &nodeinfo);
+ if(nodeinfo == NULL) {
+ // did not mark the obj, error!
+ BAMBOO_DEBUGPRINT_REG(((int *)data1)[6]);
+ BAMBOO_EXIT(0xb008);
+ } else {
+ struct requestcoreinfo * coreinfo = nodeinfo->cores;
+ if(coreinfo == NULL) {
+ nodeinfo->cores =
+ (struct requestcoreinfo *)RUNMALLOC_I(
+ sizeof(struct requestcoreinfo));
+ nodeinfo->cores->core = data2;
+ nodeinfo->cores->next = NULL;
+ } else {
+ while(true) {
+ if(coreinfo->core == data2) {
+ break;
+ } else if ((coreinfo->core > data2) ||
+ (coreinfo->next == NULL)) {
+ // insert here
+ struct requestcoreinfo * toinsert =
+ (struct requestcoreinfo *)RUNMALLOC_I(
+ sizeof(struct requestcoreinfo));
+ if(coreinfo->core > data2) {
+ toinsert->next = coreinfo->next;
+ toinsert->core = coreinfo->core;
+ coreinfo->core = data2;
+ } else {
+ toinsert->core = data2;
+ }
+ coreinfo->next = toinsert;
+ break;
+ } else {
+ coreinfo = coreinfo->next;
+ }
+ }
+ }
+ }*/
+ struct rcoreinfo * coreinfo = NULL;
+ RuntimeHashget(gcrcoretbl, data1, &coreinfo);
+ if(coreinfo == NULL) {
+ coreinfo =
+ (struct rcoreinfo *)RUNMALLOC_I(sizeof(struct rcoreinfo));
+ coreinfo->high = coreinfo->low = 0;
+ if(data2 > 31) {
+ coreinfo->high |= 1<<(data2-32);
+ } else {
+ coreinfo->low |= 1<<data2;
+ }
+ RuntimeHashadd_I(gcrcoretbl, data1, (int)coreinfo);
+ if(gcmappingtbl[data2][0] < NUM_MAPPING-1) {
+ int pos = ++gcmappingtbl[data2][0];
+ gcmappingtbl[data2][pos] = data1;
+ }
+ } else {
+ bool toadd = false;
+ if(data2 > 31) {
+ if((coreinfo->high)&(1<<(data2-32))==0) {
+ toadd = true;
+ coreinfo->high |= 1<<(data2-32);
+ }
+ } else {
+ if((coreinfo->low)&(1<<data2)==0) {
+ toadd = true;
+ coreinfo->low |= 1<<data2;
+ }
+ }
+ if((toadd) && (gcmappingtbl[data2][0] < NUM_MAPPING-1)) {
+ int pos = ++gcmappingtbl[data2][0];
+ gcmappingtbl[data2][pos] = data1;
+ }
+ }
}
gcself_numreceiveobjs++;
gcbusystatus = true;
}
INLINE void processmsg_gcmaprequest_I() {
+ // should not have such msg any more
+ //BAMBOO_EXIT(0xb009);
#ifdef GC_PROFILE
//unsigned long long ttime = BAMBOO_GET_EXE_TIME();
#endif
MSG_INDEXINC_I();
//dstptr = mgchashSearch(msgdata[1]);
#ifdef GC_PROFILE
- unsigned long long ttime = BAMBOO_GET_EXE_TIME();
+ // TODO unsigned long long ttime = BAMBOO_GET_EXE_TIME();
#endif
RuntimeHashget(gcpointertbl, data1, &dstptr);
#ifdef GC_PROFILE
- flushstalltime += BAMBOO_GET_EXE_TIME() - ttime;
+ // TODO flushstalltime += BAMBOO_GET_EXE_TIME() - ttime;
#endif
int data2 = msgdata[msgdataindex];
MSG_INDEXINC_I();
//MGCHashget(gcpointertbl, msgdata[1], &dstptr);
#ifdef GC_PROFILE
- unsigned long long ttimei = BAMBOO_GET_EXE_TIME();
+ // TODO unsigned long long ttimei = BAMBOO_GET_EXE_TIME();
#endif
if(NULL == dstptr) {
// no such pointer in this core, something is wrong
BAMBOO_DEBUGPRINT_REG(data1);
BAMBOO_DEBUGPRINT_REG(data2);
#endif
- BAMBOO_EXIT(0xb007);
+ BAMBOO_EXIT(0xb009);
//assume that the object was not moved, use the original address
/*if(isMsgSending) {
cache_msg_3(msgdata[2], GCMAPINFO, msgdata[1], msgdata[1]);
}
}
#ifdef GC_PROFILE
- flushstalltime_i += BAMBOO_GET_EXE_TIME()-ttimei;
+ // TODO flushstalltime_i += BAMBOO_GET_EXE_TIME()-ttimei;
//num_mapinforequest_i++;
#endif
}
#endif
int data1 = msgdata[msgdataindex];
MSG_INDEXINC_I();
+#if 0
if(data1 != gcobj2map) {
// obj not matched, something is wrong
#ifdef DEBUG
BAMBOO_DEBUGPRINT_REG(gcobj2map);
BAMBOO_DEBUGPRINT_REG(msgdata[1]);
#endif
- BAMBOO_EXIT(0xb008);
+ BAMBOO_EXIT(0xb00a);
} else {
+#endif
gcmappedobj = msgdata[msgdataindex]; // [2]
MSG_INDEXINC_I();
//mgchashReplace_I(msgdata[1], msgdata[2]);
//mgchashInsert_I(gcobj2map, gcmappedobj);
RuntimeHashadd_I(gcpointertbl, gcobj2map, gcmappedobj);
+ /*struct nodemappinginfo * nodeinfo =
+ (struct nodemappinginfo *)RUNMALLOC_I(sizeof(struct nodemappinginfo));
+ nodeinfo->ptr = (void *)gcmappedobj;
+ nodeinfo->cores = NULL;
+ RuntimeHashadd_I(gcpointertbl, data1, (int)nodeinfo);*/
//MGCHashadd_I(gcpointertbl, gcobj2map, gcmappedobj);
+// }
+ if(data1 == gcobj2map) {
+ gcismapped = true;
}
- gcismapped = true;
#ifdef GC_PROFILE
//flushstalltime += BAMBOO_GET_EXE_TIME() - ttime;
#endif
#ifndef CLOSE_PRINT
BAMBOO_DEBUGPRINT_REG(data2);
#endif
- BAMBOO_EXIT(0xb009);
+ BAMBOO_EXIT(0xb00b);
}
// store the mark result info
int cnum = data2;
MSG_INDEXINC_I();
//mgchashInsert_I(msgdata[1], msgdata[2]);
RuntimeHashadd_I(gcpointertbl, data1, data2);
+ /*struct nodemappinginfo * nodeinfo =
+ (struct nodemappinginfo *)RUNMALLOC_I(sizeof(struct nodemappinginfo));
+ nodeinfo->ptr = (void *)data2;
+ nodeinfo->cores = NULL;
+ RuntimeHashadd_I(gcpointertbl, data1, (int)nodeinfo);*/
//MGCHashadd_I(gcpointertbl, msgdata[1], msgdata[2]);
}
#endif // #ifdef MULTICORE_GC
break;
} // case GCSTARTCOMPACT
+ case GCSTARTMAPINFO: {
+ // received a flush phase start msg
+ processmsg_gcstartmapinfo_I();
+ break;
+ } // case GCSTARTFLUSH
+
case GCSTARTFLUSH: {
// received a flush phase start msg
processmsg_gcstartflush_I();
break;
} // case GCFINISHCOMPACT
+ case GCFINISHMAPINFO: {
+ processmsg_gcfinishmapinfo_I();
+ break;
+ } // case GCFINISHMAPINFO
+
case GCFINISHFLUSH: {
processmsg_gcfinishflush_I();
break;
// reside on this core
if(!RuntimeHashcontainskey(locktbl, reallock)) {
// no locks for this object, something is wrong
- BAMBOO_EXIT(0xa011);
+ BAMBOO_EXIT(0xa00b);
} else {
int rwlock_obj = 0;
struct LockValue * lockvalue = NULL;
projects / IRC.git / blobdiff