Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for headerBlock (0.21 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. 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)
  4. 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)
  5. 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)
  6. 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)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

          }
        }
    
        override fun headers(
          inFinished: Boolean,
          streamId: Int,
          associatedStreamId: Int,
          headerBlock: List<Header>,
        ) {
          if (pushedStream(streamId)) {
            pushHeadersLater(streamId, headerBlock, inFinished)
            return
          }
          val stream: Http2Stream?
          ******@****.***ck {
            stream = getStream(streamId)
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
Back to top