raw_decoder.hpp

Go to the documentation of this file.

/* SPDX-License-Identifier: MPL-2.0 */
 
#ifndef __ZMQ_RAW_DECODER_HPP_INCLUDED__
#define __ZMQ_RAW_DECODER_HPP_INCLUDED__
 
#include "msg.hpp"
#include "i_decoder.hpp"
#include "stdint.hpp"
#include "decoder_allocators.hpp"
 
namespace zmq
{
//  Decoder for 0MQ v1 framing protocol. Converts data stream into messages.
 
class raw_decoder_t ZMQ_FINAL : public i_decoder
{
  public:
    raw_decoder_t (size_t bufsize_);
    ~raw_decoder_t ();
 
    //  i_decoder interface.
 
    void get_buffer (unsigned char **data_, size_t *size_);
 
    int decode (const unsigned char *data_, size_t size_, size_t &bytes_used_);
 
    msg_t *msg () { return &_in_progress; }
 
    void resize_buffer (size_t) {}
 
  private:
    msg_t _in_progress;
 
    shared_message_memory_allocator _allocator;
 
    ZMQ_NON_COPYABLE_NOR_MOVABLE (raw_decoder_t)
};
}
 
#endif