aboutsummaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@oath.com>2018-03-23 00:11:07 +0100
committerHenning Baldersheim <balder@oath.com>2018-04-03 18:33:28 +0200
commit063140bbbd80e7329aa528bc3e467fb5a5e6f777 (patch)
tree0be817d3cde38dba197c70c2e09465c16c920cb0 /storage
parent8c80fadcafb2d600ae72d01f5e2034a3ed8df670 (diff)
Do not store text only for debugging
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/distributor/pendingmessagetracker.cpp41
-rw-r--r--storage/src/vespa/storage/distributor/pendingmessagetracker.h8
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:
};
}
-}