Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 36 for dial (0.2 sec)

  1. src/net/iprawsock_posix.go

    			return sd.Dialer.Control(network, address, c)
    		}
    	}
    	fd, err := internetSocket(ctx, network, laddr, raddr, syscall.SOCK_RAW, proto, "dial", ctrlCtxFn)
    	if err != nil {
    		return nil, err
    	}
    	return newIPConn(fd), nil
    }
    
    func (sl *sysListener) listenIP(ctx context.Context, laddr *IPAddr) (*IPConn, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. security/pkg/nodeagent/caclient/providers/citadel/client.go

    	opts, err := istiogrpc.ClientOptions(nil, tlsOpts)
    	if err != nil {
    		return nil, err
    	}
    	opts = append(opts,
    		grpc.WithPerRPCCredentials(c.provider),
    		security.CARetryInterceptor(),
    	)
    	conn, err := grpc.Dial(c.opts.CAEndpoint, opts...)
    	if err != nil {
    		citadelClientLog.Errorf("Failed to connect to endpoint %s: %v", c.opts.CAEndpoint, err)
    		return nil, fmt.Errorf("failed to connect to endpoint %s", c.opts.CAEndpoint)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. internal/http/dial_linux.go

    					_ = syscall.SetsockoptString(fd, syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface)
    				}
    			}
    		})
    		return nil
    	}
    }
    
    // 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
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 4.8K bytes
    - Viewed (3)
  4. src/net/http/transport_internal_test.go

    							StatusCode: 200,
    						}, nil
    					}
    					roundTripped = true
    					return nil, http2noCachedConnError{}
    				})
    			},
    		},
    		DialTLS: func(_, _ string) (net.Conn, error) {
    			tc, err := tls.Dial("tcp", addr, &tls.Config{
    				InsecureSkipVerify: true,
    				NextProtos:         []string{"foo"},
    			})
    			if err != nil {
    				return nil, err
    			}
    			if err := tc.Handshake(); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 15:57:17 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  5. src/net/ipsock_posix.go

    //     "udp", with a wildcard address: If the platform supports
    //     both IPv6 and IPv4-mapped IPv6 communication capabilities,
    //     or does not support IPv4, we use a dual stack, AF_INET6 and
    //     IPV6_V6ONLY=0, wildcard address listen. The dual stack
    //     wildcard address listen may fall back to an IPv6-only,
    //     AF_INET6 and IPV6_V6ONLY=1, wildcard address listen.
    //     Otherwise we prefer an IPv4-only, AF_INET, wildcard address
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  6. 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)
  7. src/net/udpsock_posix.go

    			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
    	}
    	return newUDPConn(fd), nil
    }
    
    func (sl *sysListener) listenUDP(ctx context.Context, laddr *UDPAddr) (*UDPConn, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  8. src/net/lookup_windows_test.go

    	for _, ans := range rx.FindAllStringSubmatch(r, -1) {
    		ptr = append(ptr, absDomainName(ans[1]))
    	}
    	return
    }
    
    func localIP() (ip IP, err error) {
    	conn, err := Dial("udp", "golang.org:80")
    	if err != nil {
    		return nil, err
    	}
    	defer conn.Close()
    
    	localAddr := conn.LocalAddr().(*UDPAddr)
    
    	return localAddr.IP, nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  9. src/cmd/pprof/pprof.go

    	// url.Parse will recognize it as a link and ultimately report an error,
    	// similar to `abc:123/mem_2023-11-02_03:55:24:
    	// Get "http://abc:123/mem_2023-11-02_03:55:24": dial tcp: lookup abc: no such host`
    	if _, openErr := os.Stat(src); openErr == nil {
    		return nil, "", nil
    	}
    	sourceURL, timeout := adjustURL(src, duration, timeout)
    	if sourceURL == "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  10. src/cmd/asm/main.go

    			flags.D = append(flags.D, "GOEXPERIMENT_"+exp)
    		}
    	}
    
    	var ok, diag bool
    	var failedFile string
    	for _, f := range flag.Args() {
    		lexer := lex.NewLexer(f)
    		parser := asm.NewParser(ctxt, architecture, lexer)
    		ctxt.DiagFunc = func(format string, args ...interface{}) {
    			diag = true
    			log.Printf(format, args...)
    		}
    		if *flags.SymABIs {
    			ok = parser.ParseSymABIs(buf)
    		} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top