STAPL: stapl::directory< Key, Transmitter, Mapper, Registry, true

Specialization with migration support. More...

Public Member Functions
template<typename Function , typename MapperParam >
	directory (Function &&f, MapperParam &&mapper_param, bool b_migration_enabled, bool b_enable_buffering)
	Constructor used by PARAGRAPH. More...

template<typename Functor >
void	migrate (Key const &key, const location_type loc, Functor &&f)
	Change location a key is registered / associated with. After registry is updated, apply f is applied a new associated location. More...

bool	has_perfect_mapper (void) const

mapper_t const &	key_mapper (void) const

mapper_t &	key_mapper (void)

bool	empty (void) const
	Returns `true` if there are no entries in directory's registry on this location.

void	reset (void)
	Clear all local registrations and pending messages in directory. Used by `clear()` methods of container distributions.

bool	try_register_key_local (Key const &key)
	Attempt registration from the managing location. Return true if successful (i.e., not already registered).

void	register_key (Key const &key)
	Associate `key` in directory's registry with the location invoking this method. More...

void	register_keys (std::pair< Key, Key > const &keys)

void	register_apply (Key const &key, Functor &&f)
	Associate `key` in directory's registry with location invoking this method. Registration location is implicitly set to be caller of this method. More...

void	register_apply (Key const &key, Functor &&f, location_type location)
	Associate `key` in directory's registry with location invoking this method. More...

void	unregister_key (Key const &key)
	Unregister `key` in directory's registry.

void	unregister_apply (Key const &key, Functor &&f)
	Unregister `key` and apply a function object `f` at location where directory's registry manages `key`. More...

void	invoke_where (Functor &&f, Key const &key)
	Invoke function object at the location where key is currently registered. More...

void	try_invoke_where (Functor &&f, Key const &key)
	Invoke function object at the location where key is currently registered if the key is registered. More...

void	unordered_invoke_where (Functor &&f, Key const &key)
	Invoke function object at the location where key is currently registered, disregarding RMI causal ordering. More...

locality_info	locality (Key const &key)
	Provide locality information about a key managed by the directory. More...

runtime::location_md const &	get_location_md (void) const noexcept
	Returns the location metadata of the location this object registered in.

runtime::location_md &	get_location_md (void) noexcept
	Returns the location metadata of the location this object registered in. noexcept More...

Distributed Object Management
rmi_handle::const_reference const &	get_rmi_handle (void) const noexcept
	Returns the associated rmi_handle.

rmi_handle::reference const &	get_rmi_handle (void) noexcept
	Returns the associated rmi_handle.

size_type	get_location_id (void) const noexcept
	Returns the location id of the local sub-object.

size_type	get_num_locations (void) const noexcept
	Returns the number of locations of the gang of this p_object.

void	advance_epoch (void)
	Advances the epoch of the object. More...

void	unlock (void)
	Used by `lock_guard` functionality in method of derived classes to request atomicity with respect to incoming RMIs. More...

void	lock (void)
	Used by `lock_guard` functionality in method of derived classes to request atomicity with respect to incoming RMIs. More...

bool	try_lock (void)
	Attempt to maintain atomicity with respect to incoming RMIs. More...

Public Types
using	base_directory_type = base_t

using	manager_type = mapper_t

using	registry_type = registry_t

using	key_type = Key

using	size_type = rmi_handle::size_type

Protected Member Functions
void	execute (Functor &&f)
	Internal method, target of RMI called via migrate_impl to invoke functor `f` at new registration location, post registry update. More...

void	invoke_at_manager (Key const &key, void(Directory::*const pmf)(PMFArgs...), Args &&... args)
	Forwards functor and arguments to location managing `key`. The location managing the key will invoke the method with the supplied arguments. More...

void	invoke_at_manager (Key const &key, void(Directory::*const pmf)(PMFArgs...) const, Args &&... args) const
	Forwards const functor and arguments to location managing `key`. The location managing the key will invoke the method with the supplied arguments. More...

void	invoke_at_manager_impl (Key const &key, void(Directory::*const pmf)(PMFArgs...), Args &&... args)
	Implementation of. More...

void	invoke_at_manager_impl (Key const &key, void(Directory::*const pmf)(PMFArgs...) const, Args &&... args) const
	Implementation of. More...

void	flush_pending (const location_type loc, Key const &key, queue_t &pending)
	Forward all buffered requests for `key` to location `loc.` More...

void	request_forward (Key const &key, Functor &&f)
	Internal method used to facilitate invocation of `f` on location where `key` is currently registered. Called via RMI on directory location where `key` is managed. More...

void	try_request_forward (Key const &key, Functor &&f)
	Internal method used to facilitate invocation of `f` on location where `key` is currently registered. If `key` is not registered, the request is dropped; otherwise, it is called via RMI on directory location where `key` is managed. This is directed at situations where it is legal for a key to not exist, i.e. erasing non-existent keys in the unordered set container. More...

Protected Types
using	mapper_t = typename select_parameter< Mapper, detail::default_key_mapper< Key > >::type

