Thrill  0.1
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
dispatcher.hpp File Reference
#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
 

Macro Definition Documentation

#define THRILL_NET_DISPATCHER_HEADER

Definition at line 16 of file dispatcher.hpp.