-coreprof-eventwords 1024*1024*128 \
-coreprof-enable cpe_main \
-coreprof-enable cpe_taskexecute \
- -coreprof-enable cpe_taskretire \
+ -coreprof-enable cpe_taskdispatch \
+ -coreprof-enable cpe_runmalloc \
+ -coreprof-enable cpe_rcr_traverse
+# -coreprof-enable cpe_taskretire \
-coreprof-enable cpe_workschedsubmit \
-coreprof-enable cpe_workschedgrab \
- -coreprof-enable cpe_taskdispatch
-# -coreprof-enable cpe_runmalloc \
-# -coreprof-enable cpe_poolalloc \
-# -coreprof-enable cpe_preparememq \
-# -coreprof-enable cpe_runfree \
-# -coreprof-enable cpe_count_poolalloc \
-# -coreprof-enable cpe_count_poolreuse \
-# -coreprof-enable cpe_taskstallvar \
-# -coreprof-enable cpe_taskstallmem
-
-
-USEOOO= -ooojava 24 2 -ooodebug -squeue #-ooodebug-disable-task-mem-pool
+ -coreprof-enable cpe_poolalloc \
+ -coreprof-enable cpe_preparememq \
+ -coreprof-enable cpe_runfree \
+ -coreprof-enable cpe_count_poolalloc \
+ -coreprof-enable cpe_count_poolreuse \
+ -coreprof-enable cpe_taskstallvar \
+ -coreprof-enable cpe_taskstallmem
+
+
+USEOOO= -ooojava 24 2 -ooodebug -squeue #-ooodebug-disable-task-mem-pool
USERCR= -ooojava 23 2 -rcr -ooodebug -squeue
BSFLAGS= -64bit -mainclass $(PROGRAM) -heapsize-mb 8000 -garbagestats -joptimize -noloop -optimize -debug #-nooptimize #src-after-pp #-debug
#include "trqueue.h"
+#include "coreprof/coreprof.h"
#include "mlp_runtime.h"
#include "rcr_runtime.h"
#include "hashStructure.h"
#include "structdefs.h"
#include "RuntimeConflictResolver.h"
+
void * workerTR(void *x) {
struct trQueue * queue=(struct trQueue *)x;
allHashStructures=queue->allHashStructures;
+
+ CP_CREATE();
+
while(1) {
SESEcommon * tmp;
do {
tmp=(SESEcommon *) dequeueTR(queue);
if (tmp!=NULL) {
+
+#ifdef CP_EVENTID_RCR_TRAVERSE
+ CP_LOGEVENT( CP_EVENTID_RCR_TRAVERSE, CP_EVENTTYPE_BEGIN );
+#endif
tasktraverse(tmp);
+
+#ifdef CP_EVENTID_RCR_TRAVERSE
+ CP_LOGEVENT( CP_EVENTID_RCR_TRAVERSE, CP_EVENTTYPE_END );
+#endif
+
} else {
sched_yield();
}
} while(1);
}
+
+ CP_EXIT();
+
return NULL;
}