mirror of
https://github.com/monero-project/monero.git
synced 2024-12-26 03:49:25 -05:00
connection_basic: remove unused floating time start time
This commit is contained in:
parent
e5108a294a
commit
758d768486
@ -92,7 +92,6 @@ class connection_basic { // not-templated base class for rapid developmet of som
|
|||||||
critical_section m_send_que_lock;
|
critical_section m_send_que_lock;
|
||||||
std::list<std::string> m_send_que;
|
std::list<std::string> m_send_que;
|
||||||
volatile bool m_is_multithreaded;
|
volatile bool m_is_multithreaded;
|
||||||
double m_start_time;
|
|
||||||
/// Strand to ensure the connection's handlers are not called concurrently.
|
/// Strand to ensure the connection's handlers are not called concurrently.
|
||||||
boost::asio::io_service::strand strand_;
|
boost::asio::io_service::strand strand_;
|
||||||
/// Socket for the connection.
|
/// Socket for the connection.
|
||||||
@ -112,8 +111,6 @@ class connection_basic { // not-templated base class for rapid developmet of som
|
|||||||
void logger_handle_net_write(size_t size); // network data written
|
void logger_handle_net_write(size_t size); // network data written
|
||||||
void logger_handle_net_read(size_t size); // network data read
|
void logger_handle_net_read(size_t size); // network data read
|
||||||
|
|
||||||
void set_start_time();
|
|
||||||
|
|
||||||
// config for rate limit
|
// config for rate limit
|
||||||
|
|
||||||
static void set_rate_up_limit(uint64_t limit);
|
static void set_rate_up_limit(uint64_t limit);
|
||||||
|
@ -250,22 +250,15 @@ void connection_basic::sleep_before_packet(size_t packet_size, int phase, int q
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
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 ) {
|
void connection_basic::do_send_handler_write(const void* ptr , size_t cb ) {
|
||||||
// No sleeping here; sleeping is done once and for all in connection<t_protocol_handler>::handle_write
|
// No sleeping here; sleeping is done once and for all in connection<t_protocol_handler>::handle_write
|
||||||
MTRACE("handler_write (direct) - before ASIO write, for packet="<<cb<<" B (after sleep)");
|
MTRACE("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 ) {
|
void connection_basic::do_send_handler_write_from_queue( const boost::system::error_code& e, size_t cb, int q_len ) {
|
||||||
// No sleeping here; sleeping is done once and for all in connection<t_protocol_handler>::handle_write
|
// No sleeping here; sleeping is done once and for all in connection<t_protocol_handler>::handle_write
|
||||||
MTRACE("handler_write (after write, from queue="<<q_len<<") - before ASIO write, for packet="<<cb<<" B (after sleep)");
|
MTRACE("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
|
void connection_basic::logger_handle_net_read(size_t size) { // network data read
|
||||||
|
Loading…
Reference in New Issue
Block a user