diff options
Diffstat (limited to 'src/mongo/util/producer_consumer_queue_test.cpp')
| -rw-r--r-- | src/mongo/util/producer_consumer_queue_test.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/util/producer_consumer_queue_test.cpp b/src/mongo/util/producer_consumer_queue_test.cpp index 34ff9227a8d..ba39482d0d0 100644 --- a/src/mongo/util/producer_consumer_queue_test.cpp +++ b/src/mongo/util/producer_consumer_queue_test.cpp @@ -861,7 +861,7 @@ PRODUCER_CONSUMER_QUEUE_TEST(pipeProducerEndClosesAfterProducersLeave, ASSERT_EQUALS(consumer.pop(), MoveOnly(2)); auto thread3 = - helper.runThread("Producer3", [producer = std::move(producer)](OperationContext * opCtx) { + helper.runThread("Producer3", [producer = std::move(producer)](OperationContext* opCtx) { producer.push(MoveOnly(3), opCtx); }); @@ -882,7 +882,7 @@ PRODUCER_CONSUMER_QUEUE_TEST(pipeConsumerEndClosesAfterConsumersLeave, helper.runThread("Consumer2", [consumer](OperationContext* opCtx) { consumer.pop(opCtx); }); auto thread3 = - helper.runThread("Consumer3", [consumer = std::move(consumer)](OperationContext * opCtx) { + helper.runThread("Consumer3", [consumer = std::move(consumer)](OperationContext* opCtx) { consumer.pop(opCtx); }); |