[rocpd] CSV python writer

source/lib/python/rocpd/libpyrocpd.cpp

@@ -23,7 +23,6 @@
 #include "libpyrocpd.hpp"
 #include "lib/output/format_path.hpp"
 #include "lib/python/rocpd/source/common.hpp"
-#include "lib/python/rocpd/source/csv.hpp"
 #include "lib/python/rocpd/source/functions.hpp"
 #include "lib/python/rocpd/source/interop.hpp"
 #include "lib/python/rocpd/source/otf2.hpp"
@@ -505,112 +504,6 @@ PYBIND11_MODULE(libpyrocpd, pyrocpd)
         },
         "Write pftrace output file from rocpd SQLite3 database");
 
-    pyrocpd.def(
-        "write_csv",
-        [](rocpd::RocpdImportData& data, const rocprofiler::tool::output_config& output_cfg) {
-            auto sqlgen_csv = common::simple_timer{
-                fmt::format("CSV generation from {} SQL database(s)", data.size())};
-
-            if(data.empty()) return;
-
-            auto csv_manager = rocpd::output::CsvManager{output_cfg};
-
-            for(auto obj : {data.connection})
-            {
-                auto* conn  = rocpd::interop::get_connection(std::move(obj));
-                auto  nodes = rocpd::read<rocpd::types::node>(conn);
-
-                for(const auto& nitr : nodes)
-                {
-                    auto agents = rocpd::read<rocpd::types::agent>(
-                        conn, fmt::format("WHERE guid = '{}' AND nid = {}", nitr.guid, nitr.id));
-                    auto processes = rocpd::read<rocpd::types::process>(
-                        conn, fmt::format("WHERE guid = '{}' AND nid = {}", nitr.guid, nitr.id));
-
-                    for(const auto& pitr : processes)
-                    {
-                        ROCP_FATAL_IF(pitr.nid != nitr.id || pitr.guid != nitr.guid)
-                            << fmt::format("Found process with a mismatched nid/guid. process: "
-                                           "{}/{} vs. node: {}/{}",
-                                           pitr.nid,
-                                           pitr.guid,
-                                           nitr.id,
-                                           nitr.guid);
-                        auto _sqlgen_csv = common::simple_timer{fmt::format(
-                            "CSV generation from SQL for process {} (total)", pitr.pid)};
-
-                        auto select_guid_nid_pid = [&nitr, &pitr](std::string_view tbl,
-                                                                  std::string_view
-                                                                      where_extra_condition = {}) {
-                            return fmt::format(
-                                "SELECT * FROM {} WHERE guid = '{}' AND nid = {} AND pid = {} {}",
-                                tbl,
-                                pitr.guid,
-                                nitr.id,
-                                pitr.pid,
-                                where_extra_condition);
-                        };
-
-                        rocpd::output::write_agent_info_csv(csv_manager, agents);
-
-                        constexpr auto region_order_by = "start ASC, end DESC";
-
-                        auto kernels = rocpd::sql_generator<rocpd::types::kernel_dispatch>{
-                            conn, select_guid_nid_pid("kernels"), region_order_by};
-                        auto memory_copies = rocpd::sql_generator<rocpd::types::memory_copies>{
-                            conn, select_guid_nid_pid("memory_copies"), region_order_by};
-                        auto memory_allocations =
-                            rocpd::sql_generator<rocpd::types::memory_allocation>{
-                                conn, select_guid_nid_pid("memory_allocations"), region_order_by};
-                        auto hip_api_calls = rocpd::sql_generator<rocpd::types::region>{
-                            conn,
-                            select_guid_nid_pid("regions", "AND category LIKE 'HIP_%'"),
-                            region_order_by};
-                        auto hsa_api_calls = rocpd::sql_generator<rocpd::types::region>{
-                            conn,
-                            select_guid_nid_pid("regions", "AND category LIKE 'HSA_%'"),
-                            region_order_by};
-                        auto marker_api_calls = rocpd::sql_generator<rocpd::types::region>{
-                            conn,
-                            select_guid_nid_pid("regions_and_samples",
-                                                "AND category LIKE 'MARKER_%'"),
-                            region_order_by};
-                        auto counters_calls = rocpd::sql_generator<rocpd::types::counter>{
-                            conn, select_guid_nid_pid("counters_collection"), region_order_by};
-                        auto scratch_memory_calls =
-                            rocpd::sql_generator<rocpd::types::scratch_memory>{
-                                conn, select_guid_nid_pid("scratch_memory"), region_order_by};
-                        auto rccl_calls = rocpd::sql_generator<rocpd::types::region>{
-                            conn,
-                            select_guid_nid_pid("regions", "AND category LIKE 'RCCL_%'"),
-                            region_order_by};
-                        auto rocdecode_calls = rocpd::sql_generator<rocpd::types::region>{
-                            conn,
-                            select_guid_nid_pid("regions", "AND category LIKE 'ROCDECODE_%'"),
-                            region_order_by};
-                        auto rocjpeg_calls = rocpd::sql_generator<rocpd::types::region>{
-                            conn,
-                            select_guid_nid_pid("regions", "AND category LIKE 'ROCJPEG_%'"),
-                            region_order_by};
-
-                        rocpd::output::write_csvs(csv_manager,
-                                                  kernels,
-                                                  memory_copies,
-                                                  memory_allocations,
-                                                  hip_api_calls,
-                                                  hsa_api_calls,
-                                                  marker_api_calls,
-                                                  counters_calls,
-                                                  scratch_memory_calls,
-                                                  rccl_calls,
-                                                  rocdecode_calls,
-                                                  rocjpeg_calls);
-                    }
-                }
-            }
-        },
-        "Write trace data to CSV files");
-
     pyrocpd.def(
         "write_otf2",
         [](rocpd::RocpdImportData& data, const tool::output_config& output_cfg) {

source/lib/python/rocpd/source/CMakeLists.txt

@@ -2,19 +2,10 @@
 # libpyrocpd python binding sources
 #
 
-set(libpyrocpd_source_headers
-    common.hpp
-    functions.hpp
-    interop.hpp
-    perfetto.hpp
-    csv.hpp
-    otf2.hpp
-    sql_generator.hpp
-    pysqlite_Connection.h
-    types.hpp)
+set(libpyrocpd_source_headers common.hpp functions.hpp interop.hpp perfetto.hpp otf2.hpp
+                              sql_generator.hpp pysqlite_Connection.h types.hpp)
 
-set(libpyrocpd_source_sources csv.cpp functions.cpp interop.cpp otf2.cpp perfetto.cpp
-                              types.cpp)
+set(libpyrocpd_source_sources functions.cpp interop.cpp otf2.cpp perfetto.cpp types.cpp)
 
 foreach(_PYTHON_VERSION ${ROCPROFILER_PYTHON_VERSIONS})
     rocprofiler_rocpd_python_bindings_target_sources(