diff --git a/src/vt/termination/termination.cc b/src/vt/termination/termination.cc index 096fed37e7..11149d0f52 100644 --- a/src/vt/termination/termination.cc +++ b/src/vt/termination/termination.cc @@ -142,26 +142,6 @@ TerminationDetector::findOrCreateState(EpochType const& epoch, bool is_ready) { return epoch_iter->second; } -void TerminationDetector::produceConsumeState( - TermStateType& state, TermCounterType const num_units, bool produce, - NodeType node -) { - auto& counter = produce ? state.l_prod : state.l_cons; - counter += num_units; - - vt_debug_print( - verbose, term, - "produceConsumeState: epoch={:x}, event_count={}, l_prod={}, l_cons={}, " - "num_units={}, produce={}, node={}\n", - state.getEpoch(), state.getRecvChildCount(), state.l_prod, state.l_cons, num_units, - print_bool(produce), node - ); - - if (state.readySubmitParent()) { - propagateEpoch(state); - } -} - TerminationDetector::TermStateDSType* TerminationDetector::getDSTerm(EpochType epoch, bool is_root) { vt_debug_print( @@ -189,38 +169,6 @@ TerminationDetector::getDSTerm(EpochType epoch, bool is_root) { } } -void TerminationDetector::produceConsume( - EpochType epoch, TermCounterType num_units, bool produce, NodeType node -) { - vt_debug_print( - normal, term, - "produceConsume: epoch={:x}, rooted={}, ds={}, count={}, produce={}, " - "node={}\n", - epoch, isRooted(epoch), isDS(epoch), num_units, produce, node - ); - - // If a node is not passed, use the current node (self-prod/cons) - if (node == uninitialized_destination) { - node = theContext()->getNode(); - } - - produceConsumeState(any_epoch_state_, num_units, produce, node); - - if (epoch != any_epoch_sentinel) { - if (isDS(epoch)) { - auto ds_term = getDSTerm(epoch); - if (produce) { - ds_term->msgSent(node,num_units); - } else { - ds_term->msgProcessed(node,num_units); - } - } else { - auto& state = findOrCreateState(epoch, false); - produceConsumeState(state, num_units, produce, node); - } - } -} - void TerminationDetector::maybePropagate() { if (any_epoch_state_.readySubmitParent()) { propagateEpoch(any_epoch_state_);