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

#include <arcane/accelerator/core/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

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 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.

Description détaillée

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

Définition à la ligne 39 du fichier 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 51 du fichier RunCommandImpl.cc.

Documentation des fonctions membres

◆ _createEvent()

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

private

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

◆ _freePools()

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

private

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

◆ _getOrCreateReduceMemoryImpl()

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

private

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

◆ _init()

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

private

Définition à la ligne 85 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 301 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 215 du fichier RunCommandImpl.cc.

◆ create()

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

static

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

◆ getOrCreateReduceMemoryImpl()

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

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

◆ internalStream()

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

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

◆ kernelName()

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

inline

Définition à la ligne 58 du fichier internal/RunCommandImpl.h.

◆ notifyBeginLaunchKernel()

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

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

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

Références ARCANE_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 190 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 150 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 170 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 247 du fichier RunCommandImpl.cc.

◆ runner()

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

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

◆ traceInfo()

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

inline

Définition à la ligne 57 du fichier 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 93 du fichier 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 110 du fichier internal/RunCommandImpl.h.

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

◆ 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 96 du fichier 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 128 du fichier 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 125 du fichier internal/RunCommandImpl.h.

Référencé par notifyBeginLaunchKernel().

◆ m_kernel_name

String Arcane::Accelerator::impl::RunCommandImpl::m_kernel_name

private

Définition à la ligne 82 du fichier internal/RunCommandImpl.h.

◆ m_loop_one_exec_stat

ForLoopOneExecStat Arcane::Accelerator::impl::RunCommandImpl::m_loop_one_exec_stat

private

Définition à la ligne 112 du fichier internal/RunCommandImpl.h.

◆ m_loop_one_exec_stat_ptr

ForLoopOneExecStat* Arcane::Accelerator::impl::RunCommandImpl::m_loop_one_exec_stat_ptr = nullptr

private

Définition à la ligne 113 du fichier internal/RunCommandImpl.h.

◆ m_may_be_put_in_pool

bool Arcane::Accelerator::impl::RunCommandImpl::m_may_be_put_in_pool = false

private

Indique si on peut remettre la commande dans le pool associé à la RunQueue.

Définition à la ligne 131 du fichier internal/RunCommandImpl.h.

Référencé par Arcane::Accelerator::impl::RunQueueImpl::_checkPutCommandInPoolNoLock(), et _notifyDestroyRunCommand().

◆ m_nb_thread_per_block

Int32 Arcane::Accelerator::impl::RunCommandImpl::m_nb_thread_per_block = 0

private

Définition à la ligne 83 du fichier internal/RunCommandImpl.h.

◆ m_parallel_loop_options

ParallelLoopOptions Arcane::Accelerator::impl::RunCommandImpl::m_parallel_loop_options

private

Définition à la ligne 84 du fichier internal/RunCommandImpl.h.

◆ m_queue

RunQueueImpl* Arcane::Accelerator::impl::RunCommandImpl::m_queue

private

Définition à la ligne 80 du fichier internal/RunCommandImpl.h.

◆ m_reduce_memory_pool

std::stack<ReduceMemoryImpl*> Arcane::Accelerator::impl::RunCommandImpl::m_reduce_memory_pool

private

Définition à la ligne 90 du fichier internal/RunCommandImpl.h.

◆ m_start_event

IRunQueueEventImpl* Arcane::Accelerator::impl::RunCommandImpl::m_start_event = nullptr

private

Évènements pour le début et la fin de l'exécution.

Définition à la ligne 105 du fichier internal/RunCommandImpl.h.

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

◆ m_stop_event

IRunQueueEventImpl* Arcane::Accelerator::impl::RunCommandImpl::m_stop_event = nullptr

private

Évènements pour la fin de l'exécution.

Définition à la ligne 107 du fichier internal/RunCommandImpl.h.

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

◆ m_trace_info

TraceInfo Arcane::Accelerator::impl::RunCommandImpl::m_trace_info

private

Définition à la ligne 81 du fichier internal/RunCommandImpl.h.

◆ m_use_accelerator

const bool Arcane::Accelerator::impl::RunCommandImpl::m_use_accelerator = false

private

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

Définition à la ligne 116 du fichier internal/RunCommandImpl.h.

◆ m_use_profiling

bool Arcane::Accelerator::impl::RunCommandImpl::m_use_profiling = false

private

Indique si on souhaite le profiling.

Définition à la ligne 99 du fichier internal/RunCommandImpl.h.

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

◆ m_use_sequential_timer_event

bool Arcane::Accelerator::impl::RunCommandImpl::m_use_sequential_timer_event = false

private

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

Définition à la ligne 102 du fichier internal/RunCommandImpl.h.

◆ RunCommand

friend Arcane::Accelerator::impl::RunCommandImpl::RunCommand

private

Définition à la ligne 41 du fichier internal/RunCommandImpl.h.

◆ RunQueueImpl

friend Arcane::Accelerator::impl::RunCommandImpl::RunQueueImpl

private

Définition à la ligne 42 du fichier internal/RunCommandImpl.h.

La documentation de cette classe a été générée à partir des fichiers suivants :

Fonctions membres publiques

Fonctions membres publiques statiques

Fonctions membres privées

Attributs privés

Description détaillée

Documentation des constructeurs et destructeur

◆ RunCommandImpl()

◆ ~RunCommandImpl()

Documentation des fonctions membres

◆ _createEvent()

◆ _freePools()

◆ _getOrCreateReduceMemoryImpl()

◆ _init()

◆ _notifyDestroyRunCommand()

◆ _reset()

◆ create()

◆ getOrCreateReduceMemoryImpl()

◆ internalStream()

◆ kernelName()

◆ notifyBeginLaunchKernel()

◆ notifyEndExecuteKernel()

◆ notifyEndLaunchKernel()

◆ notifyLaunchKernelSyclEvent()

◆ releaseReduceMemoryImpl()

◆ runner()

◆ traceInfo()

Documentation des données membres

◆ m_active_reduce_memory_list

◆ m_begin_time

◆ m_has_been_launched

◆ m_has_living_run_command

◆ m_is_allow_reuse_command

◆ m_kernel_name

◆ m_loop_one_exec_stat

◆ m_loop_one_exec_stat_ptr

◆ m_may_be_put_in_pool

◆ m_nb_thread_per_block

◆ m_parallel_loop_options

◆ m_queue

◆ m_reduce_memory_pool

◆ m_start_event

◆ m_stop_event

◆ m_trace_info

◆ m_use_accelerator

◆ m_use_profiling

◆ m_use_sequential_timer_event

◆ RunCommand

◆ RunQueueImpl