From 019da72568dacc92fa11a77c091b6cd232143d38 Mon Sep 17 00:00:00 2001
From: Miguel Freitas <miguel@mf.site>
Date: Sat, 12 Oct 2013 17:31:49 -0300
Subject: [PATCH] rework initialization order a little, try to start torrents
 after dht comes up

---
 src/twister.cpp | 34 ++++++++++++++++++++++------------
 1 file changed, 22 insertions(+), 12 deletions(-)

diff --git a/src/twister.cpp b/src/twister.cpp
index af4211c8..8fa29502 100644
--- a/src/twister.cpp
+++ b/src/twister.cpp
@@ -161,21 +161,31 @@ void ThreadWaitExtIP()
     settings.anonymous_mode = false; // (false => send peer_id, avoid connecting to itself)
     ses->set_settings(settings);
 
+    printf("libtorrent + dht started\n");
 
-    boost::filesystem::path userDataPath = GetDataDir() / "user_data";
-    loadUserData(userDataPath.string(), m_users);
-    printf("loaded user_data for %zd users\n", m_users.size());
+    // wait up to 10 seconds for dht nodes to be set
+    for( int i = 0; i < 10; i++ ) {
+        MilliSleep(1000);
+        session_status ss = ses->status();
+        if( ss.dht_nodes )
+            break;
+    }
 
-    // now restart the user torrents (all m_following)
-    std::map<std::string,UserData>::const_iterator i;
-    for (i = m_users.begin(); i != m_users.end(); ++i) {
-        UserData const &data = i->second;
-        BOOST_FOREACH(string username, data.m_following) {
-            startTorrentUser(username);
+    {
+        LOCK(cs_twister);
+        boost::filesystem::path userDataPath = GetDataDir() / "user_data";
+        loadUserData(userDataPath.string(), m_users);
+        printf("loaded user_data for %zd users\n", m_users.size());
+
+        // now restart the user torrents (all m_following)
+        std::map<std::string,UserData>::const_iterator i;
+        for (i = m_users.begin(); i != m_users.end(); ++i) {
+            UserData const &data = i->second;
+            BOOST_FOREACH(string username, data.m_following) {
+                startTorrentUser(username);
+            }
         }
     }
-
-    printf("libtorrent + dht started\n");
 }
 
 void ThreadMaintainDHTNodes()
@@ -183,7 +193,7 @@ void ThreadMaintainDHTNodes()
     RenameThread("maintain-dht-nodes");
 
     while(1) {
-        MilliSleep(15000);
+        MilliSleep(5000);
 
         bool nodesAdded = false;
         if( ses ) {