/** * Copyright (C) 2018-present MongoDB, Inc. * * This program is free software: you can redistribute it and/or modify * it under the terms of the Server Side Public License, version 1, * as published by MongoDB, Inc. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * Server Side Public License for more details. * * You should have received a copy of the Server Side Public License * along with this program. If not, see * . * * As a special exception, the copyright holders give permission to link the * code of portions of this program with the OpenSSL library under certain * conditions as described in each individual source file and distribute * linked combinations including the program with the OpenSSL library. You * must comply with the Server Side Public License in all respects for * all of the code used other than as permitted herein. If you modify file(s) * with this exception, you may extend this exception to your version of the * file(s), but you are not obligated to do so. If you do not wish to do so, * delete this exception statement from your version. If you delete this * exception statement from all source files in the program, then also delete * it in the license file. */ #pragma once #include #include #include #include "mongo/bson/ordering.h" #include "mongo/bson/timestamp.h" #include "mongo/db/index/multikey_paths.h" #include "mongo/db/namespace_string.h" #include "mongo/db/record_id.h" #include "mongo/db/storage/key_string.h" #include "mongo/platform/atomic_word.h" #include "mongo/platform/mutex.h" #include "mongo/util/debug_util.h" namespace mongo { class CollatorInterface; class Collection; class CollectionPtr; class CollectionCatalogEntry; class Ident; class IndexAccessMethod; class SortedDataIndexAccessMethod; class IndexBuildInterceptor; class IndexDescriptor; class MatchExpression; class OperationContext; class IndexCatalogEntry : public std::enable_shared_from_this { public: IndexCatalogEntry() = default; virtual ~IndexCatalogEntry() = default; inline IndexCatalogEntry(IndexCatalogEntry&&) = delete; inline IndexCatalogEntry& operator=(IndexCatalogEntry&&) = delete; virtual void init(std::unique_ptr accessMethod) = 0; virtual const std::string& getIdent() const = 0; virtual std::shared_ptr getSharedIdent() const = 0; virtual IndexDescriptor* descriptor() = 0; virtual const IndexDescriptor* descriptor() const = 0; virtual IndexAccessMethod* accessMethod() const = 0; virtual bool isHybridBuilding() const = 0; virtual IndexBuildInterceptor* indexBuildInterceptor() const = 0; virtual void setIndexBuildInterceptor(IndexBuildInterceptor* interceptor) = 0; virtual const Ordering& ordering() const = 0; virtual const MatchExpression* getFilterExpression() const = 0; virtual const CollatorInterface* getCollator() const = 0; /** * Looks up the namespace name in the durable catalog. May do I/O. */ virtual NamespaceString getNSSFromCatalog(OperationContext* opCtx) const = 0; /// --------------------- virtual void setIsReady(bool newIsReady) = 0; virtual void setDropped() = 0; virtual bool isDropped() const = 0; // -- /** * Returns true if this index is multikey and false otherwise. */ virtual bool isMultikey(OperationContext* opCtx, const CollectionPtr& collection) const = 0; /** * Returns the path components that cause this index to be multikey if this index supports * path-level multikey tracking, and returns an empty vector if path-level multikey tracking * isn't supported. * * If this index supports path-level multikey tracking but isn't multikey, then this function * returns a vector with size equal to the number of elements in the index key pattern where * each element in the vector is an empty set. */ virtual MultikeyPaths getMultikeyPaths(OperationContext* opCtx, const CollectionPtr& collection) const = 0; /** * Sets this index to be multikey. Information regarding which newly detected path components * cause this index to be multikey can also be specified. * * If this index doesn't support path-level multikey tracking, then 'multikeyPaths' is ignored. * * If this index supports path-level multikey tracking, then 'multikeyPaths' must be a vector * with size equal to the number of elements in the index key pattern. Additionally, at least * one path component of the indexed fields must cause this index to be multikey. * * If isTrackingMultikeyPathInfo() is set on the OperationContext's MultikeyPathTracker, * then after we confirm that we actually need to set the index as multikey, we will save the * namespace, index name, and multikey paths on the OperationContext rather than set the index * as multikey here. */ virtual void setMultikey(OperationContext* opCtx, const CollectionPtr& coll, const KeyStringSet& multikeyMetadataKeys, const MultikeyPaths& multikeyPaths) const = 0; /** * Sets the index to be multikey with the provided paths. This performs minimal validation of * the inputs and is intended to be used internally to "correct" multikey metadata that drifts * from the underlying data. * * This may also be used to allow indexes built before 3.4 to start tracking multikey path * metadata in the catalog. */ virtual void forceSetMultikey(OperationContext* opCtx, const CollectionPtr& coll, bool isMultikey, const MultikeyPaths& multikeyPaths) const = 0; /** * Returns whether this index is ready for queries. This is potentially unsafe in that it does * not consider whether the index is visible or ready in the current storage snapshot. For * that, use isReadyInMySnapshot() or isPresentInMySnapshot(). */ virtual bool isReady(OperationContext* opCtx) const = 0; /** * Safely check whether this index is visible in the durable catalog in the current storage * snapshot. */ virtual bool isPresentInMySnapshot(OperationContext* opCtx) const = 0; /** * Check whether this index is ready in the durable catalog in the current storage snapshot. It * is unsafe to call this if isPresentInMySnapshot() has not also been checked. */ virtual bool isReadyInMySnapshot(OperationContext* opCtx) const = 0; /** * Returns true if this index is not ready, and it is not currently in the process of being * built either. */ virtual bool isFrozen() const = 0; /** * Returns true if the documents should be validated for incompatible values for this index. */ virtual bool shouldValidateDocument() const = 0; /** * If return value is not boost::none, reads with majority read concern using an older snapshot * must treat this index as unfinished. */ virtual boost::optional getMinimumVisibleSnapshot() const = 0; virtual void setMinimumVisibleSnapshot(Timestamp name) = 0; }; class IndexCatalogEntryContainer { public: typedef std::vector>::const_iterator const_iterator; typedef std::vector>::const_iterator iterator; const_iterator begin() const { return _entries.begin(); } const_iterator end() const { return _entries.end(); } iterator begin() { return _entries.begin(); } iterator end() { return _entries.end(); } unsigned size() const { return _entries.size(); } // ----------------- /** * Removes from _entries and returns the matching entry or NULL if none matches. */ std::shared_ptr release(const IndexDescriptor* desc); bool remove(const IndexDescriptor* desc) { return static_cast(release(desc)); } void add(std::shared_ptr&& entry) { _entries.push_back(std::move(entry)); } std::vector> getAllEntries() const { return {_entries.begin(), _entries.end()}; } private: std::vector> _entries; }; } // namespace mongo