diff options
author | Tor Egge <Tor.Egge@oath.com> | 2018-03-07 14:56:57 +0000 |
---|---|---|
committer | Tor Egge <Tor.Egge@oath.com> | 2018-03-07 14:56:57 +0000 |
commit | 6d57bce6d57f1f71ce84510d1bd321daa858c3dc (patch) | |
tree | 92e9c8cfe5ac942e700ce4ce87e72d39cb51ac7a /storage | |
parent | 714c5340578273956221c48342f9c6802521876b (diff) |
Report delayed bucket requests.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/distributor/bucketdbupdater.cpp | 14 |
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 ""; } |