diff options
author | Bernard Gorman <bernard.gorman@gmail.com> | 2017-05-25 20:36:12 +0100 |
---|---|---|
committer | Bernard Gorman <bernard.gorman@gmail.com> | 2017-05-26 08:05:22 +0100 |
commit | 58486605c09672b3bfce8608dca403a145413bba (patch) | |
tree | 62f44cbd43515b591e6af6347c0a75eb5c6ab5fb /src/mongo/db/namespace_string.cpp | |
parent | 4b88bf79dc47cbdfd74a11605cc5ee1c61e379f8 (diff) | |
download | mongo-58486605c09672b3bfce8608dca403a145413bba.tar.gz |
SERVER-19318 Add $currentOp aggregation stage for mongoD
Diffstat (limited to 'src/mongo/db/namespace_string.cpp')
-rw-r--r-- | src/mongo/db/namespace_string.cpp | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/src/mongo/db/namespace_string.cpp b/src/mongo/db/namespace_string.cpp index d2bc6ac1545..0e195ee7870 100644 --- a/src/mongo/db/namespace_string.cpp +++ b/src/mongo/db/namespace_string.cpp @@ -77,6 +77,7 @@ const char kLogicalTimeKeysCollection[] = "admin.system.keys"; constexpr auto listCollectionsCursorCol = "$cmd.listCollections"_sd; constexpr auto listIndexesCursorNSPrefix = "$cmd.listIndexes."_sd; +constexpr auto collectionlessAggregateCursorCol = "$cmd.aggregate"_sd; constexpr auto dropPendingNSPrefix = "system.drop."_sd; } // namespace @@ -124,6 +125,10 @@ bool NamespaceString::isListIndexesCursorNS() const { coll().startsWith(listIndexesCursorNSPrefix); } +bool NamespaceString::isCollectionlessAggregateNS() const { + return coll() == collectionlessAggregateCursorCol; +} + NamespaceString NamespaceString::makeListCollectionsNSS(StringData dbName) { NamespaceString nss(dbName, listCollectionsCursorCol); dassert(nss.isValid()); @@ -138,6 +143,13 @@ NamespaceString NamespaceString::makeListIndexesNSS(StringData dbName, StringDat return nss; } +NamespaceString NamespaceString::makeCollectionlessAggregateNSS(StringData dbname) { + NamespaceString nss(dbname, collectionlessAggregateCursorCol); + dassert(nss.isValid()); + dassert(nss.isCollectionlessAggregateNS()); + return nss; +} + NamespaceString NamespaceString::getTargetNSForListIndexes() const { dassert(isListIndexesCursorNS()); return NamespaceString(db(), coll().substr(listIndexesCursorNSPrefix.size())); |