Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for headerBlock (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(synStream.associatedStreamId).isEqualTo(-1)
        assertThat(synStream.headerBlock).isEqualTo(headerEntries("b", "banana"))
        val requestData = peer.takeFrame()
        assertArrayEquals("c3po".toByteArray(), requestData.data)
        val nextFrame = peer.takeFrame()
        assertThat(nextFrame.headerBlock).isEqualTo(headerEntries("e", "elephant"))
      }
    
      @Test fun clientCreatesStreamAndServerRepliesWithFin() {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  5. src/net/http/h2_bundle.go

    	// only waste 9 bytes anyway.
    	const maxFrameSize = 16384
    
    	first := true
    	for len(headerBlock) > 0 {
    		frag := headerBlock
    		if len(frag) > maxFrameSize {
    			frag = frag[:maxFrameSize]
    		}
    		headerBlock = headerBlock[len(frag):]
    		if err := fn(ctx, frag, first, len(headerBlock) == 0); err != nil {
    			return err
    		}
    		first = false
    	}
    	return nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
  6. testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt

    Class <org.gradle.cache.internal.btree.BTreePersistentIndexedCache$HeaderBlock> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (BTreePersistentIndexedCache.java:0)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 967.9K bytes
    - Viewed (0)
Back to top