- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for ListenConfig (0.39 sec)
-
internal/http/check_port_linux.go
// It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{ Control: func(network, address string, c syscall.RawConn) error { c.Control(func(fdPtr uintptr) { if opts.Interface != "" { // When interface is specified look for specifically port availability on
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.9K bytes - Viewed (0) -
src/net/tcpsock_plan9.go
func (sl *sysListener) listenTCP(ctx context.Context, laddr *TCPAddr) (*TCPListener, error) { fd, err := listenPlan9(ctx, sl.network, laddr) if err != nil { return nil, err } return &TCPListener{fd: fd, lc: sl.ListenConfig}, nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.3K bytes - Viewed (0) -
src/net/mptcpsock_linux_test.go
package net import ( "bytes" "context" "errors" "syscall" "testing" ) func newLocalListenerMPTCP(t *testing.T, envVar bool) Listener { lc := &ListenConfig{} if envVar { if !lc.MultipathTCP() { t.Fatal("MultipathTCP Listen is not on despite GODEBUG=multipathtcp=1") } } else { if lc.MultipathTCP() { t.Error("MultipathTCP should be off by default")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 00:36:57 UTC 2023 - 4.1K bytes - Viewed (0) -
tools/istio-iptables/pkg/validation/validator.go
// at most 2 message: ipv4 and ipv6 c := make(chan ReturnCode, 2) hasAtLeastOneListener := false for _, addr := range s.Config.ServerListenAddress { log.Infof("Listening on %v", addr) config := &net.ListenConfig{Control: reuseAddr} l, err := config.Listen(context.Background(), "tcp", addr) // bind to the address:port if err != nil { log.Errorf("Error on listening: %v", err) continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 01 04:37:36 UTC 2023 - 5.5K bytes - Viewed (0) -
internal/http/listener.go
listeners := make([]net.Listener, 0, len(serverAddrs)) listenErrs = make([]error, len(serverAddrs)) // Unix listener with special TCP options. listenCfg := net.ListenConfig{ Control: setTCPParametersFn(opts), } for i, serverAddr := range serverAddrs { l, e := listenCfg.Listen(ctx, "tcp", serverAddr) if e != nil { if opts.Trace != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
api/go1.11.txt
pkg go/types, method (*Var) Embedded() bool pkg net, method (*ListenConfig) Listen(context.Context, string, string) (Listener, error) pkg net, method (*ListenConfig) ListenPacket(context.Context, string, string) (PacketConn, error) pkg net, type Dialer struct, Control func(string, string, syscall.RawConn) error pkg net, type ListenConfig struct pkg net, type ListenConfig struct, Control func(string, string, syscall.RawConn) error
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 22 03:48:56 UTC 2018 - 25K bytes - Viewed (0) -
src/net/listen_test.go
continue } ln := newLocalListener(t, network, &ListenConfig{Control: controlOnConnSetup}) ln.Close() } }) t.Run("PacketListen", func(t *testing.T) { for _, network := range []string{"udp", "udp4", "udp6", "unixgram"} { if !testableNetwork(network) { continue } c := newLocalPacketListener(t, network, &ListenConfig{Control: controlOnConnSetup}) c.Close() } })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.5K bytes - Viewed (0) -
api/go1.23.txt
pkg net, type KeepAliveConfig struct, Enable bool #62254 pkg net, type KeepAliveConfig struct, Idle time.Duration #62254 pkg net, type KeepAliveConfig struct, Interval time.Duration #62254 pkg net, type ListenConfig struct, KeepAliveConfig KeepAliveConfig #62254 pkg net/http, func ParseCookie(string) ([]*Cookie, error) #66008 pkg net/http, func ParseSetCookie(string) (*Cookie, error) #66008
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 05 20:48:49 UTC 2024 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving.go
} if s.BindPort <= 0 && s.Listener == nil { return nil } if s.Listener == nil { var err error addr := net.JoinHostPort(s.BindAddress.String(), strconv.Itoa(s.BindPort)) c := net.ListenConfig{} ctls := multipleControls{} if s.PermitPortSharing { ctls = append(ctls, permitPortReuse) } if s.PermitAddressSharing { ctls = append(ctls, permitAddressReuse) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 13:08:18 UTC 2024 - 15.9K bytes - Viewed (1) -
api/go1.21.txt
pkg net/http, var ErrSchemeMismatch error #44855 pkg net, method (*Dialer) MultipathTCP() bool #56539 pkg net, method (*Dialer) SetMultipathTCP(bool) #56539 pkg net, method (*ListenConfig) MultipathTCP() bool #56539 pkg net, method (*ListenConfig) SetMultipathTCP(bool) #56539 pkg net, method (*TCPConn) MultipathTCP() (bool, error) #59166 pkg reflect, method (Value) Clear() #55002 pkg reflect, type SliceHeader //deprecated #56906
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 07 09:39:17 UTC 2023 - 25.6K bytes - Viewed (0)