From 8a0f6abd288ac4dd6dd074a5a0b7f21b774eaf66 Mon Sep 17 00:00:00 2001 From: nolouch Date: Thu, 25 Apr 2019 15:11:17 +0800 Subject: [PATCH] server: address comments Signed-off-by: nolouch --- server/heartbeat_streams.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/heartbeat_streams.go b/server/heartbeat_streams.go index ec4c8e44cb63..a42cfd15743e 100644 --- a/server/heartbeat_streams.go +++ b/server/heartbeat_streams.go @@ -170,14 +170,14 @@ func (s *heartbeatStreams) sendErr(errType pdpb.ErrorType, errMsg string, target msg := &pdpb.RegionHeartbeatResponse{ Header: &pdpb.ResponseHeader{ - ClusterId: s.clusterID, + ClusterId: s.clusterID, + TargetPeer: targetPeer, Error: &pdpb.Error{ Type: errType, Message: errMsg, }, }, } - msg.TargetPeer = targetPeer select { case s.msgCh <- msg: