X-Git-Url: http://plrg.eecs.uci.edu/git/?p=satune.git;a=blobdiff_plain;f=src%2FTuner%2Fmultituner.cc;h=4715ade353532f0707166e3a95740832437c4599;hp=2504110fd3fe2003c5301cf405bcce400f20ba69;hb=e368a6222771bc9876d56b4e6c16fdea896cab77;hpb=3aba47a18f71d1905ee5b4b886998a5025a3550d diff --git a/src/Tuner/multituner.cc b/src/Tuner/multituner.cc index 2504110..4715ade 100644 --- a/src/Tuner/multituner.cc +++ b/src/Tuner/multituner.cc @@ -10,7 +10,7 @@ #define UNSETVALUE -1 -Problem::Problem(const char *_problem) : result(UNSETVALUE) { +Problem::Problem(const char *_problem) : problemnumber(-1), result(UNSETVALUE) { uint len = strlen(_problem); problem = (char *) ourmalloc(len + 1); memcpy(problem, _problem, len + 1); @@ -50,30 +50,139 @@ MultiTuner::~MultiTuner() { } void MultiTuner::addProblem(const char *filename) { - problems.push(new Problem(filename)); + Problem *p = new Problem(filename); + p->problemnumber = problems.getSize(); + problems.push(p); +} + +void MultiTuner::printData() { + model_print("*********** DATA DUMP ***********\n"); + for (uint i = 0; i < allTuners.getSize(); i++) { + TunerRecord *tuner = allTuners.get(i); + SearchTuner *stun = tuner->getTuner(); + model_print("Tuner %u\n", i); + stun->print(); + model_print("----------------------------------\n\n\n"); + for (uint j = 0; j < tuner->problems.getSize(); j++) { + Problem *problem = tuner->problems.get(j); + model_print("Problem %s\n", problem->getProblem()); + model_print("Time = %lld\n", tuner->getTime(problem)); + } + } } void MultiTuner::addTuner(SearchTuner *tuner) { TunerRecord *t = new TunerRecord(tuner); tuners.push(t); + t->tunernumber = allTuners.getSize(); allTuners.push(t); } -long long MultiTuner::evaluate(Problem *problem, SearchTuner *tuner) { + +void MultiTuner::readData(uint numRuns) { + for (uint i = 0; i < numRuns; i++) { + ifstream myfile; + char buffer[512]; + uint tunernumber; + snprintf(buffer, sizeof(buffer), "tunernum%u", i); + myfile.open (buffer, ios::in); + myfile >> tunernumber; + myfile.close(); + if (allTuners.getSize() <= tunernumber) + allTuners.setSize(tunernumber + 1); + if (allTuners.get(tunernumber) == NULL) { + snprintf(buffer, sizeof(buffer), "tuner%u", i); + allTuners.set(tunernumber, new TunerRecord(new SearchTuner(buffer))); + } + //Add any new used records + snprintf(buffer, sizeof(buffer), "tuner%uused", i); + TunerRecord *tuner = allTuners.get(tunernumber); + tuner->getTuner()->addUsed(buffer); + + char problemname[512]; + uint problemnumber; + snprintf(buffer, sizeof(buffer), "problem%u", i); + myfile.open(buffer, ios::in); + myfile.getline(problemname, sizeof(problemname)); + myfile >> problemnumber; + myfile.close(); + if (problems.getSize() <= problemnumber) + problems.setSize(problemnumber + 1); + if (problems.get(problemnumber) == NULL) + problems.set(problemnumber, new Problem(problemname)); + Problem *problem = problems.get(problemnumber); + long long metric = -1; + int sat = IS_INDETER; + //Read data in from results file + snprintf(buffer, sizeof(buffer), "result%u", i); + + myfile.open (buffer, ios::in); + + + if (myfile.is_open()) { + myfile >> metric; + myfile >> sat; + myfile.close(); + } + if (problem->result == UNSETVALUE && sat != IS_INDETER) { + problem->result = sat; + } else if (problem->result != sat && sat != IS_INDETER) { + model_print("******** Result has changed ********\n"); + } + + if (metric != -1) { + if (tuner->getTime(problem) == -1) + tuner->problems.push(problem); + tuner->setTime(problem, metric); + } + + } + +} + +long long MultiTuner::evaluate(Problem *problem, TunerRecord *tuner) { char buffer[512]; + { + snprintf(buffer, sizeof(buffer), "problem%u", execnum); + + ofstream myfile; + myfile.open (buffer, ios::out); + + + if (myfile.is_open()) { + myfile << problem->getProblem() << endl; + myfile << problem->problemnumber << endl; + myfile.close(); + } + } + + { + snprintf(buffer, sizeof(buffer), "tunernum%u", execnum); + + ofstream myfile; + myfile.open (buffer, ios::out); + + + if (myfile.is_open()) { + myfile << tuner->tunernumber << endl; + myfile.close(); + } + } + //Write out the tuner snprintf(buffer, sizeof(buffer), "tuner%u", execnum); - tuner->serialize(buffer); + tuner->getTuner()->serialize(buffer); //Do run - snprintf(buffer, sizeof(buffer), "deserializerun %s %u tuner%u result%s%u > log%u", problem->getProblem(), timeout, execnum, problem->getProblem(), execnum, execnum); + snprintf(buffer, sizeof(buffer), "./run.sh deserializerun %s %u tuner%u result%u > log%u", problem->getProblem(), timeout, execnum, execnum, execnum); int status = system(buffer); long long metric = -1; int sat = IS_INDETER; + if (status == 0) { //Read data in from results file - snprintf(buffer, sizeof(buffer), "result%s%u", problem->getProblem(), execnum); + snprintf(buffer, sizeof(buffer), "result%u", execnum); ifstream myfile; myfile.open (buffer, ios::in); @@ -84,6 +193,9 @@ long long MultiTuner::evaluate(Problem *problem, SearchTuner *tuner) { myfile >> sat; myfile.close(); } + + snprintf(buffer, sizeof(buffer), "tuner%uused", execnum); + tuner->getTuner()->addUsed(buffer); } //Increment execution count execnum++; @@ -99,10 +211,15 @@ long long MultiTuner::evaluate(Problem *problem, SearchTuner *tuner) { void MultiTuner::tuneComp() { Vector *tunerV = new Vector(&tuners); for (uint b = 0; b < budget; b++) { + model_print("Round %u of %u\n", b, budget); uint tSize = tunerV->getSize(); for (uint i = 0; i < tSize; i++) { SearchTuner *tmpTuner = mutateTuner(tunerV->get(i)->getTuner(), b); - tunerV->push(new TunerRecord(tmpTuner)); + TunerRecord *tmp = new TunerRecord(tmpTuner); + tmp->tunernumber = allTuners.getSize(); + model_print("Mutated tuner %u to generate tuner %u\n", tunerV->get(i)->tunernumber, tmp->tunernumber); + allTuners.push(tmp); + tunerV->push(tmp); } Hashtable scores; @@ -113,7 +230,12 @@ void MultiTuner::tuneComp() { TunerRecord *tuner = tunerV->get(j); long long metric = tuner->getTime(problem); if (metric == -1) { - metric = evaluate(problem, tuner->getTuner()); + metric = evaluate(problem, tuner); + if (tuner->getTime(problem) == -1){ + tuner->problems.push(problem); + } + DEBUG("%u.Problem<%s>\tTuner<%p>\tMetric<%lld>\n", i, problem->problem,tuner, metric); + DEBUG("*****************************\n"); if (metric != -1) tuner->setTime(problem, metric); } @@ -123,18 +245,21 @@ void MultiTuner::tuneComp() { if (metric < places.get(k)->getTime(problem)) break; } + DEBUG("place[%u]=Tuner<%p>\n", k, tuner); places.insertAt(k, tuner); } } int points = 9; for (uint k = 0; k < places.getSize() && points; k++) { TunerRecord *tuner = places.get(k); - points = points / 3; int currScore = 0; if (scores.contains(tuner)) currScore = scores.get(tuner); currScore += points; + DEBUG("Problem<%s>\tTuner<%p>\tmetric<%d>\n", problem->problem, tuner, currScore); + DEBUG("**************************\n"); scores.put(tuner, currScore); + points = points / 3; } } Vector ranking; @@ -149,19 +274,24 @@ void MultiTuner::tuneComp() { int tscore = 0; if (scores.contains(t)) tscore = scores.get(t); - if (score > tscore) + if (score < tscore) break; } + DEBUG("ranking[%u]=tuner<%p>(Score=%d)\n", j, tuner, score); + DEBUG("************************\n"); ranking.insertAt(j, tuner); } + DEBUG("tunerSize=%u\trankingSize=%u\ttunerVSize=%u\n", tuners.getSize(), ranking.getSize(), tunerV->getSize()); for (uint i = tuners.getSize(); i < ranking.getSize(); i++) { - TunerRecord * tuner = ranking.get(i); - for(uint j = 0; j < tunerV->getSize(); j++) { - if (tunerV->get(j) == tuner) - tunerV->removeAt(j); - } + TunerRecord *tuner = ranking.get(i); + for (uint j = 0; j < tunerV->getSize(); j++) { + model_print("Removing tuner %u\n", tuner->tunernumber); + if (tunerV->get(j) == tuner) + tunerV->removeAt(j); + } } } + printData(); } void MultiTuner::mapProblemsToTuners(Vector *tunerV) { @@ -173,7 +303,7 @@ void MultiTuner::mapProblemsToTuners(Vector *tunerV) { TunerRecord *tuner = tunerV->get(j); long long metric = tuner->getTime(problem); if (metric == -1) { - metric = evaluate(problem, tuner->getTuner()); + metric = evaluate(problem, tuner); if (metric != -1) tuner->setTime(problem, metric); } @@ -227,7 +357,7 @@ double MultiTuner::evaluateAll(TunerRecord *tuner) { Problem *problem = tuner->problems.get(i); long long metric = tuner->getTime(problem); if (metric == -1) { - metric = evaluate(problem, tuner->getTuner()); + metric = evaluate(problem, tuner); if (metric != -1) tuner->setTime(problem, metric); } @@ -262,6 +392,7 @@ TunerRecord *MultiTuner::tune(TunerRecord *tuner) { for (uint i = 0; i < budget; i++) { SearchTuner *tmpTuner = mutateTuner(oldTuner->getTuner(), i); TunerRecord *newTuner = oldTuner->changeTuner(tmpTuner); + newTuner->tunernumber = allTuners.getSize(); allTuners.push(newTuner); double newScore = evaluateAll(newTuner); newTuner->tuner->printUsed();