- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for tcpNone (0.11 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
doc/next/6-stdlib/99-minor/net/62254.md
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 20:57:18 UTC 2024 - 205 bytes - Viewed (0) -
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) -
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)