summaryrefslogtreecommitdiff
path: root/src/mongo/db/service_context_d.h
diff options
context:
space:
mode:
authorAndy Schwerin <schwerin@mongodb.com>2015-04-02 15:48:57 -0400
committerAndy Schwerin <schwerin@mongodb.com>2015-04-03 15:13:55 -0400
commit789ad901737cfed9f383e467464c23943c94ecf4 (patch)
treeabda24f89ace5793aad5212c1cfde9b57e4f2c9a /src/mongo/db/service_context_d.h
parent78aa03b4eda2784ae67eba32d6b103166f1c57ad (diff)
downloadmongo-789ad901737cfed9f383e467464c23943c94ecf4.tar.gz
SERVER-17878 Rename GlobalEnvironmentExperiment to ServiceContext.
Diffstat (limited to 'src/mongo/db/service_context_d.h')
-rw-r--r--src/mongo/db/service_context_d.h118
1 files changed, 118 insertions, 0 deletions
diff --git a/src/mongo/db/service_context_d.h b/src/mongo/db/service_context_d.h
new file mode 100644
index 00000000000..cae5841ee7a
--- /dev/null
+++ b/src/mongo/db/service_context_d.h
@@ -0,0 +1,118 @@
+/**
+ * Copyright (C) 2014 MongoDB Inc.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3,
+ * as published by the Free Software Foundation.
+ *
+ * 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
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ *
+ * 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 GNU Affero General 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 <boost/scoped_ptr.hpp>
+#include <vector>
+
+#include "mongo/db/service_context.h"
+#include "mongo/platform/unordered_set.h"
+#include "mongo/util/concurrency/mutex.h"
+
+namespace mongo {
+
+ class Client;
+ class StorageEngineLockFile;
+
+ class ServiceContextMongoD : public ServiceContext {
+ public:
+ typedef std::map<std::string, const StorageEngine::Factory*> FactoryMap;
+
+ ServiceContextMongoD();
+
+ ~ServiceContextMongoD();
+
+ StorageEngine* getGlobalStorageEngine();
+
+ void setGlobalStorageEngine(const std::string& name);
+
+ void shutdownGlobalStorageEngineCleanly();
+
+ void registerStorageEngine(const std::string& name,
+ const StorageEngine::Factory* factory);
+
+ bool isRegisteredStorageEngine(const std::string& name);
+
+ StorageFactoriesIterator* makeStorageFactoriesIterator();
+
+ void setKillAllOperations();
+
+ void unsetKillAllOperations();
+
+ bool getKillAllOperations();
+
+ bool killOperation(unsigned int opId);
+
+ void killAllUserOperations(const OperationContext* txn);
+
+ void registerKillOpListener(KillOpListenerInterface* listener);
+
+ OperationContext* newOpCtx();
+
+ void setOpObserver(std::unique_ptr<OpObserver> opObserver);
+
+ OpObserver* getOpObserver();
+
+ private:
+
+ bool _killOperationsAssociatedWithClientAndOpId_inlock(Client* client, unsigned int opId);
+
+ bool _globalKill;
+
+ // protected by Client::clientsMutex
+ std::vector<KillOpListenerInterface*> _killOpListeners;
+
+ boost::scoped_ptr<StorageEngineLockFile> _lockFile;
+
+ // logically owned here, but never deleted by anyone.
+ StorageEngine* _storageEngine;
+
+ // logically owned here.
+ std::unique_ptr<OpObserver> _opObserver;
+
+ // All possible storage engines are registered here through MONGO_INIT.
+ FactoryMap _storageFactories;
+ };
+
+ class StorageFactoriesIteratorMongoD : public StorageFactoriesIterator {
+ public:
+
+ typedef ServiceContextMongoD::FactoryMap::const_iterator FactoryMapIterator;
+ StorageFactoriesIteratorMongoD(const FactoryMapIterator& begin,
+ const FactoryMapIterator& end);
+
+ virtual bool more() const;
+ virtual const StorageEngine::Factory* next();
+
+ private:
+ FactoryMapIterator _curr;
+ FactoryMapIterator _end;
+ };
+
+} // namespace mongo