- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 35 for Rings (0.09 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
private val settingsListenerQueue = taskRunner.newQueue() /** User code to run in response to push promise events. */ private val pushObserver: PushObserver = builder.pushObserver // Total number of pings send and received of the corresponding types. All guarded by this. private var intervalPingsSent = 0L private var intervalPongsReceived = 0L private var degradedPingsSent = 0L private var degradedPongsReceived = 0L
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go
TLS *tls.Config // Proxier is a proxy function invoked on each request. Optional. Proxier func(*http.Request) (*url.URL, error) // PingPeriod is a period for sending SPDY Pings on the connection. // Optional. PingPeriod time.Duration // UpgradeTransport is a subtitute transport used for dialing. If set, // this field will be used instead of "TLS" and "Proxier" for connection creation.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 12.7K bytes - Viewed (0) -
src/sort/sort.go
// unstable or rely on enough different elements in each step to encode the // performed block rearrangements. See also "In-Place Merging Algorithms", // Denham Coates-Evely, Department of Computer Science, Kings College, // January 2004 and the references in there. // - Often "optimal" algorithms are optimal in the number of assignments // but Interface has only Swap as operation.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 28 16:40:32 UTC 2023 - 10.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
client.processNextFrame() taskFaker.runTasks() server.webSocket!!.pong("pong 3".encodeUtf8()) client.processNextFrame() // After 500ms the client automatically pings and the server pongs back. taskFaker.advanceUntil(ns(500L)) server.processNextFrame() // Ping. client.processNextFrame() // Pong.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
prow/config/calico.yaml
type: integer type: description: Match on a specific ICMP type. For example a value of 8 refers to ICMP Echo Request (i.e. pings). type: integer type: object ipVersion: description: IPVersion is an optional field that restricts the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 246.5K bytes - Viewed (0) -
cmd/kubelet/app/server.go
return nil, nil, err } var onHeartbeatFailure func() // Kubelet needs to be able to recover from stale http connections. // HTTP2 has a mechanism to detect broken connections by sending periodical pings. // HTTP1 only can have one persistent connection, and it will close all Idle connections // once the Kubelet heartbeat fails. However, since there are many edge cases that we can't
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
## Version 4.3.0 _2019-12-31_ * Fix: Degrade HTTP/2 connections after a timeout. When an HTTP/2 stream times out it may impact the stream only or the entire connection. With this fix OkHttp will now send HTTP/2 pings after a stream timeout to determine whether the connection should remain eligible for pooling. * Fix: Don't call `EventListener.responseHeadersStart()` or `responseBodyStart()` until bytes have
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 17 13:25:31 UTC 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
.pingInterval(Duration.ofMillis(500)) .build() // Set up the server to ignore the socket. It won't respond to pings! server.enqueue(MockResponse(socketPolicy = StallSocketAtStart)) // Make a call. It'll fail as soon as our pings detect a problem. val call = client.newCall(Request(server.url("/"))) val executeAtNanos = System.nanoTime()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
internal/grid/grid_test.go
return nil }) if !errors.Is(err, context.Canceled) { t.Error("expected context.Canceled, got", err) } } // testServerStreamNoPing will test if server and client handle no pings. func testServerStreamNoPing(t *testing.T, local, remote *Manager, inCap int) { defer testlogger.T.SetErrorTB(t)() errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt
10B36..10B38 ; disallowed # NA <reserved-10B36>..<reserved-10B38> 10B39..10B3F ; valid ; ; NV8 # 5.2 AVESTAN ABBREVIATION MARK..LARGE ONE RING OVER TWO RINGS PUNCTUATION 10B40..10B55 ; valid # 5.2 INSCRIPTIONAL PARTHIAN LETTER ALEPH..INSCRIPTIONAL PARTHIAN LETTER TAW
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Feb 10 11:25:47 UTC 2024 - 854.1K bytes - Viewed (0)