flow.hpp

Go to the documentation of this file.

#ifndef ZIO_FLOW_HPP_SEEN
#define ZIO_FLOW_HPP_SEEN

#include "zio/port.hpp"
#include "zio/message.hpp"

namespace zio {

    
    namespace flow {
        enum Direction { undefined, extract, inject };


        class Flow {
        public:
            Flow(portptr_t port);
            ~Flow();

            void send_bot(Message& bot);

            bool recv_bot(Message& bot, int timeout=-1);

            bool put(Message& dat);
            
            int slurp_pay(int timeout);

            bool get(Message& dat, int timeout=-1);

            int flush_pay();

            void send_eot(Message& msg);

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

            bool is_sender() const { return m_sender; }
            int credit() const { return m_credit; }
            int total_credit() const { return m_total_credit; }
        private:
            portptr_t m_port;
            int m_credit, m_total_credit;
            bool m_sender;      // false if we are recver

            // A Flow can use a SERVER socket.  The BOT in recv() sets
            // this.  It will be set on the message prior to any
            // subsequent send()
            Message::routing_id_t m_rid;

            int m_send_seqno{-1};
            int m_recv_seqno{-1};

            bool parse_label(Message& msg, zio::json& lobj);
        };

    }
}

#endif