this contains PaRSEC-based TTG functionality More...

Namespaces
namespace	detail

Classes
struct	Buffer

struct	devicescratch

struct	msg_header_t

struct	Ptr

struct	ptr

class	TT

struct	TTValue

class	WorldImpl

Typedefs
template<typename keyT , typename output_terminalsT , typename derivedT , typename... input_valueTs>
using	Op = TT< keyT, output_terminalsT, derivedT, ttg::typelist< input_valueTs... > >

template<typename keyT , typename output_terminalsT , typename derivedT , typename... input_valueTs>
using	TemplateTask = TT< keyT, output_terminalsT, derivedT, ttg::typelist< input_valueTs... > >

typedef void(*	static_set_arg_fct_type) (void , size_t, ttg::TTBase )

typedef std::pair< static_set_arg_fct_type, ttg::TTBase * >	static_set_arg_fct_call_t

typedef std::tuple< int, std::unique_ptr< std::byte[]>, size_t >	static_set_arg_fct_arg_t

Functions
int	num_devices ()

template<typename... Views>
bool	register_device_memory (std::tuple< Views &... > &views)

template<typename T , std::size_t N>
bool	register_device_memory (const ttg::span< T, N > &span)

template<typename... Buffer>
void	mark_device_out (std::tuple< Buffer &... > &b)

template<typename... Buffer>
void	post_device_out (std::tuple< Buffer &... > &b)

template<typename T >
parsec_data_t *	buffer_data (T &&buffer)

void	make_executable_hook (ttg::World &)

void	ttg_initialize (int argc, char *argv, int num_threads=-1, parsec_context_s =nullptr)

void	ttg_finalize ()

ttg::World	ttg_default_execution_context ()

void	ttg_execute (ttg::World world)

void	ttg_fence (ttg::World world)

template<typename T >
void	ttg_register_ptr (ttg::World world, const std::shared_ptr< T > &ptr)

void	ttg_register_status (ttg::World world, const std::shared_ptr< std::promise< void > > &status_ptr)

template<typename Callback >
void	ttg_register_callback (ttg::World world, Callback &&callback)

ttg::Edge &	ttg_ctl_edge (ttg::World world)

void	ttg_sum (ttg::World world, double &value)

template<typename T , typename... Args>
Ptr< T >	make_ptr (Args &&... args)

template<typename T >
Ptr< std::decay_t< T > >	get_ptr (T &&obj)

void	ttg_initialize (int argc, char *argv, int num_threads, parsec_context_t ctx)

template<typename T >
void	ttg_register_ptr (ttg::World world, std::unique_ptr< T > &&ptr)

template<typename T >
void	ttg_broadcast (::ttg::World world, T &data, int source_rank)

template<typename ValueT >
auto	persistent (ValueT &&value)

Variables
std::map< uint64_t, static_set_arg_fct_call_t >	static_id_to_op_map

std::mutex	static_map_mutex

std::multimap< uint64_t, static_set_arg_fct_arg_t >	delayed_unpack_actions

Detailed Description

this contains PaRSEC-based TTG functionality

Typedef Documentation

◆ Op

template<typename keyT , typename output_terminalsT , typename derivedT , typename... input_valueTs>

using ttg_parsec::Op = typedef TT<keyT, output_terminalsT, derivedT, ttg::typelist<input_valueTs...> >

Definition at line 24 of file fwd.h.

◆ static_set_arg_fct_arg_t

typedef std::tuple<int, std::unique_ptr<std::byte[]>, size_t> ttg_parsec::static_set_arg_fct_arg_t

Definition at line 139 of file ttg.h.

◆ static_set_arg_fct_call_t

typedef std::pair<static_set_arg_fct_type, ttg::TTBase *> ttg_parsec::static_set_arg_fct_call_t

Definition at line 136 of file ttg.h.

◆ static_set_arg_fct_type

typedef void(* ttg_parsec::static_set_arg_fct_type) (void *, size_t, ttg::TTBase *)

Definition at line 135 of file ttg.h.

◆ TemplateTask

template<typename keyT , typename output_terminalsT , typename derivedT , typename... input_valueTs>

using ttg_parsec::TemplateTask = typedef TT<keyT, output_terminalsT, derivedT, ttg::typelist<input_valueTs...> >

Definition at line 27 of file fwd.h.

Function Documentation

◆ buffer_data()

template<typename T >

parsec_data_t * ttg_parsec::buffer_data ( T && buffer )

Definition at line 279 of file devicefunc.h.

Here is the call graph for this function:

◆ get_ptr()

template<typename T >

Ptr< std::decay_t< T > > ttg_parsec::get_ptr ( T && obj )

inline

Definition at line 253 of file ptr.h.

Here is the call graph for this function:

◆ make_executable_hook()

void ttg_parsec::make_executable_hook ( ttg::World & world )

inline

Definition at line 1170 of file ttg.h.

Here is the call graph for this function:

◆ make_ptr()

template<typename T , typename... Args>

Ptr< T > ttg_parsec::make_ptr ( Args &&... args )

inline

Definition at line 271 of file ptr.h.

◆ mark_device_out()

template<typename... Buffer>

void ttg_parsec::mark_device_out ( std::tuple< Buffer &... > & b )

Definition at line 237 of file devicefunc.h.

Here is the call graph for this function:

◆ num_devices()

int ttg_parsec::num_devices ( )

inline

Definition at line 42 of file device.h.

◆ persistent()

