ark::pipeline::ShutdownStage

Defined in header “ark/pipeline/test/shutdown_stage.hh”.


This is a stage that requests a shutdown after a period of time, this just verifies the real time executor exits when someone requests it. This is shared between multiple tests.

Methods

  • ShutdownStage(std::string name, ShutdownTokenType type, std::chrono::nanoseconds delay, bool request_failure)
    Constructor. The delay indicates how long we wait before requesting a shutdown.

  • void initialize(StageInterface & interface)
    Adds a timer that requests a shutdown after a period of time.

  • ShutdownTokenPtr shutdown_token()
    Returns our registered shutdown token.

  • std::chrono::steady_clock::time_point shutdown_time()
    Returns the requested shutdown time.