diff options
author | Martin Bligh <mbligh@mongodb.com> | 2015-09-25 09:15:47 -0400 |
---|---|---|
committer | Martin Bligh <mbligh@mongodb.com> | 2015-09-25 09:16:40 -0400 |
commit | 0c001db908b6811c0e665e15150d1d30c47b8b5c (patch) | |
tree | 50a7c8e8b40f71a1e20c25086653f2fcd0548a05 /src/mongo/db/op_observer.cpp | |
parent | 4898cb582633fd686c3057824ce0d1713284d15d (diff) | |
download | mongo-0c001db908b6811c0e665e15150d1d30c47b8b5c.tar.gz |
SERVER-20438: logOp refactor prior to vectorizing
Diffstat (limited to 'src/mongo/db/op_observer.cpp')
-rw-r--r-- | src/mongo/db/op_observer.cpp | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/src/mongo/db/op_observer.cpp b/src/mongo/db/op_observer.cpp index 2d1ce157b43..0563482a99a 100644 --- a/src/mongo/db/op_observer.cpp +++ b/src/mongo/db/op_observer.cpp @@ -47,7 +47,7 @@ void OpObserver::onCreateIndex(OperationContext* txn, const std::string& ns, BSONObj indexDoc, bool fromMigrate) { - repl::_logOp(txn, "i", ns.c_str(), indexDoc, nullptr, fromMigrate); + repl::logOp(txn, "i", ns.c_str(), indexDoc, nullptr, fromMigrate); getGlobalAuthorizationManager()->logOp(txn, "i", ns.c_str(), indexDoc, nullptr); logOpForSharding(txn, "i", ns.c_str(), indexDoc, nullptr, fromMigrate); @@ -58,7 +58,7 @@ void OpObserver::onInsert(OperationContext* txn, const NamespaceString& ns, BSONObj doc, bool fromMigrate) { - repl::_logOp(txn, "i", ns.ns().c_str(), doc, nullptr, fromMigrate); + repl::logOp(txn, "i", ns.ns().c_str(), doc, nullptr, fromMigrate); getGlobalAuthorizationManager()->logOp(txn, "i", ns.ns().c_str(), doc, nullptr); logOpForSharding(txn, "i", ns.ns().c_str(), doc, nullptr, fromMigrate); @@ -69,7 +69,7 @@ void OpObserver::onInsert(OperationContext* txn, } void OpObserver::onUpdate(OperationContext* txn, oplogUpdateEntryArgs args) { - repl::_logOp(txn, "u", args.ns.c_str(), args.update, &args.criteria, args.fromMigrate); + repl::logOp(txn, "u", args.ns.c_str(), args.update, &args.criteria, args.fromMigrate); getGlobalAuthorizationManager()->logOp(txn, "u", args.ns.c_str(), args.update, &args.criteria); logOpForSharding(txn, "u", args.ns.c_str(), args.update, &args.criteria, args.fromMigrate); @@ -83,7 +83,7 @@ void OpObserver::onDelete(OperationContext* txn, const std::string& ns, const BSONObj& idDoc, bool fromMigrate) { - repl::_logOp(txn, "d", ns.c_str(), idDoc, nullptr, fromMigrate); + repl::logOp(txn, "d", ns.c_str(), idDoc, nullptr, fromMigrate); getGlobalAuthorizationManager()->logOp(txn, "d", ns.c_str(), idDoc, nullptr); logOpForSharding(txn, "d", ns.c_str(), idDoc, nullptr, fromMigrate); @@ -94,7 +94,7 @@ void OpObserver::onDelete(OperationContext* txn, } void OpObserver::onOpMessage(OperationContext* txn, const BSONObj& msgObj) { - repl::_logOp(txn, "n", "", msgObj, nullptr, false); + repl::logOp(txn, "n", "", msgObj, nullptr, false); } void OpObserver::onCreateCollection(OperationContext* txn, @@ -108,7 +108,7 @@ void OpObserver::onCreateCollection(OperationContext* txn, if (!collectionName.isSystemDotProfile()) { // do not replicate system.profile modifications - repl::_logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); } getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), cmdObj, nullptr); @@ -123,7 +123,7 @@ void OpObserver::onCollMod(OperationContext* txn, if (!NamespaceString(NamespaceString(dbName).db(), coll).isSystemDotProfile()) { // do not replicate system.profile modifications - repl::_logOp(txn, "c", dbName.c_str(), collModCmd, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), collModCmd, nullptr, false); } getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), collModCmd, nullptr); @@ -133,7 +133,7 @@ void OpObserver::onCollMod(OperationContext* txn, void OpObserver::onDropDatabase(OperationContext* txn, const std::string& dbName) { BSONObj cmdObj = BSON("dropDatabase" << 1); - repl::_logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), cmdObj, nullptr); logOpForDbHash(txn, dbName.c_str()); @@ -145,7 +145,7 @@ void OpObserver::onDropCollection(OperationContext* txn, const NamespaceString& if (!collectionName.isSystemDotProfile()) { // do not replicate system.profile modifications - repl::_logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); } getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), cmdObj, nullptr); @@ -155,7 +155,7 @@ void OpObserver::onDropCollection(OperationContext* txn, const NamespaceString& void OpObserver::onDropIndex(OperationContext* txn, const std::string& dbName, const BSONObj& idxDescriptor) { - repl::_logOp(txn, "c", dbName.c_str(), idxDescriptor, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), idxDescriptor, nullptr, false); getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), idxDescriptor, nullptr); logOpForDbHash(txn, dbName.c_str()); @@ -171,7 +171,7 @@ void OpObserver::onRenameCollection(OperationContext* txn, BSON("renameCollection" << fromCollection.ns() << "to" << toCollection.ns() << "stayTemp" << stayTemp << "dropTarget" << dropTarget); - repl::_logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), cmdObj, nullptr); logOpForDbHash(txn, dbName.c_str()); @@ -180,7 +180,7 @@ void OpObserver::onRenameCollection(OperationContext* txn, void OpObserver::onApplyOps(OperationContext* txn, const std::string& dbName, const BSONObj& applyOpCmd) { - repl::_logOp(txn, "c", dbName.c_str(), applyOpCmd, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), applyOpCmd, nullptr, false); getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), applyOpCmd, nullptr); logOpForDbHash(txn, dbName.c_str()); @@ -194,7 +194,7 @@ void OpObserver::onConvertToCapped(OperationContext* txn, if (!collectionName.isSystemDotProfile()) { // do not replicate system.profile modifications - repl::_logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); } getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), cmdObj, nullptr); @@ -207,7 +207,7 @@ void OpObserver::onEmptyCapped(OperationContext* txn, const NamespaceString& col if (!collectionName.isSystemDotProfile()) { // do not replicate system.profile modifications - repl::_logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); + repl::logOp(txn, "c", dbName.c_str(), cmdObj, nullptr, false); } getGlobalAuthorizationManager()->logOp(txn, "c", dbName.c_str(), cmdObj, nullptr); |