diff --git a/libethereum/EthereumHost.h b/libethereum/EthereumHost.h index f92456e8b..f172ea508 100644 --- a/libethereum/EthereumHost.h +++ b/libethereum/EthereumHost.h @@ -94,7 +94,7 @@ private: mutable std::mutex x_blocksNeeded; u256 m_totalDifficultyOfNeeded; - h256s m_blocksNeeded; /// From latest to earliest. + h256s m_blocksNeeded; h256Set m_blocksOnWay; h256 m_latestBlockSent; diff --git a/libethereum/EthereumSession.cpp b/libethereum/EthereumSession.cpp index b90665b4b..579aa5354 100644 --- a/libethereum/EthereumSession.cpp +++ b/libethereum/EthereumSession.cpp @@ -123,11 +123,11 @@ bool EthereumPeer::interpret(RLP const& _r) clogS(NetMessageSummary) << "Status: " << m_protocolVersion << "/" << m_networkId << "/" << genesisHash.abridged() << ", TD:" << m_totalDifficulty << "=" << m_latestHash.abridged(); - if (genesisHash != m_server->m_chain->genesisHash()) + if (genesisHash != hostCapability()->m_chain->genesisHash()) disable("Invalid genesis hash"); - if (m_protocolVersion != EthereumHost::protocolVersion()) + if (m_protocolVersion != hostCapability()->protocolVersion()) disable("Invalid protocol version."); - if (m_networkId != m_server->networkId() || !m_id) + if (m_networkId != hostCapability()->networkId() || !m_id) disable("Invalid network identifier."); startInitialSync(); @@ -135,14 +135,10 @@ bool EthereumPeer::interpret(RLP const& _r) } case GetTransactionsPacket: { - if (m_server->m_mode == NodeMode::PeerServer) - break; m_requireTransactions = true; break; } case TransactionsPacket: - if (m_server->m_mode == NodeMode::PeerServer) - break; clogS(NetMessageSummary) << "Transactions (" << dec << (_r.itemCount() - 1) << " entries)"; m_rating += _r.itemCount() - 1; for (unsigned i = 1; i < _r.itemCount(); ++i) @@ -153,8 +149,6 @@ bool EthereumPeer::interpret(RLP const& _r) break; case GetBlockHashesPacket: { - if (m_server->m_mode == NodeMode::PeerServer) - break; h256 later = _r[1].toHash(); unsigned limit = _r[2].toInt(); clogS(NetMessageSummary) << "GetBlockHashes (" << limit << "entries, " << later.abridged() << ")"; @@ -171,8 +165,6 @@ bool EthereumPeer::interpret(RLP const& _r) } case BlockHashesPacket: { - if (m_server->m_mode == NodeMode::PeerServer) - break; clogS(NetMessageSummary) << "BlockHashes (" << dec << (_r.itemCount() - 1) << " entries)"; if (_r.itemCount() == 1) { @@ -199,8 +191,6 @@ bool EthereumPeer::interpret(RLP const& _r) } case GetBlocksPacket: { - if (m_server->m_mode == NodeMode::PeerServer) - break; clogS(NetMessageSummary) << "GetBlocks (" << dec << (_r.itemCount() - 1) << " entries)"; // TODO: return the requested blocks. bytes rlp; @@ -220,8 +210,6 @@ bool EthereumPeer::interpret(RLP const& _r) } case BlocksPacket: { - if (m_server->m_mode == NodeMode::PeerServer) - break; clogS(NetMessageSummary) << "Blocks (" << dec << (_r.itemCount() - 1) << " entries)"; if (_r.itemCount() == 1 && !m_askedBlocksChanged)