github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

apiserver/watchcache: doc watch event fan-out to blocked watchers better

Browse Source
This commit is contained in:
Dr. Stefan Schimanski
2021-10-08 17:05:27 +02:00
parent 8d0acaa3ff
commit 94b2bb1d3d
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
View File

@@ -934,8 +934,11 @@ func (c *Cacher) dispatchEvent(event *watchCacheEvent) {
timeout := c.dispatchTimeoutBudget.takeAvailable() timeout := c.dispatchTimeoutBudget.takeAvailable()
c.timer.Reset(timeout) c.timer.Reset(timeout)
// Make sure every watcher will try to send event without blocking first, // Send event to all blocked watchers. As long as timer is running,
// even if the timer has already expired. // `add` will wait for the watcher to unblock. After timeout,
// `add` will not wait, but immediately close a still blocked watcher.
// Hence, every watcher gets the chance to unblock itself while timer
// is running, not only the first ones in the list.
timer := c.timer timer := c.timer
for _, watcher := range c.blockedWatchers { for _, watcher := range c.blockedWatchers {
if !watcher.add(event, timer) { if !watcher.add(event, timer) {