- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for SOCKET (0.12 sec)
-
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
.socketFactory( object : DelegatingSocketFactory(getDefault()) { override fun configureSocket(socket: Socket): Socket { socket.receiveBufferSize = socketBufferSize socket.sendBufferSize = socketBufferSize return socket } }, ) .writeTimeout(Duration.ofMillis(500)) .build() server.start()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 131.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
callback.await(server.url("/a")).assertFailure("Canceled", "Socket closed", "Socket is closed") } @Test fun cancelAll() { val call = client.newCall(Request(server.url("/"))) call.enqueue(callback) client.dispatcher.cancelAll() callback.await(server.url("/")).assertFailure("Canceled", "Socket closed", "Socket is closed") } @Test
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
pkg/config/validation/validation.go
func ValidateUnixAddress(addr string) error { if len(addr) == 0 { return errors.New("unix address must not be empty") } // Allow unix abstract domain sockets whose names start with @ if strings.HasPrefix(addr, "@") { return nil } // Note that we use path, not path/filepath even though a domain socket path is a file path. We don't want the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
pkg/config/validation/validation_test.go
valid: false, }, { name: "unix socket", in: &networking.ServiceEntry{ Hosts: []string{"uds.cluster.local"}, Ports: []*networking.ServicePort{ {Number: 6553, Protocol: "grpc", Name: "grpc-service1"}, }, Resolution: networking.ServiceEntry_STATIC, Endpoints: []*networking.WorkloadEntry{ {Address: "unix:///path/to/socket"}, }, }, valid: true, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 03:11:45 UTC 2024 - 196K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
g.Expect(len(clusters)).ShouldNot(Equal(0)) for _, cluster := range clusters { socket := cluster.GetLoadAssignment().GetEndpoints()[0].LbEndpoints[0].GetEndpoint().GetAddress().GetSocketAddress() g.Expect(socket.GetAddress()).To(Equal(c.expectedAddr)) g.Expect(socket.GetPortValue()).To(Equal(c.expectedPort)) } }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
cluster/gce/gci/configure-helper.sh
function prepare-etcd-manifest { local host_name=${ETCD_HOSTNAME:-$(hostname -s)} local resolve_host_script_py=' import socket import time import sys timeout_sec=300 def resolve(host): for attempt in range(timeout_sec): try: print(socket.gethostbyname(host)) break except Exception as e:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 22:07:47 UTC 2024 - 141.1K bytes - Viewed (0) -
go.sum
github.com/mdlayher/netlink v1.7.2/go.mod h1:xraEF7uJbxLhc5fpHL4cPe221LI2bdttWlU+ZGLfQSw= github.com/mdlayher/socket v0.1.1/go.mod h1:mYV5YIZAfHh4dzDVzI8x8tWLWCliuX8Mon5Awbj+qDs= github.com/mdlayher/socket v0.5.0 h1:ilICZmJcQz70vrWVes1MFera4jGiWNocSkykwwoy3XI= github.com/mdlayher/socket v0.5.0/go.mod h1:WkcBFfvyG8QENs5+hfQPl1X6Jpd2yeLIYgrGFmJiJxI= github.com/miekg/dns v1.1.59 h1:C9EXc/UToRwKLhK5wKU/I4QVsBUc8kE6MkHBkeypWZs=
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 15:32:28 UTC 2024 - 101.6K bytes - Viewed (0) -
src/net/http/transport_test.go
targetConn, err := net.Dial("tcp", targetHost) if err != nil { t.Errorf("net.Dial failed") return } go io.Copy(targetConn, s) io.Copy(s, targetConn) // Wait for the client to close the socket. targetConn.Close() } pu, err := url.Parse("socks5://" + l.Addr().String()) if err != nil { t.Fatal(err) } sentinelHeader := "X-Sentinel" sentinelValue := "12345"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/types_windows.go
Bias int32 StandardName [32]uint16 StandardDate Systemtime StandardBias int32 DaylightName [32]uint16 DaylightDate Systemtime DaylightBias int32 } // Socket related. const ( AF_UNSPEC = 0 AF_UNIX = 1 AF_INET = 2 AF_NETBIOS = 17 AF_INET6 = 23 AF_IRDA = 26 AF_BTH = 32 SOCK_STREAM = 1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 22:18:42 UTC 2024 - 104.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/zsyscall_windows.go
procshutdown = modws2_32.NewProc("shutdown") procsocket = modws2_32.NewProc("socket") procWTSEnumerateSessionsW = modwtsapi32.NewProc("WTSEnumerateSessionsW") procWTSFreeMemory = modwtsapi32.NewProc("WTSFreeMemory")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 195.8K bytes - Viewed (0)