(rocketmq-client-go) branch master updated: fix: ignore name server connection read timeout log (#1117)

[dinglei]

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

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new 5af5d6d  fix: ignore name server connection read timeout log (#1117)
5af5d6d is described below

commit 5af5d6d7cae3305729d8290324aab0617752e685
Author: WeizhongTu <weizhong....@alibaba-inc.com>
AuthorDate: Wed Dec 6 17:59:31 2023 +0800

    fix: ignore name server connection read timeout log (#1117)
    
    * fix: ignore conn read timeout
    
    * fix: ignore conn read timeout
    
    * fix: ignore conn read timeout
---
 internal/remote/remote_client.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/internal/remote/remote_client.go b/internal/remote/remote_client.go
index d433b8d..76db1a1 100644
--- a/internal/remote/remote_client.go
+++ b/internal/remote/remote_client.go
@@ -179,7 +179,12 @@ func (c *remotingClient) receiveResponse(r 
*tcpConnWrapper) {
                        if r.isClosed(err) {
                                return
                        }
-                       if err != io.EOF {
+                       // ignore name server connection read timeout
+                       if netErr, ok := err.(net.Error); ok && 
netErr.Timeout() {
+                               rlog.Debug("conn error, close connection", 
map[string]interface{}{
+                                       rlog.LogKeyUnderlayError: err,
+                               })
+                       } else if err != io.EOF {
                                rlog.Error("conn error, close connection", 
map[string]interface{}{
                                        rlog.LogKeyUnderlayError: err,
                                })