You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2021/10/30 15:42:46 UTC
[pulsar] 02/06: [C++] Fixed connection read error logging (#12492)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit c36b9d0337bf956eff0e2da068cfbdb3f5a273bb
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Mon Oct 25 21:15:57 2021 -0700
[C++] Fixed connection read error logging (#12492)
---
pulsar-client-cpp/lib/ClientConnection.cc | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/pulsar-client-cpp/lib/ClientConnection.cc b/pulsar-client-cpp/lib/ClientConnection.cc
index 6e6f2a3..6e5245e 100644
--- a/pulsar-client-cpp/lib/ClientConnection.cc
+++ b/pulsar-client-cpp/lib/ClientConnection.cc
@@ -584,9 +584,9 @@ void ClientConnection::handleRead(const boost::system::error_code& err, size_t b
if (err || bytesTransferred == 0) {
if (err) {
if (err == boost::asio::error::operation_aborted) {
- LOG_DEBUG(cnxString_ << "Read failed: " << err.message());
+ LOG_DEBUG(cnxString_ << "Read operation was canceled: " << err.message());
} else {
- LOG_ERROR(cnxString_ << "Read operation was cancelled");
+ LOG_ERROR(cnxString_ << "Read operation failed: " << err.message());
}
} // else: bytesTransferred == 0, which means server has closed the connection
close();