provider.hpp

Go to the documentation of this file.

#ifndef CORAL_PROVIDER_PROVIDER_HPP_INCLUDED
#define CORAL_PROVIDER_PROVIDER_HPP_INCLUDED

#include <exception>
#include <functional>
#include <memory>
#include <string>
#include <thread>
#include <vector>

#include <coral/config.h>
#include <coral/provider/slave_creator.hpp>


// Forward declaration to avoid dependency on ZMQ headers
namespace zmq { class socket_t; }


namespace coral
{
namespace provider
{


class SlaveProvider
{
public:
    SlaveProvider(
        const std::string& slaveProviderID,
        std::vector<std::unique_ptr<SlaveCreator>>&& slaveTypes,
        const coral::net::ip::Address& networkInterface,
        coral::net::ip::Port discoveryPort,
        std::function<void(std::exception_ptr)> exceptionHandler = nullptr);

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

    CORAL_DEFINE_DEFAULT_MOVE(SlaveProvider, m_killSocket, m_thread);

    ~SlaveProvider() CORAL_NOEXCEPT;

    void Stop();

private:
    std::unique_ptr<zmq::socket_t> m_killSocket;
    std::thread m_thread;
};


}}      // namespace
#endif  // header guard