diff options
Diffstat (limited to 'src/mongo/util/producer_consumer_queue.h')
| -rw-r--r-- | src/mongo/util/producer_consumer_queue.h | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/mongo/util/producer_consumer_queue.h b/src/mongo/util/producer_consumer_queue.h index c103515d19f..05b39eff7db 100644 --- a/src/mongo/util/producer_consumer_queue.h +++ b/src/mongo/util/producer_consumer_queue.h @@ -336,8 +336,7 @@ public: explicit Waiter(ProducerState& x, size_t wants) : _x(x) { uassert(ErrorCodes::ProducerConsumerQueueProducerQueueDepthExceeded, str::stream() << "ProducerConsumerQueue producer queue depth exceeded, " - << (_x._producerQueueDepth + wants) - << " > " + << (_x._producerQueueDepth + wants) << " > " << _x._maxProducerQueueDepth, _x._maxProducerQueueDepth == std::numeric_limits<size_t>::max() || _x._producerQueueDepth + wants <= _x._maxProducerQueueDepth); @@ -473,8 +472,7 @@ public: auto cost = _invokeCostFunc(t, lk); uassert(ErrorCodes::ProducerConsumerQueueBatchTooLarge, str::stream() << "cost of item (" << cost - << ") larger than maximum queue size (" - << _options.maxQueueDepth + << ") larger than maximum queue size (" << _options.maxQueueDepth << ")", cost <= _options.maxQueueDepth); @@ -506,8 +504,7 @@ public: uassert(ErrorCodes::ProducerConsumerQueueBatchTooLarge, str::stream() << "cost of items in batch (" << cost - << ") larger than maximum queue size (" - << _options.maxQueueDepth + << ") larger than maximum queue size (" << _options.maxQueueDepth << ")", cost <= _options.maxQueueDepth); |