- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 75 for Ln (0.02 sec)
-
src/net/sendfile_test.go
t.Error("internal.poll.SendFile called with unexpected FD") } } func TestSendfile(t *testing.T) { ln := newLocalListener(t, "tcp") defer ln.Close() errc := make(chan error, 1) go func(ln Listener) { // Wait for a connection. conn, err := ln.Accept() if err != nil { errc <- err close(errc) return } go func() { defer close(errc)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0) -
src/net/tcpsock_test.go
t.Skipf("not supported on %s", runtime.GOOS) } ln, err := Listen("tcp", "127.0.0.1:0") if err != nil { t.Fatal(err) } defer ln.Close() var server Conn errc := make(chan error, 1) go func() { var err error server, err = ln.Accept() errc <- err }() client, err := Dial("tcp", ln.Addr().String()) if err != nil { t.Fatal(err) } defer client.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0) -
src/net/timeout_test.go
case "plan9": t.Skipf("not supported on %s", runtime.GOOS) } ln := newLocalListener(t, "tcp") defer ln.Close() if err := ln.(*TCPListener).SetDeadline(noDeadline); err != nil { t.Error(err) } if err := ln.(*TCPListener).SetDeadline(time.Now().Add(10 * time.Millisecond)); err != nil { t.Error(err) } c, err := ln.Accept() if err == nil { c.Close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 18:06:55 UTC 2024 - 30K bytes - Viewed (0) -
src/net/net_test.go
t.Skipf("network %s is not testable on the current platform", network) } t.Parallel() ln := newLocalListener(t, network) switch network { case "unix", "unixpacket": defer os.Remove(ln.Addr().String()) } defer ln.Close() c, err := Dial(ln.Addr().Network(), ln.Addr().String()) if err != nil { t.Fatal(err) } switch network { case "unix", "unixpacket":
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/listen_test.go
} }() if ln, err := Listen("tcp", ""); err == nil { ln.Close() } if ln, err := ListenPacket("udp", ""); err == nil { ln.Close() } if ln, err := ListenTCP("tcp", nil); err == nil { ln.Close() } if ln, err := ListenUDP("udp", nil); err == nil { ln.Close() } if ln, err := ListenIP("ip:icmp", nil); err == nil { ln.Close() } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.5K bytes - Viewed (0) -
src/net/mockserver_test.go
}, port: port, }, nil } func (ls *localServer) transponder(ln Listener, ch chan<- error) { defer close(ch) switch ln := ln.(type) { case *TCPListener: ln.SetDeadline(time.Now().Add(someTimeout)) case *UnixListener: ln.SetDeadline(time.Now().Add(someTimeout)) } c, err := ln.Accept() if err != nil { if perr := parseAcceptError(err); perr != nil { ch <- perr }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 13.3K bytes - Viewed (0) -
src/net/dial_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 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 30.3K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/likelyadjust.go
} } ln.initializedChildren = true } // calculateDepths uses the children field of loops // to determine the nesting depth (outer=1) of each // loop. This is helpful for finding exit edges. func (ln *loopnest) calculateDepths() { if ln.initializedDepth { return } ln.assembleChildren() for _, l := range ln.loops { if l.outer == nil { l.setDepth(1) } } ln.initializedDepth = true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 31 21:41:20 UTC 2022 - 15.4K bytes - Viewed (0) -
src/net/error_test.go
t.Error(perr) } } else { c.Close() t.Error("should fail") } ln, err := FileListener(f) if err != nil { if ln != nil { t.Errorf("FileListener returned non-nil interface %T(%v) with err != nil", ln, ln) } if perr := parseCommonError(err); perr != nil { t.Error(perr) } } else { ln.Close() t.Error("should fail") } pc, err := FilePacketConn(f) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.3K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/lds.go
} for _, name := range allNames { ln, ok := filter[name] if !ok { ln = listenerName{RequestedNames: sets.New[string]()} } ln.RequestedNames.Insert(requestedName) // only build the portmap if we aren't filtering this name yet, or if the existing filter is non-empty if hasPort && (!ok || len(ln.Ports) != 0) { if ln.Ports == nil { ln.Ports = map[string]struct{}{} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 14.6K bytes - Viewed (0)