/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
|