- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 29 for setBuffer (2.45 sec)
-
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) -
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) -
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) -
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) -
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) -
src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.7K bytes - Viewed (0) -
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) -
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) -
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) -
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)