Skip to content
Snippets Groups Projects
Select Git revision
  • 3a67624b99854a73b138d9b3bb711c3e24e3ce8c
  • master default
  • windows_ci_static
  • c_link
  • cpack
  • windows_ci
  • cert_pk_id
  • proxy_push_result
  • cnode_put_id
  • update-windows-build
  • proxy
  • resubscribe_on_token_change
  • actions
  • client_mode
  • llhttp
  • search_node_add
  • crypto_aes_gcm_argon2
  • ios_notifications
  • log_fmt
  • v2asio
  • fix-msvc
  • v3.4.0
  • v3.3.1
  • v3.3.1rc1
  • v3.3.1rc2
  • v3.3.0
  • v3.2.0
  • v3.1.11
  • v3.1.10
  • v3.1.9
  • v3.1.8.2
  • v3.1.8.1
  • v3.1.8
  • v3.1.7
  • v3.1.6
  • v3.1.5
  • v3.1.4
  • v3.1.3
  • v3.1.2
  • v3.1
  • v3.0.1
41 results

dht.cpp

Blame
  • Code owners
    Assign users and groups as approvers for specific file changes. Learn more.
    upnp_context.cpp 40.35 KiB
    /*
     *  Copyright (C) 2004-2023 Savoir-faire Linux Inc.
     *
     *  This program is free software: you can redistribute it and/or modify
     *  it under the terms of the GNU General Public License as published by
     *  the Free Software Foundation, either version 3 of the License, or
     *  (at your option) any later version.
     *
     *  This program is distributed in the hope that it will be useful,
     *  but WITHOUT ANY WARRANTY; without even the implied warranty of
     *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
     *  GNU General Public License for more details.
     *
     *  You should have received a copy of the GNU General Public License
     *  along with this program. If not, see <https://www.gnu.org/licenses/>.
     */
    #include "upnp/upnp_context.h"
    #include "protocol/upnp_protocol.h"
    
    #if HAVE_LIBNATPMP
    #include "protocol/natpmp/nat_pmp.h"
    #endif
    #if HAVE_LIBUPNP
    #include "protocol/pupnp/pupnp.h"
    #endif
    
    #include <asio/steady_timer.hpp>
    #if __has_include(<fmt/std.h>)
    #include <fmt/std.h>
    #else
    #include <fmt/ostream.h>
    #endif
    
    namespace dhtnet {
    namespace upnp {
    
    constexpr static auto MAP_UPDATE_INTERVAL = std::chrono::seconds(30);
    constexpr static int MAX_REQUEST_RETRIES = 20;
    constexpr static int MAX_REQUEST_REMOVE_COUNT = 5;
    
    constexpr static uint16_t UPNP_TCP_PORT_MIN {10000};
    constexpr static uint16_t UPNP_TCP_PORT_MAX {UPNP_TCP_PORT_MIN + 5000};
    constexpr static uint16_t UPNP_UDP_PORT_MIN {20000};
    constexpr static uint16_t UPNP_UDP_PORT_MAX {UPNP_UDP_PORT_MIN + 5000};
    
    UPnPContext::UPnPContext(const std::shared_ptr<asio::io_context>& ioContext, const std::shared_ptr<dht::log::Logger>& logger)
     : ctx(createIoContext(ioContext, logger))
     , mappingListUpdateTimer_(*ioContext)
     , connectivityChangedTimer_(*ioContext)
     , logger_(logger)
    {
        if (logger_) logger_->debug("Creating UPnPContext instance [{}]", fmt::ptr(this));
    
        // Set port ranges
        portRange_.emplace(PortType::TCP, std::make_pair(UPNP_TCP_PORT_MIN, UPNP_TCP_PORT_MAX));
        portRange_.emplace(PortType::UDP, std::make_pair(UPNP_UDP_PORT_MIN, UPNP_UDP_PORT_MAX));
    
        ctx->post([this] { init(); });
    }
    
    std::shared_ptr<asio::io_context>
    UPnPContext::createIoContext(const std::shared_ptr<asio::io_context>& ctx, const std::shared_ptr<dht::log::Logger>& logger) {
        if (ctx) {
            return ctx;
        } else {
            if (logger) logger->debug("UPnPContext: starting dedicated io_context thread");
            auto ioCtx = std::make_shared<asio::io_context>();
            ioContextRunner_ = std::make_unique<std::thread>([ioCtx, l=logger]() {
                try {
                    auto work = asio::make_work_guard(*ioCtx);