(err error)
| 622 | } |
| 623 | |
| 624 | func (dc *DCPClient) setCloseError(err error) { |
| 625 | dc.closeErrorLock.Lock() |
| 626 | defer dc.closeErrorLock.Unlock() |
| 627 | // If the DCPClient is already closing, don't update the error. If an initial error triggered the close, |
| 628 | // then closeError will already be set. In the event of a requested close, we want to ignore EOF errors associated |
| 629 | // with stream close |
| 630 | if dc.closing.IsTrue() { |
| 631 | return |
| 632 | } |
| 633 | if dc.closeError == nil { |
| 634 | dc.closeError = err |
| 635 | } |
| 636 | } |
| 637 | |
| 638 | func (dc *DCPClient) getCloseError() error { |
| 639 | dc.closeErrorLock.Lock() |
no test coverage detected