[dubbo-go] branch feature/dubbo_invoker_reqnum updated: add dubbo/grpc closed log

[al...@apache.org]

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

alexstocks pushed a commit to branch feature/dubbo_invoker_reqnum
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git


The following commit(s) were added to refs/heads/feature/dubbo_invoker_reqnum by this push:
     new ed2fa8d  add dubbo/grpc closed log
ed2fa8d is described below

commit ed2fa8dd28637895968dc75e78136b5ff1b74f9e
Author: AlexStocks <al...@foxmail.com>
AuthorDate: Tue Feb 23 20:24:33 2021 +0800

    add dubbo/grpc closed log
---
 protocol/dubbo/dubbo_invoker.go | 2 +-
 protocol/grpc/grpc_invoker.go   | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/protocol/dubbo/dubbo_invoker.go b/protocol/dubbo/dubbo_invoker.go
index 231db38..80a925c 100644
--- a/protocol/dubbo/dubbo_invoker.go
+++ b/protocol/dubbo/dubbo_invoker.go
@@ -106,7 +106,7 @@ func (di *DubboInvoker) Invoke(ctx context.Context, invocation protocol.Invocati
 
 	if di.client == nil {
 		result.Err = protocol.ErrClientClosed
-		logger.Debugf("result.Err: %v", result.Err)
+		logger.Warnf("the dubbo invoker client has been closed")
 		return &result
 	}
 
diff --git a/protocol/grpc/grpc_invoker.go b/protocol/grpc/grpc_invoker.go
index 7b33c67..52446f5 100644
--- a/protocol/grpc/grpc_invoker.go
+++ b/protocol/grpc/grpc_invoker.go
@@ -89,6 +89,7 @@ func (gi *GrpcInvoker) Invoke(ctx context.Context, invocation protocol.Invocatio
 
 	if gi.client == nil {
 		result.Err = protocol.ErrClientClosed
+		logger.Warn("the grpc invoker client has been closed")
 		return &result
 	}