aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-09-07 20:14:11 -0700
committerchrislu <chris.lu@gmail.com>2022-09-07 20:14:11 -0700
commit7de112943b2548183c0dfe594600479489c0bced (patch)
treeb0e0749b7a34191029b9e6d594f7f7f1868adc25
parent7e52b1e195182dc9b7179d0a01c7904d6c10b28a (diff)
parent449582343ff4c3f6add57446b58e671577edf7fe (diff)
downloadseaweedfs-7de112943b2548183c0dfe594600479489c0bced.tar.xz
seaweedfs-7de112943b2548183c0dfe594600479489c0bced.zip
Merge branch 'master' of https://github.com/seaweedfs/seaweedfs
-rw-r--r--weed/server/master_grpc_server.go6
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go
index d618f28af..b6b80ce47 100644
--- a/weed/server/master_grpc_server.go
+++ b/weed/server/master_grpc_server.go
@@ -228,7 +228,11 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
if err := stream.Send(&master_pb.HeartbeatResponse{
Leader: string(newLeader),
}); err != nil {
- glog.Warningf("SendHeartbeat.Send response to to %s:%d %v", dn.Ip, dn.Port, err)
+ if dn != nil {
+ glog.Warningf("SendHeartbeat.Send response to %s:%d %v", dn.Ip, dn.Port, err)
+ } else {
+ glog.Warningf("SendHeartbeat.Send response %v", err)
+ }
return err
}
}