Concurrency::details::_Amp_runtime_trace Class Reference

#include <amprt.h>

Public Member Functions
_AMPIMP	~_Amp_runtime_trace ()
_AMPIMP void	_Write_end_event (ULONG _Span_id)
void	_Add_accelerator_config_event (PVOID _Accelerator_id, LPCWSTR _Device_path, LPCWSTR _Device_description)
void	_Write_all_accelerator_config_events ()
ULONG	_Start_accelerator_view_wait_event (PVOID _Accelerator_id, PVOID _Accelerator_view_id)
void	_Launch_flush_event (PVOID _Accelerator_id, PVOID _Accelerator_view_id)
ULONG	_Launch_marker (PVOID _Accelerator_id, PVOID _Accelerator_view_id)
_AMPIMP ULONG	_Start_parallel_for_each_event_helper (_In_ _DPC_call_handle *_Handle)
concurrency::completion_future	_Start_async_op_wait_event_helper (ULONG _Async_op_id, _Event _Ev)
_AMPIMP ULONG	_Start_array_view_synchronize_event_helper (const _Buffer_descriptor &_Buff_desc)
_AMPIMP ULONG	_Launch_array_view_synchronize_event_helper (const _Buffer_descriptor &_Buff_desc)
_AMPIMP ULONG	_Start_copy_event_helper (const _Buffer_descriptor &_Src, const _Buffer_descriptor &_Dest, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Start_copy_event_helper (nullptr_t, const _Buffer_descriptor &_Dest, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Start_copy_event_helper (const _Buffer_descriptor &_Src, nullptr_t, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Launch_async_copy_event_helper (const _Buffer_descriptor &_Src, const _Buffer_descriptor &_Dest, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Launch_async_copy_event_helper (nullptr_t, const _Buffer_descriptor &_Dest, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Launch_async_copy_event_helper (const _Buffer_descriptor &_Src, nullptr_t, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Start_copy_event_helper (const _Texture_descriptor &_Src, nullptr_t, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Start_copy_event_helper (nullptr_t, const _Texture_descriptor &_Dest, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Start_copy_event_helper (const _Texture_descriptor &_Src, const _Texture_descriptor &_Dest, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Launch_async_copy_event_helper (const _Texture_descriptor &_Src, nullptr_t, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Launch_async_copy_event_helper (nullptr_t, const _Texture_descriptor &_Dest, ULONGLONG _Num_bytes_for_copy)
_AMPIMP ULONG	_Launch_async_copy_event_helper (const _Texture_descriptor &_Src, const _Texture_descriptor &_Dest, ULONGLONG _Num_bytes_for_copy)
void	_Enable_provider (bool _Enable=true)

Private Member Functions
	_Amp_runtime_trace (PVOID _Callback_function, _In_ _Trace *_Trace)
	_Amp_runtime_trace (const _Amp_runtime_trace &)
_Amp_runtime_trace &	operator= (const _Amp_runtime_trace &)
void	_Write_accelerator_config_event (const std::tuple< PVOID, LPCWSTR, LPCWSTR > &_ConfigTuple)
ULONG	_Start_parallel_for_each_event (PVOID _Accelerator_id, PVOID _Accelerator_view_id, BOOL _Is_tiled_explicitly, ULONGLONG _Num_of_tiles, ULONG _Num_of_threads_per_tile, BOOL _Is_aliased, ULONG _Num_read_only_resources, ULONG _Num_read_write_resources, ULONGLONG _Size_of_all_resouces, ULONG _Size_of_const_data, ULONGLONG _Size_of_data_for_copy)
ULONG	_Start_copy_event (PVOID _Src_accelerator_id, PVOID _Src_accelerator_view_id, PVOID _Dst_accelerator_id, PVOID _Dst_accelerator_view_id, ULONGLONG _Num_bytes_for_copy, BOOL _Is_src_staging, BOOL _Is_dst_staging)
ULONG	_Launch_async_copy_event (PVOID _Src_accelerator_id, PVOID _Src_accelerator_view_id, PVOID _Dst_accelerator_id, PVOID _Dst_accelerator_view_id, ULONGLONG _Num_bytes_for_copy, BOOL _Is_src_staging, BOOL _Is_dst_staging)
_AMPIMP ULONG	_Start_async_op_wait_event (ULONG _Async_op_id)
ULONG	_Start_array_view_synchronize_event (ULONGLONG _Num_bytes_to_synchronize)
ULONG	_Launch_array_view_synchronize_event (ULONGLONG _Num_bytes_to_synchronize)
std::tuple< PVOID, PVOID, BOOL >	_Get_resource_diagnostic_info (const _Buffer_descriptor &_Buff_desc, accelerator_view _Accl_view) const
std::tuple< PVOID, PVOID, BOOL >	_Get_resource_diagnostic_info (const _Texture_descriptor &_Tex_desc) const
ULONG	_Get_unique_identifier ()

Private Attributes
Concurrency::critical_section	_M_critical_section
std::vector< std::tuple< PVOID, LPCWSTR, LPCWSTR > >	_M_accelerator_configs
volatile ULONG	_M_counter
_Trace *	_M_trace_ptr

Static Private Attributes
static const ULONG	_M_event_disabled = 0

Friends
BOOL CALLBACK	_Init_amp_runtime_trace (PINIT_ONCE _Init_once, PVOID _Param, _Inout_ PVOID *_Context)

Constructor & Destructor Documentation

_AMPIMP Concurrency::details::_Amp_runtime_trace::~_Amp_runtime_trace

(

)

Concurrency::details::_Amp_runtime_trace::_Amp_runtime_trace ( PVOID  _Callback_function, _In_ _Trace *  _Trace  )

private

Concurrency::details::_Amp_runtime_trace::_Amp_runtime_trace ( const _Amp_runtime_trace &  )

private

Member Function Documentation

void Concurrency::details::_Amp_runtime_trace::_Add_accelerator_config_event	(	PVOID	_Accelerator_id,
		LPCWSTR	_Device_path,
		LPCWSTR	_Device_description
	)

void Concurrency::details::_Amp_runtime_trace::_Enable_provider

(

bool

_Enable = true

)

std::tuple<PVOID, PVOID, BOOL> Concurrency::details::_Amp_runtime_trace::_Get_resource_diagnostic_info ( const _Buffer_descriptor &  _Buff_desc, accelerator_view  _Accl_view  ) const

private

std::tuple<PVOID, PVOID, BOOL> Concurrency::details::_Amp_runtime_trace::_Get_resource_diagnostic_info ( const _Texture_descriptor &  _Tex_desc ) const

private

ULONG Concurrency::details::_Amp_runtime_trace::_Get_unique_identifier ( )

private

ULONG Concurrency::details::_Amp_runtime_trace::_Launch_array_view_synchronize_event ( ULONGLONG  _Num_bytes_to_synchronize )

private

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Launch_array_view_synchronize_event_helper

(

const _Buffer_descriptor &

_Buff_desc

)

ULONG Concurrency::details::_Amp_runtime_trace::_Launch_async_copy_event ( PVOID  _Src_accelerator_id, PVOID  _Src_accelerator_view_id, PVOID  _Dst_accelerator_id, PVOID  _Dst_accelerator_view_id, ULONGLONG  _Num_bytes_for_copy, BOOL  _Is_src_staging, BOOL  _Is_dst_staging  )

private

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Launch_async_copy_event_helper	(	const _Buffer_descriptor &	_Src,
		const _Buffer_descriptor &	_Dest,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Launch_async_copy_event_helper	(	nullptr_t	,
		const _Buffer_descriptor &	_Dest,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Launch_async_copy_event_helper	(	const _Buffer_descriptor &	_Src,
		nullptr_t	,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Launch_async_copy_event_helper	(	const _Texture_descriptor &	_Src,
		nullptr_t	,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Launch_async_copy_event_helper	(	nullptr_t	,
		const _Texture_descriptor &	_Dest,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Launch_async_copy_event_helper	(	const _Texture_descriptor &	_Src,
		const _Texture_descriptor &	_Dest,
		ULONGLONG	_Num_bytes_for_copy
	)

void Concurrency::details::_Amp_runtime_trace::_Launch_flush_event	(	PVOID	_Accelerator_id,
		PVOID	_Accelerator_view_id
	)

ULONG Concurrency::details::_Amp_runtime_trace::_Launch_marker	(	PVOID	_Accelerator_id,
		PVOID	_Accelerator_view_id
	)

ULONG Concurrency::details::_Amp_runtime_trace::_Start_accelerator_view_wait_event	(	PVOID	_Accelerator_id,
		PVOID	_Accelerator_view_id
	)

ULONG Concurrency::details::_Amp_runtime_trace::_Start_array_view_synchronize_event ( ULONGLONG  _Num_bytes_to_synchronize )

private

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_array_view_synchronize_event_helper

(

const _Buffer_descriptor &

_Buff_desc

)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_async_op_wait_event ( ULONG  _Async_op_id )

private

concurrency::completion_future Concurrency::details::_Amp_runtime_trace::_Start_async_op_wait_event_helper ( ULONG  _Async_op_id, _Event  _Ev  )

inline

    {
        std::shared_future<void> retFuture;
        concurrency::task_completion_event<void> retTaskCompletionEvent;

        // Create a std::shared_future by creating a deferred task through std::async that waits for the
        // event _Ev to finish. Wrap functor with start and end events
        retFuture = std::async(std::launch::deferred, [=]() mutable {
            try
            {
                if (_Async_op_id == _Amp_runtime_trace::_M_event_disabled)
                {
                    _Ev._Get();
                }
                else
                {
                    auto _Span_id = details::_Get_amp_trace()->_Start_async_op_wait_event(_Async_op_id);
                    _Ev._Get();
                    details::_Get_amp_trace()->_Write_end_event(_Span_id);
                }
            }
            catch(...)
            {
                // If an exception is encountered when executing the asynchronous operation
                // we should set the exception on the retTaskCompletionEvent so that it is
                // appropriately canceled and the exception is propagated to continuations
                retTaskCompletionEvent.set_exception(std::current_exception());
                throw;
            }

            retTaskCompletionEvent.set();
        });

        // Register the async event with the runtime asynchronous events manager
        _Register_async_event(_Ev, retFuture);

        // Lets issue a continuation just to swallow any exceptions that are encountered during the
        // async operation and are never observed by the user or are just observed through the
        // shared_future and not through the task
        concurrency::task<void> retTask(retTaskCompletionEvent);
        retTask.then([](concurrency::task<void> _Task) {
            try {
                _Task.get();
            }
            catch(...) {
            }
        });

        return Concurrency::completion_future(retFuture, retTask);
    }

ULONG Concurrency::details::_Amp_runtime_trace::_Start_copy_event ( PVOID  _Src_accelerator_id, PVOID  _Src_accelerator_view_id, PVOID  _Dst_accelerator_id, PVOID  _Dst_accelerator_view_id, ULONGLONG  _Num_bytes_for_copy, BOOL  _Is_src_staging, BOOL  _Is_dst_staging  )

private

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_copy_event_helper	(	const _Buffer_descriptor &	_Src,
		const _Buffer_descriptor &	_Dest,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_copy_event_helper	(	nullptr_t	,
		const _Buffer_descriptor &	_Dest,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_copy_event_helper	(	const _Buffer_descriptor &	_Src,
		nullptr_t	,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_copy_event_helper	(	const _Texture_descriptor &	_Src,
		nullptr_t	,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_copy_event_helper	(	nullptr_t	,
		const _Texture_descriptor &	_Dest,
		ULONGLONG	_Num_bytes_for_copy
	)

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_copy_event_helper	(	const _Texture_descriptor &	_Src,
		const _Texture_descriptor &	_Dest,
		ULONGLONG	_Num_bytes_for_copy
	)

ULONG Concurrency::details::_Amp_runtime_trace::_Start_parallel_for_each_event ( PVOID  _Accelerator_id, PVOID  _Accelerator_view_id, BOOL  _Is_tiled_explicitly, ULONGLONG  _Num_of_tiles, ULONG  _Num_of_threads_per_tile, BOOL  _Is_aliased, ULONG  _Num_read_only_resources, ULONG  _Num_read_write_resources, ULONGLONG  _Size_of_all_resouces, ULONG  _Size_of_const_data, ULONGLONG  _Size_of_data_for_copy  )

private

_AMPIMP ULONG Concurrency::details::_Amp_runtime_trace::_Start_parallel_for_each_event_helper

(

_In_ _DPC_call_handle *

_Handle

)

void Concurrency::details::_Amp_runtime_trace::_Write_accelerator_config_event ( const std::tuple< PVOID, LPCWSTR, LPCWSTR > &  _ConfigTuple )

private

void Concurrency::details::_Amp_runtime_trace::_Write_all_accelerator_config_events

(

)

_AMPIMP void Concurrency::details::_Amp_runtime_trace::_Write_end_event

(

ULONG

_Span_id

)

_Amp_runtime_trace& Concurrency::details::_Amp_runtime_trace::operator= ( const _Amp_runtime_trace &  )

private

Friends And Related Function Documentation

BOOL CALLBACK _Init_amp_runtime_trace ( PINIT_ONCE  _Init_once, PVOID  _Param, _Inout_ PVOID *  _Context  )

friend

Member Data Documentation

std::vector<std::tuple<PVOID, LPCWSTR, LPCWSTR> > Concurrency::details::_Amp_runtime_trace::_M_accelerator_configs

private

volatile ULONG Concurrency::details::_Amp_runtime_trace::_M_counter

private

Concurrency::critical_section Concurrency::details::_Amp_runtime_trace::_M_critical_section

private

const ULONG Concurrency::details::_Amp_runtime_trace::_M_event_disabled = 0

staticprivate

_Trace* Concurrency::details::_Amp_runtime_trace::_M_trace_ptr

private

---

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

• VS2017/inc/amprt.h