From 7c65a929d024db05d08108c50348331d98132405 Mon Sep 17 00:00:00 2001
From: cvictory <shenglicao2@gmail.com>
Date: Sun, 31 Jan 2021 19:18:18 +0800
Subject: [PATCH] add some log
---
remoting/getty/getty_client.go | 1 +
remoting/getty/listener.go | 2 ++
2 files changed, 3 insertions(+)
diff --git a/remoting/getty/getty_client.go b/remoting/getty/getty_client.go
index 1d04d39ee..338478c60 100644
--- a/remoting/getty/getty_client.go
+++ b/remoting/getty/getty_client.go
@@ -182,6 +182,7 @@ func (c *Client) Request(request *remoting.Request, timeout time.Duration, respo
)
if totalLen, sendLen, err = c.transfer(session, request, timeout); err != nil {
if sendLen != 0 && totalLen != sendLen {
+ logger.Warnf("start to close the session at request because %d of %d bytes data is sent success. err:%+v", sendLen, totalLen, err)
go c.Close()
}
return perrors.WithStack(err)
diff --git a/remoting/getty/listener.go b/remoting/getty/listener.go
index ac1b6749d..5443d3710 100644
--- a/remoting/getty/listener.go
+++ b/remoting/getty/listener.go
@@ -357,6 +357,7 @@ func (h *RpcServerHandler) OnCron(session getty.Session) {
func reply(session getty.Session, resp *remoting.Response) {
if totalLen, sendLen, err := session.WritePkg(resp, WritePkg_Timeout); err != nil {
if sendLen != 0 && totalLen != sendLen {
+ logger.Warnf("start to close the session at replying because %d of %d bytes data is sent success. err:%+v", sendLen, totalLen, err)
go session.Close()
}
logger.Errorf("WritePkg error: %#v, %#v", perrors.WithStack(err), resp)
@@ -371,6 +372,7 @@ func heartbeat(session getty.Session, timeout time.Duration, callBack func(err e
remoting.AddPendingResponse(resp)
totalLen, sendLen, err := session.WritePkg(req, 3*time.Second)
if sendLen != 0 && totalLen != sendLen {
+ logger.Warnf("start to close the session at heartbeat because %d of %d bytes data is sent success. err:%+v", sendLen, totalLen, err)
go session.Close()
}
--
GitLab