- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 2,972 for Mlock (4.47 sec)
-
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) -
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) -
cmd/handler-api.go
// ram_per_request is (1MiB+32KiB) * driveCount \ // + 2 * 10MiB (default erasure block size v1) + 2 * 1MiB (default erasure block size v2) apiRequestsMaxPerNode = int(maxMem / uint64(maxSetDrives*blockSize+int(blockSizeV1*2+blockSizeV2*2))) } else { // ram_per_request is (1MiB+32KiB) * driveCount \ // + 2 * 1MiB (default erasure block size v2) apiRequestsMaxPerNode = int(maxMem / uint64(maxSetDrives*blockSize+int(blockSizeV2*2)))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 08:13:12 UTC 2024 - 10.4K bytes - Viewed (0) -
src/runtime/traceregion.go
if block != nil { r := block.off.Add(n) if r <= uintptr(len(block.data)) { return (*notInHeap)(unsafe.Pointer(&block.data[r-n])) } } // Try to install a new block. lock(&a.lock) // Check block again under the lock. Someone may // have gotten here first. block = (*traceRegionAllocBlock)(a.current.Load()) if block != nil { r := block.off.Add(n) if r <= uintptr(len(block.data)) { unlock(&a.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/kubelet/util/node_startup_latency_tracker.go
bootTime: bootTime, kubeletStartTime: time.Now(), clock: clock.RealClock{}, } } func (n *basicNodeStartupLatencyTracker) RecordAttemptRegisterNode() { n.lock.Lock() defer n.lock.Unlock() if !n.firstRegistrationAttemptTime.IsZero() { return } n.firstRegistrationAttemptTime = n.clock.Now() } func (n *basicNodeStartupLatencyTracker) RecordRegisteredNewNode() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 05:54:25 UTC 2023 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/lruexpirecache.go
} // NewLRUExpireCacheWithClock creates an expiring cache with the given size, using the specified clock to obtain the current time. func NewLRUExpireCacheWithClock(maxSize int, clock Clock) *LRUExpireCache { if maxSize <= 0 { panic("maxSize must be > 0") } return &LRUExpireCache{ clock: clock, maxSize: maxSize, entries: map[interface{}]*list.Element{}, } } type cacheEntry struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 4.3K bytes - Viewed (0) -
pilot/pkg/config/memory/store.go
mutex sync.RWMutex } func (cr *store) Schemas() collection.Schemas { return cr.schemas } func (cr *store) Get(kind config.GroupVersionKind, name, namespace string) *config.Config { cr.mutex.RLock() defer cr.mutex.RUnlock() _, ok := cr.data[kind] if !ok { return nil } ns, exists := cr.data[kind][namespace] if !exists { return nil } out, exists := ns[name] if !exists {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 26 01:14:27 UTC 2023 - 6.3K bytes - Viewed (0) -
internal/config/storageclass/storage-class.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
internal/dsync/lock-args_gen_test.go
Klaus Post <******@****.***> 1700528975 -0800
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 4.4K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ChainingHttpHandler.java
ChainingHttpHandler(Lock lock, int timeoutMs, AtomicInteger counter, WaitPrecondition first) { this.lock = lock; this.condition = lock.newCondition(); this.timeoutMs = timeoutMs; this.counter = counter; this.last = first; } public <T extends TrackingHttpHandler> T addHandler(HandlerFactory<T> factory) { lock.lock(); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.5K bytes - Viewed (0)