![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include <decoder_allocators.hpp>
Public Member Functions | |
shared_message_memory_allocator (std::size_t bufsize_) | |
shared_message_memory_allocator (std::size_t bufsize_, std::size_t maxMessages) | |
~shared_message_memory_allocator () | |
void | advance_content () |
unsigned char * | allocate () |
unsigned char * | buffer () |
unsigned char * | data () |
void | deallocate () |
void | inc_ref () |
zmq::msg_t::content_t * | provide_content () |
unsigned char * | release () |
void | resize (std::size_t new_size) |
std::size_t | size () const |
Static Public Member Functions | |
static void | call_dec_ref (void *, void *buffer) |
Private Attributes | |
unsigned char * | buf |
std::size_t | bufsize |
std::size_t | max_size |
std::size_t | maxCounters |
zmq::msg_t::content_t * | msg_content |
Definition at line 93 of file decoder_allocators.hpp.
|
explicit |
Definition at line 37 of file decoder_allocators.cpp.
zmq::shared_message_memory_allocator::shared_message_memory_allocator | ( | std::size_t | bufsize_, |
std::size_t | maxMessages | ||
) |
Definition at line 46 of file decoder_allocators.cpp.
zmq::shared_message_memory_allocator::~shared_message_memory_allocator | ( | ) |
Definition at line 55 of file decoder_allocators.cpp.
References deallocate().
|
inline |
Definition at line 141 of file decoder_allocators.hpp.
Referenced by zmq::raw_decoder_t::decode(), and zmq::v2_decoder_t::size_ready().
unsigned char * zmq::shared_message_memory_allocator::allocate | ( | ) |
Definition at line 60 of file decoder_allocators.cpp.
References alloc_assert, buf, bufsize, max_size, maxCounters, msg_content, release(), zmq::atomic_counter_t::set(), and zmq::atomic_counter_t::sub().
Referenced by zmq::raw_decoder_t::get_buffer().
|
inline |
Definition at line 126 of file decoder_allocators.hpp.
References zmq::c_single_allocator::buf.
Referenced by zmq::raw_decoder_t::decode(), and zmq::v2_decoder_t::size_ready().
|
static |
Definition at line 122 of file decoder_allocators.cpp.
References buf, zmq_assert, and zmq::atomic_counter_t::~atomic_counter_t().
Referenced by zmq::raw_decoder_t::decode(), and zmq::v2_decoder_t::size_ready().
unsigned char * zmq::shared_message_memory_allocator::data | ( | ) |
Definition at line 141 of file decoder_allocators.cpp.
References buf.
Referenced by zmq::v2_decoder_t::size_ready().
void zmq::shared_message_memory_allocator::deallocate | ( | ) |
Definition at line 98 of file decoder_allocators.cpp.
References buf, release(), and zmq::atomic_counter_t::sub().
Referenced by ~shared_message_memory_allocator().
void zmq::shared_message_memory_allocator::inc_ref | ( | ) |
Definition at line 117 of file decoder_allocators.cpp.
References buf.
Referenced by zmq::v2_decoder_t::size_ready().
|
inline |
Definition at line 136 of file decoder_allocators.hpp.
Referenced by zmq::raw_decoder_t::decode(), and zmq::v2_decoder_t::size_ready().
unsigned char * zmq::shared_message_memory_allocator::release | ( | ) |
Definition at line 107 of file decoder_allocators.cpp.
References buf, bufsize, and msg_content.
Referenced by allocate(), deallocate(), and zmq::raw_decoder_t::decode().
|
inline |
Definition at line 131 of file decoder_allocators.hpp.
References zmq::c_single_allocator::bufsize.
std::size_t zmq::shared_message_memory_allocator::size | ( | ) | const |
Definition at line 136 of file decoder_allocators.cpp.
References bufsize.
Referenced by zmq::raw_decoder_t::get_buffer(), and zmq::v2_decoder_t::size_ready().
|
private |
Definition at line 147 of file decoder_allocators.hpp.
Referenced by allocate(), call_dec_ref(), data(), deallocate(), inc_ref(), and release().
|
private |
Definition at line 148 of file decoder_allocators.hpp.
Referenced by allocate(), release(), and size().
|
private |
Definition at line 149 of file decoder_allocators.hpp.
Referenced by allocate().
|
private |
Definition at line 151 of file decoder_allocators.hpp.
Referenced by allocate().
|
private |
Definition at line 150 of file decoder_allocators.hpp.
Referenced by allocate(), and release().