- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 850 for net (0.04 sec)
-
src/net/http/httptest/server.go
"crypto/x509" "flag" "fmt" "log" "net" "net/http" "net/http/internal/testcert" "os" "strings" "sync" "time" ) // A Server is an HTTP server listening on a system-chosen port on the // local loopback interface, for use in end-to-end HTTP tests. type Server struct { URL string // base URL of form http://ipaddr:port with no trailing slash Listener net.Listener
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving.go
limitations under the License. */ package options import ( "context" "fmt" "net" "path" "strconv" "strings" "syscall" "github.com/spf13/pflag" "k8s.io/klog/v2" netutils "k8s.io/utils/net" utilnet "k8s.io/apimachinery/pkg/util/net" "k8s.io/apiserver/pkg/server" "k8s.io/apiserver/pkg/server/dynamiccertificates" certutil "k8s.io/client-go/util/cert"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 13:08:18 UTC 2024 - 15.9K bytes - Viewed (1) -
src/crypto/tls/handshake_test.go
// localListener is set up by TestMain and used by localPipe to create Conn // pairs like net.Pipe, but connected by an actual buffered TCP connection. var localListener struct { mu sync.Mutex addr net.Addr ch chan net.Conn } const localFlakes = 0 // change to 1 or 2 to exercise localServer/localPipe handling of mismatches func localServer(l net.Listener) { for n := 0; ; n++ { c, err := l.Accept() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 24.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
package proxy import ( "bufio" "bytes" "errors" "fmt" "net" "net/http" "strings" "sync" "time" gwebsocket "github.com/gorilla/websocket" "k8s.io/apimachinery/pkg/util/httpstream" "k8s.io/apimachinery/pkg/util/httpstream/spdy" "k8s.io/apimachinery/pkg/util/httpstream/wsstream" utilnet "k8s.io/apimachinery/pkg/util/net" constants "k8s.io/apimachinery/pkg/util/portforward"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
// go away. // // Copied from Go 1.7.2 net/http/server.go type tcpKeepAliveListener struct { net.Listener } func (ln tcpKeepAliveListener) Accept() (net.Conn, error) { c, err := ln.Listener.Accept() if err != nil { return nil, err } if tc, ok := c.(*net.TCPConn); ok { tc.SetKeepAlive(true) tc.SetKeepAlivePeriod(defaultKeepAlivePeriod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
src/net/lookup_plan9.go
} } } func queryCS(ctx context.Context, net, host, service string) (res []string, err error) { switch net { case "tcp4", "tcp6": net = "tcp" case "udp4", "udp6": net = "udp" } if host == "" { host = "*" } return query(ctx, netdir+"/cs", net+"!"+host+"!"+service, 128) } func queryCS1(ctx context.Context, net string, ip IP, port int) (clone, dest string, err error) { ips := "*"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 17:08:38 UTC 2024 - 9.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/runtimeshaded/RuntimeShadedJarCreatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 13:39:49 UTC 2024 - 20.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CookiesTest.kt
import assertk.assertions.isNull import assertk.assertions.isTrue import assertk.fail import java.net.CookieHandler import java.net.CookieManager import java.net.CookiePolicy import java.net.HttpCookie import java.net.HttpURLConnection import java.net.InetAddress import java.net.URI import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import okhttp3.Cookie.Companion.parse
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13K bytes - Viewed (0) -
src/net/listen_test.go
// darwin, kernel version 11.3.0 // net.inet6.ip6.v6only=0 (overridable by sysctl or IPV6_V6ONLY option) // freebsd, kernel version 8.2 // net.inet6.ip6.v6only=1 (overridable by sysctl or IPV6_V6ONLY option) // linux, kernel version 3.0.0 // net.ipv6.bindv6only=0 (overridable by sysctl or IPV6_V6ONLY option) // openbsd, kernel version 5.0 // net.inet6.ip6.v6only=1 (overriding is prohibited)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/OkHttpClientTest.kt
import assertk.assertions.isSameAs import java.io.IOException import java.net.CookieManager import java.net.Proxy import java.net.ProxySelector import java.net.ResponseCache import java.net.SocketAddress import java.net.URI import java.time.Duration import java.util.AbstractList import javax.net.ssl.SSLSession import javax.net.ssl.SSLSocketFactory import kotlin.test.assertFailsWith import mockwebserver3.MockResponse
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 13.2K bytes - Viewed (0)