Increment size before putting in the queue (#2044)

Signed-off-by: Joe Elliott <[email protected]> Co-authored-by: Juraci Paixão Kröhling <[email protected]>
jaegertracing · Jan 28, 2020 · 0e974ce · 0e974ce
1 parent da2d889
commit 0e974ce
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/queue/bounded_queue.go b/pkg/queue/bounded_queue.go
@@ -105,12 +105,13 @@ func (q *BoundedQueue) Produce(item interface{}) bool {
 		return false
 	}
 
+	q.size.Add(1)
 	select {
 	case *q.items <- item:
-		q.size.Add(1)
 		return true
 	default:
 		// should not happen, as overflows should have been captured earlier
+		q.size.Sub(1)
 		if q.onDroppedItem != nil {
 			q.onDroppedItem(item)
 		}