- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 71 for dialFn (0.1 sec)
-
src/net/iprawsock_test.go
} a, err := ResolveIPAddr("ip", args[1]) if err != nil { t.Errorf("ResolveIPAddr(\"ip\", %q) = %v", args[1], err) continue } _, err = DialIP(args[0], nil, a) if tt.shouldFail != (err != nil) { t.Errorf("DialIP(%q, %v) = %v; want (err != nil) is %t", args[0], a, err, tt.shouldFail) } _, err = ListenIP(args[0], a) if tt.shouldFail != (err != nil) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 6K bytes - Viewed (0) -
internal/http/dial_linux.go
// DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error) // NewInternodeDialContext setups a custom dialer for internode communication func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.8K bytes - Viewed (3) -
pkg/util/filesystem/util_windows.go
// dial multiple times var lastSocketErr error err := wait.PollImmediate(socketDialRetryPeriod, socketDialTimeout, func() (bool, error) { klog.V(6).InfoS("Dialing the socket", "filePath", filePath) var c net.Conn c, lastSocketErr = net.Dial("unix", filePath) if lastSocketErr == nil { c.Close() klog.V(6).InfoS("Socket dialed successfully", "filePath", filePath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 4K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/html/header.html
<button id="save-cancel">Cancel</button> <button id="save-confirm">Save</button> </div> </div> <div class="dialog" id="delete-dialog"> <div class="dialog-header" id="delete-dialog-title">Delete config</div> <div id="delete-prompt"></div> <div class="dialog-footer"> <span class="dialog-error" id="delete-error"></span> <button id="delete-cancel">Cancel</button> <button id="delete-confirm">Delete</button>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 16 15:19:53 UTC 2024 - 3.4K bytes - Viewed (0) -
cmd/sftp-server_test.go
newSSHCon := newSSHConnMock("dillon=ldap") _, err := sshPasswordAuth(newSSHCon, []byte("dillon")) if err == nil || !errors.Is(err, errSFTPUserHasNoPolicies) { c.Fatalf("expected err(%s) but got (%s)", errSFTPUserHasNoPolicies, err) } newSSHCon = newSSHConnMock("dillon") _, err = sshPasswordAuth(newSSHCon, []byte("dillon")) if err == nil || !errors.Is(err, errNoSuchUser) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/dial_test.go
}, "insecure, custom dial": { TLSConfig: &tls.Config{InsecureSkipVerify: true}, Dial: d.DialContext, }, "secure, no roots, custom dial": { TLSConfig: &tls.Config{InsecureSkipVerify: false}, Dial: d.DialContext, ExpectError: "unknown authority|not trusted", }, "secure with roots, custom dial": { TLSConfig: &tls.Config{InsecureSkipVerify: false, RootCAs: roots},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 8.4K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/util.go
return dialer.(hbone.Dialer) } out := &net.Dialer{ Timeout: common.ConnectionTimeout, } if cfg.forceDNSLookup { out.Resolver = newResolver(common.ConnectionTimeout, "", "") } return out } func newResolver(timeout time.Duration, protocol, dnsServer string) *net.Resolver { return &net.Resolver{ PreferGo: true, Dial: func(ctx context.Context, network, address string) (net.Conn, error) { d := net.Dialer{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 4.4K 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) -
pkg/kubelet/util/util_windows_test.go
address, dialer, err := util.GetAddressAndDialer(fullPath) require.NoErrorf(t, err, "Failed to parse the endpoint path and get back address and dialer (path=%q)", fullPath) dialerPointer := reflect.ValueOf(dialer).Pointer() actualDialerName := runtime.FuncForPC(dialerPointer).Name() assert.Equalf(t, npipeDialPointer, dialerPointer, "Expected dialer %s, but get %s", expectedDialerName, actualDialerName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3.1K bytes - Viewed (0) -
internal/grid/debug.go
if err != nil { return nil, err } dialer := &net.Dialer{ Timeout: 5 * time.Second, } var res TestGrid res.Hosts = hosts ready := make(chan struct{}) ctx, cancel := context.WithCancel(context.Background()) res.cancel = cancel for i, host := range hosts { manager, err := NewManager(ctx, ManagerOptions{ Dialer: dialer.DialContext, Local: host, Hosts: hosts,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 4.2K bytes - Viewed (0)