summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@oath.com>2018-03-07 14:56:57 +0000
committerTor Egge <Tor.Egge@oath.com>2018-03-07 14:56:57 +0000
commit6d57bce6d57f1f71ce84510d1bd321daa858c3dc (patch)
tree92e9c8cfe5ac942e700ce4ce87e72d39cb51ac7a /storage
parent714c5340578273956221c48342f9c6802521876b (diff)
Report delayed bucket requests.
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/distributor/bucketdbupdater.cpp14
1 files changed, 14 insertions, 0 deletions
diff --git a/storage/src/vespa/storage/distributor/bucketdbupdater.cpp b/storage/src/vespa/storage/distributor/bucketdbupdater.cpp
index 84332851340..82eb7b9f6eb 100644
--- a/storage/src/vespa/storage/distributor/bucketdbupdater.cpp
+++ b/storage/src/vespa/storage/distributor/bucketdbupdater.cpp
@@ -591,6 +591,20 @@ BucketDBUpdater::reportXmlStatus(vespalib::xml::XmlOutputStream& xos,
xos << XmlAttribute("sendtimestamp", entry.second.timestamp)
<< XmlEndTag();
}
+ xos << XmlEndTag()
+ << XmlTag("delayed_single_bucket_requests");
+ for (const auto & entry : _delayedRequests)
+ {
+ xos << XmlTag("storagenode")
+ << XmlAttribute("index", entry.second.targetNode);
+ if (entry.second.bucket.getBucketId().getRawId() == 0) {
+ xos << XmlAttribute("bucket", ALL);
+ } else {
+ xos << XmlAttribute("bucket", entry.second.bucket.getBucketId().getId(), XmlAttribute::HEX);
+ }
+ xos << XmlAttribute("resendtimestamp", entry.first.getTime())
+ << XmlEndTag();
+ }
xos << XmlEndTag() << XmlEndTag();
return "";
}