Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 29 for setBuffer (2.45 sec)

  1. docs/smb3-features/05-rdma-smb-direct-design.md

            RdmaMemoryRegion sendRegion = bufferManager.getSendRegion(requestBuffer.remaining());
            sendRegion.getBuffer().put(requestBuffer);
            sendRegion.getBuffer().flip();
            
            try {
                // Send via RDMA
                rdmaConnection.send(sendRegion.getBuffer(), sendRegion);
                rdmaConnection.consumeSendCredit();
                
                // Receive response
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K 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
         *
         * @param buf the buffer to return to the cache
    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/internal/smb2/rdma/RdmaIntegrationTest.java

                // Test data preparation
                byte[] testData = "Test RDMA data transfer".getBytes();
                sendBuffer.getBuffer().put(testData);
                sendBuffer.getBuffer().flip();
                assertEquals(testData.length, sendBuffer.getBuffer().remaining(), "Buffer should contain test data");
    
                // Clean up
                bufferManager.releaseSendRegion(sendBuffer);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 13.8K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/main/java/jcifs/dcerpc/DcerpcHandle.java

            if (this.state == 0) {
                bind();
            }
            final byte[] inB = this.transportContext.getBufferCache().getBuffer();
            final byte[] out = this.transportContext.getBufferCache().getBuffer();
            try {
                final NdrBuffer buf = encodeMessage(msg, out);
                final int off = sendFragments(msg, out, buf);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/CriticalPerformanceTest.java

                            // Test allocation performance
                            long allocStart = System.nanoTime();
                            byte[] buffer = BufferCache.getBuffer();
                            long allocEnd = System.nanoTime();
                            totalAllocTime.addAndGet(allocEnd - allocStart);
                            allocations.incrementAndGet();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.3K bytes
    - Viewed (0)
Back to top