- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for expectsContinue (0.2 sec)
-
src/net/http/request.go
i := 0 for _, seg := range r.pat.segments { if seg.wild && seg.s != "" { if name == seg.s { return i } i++ } } return -1 } func (r *Request) expectsContinue() bool { return hasToken(r.Header.get("Expect"), "100-continue") } func (r *Request) wantsHttp10KeepAlive() bool { if r.ProtoMajor != 1 || r.ProtoMinor != 0 { return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0) -
src/net/http/transport.go
requestedGzip = true req.extraHeaders().Set("Accept-Encoding", "gzip") } var continueCh chan struct{} if req.ProtoAtLeast(1, 1) && req.Body != nil && req.expectsContinue() { continueCh = make(chan struct{}, 1) } if pc.t.DisableKeepAlives && !req.wantsClose() && !isProtocolSwitchHeader(req.Header) { req.extraHeaders().Set("Connection", "close") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
fun finishRequest() /** * Parses bytes of a response header from an HTTP transport. * * @param expectContinue true to return null if this is an intermediate response with a "100" * response code. Otherwise this method never returns null. */ @Throws(IOException::class) fun readResponseHeaders(expectContinue: Boolean): Response.Builder? @Throws(IOException::class) fun reportedContentLength(response: Response): Long
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
if ("100-continue".equals(request.header("Expect"), ignoreCase = true)) { exchange.flushRequest() responseBuilder = exchange.readResponseHeaders(expectContinue = true) exchange.responseHeadersStart() invokeStartEvent = false } if (responseBuilder == null) { if (requestBody.isDuplex()) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
stream!!.getSink().close() } override fun readResponseHeaders(expectContinue: Boolean): Response.Builder? { val stream = stream ?: throw IOException("stream wasn't created") val headers = stream.takeHeaders(callerIsIdle = expectContinue) val responseBuilder = readHttp2HeadersList(headers, protocol) return if (expectContinue && responseBuilder.code == HTTP_CONTINUE) { null } else {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
src/net/http/server.go
const publicErr = "400 Bad Request" fmt.Fprintf(c.rwc, "HTTP/1.1 "+publicErr+errorHeaders+publicErr) return } } // Expect 100 Continue support req := w.req if req.expectsContinue() { if req.ProtoAtLeast(1, 1) && req.ContentLength != 0 { // Wrap the Body reader with one that replies on the connection req.Body = &expectContinueReader{readCloser: req.Body, resp: w}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/SocketPolicy.kt
DISCONNECT_DURING_RESPONSE_BODY, DO_NOT_READ_REQUEST_BODY, FAIL_HANDSHAKE, SHUTDOWN_INPUT_AT_END, SHUTDOWN_OUTPUT_AT_END, STALL_SOCKET_AT_START, NO_RESPONSE, RESET_STREAM_AT_START, EXPECT_CONTINUE, CONTINUE_ALWAYS,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
} result.settings(settings) result.status = status result.headers(headers) result.trailers(trailers) result.socketPolicy = when (socketPolicy) { SocketPolicy.EXPECT_CONTINUE, SocketPolicy.CONTINUE_ALWAYS -> { result.add100Continue() KeepOpen } SocketPolicy.UPGRADE_TO_SSL_AT_END -> { result.inTunnel() KeepOpen }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
} fun responseHeadersStart() { eventListener.responseHeadersStart(call) } @Throws(IOException::class) fun readResponseHeaders(expectContinue: Boolean): Response.Builder? { try { val result = codec.readResponseHeaders(expectContinue) result?.initExchange(this) return result } catch (e: IOException) { eventListener.responseFailed(call, e) trackFailure(e)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
expectContinue: false, }, { name: "test List with filter returning two items, more pages possible", prefix: "/pods", pred: storage.SelectionPredicate{ Field: fields.OneTermEqualSelector("metadata.name", "bar"), Label: labels.Everything(), Limit: 2, }, expectContinue: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0)