Skip to content

Commit 70164cc

Browse files
frankistcodebot
authored andcommitted
support: avoid touching local queue of mpsc concurrent_queue during request for removal
1 parent ac0e7bb commit 70164cc

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

include/srsran/adt/concurrent_queue.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -290,8 +290,6 @@ class queue_impl<T, concurrent_queue_policy::locking_mpsc, BlockingPolicy>
290290
{
291291
std::lock_guard<std::mutex> lock(mutex);
292292
queue.clear();
293-
count_local_objs.store(0, std::memory_order_relaxed);
294-
popped_items.clear();
295293
barrier.request_stop();
296294
}
297295

0 commit comments

Comments
 (0)