- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 190 for TCP (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)