Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 61 for tcp (0.01 seconds)

  1. 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)
  2. internal/http/listener.go

    type httpListener struct {
    	opts        TCPOptions
    	listeners   []net.Listener    // underlying TCP listeners.
    	acceptCh    chan acceptResult // channel where all TCP listeners write accepted connection.
    	ctxDoneCh   <-chan struct{}
    	ctxCanceler context.CancelFunc
    }
    
    // start - starts separate goroutine for each TCP listener.  A valid new connection is passed to httpListener.acceptCh.
    func (listener *httpListener) start() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb2/rdma/RdmaProviderFactoryTest.java

        }
    
        @Test
        public void testCreateProviderTcp() {
            RdmaProvider provider = RdmaProviderFactory.createProvider("tcp");
            assertNotNull(provider, "TCP provider should always be available");
            assertTrue(provider.isAvailable(), "TCP provider should be available");
            assertEquals("TCP Fallback", provider.getProviderName());
        }
    
        @Test
        public void testCreateProviderDisni() {
    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)
  4. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpMemoryRegion.java

     */
    package jcifs.internal.smb2.rdma.tcp;
    
    import java.nio.ByteBuffer;
    import java.util.EnumSet;
    import java.util.concurrent.atomic.AtomicInteger;
    
    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
    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)
  5. docs/features/connections.md

     * Don't start a new attempt until 250 ms after the most recent attempt was started.
     * Keep whichever TCP connection succeeds first and cancel all the others.
     * Race TCP only. Only attempt a TLS handshake on the winning TCP connection.
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:01:42 GMT 2026
    - 5.4K bytes
    - Click Count (0)
  6. src/test/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProviderTest.java

    import jcifs.internal.smb2.rdma.RdmaMemoryRegion;
    
    /**
     * Unit tests for TCP RDMA provider
     */
    public class TcpRdmaProviderTest {
    
        private TcpRdmaProvider provider;
    
        @BeforeEach
        public void setUp() {
            provider = new TcpRdmaProvider();
        }
    
        @Test
        public void testIsAvailable() {
            assertTrue(provider.isAvailable(), "TCP provider should always be available");
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  7. docs/smb3-features/05-rdma-smb-direct-design.md

    }
    ```
    
    #### 4.5.2 Fallback TCP Provider
    ```java
    package jcifs.internal.smb2.rdma.tcp;
    
    public class TcpRdmaProvider implements RdmaProvider {
        @Override
        public boolean isAvailable() {
            return true;  // TCP is always available
        }
        
        @Override
        public Set<RdmaCapability> getSupportedCapabilities() {
            // TCP fallback only supports send/receive
    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)
  8. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java

                throw new IOException("TCP RDMA receive failed", e);
            }
        }
    
        @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
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  9. src/main/java/jcifs/internal/smb2/rdma/RdmaProviderFactory.java

    import java.util.List;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.Configuration;
    import jcifs.internal.smb2.rdma.disni.DisniRdmaProvider;
    import jcifs.internal.smb2.rdma.tcp.TcpRdmaProvider;
    
    /**
     * Factory for creating RDMA provider instances.
     *
     * This factory attempts to select the best available RDMA provider
     * based on system capabilities and configuration preferences.
     */
    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)
  10. okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt

          check(connectState == ConnectState.READY)
          events += "plan $id TCP connecting..."
    
          taskFaker.sleep(tcpConnectDelayNanos)
    
          if (yieldBeforeTcpConnectReturns) {
            taskFaker.yield()
          }
    
          return when {
            tcpConnectThrowable != null -> {
              events += "plan $id TCP connect failed"
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 6.1K bytes
    - Click Count (0)
Back to Top