Skip to content
Snippets Groups Projects
Commit 6821e5bd authored by Adrien Béraud's avatar Adrien Béraud
Browse files

dhtrunner: default to null function instead of AllFilter

parent c4ec1e78
No related branches found
No related tags found
No related merge requests found
...@@ -105,7 +105,7 @@ public: ...@@ -105,7 +105,7 @@ public:
getFilterSet<T>()); getFilterSet<T>());
} }
std::future<std::vector<std::shared_ptr<dht::Value>>> get(InfoHash key, Value::Filter f = Value::AllFilter(), Where w = {}) { std::future<std::vector<std::shared_ptr<dht::Value>>> get(InfoHash key, Value::Filter f = {}, Where w = {}) {
auto p = std::make_shared<std::promise<std::vector<std::shared_ptr< dht::Value >>>>(); auto p = std::make_shared<std::promise<std::vector<std::shared_ptr< dht::Value >>>>();
auto values = std::make_shared<std::vector<std::shared_ptr< dht::Value >>>(); auto values = std::make_shared<std::vector<std::shared_ptr< dht::Value >>>();
get(key, [=](const std::vector<std::shared_ptr<dht::Value>>& vlist) { get(key, [=](const std::vector<std::shared_ptr<dht::Value>>& vlist) {
...@@ -136,7 +136,7 @@ public: ...@@ -136,7 +136,7 @@ public:
query(hash, cb, bindDoneCb(done_cb), q); query(hash, cb, bindDoneCb(done_cb), q);
} }
std::future<size_t> listen(InfoHash key, ValueCallback vcb, Value::Filter f = Value::AllFilter(), Where w = {}); std::future<size_t> listen(InfoHash key, ValueCallback vcb, Value::Filter f = {}, Where w = {});
std::future<size_t> listen(InfoHash key, GetCallback cb, Value::Filter f={}, Where w={}) { std::future<size_t> listen(InfoHash key, GetCallback cb, Value::Filter f={}, Where w={}) {
return listen(key, [cb](const std::vector<Sp<Value>>& vals, bool expired){ return listen(key, [cb](const std::vector<Sp<Value>>& vals, bool expired){
...@@ -145,8 +145,8 @@ public: ...@@ -145,8 +145,8 @@ public:
return true; return true;
}, std::forward<Value::Filter>(f), std::forward<Where>(w)); }, std::forward<Value::Filter>(f), std::forward<Where>(w));
} }
std::future<size_t> listen(const std::string& key, GetCallback vcb, Value::Filter f = Value::AllFilter(), Where w = {}); std::future<size_t> listen(const std::string& key, GetCallback vcb, Value::Filter f = {}, Where w = {});
std::future<size_t> listen(InfoHash key, GetCallbackSimple cb, Value::Filter f = Value::AllFilter(), Where w = {}) { std::future<size_t> listen(InfoHash key, GetCallbackSimple cb, Value::Filter f = {}, Where w = {}) {
return listen(key, bindGetCb(cb), f, w); return listen(key, bindGetCb(cb), f, w);
} }
...@@ -168,7 +168,7 @@ public: ...@@ -168,7 +168,7 @@ public:
} }
template <typename T> template <typename T>
std::future<size_t> listen(InfoHash hash, std::function<bool(T&&)> cb, Value::Filter f = Value::AllFilter(), Where w = {}) std::future<size_t> listen(InfoHash hash, std::function<bool(T&&)> cb, Value::Filter f = {}, Where w = {})
{ {
return listen(hash, [=](const std::vector<std::shared_ptr<Value>>& vals) { return listen(hash, [=](const std::vector<std::shared_ptr<Value>>& vals) {
for (const auto& v : vals) { for (const auto& v : vals) {
...@@ -184,7 +184,7 @@ public: ...@@ -184,7 +184,7 @@ public:
getFilterSet<T>(f), w); getFilterSet<T>(f), w);
} }
template <typename T> template <typename T>
std::future<size_t> listen(InfoHash hash, std::function<bool(T&&, bool)> cb, Value::Filter f = Value::AllFilter(), Where w = {}) std::future<size_t> listen(InfoHash hash, std::function<bool(T&&, bool)> cb, Value::Filter f = {}, Where w = {})
{ {
return listen(hash, [=](const std::vector<std::shared_ptr<Value>>& vals, bool expired) { return listen(hash, [=](const std::vector<std::shared_ptr<Value>>& vals, bool expired) {
for (const auto& v : vals) { for (const auto& v : vals) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment