Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 761 - 770 of 960 for Buffers (0.08 seconds)

  1. cmd/callhome.go

    	_, err := globalSubnetConfig.Upload(url, filename, createHealthJSONGzip(ctx, healthInfo))
    	return err
    }
    
    func createHealthJSONGzip(ctx context.Context, healthInfo madmin.HealthInfo) []byte {
    	var b bytes.Buffer
    	gzWriter := gzip.NewWriter(&b)
    
    	header := struct {
    		Version string `json:"version"`
    	}{Version: healthInfo.Version}
    
    	enc := json.NewEncoder(gzWriter)
    	if e := enc.Encode(header); e != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/cache/Striped64.java

       */
      abstract long fn(long currentValue, long newValue);
    
      /**
       * Handles cases of updates involving initialization, resizing, creating new Cells, and/or
       * contention. See above for explanation. This method suffers the usual non-modularity problems of
       * optimistic retry code, relying on rechecked sets of reads.
       *
       * @param x the value
       * @param hc the hash code holder
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 15 22:17:15 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/Smb2CancelRequest.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/SmbTreeHandleImplTest.java

            assertFalse(handle.isSameTree(other));
            verify(treeConnection, times(2)).isSame(otherConn);
        }
    
        @Test
        @DisplayName("Buffer sizes and signing flags from negotiate response")
        void bufferSizesAndSigning() throws Exception {
            // Validate buffer sizes and signing flag are read from negotiate response
            SmbNegotiationResponse nego = mock(SmbNegotiationResponse.class);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  5. src/main/java/jcifs/internal/smb2/Smb2EchoRequest.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/smb2/session/Smb2LogoffRequest.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb2/create/Smb2CloseRequest.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. benchmarks/src/main/java/org/elasticsearch/benchmark/routing/allocation/AllocationBenchmark.java

        // we cannot use individual @Params as some will lead to invalid combinations which do not let the benchmark terminate. JMH offers no
        // support to constrain the combinations of benchmark parameters and we do not want to rely on OptionsBuilder as each benchmark would
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Apr 13 08:33:41 GMT 2021
    - 6.7K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

            // This check is imperfect: it doesn't tell us whether a handshake will succeed, just
            // that it will almost certainly fail because the proxy has sent unexpected data.
            if (!socket.source.buffer.exhausted() || !socket.sink.buffer.exhausted()) {
              throw IOException("TLS tunnel buffered too many bytes!")
            }
    
            call.eventListener.secureConnectStart(call)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
  10. src/test/java/jcifs/smb/SpnegoContextTest.java

        }
    
        @Test
        @DisplayName("initSecContext with null buffer and non-zero len throws NPE")
        void testInitSecContextNullBufferNonZeroLen() throws Exception {
            SpnegoContext ctx = newContext();
            // A null buffer with non-zero len leads to NPE while slicing input
            assertThrows(NullPointerException.class, () -> ctx.initSecContext(null, 0, 1));
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.3K bytes
    - Click Count (0)
Back to Top