Implémentation d'une commande pour accélérateur. Plus de détails...

#include </__w/arcaneframework.github.io/arcaneframework.github.io/framework/arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h>

Graphe de collaboration de Arcane::Accelerator::Impl::RunCommandImpl:

Fonctions membres publiques
	RunCommandImpl (RunQueueImpl *queue)

	RunCommandImpl (const RunCommandImpl &)=delete

RunCommandImpl &	operator= (const RunCommandImpl &)=delete

const TraceInfo &	traceInfo () const

const String &	kernelName () const

void	notifyBeginLaunchKernel ()
	Notification du début d'exécution de la commande.

void	notifyEndLaunchKernel ()
	Notification de la fin de lancement de la commande.

void	notifyEndExecuteKernel ()
	Notification de la fin d'exécution du noyau.

Impl::IReduceMemoryImpl *	getOrCreateReduceMemoryImpl ()

void	releaseReduceMemoryImpl (ReduceMemoryImpl *p)

IRunQueueStream *	internalStream () const

RunnerImpl *	runner () const

bool	hasActiveReduction () const

void	notifyLaunchKernelSyclEvent (void *sycl_event_ptr)
	Notification du lancement d'un kernel SYCL.

Fonctions membres publiques statiques
static RunCommandImpl *	create (RunQueueImpl *r)

Fonctions membres privées
ReduceMemoryImpl *	_getOrCreateReduceMemoryImpl ()

void	_freePools ()

void	_reset ()

void	_init ()

IRunQueueEventImpl *	_createEvent ()

void	_notifyDestroyRunCommand ()
	Méthode appelée quand l'instance RunCommand associée est détruite.

Attributs privés
friend	RunCommand

friend	RunQueueImpl

RunQueueImpl *	m_queue

TraceInfo	m_trace_info

String	m_kernel_name

Int32	m_nb_thread_per_block = 0

ParallelLoopOptions	m_parallel_loop_options

std::stack< ReduceMemoryImpl * >	m_reduce_memory_pool

std::set< ReduceMemoryImpl * >	m_active_reduce_memory_list
	Liste des réductions actives.

bool	m_has_been_launched = false
	Indique si la commande a été lancée.

bool	m_use_profiling = false
	Indique si on souhaite le profiling.

bool	m_use_sequential_timer_event = false
	Indique si on utilise les évènements séquentiels pour calculer le temps d'exécution.

IRunQueueEventImpl *	m_start_event = nullptr
	Évènements pour le début et la fin de l'exécution.

IRunQueueEventImpl *	m_stop_event = nullptr
	Évènements pour la fin de l'exécution.

Int64	m_begin_time = 0
	Temps au lancement de la commande.

ForLoopOneExecStat	m_loop_one_exec_stat

ForLoopOneExecStat *	m_loop_one_exec_stat_ptr = nullptr

const eExecutionPolicy	m_execution_policy = eExecutionPolicy::None
	Indique si la commande s'exécute sur accélérateur.

const bool	m_use_accelerator = false
	Indique si la commande s'exécute sur accélérateur.

bool	m_is_allow_reuse_command = false
	Indique si on autorise à utiliser plusieurs fois la même commande.

bool	m_has_living_run_command = false
	Indique si une RunCommand a une référence sur cette instance.

bool	m_may_be_put_in_pool = false
	Indique si on peut remettre la commande dans le pool associé à la RunQueue.

Int32	m_shared_memory_size = 0
	Taille de la mémoire partagée à allouer.

Int32	m_nb_stride = 1
	Nombre de pas de décomposition de la boucle.

Int32	m_default_nb_stride = 1
	Nombre de pas de décomposition par défaut.

Description détaillée

Implémentation d'une commande pour accélérateur.

Définition à la ligne 39 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

Documentation des constructeurs et destructeur

◆ RunCommandImpl()

Arcane::Accelerator::Impl::RunCommandImpl::RunCommandImpl ( RunQueueImpl * queue )

explicit

