Giovanni Lenzi Baraldi
9676295d3d
* DRM Issue Fix for SLES 15 (#897) * DRM Issue Fix * Formatting Fix * PC sampling: CID manager unit test (#898) * Adding per-dispatch userdata field to ATT * Clang tidy * Formatting * Update source/lib/rocprofiler-sdk/hsa/aql_packet.hpp Co-authored-by: Vladimir Indic <139573562+vlaindic@users.noreply.github.com> * Adding dispatch_id, fixing user_data and update aql_profile_v2 * Formatting * Tidy fixes * Second fix for userdata * removing assert for union * Adding serialization. Created agent profiling-like thread trace * Implemented agent thread trace * Update source/lib/rocprofiler-sdk/hsa/aql_packet.hpp Co-authored-by: Vladimir Indic <139573562+vlaindic@users.noreply.github.com> * Restructured thread trace packets * Added agent API tests * Fixing multigpu for agent test * Formatting * Formatting * Improving header locations * Fixing merge conflicts * Tidy * Tidy * Tidy --------- Co-authored-by: Ammar ELWazir <ammar.elwazir@amd.com> Co-authored-by: Vladimir Indic <139573562+vlaindic@users.noreply.github.com>
103 خطوط
4.1 KiB
C++
103 خطوط
4.1 KiB
C++
#pragma once
|
|
#include <rocprofiler-sdk/fwd.h>
|
|
#include <rocprofiler-sdk/rocprofiler.h>
|
|
|
|
#include <atomic>
|
|
#include <cassert>
|
|
#include <cstdint>
|
|
#include <cstdlib>
|
|
#include <map>
|
|
#include <mutex>
|
|
#include <set>
|
|
#include <string>
|
|
#include <unordered_map>
|
|
|
|
#define ROCPROFILER_VAR_NAME_COMBINE(X, Y) X##Y
|
|
#define ROCPROFILER_VARIABLE(X, Y) ROCPROFILER_VAR_NAME_COMBINE(X, Y)
|
|
|
|
#define ROCPROFILER_CALL(result, msg) \
|
|
{ \
|
|
rocprofiler_status_t ROCPROFILER_VARIABLE(CHECKSTATUS, __LINE__) = result; \
|
|
if(ROCPROFILER_VARIABLE(CHECKSTATUS, __LINE__) != ROCPROFILER_STATUS_SUCCESS) \
|
|
{ \
|
|
std::string status_msg = \
|
|
rocprofiler_get_status_string(ROCPROFILER_VARIABLE(CHECKSTATUS, __LINE__)); \
|
|
std::cerr << "[" #result "][" << __FILE__ << ":" << __LINE__ << "] " << msg \
|
|
<< " failed with error code " << ROCPROFILER_VARIABLE(CHECKSTATUS, __LINE__) \
|
|
<< ": " << status_msg << std::endl; \
|
|
std::stringstream errmsg{}; \
|
|
errmsg << "[" #result "][" << __FILE__ << ":" << __LINE__ << "] " << msg " failure (" \
|
|
<< status_msg << ")"; \
|
|
throw std::runtime_error(errmsg.str()); \
|
|
} \
|
|
}
|
|
|
|
#define C_API_BEGIN \
|
|
try \
|
|
{
|
|
#define C_API_END \
|
|
} \
|
|
catch(std::exception & e) \
|
|
{ \
|
|
std::cerr << "Error in " << __FILE__ << ':' << __LINE__ << ' ' << e.what() << std::endl; \
|
|
} \
|
|
catch(...) { std::cerr << "Error in " << __FILE__ << ':' << __LINE__ << std::endl; }
|
|
|
|
namespace ATTTest
|
|
{
|
|
struct TrackedIsa
|
|
{
|
|
std::atomic<size_t> hitcount{0};
|
|
std::atomic<size_t> latency{0};
|
|
std::string inst{};
|
|
};
|
|
|
|
struct pcInfo
|
|
{
|
|
size_t addr;
|
|
size_t marker_id;
|
|
|
|
bool operator==(const pcInfo& other) const
|
|
{
|
|
return addr == other.addr && marker_id == other.marker_id;
|
|
}
|
|
bool operator<(const pcInfo& other) const
|
|
{
|
|
if(marker_id == other.marker_id) return addr < other.addr;
|
|
return marker_id < other.marker_id;
|
|
}
|
|
};
|
|
|
|
struct ToolData
|
|
{
|
|
std::unordered_map<uint64_t, std::string> kernel_id_to_kernel_name = {};
|
|
std::map<pcInfo, std::unique_ptr<TrackedIsa>> isa_map;
|
|
|
|
std::atomic<int> waves_started = 0;
|
|
std::atomic<int> waves_ended = 0;
|
|
std::mutex isa_map_mut;
|
|
std::set<pcInfo> wave_start_locations{};
|
|
};
|
|
|
|
namespace Callbacks
|
|
{
|
|
void
|
|
tool_codeobj_tracing_callback(rocprofiler_callback_tracing_record_t record,
|
|
rocprofiler_user_data_t*,
|
|
void* callback_data);
|
|
|
|
void
|
|
shader_data_callback(int64_t se_id,
|
|
void* se_data,
|
|
size_t data_size,
|
|
rocprofiler_user_data_t userdata);
|
|
|
|
void
|
|
callbacks_init();
|
|
|
|
void
|
|
callbacks_fini();
|
|
|
|
}; // namespace Callbacks
|
|
|
|
}; // namespace ATTTest
|