diff options
author | Henning Baldersheim <balder@oath.com> | 2018-03-23 00:11:07 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@oath.com> | 2018-04-03 18:33:28 +0200 |
commit | 063140bbbd80e7329aa528bc3e467fb5a5e6f777 (patch) | |
tree | 0be817d3cde38dba197c70c2e09465c16c920cb0 /storage | |
parent | 8c80fadcafb2d600ae72d01f5e2034a3ed8df670 (diff) |
Do not store text only for debugging
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/distributor/pendingmessagetracker.cpp | 41 | ||||
-rw-r--r-- | storage/src/vespa/storage/distributor/pendingmessagetracker.h | 8 |
2 files changed, 13 insertions, 36 deletions
diff --git a/storage/src/vespa/storage/distributor/pendingmessagetracker.cpp b/storage/src/vespa/storage/distributor/pendingmessagetracker.cpp index 5035e6feeab..e3fd0c1f72d 100644 --- a/storage/src/vespa/storage/distributor/pendingmessagetracker.cpp +++ b/storage/src/vespa/storage/distributor/pendingmessagetracker.cpp @@ -20,27 +20,17 @@ PendingMessageTracker::PendingMessageTracker(framework::ComponentRegister& cr) _component.registerStatusPage(*this); } -PendingMessageTracker::~PendingMessageTracker() -{ -} +PendingMessageTracker::~PendingMessageTracker() = default; -PendingMessageTracker::MessageEntry::MessageEntry( - TimePoint timeStamp_, - uint32_t msgType_, - uint32_t priority_, - uint64_t msgId_, - document::Bucket bucket_, - uint16_t nodeIdx_, - const vespalib::string & msgText_) +PendingMessageTracker::MessageEntry::MessageEntry(TimePoint timeStamp_, uint32_t msgType_, uint32_t priority_, + uint64_t msgId_, document::Bucket bucket_, uint16_t nodeIdx_) : timeStamp(timeStamp_), msgType(msgType_), priority(priority_), msgId(msgId_), bucket(bucket_), - nodeIdx(nodeIdx_), - msgText(msgText_) -{ -} + nodeIdx(nodeIdx_) +{ } PendingMessageTracker::TimePoint PendingMessageTracker::currentTime() const @@ -88,19 +78,13 @@ PendingMessageTracker::clearMessagesForNode(uint16_t node) } void -PendingMessageTracker::insert( - const std::shared_ptr<api::StorageMessage>& msg) +PendingMessageTracker::insert(const std::shared_ptr<api::StorageMessage>& msg) { std::lock_guard<std::mutex> guard(_lock); if (msg->getAddress()) { _messages.insert( - MessageEntry(currentTime(), - msg->getType().getId(), - msg->getPriority(), - msg->getMsgId(), - msg->getBucket(), - msg->getAddress()->getIndex(), - msg->getSummary())); + MessageEntry(currentTime(), msg->getType().getId(), msg->getPriority(), msg->getMsgId(), + msg->getBucket(), msg->getAddress()->getIndex())); _nodeInfo.incPending(msg->getAddress()->getIndex()); @@ -210,8 +194,7 @@ PendingMessageTracker::getStatusPerBucket(std::ostream& out) const << msg.nodeIdx << "</i>: " << "<b>" << framework::MilliSecTime(msg.timeStamp.count()).toString() - << "</b> " - << msg.msgText << "</li>\n"; + << "</b> </li>\n"; perBucketMsgs[msg.bucket].emplace_back(ss.str()); } @@ -256,8 +239,7 @@ PendingMessageTracker::getStatusPerNode(std::ostream& out) const out << "<li><b>" << framework::MilliSecTime(iter->timeStamp.count()).toString() - << "</b> " - << iter->msgText << "</li>\n"; + << "</b> </li>\n"; } if (lastNode != -1) { @@ -266,8 +248,7 @@ PendingMessageTracker::getStatusPerNode(std::ostream& out) const } void -PendingMessageTracker::reportHtmlStatus( - std::ostream& out, const framework::HttpUrlPath& path) const +PendingMessageTracker::reportHtmlStatus(std::ostream& out, const framework::HttpUrlPath& path) const { if (!path.hasAttribute("order")) { getStatusStartPage(out); diff --git a/storage/src/vespa/storage/distributor/pendingmessagetracker.h b/storage/src/vespa/storage/distributor/pendingmessagetracker.h index 59bcb206127..c899fea6dbb 100644 --- a/storage/src/vespa/storage/distributor/pendingmessagetracker.h +++ b/storage/src/vespa/storage/distributor/pendingmessagetracker.h @@ -22,8 +22,7 @@ #include <chrono> #include <mutex> -namespace storage { -namespace distributor { +namespace storage::distributor { class PendingMessageTracker : public framework::HtmlStatusReporter { @@ -106,15 +105,13 @@ private: uint64_t msgId; document::Bucket bucket; uint16_t nodeIdx; - vespalib::string msgText; MessageEntry(TimePoint timeStamp, uint32_t msgType, uint32_t priority, uint64_t msgId, document::Bucket bucket, - uint16_t nodeIdx, - const vespalib::string & msgText); + uint16_t nodeIdx); }; struct MessageIdKey @@ -195,4 +192,3 @@ private: }; } -} |