Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 42 for Chunk (0.02 sec)

  1. guava/src/com/google/common/hash/SipHashFunction.java

        private long v2 = 0x6c7967656e657261L;
        private long v3 = 0x7465646279746573L;
    
        // The number of bytes in the input.
        private long b = 0;
    
        // The final 64-bit chunk includes the last 0 through 7 bytes of m followed by null bytes
        // and ending with a byte encoding the positive integer b mod 256.
        private long finalM = 0;
    
        SipHasher(int c, int d, long k0, long k1) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 5.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java

        }
    
        // ensures that the number of invocations looks sane
        void assertInvariants(int expectedBytes) {
          // we should have seen as many bytes as the next multiple of chunk after expectedBytes - 1
          assertEquals(out.toByteArray().length, ceilToMultiple(expectedBytes, chunkSize));
          assertEquals(expectedBytes / chunkSize, processCalled);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  3. .github/workflows/update-rbe.yml

        - name: Update the RBE Configs
          run: |
            function map() {
              # The "digest" that allows us to pull an image is not the digest as
              # returned by the API, but a sha256sum of the entire chunk of image
              # metadata. gcr.io helpfully includes it in the header of the response
              # as docker-content-digest: sha256:[digest]. Note we use egrep to
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:40:10 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

            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.toMockResponseBody()
        }
    
        /**
         * Sets the response body to the UTF-8 encoded bytes of [body],
         * chunked every [maxChunkSize] bytes.
         */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/EventListenerTest.kt

      }
    
      private inner class NonCompletingRequestBody : RequestBody() {
        private val chunk: ByteArray? = ByteArray(1024 * 1024)
        var ioe: IOException? = null
    
        override fun contentType(): MediaType? {
          return "text/plain".toMediaType()
        }
    
        override fun contentLength(): Long {
          return chunk!!.size * 8L
        }
    
        override fun writeTo(sink: BufferedSink) {
          try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  6. cmd/test-utils_test.go

    	"Content-Type":  true,
    	"Content-Md5":   true,
    	"User-Agent":    true,
    }
    
    // calculateSignedChunkLength - calculates the length of chunk metadata
    func calculateSignedChunkLength(chunkDataSize int64) int64 {
    	return int64(len(fmt.Sprintf("%x", chunkDataSize))) +
    		17 + // ";chunk-signature="
    		64 + // e.g. "f2ca1bb6c7e907d06dafe4687e579fce76b37e4e93b7605022da52e6ccc26fd2"
    		2 + // CRLF
    		chunkDataSize +
    		2 // CRLF
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  7. src/bytes/bytes.go

    		chunkMax = chunkLimit / len(b) * len(b)
    		if chunkMax == 0 {
    			chunkMax = len(b)
    		}
    	}
    	nb := bytealg.MakeNoZero(n)[:n:n]
    	bp := copy(nb, b)
    	for bp < n {
    		chunk := min(bp, chunkMax)
    		bp += copy(nb[bp:], nb[:chunk])
    	}
    	return nb
    }
    
    // ToUpper returns a copy of the byte slice s with all Unicode letters mapped to
    // their upper case.
    func ToUpper(s []byte) []byte {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 35.6K bytes
    - Viewed (0)
  8. cmd/object-handlers_test.go

    			accessKey:          credentials.AccessKey,
    			secretKey:          credentials.SecretKey,
    			shouldPass:         false,
    			fault:              malformedEncoding,
    		},
    		// Test case - 8
    		// Chunk with shorter than advertised chunk data.
    		{
    			bucketName:         bucketName,
    			objectName:         objectName,
    			data:               oneKData,
    			dataLen:            1024,
    			chunkSize:          1024,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/Splitter.java

       * {@link Splitter}.
       *
       * @since 10.0
       */
      public static final class MapSplitter {
        private static final String INVALID_ENTRY_MESSAGE = "Chunk [%s] is not a valid entry";
        private final Splitter outerSplitter;
        private final Splitter entrySplitter;
    
        private MapSplitter(Splitter outerSplitter, Splitter entrySplitter) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 21:14:05 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  10. src/bufio/bufio.go

    	*b = Reader{
    		buf:          buf,
    		rd:           r,
    		lastByte:     -1,
    		lastRuneSize: -1,
    	}
    }
    
    var errNegativeRead = errors.New("bufio: reader returned negative count from Read")
    
    // fill reads a new chunk into the buffer.
    func (b *Reader) fill() {
    	// Slide existing data to beginning.
    	if b.r > 0 {
    		copy(b.buf, b.buf[b.r:b.w])
    		b.w -= b.r
    		b.r = 0
    	}
    
    	if b.w >= len(b.buf) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
Back to top