- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for WriteHeaders (0.32 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/HpackTest.kt
} @Test fun staticTableIndexedHeaders() { hpackWriter!!.writeHeaders(headerEntries(":method", "GET")) assertBytes(0x82) assertThat(hpackWriter!!.headerCount).isEqualTo(0) hpackWriter!!.writeHeaders(headerEntries(":method", "POST")) assertBytes(0x83) assertThat(hpackWriter!!.headerCount).isEqualTo(0) hpackWriter!!.writeHeaders(headerEntries(":path", "/")) assertBytes(0x84)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 38.2K bytes - Viewed (0) -
cmd/object-handlers-common.go
// If the object ETag matches with the specified ETag. writeHeaders() writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPreconditionFailed), r.URL) return true } } etagMatch := opts.PreserveETag != "" && isETagEqual(objInfo.ETag, opts.PreserveETag) vidMatch := opts.VersionID != "" && opts.VersionID == objInfo.VersionID if etagMatch && vidMatch { writeHeaders()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 14.6K bytes - Viewed (0) -
internal/config/cache/remote.go
Data []byte `json:"data,omitempty" msg:",omitempty"` // Data can container full data of the object or partial } // WriteHeaders writes the response headers for conditional requests func (oi ObjectInfo) WriteHeaders(w http.ResponseWriter, preamble, statusCode func()) { preamble() if !oi.ModTime.IsZero() { w.Header().Set(xhttp.LastModified, oi.ModTime.UTC().Format(http.TimeFormat)) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Nov 22 21:46:17 UTC 2023 - 3.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java
try (ServletOutputStream out = response.getOutputStream(); InputStream in = curlResponse.getContentAsStream()) { response.setStatus(curlResponse.getHttpStatusCode()); writeHeaders(response); final String responseContentType = curlResponse.getHeaderValue("Content-Type"); if (StringUtil.isBlank(responseContentType)) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu May 09 06:28:46 UTC 2024 - 10.8K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
path: String, ) { val responseHeaders = listOf( Header(":status", "404"), Header(":version", "HTTP/1.1"), Header("content-type", "text/plain"), ) stream.writeHeaders( responseHeaders = responseHeaders, outFinished = false, flushHeaders = false, ) val out = stream.getSink().buffer() out.writeUtf8("Not found: $path") out.close() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/BaseApiManager.java
response.setContentType(buf.toString()); writeHeaders(response); try (PrintWriter out = new PrintWriter(new OutputStreamWriter(response.getOutputStream(), enc))) { out.print(text); } catch (final IOException e) { throw new IORuntimeException(e); } } protected abstract void writeHeaders(final HttpServletResponse response);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.3K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt
assumeFalse( story === Story.MISSING, "Test stories missing, checkout git submodule", ) val newCases = mutableListOf<Case>() for (case in story.cases) { hpackWriter.writeHeaders(case.headersList) newCases += case.copy(wire = bytesOut.readByteString()) } testDecoder(story.copy(cases = newCases)) } companion object { private val RAW_DATA = arrayOf("raw-data")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
internal/http/response-recorder.go
// Always logging error responses. lrw.body.Write(p) } if err != nil { return n, err } return n, err } // Write the headers into the given buffer func (lrw *ResponseRecorder) writeHeaders(w io.Writer, statusCode int, headers http.Header) { n, _ := fmt.Fprintf(w, "%d %s\n", statusCode, http.StatusText(statusCode)) lrw.headerBytesWritten += n for k, v := range headers {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 02 00:13:19 UTC 2023 - 4.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
* @param flushHeaders true to force flush the response headers. This should be true unless the * response body exists and will be written immediately. */ @Throws(IOException::class) fun writeHeaders( responseHeaders: List<Header>, outFinished: Boolean, flushHeaders: Boolean, ) { lock.assertNotHeld() var flushHeaders = flushHeaders this.withLock {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
fun pushPromise( streamId: Int, promisedStreamId: Int, requestHeaders: List<Header>, ) { this.withLock { if (closed) throw IOException("closed") hpackWriter.writeHeaders(requestHeaders) val byteCount = hpackBuffer.size val length = minOf(maxFrameSize - 4L, byteCount).toInt() frameHeader( streamId = streamId, length = length + 4,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0)