Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for ListenConfig (0.16 sec)

  1. src/net/tcpsock_posix.go

    	var ctrlCtxFn func(ctx context.Context, network, address string, c syscall.RawConn) error
    	if sl.ListenConfig.Control != nil {
    		ctrlCtxFn = func(ctx context.Context, network, address string, c syscall.RawConn) error {
    			return sl.ListenConfig.Control(network, address, c)
    		}
    	}
    	fd, err := internetSocket(ctx, sl.network, laddr, nil, syscall.SOCK_STREAM, proto, "listen", ctrlCtxFn)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. src/net/iprawsock_posix.go

    		return nil, UnknownNetworkError(sl.network)
    	}
    	var ctrlCtxFn func(ctx context.Context, network, address string, c syscall.RawConn) error
    	if sl.ListenConfig.Control != nil {
    		ctrlCtxFn = func(ctx context.Context, network, address string, c syscall.RawConn) error {
    			return sl.ListenConfig.Control(network, address, c)
    		}
    	}
    	fd, err := internetSocket(ctx, network, laddr, nil, syscall.SOCK_RAW, proto, "listen", ctrlCtxFn)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. doc/next/6-stdlib/99-minor/net/62254.md

    The new type [KeepAliveConfig] permits fine-tuning the keep-alive
    options for TCP connections, via a new [TCPConn.SetKeepAliveConfig]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 20:57:18 UTC 2024
    - 205 bytes
    - Viewed (0)
  4. src/net/unixsock_posix.go

    	var ctrlCtxFn func(ctx context.Context, network, address string, c syscall.RawConn) error
    	if sl.ListenConfig.Control != nil {
    		ctrlCtxFn = func(ctx context.Context, network, address string, c syscall.RawConn) error {
    			return sl.ListenConfig.Control(network, address, c)
    		}
    	}
    	fd, err := unixSocket(ctx, sl.network, laddr, nil, "listen", 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)
  5. src/net/udpsock_posix.go

    	var ctrlCtxFn func(ctx context.Context, network, address string, c syscall.RawConn) error
    	if sl.ListenConfig.Control != nil {
    		ctrlCtxFn = func(ctx context.Context, network, address string, c syscall.RawConn) error {
    			return sl.ListenConfig.Control(network, address, c)
    		}
    	}
    	fd, err := internetSocket(ctx, sl.network, laddr, nil, syscall.SOCK_DGRAM, 0, "listen", ctrlCtxFn)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  6. src/net/tcpconn_keepalive_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: Mon Apr 15 03:10:07 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  7. internal/http/check_port_others.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{}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top