Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 190 for tcp (0.03 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.advanceUntil(520.ms)
        assertEvents(
          "plan 1 TCP connect failed",
        )
    
        taskFaker.advanceUntil(530.ms)
        assertEvents(
          "plan 2 TCP connect failed",
          "take plan 3",
          "plan 3 TCP connecting...",
        )
    
        taskFaker.advanceUntil(780.ms)
        assertEvents(
          "take plan 4",
          "plan 4 TCP connecting...",
        )
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. 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
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  3. 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() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.8K bytes
    - Viewed (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
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  5. 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() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  6. internal/http/dial_linux.go

    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, 15)
    			}
    
    			// Set tcp user timeout in addition to the keep-alive - tcp-keepalive is not enough to close a socket
    			// with dead end because tcp-keepalive is not fired when there is data in the socket buffer.
    			//    https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. helm/minio/templates/networkpolicy.yaml

        matchLabels:
          app: {{ template "minio.name" . }}
          release: {{ .Release.Name }}
      ingress:
        - ports:
            - port: {{ .Values.minioAPIPort }}
              protocol: TCP
            - port: {{ .Values.minioConsolePort }}
              protocol: TCP
          {{- if not .Values.networkPolicy.allowExternal }}
          from:
            - podSelector:
                matchLabels:
                  {{ template "minio.name" . }}-client: "true"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Jun 08 16:14:18 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  8. 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
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  9. 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
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  10. 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.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
Back to top