=rpc添加了一些日志

LionelWoody · May 24, 2017 · f9ae932 · f9ae932
1 parent 01b2db1
commit f9ae932
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/rpc/base/rpc_server.go b/rpc/base/rpc_server.go
@@ -151,6 +151,11 @@ func (s *RPCServer) on_callback_handle(callbacks <-chan mqrpc.CallInfo) {
 				if callInfo.RpcInfo.Reply {
 					//需要回复的才回复
 					callInfo.Agent.(mqrpc.MQServer).Callback(callInfo)
+				}else{
+					//对于不需要回复的消息,可以判断一下是否出现错误，打印一些警告
+					if callInfo.Result.Error!=""{
+						log.Warning("rpc callback erro :\n%s",callInfo.Result.Error)
+					}
 				}
 			}
 		}