Home
last modified time | relevance | path

Searched refs:newTaskMutex (Results 1 – 25 of 28) sorted by relevance

12

/dports/net-p2p/namecoin-daemon/namecoin-core-nc0.21.0.1/src/
H A Dscheduler.h73 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 Dscheduler.cpp25 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 Dscheduler.h73 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 Dscheduler.cpp25 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 Dscheduler.h73 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 Dscheduler.cpp25 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 Dscheduler.h75 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 Dscheduler.cpp27 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 Dscheduler.h75 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 Dscheduler.cpp27 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 Dscheduler.h75 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 Dscheduler.cpp27 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 Dscheduler.h90 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 Dscheduler.cpp25 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 Dscheduler.cpp34 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 Dscheduler.cpp34 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 Dscheduler.cpp34 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 Dscheduler.cpp32 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 Dscheduler.h76 mutable boost::mutex newTaskMutex; variable
/dports/net-p2p/zetacoin/zetacoin-0.13.2.1/src/
H A Dscheduler.cpp32 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 Dscheduler.h76 mutable boost::mutex newTaskMutex; variable
/dports/net-p2p/zetacoin-daemon/zetacoin-0.13.2.1/src/
H A Dscheduler.cpp32 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 Dscheduler.h76 mutable boost::mutex newTaskMutex; variable
/dports/net/concourse-fly/concourse-6.7.1/worker/runtime/libcontainerd/libcontainerdfakes/
H A Dfake_container.go107 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 Dfake_container.go107 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 …]

12