using	registry_t = typename select_parameter< Registry, boost::unordered_map< Key, location_type, boost::hash< Key >, std::equal_to< Key >, pool_allocator< std::pair< Key const, location_type > > > >::type

using	transmitter_type = typename select_parameter< Transmitter, async_transmitter >::type

using	queue_t = request_queue< request_t >

using	queues_t = boost::unordered_map< Key, queue_t, stapl::hash< Key >, std::equal_to< Key >, pool_allocator< std::pair< Key const, queue_t > > >

Protected Attributes
registry_t	m_registry
	Stores key to locations mapping.

queues_t	m_pending
	Map of queues, indexed by `Key`. Entry for keys exists when messages arrive and must be buffered prior to registration, during migration, etc.

mapper_t	m_key_mapper
	Map a key to location that manages it (i.e., where it has entry in m_registry).

bool	m_b_perfect_mapper

Detailed Description

template<typename Key, typename Transmitter, typename Mapper, typename Registry>
class stapl::directory< Key, Transmitter, Mapper, Registry, true >

Specialization with migration support.

Constructor & Destructor Documentation

◆ directory()

template<typename Key , typename Transmitter , typename Mapper , typename Registry >

template<typename Function , typename MapperParam >

stapl::directory< Key, Transmitter, Mapper, Registry, true >::directory	(	Function &&	f,
		MapperParam &&	mapper_param,
		bool	b_migration_enabled,
		bool	b_enable_buffering
	)

Constructor used by PARAGRAPH.

Parameters

f	Unary functor passed key and return true iff current location has key registered here (in this context, a wrapper around an edge_container method).
b_migration_enabled	Specifies whether object allows key migration.
b_enable_buffering	Specifies whether directory requests using ARMI are buffered.

Member Function Documentation

◆ migrate()

template<typename Key , typename Transmitter , typename Mapper , typename Registry >

template<typename Functor >

void stapl::directory< Key, Transmitter, Mapper, Registry, true >::migrate	(	Key const &	key,
		const location_type	loc,
		Functor &&	f
	)

Change location a key is registered / associated with. After registry is updated, apply f is applied a new associated location.

Parameters

key	Key whose registered location is to be updated.
loc	Location which `key` should now be associated with.
f	Nullary function object applied at `loc` after the registry is updated.

◆ execute()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::execute ( Functor && f )

protectedinherited

Internal method, target of RMI called via migrate_impl to invoke functor f at new registration location, post registry update.

Parameters

f	Nullary functor to apply.

See also: migrate_impl()

◆ invoke_at_manager() [1/2]

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::invoke_at_manager	(	Key const &	key,
		void(Directory::*)(PMFArgs...)	pmf,
		Args &&...	args
	)

protectedinherited

Forwards functor and arguments to location managing key. The location managing the key will invoke the method with the supplied arguments.

Parameters

key	Key value whose managing location (i.e., where registry entry is stored) is where `pmf` will be invoked.
pmf	Directory member function to be invoked.
args	variadic list of arguments to be applied.

This is used to internally encapsulate to forward various method invocations from the requester (e.g., registration, invoke_where, etc) to the location where they can be serviced, forwarded, etc.

See also: directory_base::invoke_where

◆ invoke_at_manager() [2/2]

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::invoke_at_manager	(	Key const &	key,
		void(Directory::*)(PMFArgs...) const	pmf,
		Args &&...	args
	)		const

protectedinherited

Forwards const functor and arguments to location managing key. The location managing the key will invoke the method with the supplied arguments.

Parameters

key	Key value whose managing location (i.e., where registry entry is stored) is where `pmf` will be invoked.
pmf	Directory const member function to be invoked.
args	variadic list of arguments to be applied.

This is used to internally encapsulate to forward various method invocations from the requester (e.g., registration, invoke_where, etc) to the location where they can be serviced, forwarded, etc.

See also: directory_base::invoke_where

◆ invoke_at_manager_impl() [1/2]

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::invoke_at_manager_impl	(	Key const &	key,
		void(Directory::*)(PMFArgs...)	pmf,
		Args &&...	args
	)

protectedinherited

Implementation of.

See also: invoke_at_manager with a given transmitter

Template Parameters

Trans The transmitter type

◆ invoke_at_manager_impl() [2/2]

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::invoke_at_manager_impl	(	Key const &	key,
		void(Directory::*)(PMFArgs...) const	pmf,
		Args &&...	args
	)		const

protectedinherited

Implementation of.

See also: invoke_at_manager with a given transmitter

Template Parameters

Trans The given transmitter type

◆ flush_pending()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::flush_pending	(	const location_type	loc,
		Key const &	key,
		queue_t &	pending
	)

protectedinherited

Forward all buffered requests for key to location loc.

Parameters

loc	Location to send buffered requests to.
key	Key value buffered requests are for.
pending	Pending queue associated with `Key`.

This is internal method only called on the directory location managing key.

◆ request_forward()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::request_forward	(	Key const &	key,
		Functor &&	f
	)

protectedinherited

Internal method used to facilitate invocation of f on location where key is currently registered. Called via RMI on directory location where key is managed.

Parameters

