Peerplays_Blockchain/peerplays-fc
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update NTP performance requirments

Browse source 
NTP server must ACK within 300ms or time will not be set.
Removed extra printing
This commit is contained in:
Daniel Larimer 2015-09-23 16:22:11 -04:00
parent d19f67d94f
commit 83a9e4d7c8
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/network/ntp.cpp
View file

@ -74,11 +74,11 @@ namespace fc
{ {
try try
{ {
wlog( "resolving... ${r}", ("r", item) ); //wlog( "resolving... ${r}", ("r", item) );
auto eps = resolve( item.first, item.second ); auto eps = resolve( item.first, item.second );
for( auto ep : eps ) for( auto ep : eps )
{ {
wlog( "sending request to ${ep}", ("ep",ep) ); // wlog( "sending request to ${ep}", ("ep",ep) );
std::shared_ptr<char> send_buffer(new char[48], [](char* p){ delete[] p; }); std::shared_ptr<char> send_buffer(new char[48], [](char* p){ delete[] p; });
std::array<unsigned char, 48> packet_to_send { {010,0,0,0,0,0,0,0,0} }; std::array<unsigned char, 48> packet_to_send { {010,0,0,0,0,0,0,0,0} };
memcpy(send_buffer.get(), packet_to_send.data(), packet_to_send.size()); memcpy(send_buffer.get(), packet_to_send.data(), packet_to_send.size());
@ -144,7 +144,7 @@ namespace fc
try try
{ {
_sock.receive_from( receive_buffer, receive_buffer_size, from ); _sock.receive_from( receive_buffer, receive_buffer_size, from );
wlog("received ntp reply from ${from}",("from",from) ); // wlog("received ntp reply from ${from}",("from",from) );
} FC_RETHROW_EXCEPTIONS(error, "Error reading from NTP socket"); } FC_RETHROW_EXCEPTIONS(error, "Error reading from NTP socket");
fc::time_point receive_time = fc::time_point::now(); fc::time_point receive_time = fc::time_point::now();
@ -158,10 +158,10 @@ namespace fc
(server_transmit_time - server_receive_time)); (server_transmit_time - server_receive_time));
//wlog("origin_time = ${origin_time}, server_receive_time = ${server_receive_time}, server_transmit_time = ${server_transmit_time}, receive_time = ${receive_time}", //wlog("origin_time = ${origin_time}, server_receive_time = ${server_receive_time}, server_transmit_time = ${server_transmit_time}, receive_time = ${receive_time}",
// ("origin_time", origin_time)("server_receive_time", server_receive_time)("server_transmit_time", server_transmit_time)("receive_time", receive_time)); // ("origin_time", origin_time)("server_receive_time", server_receive_time)("server_transmit_time", server_transmit_time)("receive_time", receive_time));
wlog("ntp offset: ${offset}, round_trip_delay ${delay}", ("offset", offset)("delay", round_trip_delay)); // wlog("ntp offset: ${offset}, round_trip_delay ${delay}", ("offset", offset)("delay", round_trip_delay));
//if the reply we just received has occurred more than a second after our last time request (it was more than a second ago since our last request) //if the reply we just received has occurred more than a second after our last time request (it was more than a second ago since our last request)
if( round_trip_delay > fc::seconds(1) ) if( round_trip_delay > fc::microseconds(300000) )
{ {
wlog("received stale ntp reply requested at ${request_time}, send a new time request", ("request_time", origin_time)); wlog("received stale ntp reply requested at ${request_time}, send a new time request", ("request_time", origin_time));
request_now(); //request another reply and ignore this one request_now(); //request another reply and ignore this one
@ -174,7 +174,7 @@ namespace fc
_last_ntp_delta_initialized = true; _last_ntp_delta_initialized = true;
fc::microseconds ntp_delta_time = fc::microseconds(_last_ntp_delta_microseconds); fc::microseconds ntp_delta_time = fc::microseconds(_last_ntp_delta_microseconds);
_last_valid_ntp_reply_received_time = receive_time; _last_valid_ntp_reply_received_time = receive_time;
wlog("ntp_delta_time updated to ${delta_time}", ("delta_time",ntp_delta_time) ); wlog("ntp_delta_time updated to ${delta_time} us", ("delta_time",ntp_delta_time) );
} }
else else
elog( "NTP time and local time vary by more than a day! ntp:${ntp_time} local:${local}", elog( "NTP time and local time vary by more than a day! ntp:${ntp_time} local:${local}",