Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 137 for burgers (0.21 seconds)

  1. guava/src/com/google/common/io/ByteStreams.java

        // Starting with an 8k buffer, double the size of each successive buffer. Smaller buffers
        // quadruple in size until they reach 8k, to minimize the number of small reads for longer
        // streams. Buffers are retained in a deque so that there's no copying between buffers while
        // reading and so all of the bytes in each new allocated buffer are available for reading from
        // the stream.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 31.1K bytes
    - Click Count (0)
  2. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt

    package okhttp3.tls.internal.der
    
    import java.math.BigInteger
    import okio.Buffer
    import okio.BufferedSink
    import okio.ByteString
    
    internal class DerWriter(
      sink: BufferedSink,
    ) {
      /** A stack of buffers that will be concatenated once we know the length of each. */
      private val stack = mutableListOf(sink)
    
      /** Type hints scoped to the call stack, manipulated with [pushTypeHint] and [popTypeHint]. */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  3. internal/http/dial_linux.go

    			fd := int(fdPtr)
    
    			_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_REUSEADDR, 1)
    
    			_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_REUSEPORT, 1)
    
    			// Enable custom socket send/recv buffers.
    			if opts.SendBufSize > 0 {
    				_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_SNDBUF, opts.SendBufSize)
    			}
    
    			if opts.RecvBufSize > 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jul 23 10:53:03 GMT 2024
    - 5K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/BufferCacheImplTest.java

            // Subsequent get should still work
            assertEquals(4, impl.getBuffer().length);
        }
    
        // Capacity behavior: when full, additional releases are dropped; only cached buffers are returned
        @Test
        @DisplayName("Cache capacity respected: extra releases dropped; retrieval order by first free slot")
        void cacheCapacityAndRetrievalOrder() {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  5. cmd/dummy-data-generator_test.go

    		n2, e2 := io.ReadFull(r2, b2)
    		if n1 != n2 {
    			return false, fmt.Sprintf("Read %d != %d bytes from the readers", n1, n2)
    		}
    		if !bytes.Equal(b1[:n1], b2[:n2]) {
    			return false, fmt.Sprintf("After reading %d equal buffers (32Kib each), we got the following two strings:\n%v\n%v\n",
    				i, b1, b2)
    		}
    		// Check if stream has ended
    		if (e1 == io.ErrUnexpectedEOF && e2 == io.ErrUnexpectedEOF) || (e1 == io.EOF && e2 == io.EOF) {
    			break
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  6. src/test/java/jcifs/internal/smb2/create/CreateContextRequestTest.java

                // Encode to different buffers
                int result1 = request.encode(buffer1, 0);
                int result2 = request.encode(buffer2, 50);
    
                // Both should succeed independently
                assertTrue(result1 > 0);
                assertTrue(result2 > 0);
    
                // Verify headers in both buffers
                for (int i = 0; i < 8; i++) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  7. docs/works_with_okhttp.md

     * [Stetho](https://github.com/facebook/stetho): Stetho is a debug bridge for Android applications.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 26 07:59:38 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  8. docs/metrics/prometheus/list.md

    | `minio_node_mem_available_max` | Available memory on the node (max).       |
    | `minio_node_mem_buffers`       | Buffers memory on the node.               |
    | `minio_node_mem_buffers_avg`   | Buffers memory on the node (avg).         |
    | `minio_node_mem_buffers_max`   | Buffers memory on the node (max).         |
    | `minio_node_mem_cache`         | Cache memory on the node.                 |
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 43.4K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/helper/SuggestHelper.java

                ThreadUtil.sleep(interval);
            }).then(response -> {
                refresh();
                success.accept(true);
            }).error(t -> error.accept(t));
        }
    
        /**
         * Purges old suggest data from documents.
         *
         * @param time The timestamp to purge data before.
         */
        public void purgeDocumentSuggest(final LocalDateTime time) {
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 22.3K bytes
    - Click Count (0)
  10. src/main/java/jcifs/pac/Pac.java

            }
    
            if (this.serverSignature == null || this.kdcSignature == null || this.logonInfo == null) {
                throw new PACDecodingException("Missing required buffers");
            }
    
            if (log.isTraceEnabled()) {
                log.trace(String.format("Checksum data %s type %d signature %s", Hexdump.toHexString(checksumData),
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 7.3K bytes
    - Click Count (0)
Back to Top