- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Dialer (0.19 sec)
-
src/crypto/tls/tls_test.go
if err != nil { close(acceptc) return } acceptc <- conn } }() addr := listener.Addr().String() dialer := &net.Dialer{ Timeout: timeout, } if conn, err := DialWithDialer(dialer, "tcp", addr, nil); err == nil { conn.Close() t.Errorf("DialWithTimeout unexpectedly completed successfully") } else if !isTimeoutError(err) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
cmd/kubelet/app/server.go
func updateDialer(clientConfig *restclient.Config) (func(), error) { if clientConfig.Transport != nil || clientConfig.Dial != nil { return nil, fmt.Errorf("there is already a transport or dialer configured") } d := connrotation.NewDialer((&net.Dialer{Timeout: 30 * time.Second, KeepAlive: 30 * time.Second}).DialContext) clientConfig.Dial = d.DialContext return d.CloseAll, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
resp, err := c.Do(makeReq(t, "POST", url, "v4.channel.k8s.io")) if err != nil { t.Fatalf("Got error POSTing: %v", err) } defer resp.Body.Close() upgradeRoundTripper.Dialer = &net.Dialer{ Deadline: time.Now().Add(60 * time.Second), Timeout: 60 * time.Second, } conn, err := upgradeRoundTripper.NewConnection(resp) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
src/net/http/client_test.go
})).ts writes := 0 dialer := func(netz string, addr string) (net.Conn, error) { c, err := net.Dial(netz, addr) if err == nil { c = &writeCountingConn{c, &writes} } return c, err } c := ts.Client() c.Transport.(*Transport).Dial = dialer _, err := c.Get(ts.URL) if err != nil { t.Fatal(err) } if writes != 1 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
src/net/http/transport.go
// and NO_PROXY (or the lowercase versions thereof). var DefaultTransport RoundTripper = &Transport{ Proxy: ProxyFromEnvironment, DialContext: defaultTransportDialContext(&net.Dialer{ Timeout: 30 * time.Second, KeepAlive: 30 * time.Second, }), ForceAttemptHTTP2: true, MaxIdleConns: 100, IdleConnTimeout: 90 * time.Second, TLSHandshakeTimeout: 10 * time.Second,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/crypto/tls/conn.go
// first [Conn.Read] or [Conn.Write] will call it automatically. // // For control over canceling or setting a timeout on a handshake, use // [Conn.HandshakeContext] or the [Dialer]'s DialContext method instead. // // In order to avoid denial of service attacks, the maximum RSA key size allowed // in certificates sent by either the TLS server or client is limited to 8192
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
} type Event = xdsfake.Event func initServiceDiscovery(t test.Failer) (model.ConfigStore, *Controller, *xdsfake.Updater) { return initServiceDiscoveryWithOpts(t, false) } // initServiceDiscoveryWithoutEvents initializes a test setup with no events. This avoids excessive attempts to push // EDS updates to a full queue func initServiceDiscoveryWithoutEvents(t test.Failer) (model.ConfigStore, *Controller) { store := memory.Make(collections.Pilot)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute_test.go
DNSDomain: "local.campus.net", }, want: []string{ "foo.local.campus.net", "foo", "alias.local.campus.net", "alias", }, }, } testFn := func(t test.Failer, service *model.Service, port int, node *model.Proxy, want []string) { out, _ := generateVirtualHostDomains(service, port, port, node) assert.Equal(t, out, want) } for _, c := range cases { c := c
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 51.4K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KaFirResolver.kt
* provided, an empty map is returned defensively so that [toTypeArgumentsMapping] doesn't conjure any error types. If you want to map * too few type arguments meaningfully, please provide filler types explicitly. */ private fun toTypeArgumentsMapping( typeArguments: List<FirTypeProjection>, partiallyAppliedSymbol: KaPartiallyAppliedSymbol<*, *>,
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 73K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
} }) } } type clusterServicesMetadata struct { Services []struct { Host string Name string Namespace string } } func extractClusterMetadataServices(t test.Failer, c *cluster.Cluster) []string { got := c.GetMetadata().GetFilterMetadata()[util.IstioMetadataKey] if got == nil { return nil } s, err := protomarshal.Marshal(got) if err != nil { t.Fatal(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0)