Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for tcpNone (0.11 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_plan9.go

    package net
    
    import (
    	"context"
    	"io"
    	"os"
    )
    
    func (c *TCPConn) readFrom(r io.Reader) (int64, error) {
    	return genericReadFrom(c, r)
    }
    
    func (c *TCPConn) writeTo(w io.Writer) (int64, error) {
    	return genericWriteTo(c, w)
    }
    
    func (sd *sysDialer) dialTCP(ctx context.Context, laddr, raddr *TCPAddr) (*TCPConn, error) {
    	if h := sd.testHookDialTCP; h != nil {
    		return h(ctx, sd.network, laddr, raddr)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  3. 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)
  4. src/net/net_test.go

    // both have completed.
    func withTCPConnPair(t *testing.T, peer1, peer2 func(c *TCPConn) error) {
    	t.Helper()
    	ln := newLocalListener(t, "tcp")
    	defer ln.Close()
    	errc := make(chan error, 2)
    	go func() {
    		c1, err := ln.Accept()
    		if err != nil {
    			errc <- err
    			return
    		}
    		err = peer1(c1.(*TCPConn))
    		c1.Close()
    		errc <- err
    	}()
    	go func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jan 22 21:04:44 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  5. 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)
  6. src/net/rawconn_test.go

    			t.Fatal(err)
    		}
    
    		c, err := Dial(ls.Listener.Addr().Network(), ls.Listener.Addr().String())
    		if err != nil {
    			t.Fatal(err)
    		}
    		defer c.Close()
    
    		cc, err := c.(*TCPConn).SyscallConn()
    		if err != nil {
    			t.Fatal(err)
    		}
    		data := []byte("HELLO-R-U-THERE")
    		if err := writeRawConn(cc, data); err != nil {
    			t.Fatal(err)
    		}
    		var b [32]byte
    		n, err := readRawConn(cc, b[:])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. src/net/writev_test.go

    		writeLog.Lock()
    		writeLog.log = append(writeLog.log, size)
    		writeLog.Unlock()
    	}
    	var want bytes.Buffer
    	for i := 0; i < chunks; i++ {
    		want.WriteByte(byte(i))
    	}
    
    	withTCPConnPair(t, func(c *TCPConn) error {
    		buffers := make(Buffers, chunks)
    		for i := range buffers {
    			buffers[i] = want.Bytes()[i : i+1]
    		}
    		var n int64
    		var err error
    		if useCopy {
    			n, err = io.Copy(c, &buffers)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 5K bytes
    - Viewed (0)
Back to top