- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for forceClose (0.09 sec)
-
pkg/test/echo/server/endpoint/util.go
if err != nil { return nil, 0, err } port = ln.LocalAddr().(*net.UDPAddr).Port return ln, port, nil } // forceClose the given socket. func forceClose(conn net.Conn) error { // Close may be called more than once. defer func() { _ = conn.Close() }() // Force the connection closed (should result in sending RST)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/tcp.go
go func() { select { case <-done: return case <-time.After(requestTimeout): epLog.WithLabels("id", id).Warnf("TCP forcing connection closed after request timeout") _ = forceClose(conn) return } }() } }() // Notify the WaitGroup once the port has transitioned to ready. go s.awaitReady(onReady, listener.Addr().String()) return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 16:20:31 UTC 2023 - 5.7K bytes - Viewed (0)