()
| 402 | } |
| 403 | |
| 404 | func (srv *Server) closeDoneChanLocked() { |
| 405 | ch := srv.getDoneChanLocked() |
| 406 | select { |
| 407 | case <-ch: |
| 408 | // Already closed. Don't close again. |
| 409 | default: |
| 410 | // Safe to close here. We're the only closer, guarded |
| 411 | // by srv.mu. |
| 412 | close(ch) |
| 413 | } |
| 414 | } |
| 415 | |
| 416 | func (srv *Server) closeListenersLocked() error { |
| 417 | var err error |
no test coverage detected