Agent Implementation (#78)

* Agent Implementation

* Remove unused Findrocprofiler

* Update lib/rocprofiler/hsa/agent.{hpp,cpp}

- default AgentInfo ctor
- getNumaNode() const
- noexcept move ctors
- default initializers for member variables
- fixed clang-tidy recommentations
  - preallocate
  - static in anon namespace
- AgentInfo::setName uses strncpy and ensures that it is terminated

* Update lib/rocprofiler/rocprofiler.cpp (agent.cpp and pc_sampling.cpp)

- move public PC sampling function implementations to pc_sampling.cpp
- move public agent function implementation to agent.cpp

[ROCm/rocprofiler-sdk commit: 6fb9000fa1]
Tento commit je obsažen v:
Jonathan R. Madsen
2023-09-22 13:51:21 -05:00
odevzdal GitHub
rodič ba4c3a123e
revize d98973ffb5
13 změnil soubory, kde provedl 858 přidání a 173 odebrání
+1 -66
Zobrazit soubor
@@ -26,6 +26,7 @@
#include "lib/common/utility.hpp"
#include "lib/rocprofiler/context/context.hpp"
#include "lib/rocprofiler/context/domain.hpp"
#include "lib/rocprofiler/hsa/agent.hpp"
#include "lib/rocprofiler/hsa/hsa.hpp"
#include "lib/rocprofiler/registration.hpp"
@@ -56,70 +57,4 @@ rocprofiler_get_timestamp(rocprofiler_timestamp_t* ts)
*ts = rocprofiler::common::timestamp_ns();
return ROCPROFILER_STATUS_SUCCESS;
}
rocprofiler_status_t
rocprofiler_query_available_agents(rocprofiler_available_agents_cb_t callback,
size_t agent_size,
void* user_data)
{
using pc_sampling_config_vec_t = std::vector<rocprofiler_pc_sampling_configuration_t>;
static const auto _default_pc_config =
rocprofiler_pc_sampling_configuration_t{ROCPROFILER_PC_SAMPLING_METHOD_HOST_TRAP,
ROCPROFILER_PC_SAMPLING_UNIT_TIME,
1UL,
1000000000UL,
0};
static const auto _dummy_pc_configs = pc_sampling_config_vec_t{_default_pc_config};
static auto _default_cpu_agent = rocprofiler_agent_t{rocprofiler_agent_id_t{0},
ROCPROFILER_AGENT_TYPE_CPU,
"cpu",
rocprofiler_pc_sampling_config_array_t{}};
static auto _default_gpu_agent = rocprofiler_agent_t{rocprofiler_agent_id_t{1},
ROCPROFILER_AGENT_TYPE_GPU,
"gpu",
rocprofiler_pc_sampling_config_array_t{}};
// get the agents
auto _agents = std::vector<rocprofiler_agent_t*>{&_default_cpu_agent, &_default_gpu_agent};
auto _pc_sampling_config = std::vector<pc_sampling_config_vec_t>{};
for(auto* itr : _agents)
{
auto& _data = _pc_sampling_config.emplace_back();
if(itr->type == ROCPROFILER_AGENT_TYPE_GPU) _data = {_default_pc_config};
itr->pc_sampling_configs =
rocprofiler_pc_sampling_config_array_t{_data.data(), _data.size()};
}
assert(agent_size <= sizeof(rocprofiler_agent_t) &&
"rocprofiler_agent_t used by caller is ABI-incompatible with rocprofiler_agent_t in "
"rocprofiler");
return callback(_agents.data(), _agents.size(), user_data);
}
rocprofiler_status_t
rocprofiler_configure_pc_sampling_service(rocprofiler_context_id_t context_id,
rocprofiler_agent_t agent,
rocprofiler_pc_sampling_method_t method,
rocprofiler_pc_sampling_unit_t unit,
uint64_t interval,
rocprofiler_buffer_id_t buffer_id)
{
if(rocprofiler::registration::get_init_status() > 0)
return ROCPROFILER_STATUS_ERROR_CONFIGURATION_LOCKED;
consume_args(context_id, agent, method, unit, interval, buffer_id);
return ROCPROFILER_STATUS_ERROR_NOT_IMPLEMENTED;
}
rocprofiler_status_t
rocprofiler_query_pc_sampling_agent_configurations(rocprofiler_agent_t agent,
rocprofiler_pc_sampling_configuration_t* config,
size_t* config_count)
{
consume_args(agent, config, config_count);
return ROCPROFILER_STATUS_ERROR_NOT_IMPLEMENTED;
}
}