Thrill  0.1
Dispatcher Member List

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) finalDispatcherinlinevirtual
AddTimer(const std::chrono::milliseconds &timeout, const TimerCallback &cb)Dispatcherinline
AddWrite(net::Connection &, const Callback &) finalDispatcherinlinevirtual
async_read_Dispatcherprotected
async_read_block_Dispatcherprotected
async_write_Dispatcherprotected
async_write_block_Dispatcherprotected
AsyncRead(net::Connection &c, uint32_t seq, size_t size, const AsyncReadBufferCallback &done_cb=AsyncReadBufferCallback()) finalDispatcherinlinevirtual
AsyncRead(net::Connection &c, uint32_t seq, size_t size, data::PinnedByteBlockPtr &&block, const AsyncReadByteBlockCallback &done_cb) finalDispatcherinlinevirtual
AsyncWrite(net::Connection &c, uint32_t seq, Buffer &&buffer, const AsyncWriteCallback &done_cb=AsyncWriteCallback()) finalDispatcherinlinevirtual
AsyncWrite(net::Connection &c, uint32_t seq, data::PinnedBlock &&block, const AsyncWriteCallback &done_cb=AsyncWriteCallback()) finalDispatcherinlinevirtual
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
Callback typedefDispatcher
Cancel(net::Connection &c) finalDispatcherinlinevirtual
debugDispatcherprivatestatic
DefaultExceptionCallback()Dispatcherinlineprivatestatic
Dispatch()Dispatcherinline
Dispatcher(size_t group_size)Dispatcher
thrill::net::Dispatcher::Dispatcher()=defaultDispatcher
thrill::net::Dispatcher::Dispatcher(const Dispatcher &)=deleteDispatcher
DispatchOne(const std::chrono::milliseconds &timeout) finalDispatchervirtual
ExceptionCallback(Connection &c)Dispatcherinlineprotectedstatic
HasAsyncWrites() constDispatcherinline
Interrupt() finalDispatcherinlinevirtual
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()Dispatcherinline
mpi_async_Dispatcherprivate
mpi_async_out_Dispatcherprivate
mpi_async_requests_Dispatcherprivate
mpi_status_out_Dispatcherprivate
operator=(const Dispatcher &)=deleteDispatcher
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_Dispatcherprivate
recv_queue_Dispatcherprivate
send_active_Dispatcherprivate
send_queue_Dispatcherprivate
SetExcept(net::Connection &c, const Callback &except_cb)Dispatcherinline
Terminate()Dispatcherinline
terminate_Dispatcherprotected
timer_pq_Dispatcherprotected
TimerPQ typedefDispatcherprotected
watch_Dispatcherprivate
watch_active_Dispatcherprivate
~Dispatcher()Dispatchervirtual