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

Method runLearnPhase

src/log/consensus.cpp:739–749  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

737 }
738
739 void runLearnPhase(const Action& action)
740 {
741 CHECK(action.has_learned() && action.learned());
742
743 // We need to make sure that the learned message has been
744 // broadcasted before the fill process completes. Some users may
745 // rely on this invariant (e.g. checking if the local replica has
746 // learned the action).
747 log::learn(network, action)
748 .onAny(defer(self(), &Self::checkLearnPhase, action, lambda::_1));
749 }
750
751 void checkLearnPhase(const Action& action, const Future<Nothing>& future)
752 {

Callers

nothing calls this directly

Calls 3

learnFunction · 0.85
deferFunction · 0.85
learnedMethod · 0.80

Tested by

no test coverage detected