mirror of
https://github.com/Xahau/xahaud.git
synced 2025-12-06 17:27:52 +00:00
Make debug easier.
This commit is contained in:
31
src/Peer.cpp
31
src/Peer.cpp
@@ -38,7 +38,7 @@ void Peer::handle_write(const boost::system::error_code& error, size_t bytes_tra
|
|||||||
|
|
||||||
if(error)
|
if(error)
|
||||||
{
|
{
|
||||||
detach();
|
detach("hw");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -53,8 +53,11 @@ void Peer::handle_write(const boost::system::error_code& error, size_t bytes_tra
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void Peer::detach()
|
void Peer::detach(const char *rsn)
|
||||||
{
|
{
|
||||||
|
#ifdef DEBUG
|
||||||
|
std::cerr << "DETACHING PEER: " << rsn << std::endl;
|
||||||
|
#endif
|
||||||
boost::system::error_code ecCancel;
|
boost::system::error_code ecCancel;
|
||||||
|
|
||||||
(void) mVerifyTimer.cancel();
|
(void) mVerifyTimer.cancel();
|
||||||
@@ -90,7 +93,7 @@ void Peer::handleVerifyTimer(const boost::system::error_code& ecResult)
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
std::cerr << "Peer failed to verify in time." << std::endl;
|
std::cerr << "Peer failed to verify in time." << std::endl;
|
||||||
detach();
|
detach("hvt");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -114,7 +117,7 @@ void Peer::connect(const std::string strIp, int iPort)
|
|||||||
if (err || itrEndpoint == boost::asio::ip::tcp::resolver::iterator())
|
if (err || itrEndpoint == boost::asio::ip::tcp::resolver::iterator())
|
||||||
{
|
{
|
||||||
std::cerr << "Peer::connect: Bad IP" << std::endl;
|
std::cerr << "Peer::connect: Bad IP" << std::endl;
|
||||||
detach();
|
detach("c");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
@@ -125,7 +128,7 @@ void Peer::connect(const std::string strIp, int iPort)
|
|||||||
if (err)
|
if (err)
|
||||||
{
|
{
|
||||||
std::cerr << "Peer::connect: Failed to set timer." << std::endl;
|
std::cerr << "Peer::connect: Failed to set timer." << std::endl;
|
||||||
detach();
|
detach("c2");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -154,7 +157,7 @@ void Peer::handleStart(const boost::system::error_code& error)
|
|||||||
if (error)
|
if (error)
|
||||||
{
|
{
|
||||||
std::cerr << "Peer::handleStart: failed:" << error << std::endl;
|
std::cerr << "Peer::handleStart: failed:" << error << std::endl;
|
||||||
detach();
|
detach("hs");
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -169,7 +172,7 @@ void Peer::handleConnect(const boost::system::error_code& error, boost::asio::ip
|
|||||||
if (error)
|
if (error)
|
||||||
{
|
{
|
||||||
std::cerr << "Connect peer: failed:" << error << std::endl;
|
std::cerr << "Connect peer: failed:" << error << std::endl;
|
||||||
detach();
|
detach("hc");
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -198,13 +201,13 @@ void Peer::connected(const boost::system::error_code& error)
|
|||||||
if (error)
|
if (error)
|
||||||
{
|
{
|
||||||
std::cerr << "Remote peer: accept error: " << strIp << " " << iPort << " : " << error << std::endl;
|
std::cerr << "Remote peer: accept error: " << strIp << " " << iPort << " : " << error << std::endl;
|
||||||
detach();
|
detach("ctd");
|
||||||
}
|
}
|
||||||
else if (!theApp->getConnectionPool().peerRegister(shared_from_this(), strIp, iPort))
|
else if (!theApp->getConnectionPool().peerRegister(shared_from_this(), strIp, iPort))
|
||||||
{
|
{
|
||||||
std::cerr << "Remote peer: rejecting: " << strIp << " " << iPort << std::endl;
|
std::cerr << "Remote peer: rejecting: " << strIp << " " << iPort << std::endl;
|
||||||
// XXX Reject with a rejection message: already connected
|
// XXX Reject with a rejection message: already connected
|
||||||
detach();
|
detach("ctd2");
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -277,14 +280,14 @@ void Peer::handle_read_header(const boost::system::error_code& error)
|
|||||||
// WRITEME: Compare to maximum message length, abort if too large
|
// WRITEME: Compare to maximum message length, abort if too large
|
||||||
if(msg_len>(32*1024*1024))
|
if(msg_len>(32*1024*1024))
|
||||||
{
|
{
|
||||||
detach();
|
detach("hrh");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
start_read_body(msg_len);
|
start_read_body(msg_len);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
detach();
|
detach("hrh2");
|
||||||
std::cerr << "Peer::handle_read_header: Error: " << error << std::endl; //else BOOST_LOG_TRIVIAL(info) << "Error: " << error;
|
std::cerr << "Peer::handle_read_header: Error: " << error << std::endl; //else BOOST_LOG_TRIVIAL(info) << "Error: " << error;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -298,7 +301,7 @@ void Peer::handle_read_body(const boost::system::error_code& error)
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
detach();
|
detach("hrb");
|
||||||
std::cerr << "Peer::handle_read_body: Error: " << error << std::endl; //else BOOST_LOG_TRIVIAL(info) << "Error: " << error;
|
std::cerr << "Peer::handle_read_body: Error: " << error << std::endl; //else BOOST_LOG_TRIVIAL(info) << "Error: " << error;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -315,7 +318,7 @@ void Peer::processReadBuffer()
|
|||||||
if (mIpPort.first.empty() == (type == newcoin::mtHELLO))
|
if (mIpPort.first.empty() == (type == newcoin::mtHELLO))
|
||||||
{
|
{
|
||||||
std::cerr << "Wrong message type: " << type << std::endl;
|
std::cerr << "Wrong message type: " << type << std::endl;
|
||||||
detach();
|
detach("prb1");
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -551,7 +554,7 @@ void Peer::recvHello(newcoin::TMHello& packet)
|
|||||||
if (bDetach)
|
if (bDetach)
|
||||||
{
|
{
|
||||||
mNodePublic.clear();
|
mNodePublic.clear();
|
||||||
detach();
|
detach("recvh");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -104,7 +104,7 @@ public:
|
|||||||
|
|
||||||
void connect(const std::string strIp, int iPort);
|
void connect(const std::string strIp, int iPort);
|
||||||
void connected(const boost::system::error_code& error);
|
void connected(const boost::system::error_code& error);
|
||||||
void detach();
|
void detach(const char *);
|
||||||
bool samePeer(Peer::pointer p) { return samePeer(*p); }
|
bool samePeer(Peer::pointer p) { return samePeer(*p); }
|
||||||
bool samePeer(const Peer& p) { return this == &p; }
|
bool samePeer(const Peer& p) { return this == &p; }
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user