- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 183 for deltaY (1.13 sec)
-
pkg/registry/core/service/ipallocator/controller/repairip.go
key, err := cache.MetaNamespaceKeyFunc(new) if err == nil { r.svcQueue.Add(key) } }, DeleteFunc: func(obj interface{}) { // IndexerInformer uses a delta queue, therefore for deletes we have to use this // key function. key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err == nil { r.svcQueue.Add(key) } }, }, interval)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
} @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { TrustedListenableFutureTask<@Nullable Void> task = TrustedListenableFutureTask.create(command, null); ScheduledFuture<?> scheduled = delegate.schedule(task, delay, unit); return new ListenableScheduledTask<@Nullable Void>(task, scheduled); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 39K bytes - Viewed (0) -
cluster/gce/gci/configure.sh
exit 2 ;; esac } # Retries a command forever with a delay between retries. # Args: # $1 : delay between retries, in seconds. # $2... : the command to run. function retry-forever { local -r delay="$1" shift 1 until "$@"; do echo "== $* failed, retrying after ${delay}s" sleep "${delay}" done } # Initializes variables used by the log-* functions. #
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 04:14:02 UTC 2024 - 36.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 finished run in 0 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task", ) } /** Repeat with a delay of 200 but schedule with a delay of 50. The schedule wins. */ @Test fun executeScheduledEarlierReplacesRepeatedLater() { val task = object : Task("task") { val schedules = mutableListOf(50.µs)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_test.go
proxy.connectedMutex.Lock() defer proxy.connectedMutex.Unlock() if proxy.connected != nil { return fmt.Errorf("still connected") } return nil }, retry.Timeout(time.Second), retry.Delay(time.Millisecond)) } expectCondition := func(expected string) { t.Helper() retry.UntilSuccessOrFail(t, func() error { cfg := f.Store().Get(gvk.WorkloadEntry, "group-1.1.1.1", "default") if cfg == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 18.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableListTest.java
} } public void testCopyOf_concurrentlyMutating() { List<String> sample = Lists.newArrayList("a", "b", "c"); for (int delta : new int[] {-1, 0, 1}) { for (int i = 0; i < sample.size(); i++) { Collection<String> misleading = Helpers.misleadingSizeCollection(delta); List<String> expected = sample.subList(0, i); misleading.addAll(expected);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 15:27:58 UTC 2024 - 23.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/primitives/CharsTest.java
} public void testToArray_threadSafe() { for (int delta : new int[] {+1, 0, -1}) { for (int i = 0; i < VALUES.length; i++) { List<Character> list = Chars.asList(VALUES).subList(0, i); Collection<Character> misleadingSize = Helpers.misleadingSizeCollection(delta); misleadingSize.addAll(list); char[] arr = Chars.toArray(misleadingSize);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 20 17:00:05 UTC 2024 - 24.7K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
}) for _, fn := range fns { l.AddRunFunction(fn) } stop := make(chan struct{}) go l.Run(stop) retry.UntilOrFail(t, func() bool { return l.isLeader() == expectLeader }, retry.Converge(5), retry.Delay(time.Millisecond*100), retry.Timeout(time.Second*10)) return l, stop } type fakeDefaultWatcher struct { defaultRevision string } func (w *fakeDefaultWatcher) Run(stop <-chan struct{}) { }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/primitives/BooleansTest.java
boolean[] VALUES = BooleansTest.VALUES; VALUES = Booleans.concat(VALUES, VALUES); for (int delta : new int[] {+1, 0, -1}) { for (int i = 0; i < VALUES.length; i++) { List<Boolean> list = Booleans.asList(VALUES).subList(0, i); Collection<Boolean> misleadingSize = Helpers.misleadingSizeCollection(delta); misleadingSize.addAll(list); boolean[] arr = Booleans.toArray(misleadingSize);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Mar 04 15:43:29 UTC 2024 - 23.9K bytes - Viewed (0) -
src/encoding/binary/binary_test.go
count := func() int { var i int structSize.Range(func(_, _ any) bool { i++ return true }) return i } var total int added := func() int { delta := count() - total total += delta return delta } type foo struct { A uint32 } type bar struct { A Struct B foo C Struct } testcases := []struct { val any want int
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 19:16:18 UTC 2024 - 25.4K bytes - Viewed (0)