port.hpp

Go to the documentation of this file.

#ifndef ZIO_PORT_HPP_SEEN
#define ZIO_PORT_HPP_SEEN

#include "zio/peer.hpp"
#include "zio/message.hpp"
#include "zio/interned.hpp"

#include <memory>
#include <map>


namespace zio {

    class Port {
    public:
        typedef std::string address_t;
        typedef std::string nodename_t;
        typedef std::string portname_t;

        Port(const std::string& name, int stype,
             const std::string& hostname = "127.0.0.1");
        ~Port();

        void set_origin(origin_t origin) { m_origin = origin; }

        void set_verbose(bool verbose = true) { m_verbose = verbose; }

        const std::string& name() const { return m_name; }

        void bind();

        void bind(const std::string& hostname, int tcpportnum);

        void bind(const address_t& address);

        void connect(const address_t& address);

        void connect(const nodename_t& node, const portname_t& port);

        void subscribe(const std::string& prefix = "");

        void set_header(const std::string& leafname, const std::string& value);

        headerset_t do_binds();

        void online(Peer& peer);

        void offline();

        void send(Message& msg);

        bool recv(Message& msg, int timeout=-1);

        zio::socket_t& socket() { return m_sock; }

    private:
        const std::string m_name;
        zio::context_t m_ctx;
        zio::socket_t m_sock;
        std::string m_hostname;
        bool m_online;
        std::map<std::string, std::string> m_headers;
        origin_t m_origin;

        // functions which perform a bind() and return associated header
        typedef std::function<address_t()> binder_t;
        std::vector<binder_t> m_binders;

        std::vector<address_t> m_connect_addresses, m_connected, m_bound;
        std::vector< std::pair<nodename_t, portname_t> > m_connect_nodeports;
        
        bool m_verbose{false};
    };

    typedef std::shared_ptr<Port> portptr_t;

}
#endif