From bd520e5829894dc5c8830275ea18c8ed084b0c28 Mon Sep 17 00:00:00 2001 From: HunDunDM Date: Fri, 24 Sep 2021 18:22:11 +0800 Subject: [PATCH] address comment Signed-off-by: HunDunDM --- server/encryptionkm/key_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/encryptionkm/key_manager.go b/server/encryptionkm/key_manager.go index afdd466e572..68c60498b30 100644 --- a/server/encryptionkm/key_manager.go +++ b/server/encryptionkm/key_manager.go @@ -226,7 +226,7 @@ func (m *KeyManager) StartBackgroundLoop(ctx context.Context) { for { select { case resp, ok = <-rch: - if !ok || resp.CompactRevision != 0 || resp.Canceled { + if !ok || resp.Err() != nil { // If chan is closed or canceled, exit watch loop // Ref https://etcd.io/docs/v3.4/learning/api/#watch-streams break keyWatchLoop