From 01345c60e71f818b6f513e801d010169d5a402d7 Mon Sep 17 00:00:00 2001 From: Richard Fuchs Date: Mon, 7 Jul 2025 11:51:50 -0400 Subject: [PATCH] MT#63171 AmSessionProcessor: use lock guard Change-Id: I7efd07029a326d58784d45db2de2b2fab3770f79 --- core/AmSessionProcessor.cpp | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/core/AmSessionProcessor.cpp b/core/AmSessionProcessor.cpp index 98eb49ad..bff81f01 100644 --- a/core/AmSessionProcessor.cpp +++ b/core/AmSessionProcessor.cpp @@ -42,10 +42,9 @@ vector::iterator AmSessionProcessor::threads_it = AmSessionProcessor::threads.begin(); AmSessionProcessorThread* AmSessionProcessor::getProcessorThread() { - threads_mut.lock(); + std::lock_guard _l(threads_mut); if (!threads.size()) { ERROR("requesting Session processing thread but none available\n"); - threads_mut.unlock(); return NULL; } @@ -55,20 +54,18 @@ AmSessionProcessorThread* AmSessionProcessor::getProcessorThread() { AmSessionProcessorThread* res = *threads_it; threads_it++; - threads_mut.unlock(); return res; } void AmSessionProcessor::addThreads(unsigned int num_threads) { DBG("starting %u session processor threads\n", num_threads); - threads_mut.lock(); + std::lock_guard _l(threads_mut); for (unsigned int i=0; i < num_threads;i++) { threads.push_back(new AmSessionProcessorThread()); threads.back()->start(); } threads_it = threads.begin(); DBG("now %zd session processor threads running\n", threads.size()); - threads_mut.unlock(); }