summaryrefslogtreecommitdiff
path: root/src/mongo/util/queue.h
diff options
context:
space:
mode:
authorChristopher Caplinger <christopher.caplinger@mongodb.com>2022-06-06 14:54:00 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-06-06 15:28:59 +0000
commiteaa1d95dd83ed50c6730da464df7a8140a65adc2 (patch)
treea01e434629e2b14c2cdee632c4e7cd8e372cf9fc /src/mongo/util/queue.h
parenta192781bcf9b9c04a18431bb07ddc72133ae53df (diff)
downloadmongo-eaa1d95dd83ed50c6730da464df7a8140a65adc2.tar.gz
SERVER-63789 Async file copy/import
Diffstat (limited to 'src/mongo/util/queue.h')
-rw-r--r--src/mongo/util/queue.h5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/util/queue.h b/src/mongo/util/queue.h
index 176e719cfdf..ee0caf01ece 100644
--- a/src/mongo/util/queue.h
+++ b/src/mongo/util/queue.h
@@ -107,6 +107,11 @@ public:
}
}
+ void pushBlocking(const T& t) {
+ std::vector<T> vec{t};
+ pushAllBlocking(vec.begin(), vec.end());
+ }
+
bool empty() const {
stdx::lock_guard<Latch> lk(_lock);
return _queue.empty();