Search Options

Display Count
Sort
Preferred Language
Advanced Search

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

  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...",
        )
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 20.9K bytes
    - Click Count (0)
  2. 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/
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jul 23 10:53:03 GMT 2024
    - 5K bytes
    - Click Count (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() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  4. 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"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jun 08 16:14:18 GMT 2025
    - 1.9K 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 Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Feb 21 03:33:59 GMT 2022
    - 5.4K bytes
    - Click Count (0)
  6. docs/en/docs/deployment/https.md

    After this, the client and the server have an **encrypted TCP connection**, this is what TLS provides. And then they can use that connection to start the actual **HTTP communication**.
    
    And that's what **HTTPS** is, it's just plain **HTTP** inside a **secure TLS connection** instead of a pure (unencrypted) TCP connection.
    
    /// tip
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 19:34:08 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  7. internal/http/check_port_test.go

    	if runtime.GOOS != "linux" {
    		t.Skip()
    	}
    
    	l, err := net.Listen("tcp", "localhost:0") // ask kernel for a free port.
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer l.Close()
    
    	port := l.Addr().(*net.TCPAddr).Port
    
    	testCases := []struct {
    		host        string
    		port        int
    		expectedErr error
    	}{
    		{"", port, fmt.Errorf("listen tcp :%v: bind: address already in use", port)},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Click Count (0)
  8. internal/rest/rpc-stats.go

    	tcpTimeForFirstByteTotalDur uint64
    }{}
    
    // RPCStats holds information about the DHCP/TCP metrics and errors
    type RPCStats struct {
    	Errs uint64
    
    	DialAvgDuration uint64
    	TTFBAvgDuration uint64
    	DialErrs        uint64
    }
    
    // GetRPCStats returns RPC stats, include calls errors and dhcp/tcp metrics
    func GetRPCStats() RPCStats {
    	s := RPCStats{
    		Errs:     atomic.LoadUint64(&globalStats.errs),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 13 18:21:34 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  9. docs/ru/docs/deployment/https.md

    * Шифрование соединения происходит на **уровне TCP**.
        * Это на один уровень **ниже HTTP**.
        * Поэтому **сертификаты и шифрование** обрабатываются **до HTTP**.
    * **TCP не знает о «доменах»**. Только об IP-адресах.
        * Информация о **конкретном домене** передаётся в **данных HTTP**.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Sep 30 11:24:39 GMT 2025
    - 23K 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 Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 6.1K bytes
    - Click Count (0)
Back to Top