- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for mkcounter (0.37 sec)
-
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) -
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) -
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) -
pilot/pkg/networking/core/listener_test.go
TotalMatch: true, }, }, }) }) } func TestOutboundListenerConflict_HTTPWithCurrentUnknown(t *testing.T) { // The oldest service port is unknown. We should encounter conflicts when attempting to add the HTTP ports. Purposely // storing the services out of time order to test that it's being sorted properly. testOutboundListenerConflict(t,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test.go
// counter := 0 return wait.PollUntilContextCancel(context.TODO(), 100*time.Millisecond, true, func(_ context.Context) (done bool, err error) { counter += 1 err = applyPatchOperation{ gvr: myCRDV1Beta1, name: "sentinel-resource", patch: map[string]interface{}{ sentinelName: fmt.Sprintf("invalid-%d", counter), }}.Do(ctx) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 59.5K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
// and by the end of the GC mark phase, the heap tends to be densely packed. Releasing // memory in these densely packed chunks while they're being packed is counter-productive, // and worse, it breaks up huge pages on systems that support them. The scavenger (invoked // during memory allocation) further ensures that chunks it identifies as "dense" are
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
src/runtime/traceback.go
// - pc is the PC in the running function. // - sp is the stack pointer at that program counter. // - For the innermost frame on LR machines, lr is the program counter that called fn. // // On return, u.frame contains: // - fp is the stack pointer of the caller. // - lr is the program counter that called fn. // - varp, argp, and continpc are populated for the current frame. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 55.1K bytes - Viewed (0)