Loading [MathJax]/extensions/tex2jax.js
Thrill  0.1
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Modules Pages
Dispatcher Member List

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

AddRead(Connection &c, const AsyncCallback &read_cb)=0Dispatcherpure virtual
AddTimer(const std::chrono::milliseconds &timeout, const TimerCallback &cb)Dispatcherinline
AddWrite(Connection &c, const AsyncCallback &write_cb)=0Dispatcherpure virtual
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
Cancel(Connection &c)=0Dispatcherpure virtual
debugDispatcherprivatestatic
Dispatch()Dispatcherinline
Dispatcher()=defaultDispatcher
Dispatcher(const Dispatcher &)=deleteDispatcher
DispatchOne(const std::chrono::milliseconds &timeout)=0Dispatcherprotectedpure virtual
ExceptionCallback(Connection &c)Dispatcherinlineprotectedstatic
HasAsyncWrites() constDispatcherinline
Interrupt()=0Dispatcherpure virtual
Loop()Dispatcherinline
milliseconds typedefDispatcherprivate
operator=(const Dispatcher &)=deleteDispatcher
steady_clock typedefDispatcherprivate
Terminate()Dispatcherinline
terminate_Dispatcherprotected
timer_pq_Dispatcherprotected
TimerPQ typedefDispatcherprotected
~Dispatcher()Dispatcherinlinevirtual