Skip to content

Commit

Permalink
Cleanup logging
Browse files Browse the repository at this point in the history
  • Loading branch information
dagardner-nv committed Sep 29, 2023
1 parent d3f5a21 commit 9565284
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion cpp/mrc/include/mrc/segment/runnable.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ class Runnable : public Object<NodeT>, public runnable::Launchable

void destroy() final
{
LOG(INFO) << "Destroying runnable " << this->type_name();
DVLOG(10) << "Destroying runnable " << this->type_name();
m_node.reset();
}

Expand Down
10 changes: 5 additions & 5 deletions cpp/mrc/src/internal/pipeline/pipeline_instance.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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<segment::SegmentInstance>(definition, rank, *this, partition_id);

for (const auto& name : definition->egress_port_names())
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -205,12 +205,12 @@ void PipelineInstance::do_service_stop()
void PipelineInstance::do_service_kill()
{
std::lock_guard<decltype(m_kill_mux)> 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();
}

Expand Down
2 changes: 1 addition & 1 deletion cpp/mrc/src/internal/segment/segment_instance.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -335,7 +335,7 @@ void SegmentInstance::shutdown()
{
// TODO: Merge with service_stop
std::lock_guard<decltype(m_mutex)> lock(m_mutex);
LOG(INFO) << m_name << " - " << info() << " - shutting down segment";
DVLOG(10) << m_name << " - " << info() << " - shutting down segment";
m_builder->shutdown();
}

Expand Down

0 comments on commit 9565284

Please sign in to comment.