- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 178 for Ln (0.06 sec)
-
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/tcpsock_unix_test.go
t.Skip("skipping in short mode") } ln := newLocalListener(t, "tcp") var wg sync.WaitGroup wg.Add(1) go func(ln Listener) { defer wg.Done() for { c, err := ln.Accept() if err != nil { return } wg.Add(1) go func(c Conn) { var b [1]byte c.Read(b[:]) c.Close() wg.Done() }(c) } }(ln) attempts := int(1e4) // larger is better
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.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/net_fake_test.go
var dialed []Conn defer func() { ln.Close() for _, c := range dialed { c.Close() } <-done }() // Since this test is not running in parallel, we expect to be able to open // all 65535 valid (fake) ports. The listener is already using one, so // we should be able to Dial the remaining 65534. for len(dialed) < (1<<16)-2 { c, err := Dial(ln.Addr().Network(), ln.Addr().String()) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.8K bytes - Viewed (0) -
src/net/http/transport_internal_test.go
func TestTransportPersistConnReadLoopEOF(t *testing.T) { ln := newLocalListener(t) defer ln.Close() connc := make(chan net.Conn, 1) go func() { defer close(connc) c, err := ln.Accept() if err != nil { t.Error(err) return } connc <- c }() tr := new(Transport) req, _ := NewRequest("GET", "http://"+ln.Addr().String(), nil) req = req.WithT(t)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K 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) -
test/heapsampling.go
objectCount += a[ln].objects } totalCount = append(totalCount, objectCount) } for i, w := range size { ln := firstLine + i if err := checkValue(frames[0], ln, "objects", count, objectsPerLine[ln]); err != nil { return err } if err := checkValue(frames[0], ln, "bytes", count*w, bytesPerLine[ln]); err != nil { return err } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 27 21:36:06 UTC 2022 - 9.7K 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) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/catalog/AbstractSourceGenerator.java
writeLn("import " + clazz + ";"); } protected void writeLn() throws IOException { writer.write(ln); } public void writeLn(String source) throws IOException { writeIndent(); writer.write(source + ln); } protected void writeIndent() throws IOException { for (int i = 0; i < indent; i++) { writer.write(" "); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 2.4K bytes - Viewed (0) -
src/runtime/race/testdata/io_test.go
fmt.Fprintf(w, "test") handlerData++ }) }) ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { t.Fatalf("net.Listen: %v", err) } defer ln.Close() go http.Serve(ln, nil) handlerData++ _, err = http.Get("http://" + ln.Addr().String()) if err != nil { t.Fatalf("http.Get: %v", err) } handlerData++ _, err = http.Get("http://" + ln.Addr().String()) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 08 07:33:58 UTC 2021 - 1.3K bytes - Viewed (0)