diff options
| author | Adityavardhan Agrawal <adi.agrawal@mongodb.com> | 2023-02-14 14:20:29 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-02-14 17:11:49 +0000 |
| commit | c315b8d211541600441fec639a9cc473479f2ee8 (patch) | |
| tree | 917ae3382febcdff26c6b200600edcfd3b222af1 | |
| parent | cfbe26d87f74d128a33003bdd3aafd5a97a4a46e (diff) | |
| download | mongo-c315b8d211541600441fec639a9cc473479f2ee8.tar.gz | |
SERVER-73591 Make_bytesSpilled in sorterFileStats atomic
| -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; }; /** |