- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 446 for isSocket (0.11 sec)
-
pkg/kubelet/apis/podresources/client.go
return nil, nil, fmt.Errorf("error dialing socket %s: %v", socket, err) } return v1alpha1.NewPodResourcesListerClient(conn), conn, nil } // GetV1Client returns a client for the PodResourcesLister grpc service func GetV1Client(socket string, connectionTimeout time.Duration, maxMsgSize int) (v1.PodResourcesListerClient, *grpc.ClientConn, error) { addr, dialer, err := util.GetAddressAndDialer(socket) if err != nil { return nil, nil, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.5K bytes - Viewed (0) -
src/net/sock_cloexec_solaris.go
// Solaris in the 11.4 release. Thus, on releases prior to 11.4, we fall back // to the combination of socket(3c) and fcntl(2). package net import ( "internal/poll" "internal/syscall/unix" "os" "syscall" ) // Wrapper around the socket system call that marks the returned file // descriptor as nonblocking and close-on-exec. func sysSocket(family, sotype, proto int) (int, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:17:25 UTC 2024 - 1.4K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/InsecureExtendedTrustManager.kt
override fun checkServerTrusted( chain: Array<out X509Certificate>, authType: String, socket: Socket, ) { if (socket.peerName() !in insecureHosts) { delegate.checkServerTrusted(chain, authType, socket) } } override fun checkServerTrusted( chain: Array<out X509Certificate>, authType: String, engine: SSLEngine, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/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 unix 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: Tue Nov 09 20:10:21 UTC 2021 - 2.6K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java
} @Override public Socket createSocket(String host, int port) throws IOException { Socket result = createSocket(); try { result.connect(new InetSocketAddress(host, port)); } catch (IOException e) { result.close(); throw e; } return result; } @Override public Socket createSocket(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Dec 03 21:33:52 UTC 2023 - 2.1K bytes - Viewed (0) -
internal/http/dial_linux.go
// 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/ // This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can // affect clients reading data with a very slow pace (disappropriate with socket buffer sizes) if opts.UserTimeout > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/TcpOutgoingConnector.java
} throw new java.net.ConnectException(String.format("Socket connected to itself on %s port %s.", candidate, address.getPort())); } boolean detectSelfConnect(SocketChannel socketChannel) { Socket socket = socketChannel.socket(); SocketAddress localAddress = socket.getLocalSocketAddress(); SocketAddress remoteAddress = socket.getRemoteSocketAddress(); if (localAddress.equals(remoteAddress)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 4.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SocksProxy.kt
fun play() { serverSocket = ServerSocket(0) executor.execute { val threadName = "SocksProxy ${serverSocket!!.localPort}" Thread.currentThread().name = threadName try { while (true) { val socket = serverSocket!!.accept() connectionCount.incrementAndGet() service(socket) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/prometheus-scrape.yaml.injected
kubectl.kubernetes.io/default-logs-container: hello prometheus.io/scrape: "false" 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.4K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/proxy-override-args.yaml.injected
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.4K bytes - Viewed (0)