zishuo/rpcx
1
0
Fork 0
mirror of https://github.com/smallnest/rpcx.git synced 2025-12-24 12:27:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

#825 fix clients have not received server errors

Browse Source
This commit is contained in:
smallnest
2023-11-16 23:40:46 +08:00
parent 2781b4c50d
commit 4c029824c7
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
.gitignore vendored
View File

@@ -6,3 +6,5 @@ vendor/
.idea
cover.html
.history

6
server/server.go
View File

@@ -722,7 +722,10 @@ func (s *Server) handleRequest(ctx context.Context, req *protocol.Message) (res
err = service.call(ctx, mtype, reflect.ValueOf(argv), reflect.ValueOf(replyv))
}
replyv, err = s.Plugins.DoPostCall(ctx, serviceName, methodName, argv, replyv, err)
replyv, err1 := s.Plugins.DoPostCall(ctx, serviceName, methodName, argv, replyv, err)
if err == nil {
err = err1
}
// return argc to object pool
reflectTypePools.Put(mtype.ArgType, argv)
@@ -809,7 +812,6 @@ func (s *Server) handleRequestForFunction(ctx context.Context, req *protocol.Mes
replyv, err = s.Plugins.DoPostCall(ctx, serviceName, methodName, argv, replyv, err)
reflectTypePools.Put(mtype.ArgType, argv)
if err != nil {
reflectTypePools.Put(mtype.ReplyType, replyv)
return s.handleError(res, err)