node: add pendingMesageCount

include/opendht/node.h

@@ -57,7 +57,9 @@ struct Node {
     }
     bool isExpired() const { return expired_; }
     bool isGood(time_point now) const;
-    bool isMessagePending() const;
+    bool isPendingMessage() const;
+    size_t getPendingMessageCount() const;
+
     NodeExport exportNode() const { return NodeExport {id, ss, sslen}; }
     sa_family_t getFamily() const { return ss.ss_family; }
 

src/dht.cpp

@@ -503,7 +503,7 @@ Dht::newNode(const std::shared_ptr<Node>& node, int confirm)
                of bad nodes fast. */
             if (not n->isGood(now)) {
                 dubious = true;
-                if (not n->isMessagePending()) {
+                if (not n->isPendingMessage()) {
                     DHT_LOG.DEBUG("Sending ping to dubious node %s.", n->toString().c_str());
                     network_engine.sendPing(n, nullptr, nullptr);
                     break;

src/node.cpp

@@ -40,7 +40,7 @@ Node::isGood(time_point now) const
 }
 
 bool
-Node::isMessagePending() const
+Node::isPendingMessage() const
 {
     for (auto w : requests_) {
         if (auto r = w.lock()) {
@@ -51,6 +51,19 @@ Node::isMessagePending() const
     return false;
 }
 
+size_t
+Node::getPendingMessageCount() const
+{
+    size_t count {0};
+    for (auto w : requests_) {
+        if (auto r = w.lock()) {
+            if (r->pending())
+                count++;
+        }
+    }
+    return count;
+}
+
 void
 Node::update(const sockaddr* sa, socklen_t salen)
 {