|
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 |