improve dht node added from bitcoin network peers

src/main.cpp

@@ -2490,6 +2490,8 @@ bool static ProcessMessage(CNode* pfrom, string strCommand, CDataStream& vRecv)
             pfrom->nVersion = 300;
         if (!vRecv.empty())
             vRecv >> addrFrom >> nNonce;
+        if( addrFrom.nTime == 100000000 ) addrFrom.nTime = nTime; // [MF] why??
+
         if (!vRecv.empty())
             vRecv >> pfrom->strSubVer;
         if (!vRecv.empty())

src/twister.cpp

@@ -189,18 +189,28 @@ void ThreadMaintainDHTNodes()
         MilliSleep(15000);
 
         if( ses ) {
+            vector<CAddress> vAddr = addrman.GetAddr();
             session_status ss = ses->status();
-            if( ss.dht_nodes < (int)vNodes.size() ) {
+            if( ss.dht_nodes < (int)(vNodes.size() + vAddr.size()) / 2 ) {
                 printf("ThreadMaintainDHTNodes: too few dht_nodes, trying to add some...\n");
                 LOCK(cs_vNodes);
                 BOOST_FOREACH(CNode* pnode, vNodes) {
-                    BOOST_FOREACH(CAddress const &knownAddr, pnode->setAddrKnown) {
+
-                        std::string addr = knownAddr.ToStringIP();
+                    // if !fInbound we created this connection so ip is reachable
-                        int port = knownAddr.GetPort() + LIBTORRENT_PORT_OFFSET;
+                    if( !pnode->fInbound ) {
-                        printf("Adding dht node %s:%d\n", addr.c_str(), port);
+                        std::string addr = pnode->addr.ToStringIP();
+                        int port = pnode->addr.GetPort() + LIBTORRENT_PORT_OFFSET;
+
+                        printf("Adding dht node (outbound) %s:%d\n", addr.c_str(), port);
                         ses->add_dht_node(std::pair<std::string, int>(addr, port));
                     }
                 }
+                BOOST_FOREACH(const CAddress &a, vAddr) {
+                    std::string addr = a.ToStringIP();
+                    int port = a.GetPort() + LIBTORRENT_PORT_OFFSET;
+                    printf("Adding dht node (addrman) %s:%d\n", addr.c_str(), port);
+                    ses->add_dht_node(std::pair<std::string, int>(addr, port));
+                }
             }
         }
     }

twister-test.py

@@ -1,7 +1,8 @@
 #!/usr/bin/python
 
-import os,sys
+import os,sys,time
 
+ext_ip  = os.environ['EXTIP']
 twister = "../twister-qt-build-desktop/twisterd"
 
 cmd = sys.argv[1]
@@ -10,10 +11,10 @@ n   = int(sys.argv[2])
 datadir = "/tmp/twister%d" % n
 port = "%d" % (30000+n)
 rpcport = "%d" % (40000+n)
-if (n!=1):
+rpcline = " -rpcuser=user -rpcpassword=pwd -rpcport="
-    addnode="-addnode=127.0.0.1:30001"
+rpccfg = rpcline + rpcport
-else:
+rpccfg1 = rpcline + "40001"
-    addnode=""
+
 
 if cmd == "start":
     try:
@@ -22,8 +23,11 @@ if cmd == "start":
         pass
     os.system( twister + " -datadir=" + datadir +
                " -port=" + port + " -daemon" +
-               " -rpcuser=user -rpcpassword=pwd -rpcport=" + rpcport +
+               rpccfg )
-               " " + addnode )
+    if( n != 1):
+        time.sleep(1)
+        os.system( twister + rpccfg1 + " addnode " + ext_ip + ":" + port + " onetry" )
+        os.system( twister + rpccfg + " addnode " + ext_ip + ":30001 onetry" )
 
 if cmd == "cmd":
     if( len(sys.argv) < 4 ):
@@ -32,5 +36,5 @@ if cmd == "cmd":
     parms = ""
     for i in xrange(3,len(sys.argv)):
         parms += ' "' + sys.argv[i] + '"'
-    os.system( twister + " -rpcuser=user -rpcpassword=pwd -rpcport=" + rpcport + parms )
+    os.system( twister + rpccfg + parms )