From 66c4770b07cd3b980783edbdae00e7bf7bd0e6f8 Mon Sep 17 00:00:00 2001 From: crusader Date: Thu, 23 Nov 2017 17:14:35 +0900 Subject: [PATCH] ing --- client/client.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/client/client.go b/client/client.go index 95bcb40..fede17a 100644 --- a/client/client.go +++ b/client/client.go @@ -10,6 +10,7 @@ import ( "sync/atomic" "time" + "git.loafle.net/commons_go/logging" "git.loafle.net/commons_go/rpc/protocol" ) @@ -262,7 +263,8 @@ func (c *client) rpcWriter(stopChan <-chan struct{}, writerDone chan<- error) { if n > 10*c.ch.GetPendingRequests() { err = fmt.Errorf("Client: The server didn't return %d responses yet. Closing server connection in order to prevent client resource leaks", n) - return + logging.Logger().Error(err.Error()) + continue } } @@ -273,7 +275,8 @@ func (c *client) rpcWriter(stopChan <-chan struct{}, writerDone chan<- error) { } if nil != err { err = fmt.Errorf("Client: Cannot send request to wire: [%s]", err) - return + logging.Logger().Error(err.Error()) + continue } } }