- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ListenConfig (0.2 sec)
-
src/net/dial.go
if err != nil { return nil, &OpError{Op: "dial", Net: sd.network, Source: la, Addr: ra, Err: err} // c is non-nil interface containing nil pointer } return c, nil } // ListenConfig contains options for listening to an address. type ListenConfig struct { // If Control is not nil, it is called after creating the network // connection but before binding it to the operating system. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
src/net/mockserver_test.go
if err := os.RemoveAll(d); err != nil { t.Error(err) } }) return filepath.Join(d, "sock") } func newLocalListener(t testing.TB, network string, lcOpt ...*ListenConfig) Listener { var lc *ListenConfig switch len(lcOpt) { case 0: lc = new(ListenConfig) case 1: lc = lcOpt[0] default: t.Helper() t.Fatal("too many ListenConfigs passed to newLocalListener: want 0 or 1") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 13.3K 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) -
src/net/tcpsock.go
} return c, nil } // TCPListener is a TCP network listener. Clients should typically // use variables of type [Listener] instead of assuming TCP. type TCPListener struct { fd *netFD lc ListenConfig } // SyscallConn returns a raw network connection. // This implements the [syscall.Conn] interface. // // The returned RawConn only supports calling Control. Read and // Write return an error.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 13.7K bytes - Viewed (0) -
src/net/dial_test.go
}) handler := func(ls *localServer, ln Listener) { for { c, err := ln.Accept() if err != nil { return } c.Close() } } ln := newLocalListener(t, "tcp", &ListenConfig{ KeepAlive: -1, // prevent calling hook from accepting }) ls := (&streamListener{Listener: ln}).newLocalServer() defer ls.teardown() if err := ls.buildup(handler); err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 30.3K bytes - Viewed (0)