summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/collection_cloner.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/collection_cloner.cpp')
-rw-r--r--src/mongo/db/repl/collection_cloner.cpp11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/mongo/db/repl/collection_cloner.cpp b/src/mongo/db/repl/collection_cloner.cpp
index 56066be614b..3a89ece4d4b 100644
--- a/src/mongo/db/repl/collection_cloner.cpp
+++ b/src/mongo/db/repl/collection_cloner.cpp
@@ -83,11 +83,14 @@ namespace repl {
uassert(ErrorCodes::BadValue, "null replication executor", executor);
uassert(ErrorCodes::BadValue, "invalid collection namespace: " + sourceNss.ns(),
sourceNss.isValid());
- uassert(ErrorCodes::BadValue, "null storage interface", storageInterface);
uassertStatusOK(options.validate());
+ uassert(ErrorCodes::BadValue, "callback function cannot be null", work);
+ uassert(ErrorCodes::BadValue, "null storage interface", storageInterface);
}
- CollectionCloner::~CollectionCloner() { }
+ const NamespaceString& CollectionCloner::getSourceNamespace() const {
+ return _sourceNss;
+ }
std::string CollectionCloner::getDiagnosticString() const {
boost::lock_guard<boost::mutex> lk(_mutex);
@@ -172,7 +175,7 @@ namespace repl {
}
}
- void CollectionCloner::setScheduleDbWorkFn(ScheduleDbWorkFn scheduleDbWorkFn) {
+ void CollectionCloner::setScheduleDbWorkFn(const ScheduleDbWorkFn& scheduleDbWorkFn) {
boost::lock_guard<boost::mutex> lk(_mutex);
_scheduleDbWorkFn = scheduleDbWorkFn;
@@ -293,7 +296,5 @@ namespace repl {
_work(Status::OK());
}
- CollectionCloner::StorageInterface::~StorageInterface() { }
-
} // namespace repl
} // namespace mongo