.. _program_listing_file_lib_action.cc:

Program Listing for File action.cc
==================================

|exhale_lsh| :ref:`Return to documentation for file <file_lib_action.cc>` (``lib/action.cc``)

.. |exhale_lsh| unicode:: U+021B0 .. UPWARDS ARROW WITH TIP LEFTWARDS

.. code-block:: cpp

   /*
    * Copyright (C) 2019 TU Dresden
    * All rights reserved.
    *
    * Authors:
    *   Christian Menard
    */
   
   #include "reactor-cpp/action.hh"
   
   #include "reactor-cpp/assert.hh"
   #include "reactor-cpp/environment.hh"
   #include "reactor-cpp/reaction.hh"
   #include "reactor-cpp/time.hh"
   
   namespace reactor {
   
   void BaseAction::register_trigger(Reaction* reaction) {
     reactor_assert(reaction != nullptr);
     reactor_assert(this->environment() == reaction->environment());
     assert_phase(this, Environment::Phase::Assembly);
     validate(this->container() == reaction->container(),
              "Action triggers must belong to the same reactor as the triggered "
              "reaction");
     reactor_assert(triggers_.insert(reaction).second);
   }
   
   void BaseAction::register_scheduler(Reaction* reaction) {
     reactor_assert(reaction != nullptr);
     reactor_assert(this->environment() == reaction->environment());
     assert_phase(this, Environment::Phase::Assembly);
     // the reaction must belong to the same reactor as this action
     validate(this->container() == reaction->container(), "Scheduable actions must belong to the same reactor as the "
                                                          "triggered reaction");
     reactor_assert(schedulers_.insert(reaction).second);
   }
   
   void Timer::startup() {
     // abort if the offset is the maximum duration
     if (offset_ == Duration::max()) {
       return;
     }
   
     Tag tag_zero = Tag::from_physical_time(environment()->start_time());
     if (offset_ != Duration::zero()) {
       environment()->scheduler()->schedule_sync(this, tag_zero.delay(offset_));
     } else {
       environment()->scheduler()->schedule_sync(this, tag_zero);
     }
   }
   
   void Timer::cleanup() noexcept {
     BaseAction::cleanup();
     // schedule the timer again
     if (period_ != Duration::zero()) {
       Tag now = Tag::from_logical_time(environment()->logical_time());
       Tag next = now.delay(period_);
       environment()->scheduler()->schedule_sync(this, next);
     }
   }
   
   ShutdownTrigger::ShutdownTrigger(const std::string& name, Reactor* container)
       : Timer(name, container, Duration::zero(), container->environment()->timeout()) {}
   
   void ShutdownTrigger::setup() noexcept {
     BaseAction::setup();
     environment()->sync_shutdown();
   }
   
   void ShutdownTrigger::shutdown() {
     if (!is_present()) {
       Tag tag = Tag::from_logical_time(environment()->logical_time()).delay();
       environment()->scheduler()->schedule_sync(this, tag);
     }
   }
   
   } // namespace reactor