- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,613 for cleaned (0.16 sec)
-
pilot/pkg/autoregistration/controller.go
// and make the workload entry enqueue `cleanupQueue` // cleanup is to delete the workload entry // queue contains workloadEntry that need to be unregistered queue controllers.Queue // cleanupLimit rate limit's auto registered WorkloadEntry cleanup calls to k8s cleanupLimit *rate.Limiter // cleanupQueue delays the cleanup of auto registered WorkloadEntries to allow for grace period cleanupQueue queue.Delayed
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
return nil } func (m *manager) Allocate(p *v1.Pod, c *v1.Container) error { // The pod is during the admission phase. We need to save the pod to avoid it // being cleaned before the admission ended m.setPodPendingAdmission(p) // Garbage collect any stranded resources before allocating CPUs. m.removeStaleState() m.Lock() defer m.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (0) -
src/internal/fuzz/worker_test.go
w, err := newWorker(c, dir, binPath, args, env) if err != nil { tb.Fatal(err) } tb.Cleanup(func() { if err := w.cleanup(); err != nil { tb.Error(err) } }) if err := w.startAndPing(context.Background()); err != nil { tb.Fatal(err) } tb.Cleanup(func() { if err := w.stop(); err != nil { tb.Error(err) } }) return w }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 4.8K bytes - Viewed (0) -
build-logic/performance-testing/src/main/kotlin/gradlebuild/performance/tasks/BuildCommitDistribution.kt
copyToFinalDestination(checkoutDir) println("Building the commit distribution in $checkoutDir succeeded, now the baseline is ${commitBaseline.get()}") } /** * Sometimes, the nightly might be cleaned up before GA comes out. If this happens, we fall back to latest RC version or nightly version. */ private fun determineClosestReleasedVersion(expectedBaseVersion: GradleVersion): GradleVersion {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 22 08:07:16 UTC 2024 - 7.4K bytes - Viewed (0) -
internal/event/target/postgresql.go
if match, err := regexp.MatchString("^\"[^\"]+\"$", name); err != nil { return err } else if match { return nil } // normalize the name to letters, digits, _ or $ valid := true cleaned := strings.Map(func(r rune) rune { switch { case unicode.IsLetter(r): return 'a' case unicode.IsDigit(r): return '0' case r == '_', r == '$': return r default: valid = false
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/volume/util/subpath/subpath_linux.go
return bindPathTarget, nil } success := false defer func() { // Cleanup subpath on error if !success { klog.V(4).Infof("doBindSubPath() failed for %q, cleaning up subpath", bindPathTarget) if cleanErr := cleanSubPath(mounter, subpath); cleanErr != nil { klog.Errorf("Failed to clean subpath %q: %v", bindPathTarget, cleanErr) } } }() kubeletPid := os.Getpid()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 12 14:09:11 UTC 2022 - 21.4K bytes - Viewed (0) -
tools/istio-iptables/pkg/validation/validator.go
go func() { c := Client{Config: validator.Config} <-c.Config.ServerReadyBarrier for { _ = c.Run() // Avoid spamming the request to the validation server. // Since the TIMEWAIT socket is cleaned up in 60 second, // it's maintaining 60 TIMEWAIT sockets. Not big deal. time.Sleep(time.Second) } }() select { case <-sTimer.C: return fmt.Errorf("validation timeout") case err := <-sError:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 01 04:37:36 UTC 2023 - 5.5K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
select { case <-timeout.C(): klog.InfoS("Eviction manager: timed out waiting for pods to be cleaned up", "pods", klog.KObjSlice(pods)) return case <-ticker.C(): for i, pod := range pods { if !podCleanedUpFunc(pod) { break } if i == len(pods)-1 { klog.InfoS("Eviction manager: pods successfully cleaned up", "pods", klog.KObjSlice(pods)) return } } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilder.java
* * <p>Expired entries may be counted in {@link Cache#size}, but will never be visible to read or * write operations. Expired entries are cleaned up as part of the routine maintenance described * in the class javadoc. * * @param duration the length of time after an entry is created that it should be automatically * removed * @return this {@code CacheBuilder} instance (for chaining)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 51.3K bytes - Viewed (0) -
src/cmd/go/internal/vet/vetflag.go
packageNames = args break } if err != nil { fmt.Fprintln(os.Stderr, err) exitWithUsage() } if isVetFlag[f.Name] { // Forward the raw arguments rather than cleaned equivalents, just in // case the vet tool parses them idiosyncratically. explicitFlags = append(explicitFlags, args[:len(args)-len(remainingArgs)]...)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 19 14:42:39 UTC 2023 - 5.1K bytes - Viewed (0)