MCPcopy Create free account
hub / github.com/apache/mesos / initialize

Method initialize

src/log/consensus.cpp:459–470  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

457
458protected:
459 void initialize() override
460 {
461 // Stop when no one cares.
462 promise.future().onDiscard(lambda::bind(
463 static_cast<void(*)(const UPID&, bool)>(terminate), self(), true));
464
465 // Wait until there are enough (i.e., quorum of) replicas in the
466 // network. This is because if there are less than quorum number
467 // of replicas in the network, the operation will not finish.
468 network->watch(quorum, Network::GREATER_THAN_OR_EQUAL_TO)
469 .onAny(defer(self(), &Self::watched, lambda::_1));
470 }
471
472 void finalize() override
473 {

Callers

nothing calls this directly

Calls 4

deferFunction · 0.85
bindFunction · 0.50
futureMethod · 0.45
watchMethod · 0.45

Tested by

no test coverage detected