[core] Made CSndQueue::m_counter atomic.

Haivision · Aug 8, 2024 · b8a2822 · b8a2822
1 parent 4270a11
commit b8a2822
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/srtcore/queue.cpp b/srtcore/queue.cpp
@@ -444,7 +444,7 @@ int srt::CSndQueue::sockoptQuery(int level, int type) const
 }
 
 #if ENABLE_LOGGING
-int srt::CSndQueue::m_counter = 0;
+srt::sync::atomic<int> srt::CSndQueue::m_counter(0);
 #endif
 
 void srt::CSndQueue::init(CChannel* c, CTimer* t)

diff --git a/srtcore/queue.h b/srtcore/queue.h
@@ -469,7 +469,7 @@ class CSndQueue
 private:
 
 #if ENABLE_LOGGING
-    static int m_counter;
+    static srt::sync::atomic<int> m_counter;
 #endif
 
     CSndQueue(const CSndQueue&);

diff --git a/srtcore/sync.h b/srtcore/sync.h
@@ -540,7 +540,7 @@ class SRT_ATTR_SCOPED_CAPABILITY ExclusiveLock
         m_mutex.lock();
     }
 
-    SRT_ATTR_RELEASE()
+    SRT_ATTR_RELEASE(m_mutex)
     ~ExclusiveLock() { m_mutex.unlock(); }
 
 private: