Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for getBuffers (0.07 sec)

  1. src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java

            // When - Get a buffer
            byte[] buffer = BufferCache.getBuffer();
    
            // Then - Buffer should have expected size
            assertNotNull(buffer, "Buffer should not be null");
            assertEquals(SmbComTransaction.TRANSACTION_BUF_SIZE, buffer.length, "Buffer should have TRANSACTION_BUF_SIZE");
    
            // The validation in getBuffer() ensures size is within bounds (0 < size <= 1MB)
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/BufferCache.java

            }
    
            return new byte[bufferSize];
        }
    
        static void getBuffers(final SmbComTransaction req, final SmbComTransactionResponse rsp) {
            req.txn_buf = getBuffer();
            rsp.txn_buf = getBuffer();
        }
    
        /**
         * Returns a buffer to the cache for reuse.
         *
         * Performance: O(1) operation with size limit check
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb/BufferCacheImplTest.java

            verify(cfg, times(1)).getMaximumBufferSize();
            verifyNoMoreInteractions(cfg);
    
            // When cache is empty, getBuffer allocates a new buffer with configured size
            byte[] buf = impl.getBuffer();
            assertNotNull(buf, "getBuffer should never return null");
            assertEquals(5, buf.length, "Newly allocated buffer length should match config maximum size");
        }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  4. src/test/java/jcifs/BufferCacheTest.java

                cache.getBuffer();
                cache.releaseBuffer(new byte[1024]);
            }, "All BufferCache interface methods should be callable");
        }
    
        @Test
        @DisplayName("getBuffer should return non-null byte array")
        void testGetBufferContract() {
            // Given
            byte[] expectedBuffer = new byte[1024];
            when(mockBufferCache.getBuffer()).thenReturn(expectedBuffer);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/BufferCacheImpl.java

            this.cache = new Object[maxBuffers];
            this.bufferSize = maxSize;
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.BufferCache#getBuffer()
         */
        @Override
        public byte[] getBuffer() {
            synchronized (this.cache) {
                byte[] buf;
    
                if (this.freeBuffers > 0) {
                    for (int i = 0; i < this.cache.length; i++) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/rdma/RdmaMemoryRegion.java

        }
    
        /**
         * Get the underlying buffer
         *
         * @return memory buffer
         * @throws IllegalStateException if memory region has been invalidated
         */
        public ByteBuffer getBuffer() {
            if (!valid) {
                throw new IllegalStateException("Memory region invalidated");
            }
            return buffer;
        }
    
        /**
         * Get local memory key
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  7. guava-tests/benchmark/com/google/common/io/BaseEncodingBenchmark.java

          OutputStream encodingStream = encoding.encoding.encodingStream(target);
          encodingStream.write(encodingInputs[i & INPUTS_MASK]);
          encodingStream.close();
          tmp += target.getBuffer().length();
        }
        return tmp;
      }
    
      @Benchmark
      public int decodingStream(int reps) throws IOException {
        int tmp = 0;
        byte[] target = new byte[n];
        for (int i = 0; i < reps; i++) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

            if (minSize <= sendBufferSize) {
                RdmaMemoryRegion region = availableSendRegions.poll();
                if (region != null) {
                    region.getBuffer().clear();
                    return region;
                }
            }
    
            // Allocate new buffer
            ByteBuffer buffer = ByteBuffer.allocateDirect(Math.max(minSize, sendBufferSize));
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  9. src/main/java/jcifs/BufferCache.java

     */
    public interface BufferCache {
    
        /**
         * Gets a buffer from the cache or creates a new one if the cache is empty.
         *
         * @return a buffer from the cache, or a new one
         */
        byte[] getBuffer();
    
        /**
         * Return a buffer to the cache
         *
         * @param buf the buffer to return to the cache for reuse
         */
        void releaseBuffer(byte[] buf);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProviderTest.java

            RdmaMemoryRegion region = provider.registerMemory(buffer, access);
            assertNotNull(region, "Memory region should not be null");
            assertEquals(buffer, region.getBuffer(), "Buffer should match");
            assertEquals(1024, region.getSize(), "Size should match buffer size");
            assertTrue(region.hasAccess(RdmaAccess.LOCAL_READ), "Should have local read access");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 4.2K bytes
    - Viewed (0)
Back to top