- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 496 for clocks (0.45 sec)
-
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
jListerSynced cache.InformerSynced // Jobs that the controller will check its TTL and attempt to delete when the TTL expires. queue workqueue.TypedRateLimitingInterface[string] // The clock for tracking time clock clock.Clock } // New creates an instance of Controller func New(ctx context.Context, jobInformer batchinformers.JobInformer, client clientset.Interface) *Controller {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
src/runtime/lock_sema.go
return atomic.Loaduintptr(&l.key) > locked } func lock(l *mutex) { lockWithRank(l, getLockRank(l)) } func lock2(l *mutex) { gp := getg() if gp.m.locks < 0 { throw("runtime·lock: lock count") } gp.m.locks++ // Speculative grab for lock. if atomic.Casuintptr(&l.key, 0, locked) { return } semacreate(gp.m) timer := &lockTimer{lock: l} timer.begin()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K 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) -
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) -
src/cmd/vendor/golang.org/x/build/relnote/dump.go
// document to standard output. // It is intended for debugging. func DumpMarkdown(d *md.Document) { dumpBlocks(d.Blocks, 0) } func dumpBlocks(bs []md.Block, depth int) { for _, b := range bs { dumpBlock(b, depth) } } func dumpBlock(b md.Block, depth int) { typeName := strings.TrimPrefix(fmt.Sprintf("%T", b), "*markdown.") dprintf(depth, "%s\n", typeName) switch b := b.(type) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 1.7K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
return true, nil }) if err != nil { err = lastErr } return componentPodHash, err } // WaitForStaticPodHashChange blocks until it timeouts or notices that the Mirror Pod (for the Static Pod, respectively) has changed // This implicitly means this function blocks until the kubelet has restarted the Static Pod in question func (w *KubeWaiter) WaitForStaticPodHashChange(nodeName, component, previousHash string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
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) -
src/crypto/cipher/gcm.go
*y = z } // updateBlocks extends y with more polynomial terms from blocks, based on // Horner's rule. There must be a multiple of gcmBlockSize bytes in blocks. func (g *gcm) updateBlocks(y *gcmFieldElement, blocks []byte) { for len(blocks) > 0 { y.low ^= byteorder.BeUint64(blocks) y.high ^= byteorder.BeUint64(blocks[8:]) g.mul(y) blocks = blocks[gcmBlockSize:] } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 18:57:38 UTC 2024 - 13.7K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/worker/TestWorker.java
testServices.get(ActorFactory.class), testServices.get(Clock.class) ); IdGenerator<Object> idGenerator = Cast.uncheckedNonnullCast(testServices.get(IdGenerator.class)); targetProcessor = new WorkerTestClassProcessor(targetProcessor, idGenerator.generateId(), workerProcessContext.getDisplayName(), testServices.get(Clock.class));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 10K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/sparsecore/embedding_program_key.cc
return tpu_compile_successor; } // Get all the Blocks underneath `top` that are "in the scope" of `bottom`, // i.e., are ancestors. llvm::DenseSet<Block*> GetAllBlocksBetween(Operation* bottom, Operation* top) { llvm::DenseSet<Block*> blocks; Operation* op = bottom; while (op && op != top) { blocks.insert(op->getBlock()); op = op->getParentOp(); } return blocks; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 17.4K bytes - Viewed (0)