summaryrefslogtreecommitdiff
path: root/src/mongo/util
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/util')
-rw-r--r--src/mongo/util/producer_consumer_queue.h5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/mongo/util/producer_consumer_queue.h b/src/mongo/util/producer_consumer_queue.h
index 0c5118e52d6..bef44b6f29f 100644
--- a/src/mongo/util/producer_consumer_queue.h
+++ b/src/mongo/util/producer_consumer_queue.h
@@ -439,10 +439,11 @@ public:
size_t waitingConsumers;
size_t waitingProducers;
size_t producerQueueDepth;
+ bool producerEndClosed;
+ bool consumerEndClosed;
// TODO more stats
//
// totalTimeBlocked on either side
- // closed ends
// count of producers and consumers (blocked, or existing if we're a pipe)
};
@@ -629,6 +630,8 @@ public:
stats.waitingConsumers = _consumers;
stats.waitingProducers = _producers;
stats.producerQueueDepth = _producers.queueDepth();
+ stats.producerEndClosed = _producerEndClosed;
+ stats.consumerEndClosed = _consumerEndClosed;
return stats;
}