[inlong] branch master updated: [INLONG-9044][SDK] Add server response log to facilitate troubleshooting (#9045)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new f197546785 [INLONG-9044][SDK] Add server response log to facilitate 
troubleshooting (#9045)
f197546785 is described below

commit f19754678588a7e86cfecc2d45586290e5f3cb2b
Author: doleyzi <43397300+dole...@users.noreply.github.com>
AuthorDate: Thu Oct 12 14:15:13 2023 +0800

    [INLONG-9044][SDK] Add server response log to facilitate troubleshooting 
(#9045)
---
 .../dataproxy-sdk-twins/dataproxy-sdk-cpp/src/client/tcp_client.cc  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/client/tcp_client.cc 
b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/client/tcp_client.cc
index 6231f08518..8a2a583b3b 100644
--- a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/client/tcp_client.cc
+++ b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/client/tcp_client.cc
@@ -167,15 +167,15 @@ void TcpClient::OnWroten(const asio::error_code error,
       // operation aborted
       return;
     }
-    LOG_ERROR("write error:" << error.message() << CLIENT_INFO);
     status_ = kWriting;
+    LOG_ERROR("write error:" << error.message() << CLIENT_INFO);
     HandleFail();
     return;
   }
 
   if (0 == bytes_transferred) {
-    LOG_ERROR("transferred 0 bytes." << CLIENT_INFO);
     status_ = kWaiting;
+    LOG_ERROR("transferred 0 bytes." << CLIENT_INFO);
     HandleFail();
     return;
   }
@@ -201,6 +201,7 @@ void TcpClient::OnReturn(asio::error_code error, 
std::size_t len) {
   }
   if (len != sizeof(uint32_t)) {
     status_ = kWaiting;
+    LOG_ERROR("len :" << len <<" != sizeof(uint32_t):" <<sizeof(uint32_t)<< 
CLIENT_INFO);
     HandleFail();
     return;
   }
@@ -209,6 +210,7 @@ void TcpClient::OnReturn(asio::error_code error, 
std::size_t len) {
 
   if (resp_len > recv_buf_->m_max_size) {
     status_ = kWaiting;
+    LOG_ERROR("invalid resp_len :" << resp_len << CLIENT_INFO);
     HandleFail();
     return;
   }