Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for clocks (0.41 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. src/cmd/compile/internal/liveness/plive.go

    			}
    			c := b.Preds[0].Block()
    			d := b.Preds[1].Block()
    
    			// Find their common predecessor block (the one that branches based on wb on/off).
    			// It might be a diamond pattern, or one of the blocks in the diamond pattern might
    			// be missing.
    			var decisionBlock *ssa.Block
    			if len(c.Preds) == 1 && c.Preds[0].Block() == d {
    				decisionBlock = d
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 15:22:22 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  7. 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)
  8. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * method equivalent to {@link
     * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},
     * except that the method parameter must accept whatever condition-like object is passed into {@code
     * callAndAssertWaits} by the test.
     *
     * @param <L> the type of the lock-like object to be used
     * @author Justin T. Sampson
     */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  9. JavadocStyleGuide.md

     */
    ```
    
    ## 1.3 Code blocks and snippets
    
    `<pre>` is the default HTML tag for preformatted text.
    All code blocks and multi-line snippets should be wrapped in `<pre>{@code ...... }</pre>` at minimum.
    
    Code blocks can be optionally formatted and highlighted using [`highlight.js`](https://highlightjs.org/) with the `<code>` tag.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 15:43:07 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go

    	indexerFuncs   map[string]storage.IndexerFunc
    	clock          clock.WithTicker
    }
    
    type setupOption func(*setupOptions)
    
    func withDefaults(options *setupOptions) {
    	prefix := "/pods"
    
    	options.resourcePrefix = prefix
    	options.keyFunc = func(obj runtime.Object) (string, error) { return storage.NamespaceKeyFunc(prefix, obj) }
    	options.clock = clock.RealClock{}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 17K bytes
    - Viewed (0)
Back to top