- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 58 for mkcounter (0.66 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)