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
static constexpr bool	debug_async_recv = false
static constexpr bool	debug_async_send = false

Function Documentation

operator<<()

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

Definition at line 43 of file group.cpp.

References Traffic::total().