- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for startCaching (0.36 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
defer cacher.stopWg.Done() defer cacher.terminateAllWatchers() wait.Until( func() { if !cacher.isStopped() { cacher.startCaching(stopCh) } }, time.Second, stopCh, ) }() return cacher, nil } func (c *Cacher) startCaching(stopChannel <-chan struct{}) { // The 'usable' lock is always 'RLock'able when it is safe to use the cache.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/NonHierarchicalFileWatcherUpdaterTest.groovy
addSnapshot(snapshotRegularFile(fileInWatchableHierarchies)) then: 1 * watcher.startWatching({ equalIgnoringOrder(it, [probeRegistry.getProbeDirectory(file("first"))]) }) 1 * watcher.startWatching({ equalIgnoringOrder(it, [fileInWatchableHierarchies.parentFile]) }) 1 * watcher.startWatching({ equalIgnoringOrder(it, [watchableHierarchies[0]]) }) 0 * _ when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 23 13:24:54 UTC 2024 - 4.8K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdaterTest.groovy
when: addSnapshotInWatchableHierarchy(secondDir) then: 1 * watcher.startWatching({ equalIgnoringOrder(it, [secondDir]) }) 0 * _ when: def snapshot = addSnapshotInWatchableHierarchy(directoryWithinFirst) then: 1 * watcher.startWatching({ equalIgnoringOrder(it, [firstDir]) }) 0 * _ when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 23 13:24:54 UTC 2024 - 12K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/AbstractFileWatcherUpdaterTest.groovy
then: watchableHierarchies.each { watchableHierarchy -> 1 * watcher.startWatching({ equalIgnoringOrder(it, [watchableHierarchy]) }) ifNonHierarchical * watcher.startWatching({ equalIgnoringOrder(it, [directoryContainingSnapshot(watchableHierarchy)]) }) ifNonHierarchical * watcher.startWatching({ equalIgnoringOrder(it, [probeRegistry.getProbeDirectory(watchableHierarchy)]) }) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 21.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/event.go
// // when this variable is set to true, // a special annotation will be added // to the bookmark event. // // note that we decided to extend the event // struct field to eliminate contention // between startWatching and processEvent isInitialEventsEndBookmark bool } // parseKV converts a KeyValue retrieved from an initial sync() listing to a synthetic isCreated event. func parseKV(kv *mvccpb.KeyValue) *event { return &event{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/vfs/impl/WatchingVirtualFileSystem.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 02 16:22:15 UTC 2024 - 25.2K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdater.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
return true } return false } func (wc *watchChan) run(initialEventsEndBookmarkRequired, forceInitialEvents bool) { watchClosedCh := make(chan struct{}) go wc.startWatching(watchClosedCh, initialEventsEndBookmarkRequired, forceInitialEvents) var resultChanWG sync.WaitGroup resultChanWG.Add(1) go wc.processEvent(&resultChanWG) select { case err := <-wc.errChan:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/NonHierarchicalFileWatcherUpdater.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 17 04:59:05 UTC 2023 - 9.8K bytes - Viewed (0)