diff options
-rw-r--r-- | src/mongo/transport/message_compressor_base.h | 8 | ||||
-rw-r--r-- | src/mongo/transport/message_compressor_metrics.cpp | 16 |
2 files changed, 12 insertions, 12 deletions
diff --git a/src/mongo/transport/message_compressor_base.h b/src/mongo/transport/message_compressor_base.h index 0d1a6cf631e..5bf094919af 100644 --- a/src/mongo/transport/message_compressor_base.h +++ b/src/mongo/transport/message_compressor_base.h @@ -89,28 +89,28 @@ public: /* * This returns the number of bytes passed in the input for compressData */ - int64_t getCompressedBytesIn() const { + int64_t getCompressorBytesIn() const { return _compressBytesIn.loadRelaxed(); } /* * This returns the number of bytes written to output for compressData */ - int64_t getCompressedBytesOut() const { + int64_t getCompressorBytesOut() const { return _compressBytesOut.loadRelaxed(); } /* * This returns the number of bytes passed in the input for decompressData */ - int64_t getDecompressedBytesIn() const { + int64_t getDecompressorBytesIn() const { return _decompressBytesIn.loadRelaxed(); } /* * This returns the number of bytes written to output for decompressData */ - int64_t getDecompressedBytesOut() const { + int64_t getDecompressorBytesOut() const { return _decompressBytesOut.loadRelaxed(); } diff --git a/src/mongo/transport/message_compressor_metrics.cpp b/src/mongo/transport/message_compressor_metrics.cpp index 462ba66a4b6..91ca38991e6 100644 --- a/src/mongo/transport/message_compressor_metrics.cpp +++ b/src/mongo/transport/message_compressor_metrics.cpp @@ -49,15 +49,15 @@ void appendMessageCompressionStats(BSONObjBuilder* b) { auto&& compressor = registry.getCompressor(name); BSONObjBuilder base(compressionSection.subobjStart(name)); - BSONObjBuilder compressed(base.subobjStart("compressed")); - compressed << kBytesIn << compressor->getCompressedBytesIn() << kBytesOut - << compressor->getCompressedBytesOut(); - compressed.doneFast(); + BSONObjBuilder compressorSection(base.subobjStart("compressor")); + compressorSection << kBytesIn << compressor->getCompressorBytesIn() << kBytesOut + << compressor->getCompressorBytesOut(); + compressorSection.doneFast(); - BSONObjBuilder decompressed(base.subobjStart("decompressed")); - decompressed << kBytesIn << compressor->getDecompressedBytesIn() << kBytesOut - << compressor->getDecompressedBytesOut(); - decompressed.doneFast(); + BSONObjBuilder decompressorSection(base.subobjStart("decompressor")); + decompressorSection << kBytesIn << compressor->getDecompressorBytesIn() << kBytesOut + << compressor->getDecompressorBytesOut(); + decompressorSection.doneFast(); base.doneFast(); } compressionSection.doneFast(); |