- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 327 for crBlock (0.11 sec)
-
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/Clock.java
import org.gradle.internal.service.scopes.Scope; import org.gradle.internal.service.scopes.ServiceScope; /** * A device for obtaining the current time. * * @see Time#clock() */ @ServiceScope(Scope.Global.class) public interface Clock { /** * The current time in millis. */ long getCurrentTime();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 974 bytes - Viewed (0) -
src/sync/rwmutex.go
} } // TryLock tries to lock rw for writing and reports whether it succeeded. // // Note that while correct uses of TryLock do exist, they are rare, // and use of TryLock is often a sign of a deeper problem // in a particular use of mutexes. func (rw *RWMutex) TryLock() bool { if race.Enabled { _ = rw.w.state race.Disable() } if !rw.w.TryLock() { if race.Enabled { race.Enable()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
w.setBookmarkAfterResourceVersion(0) return w } clock := testingclock.NewFakeClock(time.Now()) watchers := newTimeBucketWatchers(clock, defaultBookmarkFrequency) now := clock.Now() watchers.addWatcherThreadUnsafe(newWatcher(now.Add(10 * time.Second))) watchers.addWatcherThreadUnsafe(newWatcher(now.Add(20 * time.Second)))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
groupResource schema.GroupResource, clock clock.Clock, maxIdleTime time.Duration, stopCh <-chan struct{}) Store { if maxIdleTime < minIdleTime { maxIdleTime = minIdleTime } store := &objectCache{ listObject: listObject, watchObject: watchObject, newObject: newObject, isImmutable: isImmutable, groupResource: groupResource, clock: clock, maxIdleTime: maxIdleTime,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
// This handler is run at the end of every Add/Update/Delete method // and additionally gets the previous value of the object. eventHandler func(*watchCacheEvent) // for testing timeouts. clock clock.Clock // An underlying storage.Versioner. versioner storage.Versioner // cacher's group resource groupResource schema.GroupResource // For testing cache interval invalidation.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
src/runtime/mgclimit.go
l.bucket.fill -= uint64(-change) } if change != 0 && enabled { l.enabled.Store(false) } } // tryLock attempts to lock l. Returns true on success. func (l *gcCPULimiterState) tryLock() bool { return l.lock.CompareAndSwap(0, 1) } // unlock releases the lock on l. Must be called if tryLock returns true. func (l *gcCPULimiterState) unlock() { old := l.lock.Swap(0) if old != 1 { throw("double unlock")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 22:07:41 UTC 2024 - 17.3K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/kubelet/cm/dra/claiminfo_test.go
description string funcGen func(cache *claimInfoCache) func() error wantErr bool }{ { description: "RLock-ed cache allows another RLock", funcGen: func(cache *claimInfoCache) func() error { return func() error { if !cache.RWMutex.TryRLock() { return errors.New("RLock failed") } return nil } }, }, { description: "cache is locked inside a function",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 21K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
startBucketID int64 clock clock.Clock bookmarkFrequency time.Duration } func newTimeBucketWatchers(clock clock.Clock, bookmarkFrequency time.Duration) *watcherBookmarkTimeBuckets { return &watcherBookmarkTimeBuckets{ watchersBuckets: make(map[int64][]*cacheWatcher), createTime: clock.Now(), startBucketID: 0, clock: clock, bookmarkFrequency: bookmarkFrequency,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
} // Option configures a PriorityQueue type Option func(*priorityQueueOptions) // WithClock sets clock for PriorityQueue, the default clock is clock.RealClock. func WithClock(clock clock.Clock) Option { return func(o *priorityQueueOptions) { o.clock = clock } } // WithPodInitialBackoffDuration sets pod initial backoff duration for PriorityQueue.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)