dash/blackcoin-more
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

log bytes recv/sent per command

Browse Source
This commit is contained in:
Jonas Schnelli
2015-08-25 16:30:31 +02:00
committed by lateminer
parent 6a4c64355e
commit 68a0b905a7
3 changed files with 67 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/net.h
View File

@@ -182,6 +182,7 @@ struct LocalServiceInfo {
extern CCriticalSection cs_mapLocalHost;
extern std::map<CNetAddr, LocalServiceInfo> mapLocalHost;
typedef std::map<std::string, uint64_t> mapMsgCmdSize; //command, total bytes
class CNodeStats
{
@@ -199,7 +200,9 @@ public:
bool fInbound;
int nStartingHeight;
uint64_t nSendBytes;
mapMsgCmdSize mapSendBytesPerMsgCmd;
uint64_t nRecvBytes;
mapMsgCmdSize mapRecvBytesPerMsgCmd;
bool fWhitelisted;
double dPingTime;
double dPingWait;
@@ -376,6 +379,9 @@ protected:
static std::vector<CSubNet> vWhitelistedRange;
static CCriticalSection cs_vWhitelistedRange;
mapMsgCmdSize mapSendBytesPerMsgCmd;
mapMsgCmdSize mapRecvBytesPerMsgCmd;
// Basic fuzz-testing
void Fuzz(int nChance); // modifies ssSend
@@ -550,7 +556,7 @@ public:
void AbortMessage() UNLOCK_FUNCTION(cs_vSend);
// TODO: Document the precondition of this function. Is cs_vSend locked?
void EndMessage() UNLOCK_FUNCTION(cs_vSend);
void EndMessage(const char* pszCommand) UNLOCK_FUNCTION(cs_vSend);
void PushVersion();
@@ -560,7 +566,7 @@ public:
try
{
BeginMessage(pszCommand);
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -576,7 +582,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -592,7 +598,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1 << a2;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -608,7 +614,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1 << a2 << a3;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -624,7 +630,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1 << a2 << a3 << a4;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -640,7 +646,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1 << a2 << a3 << a4 << a5;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -656,7 +662,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1 << a2 << a3 << a4 << a5 << a6;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -672,7 +678,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1 << a2 << a3 << a4 << a5 << a6 << a7;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -688,7 +694,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1 << a2 << a3 << a4 << a5 << a6 << a7 << a8;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{
@@ -704,7 +710,7 @@ public:
{
BeginMessage(pszCommand);
ssSend << a1 << a2 << a3 << a4 << a5 << a6 << a7 << a8 << a9;
EndMessage();
EndMessage(pszCommand);
}
catch (...)
{