- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for counter2 (0.22 sec)
-
subprojects/core/src/integTest/groovy/org/gradle/api/services/BuildServiceIntegrationTest.groovy
} } apply plugin: CounterConventionPlugin def counter1 = project.gradle.sharedServices.registerIfAbsent("counter1", CountingService) { parameters.initial = 0 } def counter2 = project.gradle.sharedServices.registerIfAbsent("counter2", CountingService) { parameters.initial = 10 } task count {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:46 UTC 2024 - 61K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
// 2. Remove the finalizers from the Pods if they completed or were removed // or the job was removed. // 3. Increment job counters for pods that no longer have a finalizer. // 4. Add Complete condition if satisfied with current counters. // // It does this up to a limited number of Pods so that the size of .status // doesn't grow too much and this sync doesn't starve other Jobs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K 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/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) -
pkg/proxy/iptables/proxier.go
return } } // ensure the nfacct counters if proxier.nfacct != nil { for name := range proxier.nfAcctCounters { if err := proxier.nfacct.Ensure(name); err != nil { proxier.nfAcctCounters[name] = false proxier.logger.Error(err, "Failed to create nfacct counter; the corresponding metric will not be updated", "counter", name) } else { proxier.nfAcctCounters[name] = true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K 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/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) -
src/cmd/go/go_test.go
defer tg.cleanup() tg.parallel() tg.tempDir("home/go") tg.setenv(homeEnvName(), tg.path("home")) // Set TEST_TELEMETRY_DIR to a path that doesn't exist // so that the counter uploading code doesn't write // the counter token file to the temp dir after the test finishes. tg.setenv("TEST_TELEMETRY_DIR", "/no-telemetry-dir") tg.run("env", "GOPATH")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 81.1K bytes - Viewed (0) -
cmd/erasure-object.go
) for success := range done { totalResp++ if success { validResp++ } if totalResp >= minDisks && opts.FastGetObjInfo { rw.Lock() ok := countErrs(errs, errFileNotFound) >= minDisks || countErrs(errs, errFileVersionNotFound) >= minDisks rw.Unlock() if ok { err = errFileNotFound if opts.VersionID != "" { err = errFileVersionNotFound } break }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
cmd/erasure-healing_test.go
_, err = objLayer.HealObject(ctx, bucket, object, "", hopts) if err != nil { t.Fatal(err) } fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true) if countErrs(errs, nil) != len(fileInfos) { t.Fatal("Expected all xl.meta healed, but partial heal detected") } fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", minioMetaBucket, cfgFile, "", false, true)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0)