diff options
author | Benety Goh <benety@mongodb.com> | 2014-06-26 18:08:46 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2014-06-27 09:42:54 -0400 |
commit | a67bddc57c9b8a8d9d13ac30ebe74f9914b0c6d0 (patch) | |
tree | abe4d1f230c8c25bf83bce46dd5b789c5260736f | |
parent | b08b3ae8320d747f25da30f3fca939051707677c (diff) | |
download | mongo-a67bddc57c9b8a8d9d13ac30ebe74f9914b0c6d0.tar.gz |
SERVER-5092 tagged storage and networking LOG() messages
-rw-r--r-- | src/mongo/client/connpool.cpp | 5 | ||||
-rw-r--r-- | src/mongo/db/storage/mmap_v1/dur.cpp | 3 | ||||
-rw-r--r-- | src/mongo/db/storage/mmap_v1/dur_journal.cpp | 5 | ||||
-rw-r--r-- | src/mongo/db/storage/mmap_v1/dur_journalformat.h | 5 | ||||
-rw-r--r-- | src/mongo/db/storage/mmap_v1/dur_writetodatafiles.cpp | 6 | ||||
-rw-r--r-- | src/mongo/db/storage/mmap_v1/durable_mapped_file.cpp | 5 | ||||
-rw-r--r-- | src/mongo/db/storage/mmap_v1/durop.cpp | 5 | ||||
-rw-r--r-- | src/mongo/db/storage/mmap_v1/durop.h | 2 | ||||
-rw-r--r-- | src/mongo/db/storage/mmap_v1/mmap_v1_extent_manager.cpp | 3 | ||||
-rw-r--r-- | src/mongo/db/structure/record_store_v1_simple.cpp | 5 | ||||
-rw-r--r-- | src/mongo/util/file_allocator.cpp | 5 | ||||
-rw-r--r-- | src/mongo/util/net/listen.cpp | 4 | ||||
-rw-r--r-- | src/mongo/util/net/message_port.cpp | 4 | ||||
-rw-r--r-- | src/mongo/util/net/miniwebserver.cpp | 5 | ||||
-rw-r--r-- | src/mongo/util/net/sock.cpp | 6 |
15 files changed, 57 insertions, 11 deletions
diff --git a/src/mongo/client/connpool.cpp b/src/mongo/client/connpool.cpp index 7f723dac582..647cc851d20 100644 --- a/src/mongo/client/connpool.cpp +++ b/src/mongo/client/connpool.cpp @@ -30,15 +30,18 @@ // _ todo: reconnect? -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/client/connpool.h" #include "mongo/client/replica_set_monitor.h" #include "mongo/client/syncclusterconnection.h" +#include "mongo/util/log.h" #include "mongo/s/shard.h" namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kNetworking); + // ------ PoolForHost ------ PoolForHost::~PoolForHost() { diff --git a/src/mongo/db/storage/mmap_v1/dur.cpp b/src/mongo/db/storage/mmap_v1/dur.cpp index 9a8fabbc66b..47b24608244 100644 --- a/src/mongo/db/storage/mmap_v1/dur.cpp +++ b/src/mongo/db/storage/mmap_v1/dur.cpp @@ -86,6 +86,7 @@ #include "mongo/db/storage_options.h" #include "mongo/server.h" #include "mongo/util/concurrency/race.h" +#include "mongo/util/log.h" #include "mongo/util/mongoutils/hash.h" #include "mongo/util/mongoutils/str.h" #include "mongo/util/stacktrace.h" @@ -95,6 +96,8 @@ using namespace mongoutils; namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kStorage); + namespace dur { void PREPLOGBUFFER(JSectHeader& outParm, AlignedBuilder&); diff --git a/src/mongo/db/storage/mmap_v1/dur_journal.cpp b/src/mongo/db/storage/mmap_v1/dur_journal.cpp index 7b499b42277..127b43ef0dd 100644 --- a/src/mongo/db/storage/mmap_v1/dur_journal.cpp +++ b/src/mongo/db/storage/mmap_v1/dur_journal.cpp @@ -28,7 +28,7 @@ * it in the license file. */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/db/storage/mmap_v1/dur_journal.h" @@ -49,6 +49,7 @@ #include "mongo/util/compress.h" #include "mongo/util/concurrency/race.h" #include "mongo/util/file.h" +#include "mongo/util/log.h" #include "mongo/util/logfile.h" #include "mongo/util/mmap.h" #include "mongo/util/mongoutils/str.h" @@ -60,6 +61,8 @@ using namespace mongoutils; namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kStorage); + class AlignedBuilder; diff --git a/src/mongo/db/storage/mmap_v1/dur_journalformat.h b/src/mongo/db/storage/mmap_v1/dur_journalformat.h index 5bf73bacfb8..80ea90bd78a 100644 --- a/src/mongo/db/storage/mmap_v1/dur_journalformat.h +++ b/src/mongo/db/storage/mmap_v1/dur_journalformat.h @@ -30,6 +30,11 @@ #pragma once +#include <sstream> +#include <string> + +#include "mongo/util/assert_util.h" + namespace mongo { namespace dur { diff --git a/src/mongo/db/storage/mmap_v1/dur_writetodatafiles.cpp b/src/mongo/db/storage/mmap_v1/dur_writetodatafiles.cpp index 05ed343c209..f64963afc26 100644 --- a/src/mongo/db/storage/mmap_v1/dur_writetodatafiles.cpp +++ b/src/mongo/db/storage/mmap_v1/dur_writetodatafiles.cpp @@ -28,15 +28,19 @@ * it in the license file. */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/db/storage/mmap_v1/dur_commitjob.h" #include "mongo/db/storage/mmap_v1/dur_recover.h" #include "mongo/db/storage/mmap_v1/dur_stats.h" +#include "mongo/util/log.h" #include "mongo/util/concurrency/mutex.h" #include "mongo/util/timer.h" namespace mongo { + + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kStorage); + namespace dur { void debugValidateAllMapsMatch(); diff --git a/src/mongo/db/storage/mmap_v1/durable_mapped_file.cpp b/src/mongo/db/storage/mmap_v1/durable_mapped_file.cpp index 6f2ad208a21..f0521ad57cf 100644 --- a/src/mongo/db/storage/mmap_v1/durable_mapped_file.cpp +++ b/src/mongo/db/storage/mmap_v1/durable_mapped_file.cpp @@ -32,7 +32,7 @@ if you don't care about journaling/durability (temp sort files & such) use MemoryMappedFile class, not this. */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/db/storage/mmap_v1/durable_mapped_file.h" @@ -41,11 +41,14 @@ #include "mongo/db/storage/mmap_v1/dur.h" #include "mongo/db/storage/mmap_v1/dur_journalformat.h" #include "mongo/util/mongoutils/str.h" +#include "mongo/util/log.h" using namespace mongoutils; namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kStorage); + void DurableMappedFile::remapThePrivateView() { verify(storageGlobalParams.dur); diff --git a/src/mongo/db/storage/mmap_v1/durop.cpp b/src/mongo/db/storage/mmap_v1/durop.cpp index 6676de4c974..9b250417a51 100644 --- a/src/mongo/db/storage/mmap_v1/durop.cpp +++ b/src/mongo/db/storage/mmap_v1/durop.cpp @@ -28,7 +28,7 @@ * it in the license file. */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/db/storage/mmap_v1/durop.h" @@ -38,6 +38,7 @@ #include "mongo/util/alignedbuilder.h" #include "mongo/util/file.h" #include "mongo/util/file_allocator.h" +#include "mongo/util/log.h" #include "mongo/util/mongoutils/str.h" using namespace mongoutils; @@ -46,6 +47,8 @@ using namespace mongoutils; namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kStorage); + namespace dur { /** read a durop from journal file referenced by br. diff --git a/src/mongo/db/storage/mmap_v1/durop.h b/src/mongo/db/storage/mmap_v1/durop.h index 43af9efe6de..d89613a72a4 100644 --- a/src/mongo/db/storage/mmap_v1/durop.h +++ b/src/mongo/db/storage/mmap_v1/durop.h @@ -62,7 +62,7 @@ namespace mongo { /** read a durop from journal file referenced by br. @param opcode the opcode which has already been written from the bufreader */ - static shared_ptr<DurOp> read(unsigned opcode, BufReader& br); + static boost::shared_ptr<DurOp> read(unsigned opcode, BufReader& br); /** replay the operation (during recovery) throws diff --git a/src/mongo/db/storage/mmap_v1/mmap_v1_extent_manager.cpp b/src/mongo/db/storage/mmap_v1/mmap_v1_extent_manager.cpp index 69cbafafcd0..1e41c8c6033 100644 --- a/src/mongo/db/storage/mmap_v1/mmap_v1_extent_manager.cpp +++ b/src/mongo/db/storage/mmap_v1/mmap_v1_extent_manager.cpp @@ -41,9 +41,12 @@ #include "mongo/db/storage/extent_manager.h" #include "mongo/db/storage/record.h" #include "mongo/db/operation_context.h" +#include "mongo/util/log.h" namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kStorage); + MmapV1ExtentManager::MmapV1ExtentManager( const StringData& dbname, const StringData& path, bool directoryPerDB ) diff --git a/src/mongo/db/structure/record_store_v1_simple.cpp b/src/mongo/db/structure/record_store_v1_simple.cpp index 92538673dd4..4a7f84bf2b1 100644 --- a/src/mongo/db/structure/record_store_v1_simple.cpp +++ b/src/mongo/db/structure/record_store_v1_simple.cpp @@ -28,6 +28,8 @@ * it in the license file. */ +#include "mongo/platform/basic.h" + #include "mongo/db/structure/record_store_v1_simple.h" #include "mongo/base/counter.h" @@ -39,12 +41,15 @@ #include "mongo/db/storage/record.h" #include "mongo/db/operation_context.h" #include "mongo/db/structure/record_store_v1_simple_iterator.h" +#include "mongo/util/log.h" #include "mongo/util/progress_meter.h" #include "mongo/util/timer.h" #include "mongo/util/touch_pages.h" namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kStorage); + static Counter64 freelistAllocs; static Counter64 freelistBucketExhausted; static Counter64 freelistIterations; diff --git a/src/mongo/util/file_allocator.cpp b/src/mongo/util/file_allocator.cpp index 741c59fcb4f..eb5625dff70 100644 --- a/src/mongo/util/file_allocator.cpp +++ b/src/mongo/util/file_allocator.cpp @@ -27,7 +27,7 @@ * then also delete it in the license file. */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/util/file_allocator.h" @@ -52,6 +52,7 @@ #include "mongo/platform/posix_fadvise.h" #include "mongo/stdx/functional.h" #include "mongo/util/concurrency/thread_name.h" +#include "mongo/util/log.h" #include "mongo/util/mongoutils/str.h" #include "mongo/util/paths.h" #include "mongo/util/processinfo.h" @@ -66,6 +67,8 @@ using namespace mongoutils; namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kStorage); + // unique number for temporary file names unsigned long long FileAllocator::_uniqueNumber = 0; static SimpleMutex _uniqueNumberMutex( "uniqueNumberMutex" ); diff --git a/src/mongo/util/net/listen.cpp b/src/mongo/util/net/listen.cpp index c97ba77f614..bf260143f9d 100644 --- a/src/mongo/util/net/listen.cpp +++ b/src/mongo/util/net/listen.cpp @@ -28,11 +28,12 @@ */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/util/net/listen.h" #include "mongo/base/owned_pointer_vector.h" +#include "mongo/util/log.h" #include "mongo/util/net/message_port.h" #include "mongo/util/net/ssl_manager.h" #include "mongo/util/scopeguard.h" @@ -67,6 +68,7 @@ namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kNetworking); // ----- Listener ------- diff --git a/src/mongo/util/net/message_port.cpp b/src/mongo/util/net/message_port.cpp index 422c1e9c3b8..01bd875806b 100644 --- a/src/mongo/util/net/message_port.cpp +++ b/src/mongo/util/net/message_port.cpp @@ -27,7 +27,7 @@ * then also delete it in the license file. */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/util/net/message_port.h" @@ -36,6 +36,7 @@ #include "mongo/util/background.h" #include "mongo/util/goodies.h" +#include "mongo/util/log.h" #include "mongo/util/net/listen.h" #include "mongo/util/net/message.h" #include "mongo/util/net/ssl_manager.h" @@ -53,6 +54,7 @@ namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kNetworking); // if you want trace output: #define mmm(x) diff --git a/src/mongo/util/net/miniwebserver.cpp b/src/mongo/util/net/miniwebserver.cpp index fc701c98b32..7f958a9dfc1 100644 --- a/src/mongo/util/net/miniwebserver.cpp +++ b/src/mongo/util/net/miniwebserver.cpp @@ -27,16 +27,19 @@ * then also delete it in the license file. */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/util/net/miniwebserver.h" #include <pcrecpp.h> #include "mongo/util/hex.h" +#include "mongo/util/log.h" namespace mongo { + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kNetworking); + MiniWebServer::MiniWebServer(const string& name, const string &ip, int port) : Listener(name, ip, port, false) {} diff --git a/src/mongo/util/net/sock.cpp b/src/mongo/util/net/sock.cpp index 5d83431f5ad..5b1b2cf2a4f 100644 --- a/src/mongo/util/net/sock.cpp +++ b/src/mongo/util/net/sock.cpp @@ -27,7 +27,7 @@ * then also delete it in the license file. */ -#include "mongo/pch.h" +#include "mongo/platform/basic.h" #include "mongo/util/net/sock.h" @@ -49,11 +49,15 @@ #include "mongo/util/concurrency/value.h" #include "mongo/util/fail_point_service.h" #include "mongo/util/mongoutils/str.h" +#include "mongo/util/log.h" #include "mongo/util/net/message.h" #include "mongo/util/net/ssl_manager.h" #include "mongo/util/net/socket_poll.h" namespace mongo { + + MONGO_LOG_DEFAULT_TAG_FILE(::mongo::logger::LogTag::kNetworking); + MONGO_FP_DECLARE(throwSockExcep); static bool ipv6 = false; |