Thrill  0.1
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
thrill::net Namespace Reference

Namespaces

 mock
 
 mpi
 
 tcp
 

Classes

class  AsyncReadBuffer
 
class  AsyncReadByteBlock
 
class  AsyncWriteBlock
 
class  AsyncWriteBuffer
 
class  Buffer
 Simple buffer of characters without initialization or growing functionality. More...
 
class  BufferBuilder
 BufferBuilder represents a dynamically growable area of memory, which can be modified by appending integral data types via Put() and other basic operations. More...
 
class  BufferReader
 BufferReader represents a BufferRef with an additional cursor with which the memory can be read incrementally. More...
 
class  BufferRef
 BufferRef represents a reference to a memory area as pointer and valid length. More...
 
class  Connection
 A Connection represents a link to another peer in a network group. More...
 
class  Dispatcher
 Dispatcher is a high level wrapper for asynchronous callback processing. More...
 
class  DispatcherThread
 DispatcherThread contains a net::Dispatcher object and an associated thread that runs in the dispatching loop. More...
 
class  Exception
 A Exception is thrown by Connection on all errors instead of returning error codes. More...
 
class  FixedBufferBuilder
 Represents a FIXED length area of memory, which can be modified by appending integral data types via Put() and other basic operations. More...
 
class  FlowControlChannel
 Provides a blocking collection for communication. More...
 
class  FlowControlChannelManager
 
class  Group
 A network Group is a collection of enumerated communication links, which provides point-to-point communication and MPI-like collective primitives. More...
 
class  Manager
 Initializes communication channels, manages communication channels and handles errors. More...
 
struct  Traffic
 

Typedefs

using AsyncCallback = tlx::delegate< bool(), mem::GPoolAllocator< char > >
 Signature of async connection readability/writability callbacks. More...
 
using AsyncDispatcherThreadCallback = tlx::delegate< void(class Dispatcher &), mem::GPoolAllocator< char > >
 Signature of generic dispatcher callback. 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 AsyncReadCallback = tlx::delegate< void(Connection &c, Buffer &&buffer), mem::GPoolAllocator< char > >
 Signature of async read callbacks. More...
 
using AsyncWriteCallback = tlx::delegate< void(Connection &), mem::GPoolAllocator< char > >
 Signature of async write callbacks. More...
 
using GroupPtr = std::unique_ptr< Group >
 unique pointer to a Group. More...
 
using TimerCallback = tlx::delegate< bool(), mem::GPoolAllocator< char > >
 Signature of timer callbacks. More...
 

Functions

template<typename Group , typename GroupCalled >
void ExecuteGroupThreads (const std::vector< std::unique_ptr< Group > > &groups, const std::function< void(GroupCalled *)> &thread_function)
 
std::ostream & operator<< (std::ostream &os, const Traffic &t)
 
void RunLoopbackGroupTest (size_t num_hosts, const std::function< void(Group *)> &thread_function)
 

Variables

static constexpr bool debug_async = false
 

Function Documentation

std::ostream& thrill::net::operator<< ( std::ostream &  os,
const Traffic &  t 
)

Definition at line 43 of file group.cpp.

References Traffic::total().