mirror of
https://github.com/smallnest/rpcx.git
synced 2025-10-24 00:23:07 +08:00
#326 fix the issue that errors have been overrided
This commit is contained in:
@@ -422,10 +422,12 @@ func (s *Server) serveConn(conn net.Conn) {
|
|||||||
res.Metadata = resMetadata
|
res.Metadata = resMetadata
|
||||||
} else {
|
} else {
|
||||||
for k, v := range resMetadata {
|
for k, v := range resMetadata {
|
||||||
|
if meta[k] == "" {
|
||||||
meta[k] = v
|
meta[k] = v
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if len(res.Payload) > 1024 && req.CompressType() != protocol.None {
|
if len(res.Payload) > 1024 && req.CompressType() != protocol.None {
|
||||||
res.SetCompressType(req.CompressType())
|
res.SetCompressType(req.CompressType())
|
||||||
|
Reference in New Issue
Block a user