From 0b83f0f18b80afe0ea5d9af6a7cbcf7ea5876bee Mon Sep 17 00:00:00 2001 From: chendongsheng Date: Fri, 5 Mar 2021 09:32:51 +0800 Subject: [PATCH] Modify log level --- mindspore/ccsrc/ps/core/abstract_node.cc | 10 +++++----- mindspore/ccsrc/ps/core/tcp_client.cc | 4 ++-- mindspore/ccsrc/ps/core/tcp_server.cc | 4 ++-- 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/mindspore/ccsrc/ps/core/abstract_node.cc b/mindspore/ccsrc/ps/core/abstract_node.cc index 39e177f2f2..4e464f5387 100644 --- a/mindspore/ccsrc/ps/core/abstract_node.cc +++ b/mindspore/ccsrc/ps/core/abstract_node.cc @@ -279,11 +279,11 @@ void AbstractNode::StartHeartbeatTimer(const std::shared_ptr &client) heart_beat_thread_ = std::make_unique([&]() { while (!is_finish_.load()) { if (!Heartbeat(client)) { - MS_LOG(ERROR) << "The node role is:" << CommUtil::NodeRoleToString(node_info_.node_role_) - << ", the node id is:" << node_info_.node_id_ << " Send heartbeat timeout!"; + MS_LOG(WARNING) << "The node role is:" << CommUtil::NodeRoleToString(node_info_.node_role_) + << ", the node id is:" << node_info_.node_id_ << " Send heartbeat timeout!"; if (!CheckSchedulerTimeout() && on_node_event_message_) { - MS_LOG(ERROR) << "The node role is:" << CommUtil::NodeRoleToString(node_info_.node_role_) - << ", the node id is:" << node_info_.node_id_ << " exited due to scheduler timeout!"; + MS_LOG(WARNING) << "The node role is:" << CommUtil::NodeRoleToString(node_info_.node_role_) + << ", the node id is:" << node_info_.node_id_ << " exited due to scheduler timeout!"; is_finish_ = true; wait_finish_cond_.notify_all(); on_node_event_message_(NodeEvent::SCHEDULER_TIMEOUT); @@ -306,7 +306,7 @@ bool AbstractNode::Heartbeat(const std::shared_ptr &client, bool is_n if (!SendMessageSync(client, meta, Protos::PROTOBUF, heartbeat_message.SerializeAsString().data(), heartbeat_message.ByteSizeLong())) { - MS_LOG(ERROR) << "The node id:" << node_info_.node_id_ << " Send heartbeat timeout!"; + MS_LOG(WARNING) << "The node id:" << node_info_.node_id_ << " Send heartbeat timeout!"; } return true; } diff --git a/mindspore/ccsrc/ps/core/tcp_client.cc b/mindspore/ccsrc/ps/core/tcp_client.cc index 5fb559347b..eec706b746 100644 --- a/mindspore/ccsrc/ps/core/tcp_client.cc +++ b/mindspore/ccsrc/ps/core/tcp_client.cc @@ -220,12 +220,12 @@ void TcpClient::EventCallback(struct bufferevent *bev, std::int16_t events, void SetTcpNoDelay(fd); MS_LOG(INFO) << "Client connected!"; } else if (events & BEV_EVENT_ERROR) { - MS_LOG(ERROR) << "Client connected error!"; + MS_LOG(WARNING) << "Client connected BEV_EVENT_ERROR!"; if (tcp_client->disconnected_callback_) { tcp_client->disconnected_callback_(); } } else if (events & BEV_EVENT_EOF) { - MS_LOG(ERROR) << "Client connected end of file"; + MS_LOG(WARNING) << "Client connected end of file"; } } diff --git a/mindspore/ccsrc/ps/core/tcp_server.cc b/mindspore/ccsrc/ps/core/tcp_server.cc index f16c2c5bec..aab6ee1b3b 100644 --- a/mindspore/ccsrc/ps/core/tcp_server.cc +++ b/mindspore/ccsrc/ps/core/tcp_server.cc @@ -375,7 +375,7 @@ void TcpServer::EventCallback(struct bufferevent *bev, std::int16_t events, void srv->RemoveConnection(conn->GetFd()); bufferevent_free(bev); } else if (events & BEV_EVENT_ERROR) { - MS_LOG(ERROR) << "Event buffer remain data: " << remain; + MS_LOG(WARNING) << "Event buffer remain data: " << remain; // Free connection structures srv->RemoveConnection(conn->GetFd()); bufferevent_free(bev); @@ -385,7 +385,7 @@ void TcpServer::EventCallback(struct bufferevent *bev, std::int16_t events, void srv->client_disconnection_(*srv, *conn); } } else { - MS_LOG(ERROR) << "Unhandled event!"; + MS_LOG(WARNING) << "Unhandled event!"; } }