diff options
Diffstat (limited to 'src/mongo/logger/logstream_builder.cpp')
| -rw-r--r-- | src/mongo/logger/logstream_builder.cpp | 197 |
1 files changed, 95 insertions, 102 deletions
diff --git a/src/mongo/logger/logstream_builder.cpp b/src/mongo/logger/logstream_builder.cpp index 1adef55dd6d..aa5d9d63eac 100644 --- a/src/mongo/logger/logstream_builder.cpp +++ b/src/mongo/logger/logstream_builder.cpp @@ -44,121 +44,114 @@ namespace mongo { namespace { - /// This flag indicates whether the system providing a per-thread cache of ostringstreams - /// for use by LogstreamBuilder instances is initialized and ready for use. Until this - /// flag is true, LogstreamBuilder instances must not use the cache. - bool isThreadOstreamCacheInitialized = false; - - MONGO_INITIALIZER(LogstreamBuilder)(InitializerContext*) { - isThreadOstreamCacheInitialized = true; - return Status::OK(); - } +/// This flag indicates whether the system providing a per-thread cache of ostringstreams +/// for use by LogstreamBuilder instances is initialized and ready for use. Until this +/// flag is true, LogstreamBuilder instances must not use the cache. +bool isThreadOstreamCacheInitialized = false; + +MONGO_INITIALIZER(LogstreamBuilder)(InitializerContext*) { + isThreadOstreamCacheInitialized = true; + return Status::OK(); +} } // namespace - TSP_DECLARE(std::unique_ptr<std::ostringstream>, threadOstreamCache); - TSP_DEFINE(std::unique_ptr<std::ostringstream>, threadOstreamCache); +TSP_DECLARE(std::unique_ptr<std::ostringstream>, threadOstreamCache); +TSP_DEFINE(std::unique_ptr<std::ostringstream>, threadOstreamCache); namespace { - // During unittests, where we don't use quickExit(), static finalization may destroy the - // cache before its last use, so mark it as not initialized in that case. - // This must be after the TSP_DEFINE so that it is destroyed first. - struct ThreadOstreamCacheFinalizer { - ~ThreadOstreamCacheFinalizer() { - isThreadOstreamCacheInitialized = false; - } - } threadOstreamCacheFinalizer; -} // namespace - -namespace logger { - - LogstreamBuilder::LogstreamBuilder(MessageLogDomain* domain, - std::string contextName, - LogSeverity severity) - : LogstreamBuilder(domain, - std::move(contextName), - std::move(severity), - LogComponent::kDefault) {} - - LogstreamBuilder::LogstreamBuilder(MessageLogDomain* domain, - std::string contextName, - LogSeverity severity, - LogComponent component) - : _domain(domain), - _contextName(std::move(contextName)), - _severity(std::move(severity)), - _component(std::move(component)), - _tee(nullptr) { - } - - LogstreamBuilder::LogstreamBuilder(logger::MessageLogDomain* domain, - const std::string& contextName, - LabeledLevel labeledLevel) - : LogstreamBuilder(domain, - std::move(contextName), - static_cast<LogSeverity>(labeledLevel)) { - - setBaseMessage(labeledLevel.getLabel()); - } - - LogstreamBuilder::LogstreamBuilder(LogstreamBuilder&& other) - : _domain(std::move(other._domain)), - _contextName(std::move(other._contextName)), - _severity(std::move(other._severity)), - _component(std::move(other._component)), - _baseMessage(std::move(other._baseMessage)), - _os(std::move(other._os)), - _tee(std::move(other._tee)) { - } - - LogstreamBuilder& LogstreamBuilder::operator=(LogstreamBuilder&& other) { - _domain = std::move(other._domain); - _contextName = std::move(other._contextName); - _severity = std::move(other._severity); - _component = std::move(other._component); - _baseMessage = std::move(other._baseMessage); - _os = std::move(other._os); - _tee = std::move(other._tee); - return *this; +// During unittests, where we don't use quickExit(), static finalization may destroy the +// cache before its last use, so mark it as not initialized in that case. +// This must be after the TSP_DEFINE so that it is destroyed first. +struct ThreadOstreamCacheFinalizer { + ~ThreadOstreamCacheFinalizer() { + isThreadOstreamCacheInitialized = false; } +} threadOstreamCacheFinalizer; +} // namespace +namespace logger { - LogstreamBuilder::~LogstreamBuilder() { - if (_os) { - if ( !_baseMessage.empty() ) _baseMessage.push_back(' '); - _baseMessage += _os->str(); - MessageEventEphemeral message(Date_t::now(), _severity, _component, _contextName, - _baseMessage); - _domain->append(message); - if (_tee) { - _os->str(""); - logger::MessageEventDetailsEncoder teeEncoder; - teeEncoder.encode(message, *_os); - _tee->write(_os->str()); - } +LogstreamBuilder::LogstreamBuilder(MessageLogDomain* domain, + std::string contextName, + LogSeverity severity) + : LogstreamBuilder( + domain, std::move(contextName), std::move(severity), LogComponent::kDefault) {} + +LogstreamBuilder::LogstreamBuilder(MessageLogDomain* domain, + std::string contextName, + LogSeverity severity, + LogComponent component) + : _domain(domain), + _contextName(std::move(contextName)), + _severity(std::move(severity)), + _component(std::move(component)), + _tee(nullptr) {} + +LogstreamBuilder::LogstreamBuilder(logger::MessageLogDomain* domain, + const std::string& contextName, + LabeledLevel labeledLevel) + : LogstreamBuilder(domain, std::move(contextName), static_cast<LogSeverity>(labeledLevel)) { + setBaseMessage(labeledLevel.getLabel()); +} + +LogstreamBuilder::LogstreamBuilder(LogstreamBuilder&& other) + : _domain(std::move(other._domain)), + _contextName(std::move(other._contextName)), + _severity(std::move(other._severity)), + _component(std::move(other._component)), + _baseMessage(std::move(other._baseMessage)), + _os(std::move(other._os)), + _tee(std::move(other._tee)) {} + +LogstreamBuilder& LogstreamBuilder::operator=(LogstreamBuilder&& other) { + _domain = std::move(other._domain); + _contextName = std::move(other._contextName); + _severity = std::move(other._severity); + _component = std::move(other._component); + _baseMessage = std::move(other._baseMessage); + _os = std::move(other._os); + _tee = std::move(other._tee); + return *this; +} + + +LogstreamBuilder::~LogstreamBuilder() { + if (_os) { + if (!_baseMessage.empty()) + _baseMessage.push_back(' '); + _baseMessage += _os->str(); + MessageEventEphemeral message( + Date_t::now(), _severity, _component, _contextName, _baseMessage); + _domain->append(message); + if (_tee) { _os->str(""); - if (isThreadOstreamCacheInitialized && !threadOstreamCache.getMake()->get()) { - *threadOstreamCache.get() = std::move(_os); - } + logger::MessageEventDetailsEncoder teeEncoder; + teeEncoder.encode(message, *_os); + _tee->write(_os->str()); + } + _os->str(""); + if (isThreadOstreamCacheInitialized && !threadOstreamCache.getMake()->get()) { + *threadOstreamCache.get() = std::move(_os); } } - - void LogstreamBuilder::operator<<(Tee* tee) { - makeStream(); // Adding a Tee counts for purposes of deciding to make a log message. - // TODO: dassert(!_tee); - _tee = tee; - } - - void LogstreamBuilder::makeStream() { - if (!_os) { - if (isThreadOstreamCacheInitialized && threadOstreamCache.getMake()->get()) { - _os = std::move(*threadOstreamCache.get()); - } - else { - _os = stdx::make_unique<std::ostringstream>(); - } +} + +void LogstreamBuilder::operator<<(Tee* tee) { + makeStream(); // Adding a Tee counts for purposes of deciding to make a log message. + // TODO: dassert(!_tee); + _tee = tee; +} + +void LogstreamBuilder::makeStream() { + if (!_os) { + if (isThreadOstreamCacheInitialized && threadOstreamCache.getMake()->get()) { + _os = std::move(*threadOstreamCache.get()); + } else { + _os = stdx::make_unique<std::ostringstream>(); } } +} } // namespace logger } // namespace mongo |