Thrill  0.1
Dispatcher Member List

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

AddRead(net::Connection &_c, const Callback &read_cb) finalDispatchervirtual
AddTimer(const std::chrono::milliseconds &timeout, const TimerCallback &cb)Dispatcherinline
AddWrite(net::Connection &_c, const Callback &write_cb) finalDispatchervirtual
async_read_Dispatcherprotected
async_read_block_Dispatcherprotected
async_write_Dispatcherprotected
async_write_block_Dispatcherprotected
AsyncRead(Connection &c, uint32_t, size_t size, const AsyncReadBufferCallback &done_cb)Dispatcherinlinevirtual
AsyncRead(Connection &c, uint32_t, size_t size, data::PinnedByteBlockPtr &&block, const AsyncReadByteBlockCallback &done_cb)Dispatcherinlinevirtual
AsyncWrite(Connection &c, uint32_t, Buffer &&buffer, const AsyncWriteCallback &done_cb=AsyncWriteCallback())Dispatcherinlinevirtual
AsyncWrite(Connection &c, uint32_t, data::PinnedBlock &&block, const AsyncWriteCallback &done_cb=AsyncWriteCallback())Dispatcherinlinevirtual
AsyncWriteCopy(Connection &c, uint32_t seq, const void *buffer, size_t size, const AsyncWriteCallback &done_cb=AsyncWriteCallback())Dispatcherinline
AsyncWriteCopy(Connection &c, uint32_t seq, const std::string &str, const AsyncWriteCallback &done_cb=AsyncWriteCallback())Dispatcherinline
Callback typedefDispatcher
Cancel(net::Connection &) finalDispatchervirtual
d_Dispatcherprivate
debugDispatcherprivatestatic
Dispatch()Dispatcherinline
Dispatcher()Dispatcher
thrill::net::Dispatcher::Dispatcher(const Dispatcher &)=deleteDispatcher
DispatchOne(const std::chrono::milliseconds &timeout) finalDispatchervirtual
ExceptionCallback(Connection &c)Dispatcherinlineprotectedstatic
GetWatch(Connection *c)Dispatcherprivate
HasAsyncWrites() constDispatcherinline
Interrupt() finalDispatchervirtual
Loop()Dispatcherinline
Notify(Connection *c)Dispatcher
operator=(const Dispatcher &)=deleteDispatcher
Terminate()Dispatcherinline
terminate_Dispatcherprotected
timer_pq_Dispatcherprotected
TimerPQ typedefDispatcherprotected
~Dispatcher()Dispatchervirtual