awaitNewConnLogOutput waits for any of grpc.NewConn's goroutines to terminate, if they're still running. It spams logs with this message. We wait for it so our log filter is still active. Otherwise the "defer restore()" at the top of various test functions restores our log filter and then the gorou
()
| 5078 | // active. Otherwise the "defer restore()" at the top of various test |
| 5079 | // functions restores our log filter and then the goroutine spams. |
| 5080 | func awaitNewConnLogOutput() { |
| 5081 | awaitLogOutput(50*time.Millisecond, "grpc: the client connection is closing; please retry") |
| 5082 | } |
| 5083 | |
| 5084 | func awaitLogOutput(maxWait time.Duration, phrase string) { |
| 5085 | pb := []byte(phrase) |
no test coverage detected