X-Git-Url: http://plrg.eecs.uci.edu/git/?p=satune.git;a=blobdiff_plain;f=src%2FTuner%2Fmultituner.cc;h=0850f66ede42289b2623187d5407fc04e372ba18;hp=f28e781fe3c915dbef2804e018eff622ffaf6a22;hb=b94774b8783de1b4eabc3ca4b0ef6aeee7a89538;hpb=b0fc62509a89f906da9bc2731afa806f3cc293c5 diff --git a/src/Tuner/multituner.cc b/src/Tuner/multituner.cc index f28e781..0850f66 100644 --- a/src/Tuner/multituner.cc +++ b/src/Tuner/multituner.cc @@ -7,10 +7,15 @@ #include #include #include +#include #define UNSETVALUE -1 -Problem::Problem(const char *_problem) : result(UNSETVALUE) { +Problem::Problem(const char *_problem) : + problemnumber(-1), + result(UNSETVALUE), + besttime(LLONG_MAX) +{ uint len = strlen(_problem); problem = (char *) ourmalloc(len + 1); memcpy(problem, _problem, len + 1); @@ -50,7 +55,9 @@ 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() { @@ -69,12 +76,121 @@ void MultiTuner::printData() { } } +void MultiTuner::findBestThreeTuners() { + if(allTuners.getSize() < 3){ + printData(); + return; + } + TunerRecord * bestTuners[3]; + double score = DBL_MAX; + for (uint i = 0; i < allTuners.getSize()-2; i++) { + for(uint j=i+1; j< allTuners.getSize()-1; j++){ + for(uint k=j+1; kgetTime(problem), tuner2->getTime(problem), tuner3->getTime(problem)), (double)1 / problems.getSize()); + } + double result=1; + for(uint l=0; l< problems.getSize(); l++){ + result *= mintimes[l]; + } + if(result < score){ + score = result; + bestTuners[0] = tuner1; + bestTuners[1] = tuner2; + bestTuners[2] = tuner3; + } + } + } + } + model_print("Best 3 tuners:\n"); + for(uint i=0; i<3; i++){ + TunerRecord * tuner = bestTuners[i]; + SearchTuner *stun = tuner->getTuner(); + model_print("Tuner %u\n", tuner->tunernumber); + stun->print(); + 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)); + } + model_print("----------------------------------\n\n\n"); + } +} + void MultiTuner::addTuner(SearchTuner *tuner) { TunerRecord *t = new TunerRecord(tuner); tuners.push(t); + t->tunernumber = allTuners.getSize(); allTuners.push(t); } + +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]; { @@ -86,6 +202,20 @@ long long MultiTuner::evaluate(Problem *problem, TunerRecord *tuner) { 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(); } } @@ -94,8 +224,13 @@ long long MultiTuner::evaluate(Problem *problem, TunerRecord *tuner) { snprintf(buffer, sizeof(buffer), "tuner%u", execnum); tuner->getTuner()->serialize(buffer); + //compute timeout + uint timeinsecs = problem->besttime / NANOSEC; + uint adaptive = (timeinsecs > 30) ? timeinsecs * 5 : 150; + uint maxtime = (adaptive < timeout) ? adaptive : timeout; + //Do run - snprintf(buffer, sizeof(buffer), "./run.sh deserializerun %s %u tuner%u result%u > log%u", problem->getProblem(), timeout, execnum, execnum, execnum); + snprintf(buffer, sizeof(buffer), "./run.sh deserializerun %s %u tuner%u result%u > log%u", problem->getProblem(), maxtime, execnum, execnum, execnum); int status = system(buffer); long long metric = -1; @@ -114,7 +249,7 @@ long long MultiTuner::evaluate(Problem *problem, TunerRecord *tuner) { myfile >> sat; myfile.close(); } - + updateTimeout(problem, metric); snprintf(buffer, sizeof(buffer), "tuner%uused", execnum); tuner->getTuner()->addUsed(buffer); } @@ -126,16 +261,28 @@ long long MultiTuner::evaluate(Problem *problem, TunerRecord *tuner) { } else if (problem->result != sat && sat != IS_INDETER) { model_print("******** Result has changed ********\n"); } + if (sat == IS_INDETER && metric != -1) {//The case when we have a timeout + metric = -1; + } return metric; } +void MultiTuner::updateTimeout(Problem *problem, long long metric) { + if (metric < problem->besttime) { + problem->besttime = metric; + } +} + 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); 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); } @@ -149,6 +296,11 @@ void MultiTuner::tuneComp() { long long metric = tuner->getTime(problem); if (metric == -1) { metric = evaluate(problem, tuner); + if (tuner->getTime(problem) == -1) { + tuner->problems.push(problem); + } + LOG("%u.Problem<%s>\tTuner<%p, %d>\tMetric<%lld>\n", i, problem->problem,tuner, tuner->tunernumber, metric); + LOG("*****************************\n"); if (metric != -1) tuner->setTime(problem, metric); } @@ -158,18 +310,21 @@ void MultiTuner::tuneComp() { if (metric < places.get(k)->getTime(problem)) break; } + LOG("place[%u]=Tuner<%p,%d>\n", k, tuner, tuner->tunernumber); 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; + LOG("Problem<%s>\tTuner<%p,%d>\tmetric<%d>\n", problem->problem, tuner, tuner->tunernumber, currScore); + LOG("**************************\n"); scores.put(tuner, currScore); + points = points / 3; } } Vector ranking; @@ -184,13 +339,17 @@ void MultiTuner::tuneComp() { int tscore = 0; if (scores.contains(t)) tscore = scores.get(t); - if (score < tscore) + if (score > tscore) break; } + LOG("ranking[%u]=tuner<%p,%u>(Score=%d)\n", j, tuner, tuner->tunernumber, score); + LOG("************************\n"); ranking.insertAt(j, tuner); } + LOG("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); + LOG("Removing tuner %u\n", tuner->tunernumber); for (uint j = 0; j < tunerV->getSize(); j++) { if (tunerV->get(j) == tuner) tunerV->removeAt(j); @@ -298,6 +457,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();