summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/balancer
diff options
context:
space:
mode:
authorKevin Pulo <kevin.pulo@mongodb.com>2018-11-01 21:17:00 +0000
committerKevin Pulo <kevin.pulo@mongodb.com>2018-11-14 01:38:39 +0000
commitc2cc425b9d2b23eead06ecbfd996375e47c81baa (patch)
treeca24166f5800b1cbee8254148b26c41a9c9f0195 /src/mongo/db/s/balancer
parent20ca44d3ab1dce18c71ff726fcab3591b809137a (diff)
downloadmongo-c2cc425b9d2b23eead06ecbfd996375e47c81baa.tar.gz
SERVER-36411 include shard id/name in changelog/actionlog entries
Diffstat (limited to 'src/mongo/db/s/balancer')
-rw-r--r--src/mongo/db/s/balancer/balancer.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/mongo/db/s/balancer/balancer.cpp b/src/mongo/db/s/balancer/balancer.cpp
index 7807503b473..f5570a52507 100644
--- a/src/mongo/db/s/balancer/balancer.cpp
+++ b/src/mongo/db/s/balancer/balancer.cpp
@@ -45,6 +45,7 @@
#include "mongo/db/operation_context.h"
#include "mongo/db/s/balancer/balancer_chunk_selection_policy_impl.h"
#include "mongo/db/s/balancer/cluster_statistics_impl.h"
+#include "mongo/db/s/sharding_logging.h"
#include "mongo/s/balancer_configuration.h"
#include "mongo/s/catalog/type_chunk.h"
#include "mongo/s/catalog_cache.h"
@@ -381,7 +382,7 @@ void Balancer::_mainThread() {
roundDetails.setSucceeded(static_cast<int>(candidateChunks.size()),
_balancedLastTime);
- shardingContext->catalogClient()
+ ShardingLogging::get(opCtx.get())
->logAction(opCtx.get(), "balancer.round", "", roundDetails.toBSON())
.transitional_ignore();
}
@@ -401,7 +402,7 @@ void Balancer::_mainThread() {
// This round failed, tell the world!
roundDetails.setFailed(e.what());
- shardingContext->catalogClient()
+ ShardingLogging::get(opCtx.get())
->logAction(opCtx.get(), "balancer.round", "", roundDetails.toBSON())
.transitional_ignore();