Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 58 for mkcounter (0.66 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go

    				clk:                    clk,
    				counter:                counter,
    				dontDump:               true,
    			}.exercise(t)
    		})
    	}
    }
    
    func TestBaseline(t *testing.T) {
    	metrics.Register()
    	now := time.Now()
    
    	clk, counter := testeventclock.NewFake(now, 0, nil)
    	qsf := newTestableQueueSetFactory(clk, countingPromiseFactoryFactory(counter))
    	qCfg := fq.QueuingConfig{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 26 12:55:23 UTC 2023
    - 58.4K bytes
    - Viewed (0)
  2. subprojects/core/src/integTest/groovy/org/gradle/api/services/BuildServiceIntegrationTest.groovy

            customTaskUsingServiceViaProperty("@${ServiceReference.name}('counter')")
            buildFile """
                gradle.sharedServices.registerIfAbsent("counter", CountingService) {
                    parameters.initial = 10
                    maxParallelUsages = 1
                }
    
                task named(type: Consumer) {
                    counter.get().increment()
                }
            """
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 19:15:46 UTC 2024
    - 61K bytes
    - Viewed (0)
  3. pkg/volume/csi/csi_mounter_test.go

    		}
    
    		mounter, err := plug.NewMounter(
    			spec,
    			&corev1.Pod{ObjectMeta: meta.ObjectMeta{UID: testPodUID, Namespace: testns}},
    			volume.VolumeOptions{},
    		)
    		if err != nil {
    			t.Fatalf("Failed to make a new Mounter: %v", err)
    		}
    
    		if mounter == nil {
    			t.Fatal("failed to create CSI mounter")
    		}
    
    		csiMounter := mounter.(*csiMountMgr)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 50.1K bytes
    - Viewed (0)
  4. pkg/volume/testing/testing.go

    // zero SetUpCallCount. Otherwise it returns an error.
    func VerifyZeroSetUpCallCount(fakeVolumePlugin *FakeVolumePlugin) error {
    	for _, mounter := range fakeVolumePlugin.GetMounters() {
    		actualCallCount := mounter.GetSetUpCallCount()
    		if actualCallCount != 0 {
    			return fmt.Errorf(
    				"At least one mounter has non-zero SetUpCallCount: <%v>.",
    				actualCallCount)
    		}
    	}
    
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      }
    
      private static class Counter<N extends Number> {
        @SuppressWarnings("unused") // used by reflection
        List<N> counts;
      }
    
      public void testWildcardCaptured_typeVariableDeclaresTypeBound_wildcardHasNoExplicitUpperBound()
          throws Exception {
        TypeToken<Counter<?>> type = new TypeToken<Counter<?>>() {};
        TypeToken<?> fieldType =
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 22 17:15:24 UTC 2024
    - 88.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      }
    
      private static class Counter<N extends Number> {
        @SuppressWarnings("unused") // used by reflection
        List<N> counts;
      }
    
      public void testWildcardCaptured_typeVariableDeclaresTypeBound_wildcardHasNoExplicitUpperBound()
          throws Exception {
        TypeToken<Counter<?>> type = new TypeToken<Counter<?>>() {};
        TypeToken<?> fieldType =
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 22 17:15:24 UTC 2024
    - 88.7K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config_test.go

    			# HELP apiserver_envelope_encryption_invalid_key_id_from_status_total [ALPHA] Number of times an invalid keyID is returned by the Status RPC call split by error.
    			# TYPE apiserver_envelope_encryption_invalid_key_id_from_status_total counter
    			apiserver_envelope_encryption_invalid_key_id_from_status_total{error="empty",provider_name="test"} 1
    			`,
    		},
    		{
    			desc: "kmsv2 provider returns a valid keyID",
    			probe: &kmsv2PluginProbe{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 72.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/ldap/LdapManager.java

            private final DirContext context;
    
            private int counter = 1;
    
            protected DirContextHolder(final DirContext context) {
                this.context = context;
            }
    
            public DirContext get() {
                return context;
            }
    
            public void inc() {
                counter++;
            }
    
            @Override
            public void close() {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 65.9K bytes
    - Viewed (0)
  9. cmd/kubelet/app/server.go

    	// Initialize the TLS Options
    	tlsOptions, err := InitializeTLS(&s.KubeletFlags, &s.KubeletConfiguration)
    	if err != nil {
    		return nil, err
    	}
    
    	mounter := mount.New(s.ExperimentalMounterPath)
    	subpather := subpath.New(mounter)
    	hu := hostutil.NewHostUtil()
    	pluginRunner := exec.New()
    
    	plugins, err := ProbeVolumePlugins(featureGate)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:34 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/ppc64/ssa.go

    		// generates STXV instructions on
    		// power9. The Short variation is used
    		// if no loop is generated.
    
    		// sizes >= 64 generate a loop as follows:
    
    		// Set up loop counter in CTR, used by BC
    		// XXLXOR clears VS32
    		//       XXLXOR VS32,VS32,VS32
    		//       MOVD len/64,REG_TMP
    		//       MOVD REG_TMP,CTR
    		//       loop:
    		//       STXV VS32,0(R20)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 19:59:38 UTC 2024
    - 55.4K bytes
    - Viewed (0)
Back to top