Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 95 for _Equal (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top