vt::term::ds::StateDS struct
#include <src/vt/termination/dijkstra-scholten/comm.h>

Derived classes

struct vt::term::TerminationDetector
Detect global termination and of subsets of work.

Public types

using Endpoint = NodeType
using TerminatorType = TermDS<StateDS>

Public static functions

static void requestAck(EpochType epoch, Endpoint successor, int64_t cnt)
static void acknowledge(EpochType epoch, Endpoint predecessor, int64_t cnt)
Make a call to gotAck(count) on predecessor's terminator instance.
static void rootTerminated(EpochType epoch)
static void disengage(EpochType epoch)

Constructors, destructors, conversion operators

StateDS() defaulted
StateDS(StateDS&&) defaulted
StateDS(StateDS const&) deleted

Public functions

auto getDSTermMap() -> std::unordered_map<EpochType, TerminatorType> const &

Protected variables

std::unordered_map<EpochType, TerminatorType> term_

Function documentation

static void vt::term::ds::StateDS::requestAck(EpochType epoch, Endpoint successor, int64_t cnt)

Make a call to needAck(self, count, tryToEngage) on successor's terminator instance

static void vt::term::ds::StateDS::disengage(EpochType epoch)

Have locally disengaged, might need to cleanup meta-data (might never be re-engaged)