Ecosystem/p2pool
1
0
Fork 0
mirror of https://github.com/SChernykh/p2pool.git synced 2025-01-22 02:14:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

P2PServer: always send peer list request to new peers

Browse source
This commit is contained in:
SChernykh 2023-05-17 11:13:25 +02:00
parent 3c7fcf65a9
commit b20db0a117
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/p2p_server.cpp
View file

@ -1987,15 +1987,19 @@ bool P2PServer::P2PClient::on_block_request(const uint8_t* buf)
bool P2PServer::P2PClient::on_block_response(const uint8_t* buf, uint32_t size, const hash& expected_id) bool P2PServer::P2PClient::on_block_response(const uint8_t* buf, uint32_t size, const hash& expected_id)
{ {
P2PServer* server = static_cast<P2PServer*>(m_owner);
const uint64_t cur_time = seconds_since_epoch();
if (!size) { if (!size) {
LOGINFO(5, "peer " << log::Gray() << static_cast<char*>(m_addrString) << log::NoColor() << " sent an empty block response"); LOGINFO(5, "peer " << log::Gray() << static_cast<char*>(m_addrString) << log::NoColor() << " sent an empty block response");
if (cur_time >= m_nextOutgoingPeerListRequest) {
server->send_peer_list_request(this, cur_time);
}
return true; return true;
} }
const uint64_t received_timestamp = microseconds_since_epoch(); const uint64_t received_timestamp = microseconds_since_epoch();
P2PServer* server = static_cast<P2PServer*>(m_owner);
MutexLock lock(server->m_blockLock); MutexLock lock(server->m_blockLock);
const int result = server->deserialize_block(buf, size, false, received_timestamp); const int result = server->deserialize_block(buf, size, false, received_timestamp);
@ -2016,7 +2020,6 @@ bool P2PServer::P2PClient::on_block_response(const uint8_t* buf, uint32_t size,
return false; return false;
} }
const uint64_t cur_time = seconds_since_epoch();
if (cur_time >= m_nextOutgoingPeerListRequest) { if (cur_time >= m_nextOutgoingPeerListRequest) {
server->send_peer_list_request(this, cur_time); server->send_peer_list_request(this, cur_time);
} }