Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for WriteHeaders (0.62 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

        body.writeTo(responseBodySink)
        responseBodySink.emit()
    
        if ("chunked".equals(response.headers["Transfer-Encoding"], ignoreCase = true)) {
          writeHeaders(sink, response.trailers)
        }
      }
    
      @Throws(IOException::class)
      private fun writeHeaders(
        sink: BufferedSink,
        headers: Headers,
      ) {
        for ((name, value) in headers) {
          sink.writeUtf8(name)
          sink.writeUtf8(": ")
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

          }
        }
    
        if (flushHeaders) {
          writer.flush()
        }
    
        return stream
      }
    
      @Throws(IOException::class)
      internal fun writeHeaders(
        streamId: Int,
        outFinished: Boolean,
        alternating: List<Header>,
      ) {
        writer.headers(outFinished, streamId, alternating)
      }
    
      /**
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Hpack.kt

           *
           * http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-12#section-6.2.3
           */
          @Throws(IOException::class)
          fun writeHeaders(headerBlock: List<Header>) {
            if (emitDynamicTableSizeUpdate) {
              if (smallestHeaderTableSizeSetting < maxDynamicTableByteCount) {
                // Multiple dynamic table size updates!
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

          assertThat(expected.message).isEqualTo("reserved bit set: -2147483645")
        }
      }
    
      private fun literalHeaders(sentHeaders: List<Header>): Buffer {
        val out = Buffer()
        Hpack.Writer(out = out).writeHeaders(sentHeaders)
        return out
      }
    
      private fun sendHeaderFrames(
        outFinished: Boolean,
        headers: List<Header>,
      ): Buffer {
        val out = Buffer()
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
Back to top