- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for RdmaMemoryRegion (0.88 sec)
-
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;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 4.3K bytes - Viewed (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();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 7.1K bytes - Viewed (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,
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/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 configuration
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/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 identifier
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 3.2K bytes - Viewed (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); /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 2.1K bytes - Viewed (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"); } @Override
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProviderTest.java
import org.junit.jupiter.api.Test; import jcifs.internal.smb2.rdma.RdmaAccess; import jcifs.internal.smb2.rdma.RdmaCapability; import jcifs.internal.smb2.rdma.RdmaConnection; import jcifs.internal.smb2.rdma.RdmaMemoryRegion; /** * Unit tests for TCP RDMA provider */ public class TcpRdmaProviderTest { private TcpRdmaProvider provider; @BeforeEach public void setUp() {
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/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();
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/tcp/TcpRdmaProvider.java
import java.util.EnumSet; import java.util.Set; import jcifs.internal.smb2.rdma.RdmaAccess; import jcifs.internal.smb2.rdma.RdmaCapability; import jcifs.internal.smb2.rdma.RdmaConnection; import jcifs.internal.smb2.rdma.RdmaMemoryRegion; import jcifs.internal.smb2.rdma.RdmaProvider; /** * TCP fallback RDMA provider. * * This provider uses regular TCP connections but maintains the RDMA
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 2.9K bytes - Viewed (0)