Changeset View
Changeset View
Standalone View
Standalone View
src/net.h
Show First 20 Lines • Show All 820 Lines • ▼ Show 20 Lines | public: | ||||
std::atomic<ServiceFlags> nServices{NODE_NONE}; | std::atomic<ServiceFlags> nServices{NODE_NONE}; | ||||
SOCKET hSocket GUARDED_BY(cs_hSocket); | SOCKET hSocket GUARDED_BY(cs_hSocket); | ||||
// Total size of all vSendMsg entries. | // Total size of all vSendMsg entries. | ||||
size_t nSendSize{0}; | size_t nSendSize{0}; | ||||
// Offset inside the first vSendMsg already sent. | // Offset inside the first vSendMsg already sent. | ||||
size_t nSendOffset{0}; | size_t nSendOffset{0}; | ||||
uint64_t nSendBytes GUARDED_BY(cs_vSend){0}; | uint64_t nSendBytes GUARDED_BY(cs_vSend){0}; | ||||
std::deque<std::vector<uint8_t>> vSendMsg GUARDED_BY(cs_vSend); | std::deque<std::vector<uint8_t>> vSendMsg GUARDED_BY(cs_vSend); | ||||
RecursiveMutex cs_vSend; | Mutex cs_vSend; | ||||
RecursiveMutex cs_hSocket; | Mutex cs_hSocket; | ||||
RecursiveMutex cs_vRecv; | Mutex cs_vRecv; | ||||
RecursiveMutex cs_vProcessMsg; | RecursiveMutex cs_vProcessMsg; | ||||
std::list<CNetMessage> vProcessMsg GUARDED_BY(cs_vProcessMsg); | std::list<CNetMessage> vProcessMsg GUARDED_BY(cs_vProcessMsg); | ||||
size_t nProcessQueueSize{0}; | size_t nProcessQueueSize{0}; | ||||
RecursiveMutex cs_sendProcessing; | RecursiveMutex cs_sendProcessing; | ||||
std::deque<CInv> vRecvGetData; | std::deque<CInv> vRecvGetData; | ||||
▲ Show 20 Lines • Show All 353 Lines • Show Last 20 Lines |