From 0117d5f8ff386075b0c4cbec0cbe460fe3cfa680 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期四, 06 五月 2021 18:57:25 +0800
Subject: [PATCH] add logging, use boost.log.
---
src/topic_node.cpp | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/src/topic_node.cpp b/src/topic_node.cpp
index f629597..c31cfc3 100644
--- a/src/topic_node.cpp
+++ b/src/topic_node.cpp
@@ -44,7 +44,7 @@
TopicNode::~TopicNode()
{
- printf("~TopicNode()\n");
+ LOG_DEBUG() << "~TopicNode()";
Stop();
}
@@ -59,7 +59,7 @@
if (ssn_id_ == 0) {
ssn_id_ = ShmMsgQueue::NewId();
}
- printf("Node Init, id %ld \n", ssn_id_);
+ LOG_DEBUG() << "Node Init, id " << ssn_id_;
MsgI msg;
msg.OffsetRef() = ssn_id_;
if (ShmMsgQueue::TrySend(shm(), BHInitAddress(), msg)) {
@@ -95,9 +95,9 @@
}
void TopicNode::Stop()
{
- printf("Node Stopping\n");
+ LOG_DEBUG() << "Node Stopping";
for (auto &p : sockets_) { p->Stop(); }
- printf("Node Stopped\n");
+ LOG_INFO() << "Node Stopped";
}
bool TopicNode::Register(ProcInfo &proc, MsgCommonReply &reply_body, const int timeout_ms)
@@ -423,7 +423,7 @@
BHAddress addr;
if (ClientQueryRPCTopic(request.topic(), addr, timeout_ms)) {
- // printf("node: %ld, topic dest: %ld\n", SockNode().id(), addr.mq_id());
+ LOG_TRACE() << "node: " << SockNode().id() << ", topic dest: " << addr.mq_id();
BHMsgHead head(InitMsgHead(GetType(request), proc_id(), ssn()));
AddRoute(head, sock.id());
head.set_topic(request.topic());
--
Gitblit v1.8.0