- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 75 for canceling (0.21 sec)
-
src/net/http/transport.go
// HTTP/2 requests are not cancelable with CancelRequest, // so we have no further need for the request context. // // On the HTTP/1 path, roundTrip takes responsibility for // canceling the context after the response body is read. cancel(errRequestDone) } resp.Request = origReq return resp, nil } // Failed. Clean up and determine whether to retry.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} if z.SinglePool() { return errInvalidArgument } z.poolMetaMutex.Lock() defer z.poolMetaMutex.Unlock() fn := z.decommissionCancelers[idx] if fn == nil { // canceling a decommission before it started return an error. return errDecommissionNotStarted } defer fn() // cancel any active thread. if z.poolMeta.DecommissionCancel(idx) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 14:30:43 UTC 2024 - 41.5K bytes - Viewed (1) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
} notAcceptingNewRequestCh := s.lifecycleSignals.NotAcceptingNewRequest drainedCh := s.lifecycleSignals.InFlightRequestsDrained // Canceling the parent context does not immediately cancel the HTTP server. // We only inherit context values here and deal with cancellation ourselves. stopHTTPServerCtx, stopHTTPServer := context.WithCancelCause(context.WithoutCancel(ctx))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
if tc.expectedCipher != hs.suite.id { t.Errorf("unexpected cipher chosen: want %d, got %d", tc.expectedCipher, hs.suite.id) } }) } } // TestServerHandshakeContextCancellation tests that canceling // the context given to the server side conn.HandshakeContext // interrupts the in-progress handshake. func TestServerHandshakeContextCancellation(t *testing.T) { c, s := localPipe(t)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0) -
src/crypto/tls/conn.go
// protocol if it has not yet been run. // // Most uses of this package need not call Handshake explicitly: the // first [Conn.Read] or [Conn.Write] will call it automatically. // // For control over canceling or setting a timeout on a handshake, use // [Conn.HandshakeContext] or the [Dialer]'s DialContext method instead. // // In order to avoid denial of service attacks, the maximum RSA key size allowed
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0) -
src/os/exec/exec.go
// (Perhaps c.Wait hadn't been called, or perhaps it happened to race with // c.ctx being canceled.) Don't inject a needless error. } else { err = wrappedError{ prefix: "exec: canceling Cmd", err: interruptErr, } } } if c.WaitDelay == 0 { resultc <- ctxResult{err: err} return } timer := time.NewTimer(c.WaitDelay) select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
responseDequeuedLatches[responseIndex].countDown() requestCanceledLatches[responseIndex].await() responseIndex++ return response } } /** Make a call and canceling it as soon as it's accepted by the server. */ private fun callAndCancel( expectedSequenceNumber: Int, responseDequeuedLatch: CountDownLatch?, requestCanceledLatch: CountDownLatch?, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
src/os/exec/exec_test.go
// Panic instead of calling t.Fatal so that we get a goroutine dump. // We want to know exactly what the os/exec goroutines got stuck on. debug.SetTraceback("system") panic("canceling context did not stop program") } // Back off exponentially (up to 1-second sleeps) to give the OS time to // terminate the process. delay *= 2 if delay > 1*time.Second {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 48.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertArrayEquals("fghi".toByteArray(), data2.data) } /** * Confirm that we account for discarded data frames. It's possible that data frames are in-flight * just prior to us canceling a stream. */ @Test fun discardedDataFramesAreCounted() { // Write the mocking script. peer.sendFrame().settings(Settings()) peer.acceptFrame() // ACK peer.acceptFrame() // SYN_STREAM 3
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
src/crypto/tls/handshake_client_test.go
serverConfig.Certificates[0].SignedCertificateTimestamps, ccs.SignedCertificateTimestamps) } } // TestClientHandshakeContextCancellation tests that canceling // the context given to the client side conn.HandshakeContext // interrupts the in-progress handshake. func TestClientHandshakeContextCancellation(t *testing.T) { c, s := localPipe(t)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0)