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

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

AddRead(Connection &c, const AsyncCallback &read_cb)DispatcherThread
AddTimer(std::chrono::milliseconds timeout, const TimerCallback &cb)DispatcherThread
AddWrite(Connection &c, const AsyncCallback &write_cb)DispatcherThread
AsyncRead(Connection &c, uint32_t seq, size_t size, const AsyncReadCallback &done_cb)DispatcherThread
AsyncRead(Connection &c, uint32_t seq, size_t size, data::PinnedByteBlockPtr &&block, const AsyncReadByteBlockCallback &done_cb)DispatcherThread
AsyncWrite(Connection &c, uint32_t seq, Buffer &&buffer, const AsyncWriteCallback &done_cb=AsyncWriteCallback())DispatcherThread
AsyncWrite(Connection &c, uint32_t seq, Buffer &&buffer, data::PinnedBlock &&block, const AsyncWriteCallback &done_cb=AsyncWriteCallback())DispatcherThread
AsyncWriteCopy(Connection &c, uint32_t seq, const void *buffer, size_t size, const AsyncWriteCallback &done_cb=AsyncWriteCallback())DispatcherThread
AsyncWriteCopy(Connection &c, uint32_t seq, const std::string &str, const AsyncWriteCallback &done_cb=AsyncWriteCallback())DispatcherThread
busy_DispatcherThreadprivate
Cancel(Connection &c)DispatcherThread
debugDispatcherThreadprivatestatic
dispatcher_DispatcherThreadprivate
DispatcherThread(std::unique_ptr< class Dispatcher > dispatcher, size_t host_rank)DispatcherThread
DispatcherThread(const DispatcherThread &)=deleteDispatcherThread
Enqueue(Job &&job)DispatcherThreadprivate
host_rank_DispatcherThreadprivate
Job typedefDispatcherThread
jobqueue_DispatcherThreadprivate
operator=(const DispatcherThread &)=deleteDispatcherThread
RunInThread(const AsyncDispatcherThreadCallback &cb)DispatcherThread
Terminate()DispatcherThread
terminate_DispatcherThreadprivate
thread_DispatcherThreadprivate
WakeUpThread()DispatcherThreadprivate
Work()DispatcherThreadprivate
~DispatcherThread()DispatcherThread