Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

v3rpc: don't elide next progress notification on progress notification

Browse Source 
Fixes #5878
This commit is contained in:
Anthony Romano 2016-07-20 11:37:20 -07:00 committed by Gyu-Ho Lee
parent 846883a979
commit a4e79d7ebf
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
etcdserver/api/v3rpc/watch.go
View File

@ -268,7 +268,8 @@ func (sws *serverWatchStream) sendLoop() {
} }
sws.mu.Lock() sws.mu.Lock()
if _, ok := sws.progress[wresp.WatchID]; ok { if len(evs) > 0 && sws.progress[wresp.WatchID] {
// elide next progress update if sent a key update
sws.progress[wresp.WatchID] = false sws.progress[wresp.WatchID] = false
} }
sws.mu.Unlock() sws.mu.Unlock()