Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 821 for buffered (0.43 sec)

  1. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

         *
         * @param buffer buffer to release
         */
        public void releaseBuffer(ByteBuffer buffer) {
            // For direct buffers, we rely on GC
            // Could implement a more sophisticated buffer pool here
        }
    
        /**
         * Clean up all pooled regions
         *
         * This method should be called when shutting down to
         * release all resources.
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  2. docs/smb3-features/05-rdma-smb-direct-design.md

            
            // Pre-allocate buffer pool
            initializeBufferPool();
        }
        
        private void initializeBufferPool() {
            // Allocate send buffers
            for (int i = 0; i < initialSendBuffers; i++) {
                try {
                    ByteBuffer buffer = ByteBuffer.allocateDirect(sendBufferSize);
                    RdmaMemoryRegion region = provider.registerMemory(buffer,
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/BufferCache.java

     */
    
    package jcifs.smb1.smb1;
    
    import jcifs.smb1.Config;
    
    /**
     * Buffer cache implementation for SMB1 protocol operations.
     * Manages a pool of byte buffers to reduce garbage collection overhead.
     *
     * Performance optimizations:
     * - Uses ConcurrentLinkedQueue for O(1) operations
     * - Lock-free operations for better concurrency
     * - Proper buffer validation and limits
     */
    public class BufferCache {
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/MultipartBodyTest.kt

        assertThat(body.isOneShot()).isEqualTo(false)
    
        val buffer = Buffer()
        body.writeTo(buffer)
        assertThat(body.contentLength()).isEqualTo(buffer.size)
        assertThat(buffer.readUtf8()).isEqualTo(expected)
    
        val buffer2 = Buffer()
        body.writeTo(buffer2)
        assertThat(body.contentLength()).isEqualTo(buffer2.size)
        assertThat(buffer2.readUtf8()).isEqualTo(expected)
      }
    
      @Test
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb1/smb1/TransWaitNamedPipeResponseTest.java

            assertTrue(str.startsWith("TransWaitNamedPipeResponse["), "toString should begin with class name");
        }
    
        /**
         * Verify that all methods can be called with null buffers without
         * throwing exceptions. This test ensures robustness of the implementation.
         */
        @Test
        void methodsHandleNullBuffersGracefully() {
            // Arrange
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/dfs/DfsReferralRequestBuffer.java

    package jcifs.internal.dfs;
    
    import java.nio.charset.StandardCharsets;
    
    import jcifs.Encodable;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * DFS (Distributed File System) referral request buffer encoder.
     * Creates encoded request buffers for DFS referral requests, specifying the maximum
     * referral level and target path for which DFS resolution is requested.
     *
     * @author mbechler
     */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/TopKSelector.java

        T pivotValue = uncheckedCastNullableTToT(buffer[pivotIndex]);
        buffer[pivotIndex] = buffer[right];
    
        int pivotNewIndex = left;
        for (int i = left; i < right; i++) {
          if (comparator.compare(uncheckedCastNullableTToT(buffer[i]), pivotValue) < 0) {
            swap(pivotNewIndex, i);
            pivotNewIndex++;
          }
        }
        buffer[right] = buffer[pivotNewIndex];
        buffer[pivotNewIndex] = pivotValue;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 31 13:15:26 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt

        val buffer = Buffer()
        buffer.write(byteString)
        deflate(buffer)
        return buffer.readByteString()
      }
    
      private fun MessageInflater.inflate(byteString: ByteString): ByteString {
        val buffer = Buffer()
        buffer.write(byteString)
        inflate(buffer)
        return buffer.readByteString()
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/io/Smb2ReadRequest.java

         *            the configuration to use for this request
         * @param fileId
         *            the file ID to read from
         * @param outputBuffer
         *            the buffer to read data into
         * @param outputBufferOffset
         *            the offset in the output buffer to start writing data
         */
        public Smb2ReadRequest(final Configuration config, final byte[] fileId, final byte[] outputBuffer, final int outputBufferOffset) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/SmbNegotiationTest.java

            assertSame(testResponseBuffer, negotiationWithNullResponse.getResponseRaw());
        }
    
        @Test
        @DisplayName("Constructor with null buffers should work")
        void testConstructorWithNullBuffers() {
            // Test that null buffers are handled properly
            SmbNegotiation negotiationWithNullBuffers = new SmbNegotiation(mockRequest, mockResponse, null, null);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.9K bytes
    - Viewed (0)
Back to top