} else if (state.DSM) {
readSourceFile(state, ClassLibraryPrefix+"ThreadDSM.java");
readSourceFile(state, ClassLibraryPrefix+"ObjectJavaDSM.java");
+ readSourceFile(state, ClassLibraryPrefix+"Barrier.java");
} else {
if (state.THREAD) {
readSourceFile(state, ClassLibraryPrefix+"Thread.java");
//int newRate = (j+1)%2+1;
int newRate = 1;
String cdname = cd.getSymbol();
- if(cdname.equals("SeriesRunner")) {
+ if((cdname.equals("SeriesRunner")) ||
+ (cdname.equals("MDRunner"))) {
newRate = 16;
- } else if(cdname.equals("MapWorker")) {
- newRate = 6;
- } else if(cdname.equals("ReduceWorker")) {
+ } else if(cdname.equals("SentenceParser")) {
+ newRate = 4;
+ } /*else if(cdname.equals("ReduceWorker")) {
newRate = 3;
- }
+ }*/
/*do {
tint = r.nextInt()%100;
} while(tint <= 0);