key	Key whose registered location determines where `f` should be executed.
f	Functor to invoke (unary, `key` passed as parameter).

Called by invoke_where and execute (the latter when migration enabled).

◆ try_request_forward()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::try_request_forward	(	Key const &	key,
		Functor &&	f
	)

protectedinherited

Internal method used to facilitate invocation of f on location where key is currently registered. If key is not registered, the request is dropped; otherwise, it is called via RMI on directory location where key is managed. This is directed at situations where it is legal for a key to not exist, i.e. erasing non-existent keys in the unordered set container.

Parameters

key	Key whose registered location determines where `f` should be executed.
f	Functor to invoke (unary, `key` passed as parameter).

Called by invoke_where and execute (the latter when migration enabled).

◆ register_key()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::register_key ( Key const & key )

inherited

Associate key in directory's registry with the location invoking this method.

◆ register_apply() [1/2]

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::register_apply	(	Key const &	key,
		Functor &&	f
	)

inherited

Associate key in directory's registry with location invoking this method. Registration location is implicitly set to be caller of this method.

Parameters

key	Key to register.
f	Unary function object (receives `key`) as parameter to call after registration.

◆ register_apply() [2/2]

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::register_apply	(	Key const &	key,
		Functor &&	f,
		location_type	location
	)

inherited

Associate key in directory's registry with location invoking this method.

Parameters

key	Key to registered.
f	Unary function object (receives `key`) as parameter to call after registration.
location	Location this key should be mapped to in the registry.

◆ unregister_apply()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::unregister_apply	(	Key const &	key,
		Functor &&	f
	)

inherited

Unregister key and apply a function object f at location where directory's registry manages key.

Parameters

key	Key to unregister.
f	Unary function object (receives `key`) as parameter to call after unregistration.

◆ invoke_where()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::invoke_where	(	Functor &&	f,
		Key const &	key
	)

inherited

Invoke function object at the location where key is currently registered.

Parameters

f	Functor to apply. Unary operator, receives key as parameter.
key	Registered key

◆ try_invoke_where()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::try_invoke_where	(	Functor &&	f,
		Key const &	key
	)

inherited

Invoke function object at the location where key is currently registered if the key is registered.

Parameters

f	Functor to apply. Unary operator, receives key as parameter.
key	Key that may not be registered when method is invoked

◆ unordered_invoke_where()

void stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::unordered_invoke_where	(	Functor &&	f,
		Key const &	key
	)

inherited

Invoke function object at the location where key is currently registered, disregarding RMI causal ordering.

Parameters

f	Functor to apply. Unary operator, receives key as parameter.
key	Registered key

◆ locality()

locality_info stapl::detail::directory_base< Key, Transmitter, Mapper, Registry, EnableMigration >::locality ( Key const & key )

inherited

Provide locality information about a key managed by the directory.

Parameters

key	registered key

Note: Used by containers that inherit / customize directory behavior.

◆ get_location_md()

runtime::location_md& stapl::p_object::get_location_md ( void )

noexceptinherited

Returns the location metadata of the location this object registered in. noexcept

noexcept

◆ advance_epoch()

void stapl::p_object::advance_epoch ( void )

inherited

Advances the epoch of the object.

Advancing the epoch will flush any pending RMIs. It will also increase the epoch of the current gang if the object is not a named object.

◆ unlock()

void stapl::p_object::unlock ( void )

inherited

Used by lock_guard functionality in method of derived classes to request atomicity with respect to incoming RMIs.

Mutates counter in the associated runqueue.

◆ lock()

void stapl::p_object::lock ( void )

inherited

Used by lock_guard functionality in method of derived classes to request atomicity with respect to incoming RMIs.

Mutates counter in the associated runqueue.

◆ try_lock()

bool stapl::p_object::try_lock ( void )

inherited

Attempt to maintain atomicity with respect to incoming RMIs.

Mutates counter in the associated runqueue.

Returns: true if the lock was able to be acquired. false if it is already locked.

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

directory.hpp

Public Member Functions

Public Types

Protected Member Functions

Protected Types

Protected Attributes

Detailed Description

template<typename Key, typename Transmitter, typename Mapper, typename Registry> class stapl::directory< Key, Transmitter, Mapper, Registry, true >

Constructor & Destructor Documentation

◆ directory()

Member Function Documentation

◆ migrate()

◆ execute()

◆ invoke_at_manager() [1/2]

◆ invoke_at_manager() [2/2]

◆ invoke_at_manager_impl() [1/2]

◆ invoke_at_manager_impl() [2/2]

◆ flush_pending()

◆ request_forward()

◆ try_request_forward()

◆ register_key()

◆ register_apply() [1/2]

◆ register_apply() [2/2]

◆ unregister_apply()

◆ invoke_where()

◆ try_invoke_where()

◆ unordered_invoke_where()

◆ locality()

◆ get_location_md()

◆ advance_epoch()

◆ unlock()

◆ lock()

◆ try_lock()

template<typename Key, typename Transmitter, typename Mapper, typename Registry>
class stapl::directory< Key, Transmitter, Mapper, Registry, true >