- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 95 for _Equal (0.12 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
assert.NoError(t, result.Error()) assert.Equal(t, 2, len(fakeRuntime.Containers)) assert.Equal(t, 2, len(fakeImage.Images)) assert.Equal(t, 1, len(fakeRuntime.Sandboxes)) for _, sandbox := range fakeRuntime.Sandboxes { assert.Equal(t, runtimeapi.PodSandboxState_SANDBOX_READY, sandbox.State) } for _, c := range fakeRuntime.Containers { assert.Equal(t, runtimeapi.ContainerState_CONTAINER_RUNNING, c.State) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
delete(parsedLog, "time") want := map[string]any{ "level": cases[i].level, "msg": cases[i].msg, } if k := cases[i].key; k != nil { want["key"] = *k } assert.Equal(t, want, parsedLog) i++ } } func TestParseCniLog(t *testing.T) { wantT := &time.Time{} assert.NoError(t, wantT.UnmarshalText([]byte("2020-01-01T00:00:00.356374Z"))) cases := []struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.1K bytes - Viewed (0) -
pilot/pkg/bootstrap/server_test.go
stop := make(chan struct{}) g.Expect(s.Start(stop)).To(Succeed()) defer func() { close(stop) s.WaitUntilCompletion() }() g.Expect(s.environment.DomainSuffix).To(Equal(c.expectedDomain)) assert.Equal(t, s.secureGrpcServer != nil, c.enableSecureGRPC) }) } } func TestMultiplex(t *testing.T) { configDir := t.TempDir() var secureGRPCPort int var err error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 23.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java
aa.lazySet(i, VALUES[i]); assertBitEquals(VALUES[i], aa.get(i)); aa.lazySet(i, -3.0); assertBitEquals(-3.0, aa.get(i)); } } /** compareAndSet succeeds in changing value if equal to expected else fails */ public void testCompareAndSet() { AtomicDoubleArray aa = new AtomicDoubleArray(SIZE); for (int i : new int[] {0, SIZE - 1}) { double prev = 0.0;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 10.5K bytes - Viewed (0) -
cmd/erasure-healing-common.go
timeOccurrenceMap := make(map[int64]int, len(times)) groupNano := group.Nanoseconds() // Ignore the uuid sentinel and count the rest. for _, t := range times { if t.Equal(timeSentinel) || t.IsZero() { continue } nano := t.UnixNano() if group > 0 { for k := range timeOccurrenceMap { if k == nano { // We add to ourself later continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 12.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
assertBitEquals(1.0, at.get()); for (double x : VALUES) { at.lazySet(x); assertBitEquals(x, at.get()); } } /** compareAndSet succeeds in changing value if equal to expected else fails */ public void testCompareAndSet() { double prev = Math.E; double unused = Math.E + Math.PI; AtomicDouble at = new AtomicDouble(prev); for (double x : VALUES) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/object-handlers-common.go
// If the object doesn't have a modtime (IsZero), or the modtime // is obviously garbage (Unix time == 0), then ignore modtimes // and don't process the If-Modified-Since header. if objInfo.ModTime.IsZero() || objInfo.ModTime.Equal(time.Unix(0, 0)) { return false } // Headers to be set of object content is not going to be written to the client. writeHeaders := func() { // set common headers setCommonHeaders(w)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging_test.go
expected: "[%START_TIME%] %REQ(:METHOD)% %REQ(X-ENVOY-ORIGINAL-PATH?:PATH)%\n", }, } for _, tc := range cases { t.Run(tc.name, func(t *testing.T) { got := fileAccessLogFormat(tc.formatString) assert.Equal(t, tc.expected, got) }) } } func TestAccessLogging(t *testing.T) { labels := map[string]string{"app": "test"} sidecar := &Proxy{ ConfigNamespace: "default", Labels: labels,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 54K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/integtests/tooling/fixture/GradleVersionSpecTest.groovy
*/ package org.gradle.integtests.tooling.fixture import org.gradle.util.GradleVersion import spock.lang.Specification class GradleVersionSpecTest extends Specification { def "greater-than-or-equal version constraint matches all versions with specified base version and later"() { def spec = new GradleVersionSpec().toSpec(">=1.0") expect: spec.isSatisfiedBy(GradleVersion.version("1.0"))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 06:17:20 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
ID: pod.UID, Name: pod.Name, Namespace: pod.Namespace, } apiStatus := kubelet.generateAPIPodStatus(pod, status, false) require.Equal(t, v1.PodFailed, apiStatus.Phase) require.Equal(t, "Evicted", apiStatus.Reason) require.Equal(t, "because", apiStatus.Message) } func TestSyncTerminatingPodKillPod(t *testing.T) { testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)