slave_provider_comm.hpp

Go to the documentation of this file.

#ifndef CORAL_BUS_SP_INFO_CLIENT_HPP
#define CORAL_BUS_SP_INFO_CLIENT_HPP

#include <chrono>
#include <cstdint>
#include <functional>
#include <memory>
#include <string>
#include <system_error>

#include "coral/config.h"
#include "coral/model.hpp"
#include "coral/net.hpp"
#include "coral/net/reactor.hpp"
#include "coral/net/reqrep.hpp"


namespace coral
{
namespace bus
{


class SlaveProviderClient
{
public:
    SlaveProviderClient(
        coral::net::Reactor& reactor,
        const coral::net::ip::Endpoint& endpoint);

    ~SlaveProviderClient() CORAL_NOEXCEPT;

    SlaveProviderClient(const SlaveProviderClient&) = delete;
    SlaveProviderClient& operator=(const SlaveProviderClient&) = delete;

    SlaveProviderClient(SlaveProviderClient&&) CORAL_NOEXCEPT;

    SlaveProviderClient& operator=(SlaveProviderClient&&) CORAL_NOEXCEPT;

    typedef std::function<void(
            const std::error_code& error,
            const coral::model::SlaveTypeDescription* slaveTypes,
            std::size_t slaveTypeCount)>
        GetSlaveTypesHandler;

    void GetSlaveTypes(
        GetSlaveTypesHandler onComplete,
        std::chrono::milliseconds timeout);

    typedef std::function<void(
            const std::error_code& ec,
            const coral::net::SlaveLocator& slaveLocator,
            const std::string& errorMessage)>
        InstantiateSlaveHandler;

    void InstantiateSlave(
        const std::string& slaveTypeUUID,
        std::chrono::milliseconds instantiationTimeout,
        InstantiateSlaveHandler onComplete,
        std::chrono::milliseconds requestTimeout = std::chrono::milliseconds(0));

private:
    class Private;
    std::unique_ptr<Private> m_private;
};


class SlaveProviderOps
{
public:
    virtual int GetSlaveTypeCount() const CORAL_NOEXCEPT = 0;

    virtual coral::model::SlaveTypeDescription GetSlaveType(int index) const = 0;

    virtual coral::net::SlaveLocator InstantiateSlave(
        const std::string& slaveTypeUUID,
        std::chrono::milliseconds timeout) = 0;

    virtual ~SlaveProviderOps() CORAL_NOEXCEPT { }
};


void MakeSlaveProviderServer(
    coral::net::reqrep::Server& server,
    std::shared_ptr<SlaveProviderOps> slaveProvider);


}} // namespace
#endif // header guard