Thrill
0.1
|
This is the complete list of members for Dispatcher, including all inherited members.
AddAsyncRequest(const MPI_Request &req, const AsyncRequestCallback &callback) | Dispatcher | |
AddRead(net::Connection &c, const Callback &read_cb) final | Dispatcher | inlinevirtual |
AddTimer(const std::chrono::milliseconds &timeout, const TimerCallback &cb) | Dispatcher | inline |
AddWrite(net::Connection &, const Callback &) final | Dispatcher | inlinevirtual |
async_read_ | Dispatcher | protected |
async_read_block_ | Dispatcher | protected |
async_write_ | Dispatcher | protected |
async_write_block_ | Dispatcher | protected |
AsyncRead(net::Connection &c, uint32_t seq, size_t size, const AsyncReadBufferCallback &done_cb=AsyncReadBufferCallback()) final | Dispatcher | inlinevirtual |
AsyncRead(net::Connection &c, uint32_t seq, size_t size, data::PinnedByteBlockPtr &&block, const AsyncReadByteBlockCallback &done_cb) final | Dispatcher | inlinevirtual |
AsyncWrite(net::Connection &c, uint32_t seq, Buffer &&buffer, const AsyncWriteCallback &done_cb=AsyncWriteCallback()) final | Dispatcher | inlinevirtual |
AsyncWrite(net::Connection &c, uint32_t seq, data::PinnedBlock &&block, const AsyncWriteCallback &done_cb=AsyncWriteCallback()) final | Dispatcher | inlinevirtual |
AsyncWriteCopy(Connection &c, uint32_t seq, const void *buffer, size_t size, const AsyncWriteCallback &done_cb=AsyncWriteCallback()) | Dispatcher | inline |
AsyncWriteCopy(Connection &c, uint32_t seq, const std::string &str, const AsyncWriteCallback &done_cb=AsyncWriteCallback()) | Dispatcher | inline |
Callback typedef | Dispatcher | |
Cancel(net::Connection &c) final | Dispatcher | inlinevirtual |
debug | Dispatcher | privatestatic |
DefaultExceptionCallback() | Dispatcher | inlineprivatestatic |
Dispatch() | Dispatcher | inline |
Dispatcher(size_t group_size) | Dispatcher | |
thrill::net::Dispatcher::Dispatcher()=default | Dispatcher | |
thrill::net::Dispatcher::Dispatcher(const Dispatcher &)=delete | Dispatcher | |
DispatchOne(const std::chrono::milliseconds &timeout) final | Dispatcher | virtual |
ExceptionCallback(Connection &c) | Dispatcher | inlineprotectedstatic |
HasAsyncWrites() const | Dispatcher | inline |
Interrupt() final | Dispatcher | inlinevirtual |
IRecv(Connection &c, uint32_t seq, void *data, size_t size) | Dispatcher | |
ISend(Connection &c, uint32_t seq, const void *data, size_t size) | Dispatcher | |
Loop() | Dispatcher | inline |
mpi_async_ | Dispatcher | private |
mpi_async_out_ | Dispatcher | private |
mpi_async_requests_ | Dispatcher | private |
mpi_status_out_ | Dispatcher | private |
operator=(const Dispatcher &)=delete | Dispatcher | |
PerformAsync(MpiAsync &&a) | Dispatcher | |
PumpRecvQueue(int peer) | Dispatcher | |
PumpSendQueue(int peer) | Dispatcher | |
QueueAsyncRecv(net::Connection &c, MpiAsync &&a) | Dispatcher | |
QueueAsyncSend(net::Connection &c, MpiAsync &&a) | Dispatcher | |
recv_active_ | Dispatcher | private |
recv_queue_ | Dispatcher | private |
send_active_ | Dispatcher | private |
send_queue_ | Dispatcher | private |
SetExcept(net::Connection &c, const Callback &except_cb) | Dispatcher | inline |
Terminate() | Dispatcher | inline |
terminate_ | Dispatcher | protected |
timer_pq_ | Dispatcher | protected |
TimerPQ typedef | Dispatcher | protected |
watch_ | Dispatcher | private |
watch_active_ | Dispatcher | private |
~Dispatcher() | Dispatcher | virtual |