- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 69 for idempotent (2.16 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) -
pkg/registry/flowcontrol/rest/storage_flowcontrol.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 12.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/MultipartReaderTest.kt
assertThat(partEfg.headers).isEqualTo(headersOf("Content-ID", "efg")) assertThat(partEfg.body.readUtf8()).isEqualTo("efgh") assertThat(parts.nextPart()).isNull() } @Test fun `no more parts is idempotent`() { val multipart = """ |--simple boundary | |abcd |--simple boundary-- | |efgh |--simple boundary-- """.trimMargin()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13.8K bytes - Viewed (0) -
internal/s3select/sql/parser.go
ObjectWildcard bool `parser:"| @\".*\""` // .* form ArrayWildcard bool `parser:"| @\"[*]\""` // [*] form } // JSONPath represents a keypath. // Instances should be treated idempotent and not change once created. type JSONPath struct { BaseKey *Identifier `parser:" @@"` PathExpr []*JSONPathElement `parser:"(@@)*"` // Cached values: pathString string
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 12.9K bytes - Viewed (0) -
src/net/http/fcgi/child.go
} } func (c *child) cleanUp() { for _, req := range c.requests { if req.pw != nil { // race with call to Close in c.serveRequest doesn't matter because // Pipe(Reader|Writer).Close are idempotent req.pw.CloseWithError(ErrConnClosed) } } } // Serve accepts incoming FastCGI connections on the listener l, creating a new // goroutine for each. The goroutine reads requests and then calls handler
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.3K 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) -
pkg/volume/util/fsquota/project.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 10.6K 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)