Added atomic to additional fields reported by sanitizer

Author: Mikołaj Małecki

srtcore/core.h

@@ -860,7 +860,7 @@ class CUDT
     int32_t m_iRcvLastSkipAck;                   // Last dropped sequence ACK
     int32_t m_iRcvLastAckAck;                    // Last sent ACK that has been acknowledged
     int32_t m_iAckSeqNo;                         // Last ACK sequence number
-    int32_t m_iRcvCurrSeqNo;                     // Largest received sequence number
+    srt::sync::atomic<int32_t> m_iRcvCurrSeqNo;  // Largest received sequence number
     int32_t m_iRcvCurrPhySeqNo;                  // Same as m_iRcvCurrSeqNo, but physical only (disregarding a filter)
 
     int32_t m_iPeerISN;                          // Initial Sequence Number of the peer side

srtcore/group.h

@@ -449,7 +449,7 @@ class CUDTGroup
     bool           m_bSyncOnMsgNo;
     SRT_GROUP_TYPE m_type;
     CUDTSocket*    m_listener; // A "group" can only have one listener.
-    int            m_iBusy;
+    srt::sync::atomic<int> m_iBusy;
     CallbackHolder<srt_connect_callback_fn> m_cbConnectHook;
     void installConnectHook(srt_connect_callback_fn* hook, void* opaq)
     {

srtcore/queue.cpp

@@ -242,15 +242,17 @@ void CUnitQueue::makeUnitFree(CUnit *unit)
     SRT_ASSERT(unit != NULL);
     SRT_ASSERT(unit->m_iFlag != CUnit::FREE);
     unit->m_iFlag = CUnit::FREE;
+
     --m_iCount;
 }
 
 void CUnitQueue::makeUnitGood(CUnit *unit)
 {
+    ++m_iCount;
+
     SRT_ASSERT(unit != NULL);
     SRT_ASSERT(unit->m_iFlag == CUnit::FREE);
     unit->m_iFlag = CUnit::GOOD;
-    ++m_iCount;
 }
 
 CSndUList::CSndUList()

srtcore/queue.h

@@ -136,7 +136,7 @@ class CUnitQueue
    CUnit* m_pAvailUnit; // recent available unit
 
    int m_iSize;         // total size of the unit queue, in number of packets
-   int m_iCount;        // total number of valid (occupied) packets in the queue
+   srt::sync::atomic<int> m_iCount;        // total number of valid (occupied) packets in the queue
 
    int m_iMSS;          // unit buffer size
    int m_iIPversion;    // IP version