diff --git a/rpc/client.go b/rpc/client.go
index eef6ee21cf..ab29107ba2 100644
--- a/rpc/client.go
+++ b/rpc/client.go
@@ -652,6 +652,7 @@ func (c *Client) dispatch(codec ServerCodec) {
 
 		case err := <-c.readErr:
 			conn.handler.log.Debug("RPC connection read error", "err", err)
+			conn.handler.cancelRoot()
 			conn.close(err, lastOp)
 			reading = false