1 files changed, 62 insertions, 17 deletions

diff --git a/toxcore/DHT.c b/toxcore/DHT.c
index 6bd23081..ac43371e 100644
--- a/toxcore/DHT.c
+++ b/toxcore/DHT.c
@@ -2333,6 +2333,58 @@ void DHT_save(DHT *dht, uint8_t *data)
     }
 }
 
+static void DHT_bootstrap_loaded_clients(DHT *dht)
+{
+        uint32_t i;
+
+        Client_data *client_list = dht->loaded_clients_list;
+        uint32_t client_count = dht->loaded_num_clients;
+
+        for (i = 0; i < client_count; ++i) {
+                if (client_list[i].assoc4.timestamp != 0)
+                        DHT_bootstrap(dht, client_list[i].assoc4.ip_port, client_list[i].client_id);
+
+                if (client_list[i].assoc6.timestamp != 0)
+                        DHT_bootstrap(dht, client_list[i].assoc6.ip_port, client_list[i].client_id);
+        }
+}
+
+static void getnodes_of_loaded_friend_clients(DHT *dht)
+{
+        uint32_t i, j;
+
+        DHT_Friend *friend_list = dht->loaded_friends_list;
+        uint32_t friend_count = dht->loaded_num_friends;
+
+        for (i = 0; i < friend_count; ++i) {
+                for (j = 0; j < MAX_FRIEND_CLIENTS; ++j) {
+                        Client_data *client = &friend_list[i].client_list[j];
+
+                        if (client->assoc4.timestamp != 0)
+                                getnodes(dht, client->assoc4.ip_port, client->client_id, friend_list[i].client_id, NULL);
+
+                        if (client->assoc6.timestamp != 0)
+                                getnodes(dht, client->assoc6.ip_port, client->client_id, friend_list[i].client_id, NULL);
+                }
+        }
+}
+
+/* Start sending packets after DHT loaded_friends_list and loaded_clients_list are set */
+int DHT_connect_after_load(DHT *dht)
+{
+        if(dht == NULL || dht->loaded_friends_list == NULL || dht->loaded_clients_list == NULL)
+                return -1;
+
+        getnodes_of_loaded_friend_clients(dht);
+        DHT_bootstrap_loaded_clients(dht);
+
+        // Loaded lists were allocd, free them
+        free(dht->loaded_friends_list);
+        free(dht->loaded_clients_list);
+
+        return 0;
+}
+
 static int dht_load_state_callback(void *outer, const uint8_t *data, uint32_t length, uint16_t type)
 {
     DHT *dht = outer;
@@ -2347,18 +2399,12 @@ static int dht_load_state_callback(void *outer, const uint8_t *data, uint32_t le
                 DHT_Friend *friend_list = (DHT_Friend *)data;
                 num = length / sizeof(DHT_Friend);
 
-                for (i = 0; i < num; ++i) {
-
-                    for (j = 0; j < MAX_FRIEND_CLIENTS; ++j) {
-                        Client_data *client = &friend_list[i].client_list[j];
-
-                        if (client->assoc4.timestamp != 0)
-                            getnodes(dht, client->assoc4.ip_port, client->client_id, friend_list[i].client_id, NULL);
+                                // Copy to loaded_friends_list
+                                dht->loaded_friends_list = calloc(num, sizeof(DHT_Friend));
+                                for(i = 0; i < num; i++)
+                                        memcpy(&(dht->loaded_friends_list[i]), &(friend_list[i]), sizeof(DHT_Friend));
+                                dht->loaded_num_friends = num;
 
-                        if (client->assoc6.timestamp != 0)
-                            getnodes(dht, client->assoc6.ip_port, client->client_id, friend_list[i].client_id, NULL);
-                    }
-                }
             } /* localize declarations */
 
             break;
@@ -2371,13 +2417,12 @@ static int dht_load_state_callback(void *outer, const uint8_t *data, uint32_t le
                 num = length / sizeof(Client_data);
                 Client_data *client_list = (Client_data *)data;
 
-                for (i = 0; i < num; ++i) {
-                    if (client_list[i].assoc4.timestamp != 0)
-                        DHT_bootstrap(dht, client_list[i].assoc4.ip_port, client_list[i].client_id);
+                                // Copy to loaded_clients_list
+                                dht->loaded_clients_list = calloc(num, sizeof(Client_data));
+                                for(i = 0; i < num; i++)
+                                        memcpy(&(dht->loaded_clients_list[i]), &(client_list[i]), sizeof(Client_data));
+                                dht->loaded_num_clients = num;
 
-                    if (client_list[i].assoc6.timestamp != 0)
-                        DHT_bootstrap(dht, client_list[i].assoc6.ip_port, client_list[i].client_id);
-                }
             } /* localize declarations */
 
             break;