test.cpp

#include <opendht.h>
#include <vector>

int main()
{
    dht::DhtRunner node;

    // Launch a dht node on a new thread, using a
    // generated RSA key pair, and listen on port 4222.
    node.run(4222, dht::crypto::generateIdentity(), true);

    // Join the network through any running node,
    // here using a known bootstrap node.
    node.bootstrap("bootstrap.ring.cx", "4222");

   for (int i = 0; i < 10000000; ++i) {}


    // put some data on the dht
    std::string v = "test";
    std::cout << "test" << std::endl;
    node.put("test2", std::vector<uint8_t> {v.begin(), v.end()}, [](bool ok) {
                std::cout << "Put: " << (ok ? "success" : "failure") << std::endl;
    });

   for (int i = 0; i < 10000000; ++i) {}
    // get data from the dht
    node.get("test2", [](const std::vector<std::shared_ptr<dht::Value>>& values) {
            std::cout << "Found!";
            // Callback called when values are found
            for (const auto& value : values)
                std::cout << "Found value: " << *value << std::endl;
            return true; // return false to stop the search
            });


    node.shutdown([&]()
    {
        std::lock_guard<std::mutex> lk(m);
        done = true;
        cv.notify_all();
    });

    // wait for shutdown
    std::unique_lock<std::mutex> lk(m);
    cv.wait(lk, [&](){ return done.load(); });

    // wait for dht threads to end
    node.join();
    return 0;
}