30 #ifndef __ZMQ_PIPE_HPP_INCLUDED__ 31 #define __ZMQ_PIPE_HPP_INCLUDED__ 56 int hwms_ [2],
bool conflate_ [2]);
80 int hwms_ [2],
bool conflate_ [2]);
88 void set_routing_id (uint32_t routing_id_);
89 uint32_t get_routing_id ();
92 void set_identity (
const blob_t &identity_);
95 blob_t get_credential ()
const;
101 bool read (
msg_t *msg_);
111 bool write (
msg_t *msg_);
131 void terminate (
bool delay_);
134 void set_hwms (
int inhwm_,
int outhwm_);
137 void set_hwms_boost(
int inhwmboost_,
int outhwmboost_);
140 bool check_hwm ()
const;
147 void process_activate_read ();
148 void process_activate_write (uint64_t msgs_read_);
149 void process_hiccup (
void *pipe_);
150 void process_pipe_term ();
151 void process_pipe_term_ack ();
154 void process_delimiter ();
159 int inhwm_,
int outhwm_,
bool conflate_);
163 void set_peer (
pipe_t *pipe_);
235 static bool is_delimiter (
const msg_t &msg_);
238 static int compute_lwm (
int hwm_);
virtual void hiccuped(zmq::pipe_t *pipe_)=0
int pipepair(zmq::object_t *parents_[2], zmq::pipe_t *pipes_[2], int hwms_[2], bool conflate_[2])
bool get_identity(void *socket, char *data, size_t *size)
ypipe_base_t< msg_t > upipe_t
virtual void write_activated(zmq::pipe_t *pipe_)=0
std::basic_string< unsigned char > blob_t
virtual void pipe_terminated(zmq::pipe_t *pipe_)=0
virtual void read_activated(zmq::pipe_t *pipe_)=0