From 55f6c847b8f6fdf958c684a50d6d067aa31a3a67 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Adrien=20B=C3=A9raud?= <adrien.beraud@savoirfairelinux.com> Date: Sun, 17 Feb 2019 02:15:36 -0500 Subject: [PATCH] build: use define flags for proxy --- CMakeLists.txt | 16 ++++--------- configure.ac | 19 ++++----------- include/opendht.h | 2 +- include/opendht/dht_proxy_client.h | 8 ++----- include/opendht/dht_proxy_server.h | 10 +++----- src/dht_proxy_client.cpp | 14 ++++------- src/dht_proxy_server.cpp | 22 ++++++++--------- src/dhtrunner.cpp | 38 +++++++++++++++--------------- src/securedht.cpp | 2 +- tools/dhtchat.cpp | 2 +- tools/dhtnode.cpp | 28 +++++++++++----------- 11 files changed, 64 insertions(+), 97 deletions(-) diff --git a/CMakeLists.txt b/CMakeLists.txt index 39d463a3..ed0a7685 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -184,11 +184,9 @@ if (OPENDHT_INDEX) endif() if (OPENDHT_PROXY_SERVER) - add_definitions(-DOPENDHT_PROXY_SERVER=true) + add_definitions(-DOPENDHT_PROXY_SERVER) if (OPENDHT_PROXY_SERVER_IDENTITY) - add_definitions(-DOPENDHT_PROXY_SERVER_IDENTITY=true) - else () - add_definitions(-DOPENDHT_PROXY_SERVER_IDENTITY=false) + add_definitions(-DOPENDHT_PROXY_SERVER_IDENTITY) endif() list (APPEND opendht_HEADERS include/opendht/dht_proxy_server.h @@ -198,28 +196,22 @@ if (OPENDHT_PROXY_SERVER) src/thread_pool.cpp src/dht_proxy_server.cpp ) -else () - add_definitions(-DENABLE_PROXY_SERVER=false) endif () if (OPENDHT_PROXY_CLIENT) - add_definitions(-DOPENDHT_PROXY_CLIENT=true) + add_definitions(-DOPENDHT_PROXY_CLIENT) list (APPEND opendht_HEADERS include/opendht/dht_proxy_client.h ) list (APPEND opendht_SOURCES src/dht_proxy_client.cpp ) -else () - add_definitions(-DOPENDHT_PROXY_CLIENT=false) endif () if (OPENDHT_PROXY_SERVER OR OPENDHT_PROXY_CLIENT) if (OPENDHT_PUSH_NOTIFICATIONS) message("Using push notification") - add_definitions(-DOPENDHT_PUSH_NOTIFICATIONS=true) - else () - add_definitions(-DOPENDHT_PUSH_NOTIFICATIONS=false) + add_definitions(-DOPENDHT_PUSH_NOTIFICATIONS) endif () list (APPEND opendht_HEADERS include/opendht/proxy.h diff --git a/configure.ac b/configure.ac index 4a8776cc..b653bf98 100644 --- a/configure.ac +++ b/configure.ac @@ -177,21 +177,10 @@ AM_COND_IF([ENABLE_TOOLS], [ ]) ]) -AM_COND_IF(ENABLE_PROXY_SERVER, - [CPPFLAGS+=" -DOPENDHT_PROXY_SERVER=true"], - [CPPFLAGS+=" -DOPENDHT_PROXY_SERVER=false"]) - -AM_COND_IF(ENABLE_PROXY_CLIENT, - [CPPFLAGS+=" -DOPENDHT_PROXY_CLIENT=true"], - [CPPFLAGS+=" -DOPENDHT_PROXY_CLIENT=false"]) - -AM_COND_IF(ENABLE_PUSH_NOTIFICATIONS, - [CPPFLAGS+=" -DOPENDHT_PUSH_NOTIFICATIONS=true"], - [CPPFLAGS+=" -DOPENDHT_PUSH_NOTIFICATIONS=false"]) - -AM_COND_IF(ENABLE_PROXY_SERVER_IDENTITY, - [CPPFLAGS+=" -DOPENDHT_PROXY_SERVER_IDENTITY=true"], - [CPPFLAGS+=" -DOPENDHT_PROXY_SERVER_IDENTITY=false"]) +AM_COND_IF(ENABLE_PROXY_SERVER, [CPPFLAGS+=" -DOPENDHT_PROXY_SERVER"], []) +AM_COND_IF(ENABLE_PROXY_CLIENT, [CPPFLAGS+=" -DOPENDHT_PROXY_CLIENT"], []) +AM_COND_IF(ENABLE_PUSH_NOTIFICATIONS, [CPPFLAGS+=" -DOPENDHT_PUSH_NOTIFICATIONS"], []) +AM_COND_IF(ENABLE_PROXY_SERVER_IDENTITY, [CPPFLAGS+=" -DOPENDHT_PROXY_SERVER_IDENTITY"], []) AM_COND_IF([HAVE_DOXYGEN], [ AC_CONFIG_FILES([doc/Doxyfile doc/Makefile]) diff --git a/include/opendht.h b/include/opendht.h index 8d0154d3..2c4b60fb 100644 --- a/include/opendht.h +++ b/include/opendht.h @@ -19,7 +19,7 @@ #pragma once #include "opendht/dhtrunner.h" -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER #include "opendht/dht_proxy_server.h" #endif #include "opendht/log.h" diff --git a/include/opendht/dht_proxy_client.h b/include/opendht/dht_proxy_client.h index 972167ca..2dae2a68 100644 --- a/include/opendht/dht_proxy_client.h +++ b/include/opendht/dht_proxy_client.h @@ -17,8 +17,6 @@ * along with this program. If not, see <https://www.gnu.org/licenses/>. */ -#if OPENDHT_PROXY_CLIENT - #pragma once #include <functional> @@ -49,7 +47,7 @@ public: explicit DhtProxyClient(std::function<void()> loopSignal, const std::string& serverHost, const std::string& pushClientId = ""); virtual void setPushNotificationToken(const std::string& token) { -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS deviceKey_ = token; #endif } @@ -376,7 +374,7 @@ private: const std::function<void()> loopSignal_; -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS void fillBody(std::shared_ptr<restbed::Request> request, bool resubscribe); void getPushRequest(Json::Value&) const; #endif // OPENDHT_PUSH_NOTIFICATIONS @@ -385,5 +383,3 @@ private: }; } - -#endif // OPENDHT_PROXY_CLIENT diff --git a/include/opendht/dht_proxy_server.h b/include/opendht/dht_proxy_server.h index 14b3d24f..d0c4d33f 100644 --- a/include/opendht/dht_proxy_server.h +++ b/include/opendht/dht_proxy_server.h @@ -17,8 +17,6 @@ * along with this program. If not, see <https://www.gnu.org/licenses/>. */ -#if OPENDHT_PROXY_SERVER - #pragma once #include "callbacks.h" @@ -179,7 +177,7 @@ private: void cancelPut(const InfoHash& key, Value::Id vid); -#if OPENDHT_PROXY_SERVER_IDENTITY +#ifdef OPENDHT_PROXY_SERVER_IDENTITY /** * Put a value to sign by the proxy on the DHT * Method: SIGN "/{InfoHash: .*}" @@ -230,7 +228,7 @@ private: */ void removeClosedListeners(bool testSession = true); -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS /** * Subscribe to push notifications for an iOS or Android device. * Method: SUBSCRIBE "/{InfoHash: .*}" @@ -307,7 +305,7 @@ private: mutable ServerStats stats_; -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS struct Listener; struct PushListener; std::mutex lockPushListeners_; @@ -317,5 +315,3 @@ private: }; } - -#endif //OPENDHT_PROXY_SERVER diff --git a/src/dht_proxy_client.cpp b/src/dht_proxy_client.cpp index 38eaf72a..a32e224c 100644 --- a/src/dht_proxy_client.cpp +++ b/src/dht_proxy_client.cpp @@ -17,8 +17,6 @@ * along with this program. If not, see <https://www.gnu.org/licenses/>. */ -#if OPENDHT_PROXY_CLIENT - #include "dht_proxy_client.h" #include "dhtrunner.h" @@ -373,7 +371,7 @@ DhtProxyClient::doPut(const InfoHash& key, Sp<Value> val, DoneCallback cb, time_ if (deviceKey_.empty()) { json["permanent"] = true; } else { -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS Json::Value refresh; getPushRequest(refresh); json["permanent"] = refresh; @@ -801,7 +799,7 @@ void DhtProxyClient::sendListen(const std::shared_ptr<restbed::Request> &req, req->set_method("LISTEN"); } try { -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS if (method != ListenMethod::LISTEN) fillBody(req, method == ListenMethod::RESUBSCRIBE); #endif @@ -994,7 +992,7 @@ DhtProxyClient::restartListeners() void DhtProxyClient::pushNotificationReceived(const std::map<std::string, std::string>& notification) { -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS scheduler.syncTime(); { // If a push notification is received, the proxy is up and running @@ -1047,7 +1045,7 @@ DhtProxyClient::pushNotificationReceived(const std::map<std::string, std::string void DhtProxyClient::resubscribe(const InfoHash& key, Listener& listener) { -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS if (deviceKey_.empty()) return; scheduler.syncTime(); DHT_LOG.d(key, "[search %s] resubscribe push listener", key.to_c_str()); @@ -1071,7 +1069,7 @@ DhtProxyClient::resubscribe(const InfoHash& key, Listener& listener) #endif } -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS void DhtProxyClient::getPushRequest(Json::Value& body) const { @@ -1109,5 +1107,3 @@ DhtProxyClient::fillBody(std::shared_ptr<restbed::Request> req, bool resubscribe #endif // OPENDHT_PUSH_NOTIFICATIONS } // namespace dht - -#endif // OPENDHT_PROXY_CLIENT diff --git a/src/dht_proxy_server.cpp b/src/dht_proxy_server.cpp index 2a241267..0cf163d4 100644 --- a/src/dht_proxy_server.cpp +++ b/src/dht_proxy_server.cpp @@ -17,7 +17,6 @@ * along with this program. If not, see <https://www.gnu.org/licenses/>. */ -#if OPENDHT_PROXY_SERVER #include "dht_proxy_server.h" #include "thread_pool.h" @@ -61,10 +60,10 @@ DhtProxyServer::DhtProxyServer(std::shared_ptr<DhtRunner> dht, in_port_t port , std::cout << "Running DHT proxy server on port " << port << std::endl; if (not pushServer.empty()) { -#if !OPENDHT_PUSH_NOTIFICATIONS - std::cerr << "Push server defined but built OpenDHT built without push notification support" << std::endl; -#else +#ifdef OPENDHT_PUSH_NOTIFICATIONS std::cout << "Using push notification server: " << pushServer << std::endl; +#else + std::cerr << "Push server defined but built OpenDHT built without push notification support" << std::endl; #endif } @@ -79,12 +78,12 @@ DhtProxyServer::DhtProxyServer(std::shared_ptr<DhtRunner> dht, in_port_t port , resource->set_path("/{hash: .*}"); resource->set_method_handler("GET", std::bind(&DhtProxyServer::get, this, _1)); resource->set_method_handler("LISTEN", [this](const Sp<restbed::Session>& session) mutable { listen(session); } ); -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS resource->set_method_handler("SUBSCRIBE", [this](const Sp<restbed::Session>& session) mutable { subscribe(session); } ); resource->set_method_handler("UNSUBSCRIBE", [this](const Sp<restbed::Session>& session) mutable { unsubscribe(session); } ); #endif //OPENDHT_PUSH_NOTIFICATIONS resource->set_method_handler("POST", [this](const Sp<restbed::Session>& session) mutable { put(session); }); -#if OPENDHT_PROXY_SERVER_IDENTITY +#ifdef OPENDHT_PROXY_SERVER_IDENTITY resource->set_method_handler("SIGN", std::bind(&DhtProxyServer::putSigned, this, _1)); resource->set_method_handler("ENCRYPT", std::bind(&DhtProxyServer::putEncrypted, this, _1)); #endif // OPENDHT_PROXY_SERVER_IDENTITY @@ -191,7 +190,7 @@ DhtProxyServer::updateStats() const auto count = requestNum_.exchange(0); auto dt = std::chrono::duration<double>(now - last); stats_.requestRate = count / dt.count(); -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS stats_.pushListenersCount = pushListeners_.size(); #endif stats_.putCount = puts_.size(); @@ -371,7 +370,7 @@ DhtProxyServer::listen(const Sp<restbed::Session>& session) ); } -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS struct DhtProxyServer::Listener { std::string clientId; @@ -688,7 +687,7 @@ DhtProxyServer::put(const std::shared_ptr<restbed::Session>& session) std::cout << "Permanent put expired: " << infoHash << " " << vid << std::endl; cancelPut(infoHash, vid); }); -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS if (not pushToken.empty()) { pput.expireNotifyJob = scheduler_.add(timeout - proxy::OP_MARGIN, [this, infoHash, vid, pushToken, clientId, isAndroid] @@ -738,7 +737,7 @@ DhtProxyServer::put(const std::shared_ptr<restbed::Session>& session) ); } -#if OPENDHT_PROXY_SERVER_IDENTITY +#ifdef OPENDHT_PROXY_SERVER_IDENTITY void DhtProxyServer::putSigned(const std::shared_ptr<restbed::Session>& session) const { @@ -844,7 +843,7 @@ void DhtProxyServer::handleOptionsMethod(const std::shared_ptr<restbed::Session>& session) const { requestNum_++; -#if OPENDHT_PROXY_SERVER_IDENTITY +#ifdef OPENDHT_PROXY_SERVER_IDENTITY const auto allowed = "OPTIONS, GET, POST, LISTEN, SIGN, ENCRYPT"; #else const auto allowed = "OPTIONS, GET, POST, LISTEN"; @@ -914,4 +913,3 @@ DhtProxyServer::removeClosedListeners(bool testSession) } } -#endif //OPENDHT_PROXY_SERVER diff --git a/src/dhtrunner.cpp b/src/dhtrunner.cpp index acc45504..7ab6f81f 100644 --- a/src/dhtrunner.cpp +++ b/src/dhtrunner.cpp @@ -21,7 +21,7 @@ #include "dhtrunner.h" #include "securedht.h" -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT #include "dht_proxy_client.h" #endif @@ -55,7 +55,7 @@ struct DhtRunner::Listener { }; DhtRunner::DhtRunner() : dht_() -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT , dht_via_proxy_() #endif //OPENDHT_PROXY_CLIENT { @@ -105,7 +105,7 @@ DhtRunner::run(const SockAddr& local4, const SockAddr& local6, DhtRunner::Config auto dht = std::unique_ptr<DhtInterface>(new Dht(s4, s6, SecureDht::getConfig(config.dht_config))); dht_ = std::unique_ptr<SecureDht>(new SecureDht(std::move(dht), config.dht_config)); -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT config_ = config; #endif enableProxy(not config.proxy_server.empty()); @@ -151,7 +151,7 @@ DhtRunner::run(const SockAddr& local4, const SockAddr& local6, DhtRunner::Config void DhtRunner::shutdown(ShutdownCallback cb) { -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT if (dht_via_proxy_) dht_via_proxy_->shutdown(cb); #endif @@ -250,7 +250,7 @@ DhtRunner::setLoggers(LogMethod error, LogMethod warn, LogMethod debug) { std::lock_guard<std::mutex> lck(dht_mtx); if (dht_) dht_->setLoggers(error, warn, debug); -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT if (dht_via_proxy_) dht_via_proxy_->setLoggers(error, warn, debug); #endif @@ -262,7 +262,7 @@ DhtRunner::setLogFilter(const InfoHash& f) { activeDht()->setLogFilter(f); if (dht_) dht_->setLogFilter(f); -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT if (dht_via_proxy_) dht_via_proxy_->setLogFilter(f); #endif @@ -376,7 +376,7 @@ DhtRunner::registerCertificate(std::shared_ptr<crypto::Certificate> cert) { void DhtRunner::setLocalCertificateStore(CertificateStoreQuery&& query_method) { std::lock_guard<std::mutex> lck(dht_mtx); -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT if (dht_via_proxy_) dht_via_proxy_->setLocalCertificateStore(std::forward<CertificateStoreQuery>(query_method)); #endif @@ -658,7 +658,7 @@ DhtRunner::listen(InfoHash hash, ValueCallback vcb, Value::Filter f, Where w) { std::lock_guard<std::mutex> lck(storage_mtx); pending_ops.emplace([=](SecureDht& dht) mutable { -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT auto tokenbGlobal = listener_token_++; Listener listener {}; listener.hash = hash; @@ -697,7 +697,7 @@ DhtRunner::cancelListen(InfoHash h, size_t token) { { std::lock_guard<std::mutex> lck(storage_mtx); -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT pending_ops.emplace([=](SecureDht&) { auto it = listeners_.find(token); if (it == listeners_.end()) return; @@ -721,7 +721,7 @@ DhtRunner::cancelListen(InfoHash h, std::shared_future<size_t> ftoken) { { std::lock_guard<std::mutex> lck(storage_mtx); -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT pending_ops.emplace([=](SecureDht&) { auto it = listeners_.find(ftoken.get()); if (it == listeners_.end()) return; @@ -973,7 +973,7 @@ DhtRunner::findCertificate(InfoHash hash, std::function<void(const std::shared_p void DhtRunner::resetDht() { -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT listeners_.clear(); dht_via_proxy_.reset(); #endif // OPENDHT_PROXY_CLIENT @@ -983,7 +983,7 @@ DhtRunner::resetDht() SecureDht* DhtRunner::activeDht() const { -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT return use_proxy? dht_via_proxy_.get() : dht_.get(); #else return dht_.get(); @@ -993,7 +993,7 @@ DhtRunner::activeDht() const void DhtRunner::setProxyServer(const std::string& proxy, const std::string& pushNodeId) { -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT if (config_.proxy_server == proxy and config_.push_node_id == pushNodeId) return; config_.proxy_server = proxy; @@ -1008,7 +1008,7 @@ DhtRunner::setProxyServer(const std::string& proxy, const std::string& pushNodeI void DhtRunner::enableProxy(bool proxify) { -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT if (dht_via_proxy_) { dht_via_proxy_->shutdown({}); } @@ -1026,7 +1026,7 @@ DhtRunner::enableProxy(bool proxify) }, config_.proxy_server, config_.push_node_id) ); dht_via_proxy_ = std::unique_ptr<SecureDht>(new SecureDht(std::move(dht_via_proxy), config_.dht_config)); -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS if (not pushToken_.empty()) dht_via_proxy_->setPushNotificationToken(pushToken_); #endif @@ -1059,8 +1059,8 @@ DhtRunner::enableProxy(bool proxify) void DhtRunner::forwardAllMessages(bool forward) { -#if OPENDHT_PROXY_SERVER -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_CLIENT if (dht_via_proxy_) dht_via_proxy_->forwardAllMessages(forward); #endif // OPENDHT_PROXY_CLIENT @@ -1074,7 +1074,7 @@ DhtRunner::forwardAllMessages(bool forward) */ void DhtRunner::setPushNotificationToken(const std::string& token) { -#if OPENDHT_PROXY_CLIENT && OPENDHT_PUSH_NOTIFICATIONS +#if defined(OPENDHT_PROXY_CLIENT) && defined(OPENDHT_PUSH_NOTIFICATIONS) pushToken_ = token; if (dht_via_proxy_) dht_via_proxy_->setPushNotificationToken(token); @@ -1084,7 +1084,7 @@ DhtRunner::setPushNotificationToken(const std::string& token) { void DhtRunner::pushNotificationReceived(const std::map<std::string, std::string>& data) { -#if OPENDHT_PROXY_CLIENT && OPENDHT_PUSH_NOTIFICATIONS +#if defined(OPENDHT_PROXY_CLIENT) && defined(OPENDHT_PUSH_NOTIFICATIONS) { std::lock_guard<std::mutex> lck(storage_mtx); pending_ops_prio.emplace([=](SecureDht&) { diff --git a/src/securedht.cpp b/src/securedht.cpp index 4be57f74..7e618899 100644 --- a/src/securedht.cpp +++ b/src/securedht.cpp @@ -235,7 +235,7 @@ SecureDht::checkValue(const Sp<Value>& v) // Decrypt encrypted values if (v->isEncrypted()) { if (not key_) { -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER if (forward_all_) // We are currently a proxy, send messages to clients. return v; #endif diff --git a/tools/dhtchat.cpp b/tools/dhtchat.cpp index 9f1bff67..03617faa 100644 --- a/tools/dhtchat.cpp +++ b/tools/dhtchat.cpp @@ -76,7 +76,7 @@ main(int argc, char **argv) if (not params.bootstrap.first.empty()) dht.bootstrap(params.bootstrap.first.c_str(), params.bootstrap.second.c_str()); -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT if (!params.proxyclient.empty()) { dht.setProxyServer(params.proxyclient); dht.enableProxy(true); diff --git a/tools/dhtnode.cpp b/tools/dhtnode.cpp index 98ae5e6a..ebab1537 100644 --- a/tools/dhtnode.cpp +++ b/tools/dhtnode.cpp @@ -58,9 +58,9 @@ void print_help() { << " ld [key] Print basic information about currenty stored values on this node (or key)." << std::endl << " lr Print the full current routing table of this node." << std::endl; -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER std::cout << std::endl << "Operations with the proxy:" << std::endl -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS << " pst [port] <pushServer> Start the proxy interface on port." << std::endl #else << " pst [port] Start the proxy interface on port." << std::endl @@ -68,9 +68,9 @@ void print_help() { << " psp [port] Stop the proxy interface on port." << std::endl; #endif //OPENDHT_PROXY_SERVER -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT std::cout << std::endl << "Operations with the proxy:" << std::endl -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS << " stt [server_address] <device_key> Start the proxy client." << std::endl << " rs [token] Resubscribe to opendht." << std::endl << " rp [token] Inject a push notification in Opendht." << std::endl @@ -102,7 +102,7 @@ void print_help() { } void cmd_loop(std::shared_ptr<DhtRunner>& dht, dht_params& params -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER , std::map<in_port_t, std::unique_ptr<DhtProxyServer>>& proxies #endif ) @@ -141,7 +141,7 @@ void cmd_loop(std::shared_ptr<DhtRunner>& dht, dht_params& params std::cout << dht->getNodesStats(AF_INET).toString() << std::endl; std::cout << "IPv6 stats:" << std::endl; std::cout << dht->getNodesStats(AF_INET6).toString() << std::endl; -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER for (const auto& proxy : proxies) { std::cout << "Stats for proxy on port " << proxy.first << std::endl; std::cout << " " << proxy.second->stats().toString() << std::endl; @@ -201,16 +201,16 @@ void cmd_loop(std::shared_ptr<DhtRunner>& dht, dht_params& params dht->connectivityChanged(); continue; } -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER else if (op == "pst") { -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS iss >> idstr >> pushServer; #else iss >> idstr; #endif // OPENDHT_PUSH_NOTIFICATIONS try { unsigned int port = std::stoi(idstr); -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS proxies.emplace(port, std::unique_ptr<DhtProxyServer>(new DhtProxyServer(dht, port, pushServer))); #else proxies.emplace(port, std::unique_ptr<DhtProxyServer>(new DhtProxyServer(dht, port))); @@ -227,7 +227,7 @@ void cmd_loop(std::shared_ptr<DhtRunner>& dht, dht_params& params continue; } #endif //OPENDHT_PROXY_SERVER -#if OPENDHT_PROXY_CLIENT +#ifdef OPENDHT_PROXY_CLIENT else if (op == "stt") { dht->enableProxy(true); continue; @@ -235,7 +235,7 @@ void cmd_loop(std::shared_ptr<DhtRunner>& dht, dht_params& params dht->enableProxy(false); continue; } -#if OPENDHT_PUSH_NOTIFICATIONS +#ifdef OPENDHT_PUSH_NOTIFICATIONS else if (op == "rp") { iss >> value; dht->pushNotificationReceived({{"to", "dhtnode"}, {"token", value}}); @@ -523,11 +523,11 @@ main(int argc, char **argv) dht->bootstrap(params.bootstrap.first.c_str(), params.bootstrap.second.c_str()); } -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER std::map<in_port_t, std::unique_ptr<DhtProxyServer>> proxies; #endif if (params.proxyserver != 0) { -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER proxies.emplace(params.proxyserver, std::unique_ptr<DhtProxyServer>(new DhtProxyServer(dht, params.proxyserver, params.pushserver))); #else std::cerr << "DHT proxy server requested but OpenDHT built without proxy server support." << std::endl; @@ -539,7 +539,7 @@ main(int argc, char **argv) while (runner.wait()); else cmd_loop(dht, params -#if OPENDHT_PROXY_SERVER +#ifdef OPENDHT_PROXY_SERVER , proxies #endif ); -- GitLab