Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 190 for TCP (0.08 sec)

  1. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

    import java.net.SocketAddress;
    import jnr.unixsocket.UnixSocket;
    import jnr.unixsocket.UnixSocketAddress;
    import jnr.unixsocket.UnixSocketChannel;
    
    /**
     * Subtype UNIX socket for a higher-fidelity impersonation of TCP sockets. This is named "tunneling"
     * because it assumes the ultimate destination has a hostname and port.
     */
    final class TunnelingUnixSocket extends UnixSocket {
      private final File path;
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 1.9K bytes
    - Viewed (0)
  2. internal/http/check_port_linux.go

    				}
    			})
    			return nil
    		},
    	}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    	// Close the listener and continue check other networks.
    	return l.Close()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  3. internal/http/close.go

    func DrainBody(respBody io.ReadCloser) {
    	// Callers should close resp.Body when done reading from it.
    	// If resp.Body is not closed, the Client's underlying RoundTripper
    	// (typically Transport) may not be able to reuse a persistent TCP
    	// connection to the server for a subsequent "keep-alive" request.
    	if respBody != nil {
    		// Drain any remaining Body and then close the connection.
    		// Without this closing connection would disallow re-using
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  4. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java

    import javax.net.ServerSocketFactory;
    import jnr.unixsocket.UnixServerSocketChannel;
    import jnr.unixsocket.UnixSocketAddress;
    import jnr.unixsocket.UnixSocketChannel;
    
    /** Impersonate TCP-style ServerSocketFactory over UNIX domain sockets. */
    public final class UnixDomainServerSocketFactory extends ServerSocketFactory {
      private final File path;
    
      public UnixDomainServerSocketFactory(File path) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 3.1K bytes
    - Viewed (0)
  5. ci/official/utilities/setup_docker.sh

        CONTAINER_IP_ADDR=$(docker inspect -f '{{range .NetworkSettings.Networks}}{{.IPAddress}}{{end}}' tf)
        netsh advfirewall firewall add rule name="Allow Metadata Proxy" dir=in action=allow protocol=TCP localport=80 remoteip="$CONTAINER_IP_ADDR"
    
        # Stop non-essential indexing and link tracking services that
        # may lock new files or symlinks.
        # They may be causing sporadic "Permission denied" errors during Bazel builds.
    Registered: Tue Dec 30 12:39:10 UTC 2025
    - Last Modified: Thu Nov 20 17:33:55 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  6. tests/gorm_test.go

    package tests_test
    
    import (
    	"testing"
    
    	"gorm.io/driver/mysql"
    
    	"gorm.io/gorm"
    )
    
    func TestOpen(t *testing.T) {
    	dsn := "gorm:gorm@tcp(localhost:9910)/gorm?loc=Asia%2FHongKong" // invalid loc
    	_, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
    	if err == nil {
    		t.Fatalf("should returns error but got nil")
    	}
    }
    
    func TestReturningWithNullToZeroValues(t *testing.T) {
    	dialect := DB.Dialector.Name()
    	switch dialect {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Jun 01 07:22:21 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/SocketEffect.kt

     */
    package mockwebserver3
    
    /**
     * An adverse action to take on a socket, intended to exercise failure modes in the calling code.
     */
    public sealed interface SocketEffect {
      /**
       * Close the TCP socket that carries this request.
       *
       * Using this as [MockResponse.onResponseEnd] is the default for HTTP/1.0.
       */
      public class CloseSocket(
        public val closeSocket: Boolean = true,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/ProtocolTest.kt

        assertThat(get("h3")).isEqualTo(Protocol.HTTP_3)
        assertThat(get("h3-29")).isEqualTo(Protocol.HTTP_3)
      }
    
      @Test
      fun testGetUnknown() {
        assertThrows(IOException::class.java) { get("tcp") }
      }
    
      @Test
      fun testToString() {
        assertThat(Protocol.HTTP_1_0.toString()).isEqualTo("http/1.0")
        assertThat(Protocol.HTTP_1_1.toString()).isEqualTo("http/1.1")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  9. internal/http/check_port_others.go

    func CheckPortAvailability(host, port string, opts TCPOptions) (err error) {
    	lc := &net.ListenConfig{}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    	// Close the listener and continue check other networks.
    	return l.Close()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  10. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java

    import java.io.IOException;
    import java.net.InetAddress;
    import java.net.InetSocketAddress;
    import java.net.Socket;
    import javax.net.SocketFactory;
    import jnr.unixsocket.UnixSocketChannel;
    
    /** Impersonate TCP-style SocketFactory over UNIX domain sockets. */
    public final class UnixDomainSocketFactory extends SocketFactory {
      private final File path;
    
      public UnixDomainSocketFactory(File path) {
        this.path = path;
      }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Dec 03 21:33:52 UTC 2023
    - 2.1K bytes
    - Viewed (0)
Back to top