Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for blockedWatchers (0.27 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    		wcEvent := *event
    		setCachingObjects(&wcEvent, c.versioner)
    		event = &wcEvent
    
    		c.blockedWatchers = c.blockedWatchers[:0]
    		for _, watcher := range c.watchersBuffer {
    			if !watcher.nonblockingAdd(event) {
    				c.blockedWatchers = append(c.blockedWatchers, watcher)
    			}
    		}
    
    		if len(c.blockedWatchers) > 0 {
    			// dispatchEvent is called very often, so arrange
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top