diff options
| author | Kshitij Gupta <kshitij.gupta@mongodb.com> | 2021-07-09 14:11:19 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-07-26 18:22:57 +0000 |
| commit | e1cd49482c88e06167dc445cb44f63d3115b36c8 (patch) | |
| tree | d008c1ddbb349f2889f2864a1658fcb80dd4008b | |
| parent | 3ff0ac5911f1909dea123cee24a6824a4ce0c658 (diff) | |
| download | mongo-e1cd49482c88e06167dc445cb44f63d3115b36c8.tar.gz | |
SERVER-58395: Resharding metrics should set donorState/RecipientState to kUnused if they are not initialized for currentOp report.
(cherry picked from commit 321032021822297b6135cee97780ebfb8651eceb)
| -rw-r--r-- | src/mongo/db/s/resharding/resharding_metrics.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/s/resharding/resharding_metrics.cpp b/src/mongo/db/s/resharding/resharding_metrics.cpp index e0eed9fdac3..a47cffc131b 100644 --- a/src/mongo/db/s/resharding/resharding_metrics.cpp +++ b/src/mongo/db/s/resharding/resharding_metrics.cpp @@ -200,7 +200,8 @@ void ReshardingMetrics::OperationMetrics::appendCurrentOpMetrics(BSONObjBuilder* case Role::kDonor: bob->append(kWritesDuringCritialSection, writesDuringCriticalSection); bob->append(kCriticalSectionTimeElapsed, getElapsedTime(inCriticalSection)); - bob->append(kDonorState, serializeState(donorState)); + bob->append(kDonorState, + serializeState(donorState.get_value_or(DonorStateEnum::kUnused))); bob->append(kOpStatus, ReshardingOperationStatus_serializer(opStatus)); break; case Role::kRecipient: @@ -213,7 +214,8 @@ void ReshardingMetrics::OperationMetrics::appendCurrentOpMetrics(BSONObjBuilder* bob->append(kOplogsFetched, oplogEntriesFetched); bob->append(kOplogsApplied, oplogEntriesApplied); bob->append(kApplyTimeElapsed, getElapsedTime(applyingOplogEntries)); - bob->append(kRecipientState, serializeState(recipientState)); + bob->append(kRecipientState, + serializeState(recipientState.get_value_or(RecipientStateEnum::kUnused))); bob->append(kOpStatus, ReshardingOperationStatus_serializer(opStatus)); break; case Role::kCoordinator: |