template<typename ValueT >

auto ttg_parsec::persistent ( ValueT && value )

inline

Definition at line 94 of file ttvalue.h.

◆ post_device_out()

template<typename... Buffer>

void ttg_parsec::post_device_out ( std::tuple< Buffer &... > & b )

Definition at line 274 of file devicefunc.h.

Here is the call graph for this function:

◆ register_device_memory() [1/2]

template<typename T , std::size_t N>

bool ttg_parsec::register_device_memory ( const ttg::span< T, N > & span )

Definition at line 108 of file devicefunc.h.

◆ register_device_memory() [2/2]

template<typename... Views>

bool ttg_parsec::register_device_memory ( std::tuple< Views &... > & views )

Definition at line 80 of file devicefunc.h.

Here is the call graph for this function:

◆ ttg_broadcast()

template<typename T >

void ttg_parsec::ttg_broadcast	(	::ttg::World	world,
		T &	data,
		int	source_rank
	)

broadcast

Template Parameters

T	a serializable type

Definition at line 1177 of file ttg.h.

Here is the call graph for this function:

◆ ttg_ctl_edge()

ttg::Edge & ttg_parsec::ttg_ctl_edge ( ttg::World world )

inline

Definition at line 1162 of file ttg.h.

Here is the call graph for this function:

◆ ttg_default_execution_context()

ttg::World ttg_parsec::ttg_default_execution_context ( )

inline

Examples: distributed.cc.

Definition at line 1137 of file ttg.h.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ttg_execute()

void ttg_parsec::ttg_execute ( ttg::World world )

inline

Definition at line 1140 of file ttg.h.

Here is the call graph for this function:

◆ ttg_fence()

void ttg_parsec::ttg_fence ( ttg::World world )

inline

Definition at line 1141 of file ttg.h.

Here is the call graph for this function:

◆ ttg_finalize()

void ttg_parsec::ttg_finalize ( )

inline

Definition at line 1127 of file ttg.h.

Here is the call graph for this function:

◆ ttg_initialize() [1/2]

void ttg_parsec::ttg_initialize	(	int	argc,
		char **	argv,
		int	num_threads,
		parsec_context_t *	ctx
	)

inline

Definition at line 1068 of file ttg.h.

Here is the call graph for this function:

◆ ttg_initialize() [2/2]

void ttg_parsec::ttg_initialize	(	int	argc,
		char **	argv,
		int	num_threads = `-1`,
		parsec_context_s *	= `nullptr`
	)

inline

◆ ttg_register_callback()

template<typename Callback >

void ttg_parsec::ttg_register_callback	(	ttg::World	world,
		Callback &&	callback
	)

inline

Definition at line 1158 of file ttg.h.

Here is the call graph for this function:

◆ ttg_register_ptr() [1/2]

template<typename T >

void ttg_parsec::ttg_register_ptr	(	ttg::World	world,
		const std::shared_ptr< T > &	ptr
	)

inline

Definition at line 1144 of file ttg.h.

Here is the call graph for this function:

◆ ttg_register_ptr() [2/2]

template<typename T >

void ttg_parsec::ttg_register_ptr	(	ttg::World	world,
		std::unique_ptr< T > &&	ptr
	)

inline

Definition at line 1149 of file ttg.h.

Here is the call graph for this function:

◆ ttg_register_status()

void ttg_parsec::ttg_register_status	(	ttg::World	world,
		const std::shared_ptr< std::promise< void > > &	status_ptr
	)

inline

Definition at line 1153 of file ttg.h.

Here is the call graph for this function:

◆ ttg_sum()

void ttg_parsec::ttg_sum	(	ttg::World	world,
		double &	value
	)

inline

Definition at line 1164 of file ttg.h.

Here is the call graph for this function:

Variable Documentation

◆ delayed_unpack_actions

std::multimap<uint64_t, static_set_arg_fct_arg_t> ttg_parsec::delayed_unpack_actions

inline

Definition at line 140 of file ttg.h.

◆ static_id_to_op_map

std::map<uint64_t, static_set_arg_fct_call_t> ttg_parsec::static_id_to_op_map

inline

Definition at line 137 of file ttg.h.

◆ static_map_mutex

std::mutex ttg_parsec::static_map_mutex

inline

Definition at line 138 of file ttg.h.

Namespaces

Classes

Typedefs

Functions

Variables

Detailed Description

Typedef Documentation

◆ Op

◆ static_set_arg_fct_arg_t

◆ static_set_arg_fct_call_t

◆ static_set_arg_fct_type

◆ TemplateTask

Function Documentation

◆ buffer_data()

◆ get_ptr()

◆ make_executable_hook()

◆ make_ptr()

◆ mark_device_out()

◆ num_devices()

◆ persistent()

◆ post_device_out()

◆ register_device_memory() [1/2]

◆ register_device_memory() [2/2]

◆ ttg_broadcast()

◆ ttg_ctl_edge()

◆ ttg_default_execution_context()

◆ ttg_execute()

◆ ttg_fence()

◆ ttg_finalize()

◆ ttg_initialize() [1/2]

◆ ttg_initialize() [2/2]

◆ ttg_register_callback()

◆ ttg_register_ptr() [1/2]

◆ ttg_register_ptr() [2/2]

◆ ttg_register_status()

◆ ttg_sum()

Variable Documentation

◆ delayed_unpack_actions

◆ static_id_to_op_map

◆ static_map_mutex