diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-07-17 23:23:01 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-07-17 23:23:01 -0700 |
| commit | 0264a7f50afe61f22b9dcf8496a57a916e2568b7 (patch) | |
| tree | 418f8ff1d572f1bc77418b99bb95505d3673fe1b | |
| parent | c33f4239557f9031c3390a4bc38b7b4623c4941d (diff) | |
| download | seaweedfs-0264a7f50afe61f22b9dcf8496a57a916e2568b7.tar.xz seaweedfs-0264a7f50afe61f22b9dcf8496a57a916e2568b7.zip | |
set the max file key when ever possible
| -rw-r--r-- | weed/server/master_grpc_server.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index 1a17327a0..e0d1fd174 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -52,8 +52,9 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ return err } + t.Sequence.SetMax(heartbeat.MaxFileKey) + if dn == nil { - t.Sequence.SetMax(heartbeat.MaxFileKey) if heartbeat.Ip == "" { if pr, ok := peer.FromContext(stream.Context()); ok { if pr.Addr != net.Addr(nil) { |