Définition à la ligne 40 du fichier RunCommandImpl.cc.

◆ ~RunCommandImpl()

Arcane::Accelerator::Impl::RunCommandImpl::~RunCommandImpl ( )

Définition à la ligne 52 du fichier RunCommandImpl.cc.

Documentation des fonctions membres

◆ _createEvent()

IRunQueueEventImpl * Arcane::Accelerator::Impl::RunCommandImpl::_createEvent ( )

private

Définition à la ligne 75 du fichier RunCommandImpl.cc.

◆ _freePools()

void Arcane::Accelerator::Impl::RunCommandImpl::_freePools ( )

private

Définition à la ligne 63 du fichier RunCommandImpl.cc.

◆ _getOrCreateReduceMemoryImpl()

ReduceMemoryImpl * Arcane::Accelerator::Impl::RunCommandImpl::_getOrCreateReduceMemoryImpl ( )

private

Définition à la ligne 289 du fichier RunCommandImpl.cc.

◆ _init()

void Arcane::Accelerator::Impl::RunCommandImpl::_init ( )

private

Définition à la ligne 86 du fichier RunCommandImpl.cc.

◆ _notifyDestroyRunCommand()

void Arcane::Accelerator::Impl::RunCommandImpl::_notifyDestroyRunCommand ( )

private

Méthode appelée quand l'instance RunCommand associée est détruite.

Définition à la ligne 312 du fichier RunCommandImpl.cc.

Références m_has_been_launched, et m_may_be_put_in_pool.

◆ _reset()

void Arcane::Accelerator::Impl::RunCommandImpl::_reset ( )

private

Définition à la ligne 224 du fichier RunCommandImpl.cc.

◆ create()

RunCommandImpl * Arcane::Accelerator::Impl::RunCommandImpl::create ( RunQueueImpl * r )

static

Définition à la ligne 118 du fichier RunCommandImpl.cc.

◆ getOrCreateReduceMemoryImpl()

IReduceMemoryImpl * Arcane::Accelerator::Impl::RunCommandImpl::getOrCreateReduceMemoryImpl ( )

Définition à la ligne 245 du fichier RunCommandImpl.cc.

◆ hasActiveReduction()

bool Arcane::Accelerator::Impl::RunCommandImpl::hasActiveReduction ( ) const

inline

Définition à la ligne 69 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

◆ internalStream()

IRunQueueStream * Arcane::Accelerator::Impl::RunCommandImpl::internalStream ( ) const

Définition à la ligne 271 du fichier RunCommandImpl.cc.

◆ kernelName()

const String & Arcane::Accelerator::Impl::RunCommandImpl::kernelName ( ) const

inline

Définition à la ligne 58 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

◆ notifyBeginLaunchKernel()

void Arcane::Accelerator::Impl::RunCommandImpl::notifyBeginLaunchKernel ( )

Notification du début d'exécution de la commande.

Définition à la ligne 131 du fichier RunCommandImpl.cc.

Références ARCCORE_FATAL, Arcane::platform::getRealTimeNS(), m_begin_time, m_has_been_launched, m_is_allow_reuse_command, m_start_event, m_use_profiling, et Arcane::Accelerator::Impl::IRunQueueStream::notifyBeginLaunchKernel().

Voici le graphe d'appel pour cette fonction :

◆ notifyEndExecuteKernel()

void Arcane::Accelerator::Impl::RunCommandImpl::notifyEndExecuteKernel ( )

Notification de la fin d'exécution du noyau.

Après cet appel, on est sur que la commande a fini de s'exécuter et on peut la recycler. En asynchrone, cette méthode est appelée lors de la synchronisation d'une file.

Définition à la ligne 199 du fichier RunCommandImpl.cc.

Références Arcane::ProfilingRegistry::_threadLocalForLoopInstance(), m_begin_time, m_has_been_launched, m_start_event, m_stop_event, m_use_profiling, et Arcane::ForLoopOneExecStat::setEndTime().

Voici le graphe d'appel pour cette fonction :

