diff --git a/cpp/mrc/include/mrc/segment/runnable.hpp b/cpp/mrc/include/mrc/segment/runnable.hpp index 4d380e622..f456f1fdd 100644 --- a/cpp/mrc/include/mrc/segment/runnable.hpp +++ b/cpp/mrc/include/mrc/segment/runnable.hpp @@ -48,7 +48,7 @@ class Runnable : public Object, public runnable::Launchable void destroy() final { - LOG(INFO) << "Destroying runnable " << this->type_name(); + DVLOG(10) << "Destroying runnable " << this->type_name(); m_node.reset(); } diff --git a/cpp/mrc/src/internal/pipeline/pipeline_instance.cpp b/cpp/mrc/src/internal/pipeline/pipeline_instance.cpp index eb8ed78b8..b427af232 100644 --- a/cpp/mrc/src/internal/pipeline/pipeline_instance.cpp +++ b/cpp/mrc/src/internal/pipeline/pipeline_instance.cpp @@ -112,7 +112,7 @@ void PipelineInstance::create_segment(const SegmentAddress& address, std::uint32 // perform our allocations on the numa domain of the intended target // CHECK_LT(partition_id, m_resources->host_resources().size()); CHECK_LT(partition_id, resources().partition_count()); - LOG(INFO) << "Enqueing Creation of segment " << ::mrc::segment::info(address); + DVLOG(10) << "Enqueing Creation of segment " << ::mrc::segment::info(address); resources() .partition(partition_id) .runnable() @@ -123,7 +123,7 @@ void PipelineInstance::create_segment(const SegmentAddress& address, std::uint32 auto [id, rank] = segment_address_decode(address); auto definition = m_definition->find_segment(id); - LOG(INFO) << "Creating segment " << definition->name() << " - " << ::mrc::segment::info(address); + DVLOG(10) << "Creating segment " << definition->name() << " - " << ::mrc::segment::info(address); auto segment = std::make_unique(definition, rank, *this, partition_id); for (const auto& name : definition->egress_port_names()) @@ -152,7 +152,7 @@ void PipelineInstance::create_segment(const SegmentAddress& address, std::uint32 segment->attach_manifold(manifold); } - LOG(INFO) << "Created segment " << definition->name() << " - " << ::mrc::segment::info(address); + DVLOG(10) << "Created segment " << definition->name() << " - " << ::mrc::segment::info(address); m_segments[address] = std::move(segment); }) .get(); @@ -205,12 +205,12 @@ void PipelineInstance::do_service_stop() void PipelineInstance::do_service_kill() { std::lock_guard guard(m_kill_mux); - LOG(INFO) << "pipeline::PipelineInstance - killing " << m_manifolds.size() << " manifolds - " << m_segments.size() + DVLOG(10) << "pipeline::PipelineInstance - killing " << m_manifolds.size() << " manifolds - " << m_segments.size() << " segments"; mark_joinable(); for (const auto& [name, manifold] : m_manifolds) { - LOG(INFO) << "pipeline::PipelineInstance - killing manifold " << name; + DVLOG(10) << "pipeline::PipelineInstance - killing manifold " << name; manifold->shutdown(); } diff --git a/cpp/mrc/src/internal/segment/segment_instance.cpp b/cpp/mrc/src/internal/segment/segment_instance.cpp index a62d90ccc..4f0639666 100644 --- a/cpp/mrc/src/internal/segment/segment_instance.cpp +++ b/cpp/mrc/src/internal/segment/segment_instance.cpp @@ -335,7 +335,7 @@ void SegmentInstance::shutdown() { // TODO: Merge with service_stop std::lock_guard lock(m_mutex); - LOG(INFO) << m_name << " - " << info() << " - shutting down segment"; + DVLOG(10) << m_name << " - " << info() << " - shutting down segment"; m_builder->shutdown(); }