ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-21 11:35:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fill in some fields in the Hello packet, and report them on reception.

Browse Source
This commit is contained in:
JoelKatz
2012-01-19 14:25:20 -08:00
parent 1c01d7dc8d
commit 10f7d3247d
1 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
Peer.cpp
View File

@@ -19,7 +19,12 @@ Peer::Peer(boost::asio::io_service& io_service)
void Peer::handle_write(const boost::system::error_code& error, size_t bytes_transferred) void Peer::handle_write(const boost::system::error_code& error, size_t bytes_transferred)
{ {
cout << "Peer::handle_write Error: " << error << " bytes: "<< bytes_transferred << endl; #ifdef DEBUG
if(error)
cout << "Peer::handle_write Error: " << error << " bytes: "<< bytes_transferred << endl;
else
cout << "Peer::handle_write bytes: "<< bytes_transferred << endl;
#endif
mSendingPacket=PackedMessage::pointer(); mSendingPacket=PackedMessage::pointer();
if(!mSendQ.empty()) if(!mSendQ.empty())
@@ -267,6 +272,9 @@ void Peer::processReadBuffer()
void Peer::recvHello(newcoin::TMHello& packet) void Peer::recvHello(newcoin::TMHello& packet)
{ {
#ifdef DEBUG
std::cerr << "Recv(Hello) v=" << packet.version() << ", index=" << packet.ledgerindex() << std::endl;
#endif
} }
void Peer::recvTransaction(newcoin::TMTransaction& packet) void Peer::recvTransaction(newcoin::TMTransaction& packet)
@@ -334,6 +342,9 @@ void Peer::sendHello()
newcoin::TMHello* h=new newcoin::TMHello(); newcoin::TMHello* h=new newcoin::TMHello();
// set up parameters // set up parameters
h->set_version(theConfig.VERSION); h->set_version(theConfig.VERSION);
h->set_ledgerindex(theApp->getOPs().getCurrentLedgerID());
h->set_nettime(theApp->getOPs().getNetworkTime());
h->set_ipv4port(theConfig.PEER_PORT);
PackedMessage::pointer packet(new PackedMessage(PackedMessage::MessagePointer(h), newcoin::mtHELLO)); PackedMessage::pointer packet(new PackedMessage(PackedMessage::MessagePointer(h), newcoin::mtHELLO));
sendPacket(packet); sendPacket(packet);
} }
@@ -341,16 +352,6 @@ void Peer::sendHello()
#if 0 #if 0
void Peer::sendHello()
{
newcoin::Hello* hello=new newcoin::Hello();
hello->set_nodeid("0");
hello->set_port(theConfig.PEER_PORT);
hello->set_version(theConfig.VERSION);
PackedMessage::pointer packet(new PackedMessage(PackedMessage::MessagePointer(hello),newcoin::mtHELLO));
sendPacket(packet);
}
/* /*
PackedMessage::pointer Peer::createFullLedger(Ledger::pointer ledger) PackedMessage::pointer Peer::createFullLedger(Ledger::pointer ledger)
{ {