- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 51 for tcpNone (0.14 sec)
-
src/runtime/testdata/testprogcgo/eintr.go
log.Fatal(err) } wg.Add(2) go func() { defer wg.Done() defer ln.Close() c, err := ln.Accept() if err != nil { log.Fatal(err) } defer c.Close() cf, err := c.(*net.TCPConn).File() if err != nil { log.Fatal(err) } defer cf.Close() if err := syscall.SetNonblock(int(cf.Fd()), false); err != nil { log.Fatal(err) } // See comments in testPipe.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 5.2K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
t.Fatalf("failed to assert to net.TCPListener") } var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() tcpConn, terr := tcpListener.AcceptTCP() if terr != nil { t.Errorf("failed to accept new connection. %v", terr) return } deadlineconn := New(tcpConn) deadlineconn.WithReadDeadline(time.Second) deadlineconn.WithWriteDeadline(time.Second) defer deadlineconn.Close() // Read a line
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Nov 05 18:09:21 UTC 2022 - 3K 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) -
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) -
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) -
src/net/mptcpsock_stub.go
// license that can be found in the LICENSE file. //go:build !linux package net import ( "context" ) func (sd *sysDialer) dialMPTCP(ctx context.Context, laddr, raddr *TCPAddr) (*TCPConn, error) { return sd.dialTCP(ctx, laddr, raddr) } func (sl *sysListener) listenMPTCP(ctx context.Context, laddr *TCPAddr) (*TCPListener, error) { return sl.listenTCP(ctx, laddr) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 18 13:48:22 UTC 2023 - 542 bytes - Viewed (0) -
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) -
src/net/hook.go
// license that can be found in the LICENSE file. package net import ( "context" ) var ( // if non-nil, overrides dialTCP. testHookDialTCP func(ctx context.Context, net string, laddr, raddr *TCPAddr) (*TCPConn, error) testHookLookupIP = func( ctx context.Context, fn func(context.Context, string, string) ([]IPAddr, error), network string, host string, ) ([]IPAddr, error) { return fn(ctx, network, host)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 934 bytes - Viewed (0)