Method SocketSendData

src/p2p/node.cpp:61–101

requires LOCK(cs_vSend)

// requires LOCK(cs_vSend)
void CNode::SocketSendData() {
    deque<CSerializeData>::iterator it = vSendMsg.begin();

    while (it != vSendMsg.end()) {
        const CSerializeData& data = *it;
        assert(data.size() > nSendOffset);
        int32_t nBytes = send(hSocket, &data[nSendOffset], data.size() - nSendOffset,
                              MSG_NOSIGNAL | MSG_DONTWAIT);
        if (nBytes > 0) {
            nLastSend = GetTime();
            nSendBytes += nBytes;
            nSendOffset += nBytes;
            RecordBytesSent(nBytes);
            if (nSendOffset == data.size()) {
                nSendOffset = 0;
                nSendSize -= data.size();
                it++;
            } else {
                // could not send full message; stop sending more
                break;
            }
        } else {
            if (nBytes < 0) {
                // error
                int32_t nErr = WSAGetLastError();
                if (nErr != WSAEWOULDBLOCK && nErr != WSAEMSGSIZE && nErr != WSAEINTR && nErr != WSAEINPROGRESS) {
                    LogPrint(BCLog::INFO, "socket send error %s\n", NetworkErrorString(nErr));
                    CloseSocketDisconnect();
                }
            }
            // couldn't send anything at all
            break;
        }
    }

    if (it == vSendMsg.end()) {
        assert(nSendOffset == 0);
        assert(nSendSize == 0);
    }
    vSendMsg.erase(vSendMsg.begin(), it);
}