DHT_table/main.cpp at main · Yezhkova/DHT_table · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
#include "Swarm.h"
#include "Utils.h"

#define TCP true
#define SIM false
#define MINUTES 60
#define SWARM_SIZE 200

int main(void) {
	Swarm& swarm = Swarm::getInstance();
	swarm.init(SIM, SWARM_SIZE);
    swarm.addTaskAfter(0, [&swarm]
    {
        uint64_t i = 0;
        auto peers = swarm.peers();
        for (auto& peer : peers)
        {
            peer.second->node().setLabel(++i);
//            LOG(peer.second->id() << " enters the swarm, " << std::dec << peer.second->packetTime());
            if (peer.second->id() != swarm.bootstrapNode()->id()) {
                peer.second->start(swarm.bootstrapNode()->id());
            }
        }
    });


    swarm.addTaskAfter(10 * MINUTES, [&swarm]
    {
        swarm.calculateStatistic();
//        Swarm::getInstance().eventQueqe().removeAllEvents();

        swarm.addTaskAfter(0 * MINUTES, [&swarm]
        {
            auto peers = swarm.peers();
            for (auto& peer : peers)
            {
                peer.second->resetFindNodeCounter();
                peer.second->resetPacketCounter();
                peer.second->resetReceiveFindNodeCounter();
                peer.second->resetFailedNode();
            }
            for (auto& peer : peers)
            {
                peer.second->findRandomNodes(1);
            }
        });

        swarm.addTaskAfter(20 * MINUTES, [&swarm]
        {
            swarm.calculateStatistic();
        });
    });

	swarm.run();
	LOG("simulation done");
	return 0;
}