|
|
|
@ -857,8 +857,10 @@ public:
|
|
|
|
|
// socket
|
|
|
|
|
std::atomic<ServiceFlags> nServices{NODE_NONE};
|
|
|
|
|
SOCKET hSocket GUARDED_BY(cs_hSocket);
|
|
|
|
|
size_t nSendSize{0}; // total size of all vSendMsg entries
|
|
|
|
|
size_t nSendOffset{0}; // offset inside the first vSendMsg already sent
|
|
|
|
|
/** Total size of all vSendMsg entries */
|
|
|
|
|
size_t nSendSize GUARDED_BY(cs_vSend){0};
|
|
|
|
|
/** Offset inside the first vSendMsg already sent */
|
|
|
|
|
size_t nSendOffset GUARDED_BY(cs_vSend){0};
|
|
|
|
|
uint64_t nSendBytes GUARDED_BY(cs_vSend){0};
|
|
|
|
|
std::deque<std::vector<unsigned char>> vSendMsg GUARDED_BY(cs_vSend);
|
|
|
|
|
RecursiveMutex cs_vSend;
|
|
|
|
@ -989,7 +991,7 @@ public:
|
|
|
|
|
Network ConnectedThroughNetwork() const;
|
|
|
|
|
|
|
|
|
|
protected:
|
|
|
|
|
mapMsgCmdSize mapSendBytesPerMsgCmd;
|
|
|
|
|
mapMsgCmdSize mapSendBytesPerMsgCmd GUARDED_BY(cs_vSend);
|
|
|
|
|
mapMsgCmdSize mapRecvBytesPerMsgCmd GUARDED_BY(cs_vRecv);
|
|
|
|
|
|
|
|
|
|
public:
|
|
|
|
|