1
0
Fork 0

Gossipping premature stop

This commit is contained in:
Kaveh Vahedipour 2016-11-02 12:01:24 +01:00
parent 134eed9c99
commit c8511619a6
1 changed files with 4 additions and 3 deletions

View File

@ -50,7 +50,8 @@ void Inception::gossip() {
auto s = std::chrono::system_clock::now(); auto s = std::chrono::system_clock::now();
std::chrono::seconds timeout(120); std::chrono::seconds timeout(120);
size_t n = 0, j = 0; size_t j = 0;
bool complete = false;
CONDITION_LOCKER(guard, _cv); CONDITION_LOCKER(guard, _cv);
@ -114,11 +115,11 @@ void Inception::gossip() {
// We're done // We're done
if (config.poolComplete()) { if (config.poolComplete()) {
if (n > 5) { if (complete) {
_agent->startConstituent(); _agent->startConstituent();
break; break;
} }
++n; complete = true;
} }
} }