diff --git a/src/dhtrunner.cpp b/src/dhtrunner.cpp index b836c3ff8c6438e0b7bf21ef6eed741e50150cc7..03c0f4caa4c0ede58352c2f2fa7a0c4b31f401dc 100644 --- a/src/dhtrunner.cpp +++ b/src/dhtrunner.cpp @@ -111,7 +111,7 @@ DhtRunner::run(const sockaddr_in* local4, const sockaddr_in6* local6, DhtRunner: void DhtRunner::shutdown(Dht::ShutdownCallback cb) { std::lock_guard<std::mutex> lck(storage_mtx); - pending_ops.emplace([=](SecureDht& dht) mutable { + pending_ops_prio.emplace([=](SecureDht& dht) mutable { dht.shutdown(cb); }); cv.notify_all();