diff options
author | Cory Fields <cory-nospam-@coryfields.com> | 2016-05-21 12:04:02 +0200 |
---|---|---|
committer | Cory Fields <cory-nospam-@coryfields.com> | 2016-09-08 12:24:06 -0400 |
commit | adf5d4c2e4e7a2979a6ca6de806151fe04c23162 (patch) | |
tree | 00608baf1c5e60f0858685ba54421def4cb91341 /src/net.cpp | |
parent | ee44fa95761724a83a76dd862a36bd9af0fc021f (diff) |
net: SocketSendData returns written size
Diffstat (limited to 'src/net.cpp')
-rw-r--r-- | src/net.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/net.cpp b/src/net.cpp index a62ee2291c..aded8d05d3 100644 --- a/src/net.cpp +++ b/src/net.cpp @@ -791,9 +791,10 @@ int CNetMessage::readData(const char *pch, unsigned int nBytes) // requires LOCK(cs_vSend) -void SocketSendData(CNode *pnode) +size_t SocketSendData(CNode *pnode) { std::deque<CSerializeData>::iterator it = pnode->vSendMsg.begin(); + size_t nSentSize = 0; while (it != pnode->vSendMsg.end()) { const CSerializeData &data = *it; @@ -804,6 +805,7 @@ void SocketSendData(CNode *pnode) pnode->nSendBytes += nBytes; pnode->nSendOffset += nBytes; pnode->RecordBytesSent(nBytes); + nSentSize += nBytes; if (pnode->nSendOffset == data.size()) { pnode->nSendOffset = 0; pnode->nSendSize -= data.size(); @@ -832,6 +834,7 @@ void SocketSendData(CNode *pnode) assert(pnode->nSendSize == 0); } pnode->vSendMsg.erase(pnode->vSendMsg.begin(), it); + return nSentSize; } static std::list<CNode*> vNodesDisconnected; |