activity-lang.cpp

Go to the documentation of this file.

/*
  ActivityLang  -  definition language framework for scheduler activities

  Copyright (C)         Lumiera.org
    2023,               Hermann Vosseler <Ichthyostega@web.de>

  This program is free software; you can redistribute it and/or
  modify it under the terms of the GNU General Public License as
  published by the Free Software Foundation; either version 2 of
  the License, or (at your option) any later version.

  This program is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  GNU General Public License for more details.

  You should have received a copy of the GNU General Public License
  along with this program; if not, write to the Free Software
  Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.

* *****************************************************/

#include "vault/gear/activity-lang.hpp"
#include "lib/format-obj.hpp"
#include "lib/symbol.hpp"
#include "vault/gear/scheduler.hpp"

#include <string>
#include <boost/functional/hash.hpp> 

using std::string;
using lib::Symbol;
using lib::time::Time;
using lib::time::TimeValue;


namespace vault{
namespace gear {
  namespace activity {
    Hook::~Hook() { } // emit VTable here...
  }
  HashVal
  hash_value (ManifestationID const& id)
    {
      return boost::hash_value (uint32_t{id});
    }
  
  Symbol WorkTiming::WORKSTART{"WorkStart"};
  Symbol WorkTiming::WORKSTOP {"WorkStop"};
  
  
  
  Activity::operator string()  const
  {
    return string{"Act("}
         + showVerb()
         + util::showAddr(this)
         + ": "
         + showData()
         + "; ⤵ "
         + (next? next->showVerb()+util::showAddr(*next)
                : util::BOTTOM_INDICATOR)
         + ")";
  }

  string
  Activity::showVerb()  const
  {
    switch (verb_) {
      case INVOKE:    return "INVOKE";
      case WORKSTART: return "WORKSTART";
      case WORKSTOP:  return "WORKSTOP";
      case NOTIFY:    return "NOTIFY";
      case GATE:      return "GATE";
      case POST:      return "POST";
      case FEED:      return "FEED";
      case HOOK:      return "HOOK";
      case TICK:      return "TICK";
      default: NOTREACHED ("uncovered Activity verb diagnostics.");
      }
  }

  string
  Activity::showData()  const
  {
    switch (verb_) {
      case INVOKE:
        return util::showPtr (data_.invocation.task)
             + ", "
             + util::toString(TimeValue{data_.invocation.time});
      case WORKSTART:
      case WORKSTOP:
        return util::toString(TimeValue{data_.timing.instant})
             + ", quality="
             + util::toString(data_.timing.quality);
      case NOTIFY:
        return util::showAddr(data_.notification.target)
             + ", timing:"
             + util::toString(Time{data_.notification.timing});
      case GATE:
        return "<"
             + util::toString(data_.condition.rest)
             + ", until "
             + util::toString(Time{data_.condition.dead});
      case POST:
        return "["
             + util::toString(Time{data_.timeWindow.life})
             + "…"
             + util::toString(Time{data_.timeWindow.dead})
             + "]";
      case FEED:
        return "{"
             + util::toString(data_.feed.one)
             + "::"
             + util::toString(data_.feed.two)
             + "}";
      case HOOK:
        return util::showPtr (data_.callback.hook)
             + "("
             + util::toString(data_.callback.arg)
             + ")";
      case TICK:
        return "◆ ";
      default:
        NOTREACHED ("uncovered Activity verb in activation function.");
      }
  }
  
  
}} // namespace vault::gear