Log outbound peer connection preparation.

Author: mtrippled

src/xrpld/peerfinder/detail/Logic.h

@@ -41,6 +41,7 @@
 #include <map>
 #include <memory>
 #include <set>
+#include <sstream>
 
 namespace ripple {
 namespace PeerFinder {
@@ -492,15 +493,21 @@ class Logic
     std::vector<beast::IP::Endpoint>
     autoconnect()
     {
+        std::stringstream ss;
+        ss << "AUTOCONNECT ";
         std::vector<beast::IP::Endpoint> const none;
 
         std::lock_guard _(lock_);
 
         // Count how many more outbound attempts to make
         //
         auto needed(counts_.attempts_needed());
-        if (needed == 0)
+        if (needed == 0) {
+            ss << "0 attempts needed, returning none";
+            JLOG(m_journal.debug()) << ss.str();
             return none;
+        }
+        ss << "attempts needed: " << needed << ". ";
 
         ConnectHandouts h(needed, m_squelches);
 
@@ -524,8 +531,9 @@ class Logic
 
             if (!h.list().empty())
             {
-                JLOG(m_journal.debug()) << beast::leftw(18) << "Logic connect "
-                                        << h.list().size() << " fixed";
+//                JLOG(m_journal.debug()) << beast::leftw(18) << "Logic connect "
+                ss << "returning Logic connect " << h.list().size() << " fixed";
+                JLOG(m_journal.debug()) << ss.str();
                 return h.list();
             }
 
@@ -534,15 +542,21 @@ class Logic
                 JLOG(m_journal.debug())
                     << beast::leftw(18) << "Logic waiting on "
                     << counts_.attempts() << " attempts";
+                ss << "returning none, pending outbound attempts " << counts_.attempts();
+                JLOG(m_journal.debug()) << ss.str();
                 return none;
             }
         }
 
         // Only proceed if auto connect is enabled and we
         // have less than the desired number of outbound slots
         //
-        if (!config_.autoConnect || counts_.out_active() >= counts_.out_max())
+        if (!config_.autoConnect || counts_.out_active() >= counts_.out_max()) {
+            ss << "returning none based on autoConnect || out_active >= out_max: "
+                << config_.autoConnect << ',' << counts_.out_active() << ',' << counts_.out_max();
+            JLOG(m_journal.debug()) << ss.str();
             return none;
+        }
 
         // 2. Use Livecache if:
         //    There are any entries in the cache OR
@@ -554,17 +568,21 @@ class Logic
                 &h, (&h) + 1, livecache_.hops.rbegin(), livecache_.hops.rend());
             if (!h.list().empty())
             {
-                JLOG(m_journal.debug())
-                    << beast::leftw(18) << "Logic connect " << h.list().size()
+//                JLOG(m_journal.debug())
+                ss
+                    << "returning Logic connect " << h.list().size()
                     << " live "
                     << ((h.list().size() > 1) ? "endpoints" : "endpoint");
+                JLOG(m_journal.debug()) << ss.str();
                 return h.list();
             }
             else if (counts_.attempts() > 0)
             {
-                JLOG(m_journal.debug())
-                    << beast::leftw(18) << "Logic waiting on "
+//                JLOG(m_journal.debug())
+                ss
+                    << "returning none, Logic waiting on "
                     << counts_.attempts() << " attempts";
+                JLOG(m_journal.debug()) << ss.str();
                 return none;
             }
         }
@@ -592,14 +610,18 @@ class Logic
 
         if (!h.list().empty())
         {
-            JLOG(m_journal.debug())
-                << beast::leftw(18) << "Logic connect " << h.list().size()
+//            JLOG(m_journal.debug())
+            ss
+                << "returning Logic connect " << h.list().size()
                 << " boot "
                 << ((h.list().size() > 1) ? "addresses" : "address");
+            JLOG(m_journal.debug()) << ss.str();
             return h.list();
         }
 
         // If we get here we are stuck
+        ss << "returning none, we are stuck";
+        JLOG(m_journal.debug()) << ss.str();
         return none;
     }