diff options
author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-15 09:09:19 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-15 09:09:19 +0100 |
commit | e49115224a7957b0e5d49326bc02ae6af186eaf9 (patch) | |
tree | 81d1ca0ea496004bbc85cec9b3289af96cdaa197 /src/zmq_decoder.hpp | |
parent | bd792faa9d6c78c375dbc52c6d773e157335da36 (diff) |
zmq_encoder/decoder are able to add/trim prefixes from messages; fair queueing and load balancing algorithms factorised into separate classes
Diffstat (limited to 'src/zmq_decoder.hpp')
-rw-r--r-- | src/zmq_decoder.hpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/zmq_decoder.hpp b/src/zmq_decoder.hpp index c5433b7..6df2558 100644 --- a/src/zmq_decoder.hpp +++ b/src/zmq_decoder.hpp @@ -32,7 +32,9 @@ namespace zmq { public: - zmq_decoder_t (size_t bufsize_); + // If prefix is not NULL, it will be glued to the beginning of every + // decoded message. + zmq_decoder_t (size_t bufsize_, void *prefix_, size_t prefix_size_); ~zmq_decoder_t (); void set_inout (struct i_inout *destination_); @@ -47,6 +49,9 @@ namespace zmq unsigned char tmpbuf [8]; ::zmq_msg_t in_progress; + void *prefix; + size_t prefix_size; + zmq_decoder_t (const zmq_decoder_t&); void operator = (const zmq_decoder_t&); }; |