diff options
author | Jacob Evans <jacob.evans@10gen.com> | 2018-10-23 12:36:19 -0400 |
---|---|---|
committer | Jacob Evans <jacob.evans@10gen.com> | 2018-10-30 12:45:34 -0400 |
commit | 27d6f6977113551e0e3444b4f76c646d94e75a49 (patch) | |
tree | 1ed44811b1d74c6dfcbea884c64886620dcc8609 /src | |
parent | 6e33fadbe17b160f500a129c92235464ec5cd5b4 (diff) | |
download | mongo-27d6f6977113551e0e3444b4f76c646d94e75a49.tar.gz |
SERVER-14364 Make OpCounters 64-bit
Diffstat (limited to 'src')
-rw-r--r-- | src/mongo/db/stats/counters.cpp | 2 | ||||
-rw-r--r-- | src/mongo/db/stats/counters.h | 24 |
2 files changed, 13 insertions, 13 deletions
diff --git a/src/mongo/db/stats/counters.cpp b/src/mongo/db/stats/counters.cpp index af695566316..81a77016a8b 100644 --- a/src/mongo/db/stats/counters.cpp +++ b/src/mongo/db/stats/counters.cpp @@ -109,7 +109,7 @@ void OpCounters::gotOp(int op, bool isCommand) { } void OpCounters::_checkWrap() { - const unsigned MAX = 1 << 30; + const int64_t MAX = 1ULL << 60; bool wrap = _insert.loadRelaxed() > MAX || _query.loadRelaxed() > MAX || _update.loadRelaxed() > MAX || _delete.loadRelaxed() > MAX || diff --git a/src/mongo/db/stats/counters.h b/src/mongo/db/stats/counters.h index e9742797100..07e38b251a9 100644 --- a/src/mongo/db/stats/counters.h +++ b/src/mongo/db/stats/counters.h @@ -61,34 +61,34 @@ public: BSONObj getObj() const; // thse are used by snmp, and other things, do not remove - const AtomicUInt32* getInsert() const { + const AtomicInt64* getInsert() const { return &_insert; } - const AtomicUInt32* getQuery() const { + const AtomicInt64* getQuery() const { return &_query; } - const AtomicUInt32* getUpdate() const { + const AtomicInt64* getUpdate() const { return &_update; } - const AtomicUInt32* getDelete() const { + const AtomicInt64* getDelete() const { return &_delete; } - const AtomicUInt32* getGetMore() const { + const AtomicInt64* getGetMore() const { return &_getmore; } - const AtomicUInt32* getCommand() const { + const AtomicInt64* getCommand() const { return &_command; } private: void _checkWrap(); - CacheAligned<AtomicUInt32> _insert; - CacheAligned<AtomicUInt32> _query; - CacheAligned<AtomicUInt32> _update; - CacheAligned<AtomicUInt32> _delete; - CacheAligned<AtomicUInt32> _getmore; - CacheAligned<AtomicUInt32> _command; + CacheAligned<AtomicInt64> _insert; + CacheAligned<AtomicInt64> _query; + CacheAligned<AtomicInt64> _update; + CacheAligned<AtomicInt64> _delete; + CacheAligned<AtomicInt64> _getmore; + CacheAligned<AtomicInt64> _command; }; extern OpCounters globalOpCounters; |