buffer: handle cancel timeout explicitly

thda · Sep 27, 2019 · cf9b6a0 · cf9b6a0
1 parent 49af1c6
commit cf9b6a0
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/buffer.go b/buffer.go
@@ -543,6 +543,8 @@ func (b *buf) processCancel() (err error) {
 	// this will effectively block until cancel packet is sent
 	select {
 	case cancelErr = <-b.cancelCh:
+	case <-time.After(time.Duration(b.CancelTimeout) * time.Second):
+		return fmt.Errorf("netlib: timeout while processing cancel")
 	}
 
 	// read until last packet