Thrill
0.1
|
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_ | DispatcherThread | private |
Cancel(Connection &c) | DispatcherThread | |
debug | DispatcherThread | privatestatic |
dispatcher_ | DispatcherThread | private |
DispatcherThread(std::unique_ptr< class Dispatcher > dispatcher, size_t host_rank) | DispatcherThread | |
DispatcherThread(const DispatcherThread &)=delete | DispatcherThread | |
Enqueue(Job &&job) | DispatcherThread | private |
host_rank_ | DispatcherThread | private |
Job typedef | DispatcherThread | |
jobqueue_ | DispatcherThread | private |
operator=(const DispatcherThread &)=delete | DispatcherThread | |
RunInThread(const AsyncDispatcherThreadCallback &cb) | DispatcherThread | |
Terminate() | DispatcherThread | |
terminate_ | DispatcherThread | private |
thread_ | DispatcherThread | private |
WakeUpThread() | DispatcherThread | private |
Work() | DispatcherThread | private |
~DispatcherThread() | DispatcherThread |