![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include <mtrie.hpp>
Public Member Functions | |
mtrie_t () | |
~mtrie_t () | |
bool | add (unsigned char *prefix_, size_t size_, zmq::pipe_t *pipe_) |
void | match (unsigned char *data_, size_t size_, void(*func_)(zmq::pipe_t *pipe_, void *arg_), void *arg_) |
void | rm (zmq::pipe_t *pipe_, void(*func_)(unsigned char *data_, size_t size_, void *arg_), void *arg_, bool call_on_uniq_) |
bool | rm (unsigned char *prefix_, size_t size_, zmq::pipe_t *pipe_) |
Private Types | |
typedef std::set< zmq::pipe_t * > | pipes_t |
Private Member Functions | |
mtrie_t (const mtrie_t &) | |
bool | add_helper (unsigned char *prefix_, size_t size_, zmq::pipe_t *pipe_) |
bool | is_redundant () const |
const mtrie_t & | operator= (const mtrie_t &) |
void | rm_helper (zmq::pipe_t *pipe_, unsigned char **buff_, size_t buffsize_, size_t maxbuffsize_, void(*func_)(unsigned char *data_, size_t size_, void *arg_), void *arg_, bool call_on_uniq_) |
bool | rm_helper (unsigned char *prefix_, size_t size_, zmq::pipe_t *pipe_) |
Private Attributes | |
unsigned short | count |
unsigned short | live_nodes |
unsigned char | min |
union { | |
class mtrie_t * node | |
class mtrie_t ** table | |
} | next |
pipes_t * | pipes |
|
private |
zmq::mtrie_t::~mtrie_t | ( | ) |
Definition at line 54 of file mtrie.cpp.
References count, LIBZMQ_DELETE, next, pipes, and zmq_assert.
|
private |
bool zmq::mtrie_t::add | ( | unsigned char * | prefix_, |
size_t | size_, | ||
zmq::pipe_t * | pipe_ | ||
) |
Definition at line 72 of file mtrie.cpp.
References add_helper().
Referenced by zmq::xpub_t::xattach_pipe(), zmq::xpub_t::xread_activated(), and zmq::xpub_t::xsetsockopt().
|
private |
Definition at line 77 of file mtrie.cpp.
References alloc_assert, count, live_nodes, min, next, and pipes.
Referenced by add().
|
private |
Definition at line 438 of file mtrie.cpp.
References live_nodes, and pipes.
Referenced by rm_helper().
void zmq::mtrie_t::match | ( | unsigned char * | data_, |
size_t | size_, | ||
void(*)(zmq::pipe_t *pipe_, void *arg_) | func_, | ||
void * | arg_ | ||
) |
void zmq::mtrie_t::rm | ( | zmq::pipe_t * | pipe_, |
void(*)(unsigned char *data_, size_t size_, void *arg_) | func_, | ||
void * | arg_, | ||
bool | call_on_uniq_ | ||
) |
Definition at line 160 of file mtrie.cpp.
References rm_helper().
Referenced by zmq::xpub_t::xpipe_terminated(), zmq::xpub_t::xread_activated(), and zmq::xpub_t::xsetsockopt().
bool zmq::mtrie_t::rm | ( | unsigned char * | prefix_, |
size_t | size_, | ||
zmq::pipe_t * | pipe_ | ||
) |
Definition at line 293 of file mtrie.cpp.
References rm_helper().
|
private |
Definition at line 169 of file mtrie.cpp.
References alloc_assert, count, LIBZMQ_DELETE, live_nodes, min, next, node, pipes, and zmq_assert.
Referenced by rm(), and rm_helper().
|
private |
Definition at line 298 of file mtrie.cpp.
References alloc_assert, count, is_redundant(), LIBZMQ_DELETE, live_nodes, min, next, pipes, rm_helper(), and zmq_assert.
|
private |
Definition at line 88 of file mtrie.hpp.
Referenced by add_helper(), match(), rm_helper(), and ~mtrie_t().
|
private |
Definition at line 89 of file mtrie.hpp.
Referenced by add_helper(), is_redundant(), and rm_helper().
|
private |
Definition at line 87 of file mtrie.hpp.
Referenced by add_helper(), match(), and rm_helper().
union { ... } zmq::mtrie_t::next |
Referenced by add_helper(), match(), rm_helper(), and ~mtrie_t().
class mtrie_t* zmq::mtrie_t::node |
Definition at line 91 of file mtrie.hpp.
Referenced by match(), and rm_helper().
|
private |
Definition at line 85 of file mtrie.hpp.
Referenced by add_helper(), is_redundant(), match(), rm_helper(), and ~mtrie_t().