Skip to content

Commit ecc075c

Browse files
committed
Unblock tbf on close
1 parent 9774e41 commit ecc075c

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

vnet/tbf.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,10 @@ func NewTokenBucketFilter(n NIC, opts ...TBFOption) (*TokenBucketFilter, error)
112112
}
113113

114114
func (t *TokenBucketFilter) onInboundChunk(c Chunk) {
115-
t.c <- c
115+
select {
116+
case t.c <- c:
117+
case <-t.done:
118+
}
116119
}
117120

118121
func (t *TokenBucketFilter) run() {

0 commit comments

Comments
 (0)