mirror of
https://github.com/zeromq/libzmq.git
synced 2025-03-14 10:02:04 +01:00
da31917f4f
Relicense permission collected from all relevant authors as tallied at: https://github.com/rlenferink/libzmq-relicense/blob/master/checklist.md The relicense grants are collected under RELICENSE/ and will be moved to the above repository in a later commit. Fixes https://github.com/zeromq/libzmq/issues/2376
44 lines
1.1 KiB
C++
44 lines
1.1 KiB
C++
/* SPDX-License-Identifier: MPL-2.0 */
|
|
|
|
#ifndef __ZMQ_V2_DECODER_HPP_INCLUDED__
|
|
#define __ZMQ_V2_DECODER_HPP_INCLUDED__
|
|
|
|
#include "decoder.hpp"
|
|
#include "decoder_allocators.hpp"
|
|
|
|
namespace zmq
|
|
{
|
|
// Decoder for ZMTP/2.x framing protocol. Converts data stream into messages.
|
|
// The class has to inherit from shared_message_memory_allocator because
|
|
// the base class calls allocate in its constructor.
|
|
class v2_decoder_t ZMQ_FINAL
|
|
: public decoder_base_t<v2_decoder_t, shared_message_memory_allocator>
|
|
{
|
|
public:
|
|
v2_decoder_t (size_t bufsize_, int64_t maxmsgsize_, bool zero_copy_);
|
|
~v2_decoder_t ();
|
|
|
|
// i_decoder interface.
|
|
msg_t *msg () { return &_in_progress; }
|
|
|
|
private:
|
|
int flags_ready (unsigned char const *);
|
|
int one_byte_size_ready (unsigned char const *);
|
|
int eight_byte_size_ready (unsigned char const *);
|
|
int message_ready (unsigned char const *);
|
|
|
|
int size_ready (uint64_t size_, unsigned char const *);
|
|
|
|
unsigned char _tmpbuf[8];
|
|
unsigned char _msg_flags;
|
|
msg_t _in_progress;
|
|
|
|
const bool _zero_copy;
|
|
const int64_t _max_msg_size;
|
|
|
|
ZMQ_NON_COPYABLE_NOR_MOVABLE (v2_decoder_t)
|
|
};
|
|
}
|
|
|
|
#endif
|