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

Method initialize

src/log/consensus.cpp:294–305  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

292
293protected:
294 void initialize() override
295 {
296 // Stop when no one cares.
297 promise.future().onDiscard(lambda::bind(
298 static_cast<void(*)(const UPID&, bool)>(terminate), self(), true));
299
300 // Wait until there are enough (i.e., quorum of) replicas in the
301 // network. This is because if there are less than quorum number
302 // of replicas in the network, the operation will not finish.
303 network->watch(quorum, Network::GREATER_THAN_OR_EQUAL_TO)
304 .onAny(defer(self(), &Self::watched, lambda::_1));
305 }
306
307 void finalize() override
308 {

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