diff options
-rw-r--r-- | src/mongo/db/sorter/sorter_stats.cpp | 2 | ||||
-rw-r--r-- | src/mongo/db/sorter/sorter_stats.h | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/sorter/sorter_stats.cpp b/src/mongo/db/sorter/sorter_stats.cpp index cbdd17568c1..fefa24797bf 100644 --- a/src/mongo/db/sorter/sorter_stats.cpp +++ b/src/mongo/db/sorter/sorter_stats.cpp @@ -35,7 +35,7 @@ namespace mongo { SorterFileStats::SorterFileStats(SorterTracker* sorterTracker) : _sorterTracker(sorterTracker){}; void SorterFileStats::addSpilledDataSize(long long data) { - _bytesSpilled += data; + _bytesSpilled.fetchAndAdd(data); if (_sorterTracker) { _sorterTracker->bytesSpilled.fetchAndAdd(data); } diff --git a/src/mongo/db/sorter/sorter_stats.h b/src/mongo/db/sorter/sorter_stats.h index dfce6c47b0f..db80dcf29a3 100644 --- a/src/mongo/db/sorter/sorter_stats.h +++ b/src/mongo/db/sorter/sorter_stats.h @@ -59,13 +59,13 @@ public: AtomicWord<long long> closed; long long bytesSpilled() const { - return _bytesSpilled; + return _bytesSpilled.load(); } private: SorterTracker* _sorterTracker; - long long _bytesSpilled = 0; + AtomicWord<long long> _bytesSpilled; }; /** |