Multiplexer Member List

This is the complete list of members for Multiplexer, including all inherited members.

active_streams_	Multiplexer	private
AllocateCatStreamId(size_t local_worker_id)	Multiplexer
AllocateMixStreamId(size_t local_worker_id)	Multiplexer
AsyncReadMultiplexerHeader(size_t peer, Connection &s)	Multiplexer	private
block_pool()	Multiplexer	inline
block_pool_	Multiplexer	private
CatLoopback(size_t stream_id, size_t to_worker_id)	Multiplexer	private
Close()	Multiplexer
closed_	Multiplexer	private
Connection typedef	Multiplexer	private
d_	Multiplexer	private
debug	Multiplexer	privatestatic
dispatcher()	Multiplexer	inline
dispatcher_	Multiplexer	private
GetNewCatStream(size_t local_worker_id, size_t dia_id)	Multiplexer
GetNewMixStream(size_t local_worker_id, size_t dia_id)	Multiplexer
GetOrCreateCatStreamData(size_t id, size_t local_worker_id, size_t dia_id)	Multiplexer
GetOrCreateMixStreamData(size_t id, size_t local_worker_id, size_t dia_id)	Multiplexer
group()	Multiplexer	inline
group_	Multiplexer	private
IntGetOrCreateCatStreamData(size_t id, size_t local_worker_id, size_t dia_id)	Multiplexer	private
IntGetOrCreateMixStreamData(size_t id, size_t local_worker_id, size_t dia_id)	Multiplexer	private
IntReleaseCatStream(size_t id, size_t local_worker_id)	Multiplexer	private
IntReleaseMixStream(size_t id, size_t local_worker_id)	Multiplexer	private
logger()	Multiplexer
max_active_streams_	Multiplexer	private
mem_manager_	Multiplexer	private
MixLoopback(size_t stream_id, size_t to_worker_id)	Multiplexer	private
Multiplexer(mem::Manager &mem_manager, BlockPool &block_pool, net::DispatcherThread &dispatcher, net::Group &group, size_t workers_per_host)	Multiplexer
Multiplexer(const Multiplexer &)=delete	Multiplexer
mutex_	Multiplexer	private
my_host_rank() const	Multiplexer	inline
num_hosts() const	Multiplexer	inline
num_parallel_async_	Multiplexer	private
num_workers() const	Multiplexer	inline
OnCatStreamBlock(size_t peer, Connection &s, const StreamMultiplexerHeader &header, const CatStreamDataPtr &stream, PinnedByteBlockPtr &&bytes)	Multiplexer	private
OnMixStreamBlock(size_t peer, Connection &s, const StreamMultiplexerHeader &header, const MixStreamDataPtr &stream, PinnedByteBlockPtr &&bytes)	Multiplexer	private
OnMultiplexerHeader(size_t peer, uint32_t seq, Connection &s, net::Buffer &&buffer)	Multiplexer	private
operator=(const Multiplexer &)=delete	Multiplexer
send_size_limit_	Multiplexer	private
workers_per_host() const	Multiplexer	inline
workers_per_host_	Multiplexer	private
~Multiplexer()	Multiplexer