Skip to content
Snippets Groups Projects
Commit cd5ca05e authored by scott.wang's avatar scott.wang
Browse files

[ISSUE #163] clean heartbeat from PendingResponse

parent 9bcb5937
No related branches found
No related tags found
No related merge requests found
...@@ -91,6 +91,7 @@ func (h *RpcClientHandler) OnMessage(session getty.Session, pkg interface{}) { ...@@ -91,6 +91,7 @@ func (h *RpcClientHandler) OnMessage(session getty.Session, pkg interface{}) {
if p.Err != nil { if p.Err != nil {
logger.Errorf("rpc heartbeat response{error: %#v}", p.Err) logger.Errorf("rpc heartbeat response{error: %#v}", p.Err)
} }
h.conn.pool.rpcClient.removePendingResponse(SequenceType(p.Header.ID))
return return
} }
logger.Debugf("get rpc response{header: %#v, body: %#v}", p.Header, p.Body) logger.Debugf("get rpc response{header: %#v, body: %#v}", p.Header, p.Body)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment