Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for headerBlock (0.2 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        frame.write(headerBlock, headerBlock.size / 2)
        frame.write(padding)
    
        // Write the continuation frame, specifying no more frames are expected.
        writeMedium(frame, headerBlock.size.toInt())
        frame.writeByte(Http2.TYPE_CONTINUATION)
        frame.writeByte(FLAG_END_HEADERS)
        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.writeAll(headerBlock)
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/HpackTest.kt

        val value = CharArray(4096)
        Arrays.fill(value, '!')
        val headerBlock = headerEntries("cookie", String(value))
        hpackWriter!!.writeHeaders(headerBlock)
        bytesIn.writeAll(bytesOut)
        hpackReader!!.readHeaders()
        assertThat(hpackReader!!.headerCount).isEqualTo(0)
        assertThat(hpackReader!!.getAndResetHeaderList()).isEqualTo(headerBlock)
      }
    
      /**
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

          inFinished: Boolean,
          streamId: Int,
          associatedStreamId: Int,
          headerBlock: List<Header>,
        ) {
          check(type == -1)
          this.type = Http2.TYPE_HEADERS
          this.inFinished = inFinished
          this.streamId = streamId
          this.associatedStreamId = associatedStreamId
          this.headerBlock = headerBlock
        }
    
        override fun data(
          inFinished: Boolean,
          streamId: Int,
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  4. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/BTreePersistentIndexedCache.java

            BlockStore.Factory factory = new BlockStore.Factory() {
                @Override
                public Object create(Class<? extends BlockPayload> type) {
                    if (type == HeaderBlock.class) {
                        return new HeaderBlock();
                    }
                    if (type == IndexBlock.class) {
                        return new IndexBlock();
                    }
                    if (type == DataBlock.class) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 26.5K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/HeadersRequestTest.kt

      @Test fun readNameValueBlockDropsForbiddenHeadersHttp2() {
        val headerBlock =
          headersOf(
            ":status",
            "200 OK",
            ":version",
            "HTTP/1.1",
            "connection",
            "close",
          )
        val request = Request.Builder().url("http://square.com/").build()
        val response = readHttp2HeadersList(headerBlock, Protocol.HTTP_2).request(request).build()
        val headers = response.headers
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt

        streamId: Int,
        source: BufferedSource,
        length: Int,
      ) {
        fail("")
      }
    
      override fun headers(
        inFinished: Boolean,
        streamId: Int,
        associatedStreamId: Int,
        headerBlock: List<Header>,
      ) {
        fail("")
      }
    
      override fun rstStream(
        streamId: Int,
        errorCode: ErrorCode,
      ) {
        fail("")
      }
    
      override fun settings(
        clearPrevious: Boolean,
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

        fun readHttp2HeadersList(
          headerBlock: Headers,
          protocol: Protocol,
        ): Response.Builder {
          var statusLine: StatusLine? = null
          val headersBuilder = Headers.Builder()
          for (i in 0 until headerBlock.size) {
            val name = headerBlock.name(i)
            val value = headerBlock.value(i)
            if (name == RESPONSE_STATUS_UTF8) {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

          headerBlockLength -= 5 // account for above read.
        }
        headerBlockLength = lengthWithoutPadding(headerBlockLength, flags, padding)
        val headerBlock = readHeaderBlock(headerBlockLength, padding, flags, streamId)
    
        handler.headers(endStream, streamId, -1, headerBlock)
      }
    
      @Throws(IOException::class)
      private fun readHeaderBlock(
        length: Int,
        padding: Int,
        flags: Int,
        streamId: Int,
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Hpack.kt

              smallestHeaderTableSizeSetting = Integer.MAX_VALUE
              writeInt(maxDynamicTableByteCount, PREFIX_5_BITS, 0x20)
            }
    
            for (i in 0 until headerBlock.size) {
              val header = headerBlock[i]
              val name = header.name.toAsciiLowercase()
              val value = header.value
              var headerIndex = -1
              var headerNameIndex = -1
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

        }
      }
    
      @Throws(IOException::class)
      fun headers(
        outFinished: Boolean,
        streamId: Int,
        headerBlock: List<Header>,
      ) {
        this.withLock {
          if (closed) throw IOException("closed")
          hpackWriter.writeHeaders(headerBlock)
    
          val byteCount = hpackBuffer.size
          val length = minOf(maxFrameSize.toLong(), byteCount)
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
Back to top