- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 95 for lasta (0.04 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_container.go
// preserving the most recent terminated init container. func (m *kubeGenericRuntimeManager) pruneInitContainersBeforeStart(ctx context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus) { // only the last execution of each init container should be preserved, and only preserve it if it is in the // list of init containers to keep. initContainerNames := sets.New[string]() for _, container := range pod.Spec.InitContainers {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Sets.java
return Iterators.find(unfiltered.iterator(), predicate); } @Override @ParametricNullness public E last() { SortedSet<E> sortedUnfiltered = (SortedSet<E>) unfiltered; while (true) { E element = sortedUnfiltered.last(); if (predicate.apply(element)) { return element; } sortedUnfiltered = sortedUnfiltered.headSet(element);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 77.3K bytes - Viewed (0) -
src/cmd/go/internal/test/test.go
An example function is similar to a test function but, instead of using *testing.T to report success or failure, prints output to os.Stdout. If the last comment in the function starts with "Output:" then the output is compared exactly against the comment (see examples below). If the last comment begins with "Unordered output:" then the output is compared to the comment, however the order of the lines is ignored. An example with no such
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 71.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
responseHeaders: List<Header>, last: Boolean, ): Boolean { assertThat(streamId).isEqualTo(2) assertThat(last).isTrue() events.add(responseHeaders) notifyAll() return false } @Synchronized override fun onData( streamId: Int, source: BufferedSource, byteCount: Int, last: Boolean, ): Boolean {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
t.Errorf("Pod %v processed %v times", i, len(events)) continue } // PodWorker guarantees the last event will be processed last := len(events) - 1 if events[last].name != strconv.Itoa(i) { t.Errorf("Pod %v: incorrect order %v, %#v", i, last, events) } } } func TestUpdatePod(t *testing.T) { one := int64(1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
src/runtime/map.go
// pointer is nil, then there are more available by bumping the pointer. // We need a safe non-nil pointer for the last overflow bucket; just use buckets. nextOverflow = (*bmap)(add(buckets, base*uintptr(t.BucketSize))) last := (*bmap)(add(buckets, (nbuckets-1)*uintptr(t.BucketSize))) last.setoverflow(t, (*bmap)(buckets)) } return buckets, nextOverflow }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 57.6K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KaFirResolver.kt
fir: FirFunctionCall, arrayAccessExpression: KtArrayAccessExpression, ): CompoundArrayAccessPartiallyAppliedSymbols? { // The last argument of `set` is the new value to be set. This value should be a call to the respective `plus`, `minus`, // `times`, `div`, or `rem` function.
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 73K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirReferenceShortener.kt
private fun findFakePackageToShorten(typeElement: KtUserType): ElementToShorten? { val deepestTypeWithQualifier = typeElement.qualifiedTypesWithSelf.last() return if (deepestTypeWithQualifier.hasFakeRootPrefix()) createElementToShorten(deepestTypeWithQualifier) else null } fun processTypeQualifier(resolvedQualifier: FirResolvedQualifier) {
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Fri Jun 07 16:54:07 UTC 2024 - 69.6K bytes - Viewed (0) -
src/cmd/dist/test.go
dt := w.dt if t.lastHeading != dt.heading { t.lastHeading = dt.heading t.out(dt.heading) } if dt != last { // Assumes all the entries for a single dt are in one worklist. last = w.dt if vflag > 0 { fmt.Printf("# go tool dist test -run=^%s$\n", dt.name) } } if vflag > 1 { errprintf("%s\n", strings.Join(w.cmd.Args, " ")) } ended++ <-w.end
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 16:01:35 UTC 2024 - 50K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
func (proxier *Proxier) SyncLoop() { // Update healthz timestamp at beginning in case Sync() never succeeds. if proxier.healthzServer != nil { proxier.healthzServer.Updated(proxier.ipFamily) } // synthesize "last change queued" time as the informers are syncing. metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime() proxier.syncRunner.Loop(wait.NeverStop) } func (proxier *Proxier) setInitialized(value bool) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0)