/dports/net-p2p/namecoin-daemon/namecoin-core-nc0.21.0.1/src/ |
H A D | scheduler.h | 73 WITH_LOCK(newTaskMutex, stopRequested = true); in stop() 79 WITH_LOCK(newTaskMutex, stopWhenEmpty = true); in StopWhenDrained() 94 mutable Mutex newTaskMutex; 96 … std::multimap<std::chrono::system_clock::time_point, Function> taskQueue GUARDED_BY(newTaskMutex); 97 int nThreadsServicingQueue GUARDED_BY(newTaskMutex){0}; in GUARDED_BY() argument 98 bool stopRequested GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 99 bool stopWhenEmpty GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 100 …bool shouldStop() const EXCLUSIVE_LOCKS_REQUIRED(newTaskMutex) { return stopRequested || (stopWhen… in shouldStop()
|
H A D | scheduler.cpp | 25 WAIT_LOCK(newTaskMutex, lock); in serviceQueue() 74 LOCK(newTaskMutex); in schedule() 85 LOCK(newTaskMutex); in MockForward() 116 LOCK(newTaskMutex); in getQueueInfo() 127 LOCK(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/namecoin/namecoin-core-nc0.21.0.1/src/ |
H A D | scheduler.h | 73 WITH_LOCK(newTaskMutex, stopRequested = true); in stop() 79 WITH_LOCK(newTaskMutex, stopWhenEmpty = true); in StopWhenDrained() 94 mutable Mutex newTaskMutex; 96 … std::multimap<std::chrono::system_clock::time_point, Function> taskQueue GUARDED_BY(newTaskMutex); 97 int nThreadsServicingQueue GUARDED_BY(newTaskMutex){0}; in GUARDED_BY() argument 98 bool stopRequested GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 99 bool stopWhenEmpty GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 100 …bool shouldStop() const EXCLUSIVE_LOCKS_REQUIRED(newTaskMutex) { return stopRequested || (stopWhen… in shouldStop()
|
H A D | scheduler.cpp | 25 WAIT_LOCK(newTaskMutex, lock); in serviceQueue() 74 LOCK(newTaskMutex); in schedule() 85 LOCK(newTaskMutex); in MockForward() 116 LOCK(newTaskMutex); in getQueueInfo() 127 LOCK(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/namecoin-utils/namecoin-core-nc0.21.0.1/src/ |
H A D | scheduler.h | 73 WITH_LOCK(newTaskMutex, stopRequested = true); in stop() 79 WITH_LOCK(newTaskMutex, stopWhenEmpty = true); in StopWhenDrained() 94 mutable Mutex newTaskMutex; 96 … std::multimap<std::chrono::system_clock::time_point, Function> taskQueue GUARDED_BY(newTaskMutex); 97 int nThreadsServicingQueue GUARDED_BY(newTaskMutex){0}; in GUARDED_BY() argument 98 bool stopRequested GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 99 bool stopWhenEmpty GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 100 …bool shouldStop() const EXCLUSIVE_LOCKS_REQUIRED(newTaskMutex) { return stopRequested || (stopWhen… in shouldStop()
|
H A D | scheduler.cpp | 25 WAIT_LOCK(newTaskMutex, lock); in serviceQueue() 74 LOCK(newTaskMutex); in schedule() 85 LOCK(newTaskMutex); in MockForward() 116 LOCK(newTaskMutex); in getQueueInfo() 127 LOCK(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/bitcoin-utils/bitcoin-22.0/src/ |
H A D | scheduler.h | 75 WITH_LOCK(newTaskMutex, stopRequested = true); in stop() 82 WITH_LOCK(newTaskMutex, stopWhenEmpty = true); in StopWhenDrained() 98 mutable Mutex newTaskMutex; 100 … std::multimap<std::chrono::system_clock::time_point, Function> taskQueue GUARDED_BY(newTaskMutex); 101 int nThreadsServicingQueue GUARDED_BY(newTaskMutex){0}; in GUARDED_BY() argument 102 bool stopRequested GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 103 bool stopWhenEmpty GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 104 …bool shouldStop() const EXCLUSIVE_LOCKS_REQUIRED(newTaskMutex) { return stopRequested || (stopWhen… in shouldStop()
|
H A D | scheduler.cpp | 27 WAIT_LOCK(newTaskMutex, lock); in serviceQueue() 76 LOCK(newTaskMutex); in schedule() 87 LOCK(newTaskMutex); in MockForward() 118 LOCK(newTaskMutex); in getQueueInfo() 129 LOCK(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/bitcoin-daemon/bitcoin-22.0/src/ |
H A D | scheduler.h | 75 WITH_LOCK(newTaskMutex, stopRequested = true); in stop() 82 WITH_LOCK(newTaskMutex, stopWhenEmpty = true); in StopWhenDrained() 98 mutable Mutex newTaskMutex; 100 … std::multimap<std::chrono::system_clock::time_point, Function> taskQueue GUARDED_BY(newTaskMutex); 101 int nThreadsServicingQueue GUARDED_BY(newTaskMutex){0}; in GUARDED_BY() argument 102 bool stopRequested GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 103 bool stopWhenEmpty GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 104 …bool shouldStop() const EXCLUSIVE_LOCKS_REQUIRED(newTaskMutex) { return stopRequested || (stopWhen… in shouldStop()
|
H A D | scheduler.cpp | 27 WAIT_LOCK(newTaskMutex, lock); in serviceQueue() 76 LOCK(newTaskMutex); in schedule() 87 LOCK(newTaskMutex); in MockForward() 118 LOCK(newTaskMutex); in getQueueInfo() 129 LOCK(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/bitcoin/bitcoin-22.0/src/ |
H A D | scheduler.h | 75 WITH_LOCK(newTaskMutex, stopRequested = true); 82 WITH_LOCK(newTaskMutex, stopWhenEmpty = true); in convert_schedule_to_repltimes() 98 mutable Mutex newTaskMutex; 100 … std::multimap<std::chrono::system_clock::time_point, Function> taskQueue GUARDED_BY(newTaskMutex); 101 int nThreadsServicingQueue GUARDED_BY(newTaskMutex){0}; 102 bool stopRequested GUARDED_BY(newTaskMutex){false}; 103 bool stopWhenEmpty GUARDED_BY(newTaskMutex){false}; 104 …bool shouldStop() const EXCLUSIVE_LOCKS_REQUIRED(newTaskMutex) { return stopRequested || (stopWhen…
|
H A D | scheduler.cpp | 27 WAIT_LOCK(newTaskMutex, lock); in serviceQueue() 76 LOCK(newTaskMutex); in schedule() 87 LOCK(newTaskMutex); in MockForward() 118 LOCK(newTaskMutex); in getQueueInfo() 129 LOCK(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/qtum/qtum-mainnet-fastlane-v0.20.3/src/ |
H A D | scheduler.h | 90 mutable Mutex newTaskMutex; 92 … std::multimap<std::chrono::system_clock::time_point, Function> taskQueue GUARDED_BY(newTaskMutex); 93 int nThreadsServicingQueue GUARDED_BY(newTaskMutex){0}; in GUARDED_BY() argument 94 bool stopRequested GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 95 bool stopWhenEmpty GUARDED_BY(newTaskMutex){false}; in GUARDED_BY() argument 96 …bool shouldStop() const EXCLUSIVE_LOCKS_REQUIRED(newTaskMutex) { return stopRequested || (stopWhen… in shouldStop()
|
H A D | scheduler.cpp | 25 WAIT_LOCK(newTaskMutex, lock); in serviceQueue() 77 LOCK(newTaskMutex); in stop() 89 LOCK(newTaskMutex); in schedule() 100 LOCK(newTaskMutex); in MockForward() 131 LOCK(newTaskMutex); in getQueueInfo() 141 LOCK(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/litecoin-daemon/litecoin-0.18.1/src/ |
H A D | scheduler.cpp | 34 boost::unique_lock<boost::mutex> lock(newTaskMutex); in serviceQueue() 96 boost::unique_lock<boost::mutex> lock(newTaskMutex); in stop() 108 boost::unique_lock<boost::mutex> lock(newTaskMutex); in schedule() 133 boost::unique_lock<boost::mutex> lock(newTaskMutex); in getQueueInfo() 143 boost::unique_lock<boost::mutex> lock(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/litecoin/litecoin-0.18.1/src/ |
H A D | scheduler.cpp | 34 boost::unique_lock<boost::mutex> lock(newTaskMutex); in serviceQueue() 96 boost::unique_lock<boost::mutex> lock(newTaskMutex); in stop() 108 boost::unique_lock<boost::mutex> lock(newTaskMutex); in schedule() 133 boost::unique_lock<boost::mutex> lock(newTaskMutex); in getQueueInfo() 143 boost::unique_lock<boost::mutex> lock(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/litecoin-utils/litecoin-0.18.1/src/ |
H A D | scheduler.cpp | 34 boost::unique_lock<boost::mutex> lock(newTaskMutex); in serviceQueue() 96 boost::unique_lock<boost::mutex> lock(newTaskMutex); in stop() 108 boost::unique_lock<boost::mutex> lock(newTaskMutex); in schedule() 133 boost::unique_lock<boost::mutex> lock(newTaskMutex); in getQueueInfo() 143 boost::unique_lock<boost::mutex> lock(newTaskMutex); in AreThreadsServicingQueue()
|
/dports/net-p2p/zetacoin-utils/zetacoin-0.13.2.1/src/ |
H A D | scheduler.cpp | 32 boost::unique_lock<boost::mutex> lock(newTaskMutex); in serviceQueue() 89 boost::unique_lock<boost::mutex> lock(newTaskMutex); in stop() 101 boost::unique_lock<boost::mutex> lock(newTaskMutex); in schedule() 126 boost::unique_lock<boost::mutex> lock(newTaskMutex); in getQueueInfo()
|
H A D | scheduler.h | 76 mutable boost::mutex newTaskMutex; variable
|
/dports/net-p2p/zetacoin/zetacoin-0.13.2.1/src/ |
H A D | scheduler.cpp | 32 boost::unique_lock<boost::mutex> lock(newTaskMutex); in serviceQueue() 89 boost::unique_lock<boost::mutex> lock(newTaskMutex); in stop() 101 boost::unique_lock<boost::mutex> lock(newTaskMutex); in schedule() 126 boost::unique_lock<boost::mutex> lock(newTaskMutex); in getQueueInfo()
|
H A D | scheduler.h | 76 mutable boost::mutex newTaskMutex; variable
|
/dports/net-p2p/zetacoin-daemon/zetacoin-0.13.2.1/src/ |
H A D | scheduler.cpp | 32 boost::unique_lock<boost::mutex> lock(newTaskMutex); in serviceQueue() 89 boost::unique_lock<boost::mutex> lock(newTaskMutex); in stop() 101 boost::unique_lock<boost::mutex> lock(newTaskMutex); in schedule() 126 boost::unique_lock<boost::mutex> lock(newTaskMutex); in getQueueInfo()
|
H A D | scheduler.h | 76 mutable boost::mutex newTaskMutex; variable
|
/dports/net/concourse-fly/concourse-6.7.1/worker/runtime/libcontainerd/libcontainerdfakes/ |
H A D | fake_container.go | 107 newTaskMutex sync.RWMutex member 610 fake.newTaskMutex.Lock() 618 fake.newTaskMutex.Unlock() 630 fake.newTaskMutex.RLock() 636 fake.newTaskMutex.Lock() 637 defer fake.newTaskMutex.Unlock() 642 fake.newTaskMutex.RLock() 649 fake.newTaskMutex.Lock() 650 defer fake.newTaskMutex.Unlock() 659 fake.newTaskMutex.Lock() [all …]
|
/dports/misc/concourse/concourse-6.7.2/worker/runtime/libcontainerd/libcontainerdfakes/ |
H A D | fake_container.go | 107 newTaskMutex sync.RWMutex member 610 fake.newTaskMutex.Lock() 618 fake.newTaskMutex.Unlock() 630 fake.newTaskMutex.RLock() 636 fake.newTaskMutex.Lock() 637 defer fake.newTaskMutex.Unlock() 642 fake.newTaskMutex.RLock() 649 fake.newTaskMutex.Lock() 650 defer fake.newTaskMutex.Unlock() 659 fake.newTaskMutex.Lock() [all …]
|