[core] Made CSndQueue::m_counter atomic.

maxsharabayko · maxsharabayko · commit b8a2822dc87f · 2024-08-08T12:21:54.000+02:00
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:

Original file line number	Diff line number	Diff line change
`@@ -444,7 +444,7 @@ int srt::CSndQueue::sockoptQuery(int level, int type) const`
`444`	`444`	`}`
`445`	`445`
`446`	`446`	`#if ENABLE_LOGGING`
`447`		`-int srt::CSndQueue::m_counter = 0;`
	`447`	`+srt::sync::atomic<int> srt::CSndQueue::m_counter(0);`
`448`	`448`	`#endif`
`449`	`449`
`450`	`450`	`void srt::CSndQueue::init(CChannel* c, CTimer* t)`
Original file line number	Diff line number	Diff line change
`@@ -540,7 +540,7 @@ class SRT_ATTR_SCOPED_CAPABILITY ExclusiveLock`
`540`	`540`	`m_mutex.lock();`
`541`	`541`	`}`
`542`	`542`
`543`		`- SRT_ATTR_RELEASE()`
	`543`	`+ SRT_ATTR_RELEASE(m_mutex)`
`544`	`544`	`~ExclusiveLock() { m_mutex.unlock(); }`
`545`	`545`
`546`	`546`	`private:`