- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 15 for RdmaMemoryRegion (0.09 seconds)
-
src/main/java/jcifs/internal/smb2/rdma/RdmaMemoryRegion.java
* * Represents a registered memory region that can be used for * RDMA operations. The memory region contains a buffer, access * permissions, and keys for local and remote access. */ public abstract class RdmaMemoryRegion implements AutoCloseable { /** Memory buffer for RDMA operations */ protected final ByteBuffer buffer; /** Access permissions for this memory region */ protected final EnumSet<RdmaAccess> accessFlags;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 4.3K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaBufferManagerTest.java
public void testReleaseSendRegion() throws Exception { RdmaMemoryRegion region = bufferManager.getSendRegion(1024); assertNotNull(region); // Release should not throw exception assertDoesNotThrow(() -> bufferManager.releaseSendRegion(region)); } @Test public void testGetReceiveRegion() throws Exception { RdmaMemoryRegion region = bufferManager.getReceiveRegion();
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 7.1K bytes - Click Count (0) -
docs/smb3-features/05-rdma-smb-direct-design.md
*/ public abstract void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException; /** * Receive data using RDMA */ public abstract ByteBuffer receive(int timeout) throws IOException; /** * Perform RDMA read operation */ public abstract void rdmaRead(RdmaMemoryRegion localRegion, long remoteAddress,Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 35.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java
private static final Logger log = LoggerFactory.getLogger(RdmaBufferManager.class); private final RdmaProvider provider; private final ConcurrentLinkedQueue<RdmaMemoryRegion> availableSendRegions; private final ConcurrentLinkedQueue<RdmaMemoryRegion> availableReceiveRegions; private final AtomicLong totalAllocated; private final AtomicLong totalReleased; // Buffer pool configurationCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 8.7K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaWorkRequest.java
/** RDMA read operation */ READ, /** RDMA write operation */ WRITE } private final long requestId; private final RequestType type; private final RdmaMemoryRegion memoryRegion; private volatile boolean completed; private volatile Exception error; /** * Create new RDMA work request * * @param requestId unique request identifierCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 3.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaIntegrationTest.java
// Test basic buffer allocation RdmaMemoryRegion sendRegion = bufferManager.getSendRegion(4096); assertNotNull(sendRegion, "Send region should not be null"); assertTrue(sendRegion.getSize() >= 4096, "Send region should be at least 4KB"); assertNotNull(sendRegion.getBuffer(), "Send region buffer should not be null"); RdmaMemoryRegion recvRegion = bufferManager.getReceiveRegion();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 13.8K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java
} } @Override public void rdmaRead(RdmaMemoryRegion localRegion, long remoteAddress, int remoteKey, int length) throws IOException { // TCP fallback doesn't support real RDMA read throw new UnsupportedOperationException("RDMA read not supported by TCP fallback"); } @OverrideCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 8.8K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java
import java.net.InetSocketAddress; import java.nio.ByteBuffer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.internal.smb2.rdma.RdmaConnection; import jcifs.internal.smb2.rdma.RdmaMemoryRegion; import jcifs.internal.smb2.rdma.RdmaNegotiateRequest; import jcifs.internal.smb2.rdma.RdmaNegotiateResponse; /** * DiSNI RDMA connection implementation. *
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 10.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java
* * @param data data buffer to send * @param region registered memory region for the data * @throws IOException if send fails */ public abstract void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException; /** * Receive data using RDMA * * @param timeout timeout in milliseconds * @return received data buffer, or null if timeoutCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 8.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpMemoryRegion.java
import jcifs.internal.smb2.rdma.RdmaAccess; import jcifs.internal.smb2.rdma.RdmaMemoryRegion; /** * TCP memory region implementation. * * For TCP fallback, memory regions are just wrappers around * ByteBuffers since no real RDMA registration is needed. */ public class TcpMemoryRegion extends RdmaMemoryRegion { private static final AtomicInteger keyGenerator = new AtomicInteger(1000); /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 2.1K bytes - Click Count (0)