Skip to content

Commit

Permalink
#1942: use isActive in termination and inline
Browse files Browse the repository at this point in the history
  • Loading branch information
stmcgovern committed Sep 20, 2022
1 parent 31988ae commit e3f59b1
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 7 deletions.
9 changes: 4 additions & 5 deletions src/vt/termination/term_state.cc
Original file line number Diff line number Diff line change
Expand Up @@ -121,15 +121,14 @@ TermCounterType TermState::decrementDependency() {
return --deps_;
}

bool TermState::readySubmitParent(bool const needs_active) const {
bool TermState::readySubmitParent() const {
vtAssert(
num_children_ != uninitialized_destination, "Children must be valid"
);

auto const ret = (epoch_active_ or not needs_active) and
recv_child_count_ == num_children_ and local_terminated_ and
submitted_wave_ == cur_wave_ - 1 and not term_detected_ and
deps_ == 0;
auto const ret = epoch_active_ and local_terminated_ and
deps_ == 0 and recv_child_count_ == num_children_ and
submitted_wave_ == cur_wave_ - 1 and not term_detected_;

vt_debug_print(
verbose, term,
Expand Down
4 changes: 3 additions & 1 deletion src/vt/termination/term_state.h
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ struct TermState : EpochDependency, EpochLabel {
void notifyLocalTerminated(bool const terminated = true);
void submitToParent(bool const is_root, bool const setup = false);
void receiveContinueSignal(TermWaveType const& wave);
bool readySubmitParent(bool const needs_active = true) const;
bool readySubmitParent() const;
EventCountType getRecvChildCount() const;
EpochType getEpoch() const;
TermWaveType getCurWave() const;
Expand All @@ -76,6 +76,8 @@ struct TermState : EpochDependency, EpochLabel {
void incrementDependency();
TermCounterType decrementDependency();

inline bool isActive() const { return epoch_active_; }

TermState(
EpochType const& in_epoch, bool const in_local_terminated, bool const active,
NodeType const& children
Expand Down
2 changes: 1 addition & 1 deletion src/vt/termination/termination.h
Original file line number Diff line number Diff line change
Expand Up @@ -422,7 +422,7 @@ struct TerminationDetector :
* \param[in] produce whether its a produce or consume
* \param[in] node the node producing to or consuming from
*/
void produceConsume(
inline void produceConsume(
EpochType epoch = any_epoch_sentinel, TermCounterType num_units = 1,
bool produce = true, NodeType node = uninitialized_destination
);
Expand Down

0 comments on commit e3f59b1

Please sign in to comment.