material_flow_logical_agent.h

// Copyright 2023 The SOLA authors
//
// This file is part of DAISI.
//
// DAISI 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; version 2.
//
// DAISI 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 DAISI. If not, see
// <https://www.gnu.org/licenses/>.
//
// SPDX-License-Identifier: GPL-2.0-only
 
#ifndef DAISI_CPPS_MATERIAL_FLOW_MATERIAL_FLOW_LOGICAL_AGENT_H_
#define DAISI_CPPS_MATERIAL_FLOW_MATERIAL_FLOW_LOGICAL_AGENT_H_
 
#include "cpps/logical/logical_agent.h"
#include "material_flow/model/material_flow.h"
#include "solanet/network_udp/message.h"
 
namespace daisi::cpps::logical {
 
class MaterialFlowLogicalAgent : public LogicalAgent {
public:
  MaterialFlowLogicalAgent(const AlgorithmConfig &config_algo, bool first_node);
 
  ~MaterialFlowLogicalAgent() override = default;  // TODO
 
  virtual void init();
 
  void start() override;
 
  virtual void addMaterialFlow(std::string mfdl_program);
 
  void setWaitingForStart();
 
  bool isBusy() const;
 
  bool isFinished() const;
 
protected:
  void initAlgorithms() override;
 
  void messageReceiveFunction(const solanet::Message &m) override;
 
  void topicMessageReceiveFunction(const sola::TopicMessage &m) override;
 
  void setServices();
 
private:
  std::shared_ptr<daisi::material_flow::MFDLScheduler> material_flow_;
 
  bool waiting_for_start_ = false;
 
  uint16_t execution_counter_ = 0;
};
 
}  // namespace daisi::cpps::logical
 
#endif