Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for chunkSize (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java

          List<Sink> sinks = new ArrayList<>();
          for (int chunkSize = 4; chunkSize <= 32; chunkSize++) {
            for (int bufferSize = chunkSize; bufferSize <= chunkSize * 4; bufferSize += chunkSize) {
              // yes, that's a lot of sinks!
              sinks.add(new Sink(chunkSize, bufferSize));
              // For convenience, testing only with big endianness, to match DataOutputStream.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  2. cmd/streaming-signature-v4_test.go

    	}
    	// Valid test cases for each chunk line.
    	for i, tt := range testCases {
    		chunkSize, chunkSignature, err := readChunkLine(tt.reader)
    		if err != tt.expectedErr {
    			t.Errorf("Test %d: Expected %s, got %s", i+1, tt.expectedErr, err)
    		}
    		if !bytes.Equal(chunkSize, tt.chunkSize) {
    			t.Errorf("Test %d: Expected %s, got %s", i+1, string(tt.chunkSize), string(chunkSize))
    		}
    		if !bytes.Equal(chunkSignature, tt.chunkSignature) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  3. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

        headersBuilder.add(CHUNKED_BODY_HEADER)
    
        val bytesOut = Buffer()
        while (!body.exhausted()) {
          val chunkSize = minOf(body.size, maxChunkSize.toLong())
          bytesOut.writeHexadecimalUnsignedLong(chunkSize)
          bytesOut.writeUtf8("\r\n")
          bytesOut.write(body, chunkSize)
          bytesOut.writeUtf8("\r\n")
        }
        bytesOut.writeUtf8("0\r\n") // Last chunk. Trailers follow!
        this.body = bytesOut
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat May 10 11:15:14 GMT 2025
    - 7.1K bytes
    - Click Count (1)
  4. mockwebserver/src/main/kotlin/mockwebserver3/internal/RecordedRequestFactory.kt

        method = requestLine.method,
        target = requestLine.target,
        version = requestLine.version,
        url = requestUrl,
        headers = headers,
        body = body,
        bodySize = bodySize,
        chunkSizes = chunkSizes,
        failure = failure,
      )
    }
    
    internal fun decodeRequestLine(requestLine: String?): RequestLine {
      val parts =
        when {
          requestLine != null -> requestLine.split(' ', limit = 3)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 12:43:16 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/hash/SipHashFunction.java

        private long finalM = 0;
    
        SipHasher(int c, int d, long k0, long k1) {
          super(CHUNK_SIZE);
          this.c = c;
          this.d = d;
          this.v0 ^= k0;
          this.v1 ^= k1;
          this.v2 ^= k0;
          this.v3 ^= k1;
        }
    
        @Override
        protected void process(ByteBuffer buffer) {
          b += CHUNK_SIZE;
          processM(buffer.getLong());
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/hash/Murmur3_128HashFunction.java

        private static final int CHUNK_SIZE = 16;
        private static final long C1 = 0x87c37b91114253d5L;
        private static final long C2 = 0x4cf5ad432745937fL;
        private long h1;
        private long h2;
        private int length;
    
        Murmur3_128Hasher(int seed) {
          super(CHUNK_SIZE);
          this.h1 = seed;
          this.h2 = seed;
          this.length = 0;
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  7. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt

        var path: String? = recordedRequest.path
        var headers: Headers = recordedRequest.headers
        val header: String? = recordedRequest.getHeader("")
        var chunkSizes: List<Int> = recordedRequest.chunkSizes
        var bodySize: Long = recordedRequest.bodySize
        var body: Buffer = recordedRequest.body
        var utf8Body: String = recordedRequest.body.readUtf8()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.3K bytes
    - Click Count (0)
  8. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt

        response = response.wrap(),
      )
    
    internal fun mockwebserver3.RecordedRequest.unwrap(): RecordedRequest =
      RecordedRequest(
        requestLine = requestLine,
        headers = headers,
        chunkSizes = chunkSizes ?: listOf(),
        bodySize = bodySize,
        body = Buffer().write(body ?: ByteString.EMPTY),
        sequenceNumber = exchangeIndex,
        failure = failure,
        method = method,
        path = target,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.3K bytes
    - Click Count (1)
  9. docs/en/docs/reference/responses.md

    ::: fastapi.responses.FileResponse
        options:
            members:
                - chunk_size
                - charset
                - status_code
                - media_type
                - body
                - background
                - raw_headers
                - render
                - init_headers
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Feb 22 16:34:59 GMT 2026
    - 4.4K bytes
    - Click Count (0)
Back to Top