aboutsummaryrefslogtreecommitdiff
path: root/weed/wdclient/masterclient.go
diff options
context:
space:
mode:
authorKonstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>2022-09-12 10:31:53 +0500
committerGitHub <noreply@github.com>2022-09-11 22:31:53 -0700
commit721c6197f9f14fb76b3ccfb77f7a5fe107b874de (patch)
treef5d72c9e21589b642a94925baf665eef12798bcd /weed/wdclient/masterclient.go
parentb834027c5ae072f86f6fc7edcf55c3be1929befb (diff)
downloadseaweedfs-721c6197f9f14fb76b3ccfb77f7a5fe107b874de.tar.xz
seaweedfs-721c6197f9f14fb76b3ccfb77f7a5fe107b874de.zip
skip deltaBeat if dn is zero (#3630)
* skip deltaBeat https://github.com/seaweedfs/seaweedfs/issues/3629 * fix GrpcPort * skip url :0 * skip empty DataCenter or Rack * skip empty heartbeat Ip * dell msg add DataCenter * comment todo * fix
Diffstat (limited to 'weed/wdclient/masterclient.go')
-rw-r--r--weed/wdclient/masterclient.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/wdclient/masterclient.go b/weed/wdclient/masterclient.go
index 41c5a8bc4..64ae876b0 100644
--- a/weed/wdclient/masterclient.go
+++ b/weed/wdclient/masterclient.go
@@ -262,6 +262,10 @@ func (mc *MasterClient) tryConnectToMaster(master pb.ServerAddress) (nextHintedL
}
func (mc *MasterClient) updateVidMap(resp *master_pb.KeepConnectedResponse) {
+ if resp.VolumeLocation.IsEmptyUrl() {
+ glog.V(0).Infof("updateVidMap ignore short heartbeat: %+v", resp)
+ return
+ }
// process new volume location
loc := Location{
Url: resp.VolumeLocation.Url,