X-Git-Url: http://plrg.eecs.uci.edu/git/?p=satune.git;a=blobdiff_plain;f=src%2FTuner%2Fmultituner.cc;h=64f67aed459a93601886b0b21486e676115828b9;hp=cc35abc16c8765adec341b17234010836655ac56;hb=bb95e237d699d0c859ef948399b63651d21d432e;hpb=2d30fc91a091de0cd71fb3b7f02ce2d07252cae0 diff --git a/src/Tuner/multituner.cc b/src/Tuner/multituner.cc index cc35abc..64f67ae 100644 --- a/src/Tuner/multituner.cc +++ b/src/Tuner/multituner.cc @@ -7,10 +7,16 @@ #include #include #include +#include #define UNSETVALUE -1 -Problem::Problem(const char *_problem) : problemnumber(-1), result(UNSETVALUE) { +Problem::Problem(const char *_problem, uint _timeout) : + problemnumber(-1), + result(UNSETVALUE) , + besttime(std::numeric_limits::infinity()), + timeout(_timeout) +{ uint len = strlen(_problem); problem = (char *) ourmalloc(len + 1); memcpy(problem, _problem, len + 1); @@ -50,7 +56,7 @@ MultiTuner::~MultiTuner() { } void MultiTuner::addProblem(const char *filename) { - Problem *p = new Problem(filename); + Problem *p = new Problem(filename, timeout); p->problemnumber = problems.getSize(); problems.push(p); } @@ -83,20 +89,58 @@ void MultiTuner::readData(uint numRuns) { for (uint i = 0; i < numRuns; i++) { ifstream myfile; char buffer[512]; - uint tunernum; + uint tunernumber; snprintf(buffer, sizeof(buffer), "tunernum%u", i); myfile.open (buffer, ios::in); - myfile >> tunernum; + 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, timeout)); + 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); + } } @@ -136,7 +180,7 @@ long long MultiTuner::evaluate(Problem *problem, TunerRecord *tuner) { tuner->getTuner()->serialize(buffer); //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(), problem->timeout, execnum, execnum, execnum); int status = system(buffer); long long metric = -1; @@ -155,7 +199,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); } @@ -167,17 +211,39 @@ 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){ + double currentTime= metric / NANOSEC; + if(currentTime < problem->besttime){ + problem->besttime = currentTime; + } + uint adoptive; + if(problem->besttime > 30){ + adoptive = problem->besttime * 5; + }else { + adoptive = 150; + } + if(adoptive < problem->timeout){ + problem->timeout = adoptive; + } + LOG("Timeout=%u\tadoptive%u\tcurrentTime=%f\n", problem->timeout, adoptive, currentTime); +} + 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); } @@ -191,6 +257,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); } @@ -200,18 +271,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; @@ -226,13 +300,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);