Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for tcpNone (0.19 sec)

  1. pilot/pkg/serviceregistry/serviceentry/conversion_test.go

    			Resolution: networking.ServiceEntry_NONE,
    		},
    	}
    )
    
    var tcpNone = &config.Config{
    	Meta: config.Meta{
    		GroupVersionKind:  gvk.ServiceEntry,
    		Name:              "tcpNone",
    		Namespace:         "tcpNone",
    		CreationTimestamp: GlobalTime,
    	},
    	Spec: &networking.ServiceEntry{
    		Hosts:     []string{"tcpnone.com"},
    		Addresses: []string{"172.217.0.0/16"},
    		Ports: []*networking.ServicePort{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 39K bytes
    - Viewed (0)
  2. src/net/tcpsock_posix.go

    	return &TCPAddr{loopbackIP(net), a.Port, a.Zone}
    }
    
    func (c *TCPConn) readFrom(r io.Reader) (int64, error) {
    	if n, err, handled := spliceFrom(c.fd, r); handled {
    		return n, err
    	}
    	if n, err, handled := sendFile(c.fd, r); handled {
    		return n, err
    	}
    	return genericReadFrom(c, r)
    }
    
    func (c *TCPConn) writeTo(w io.Writer) (int64, error) {
    	if n, err, handled := spliceTo(w, c.fd); handled {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 16:54:32 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. src/net/tcpsock.go

    	return &TCPAddr{
    		IP:   addr.Addr().AsSlice(),
    		Zone: addr.Addr().Zone(),
    		Port: int(addr.Port()),
    	}
    }
    
    // TCPConn is an implementation of the [Conn] interface for TCP network
    // connections.
    type TCPConn struct {
    	conn
    }
    
    // KeepAliveConfig contains TCP keep-alive options.
    //
    // If the Idle, Interval, or Count fields are zero, a default value is chosen.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  4. src/net/tcpconn_keepalive_test.go

    			KeepAliveConfig: cfg}
    		c, err := d.Dial("tcp", ls.Listener.Addr().String())
    		if err != nil {
    			t.Fatal(err)
    		}
    		defer c.Close()
    
    		if errHook != nil {
    			t.Fatal(errHook)
    		}
    
    		sc, err := c.(*TCPConn).SyscallConn()
    		if err != nil {
    			t.Fatal(err)
    		}
    		if err := sc.Control(func(fd uintptr) {
    			verifyKeepAliveSettings(t, fdType(fd), oldCfg, cfg)
    		}); 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)
  5. 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)
  6. src/net/tcpsock_windows.go

    // license that can be found in the LICENSE file.
    
    package net
    
    import (
    	"internal/syscall/windows"
    	"syscall"
    )
    
    // SetKeepAliveConfig configures keep-alive messages sent by the operating system.
    func (c *TCPConn) SetKeepAliveConfig(config KeepAliveConfig) error {
    	if !c.ok() {
    		return syscall.EINVAL
    	}
    
    	if err := setKeepAlive(c.fd, config.Enable); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 11:49:35 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  7. src/net/splice_linux.go

    	lr, ok := r.(*io.LimitedReader)
    	if ok {
    		remain, r = lr.N, lr.R
    		if remain <= 0 {
    			return 0, nil, true
    		}
    	}
    
    	var s *netFD
    	switch v := r.(type) {
    	case *TCPConn:
    		s = v.fd
    	case tcpConnWithoutWriteTo:
    		s = v.fd
    	case *UnixConn:
    		if v.fd.net != "unix" {
    			return 0, nil, false
    		}
    		s = v.fd
    	default:
    		return 0, nil, false
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  8. src/net/tcpsock_unix.go

    //go:build (!windows && !solaris) || illumos
    
    package net
    
    import "syscall"
    
    // SetKeepAliveConfig configures keep-alive messages sent by the operating system.
    func (c *TCPConn) SetKeepAliveConfig(config KeepAliveConfig) error {
    	if !c.ok() {
    		return syscall.EINVAL
    	}
    
    	if err := setKeepAlive(c.fd, config.Enable); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  9. src/net/splice_linux_test.go

    		if n := r.(*io.LimitedReader).N; n != int64(wantN) {
    			t.Errorf("r.N = %d, want %d", n, wantN)
    		}
    	}
    
    	// poll.Splice is expected to be called when the source is not
    	// a wrapper or the destination is TCPConn.
    	if tc.limitReadSize == 0 || tc.downNet == "tcp" {
    		// We should have called poll.Splice with the right file descriptor arguments.
    		if n > 0 && !hook.called {
    			t.Fatal("expected poll.Splice to be called")
    		}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  10. src/net/tcpsock_solaris.go

    //go:build !illumos
    
    package net
    
    import (
    	"internal/syscall/unix"
    	"syscall"
    )
    
    // SetKeepAliveConfig configures keep-alive messages sent by the operating system.
    func (c *TCPConn) SetKeepAliveConfig(config KeepAliveConfig) error {
    	if !c.ok() {
    		return syscall.EINVAL
    	}
    
    	if err := setKeepAlive(c.fd, config.Enable); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 1.3K bytes
    - Viewed (0)
Back to top