worker.hpp

Go to the documentation of this file.

#ifndef ZIO_DOMO_WORKER_HPP_SEEN
#define ZIO_DOMO_WORKER_HPP_SEEN

#include "zio/util.hpp"

namespace zio {
namespace domo {

    class Worker {
    public:
        Worker(zio::socket_t& sock, std::string broker_address,
               std::string service);
        ~Worker();

        // API methods

        zio::multipart_t work(zio::multipart_t& reply);

        void recv(zio::multipart_t& request);
        void send(zio::multipart_t& reply);


    private:
        zio::socket_t& m_sock;
        std::string m_address;
        std::string m_service;
        int m_liveness{HEARTBEAT_LIVENESS};
        time_unit_t m_heartbeat{HEARTBEAT_INTERVAL};
        time_unit_t m_reconnect{HEARTBEAT_INTERVAL};
        time_unit_t m_heartbeat_at{0};
        bool m_expect_reply{false};
        std::string m_reply_to{""};

    private:

        std::function<void(zio::socket_t& server_socket,
                           zio::multipart_t& mmsg)> really_recv;
        std::function<void(zio::socket_t& server_socket,
                           zio::multipart_t& mmsg)> really_send;

        void connect_to_broker(bool reconnect = true);

    };


    // An echo worker actor function
    void echo_worker(zio::socket_t& link, std::string address, int socktype);

}
}
#endif