Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 11 for RdmaProvider (0.14 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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 instance
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/main/java/jcifs/config/BaseConfiguration.java

            }
            if (this.loadBalancingStrategy == null) {
                this.loadBalancingStrategy = "adaptive";
            }
    
            // Initialize RDMA defaults
            if (this.rdmaProvider == null) {
                this.rdmaProvider = "auto";
            }
            if (this.rdmaReadWriteThreshold == 0) {
                this.rdmaReadWriteThreshold = 8192; // 8KB
            }
            if (this.rdmaMaxSendSize == 0) {
    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)
  10. 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)
Back to Top