[core] Added missing thread watchdog ticks in 3 thread loop (#2669).

jeandube · web-flow · commit f57ba8912f7b · 2023-02-16T11:14:01.000+01:00
diff --git a/srtcore/core.cpp b/srtcore/core.cpp
@@ -5290,6 +5290,8 @@ void * srt::CUDT::tsbpd(void* param)
         bool shall_update_group = false;
 #endif
 
+        INCREMENT_THREAD_ITERATIONS();
+
         enterCS(self->m_RcvBufferLock);
         const steady_clock::time_point tnow = steady_clock::now();
 
diff --git a/srtcore/queue.cpp b/srtcore/queue.cpp
@@ -523,6 +523,8 @@ void* srt::CSndQueue::worker(void* param)
     {
         const steady_clock::time_point next_time = self->m_pSndUList->getNextProcTime();
 
+        INCREMENT_THREAD_ITERATIONS();
+
         IF_DEBUG_HIGHRATE(self->m_WorkerStats.lIteration++);
 
         if (is_zero(next_time))
@@ -1219,6 +1221,8 @@ void* srt::CRcvQueue::worker(void* param)
     {
         bool        have_received = false;
         EReadStatus rst           = self->worker_RetrieveUnit((id), (unit), (sa));
+
+        INCREMENT_THREAD_ITERATIONS();
         if (rst == RST_OK)
         {
             if (id < 0)

Original file line number	Diff line number	Diff line change
`@@ -523,6 +523,8 @@ void* srt::CSndQueue::worker(void* param)`
`523`	`523`	`{`
`524`	`524`	`const steady_clock::time_point next_time = self->m_pSndUList->getNextProcTime();`
`525`	`525`
	`526`	`+ INCREMENT_THREAD_ITERATIONS();`
	`527`	`+`
`526`	`528`	`IF_DEBUG_HIGHRATE(self->m_WorkerStats.lIteration++);`
`527`	`529`
`528`	`530`	`if (is_zero(next_time))`
`@@ -1219,6 +1221,8 @@ void* srt::CRcvQueue::worker(void* param)`
`1219`	`1221`	`{`
`1220`	`1222`	`bool have_received = false;`
`1221`	`1223`	`EReadStatus rst = self->worker_RetrieveUnit((id), (unit), (sa));`
	`1224`	`+`
	`1225`	`+ INCREMENT_THREAD_ITERATIONS();`
`1222`	`1226`	`if (rst == RST_OK)`
`1223`	`1227`	`{`
`1224`	`1228`	`if (id < 0)`