◆ notifyEndLaunchKernel()

void Arcane::Accelerator::Impl::RunCommandImpl::notifyEndLaunchKernel ( )

Notification de la fin de lancement de la commande.

La commande continue à s'exécuter en tâche de fond.

Définition à la ligne 159 du fichier RunCommandImpl.cc.

Références m_stop_event, m_use_profiling, et Arcane::Accelerator::Impl::IRunQueueStream::notifyEndLaunchKernel().

Voici le graphe d'appel pour cette fonction :

◆ notifyLaunchKernelSyclEvent()

void Arcane::Accelerator::Impl::RunCommandImpl::notifyLaunchKernelSyclEvent ( void * sycl_event_ptr )

Notification du lancement d'un kernel SYCL.

sycl_event_ptr est de type sycl::event* et contient l'évènement associé à la commande qui est retourné lors des appels à sycl::queue::submit().

Définition à la ligne 179 du fichier RunCommandImpl.cc.

Références Arcane::Accelerator::Impl::IRunQueueStream::_setSyclLastCommandEvent(), et m_start_event.

Voici le graphe d'appel pour cette fonction :

◆ releaseReduceMemoryImpl()

void Arcane::Accelerator::Impl::RunCommandImpl::releaseReduceMemoryImpl ( ReduceMemoryImpl * p )

Définition à la ligne 258 du fichier RunCommandImpl.cc.

◆ runner()

RunnerImpl * Arcane::Accelerator::Impl::RunCommandImpl::runner ( ) const

Définition à la ligne 280 du fichier RunCommandImpl.cc.

◆ traceInfo()

const TraceInfo & Arcane::Accelerator::Impl::RunCommandImpl::traceInfo ( ) const

inline

Définition à la ligne 57 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

Documentation des données membres

◆ m_active_reduce_memory_list

std::set<ReduceMemoryImpl*> Arcane::Accelerator::Impl::RunCommandImpl::m_active_reduce_memory_list

private

Liste des réductions actives.

Définition à la ligne 94 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

◆ m_begin_time

Int64 Arcane::Accelerator::Impl::RunCommandImpl::m_begin_time = 0

private

Temps au lancement de la commande.

Définition à la ligne 111 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

Référencé par notifyBeginLaunchKernel(), et notifyEndExecuteKernel().

◆ m_default_nb_stride

Int32 Arcane::Accelerator::Impl::RunCommandImpl::m_default_nb_stride = 1

private

Nombre de pas de décomposition par défaut.

Définition à la ligne 144 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

◆ m_execution_policy

const eExecutionPolicy Arcane::Accelerator::Impl::RunCommandImpl::m_execution_policy = eExecutionPolicy::None

private

Indique si la commande s'exécute sur accélérateur.

Définition à la ligne 117 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

◆ m_has_been_launched

bool Arcane::Accelerator::Impl::RunCommandImpl::m_has_been_launched = false

private

Indique si la commande a été lancée.

Définition à la ligne 97 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

Référencé par _notifyDestroyRunCommand(), notifyBeginLaunchKernel(), et notifyEndExecuteKernel().

◆ m_has_living_run_command

bool Arcane::Accelerator::Impl::RunCommandImpl::m_has_living_run_command = false

private

Indique si une RunCommand a une référence sur cette instance.

Définition à la ligne 132 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

Référencé par Arcane::Accelerator::Impl::RunQueueImpl::_checkPutCommandInPoolNoLock().

◆ m_is_allow_reuse_command

bool Arcane::Accelerator::Impl::RunCommandImpl::m_is_allow_reuse_command = false

private

Indique si on autorise à utiliser plusieurs fois la même commande.

Normalement cela est interdit mais avant novembre 2024, il n'y avait pas de mécanisme pour détecter cela. On peut donc temporairement autoriser cela et dans un on supprimera cette possibilité.

Définition à la ligne 129 du fichier arccore/src/common/arccore/common/accelerator/internal/RunCommandImpl.h.

Référencé par notifyBeginLaunchKernel().