raw_decoder.hpp

/* 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