Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 118 for clocks (0.13 sec)

  1. cmd/kubeadm/app/preflight/checks.go

    	} else {
    		checks = append(checks, ContainerRuntimeCheck{runtime: containerRuntime})
    	}
    
    	// non-windows checks
    	checks = addSwapCheck(checks)
    	checks = addExecChecks(checks, execer)
    	checks = append(checks,
    		SystemVerificationCheck{},
    		HostnameCheck{nodeName: nodeReg.Name},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:20:55 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  2. pkg/kubelet/pleg/generic.go

    	relistDuration *RelistDuration, cache kubecontainer.Cache,
    	clock clock.Clock) PodLifecycleEventGenerator {
    	return &GenericPLEG{
    		relistDuration: relistDuration,
    		runtime:        runtime,
    		eventChannel:   eventChannel,
    		podRecords:     make(podRecords),
    		cache:          cache,
    		clock:          clock,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  3. src/sync/rwmutex.go

    		runtime_Semrelease(&rw.writerSem, false, 1)
    	}
    }
    
    // Lock locks rw for writing.
    // If the lock is already locked for reading or writing,
    // Lock blocks until the lock is available.
    func (rw *RWMutex) Lock() {
    	if race.Enabled {
    		_ = rw.w.state
    		race.Disable()
    	}
    	// First, resolve competition with other writers.
    	rw.w.Lock()
    	// Announce to readers there is a pending writer.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  4. src/sync/mutex.go

    	// Starvation mode is important to prevent pathological cases of tail latency.
    	starvationThresholdNs = 1e6
    )
    
    // Lock locks m.
    // If the lock is already in use, the calling goroutine
    // blocks until the mutex is available.
    func (m *Mutex) Lock() {
    	// Fast path: grab unlocked mutex.
    	if atomic.CompareAndSwapInt32(&m.state, 0, mutexLocked) {
    		if race.Enabled {
    			race.Acquire(unsafe.Pointer(m))
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. src/cmd/vendor/golang.org/x/build/relnote/relnote.go

    	slices.Sort(filenames)
    	return filenames, nil
    }
    
    // lastBlock returns the last block in the document.
    // It panics if the document has no blocks.
    func lastBlock(doc *md.Document) md.Block {
    	return doc.Blocks[len(doc.Blocks)-1]
    }
    
    // addLines adds n lines to the position of b.
    // n can be negative.
    func addLines(b md.Block, n int) {
    	pos := position(b)
    	pos.StartLine += n
    	pos.EndLine += n
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/LauncherServices.java

                if (!requestMetaData.isInteractive()) {
                    return new NonInteractiveUserInputHandler();
                }
    
                return new DefaultUserInputHandler(outputEventListenerManager.getBroadcaster(), clock, inputReader);
            }
    
            @Provides
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Jun 05 13:01:53 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  7. platforms/documentation/docs/src/docs/userguide/dep-man/02-declaring-dependency-versions/dependency_locking.adoc

    ====
    
    == Generating and updating dependency locks
    
    In order to generate or update lock state, you specify the `--write-locks` command line argument in addition to the normal tasks that would trigger configurations to be resolved.
    This will cause the creation of lock state for each resolved configuration in that build execution.
    Note that if lock state existed previously, it is overwritten.
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 16:55:22 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  8. manifests/addons/dashboards/jsonnetfile.lock.json

    John Howard <******@****.***> 1717524306 -0700
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 04 18:05:06 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  9. 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)
  10. pkg/kubelet/util/manager/watch_based_manager.go

    }
    
    func (i *objectCacheItem) setLastAccessTime(time time.Time) {
    	i.lock.Lock()
    	defer i.lock.Unlock()
    	i.lastAccessTime = time
    }
    
    func (i *objectCacheItem) setImmutable() {
    	i.lock.Lock()
    	defer i.lock.Unlock()
    	i.immutable = true
    }
    
    func (i *objectCacheItem) stopIfIdle(now time.Time, maxIdleTime time.Duration) bool {
    	i.lock.Lock()
    	defer i.lock.Unlock()
    	// Ensure that we don't try to stop not yet initialized reflector.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
Back to top