Server sequences outbound may not appear sequential to other listening servers.

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2018-12-06 16:52:13 -08:00
parent 4bea6e0002
commit c5ee8b2cff

View File

@@ -484,13 +484,11 @@ func (s *Server) updateRemoteServer(ms *ServerInfo) {
if su == nil {
s.sys.servers[ms.ID] = &serverUpdate{ms.Seq, time.Now()}
} else {
// Should alwqys be going up.
if ms.Seq <= su.seq {
s.Errorf("Received out of order remote server update from: %q", ms.ID)
return
}
if ms.Seq != su.seq+1 {
s.Errorf("Missed [%d] remote server updates from: %q", ms.Seq-su.seq+1, ms.ID)
}
su.seq = ms.Seq
su.ltime = time.Now()
}