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