Peerplays_Blockchain/peerplays_migrated
1
0
Fork 0
Code Issues 35 Pull requests 4 Projects Releases 20 Packages Wiki Activity Actions

Remove unreachable seed nodes

Browse source
This commit is contained in:
Vikram Rajkumar 2016-11-17 15:37:32 -06:00
parent 4e4a359fb9
commit 75f238d15f
1 changed files with 29 additions and 33 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

62
libraries/app/application.cpp
View file

@ -162,23 +162,19 @@ namespace detail {
else else
{ {
vector<string> seeds = { vector<string> seeds = {
"faucet.bitshares.org:1776", "104.236.144.84:1777", // puppies
"bitshares.openledger.info:1776", "128.199.143.47:2015", // Harvey
"bts-seed1.abit-more.com:62015", // abit "185.25.22.21:1776", // liondani (Greece)
"seed.blocktrades.us:1776", "bitshares.openledger.info:1776", // OpenLedger
"seed.bitsharesnodes.com:1776", // wackou "bts-seed1.abit-more.com:62015", // abit
"seed04.bitsharesnodes.com:1776", // thom "seed.bitsharesnodes.com:1776", // wackou
"seed05.bitsharesnodes.com:1776", // thom "seed.blocktrades.us:1776", // BlockTrades
"seed06.bitsharesnodes.com:1776", // thom "seed.roelandp.nl:1776" // roelandp (Canada)
"seed07.bitsharesnodes.com:1776", // thom "seed02.bitsharesnodes.com:1776",
"seed.cubeconnex.com:1777", // cube "seed04.bitsharesnodes.com:1776", // Thom
"54.85.252.77:39705", // lafona "seed05.bitsharesnodes.com:1776", // Thom
"104.236.144.84:1777", // puppies "seed06.bitsharesnodes.com:1776", // Thom
"40.127.190.171:1777", // betax "seed07.bitsharesnodes.com:1776", // Thom
"185.25.22.21:1776", // liondani (greece)
"212.47.249.84:50696", // iHashFury
"128.199.143.47:2015", // Harvey
"seed.roelandp.nl:1776" // @roelandp (canada)
}; };
for( const string& endpoint_string : seeds ) for( const string& endpoint_string : seeds )
{ {
@ -530,7 +526,7 @@ namespace detail {
const auto& witness = blk_msg.block.witness(*_chain_db); const auto& witness = blk_msg.block.witness(*_chain_db);
const auto& witness_account = witness.witness_account(*_chain_db); const auto& witness_account = witness.witness_account(*_chain_db);
auto last_irr = _chain_db->get_dynamic_global_properties().last_irreversible_block_num; auto last_irr = _chain_db->get_dynamic_global_properties().last_irreversible_block_num;
ilog("Got block: #${n} time: ${t} latency: ${l} ms from: ${w} irreversible: ${i} (-${d})", ilog("Got block: #${n} time: ${t} latency: ${l} ms from: ${w} irreversible: ${i} (-${d})",
("t",blk_msg.block.timestamp) ("t",blk_msg.block.timestamp)
("n", blk_msg.block.block_num()) ("n", blk_msg.block.block_num())
("l", (latency.count()/1000)) ("l", (latency.count()/1000))
@ -625,7 +621,7 @@ namespace detail {
result.reserve(limit); result.reserve(limit);
block_id_type last_known_block_id; block_id_type last_known_block_id;
if (blockchain_synopsis.empty() || if (blockchain_synopsis.empty() ||
(blockchain_synopsis.size() == 1 && blockchain_synopsis[0] == block_id_type())) (blockchain_synopsis.size() == 1 && blockchain_synopsis[0] == block_id_type()))
{ {
@ -686,13 +682,13 @@ namespace detail {
} }
/** /**
* Returns a synopsis of the blockchain used for syncing. This consists of a list of * Returns a synopsis of the blockchain used for syncing. This consists of a list of
* block hashes at intervals exponentially increasing towards the genesis block. * block hashes at intervals exponentially increasing towards the genesis block.
* When syncing to a peer, the peer uses this data to determine if we're on the same * When syncing to a peer, the peer uses this data to determine if we're on the same
* fork as they are, and if not, what blocks they need to send us to get us on their * fork as they are, and if not, what blocks they need to send us to get us on their
* fork. * fork.
* *
* In the over-simplified case, this is a straighforward synopsis of our current * In the over-simplified case, this is a straighforward synopsis of our current
* preferred blockchain; when we first connect up to a peer, this is what we will be sending. * preferred blockchain; when we first connect up to a peer, this is what we will be sending.
* It looks like this: * It looks like this:
* If the blockchain is empty, it will return the empty list. * If the blockchain is empty, it will return the empty list.
@ -708,7 +704,7 @@ namespace detail {
* the last item in the list will be the hash of the most recent block on our preferred chain * the last item in the list will be the hash of the most recent block on our preferred chain
* so if the blockchain had 26 blocks labeled a - z, the synopsis would be: * so if the blockchain had 26 blocks labeled a - z, the synopsis would be:
* a n u x z * a n u x z
* the idea being that by sending a small (<30) number of block ids, we can summarize a huge * the idea being that by sending a small (<30) number of block ids, we can summarize a huge
* blockchain. The block ids are more dense near the end of the chain where because we are * blockchain. The block ids are more dense near the end of the chain where because we are
* more likely to be almost in sync when we first connect, and forks are likely to be short. * more likely to be almost in sync when we first connect, and forks are likely to be short.
* If the peer we're syncing with in our example is on a fork that started at block 'v', * If the peer we're syncing with in our example is on a fork that started at block 'v',
@ -723,27 +719,27 @@ namespace detail {
* no reason to fetch the blocks. * no reason to fetch the blocks.
* *
* Second, when a peer replies to our initial synopsis and gives us a list of the blocks they think * Second, when a peer replies to our initial synopsis and gives us a list of the blocks they think
* we are missing, they only send a chunk of a few thousand blocks at once. After we get those * we are missing, they only send a chunk of a few thousand blocks at once. After we get those
* block ids, we need to request more blocks by sending another synopsis (we can't just say "send me * block ids, we need to request more blocks by sending another synopsis (we can't just say "send me
* the next 2000 ids" because they may have switched forks themselves and they don't track what * the next 2000 ids" because they may have switched forks themselves and they don't track what
* they've sent us). For faster performance, we want to get a fairly long list of block ids first, * they've sent us). For faster performance, we want to get a fairly long list of block ids first,
* then start downloading the blocks. * then start downloading the blocks.
* The peer doesn't handle these follow-up block id requests any different from the initial request; * The peer doesn't handle these follow-up block id requests any different from the initial request;
* it treats the synopsis we send as our blockchain and bases its response entirely off that. So to * it treats the synopsis we send as our blockchain and bases its response entirely off that. So to
* get the response we want (the next chunk of block ids following the last one they sent us, or, * get the response we want (the next chunk of block ids following the last one they sent us, or,
* failing that, the shortest fork off of the last list of block ids they sent), we need to construct * failing that, the shortest fork off of the last list of block ids they sent), we need to construct
* a synopsis as if our blockchain was made up of: * a synopsis as if our blockchain was made up of:
* 1. the blocks in our block chain up to the fork point (if there is a fork) or the head block (if no fork) * 1. the blocks in our block chain up to the fork point (if there is a fork) or the head block (if no fork)
* 2. the blocks we've already pushed from their fork (if there's a fork) * 2. the blocks we've already pushed from their fork (if there's a fork)
* 3. the block ids they've previously sent us * 3. the block ids they've previously sent us
* Segment 3 is handled in the p2p code, it just tells us the number of blocks it has (in * Segment 3 is handled in the p2p code, it just tells us the number of blocks it has (in
* number_of_blocks_after_reference_point) so we can leave space in the synopsis for them. * number_of_blocks_after_reference_point) so we can leave space in the synopsis for them.
* We're responsible for constructing the synopsis of Segments 1 and 2 from our active blockchain and * We're responsible for constructing the synopsis of Segments 1 and 2 from our active blockchain and
* fork database. The reference_point parameter is the last block from that peer that has been * fork database. The reference_point parameter is the last block from that peer that has been
* successfully pushed to the blockchain, so that tells us whether the peer is on a fork or on * successfully pushed to the blockchain, so that tells us whether the peer is on a fork or on
* the main chain. * the main chain.
*/ */
virtual std::vector<item_hash_t> get_blockchain_synopsis(const item_hash_t& reference_point, virtual std::vector<item_hash_t> get_blockchain_synopsis(const item_hash_t& reference_point,
uint32_t number_of_blocks_after_reference_point) override uint32_t number_of_blocks_after_reference_point) override
{ try { { try {
std::vector<item_hash_t> synopsis; std::vector<item_hash_t> synopsis;
@ -768,13 +764,13 @@ namespace detail {
if (reference_point_block_num < low_block_num) if (reference_point_block_num < low_block_num)
{ {
// we're on the same fork (at least as far as reference_point) but we've passed // we're on the same fork (at least as far as reference_point) but we've passed
// reference point and could no longer undo that far if we diverged after that // reference point and could no longer undo that far if we diverged after that
// block. This should probably only happen due to a race condition where // block. This should probably only happen due to a race condition where
// the network thread calls this function, and then immediately pushes a bunch of blocks, // the network thread calls this function, and then immediately pushes a bunch of blocks,
// then the main thread finally processes this function. // then the main thread finally processes this function.
// with the current framework, there's not much we can do to tell the network // with the current framework, there's not much we can do to tell the network
// thread what our current head block is, so we'll just pretend that // thread what our current head block is, so we'll just pretend that
// our head is actually the reference point. // our head is actually the reference point.
// this *may* enable us to fetch blocks that we're unable to push, but that should // this *may* enable us to fetch blocks that we're unable to push, but that should
// be a rare case (and correctly handled) // be a rare case (and correctly handled)
@ -818,7 +814,7 @@ namespace detail {
if (non_fork_high_block_num < low_block_num) if (non_fork_high_block_num < low_block_num)
{ {
wlog("Unable to generate a usable synopsis because the peer we're generating it for forked too long ago " wlog("Unable to generate a usable synopsis because the peer we're generating it for forked too long ago "
"(our chains diverge after block #${non_fork_high_block_num} but only undoable to block #${low_block_num})", "(our chains diverge after block #${non_fork_high_block_num} but only undoable to block #${low_block_num})",
("low_block_num", low_block_num) ("low_block_num", low_block_num)
("non_fork_high_block_num", non_fork_high_block_num)); ("non_fork_high_block_num", non_fork_high_block_num));
FC_THROW_EXCEPTION(graphene::net::block_older_than_undo_history, "Peer is are on a fork I'm unable to switch to"); FC_THROW_EXCEPTION(graphene::net::block_older_than_undo_history, "Peer is are on a fork I'm unable to switch to");
@ -835,11 +831,11 @@ namespace detail {
} }
// at this point: // at this point:
// low_block_num is the block before the first block we can undo, // low_block_num is the block before the first block we can undo,
// non_fork_high_block_num is the block before the fork (if the peer is on a fork, or otherwise it is the same as high_block_num) // non_fork_high_block_num is the block before the fork (if the peer is on a fork, or otherwise it is the same as high_block_num)
// high_block_num is the block number of the reference block, or the end of the chain if no reference provided // high_block_num is the block number of the reference block, or the end of the chain if no reference provided
// true_high_block_num is the ending block number after the network code appends any item ids it // true_high_block_num is the ending block number after the network code appends any item ids it
// knows about that we don't // knows about that we don't
uint32_t true_high_block_num = high_block_num + number_of_blocks_after_reference_point; uint32_t true_high_block_num = high_block_num + number_of_blocks_after_reference_point;
do do