control_host_router.hpp

Go to the documentation of this file.

#pragma once
 
#include <pulp/inspect/control_execution.hpp>
 
#include <cstdint>
#include <functional>
#include <memory>
#include <string_view>
 
namespace pulp::inspect {

class ControlHostRouter {
  public:
    using ConnectionGeneration = std::uint64_t;
    using Sender = std::function<bool(const ControlEnvelope&)>;
 
    ControlHostRouter();
    ~ControlHostRouter();
    ControlHostRouter(const ControlHostRouter&) = delete;
    ControlHostRouter& operator=(const ControlHostRouter&) = delete;
 
    bool attach(const ControlRegistrationId& registration_id,
                ConnectionGeneration connection_generation, Sender sender);
    bool attach_slot(const ControlRegistrationId& registration_id,
                     ConnectionGeneration connection_generation, std::string instance_id,
                     std::string instance_generation, Sender sender);
    void detach(const ControlRegistrationId& registration_id,
                ConnectionGeneration connection_generation) noexcept;
    bool connected(const ControlRegistrationId& registration_id) const;

    void end_authority(const ControlClientId& client_id,
                       const ControlRegistrationId& registration_id,
                       const ControlGrantId& grant_id, std::string_view reason) noexcept;

    bool receive(const ControlRegistrationId& registration_id,
                 ConnectionGeneration connection_generation, const ControlEnvelope& envelope);
 
    ControlOperationExecutor executor() const;
    void stop() noexcept;
 
  private:
    class Impl;
    std::shared_ptr<Impl> impl_;
};
 
} // namespace pulp::inspect