- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 119 for dialFn (0.22 sec)
-
src/net/unixsock_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 := unixSocket(ctx, sd.network, laddr, raddr, "dial", ctrlCtxFn) if err != nil { return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.6K bytes - Viewed (0) -
src/net/mptcpsock_linux_test.go
ch <- errors.New("incoming connection is not an MPTCP proto") return } } func dialerMPTCP(t *testing.T, addr string, envVar bool) { d := &Dialer{} if envVar { if !d.MultipathTCP() { t.Fatal("MultipathTCP Dialer is not on despite GODEBUG=multipathtcp=1") } } else { if d.MultipathTCP() { t.Error("MultipathTCP should be off by default") } d.SetMultipathTCP(true)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 00:36:57 UTC 2023 - 4.1K bytes - Viewed (0) -
docs/site-replication/gen-oidc-sts-cred.go
ProviderURL: "http://127.0.0.1:5556/dex", RedirectURL: "http://127.0.0.1:10000/oauth_callback", } oidcToken, err := cmd.MockOpenIDTestUserInteraction(ctx, appParams, "dillon@example.io", "dillon") if err != nil { log.Fatalf("Failed to generate OIDC token: %v", err) } roleARN := os.Getenv("ROLE_ARN") webID := cr.STSWebIdentity{ Client: &http.Client{}, STSEndpoint: endpoint,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 29 01:27:09 UTC 2022 - 2.3K bytes - Viewed (0) -
src/net/udpsock_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_DGRAM, 0, "dial", ctrlCtxFn) if err != nil { return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 7.5K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener_test.go
opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) { var d net.Dialer return d.DialContext(ctx, "unix", socket) })) conn, err := grpc.Dial(socket, opts...) if err != nil { return nil, err } return conn, nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:32 UTC 2024 - 1.4K bytes - Viewed (0) -
pkg/uds/listener_test.go
opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) { var d net.Dialer return d.DialContext(ctx, "unix", socket) })) conn, err := grpc.Dial(socket, opts...) if err != nil { return nil, err } return conn, nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 16 02:46:58 UTC 2021 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go
func NoOpNewStreamHandler(stream Stream, replySent <-chan struct{}) error { return nil } // Dialer knows how to open a streaming connection to a server. type Dialer interface { // Dial opens a streaming connection to a server using one of the protocols // specified (in order of most preferred to least preferred). Dial(protocols ...string) (Connection, string, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 6.4K bytes - Viewed (0) -
src/internal/nettrace/nettrace.go
// ConnectStart is called before a Dial, excluding Dials made // during DNS lookups. In the case of DualStack (Happy Eyeballs) // dialing, this may be called multiple times, from multiple // goroutines. ConnectStart func(network, addr string) // ConnectDone is called after a Dial with the results, excluding // Dials made during DNS lookups. It may also be called multiple // times, like ConnectStart.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 11:57:14 UTC 2023 - 1.8K bytes - Viewed (0) -
src/net/main_test.go
// If external IPv4 connectivity exists, we can try dialing // non-node/interface local scope IPv4 addresses. // On Windows, Lookup APIs may not return IPv4-related // resource records when a node has no external IPv4 // connectivity. testIPv4 = flag.Bool("ipv4", true, "assume external IPv4 connectivity exists") // If external IPv6 connectivity exists, we can try dialing // non-node/interface local scope IPv6 addresses.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/net/util_test.go
} } } type tcpLB struct { t *testing.T ln net.Listener serverURL string dials int32 } func (lb *tcpLB) handleConnection(in net.Conn, stopCh chan struct{}) { out, err := net.Dial("tcp", lb.serverURL) if err != nil { lb.t.Log(err) return } go io.Copy(out, in) go io.Copy(in, out) <-stopCh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 4.3K bytes - Viewed (0)