|
Thrill
0.1
|
#include <thrill/data/block.hpp>#include <thrill/data/byte_block.hpp>#include <thrill/mem/allocator.hpp>#include <thrill/net/buffer.hpp>#include <thrill/net/connection.hpp>#include <tlx/delegate.hpp>#include <tlx/die.hpp>#include <atomic>#include <chrono>#include <ctime>#include <deque>#include <functional>#include <queue>#include <string>#include <vector>
Include dependency graph for dispatcher.hpp:
This graph shows which files directly or indirectly include this file:Go to the source code of this file.
Classes | |
| class | AsyncReadBuffer |
| class | AsyncReadByteBlock |
| class | AsyncWriteBlock |
| class | AsyncWriteBuffer |
| class | Dispatcher |
| Dispatcher is a high level wrapper for asynchronous callback processing. More... | |
| struct | Dispatcher::Timer |
| struct for timer callbacks More... | |
Namespaces | |
| thrill | |
| thrill::net | |
Macros | |
| #define | THRILL_NET_DISPATCHER_HEADER |
Typedefs | |
| using | AsyncCallback = tlx::delegate< bool(), mem::GPoolAllocator< char > > |
| Signature of async connection readability/writability callbacks. More... | |
| using | AsyncReadBufferCallback = tlx::delegate< void(Connection &c, Buffer &&buffer), mem::GPoolAllocator< char > > |
| Signature of async read Buffer callbacks. More... | |
| using | AsyncReadByteBlockCallback = tlx::delegate< void(Connection &c, data::PinnedByteBlockPtr &&bytes), mem::GPoolAllocator< char > > |
| Signature of async read ByteBlock callbacks. More... | |
| using | AsyncWriteCallback = tlx::delegate< void(Connection &), mem::GPoolAllocator< char > > |
| Signature of async write callbacks. More... | |
| using | TimerCallback = tlx::delegate< bool(), mem::GPoolAllocator< char > > |
| Signature of timer callbacks. More... | |
Variables | |
| static constexpr bool | debug_async = false |
| static constexpr bool | debug_async_recv = false |
| static constexpr bool | debug_async_send = false |
| #define THRILL_NET_DISPATCHER_HEADER |
Definition at line 16 of file dispatcher.hpp.