2015-01-05 21:30:17 +02:00
|
|
|
/// @file
|
|
|
|
/// @author rfree (current maintainer in monero.cc project)
|
|
|
|
/// @brief base for connection, contains e.g. the ratelimit hooks
|
|
|
|
|
|
|
|
// Copyright (c) 2014, The Monero Project
|
|
|
|
//
|
|
|
|
// All rights reserved.
|
|
|
|
//
|
|
|
|
// Redistribution and use in source and binary forms, with or without modification, are
|
|
|
|
// permitted provided that the following conditions are met:
|
|
|
|
//
|
|
|
|
// 1. Redistributions of source code must retain the above copyright notice, this list of
|
|
|
|
// conditions and the following disclaimer.
|
|
|
|
//
|
|
|
|
// 2. Redistributions in binary form must reproduce the above copyright notice, this list
|
|
|
|
// of conditions and the following disclaimer in the documentation and/or other
|
|
|
|
// materials provided with the distribution.
|
|
|
|
//
|
|
|
|
// 3. Neither the name of the copyright holder nor the names of its contributors may be
|
|
|
|
// used to endorse or promote products derived from this software without specific
|
|
|
|
// prior written permission.
|
|
|
|
//
|
|
|
|
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY
|
|
|
|
// EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
|
|
|
|
// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
|
|
|
|
// THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
|
|
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
|
|
|
|
// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
|
|
|
// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
|
|
|
|
// STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
|
|
|
|
// THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
|
|
|
|
|
|
/* rfree: implementation for the non-template base, can be used by connection<> template class in abstract_tcp_server2 file */
|
|
|
|
|
|
|
|
#include "connection_basic.hpp"
|
|
|
|
|
|
|
|
#include <boost/asio.hpp>
|
|
|
|
#include <string>
|
|
|
|
#include <vector>
|
|
|
|
#include <boost/noncopyable.hpp>
|
|
|
|
#include <boost/shared_ptr.hpp>
|
|
|
|
#include <atomic>
|
|
|
|
|
|
|
|
#include <boost/asio.hpp>
|
|
|
|
#include <boost/array.hpp>
|
|
|
|
#include <boost/noncopyable.hpp>
|
|
|
|
#include <boost/shared_ptr.hpp>
|
|
|
|
#include <boost/enable_shared_from_this.hpp>
|
|
|
|
#include <boost/interprocess/detail/atomic.hpp>
|
|
|
|
#include <boost/thread/thread.hpp>
|
|
|
|
|
|
|
|
#include <memory>
|
|
|
|
|
|
|
|
#include "syncobj.h"
|
|
|
|
|
|
|
|
#include "../../contrib/epee/include/net/net_utils_base.h"
|
|
|
|
#include "../../contrib/epee/include/misc_log_ex.h"
|
|
|
|
#include <boost/lambda/bind.hpp>
|
|
|
|
#include <boost/foreach.hpp>
|
|
|
|
#include <boost/lambda/lambda.hpp>
|
|
|
|
#include <boost/uuid/random_generator.hpp>
|
|
|
|
#include <boost/chrono.hpp>
|
|
|
|
#include <boost/utility/value_init.hpp>
|
|
|
|
#include <boost/asio/deadline_timer.hpp>
|
|
|
|
#include <boost/date_time/posix_time/posix_time.hpp>
|
|
|
|
#include <boost/thread/thread.hpp>
|
|
|
|
#include <boost/filesystem.hpp>
|
|
|
|
#include "misc_language.h"
|
|
|
|
#include "pragma_comp_defs.h"
|
|
|
|
#include <fstream>
|
|
|
|
#include <sstream>
|
|
|
|
#include <iomanip>
|
|
|
|
#include <algorithm>
|
|
|
|
#include <mutex>
|
|
|
|
|
|
|
|
#include <boost/asio/basic_socket.hpp>
|
|
|
|
#include <boost/asio/ip/unicast.hpp>
|
|
|
|
#include "../../contrib/epee/include/net/abstract_tcp_server2.h"
|
|
|
|
|
|
|
|
#include "../../contrib/otshell_utils/utils.hpp"
|
2015-02-12 21:59:39 +02:00
|
|
|
#include "data_logger.hpp"
|
2015-01-05 21:30:17 +02:00
|
|
|
using namespace nOT::nUtils;
|
|
|
|
|
|
|
|
// TODO:
|
|
|
|
#include "../../src/p2p/network_throttle-detail.hpp"
|
|
|
|
#include "../../src/cryptonote_core/cryptonote_core.h"
|
|
|
|
|
|
|
|
// ################################################################################################
|
|
|
|
// local (TU local) headers
|
|
|
|
// ################################################################################################
|
|
|
|
|
|
|
|
namespace epee
|
|
|
|
{
|
|
|
|
namespace net_utils
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
|
|
/* ============================================================================ */
|
|
|
|
|
|
|
|
class connection_basic_pimpl {
|
|
|
|
public:
|
|
|
|
connection_basic_pimpl(const std::string &name);
|
|
|
|
|
|
|
|
static int m_default_tos;
|
|
|
|
|
|
|
|
network_throttle_bw m_throttle; // per-perr
|
|
|
|
critical_section m_throttle_lock;
|
|
|
|
|
|
|
|
int m_peer_number; // e.g. for debug/stats
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
} // namespace
|
|
|
|
} // namespace
|
|
|
|
|
|
|
|
// ################################################################################################
|
|
|
|
// The implementation part
|
|
|
|
// ################################################################################################
|
|
|
|
|
|
|
|
namespace epee
|
|
|
|
{
|
|
|
|
namespace net_utils
|
|
|
|
{
|
|
|
|
|
|
|
|
// ================================================================================================
|
|
|
|
// connection_basic_pimpl
|
|
|
|
// ================================================================================================
|
|
|
|
|
|
|
|
connection_basic_pimpl::connection_basic_pimpl(const std::string &name) : m_throttle(name) { }
|
|
|
|
|
|
|
|
// ================================================================================================
|
|
|
|
// connection_basic
|
|
|
|
// ================================================================================================
|
|
|
|
|
|
|
|
// static variables:
|
|
|
|
int connection_basic_pimpl::m_default_tos;
|
|
|
|
|
|
|
|
// methods:
|
|
|
|
connection_basic::connection_basic(boost::asio::io_service& io_service, std::atomic<long> &ref_sock_count, std::atomic<long> &sock_number)
|
|
|
|
:
|
|
|
|
mI( new connection_basic_pimpl("peer") ),
|
|
|
|
strand_(io_service),
|
|
|
|
socket_(io_service),
|
|
|
|
m_want_close_connection(false),
|
|
|
|
m_was_shutdown(false),
|
|
|
|
m_ref_sock_count(ref_sock_count)
|
|
|
|
{
|
|
|
|
++ref_sock_count; // increase the global counter
|
|
|
|
mI->m_peer_number = sock_number.fetch_add(1); // use, and increase the generated number
|
2015-02-12 21:59:39 +02:00
|
|
|
|
|
|
|
string remote_addr_str = "?";
|
|
|
|
try { remote_addr_str = socket_.remote_endpoint().address().to_string(); } catch(...){} ;
|
|
|
|
|
|
|
|
_note("Spawned connection p2p#"<<mI->m_peer_number<<" to " << remote_addr_str << " currently we have sockets count:" << m_ref_sock_count);
|
2015-02-20 23:28:03 +02:00
|
|
|
//boost::filesystem::create_directories("log/dr-monero/net/");
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
connection_basic::~connection_basic() {
|
2015-02-12 21:59:39 +02:00
|
|
|
string remote_addr_str = "?";
|
|
|
|
try { remote_addr_str = socket_.remote_endpoint().address().to_string(); } catch(...){} ;
|
|
|
|
_note("Destructing connection p2p#"<<mI->m_peer_number << " to " << remote_addr_str);
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void connection_basic::set_rate_up_limit(uint64_t limit) {
|
2015-02-12 21:59:39 +02:00
|
|
|
|
|
|
|
// TODO remove __SCALING_FACTOR...
|
|
|
|
const double SCALING_FACTOR = 2.1; // to acheve the best performance
|
|
|
|
limit *= SCALING_FACTOR;
|
2015-01-05 21:30:17 +02:00
|
|
|
{
|
|
|
|
CRITICAL_REGION_LOCAL( network_throttle_manager::m_lock_get_global_throttle_out );
|
|
|
|
network_throttle_manager::get_global_throttle_out().set_target_speed(limit);
|
2015-02-12 21:59:39 +02:00
|
|
|
network_throttle_manager::get_global_throttle_out().set_real_target_speed(limit / SCALING_FACTOR);
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
2015-02-12 21:59:39 +02:00
|
|
|
save_limit_to_file(limit);
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void connection_basic::set_rate_down_limit(uint64_t limit) {
|
|
|
|
{
|
|
|
|
CRITICAL_REGION_LOCAL( network_throttle_manager::m_lock_get_global_throttle_in );
|
|
|
|
network_throttle_manager::get_global_throttle_in().set_target_speed(limit);
|
|
|
|
}
|
|
|
|
|
|
|
|
{
|
|
|
|
CRITICAL_REGION_LOCAL( network_throttle_manager::m_lock_get_global_throttle_inreq );
|
|
|
|
network_throttle_manager::get_global_throttle_inreq().set_target_speed(limit);
|
|
|
|
}
|
|
|
|
save_limit_to_file(limit);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
void connection_basic::save_limit_to_file(int limit) {
|
|
|
|
// saving limit to file
|
2015-02-12 21:59:39 +02:00
|
|
|
if (!epee::net_utils::data_logger::m_save_graph)
|
|
|
|
return;
|
|
|
|
|
|
|
|
{
|
|
|
|
CRITICAL_REGION_LOCAL( network_throttle_manager::m_lock_get_global_throttle_out );
|
2015-02-20 23:28:03 +02:00
|
|
|
epee::net_utils::data_logger::get_instance().add_data("upload_limit", network_throttle_manager::get_global_throttle_out().get_terget_speed() / 1024);
|
2015-02-12 21:59:39 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
{
|
|
|
|
CRITICAL_REGION_LOCAL( network_throttle_manager::m_lock_get_global_throttle_in );
|
2015-02-20 23:28:03 +02:00
|
|
|
epee::net_utils::data_logger::get_instance().add_data("download_limit", network_throttle_manager::get_global_throttle_in().get_terget_speed() / 1024);
|
2015-02-12 21:59:39 +02:00
|
|
|
}
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void connection_basic::set_tos_flag(int tos) {
|
|
|
|
connection_basic_pimpl::m_default_tos = tos;
|
|
|
|
}
|
|
|
|
|
|
|
|
int connection_basic::get_tos_flag() {
|
|
|
|
return connection_basic_pimpl::m_default_tos;
|
|
|
|
}
|
|
|
|
|
|
|
|
void connection_basic::sleep_before_packet(size_t packet_size, int phase, int q_len) {
|
|
|
|
double delay=0; // will be calculated
|
|
|
|
do
|
|
|
|
{ // rate limiting
|
|
|
|
if (m_was_shutdown) {
|
|
|
|
_dbg2("m_was_shutdown - so abort sleep");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
{
|
2015-02-12 21:59:39 +02:00
|
|
|
CRITICAL_REGION_LOCAL( network_throttle_manager::m_lock_get_global_throttle_out );
|
2015-01-05 21:30:17 +02:00
|
|
|
delay = network_throttle_manager::get_global_throttle_out().get_sleep_time_after_tick( packet_size ); // decission from global
|
|
|
|
}
|
|
|
|
|
|
|
|
delay *= 0.50;
|
|
|
|
if (delay > 0) {
|
2015-02-12 21:59:39 +02:00
|
|
|
long int ms = (long int)(delay * 1000);
|
|
|
|
_info_c("net/sleep", "Sleeping in " << __FUNCTION__ << " for " << ms << " ms before packet_size="<<packet_size); // debug sleep
|
2015-01-05 21:30:17 +02:00
|
|
|
_dbg1("sleep in sleep_before_packet");
|
2015-02-12 21:59:39 +02:00
|
|
|
epee::net_utils::data_logger::get_instance().add_data("sleep_up", ms);
|
|
|
|
boost::this_thread::sleep(boost::posix_time::milliseconds( ms ) );
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
|
|
|
} while(delay > 0);
|
|
|
|
|
|
|
|
// XXX LATER XXX
|
|
|
|
{
|
|
|
|
CRITICAL_REGION_LOCAL( network_throttle_manager::m_lock_get_global_throttle_out );
|
2015-02-12 21:59:39 +02:00
|
|
|
network_throttle_manager::get_global_throttle_out().handle_trafic_exact( packet_size * 700); // increase counter - global
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
void connection_basic::set_start_time() {
|
|
|
|
CRITICAL_REGION_LOCAL( network_throttle_manager::m_lock_get_global_throttle_out );
|
|
|
|
m_start_time = network_throttle_manager::get_global_throttle_out().get_time_seconds();
|
|
|
|
}
|
|
|
|
|
|
|
|
void connection_basic::do_send_handler_write(const void* ptr , size_t cb ) {
|
|
|
|
sleep_before_packet(cb,1,-1);
|
|
|
|
_info_c("net/out/size", "handler_write (direct) - before ASIO write, for packet="<<cb<<" B (after sleep)");
|
|
|
|
set_start_time();
|
|
|
|
}
|
|
|
|
|
|
|
|
void connection_basic::do_send_handler_write_from_queue( const boost::system::error_code& e, size_t cb, int q_len ) {
|
|
|
|
sleep_before_packet(cb,2,q_len);
|
|
|
|
_info_c("net/out/size", "handler_write (after write, from queue="<<q_len<<") - before ASIO write, for packet="<<cb<<" B (after sleep)");
|
|
|
|
|
|
|
|
set_start_time();
|
|
|
|
}
|
|
|
|
|
|
|
|
void connection_basic::logger_handle_net_read(size_t size) { // network data read
|
2015-02-12 21:59:39 +02:00
|
|
|
size /= 1024;
|
|
|
|
epee::net_utils::data_logger::get_instance().add_data("download", size);
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
void connection_basic::logger_handle_net_write(size_t size) {
|
2015-02-12 21:59:39 +02:00
|
|
|
size /= 1024;
|
|
|
|
epee::net_utils::data_logger::get_instance().add_data("upload", size);
|
2015-01-05 21:30:17 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
double connection_basic::get_sleep_time(size_t cb) {
|
2015-02-24 21:12:56 +02:00
|
|
|
CRITICAL_REGION_LOCAL(epee::net_utils::network_throttle_manager::network_throttle_manager::m_lock_get_global_throttle_out);
|
2015-01-05 21:30:17 +02:00
|
|
|
auto t = network_throttle_manager::get_global_throttle_out().get_sleep_time(cb);
|
|
|
|
return t;
|
|
|
|
}
|
|
|
|
|
2015-02-12 21:59:39 +02:00
|
|
|
void connection_basic::set_save_graph(bool save_graph) {
|
|
|
|
epee::net_utils::data_logger::m_save_graph = save_graph;
|
|
|
|
}
|
|
|
|
|
2015-01-05 21:30:17 +02:00
|
|
|
|
|
|
|
} // namespace
|
|
|
|
} // namespace
|
|
|
|
|