- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 334 for dialIP (0.2 sec)
-
internal/http/dial_dnscache.go
// function. LookupHost may implement an internal DNS caching implementation, lookupHost // input if nil then net.DefaultResolver.LookupHost is used. // // It dials one by one and returns first connected `net.Conn`. // If it fails to dial all IPs from cache it returns first error. If no baseDialFunc // is given, it sets default dial function. //
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jul 03 19:30:51 UTC 2023 - 2.6K bytes - Viewed (0) -
src/crypto/tls/tls.go
// // DialWithDialer uses context.Background internally; to specify the context, // use [Dialer.DialContext] with NetDialer set to the desired dialer. func DialWithDialer(dialer *net.Dialer, network, addr string, config *Config) (*Conn, error) { return dial(context.Background(), dialer, network, addr, config) } func dial(ctx context.Context, netDialer *net.Dialer, network, addr string, config *Config) (*Conn, error) { if netDialer.Timeout != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 12.2K bytes - Viewed (0) -
src/net/dial_test.go
defer ln.Close() _, port, err := SplitHostPort(ln.Addr().String()) if err != nil { t.Fatal(err) } ctx := contextWithNonZeroDeadline{Context: context.Background()} var dialer Dialer c, err := dialer.DialContext(ctx, "tcp", JoinHostPort("", port)) if err != nil { t.Fatal(err) } c.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 30.3K bytes - Viewed (0) -
src/net/net_fake_test.go
if err != nil { t.Fatalf("unexpected error from Dial with %v connections: %v", len(dialed), err) } dialed = append(dialed, c) if testing.Verbose() && len(dialed)%(1<<12) == 0 { t.Logf("dialed %d connections", len(dialed)) } } t.Logf("dialed %d connections", len(dialed)) // Now that all of the ports are in use, dialing another should fail due // to port exhaustion, which (for POSIX-like socket APIs) should return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.8K bytes - Viewed (0) -
src/net/tcpsock_unix_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector_test.go
}, } for _, tc := range testcases { t.Run(tc.name, func(t *testing.T) { // Setup the various pieces such as the fake dialer prior to initializing the egress selector. // Go doesn't allow function pointer comparison, nor does its reflect package // So overriding the default dialer to detect if it is returned. fake := &fakeEgressSelection{} directDialer = fake.fakeDirectDialer cs, err := NewEgressSelector(tc.input)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 26 22:41:29 UTC 2023 - 12.3K bytes - Viewed (0) -
src/net/tcpsock_test.go
}() } attempts := 10 * N fails := 0 d := &Dialer{Timeout: 200 * time.Millisecond} for i := 0; i < attempts; i++ { c, err := d.Dial("tcp", ln.Addr().String()) if err != nil { fails++ } else { c.Close() } } ln.Close() wg.Wait() if fails > attempts/9 { // see issues 7400 and 7541 t.Fatalf("too many Dial failed: %v", fails) } if fails > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
} // wantDial waits for the Transport to start a Dial. func (dt *transportDialTester) wantDial() *transportDialTesterConn { c := <-dt.dials c.connID = dt.dialCount dt.dialCount++ dt.t.Logf("Dial %v: started", c.connID) return c } // finish completes a Dial. func (c *transportDialTesterConn) finish(err error) { c.t.Logf("Dial %v: finished (err:%v)", c.connID, err) c.ready <- err
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/websocket.go
return newDialer(cfg).Dial(network, addr) } if len(cfg.UDS) > 0 { dialContext = func(network, addr string) (net.Conn, error) { return newDialer(cfg).Dial("unix", cfg.UDS) } } dialer := &websocket.Dialer{ TLSClientConfig: cfg.tlsConfig, NetDial: dialContext, HandshakeTimeout: cfg.timeout, } conn, _, err := dialer.Dial(req.Url, wsReq) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 11 16:27:16 UTC 2022 - 3.3K bytes - Viewed (0) -
src/net/tcpsock_posix.go
ctrlCtxFn := sd.Dialer.ControlContext if ctrlCtxFn == nil && sd.Dialer.Control != nil { ctrlCtxFn = func(ctx context.Context, network, address string, c syscall.RawConn) error { return sd.Dialer.Control(network, address, c) } } fd, err := internetSocket(ctx, sd.network, laddr, raddr, syscall.SOCK_STREAM, proto, "dial", ctrlCtxFn)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.3K bytes - Viewed (0)