File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -857,8 +857,10 @@ class CNode
857857 // socket
858858 std::atomic<ServiceFlags> nServices{NODE_NONE};
859859 SOCKET hSocket GUARDED_BY (cs_hSocket);
860- size_t nSendSize{0 }; // total size of all vSendMsg entries
861- size_t nSendOffset{0 }; // offset inside the first vSendMsg already sent
860+ /* * Total size of all vSendMsg entries */
861+ size_t nSendSize GUARDED_BY (cs_vSend){0 };
862+ /* * Offset inside the first vSendMsg already sent */
863+ size_t nSendOffset GUARDED_BY (cs_vSend){0 };
862864 uint64_t nSendBytes GUARDED_BY (cs_vSend){0 };
863865 std::deque<std::vector<unsigned char >> vSendMsg GUARDED_BY (cs_vSend);
864866 RecursiveMutex cs_vSend;
@@ -989,7 +991,7 @@ class CNode
989991 Network ConnectedThroughNetwork () const ;
990992
991993protected:
992- mapMsgCmdSize mapSendBytesPerMsgCmd;
994+ mapMsgCmdSize mapSendBytesPerMsgCmd GUARDED_BY (cs_vSend) ;
993995 mapMsgCmdSize mapRecvBytesPerMsgCmd GUARDED_BY (cs_vRecv);
994996
995997public:
You can’t perform that action at this time.
0 commit comments