- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 146 for idempotent (0.28 sec)
-
src/runtime/pinner.go
// resilient to an empty pinner being finalized, which is done // by checking p.refs' length. SetFinalizer(p.pinner, func(i *pinner) { if len(i.refs) != 0 { i.unpin() // only required to make the test idempotent pinnerLeakPanic() } }) } } ptr := pinnerGetPtr(&pointer) if setPinned(ptr, true) { p.refs = append(p.refs, ptr) } } // Unpin unpins all pinned objects of the [Pinner].
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:29:45 UTC 2024 - 11K bytes - Viewed (0) -
guava/src/com/google/common/collect/Range.java
* * <p>The intersection exists if and only if the two ranges are {@linkplain #isConnected * connected}. * * <p>The intersection operation is commutative, associative and idempotent, and its identity * element is {@link Range#all}). * * @throws IllegalArgumentException if {@code isConnected(connectedRange)} is {@code false} */ public Range<C> intersection(Range<C> connectedRange) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 27.8K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
pod, ok := pm.podByFullName[podFullName] return pod, ok } func (pm *basicManager) TranslatePodUID(uid types.UID) kubetypes.ResolvedPodUID { // It is safe to type convert to a resolved UID because type conversion is idempotent. if uid == "" { return kubetypes.ResolvedPodUID(uid) } pm.lock.RLock() defer pm.lock.RUnlock() if translated, ok := pm.translationByUID[kubetypes.MirrorPodUID(uid)]; ok { return translated
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/micro_time_test.go
time := MicroTime{} if err := time.Unmarshal(data); err != nil { t.Fatalf("Failed to unmarshal output: '%v': %v", input, err) } if !reflect.DeepEqual(input, time) { t.Errorf("Marshal->Unmarshal is not idempotent: '%v' vs '%v'", input, time) } } } func TestMicroTimeEqual(t *testing.T) { t1 := NewMicroTime(time.Now()) cases := []struct { name string x *MicroTime y *MicroTime
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:10 UTC 2024 - 11.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Range.java
* * <p>The intersection exists if and only if the two ranges are {@linkplain #isConnected * connected}. * * <p>The intersection operation is commutative, associative and idempotent, and its identity * element is {@link Range#all}). * * @throws IllegalArgumentException if {@code isConnected(connectedRange)} is {@code false} */ public Range<C> intersection(Range<C> connectedRange) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 27.8K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/parser_test.go
"path/filepath" "regexp" "runtime" "strings" "sync" "testing" "time" ) var ( fast = flag.Bool("fast", false, "parse package files in parallel") verify = flag.Bool("verify", false, "verify idempotent printing") src_ = flag.String("src", "parser.go", "source file to parse") skip = flag.String("skip", "", "files matching this regular expression are skipped by TestStdLib") ) func TestParse(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 14 16:30:19 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
if err := p.validateState(s); err != nil { klog.ErrorS(err, "Invalid state, please drain node and remove policy state file") return err } return nil } // Allocate call is idempotent func (p *staticPolicy) Allocate(s state.State, pod *v1.Pod, container *v1.Container) (rerr error) { // allocate the memory only for guaranteed pods if v1qos.GetPodQOS(pod) != v1.PodQOSGuaranteed { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
platforms/software/signing/src/integTest/groovy/org/gradle/plugins/signing/SigningPublicationsIntegrationSpec.groovy
} @Issue([ "https://github.com/gradle/gradle/issues/21857", "https://github.com/gradle/gradle/issues/22375" ]) def "sign publication should be idempotent"() { given: buildFile << """ apply plugin: 'maven-publish' ${keyInfo.addAsPropertiesScript()} publishing { publications {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 09 01:09:32 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/kube/krt/README.md
### Transformation constraints In order for the framework to properly handle dependencies and events, transformation functions must adhere by a few properties. Basically, Transformations must be stateless and idempotent. * Any querying of other `Collection`s _must_ be done through `krt.Fetch`. * Querying other data stores that may change is not permitted. * Querying external state (e.g. making HTTP calls) is not permitted.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 18 17:21:50 UTC 2023 - 11.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair.go
// * Migrates old versions of Kubernetes services into the atomic ipallocator model automatically // // Can be run at infrequent intervals, and is best performed on startup of the master. // Is level driven and idempotent - all valid ClusterIPs will be updated into the ipallocator // map at the end of a single execution loop if no race is encountered. // // TODO: allocate new IPs if necessary // TODO: perform repair? type Repair struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 13.8K bytes - Viewed (0)