- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 11 for RdmaProvider (0.14 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/test/java/jcifs/internal/smb2/rdma/RdmaProviderFactoryTest.java
@Test public void testCreateProviderAuto() { RdmaProvider provider = RdmaProviderFactory.createProvider("auto"); assertNotNull(provider, "Auto provider selection should return a provider"); assertTrue(provider.isAvailable(), "Returned provider should be available"); } @Test public void testCreateProviderTcp() { RdmaProvider provider = RdmaProviderFactory.createProvider("tcp");Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 3.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaProviderFactory.java
*/ public static List<String> getAvailableProviders() { List<RdmaProvider> allProviders = Arrays.asList(new DisniRdmaProvider(), new TcpRdmaProvider()); return allProviders.stream() .filter(RdmaProvider::isAvailable) .map(RdmaProvider::getProviderName) .collect(java.util.stream.Collectors.toList()); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 4.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaIntegrationTest.java
// Create RDMA-enabled context Properties props = new Properties(); props.setProperty("jcifs.smb.client.useRDMA", "true"); props.setProperty("jcifs.smb.client.rdmaProvider", "auto"); PropertyConfiguration config = new PropertyConfiguration(props); testContext = new BaseContext(config); } // ============================================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/TcpRdmaProvider.java
import jcifs.internal.smb2.rdma.RdmaProvider; /** * TCP fallback RDMA provider. * * This provider uses regular TCP connections but maintains the RDMA * interface for compatibility. It only supports send/receive operations * and does not provide true RDMA read/write capabilities. */ public class TcpRdmaProvider implements RdmaProvider { /** * Creates a new TCP RDMA provider instanceCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 2.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java
this.delegate = delegate; this.rdmaProvider = RdmaProviderFactory.getProvider(context.getConfig()); this.bufferManager = new RdmaBufferManager(rdmaProvider); this.statistics = new RdmaStatistics(); log.debug("Created RDMA transport with provider: {}", rdmaProvider.getClass().getSimpleName()); } /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 8.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java
*/ public class RdmaBufferManager implements AutoCloseable { 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;Created: 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/disni/DisniRdmaProvider.java
import jcifs.internal.smb2.rdma.RdmaProvider; /** * DiSNI RDMA provider for InfiniBand/RoCE networks. * * This provider uses the DiSNI (Direct Storage and Networking Interface) * library to provide high-performance RDMA operations over InfiniBand * and RoCE (RDMA over Converged Ethernet) networks. */ public class DisniRdmaProvider implements RdmaProvider { /**
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 5.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaBufferManagerTest.java
import org.mockito.MockitoAnnotations; import jcifs.internal.smb2.rdma.tcp.TcpMemoryRegion; /** * Unit tests for RDMA buffer manager */ public class RdmaBufferManagerTest { @Mock private RdmaProvider mockProvider; private RdmaBufferManager bufferManager; private AutoCloseable mocks; @BeforeEach public void setUp() throws Exception { mocks = MockitoAnnotations.openMocks(this);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) -
src/main/java/jcifs/config/BaseConfiguration.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 36.5K bytes - Click Count (0) -
src/main/java/jcifs/config/PropertyConfiguration.java
if (value != null) { this.useRDMA = Boolean.parseBoolean(value); } value = props.getProperty("jcifs.smb.client.rdmaProvider"); if (value != null) { this.rdmaProvider = value; } value = props.getProperty("jcifs.smb.client.rdmaReadWriteThreshold"); if (value != null) { try {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:49:49 GMT 2025 - 13.3K bytes - Click Count (0)