| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/ |
| H A D | ForEach.cs | 17 private int _stopped; field in System.Reactive.Linq.ObservableImpl.ForEach._
24 _stopped = 0; in _()
34 if (_stopped == 0) in OnNext()
49 if (Interlocked.Exchange(ref _stopped, 1) == 0) in OnError()
58 if (Interlocked.Exchange(ref _stopped, 1) == 0) in OnCompleted()
72 private int _stopped; field in System.Reactive.Linq.ObservableImpl.ForEach.ForEachImpl
80 _stopped = 0; in ForEachImpl()
90 if (_stopped == 0) in OnNext()
105 if (Interlocked.Exchange(ref _stopped, 1) == 0) in OnError()
114 if (Interlocked.Exchange(ref _stopped, 1) == 0) in OnCompleted()
|
| /dports/math/gecode/gecode-0916a1a/gecode/search/ |
| H A D | worker.hh | 47 bool _stopped; member in Gecode::Search::Worker
71 : _stopped(false), root_depth(0) {} in Worker()
75 _stopped = false; in start()
82 _stopped |= o.stop->stop(*this,o); in stop()
83 return _stopped; in stop()
88 return _stopped; in stopped()
|
| /dports/devel/poco/poco-1.10.1-all/Net/src/ |
| H A D | TCPServer.cpp | 49 _stopped(true) in TCPServer()
65 _stopped(true) in TCPServer()
81 _stopped(true) in TCPServer()
108 poco_assert (_stopped); in start()
110 _stopped = false; in start()
117 if (!_stopped) in stop()
119 _stopped = true; in stop()
128 while (!_stopped) in run()
220 poco_assert (_stopped); in setConnectionFilter()
|
| /dports/deskutils/coolreader/coolreader-cr3.2.55/crengine/include/ |
| H A D | lvthread.h | 30 bool _stopped; variable
35 thread->_stopped = true; in start_routine()
49 return _stopped; in stopped()
60 : _valid(false), _stopped(false) in LVThread()
110 bool _stopped; variable
119 thread->_stopped = true; in start_routine()
133 return _stopped; in stopped()
143 : _stopped(false) in LVThread()
|
| /dports/net/sems/sems-f89581a/core/ |
| H A D | AmThread.cpp | 66 : _stopped(true) in AmThread()
78 _this->_stopped.set(true); in _start()
94 this->_stopped.lock(); in start()
95 if(!(this->_stopped.unsafe_get())){ in start()
96 this->_stopped.unlock(); in start()
100 this->_stopped.unsafe_set(false); in start()
101 this->_stopped.unlock(); in start()
153 _stopped.set(true); in cancel()
|
| /dports/deskutils/coolreader/coolreader-cr3.2.55/crengine/src/ |
| H A D | crconcurrent.cpp | 35 CRThreadExecutor::CRThreadExecutor() : _stopped(false) { in CRThreadExecutor()
42 if (!_stopped) in ~CRThreadExecutor()
49 if (_stopped) in run()
57 if (_stopped) in run()
73 if (_stopped) { in execute()
85 _stopped = true; in stop()
|
| /dports/multimedia/quodlibet/quodlibet-4.3.0/quodlibet/util/ |
| H A D | winpipe.py | 73 self._stopped = False
81 if not self._stopped:
91 if self._stopped:
116 self._stopped = True
149 if self._stopped:
163 if self._stopped:
166 self._stopped = True
|
| /dports/databases/pymongo/pymongo-3.12.0/pymongo/ |
| H A D | periodic_executor.py | 45 self._stopped = False
74 self._stopped = False
95 self._stopped = True
117 if self._stopped:
126 self._stopped = True
130 self._stopped = True
139 while not self._stopped and _time() < deadline:
|
| /dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/src/Internal/Runtime/Augments/ |
| H A D | RuntimeThread.Unix.cs | 17 private ManualResetEvent _stopped; field in Internal.Runtime.Augments.RuntimeThread
31 _stopped = new ManualResetEvent(false); in PlatformSpecificInitializeExistingThread()
80 currentThread._stopped.Set(); in OnThreadExit()
90 SafeWaitHandle waitHandle = _stopped.SafeWaitHandle; in JoinInternal()
110 return _stopped.WaitOne(millisecondsTimeout); in JoinInternal()
123 _stopped = new ManualResetEvent(false); in CreateThread()
|
| /dports/devel/poco/poco-1.10.1-all/Foundation/include/Poco/ |
| H A D | Activity.h | 83 _stopped(true), in Activity()
120 _stopped = false; in start()
137 _stopped = true; in stop()
163 return _stopped; in isStopped()
196 std::atomic<bool> _stopped; variable
|
| /dports/devel/grpc134/grpc-1.34.1/src/python/grpcio_tests/tests_aio/benchmark/ |
| H A D | benchmark_client.py | 106 self._stopped = asyncio.Event()
122 self._stopped.set()
126 await self._stopped.wait()
136 self._stopped = asyncio.Event()
152 self._stopped.set()
156 await self._stopped.wait()
166 self._stopped = asyncio.Event()
181 self._stopped.set()
185 await self._stopped.wait()
|
| /dports/devel/grpc/grpc-1.42.0/src/python/grpcio_tests/tests_aio/benchmark/ |
| H A D | benchmark_client.py | 107 self._stopped = asyncio.Event()
123 self._stopped.set()
127 await self._stopped.wait()
137 self._stopped = asyncio.Event()
153 self._stopped.set()
157 await self._stopped.wait()
167 self._stopped = asyncio.Event()
182 self._stopped.set()
186 await self._stopped.wait()
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/hotspot/share/gc/z/ |
| H A D | zMetronome.cpp | 35 _stopped(false) {} in ZMetronome()
57 if (!_stopped && timeout_ms > 0) { in wait_for_tick()
62 return !_stopped; in wait_for_tick()
69 _stopped = true; in stop()
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/hotspot/share/gc/z/ |
| H A D | zMetronome.cpp | 35 _stopped(false) {} in ZMetronome()
57 if (!_stopped && timeout_ms > 0) { in wait_for_tick()
62 return !_stopped; in wait_for_tick()
69 _stopped = true; in stop()
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/hotspot/share/gc/z/ |
| H A D | zMetronome.cpp | 35 _stopped(false) {} in ZMetronome()
57 if (!_stopped && timeout_ms > 0) { in wait_for_tick()
62 return !_stopped; in wait_for_tick()
69 _stopped = true; in stop()
|
| /dports/devel/poco/poco-1.10.1-all/XML/src/ |
| H A D | Event.cpp | 32 _stopped(false) in Event()
46 _stopped(false) in Event()
58 _stopped = true; in stopPropagation()
74 _stopped = false; in initEvent()
|
| /dports/devel/py-pyformance/pyformance-0.4/pyformance/reporters/ |
| H A D | reporter.py | 17 self._stopped = Event()
21 if self._stopped.is_set():
36 self._stopped.set()
39 while not self._stopped.is_set():
|
| /dports/net-mgmt/p5-FusionInventory-Agent/FusionInventory-Agent-2.5.2/lib/FusionInventory/Agent/Task/Deploy/ |
| H A D | UserCheck.pm | 40 _stopped => 0,
228 $self->{_stopped} = 0 ;
234 $self->{_stopped} = 1 ;
241 $self->{_stopped} = $param !~ /^0|no$/ ;
244 } elsif ($self->{_stopped}) {
267 return $self->{_stopped};
|
| /dports/devel/py-kazoo/kazoo-2.5.0/kazoo/recipe/ |
| H A D | watchers.py | 110 self._stopped = False
166 self._stopped = True
178 if self._stopped:
277 self._stopped = False
317 if self._stopped:
324 self._stopped = True
342 self._stopped = True
356 not self._watch_established and not self._stopped):
|
| /dports/devel/poco/poco-1.10.1-all/Foundation/src/ |
| H A D | DirectoryWatcher.cpp | 260 _stopped(false) in LinuxDirectoryWatcherStrategy()
298 while (!_stopped) in run()
365 _stopped = true; in stop()
375 bool _stopped; member in Poco::LinuxDirectoryWatcherStrategy
389 _stopped(false) in BSDDirectoryWatcherStrategy()
413 while (!_stopped) in run()
447 _stopped = true; in stop()
458 bool _stopped; member in Poco::BSDDirectoryWatcherStrategy
481 while (!_stopped.tryWait(1000*owner().scanInterval())) in run()
499 _stopped.set(); in stop()
[all …]
|
| /dports/multimedia/zoneminder/zoneminder-1.36.5/web/api/lib/Cake/Event/ |
| H A D | CakeEvent.php | 59 protected $_stopped = false; variable in CakeEvent
117 return $this->_stopped = true;
126 return $this->_stopped;
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Ix/NET/System.Interactive/ |
| H A D | EnumerableEx.Buffering.cs | 180 private bool _stopped; field in System.Linq.EnumerableEx.PublishedBuffer
221 if (!_stopped) in GetEnumerator_()
231 _stopped = true; in GetEnumerator_()
238 if (_stopped) in GetEnumerator_()
391 private bool _stopped; field in System.Linq.EnumerableEx.MemoizedBuffer
437 if (!_stopped) in GetEnumerator_()
447 _stopped = true; in GetEnumerator_()
454 if (_stopped) in GetEnumerator_()
|
| /dports/devel/grpc130/grpc-1.30.2/src/python/grpcio_tests/tests_aio/benchmark/ |
| H A D | benchmark_client.py | 104 self._stopped = asyncio.Event()
120 self._stopped.set()
124 await self._stopped.wait()
134 self._stopped = asyncio.Event()
150 self._stopped.set()
154 await self._stopped.wait()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Data.Entity/System/Data/Common/CommandTrees/Internal/ |
| H A D | DbExpressionRules.cs | 108 private bool _stopped; field in System.Data.Common.CommandTrees.Internal.DbExpressionRuleProcessingVisitor
124 _stopped = true; in ApplyRules()
133 if (_stopped) in VisitExpression()
141 if (_stopped) in VisitExpression()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/executor/ |
| H A D | async_stream_test.cpp | 67 _stopped.get(); in startup()
79 _stopped.emplace(true); in shutdown()
92 if (!_stopped.hasCompleted()) { in ~Server()
100 executor::Deferred<bool> _stopped; member in mongo::__anon007c5bcf0111::Server
|