From 12532c7940f23fcb3cd46208c141d47647e76231 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Wed, 22 Jun 2011 16:51:40 +0200 Subject: O(1) fair-queueing in XREP implemented Up to now the complexity of fair-queueing in XREP was O(n). Signed-off-by: Martin Sustrik --- src/pipe.cpp | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) (limited to 'src/pipe.cpp') diff --git a/src/pipe.cpp b/src/pipe.cpp index 1813ca0..c290bae 100644 --- a/src/pipe.cpp +++ b/src/pipe.cpp @@ -63,7 +63,8 @@ zmq::pipe_t::pipe_t (object_t *parent_, upipe_t *inpipe_, upipe_t *outpipe_, peer (NULL), sink (NULL), state (active), - delay (delay_) + delay (delay_), + pipe_id (0) { } @@ -85,6 +86,16 @@ void zmq::pipe_t::set_event_sink (i_pipe_events *sink_) sink = sink_; } +void zmq::pipe_t::set_pipe_id (uint32_t id_) +{ + pipe_id = id_; +} + +uint32_t zmq::pipe_t::get_pipe_id () +{ + return pipe_id; +} + bool zmq::pipe_t::check_read () { if (unlikely (!in_active || (state != active && state != pending))) -- cgit v1.2.3