- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 916 for SOCKET (0.09 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/SpecificHostSocketFactory.kt
} override fun createSocket(): Socket { return object : Socket() { override fun connect( endpoint: SocketAddress?, timeout: Int, ) { val requested = (endpoint as InetSocketAddress) val inetSocketAddress = hostMapping[requested.address] ?: defaultAddress ?: requested Platform.get().log("Socket connection to: $inetSocketAddress was: $requested")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.7K bytes - Viewed (0) -
src/net/file_unix_test.go
t.Fatalf("server error: %v", err) } // The socket should be non-blocking. rawconn, err := client.(*UnixConn).SyscallConn() if err != nil { t.Fatal(err) } err = rawconn.Control(func(fd uintptr) { nonblock, err := unix.IsNonblock(int(fd)) if err != nil { t.Fatal(err) } if !nonblock { t.Fatal("unix socket is in blocking mode") } }) if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 22 16:48:53 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/traffic-params-empty-includes.yaml.injected
prometheus.io/port: "15020" prometheus.io/scrape: "true" sidecar.istio.io/status: '{"initContainers":["istio-init"],"containers":["istio-proxy"],"volumes":["workload-socket","credential-socket","workload-certs","istio-envoy","istio-data","istio-podinfo","istio-token","istiod-ca-cert"],"imagePullSecrets":null,"revision":"default"}' creationTimestamp: null labels: app: traffic
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/truncate-canonical-name-pod.yaml.injected
prometheus.io/path: /stats/prometheus prometheus.io/port: "15020" prometheus.io/scrape: "true" sidecar.istio.io/status: '{"initContainers":["istio-init"],"containers":["istio-proxy"],"volumes":["workload-socket","credential-socket","workload-certs","istio-envoy","istio-data","istio-podinfo","istio-token","istiod-ca-cert"],"imagePullSecrets":null,"revision":"default"}' creationTimestamp: null labels: security.istio.io/tlsMode: istio
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/multiple-templates.yaml.injected
proxy.istio.io/overrides: '{"containers":[{"name":"istio-proxy","image":"foo/bar","resources":{}}]}' sidecar.istio.io/status: '{"initContainers":["istio-init"],"containers":["istio-proxy"],"volumes":["workload-socket","credential-socket","workload-certs","istio-envoy","istio-data","istio-podinfo","istio-token","istiod-ca-cert"],"imagePullSecrets":null,"revision":"default"}' creationTimestamp: null labels: app: hello
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/pod.yaml.injected
prometheus.io/path: /stats/prometheus prometheus.io/port: "15020" prometheus.io/scrape: "true" sidecar.istio.io/status: '{"initContainers":["istio-init"],"containers":["istio-proxy"],"volumes":["workload-socket","credential-socket","workload-certs","istio-envoy","istio-data","istio-podinfo","istio-token","istiod-ca-cert"],"imagePullSecrets":null,"revision":"default"}' creationTimestamp: null labels: security.istio.io/tlsMode: istio
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 5.5K bytes - Viewed (0) -
src/syscall/sockcmsg_linux.go
// Copyright 2011 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Socket control messages package syscall import "unsafe" // UnixCredentials encodes credentials into a socket control message // for sending to another process. This can be used for // authentication. func UnixCredentials(ucred *Ucred) []byte {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 17 18:42:47 UTC 2019 - 1.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private var writerTask: Task? = null /** Null until this web socket is connected. Only accessed by the reader thread. */ private var reader: WebSocketReader? = null // All mutable web socket state is guarded by this. /** Null until this web socket is connected. Note that messages may be enqueued before that. */ private var writer: WebSocketWriter? = null
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(c1.socket().isClosed).isFalse() assertThat(c2.socket().isClosed).isFalse() // Add a third connection val c3 = factory.newConnection(pool, routeC1, 75L) // The third connection bounces the first. assertThat(pool.closeConnections(100L)).isEqualTo(0L) assertThat(pool.connectionCount()).isEqualTo(2) assertThat(c1.socket().isClosed).isTrue()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/endpoint_test.go
} func TestNewEndpoint(t *testing.T) { socket := filepath.Join(os.TempDir(), esocketName()) devs := []*pluginapi.Device{ {ID: "ADeviceId", Health: pluginapi.Healthy}, } p, e := esetup(t, devs, socket, "mock", func(n string, d []pluginapi.Device) {}) defer ecleanup(t, p, e) } func TestRun(t *testing.T) { socket := filepath.Join(os.TempDir(), esocketName()) devs := []*pluginapi.Device{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 16:05:48 UTC 2022 - 7.6K bytes - Viewed (0)