- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 111 for idempotent (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
// 408's are rare in practice, but some servers like HAProxy use this response code. The // spec says that we may repeat the request without modifications. Modern browsers also // repeat the request (even non-idempotent ones.) if (!client.retryOnConnectionFailure) { // The application layer has directed us not to retry the request. return null }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/time_test.go
} time := Time{} 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 TestTimeEqual(t *testing.T) { t1 := NewTime(time.Now()) cases := []struct { name string x *Time y *Time result bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:09 UTC 2024 - 9.4K bytes - Viewed (0) -
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) -
src/cmd/go/main.go
telemetry.Start() // Open the telemetry counter file so counters can be written to it. handleChdirFlag() toolchain.Select() telemetry.StartWithUpload() // Run the upload process. Opening the counter file is idempotent. flag.Usage = base.Usage flag.Parse() telemetry.Inc("go/invocations") telemetry.CountFlags("go/flag:", *flag.CommandLine) args := flag.Args() if len(args) < 1 { base.Usage() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:09:11 UTC 2024 - 10K 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) -
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) -
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) -
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/scheduler/framework/plugins/volumebinding/volume_binding.go
return framework.AsStatus(err) } logger.V(5).Info("Success binding volumes for pod", "pod", klog.KObj(pod)) return nil } // Unreserve clears assumed PV and PVC cache. // It's idempotent, and does nothing if no cache found for the given pod. func (pl *VolumeBinding) Unreserve(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeName string) { s, err := getStateData(cs) if err != nil { return
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 16.4K bytes - Viewed (0)