Home
last modified time | relevance | path

Searched refs:m_queue_mutex (Results 1 – 25 of 26) sorted by relevance

12

/dports/devel/stxxl/stxxl-1.4.1/lib/io/
H A Drequest_queue_impl_1q.cpp64 scoped_mutex_lock Lock(m_queue_mutex); in add_request()
73 scoped_mutex_lock Lock(m_queue_mutex); in add_request()
90 scoped_mutex_lock Lock(m_queue_mutex); in cancel_request()
120 scoped_mutex_lock Lock(pthis->m_queue_mutex); in worker()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/client/dump/
H A Dobject_queue.cc50 my_boost::mutex::scoped_lock lock(m_queue_mutex); in task_availability_callback()
74 my_boost::mutex::scoped_lock lock(m_queue_mutex); in queue_thread()
119 my_boost::mutex::scoped_lock lock(m_queue_mutex); in read_object()
169 my_boost::mutex::scoped_lock lock(m_queue_mutex); in stop_queue()
H A Dobject_queue.h75 my_boost::mutex m_queue_mutex; variable
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/client/dump/
H A Dobject_queue.cc50 my_boost::mutex::scoped_lock lock(m_queue_mutex); in task_availability_callback()
74 my_boost::mutex::scoped_lock lock(m_queue_mutex); in queue_thread()
119 my_boost::mutex::scoped_lock lock(m_queue_mutex); in read_object()
169 my_boost::mutex::scoped_lock lock(m_queue_mutex); in stop_queue()
H A Dobject_queue.h75 my_boost::mutex m_queue_mutex; variable
/dports/databases/percona57-server/percona-server-5.7.36-39/client/dump/
H A Dobject_queue.cc50 my_boost::mutex::scoped_lock lock(m_queue_mutex); in task_availability_callback()
74 my_boost::mutex::scoped_lock lock(m_queue_mutex); in queue_thread()
119 my_boost::mutex::scoped_lock lock(m_queue_mutex); in read_object()
169 my_boost::mutex::scoped_lock lock(m_queue_mutex); in stop_queue()
H A Dobject_queue.h75 my_boost::mutex m_queue_mutex; variable
/dports/databases/percona57-client/percona-server-5.7.36-39/client/dump/
H A Dobject_queue.cc50 my_boost::mutex::scoped_lock lock(m_queue_mutex); in task_availability_callback()
74 my_boost::mutex::scoped_lock lock(m_queue_mutex); in queue_thread()
119 my_boost::mutex::scoped_lock lock(m_queue_mutex); in read_object()
169 my_boost::mutex::scoped_lock lock(m_queue_mutex); in stop_queue()
H A Dobject_queue.h75 my_boost::mutex m_queue_mutex; variable
/dports/databases/mysql57-client/mysql-5.7.36/client/dump/
H A Dobject_queue.cc50 my_boost::mutex::scoped_lock lock(m_queue_mutex); in task_availability_callback()
74 my_boost::mutex::scoped_lock lock(m_queue_mutex); in queue_thread()
119 my_boost::mutex::scoped_lock lock(m_queue_mutex); in read_object()
169 my_boost::mutex::scoped_lock lock(m_queue_mutex); in stop_queue()
H A Dobject_queue.h75 my_boost::mutex m_queue_mutex; variable
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/client/dump/
H A Dobject_queue.cc50 my_boost::mutex::scoped_lock lock(m_queue_mutex); in task_availability_callback()
74 my_boost::mutex::scoped_lock lock(m_queue_mutex); in queue_thread()
119 my_boost::mutex::scoped_lock lock(m_queue_mutex); in read_object()
H A Dobject_queue.h75 my_boost::mutex m_queue_mutex; variable
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/client/dump/
H A Dobject_queue.cc49 std::lock_guard<std::mutex> lock(m_queue_mutex); in task_availability_callback()
68 std::lock_guard<std::mutex> lock(m_queue_mutex); in queue_thread()
105 std::lock_guard<std::mutex> lock(m_queue_mutex); in read_object()
H A Dobject_queue.h92 std::mutex m_queue_mutex; variable
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/x/src/mq/
H A Dnotice_output_queue.cc58 MUTEX_LOCK(locker, m_queue_mutex); in emplace()
65 MUTEX_LOCK(locker, m_queue_mutex); in encode_queued_items()
H A Dnotice_output_queue.h70 Mutex m_queue_mutex{KEY_mutex_x_notice_output_queue};
/dports/net/astron/Astron-c8ba982/src/util/
H A DTaskQueue.cpp27 std::lock_guard<std::mutex> lock(m_queue_mutex); in enqueue_task()
52 std::lock_guard<std::mutex> lock(m_queue_mutex); in flush_tasks()
H A DTaskQueue.h14 std::mutex m_queue_mutex;
/dports/devel/stxxl/stxxl-1.4.1/include/stxxl/bits/io/
H A Drequest_queue_impl_1q.h36 mutex m_queue_mutex; variable
/dports/games/minetest/minetest-5.4.1/src/
H A Demerge.cpp332 MutexAutoLock queuelock(m_queue_mutex); in enqueueBlockEmergeEx()
528 MutexAutoLock queuelock(m_emerge->m_queue_mutex); in cancelPendingItems()
561 MutexAutoLock queuelock(m_emerge->m_queue_mutex); in popBlockEmerge()
H A Demerge.h189 std::mutex m_queue_mutex; variable
/dports/games/minetest/minetest-5.4.1/src/client/
H A Dminimap.h109 std::mutex m_queue_mutex;
/dports/www/domoticz/domoticz-2020.2/hardware/
H A DPiFace.h182 std::mutex m_queue_mutex; variable
H A DPiFace.cpp663 std::lock_guard<std::mutex> l(m_queue_mutex); in CallBackSendEvent()
875 m_queue_mutex.lock(); in Do_Work_Queue()
879 m_queue_mutex.unlock(); in Do_Work_Queue()

12