stapl::runtime::all_locations_rpc_aggregator Class Reference

Aggregator for RPC requests to all locations of a gang. More...

Public Member Functions
	all_locations_rpc_aggregator (const gang_md::id gid, const context::epoch_type epoch) noexcept
	Create a new all_locations_rpc_aggregator. More...
	all_locations_rpc_aggregator (gang_md &g, const context::epoch_type epoch) noexcept
	Create a new all_locations_rpc_aggregator. More...
void *	allocate (const std::size_t n)
	Allocates n bytes for storing a request.

Detailed Description

Aggregator for RPC requests to all locations of a gang.

It flushes requests by default when destroyed.

Constructor & Destructor Documentation

all_locations_rpc_aggregator() [1/2]

stapl::runtime::all_locations_rpc_aggregator::all_locations_rpc_aggregator ( const gang_md::id  gid, const context::epoch_type  epoch  )

noexcept

Create a new all_locations_rpc_aggregator.

Parameters

gid	Destination gang id.
epoch	Current epoch.

all_locations_rpc_aggregator() [2/2]

stapl::runtime::all_locations_rpc_aggregator::all_locations_rpc_aggregator ( gang_md &  g, const context::epoch_type  epoch  )

noexcept

Create a new all_locations_rpc_aggregator.

Parameters

g	Destination gang.
epoch	Current epoch.

---

The documentation for this class was generated from the following file:

• runtime/aggregator.hpp