- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for dial (0.07 sec)
-
src/crypto/tls/tls.go
return nil, err } return conn, nil } // Dial connects to the given network address using net.Dial // and then initiates a TLS handshake, returning the resulting // TLS connection. // Dial interprets a nil configuration as equivalent to // the zero configuration; see the documentation of Config // for the defaults. func Dial(network, addr string, config *Config) (*Conn, error) {
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/http/transport_test.go
w.Header().Set("X-Status", "ok") })).ts var writeNumAtomic int32 c := ts.Client() c.Transport.(*Transport).Dial = func(network, addr string) (net.Conn, error) { logf("Dial") c, err := net.Dial(network, ts.Listener.Addr().String()) if err != nil { logf("Dial error: %v", err) return nil, err } return &writerFuncConn{ Conn: c,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/net/http/transport.go
// Dial specifies the dial function for creating unencrypted TCP connections. // // Dial runs concurrently with calls to RoundTrip. // A RoundTrip call that initiates a dial may end up using // a connection dialed previously when the earlier connection // becomes idle before the later Dial completes. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
pilot/test/xds/fake.go
func (f *FakeDiscoveryServer) ConnectADS() *xds.AdsTest { conn, err := grpc.Dial("buffcon", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock(), grpc.WithContextDialer(func(context.Context, string) (net.Conn, error) { return f.BufListener.Dial() })) if err != nil { f.t.Fatalf("failed to connect: %v", err) } return xds.NewAdsTest(f.t, conn) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
src/net/http/serve_test.go
string(got), err, expected) } // Slow client that should timeout. t1 := time.Now() conn, err := net.Dial("tcp", ts.Listener.Addr().String()) if err != nil { return fmt.Errorf("Dial: %v", err) } buf := make([]byte, 1) n, err := conn.Read(buf) conn.Close() latency := time.Since(t1) if n != 0 || err != io.EOF {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
pkg/kubelet/util/queue/work_queue_test.go
q.Enqueue(types.UID("foo4"), 1*time.Minute) expected := []types.UID{types.UID("foo1"), types.UID("foo2")} compareResults(t, expected, q.GetWork()) compareResults(t, []types.UID{}, q.GetWork()) // Dial the time to 1 hour ahead. clock.Step(time.Hour) expected = []types.UID{types.UID("foo3"), types.UID("foo4")} compareResults(t, expected, q.GetWork()) compareResults(t, []types.UID{}, q.GetWork()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0) -
src/crypto/tls/bogo_shim_test.go
if err != nil { log.Fatalf("parse ech-config-list err: %s", err) } cfg.EncryptedClientHelloConfigList = echConfigList } conn, err := net.Dial("tcp", net.JoinHostPort("localhost", *port)) if err != nil { log.Fatalf("dial err: %s", err) } defer conn.Close() // Write the shim ID we were passed as a little endian uint64 shimIDBytes := make([]byte, 8)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:25:39 UTC 2024 - 12.6K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/nettest.go
func SupportsRawSocket() bool { stackOnce.Do(probeStack) return rawSocketSess } // TestableNetwork reports whether network is testable on the current // platform configuration. // // See func Dial of the standard library for the supported networks. func TestableNetwork(network string) bool { ss := strings.Split(network, ":") switch ss[0] { case "ip+nopriv": // This is an internal network name for testing on the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 8.5K bytes - Viewed (0) -
internal/http/listener_test.go
continue nextTest } t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err) } } for _, serverAddr := range listener.Addrs() { conn, err := net.Dial("tcp", serverAddr.String()) if err != nil { t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err) } conn.Close() } listener.Close() } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:41:02 UTC 2024 - 11.8K bytes - Viewed (0) -
internal/grid/manager.go
// No connection to local. continue } m.targets[host] = newConnection(connectionParams{ ctx: ctx, id: m.ID, local: o.Local, remote: host, dial: o.Dialer, handlers: &m.handlers, auth: o.AddAuth, blockConnect: o.BlockConnect, tlsConfig: o.TLSConfig, publisher: o.TraceTo, incomingBytes: o.Incoming,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K bytes - Viewed (0)