| /dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/src/System/Threading/ |
| H A D | WaitHandle.cs | 100 public virtual bool WaitOne(int millisecondsTimeout) in WaitOne() argument
102 if (millisecondsTimeout < -1) in WaitOne()
107 return WaitOneCore(millisecondsTimeout); in WaitOne()
112 Debug.Assert(millisecondsTimeout >= -1); in WaitOneCore()
137 …public virtual bool WaitOne(int millisecondsTimeout, bool exitContext) => WaitOne(millisecondsTime… in WaitOne() argument
232 if (-1 > millisecondsTimeout) in WaitAll()
264 WaitAll(waitHandles, millisecondsTimeout); in WaitAll()
291 if (-1 > millisecondsTimeout) in WaitAny()
323 WaitAny(waitHandles, millisecondsTimeout); in WaitAny()
343 if (-1 > millisecondsTimeout) in SignalAndWait()
[all …]
|
| H A D | WaitHandle.Windows.cs | 25 return context.Wait(handles, false, millisecondsTimeout); in WaitForSingleObject()
42 Debug.Assert(millisecondsTimeout >= -1); in WaitForMultipleObjectsIgnoringSyncContext()
102 Debug.Assert(millisecondsTimeout >= -1); in WaitOneCore()
104 int ret = WaitForSingleObject(handle, millisecondsTimeout, interruptible); in WaitOneCore()
124 int millisecondsTimeout, in WaitMultiple() argument
146 return context.Wait(handles, waitAll, millisecondsTimeout); in WaitMultiple()
165 int millisecondsTimeout) in WaitAnyCore() argument
173 Debug.Assert(millisecondsTimeout >= -1); in WaitAnyCore()
197 int millisecondsTimeout) in WaitAllCore() argument
202 Debug.Assert(millisecondsTimeout >= -1); in WaitAllCore()
[all …]
|
| H A D | SemaphoreSlim.cs | 287 public bool Wait(int millisecondsTimeout) in Wait() argument
310 if (millisecondsTimeout < -1) in Wait()
313 … nameof(millisecondsTimeout), millisecondsTimeout, SR.SemaphoreSlim_Wait_TimeoutWrong); in Wait()
319 if (millisecondsTimeout == 0 && m_currentCount == 0) in Wait()
326 if (millisecondsTimeout != Timeout.Infinite && millisecondsTimeout > 0) in Wait()
381 if (millisecondsTimeout == 0) in Wait()
459 if (millisecondsTimeout != Timeout.Infinite) in WaitUntilCountOrTimeout()
519 public Task<bool> WaitAsync(int millisecondsTimeout) in WaitAsync() argument
605 if (millisecondsTimeout < -1) in WaitAsync()
608 … nameof(millisecondsTimeout), millisecondsTimeout, SR.SemaphoreSlim_Wait_TimeoutWrong); in WaitAsync()
[all …]
|
| H A D | SpinLock.cs | 270 public void TryEnter(int millisecondsTimeout, ref bool lockTaken) in TryEnter()
273 if (millisecondsTimeout < -1 || //invalid parameter in TryEnter()
287 private void ContinueTryEnter(int millisecondsTimeout, ref bool lockTaken) in ContinueTryEnter()
296 if (millisecondsTimeout < -1) in ContinueTryEnter()
299 … nameof(millisecondsTimeout), millisecondsTimeout, SR.SpinLock_TryEnter_ArgumentOutOfRange); in ContinueTryEnter()
303 if (millisecondsTimeout != Timeout.Infinite && millisecondsTimeout != 0) in ContinueTryEnter()
344 if (millisecondsTimeout == 0) in ContinueTryEnter()
350 else if (millisecondsTimeout == 0) in ContinueTryEnter()
388 …if (millisecondsTimeout != Timeout.Infinite && TimeoutHelper.UpdateTimeOut(startTime, milliseconds… in ContinueTryEnter()
430 …if (millisecondsTimeout != Timeout.Infinite && TimeoutHelper.UpdateTimeOut(startTime, milliseconds… in ContinueTryEnter()
[all …]
|
| H A D | Monitor.cs | 97 public static bool TryEnter(Object obj, int millisecondsTimeout) in TryEnter() argument
99 if (millisecondsTimeout < -1) in TryEnter()
105 return TryAcquireContended(lck, obj, millisecondsTimeout); in TryEnter()
108 public static void TryEnter(Object obj, int millisecondsTimeout, ref bool lockTaken) in TryEnter() argument
112 if (millisecondsTimeout < -1) in TryEnter()
121 lockTaken = TryAcquireContended(lck, obj, millisecondsTimeout); in TryEnter()
145 public static bool Wait(Object obj, int millisecondsTimeout, bool exitContext) => in Wait() argument
146 Wait(obj, millisecondsTimeout); in Wait()
152 public static bool Wait(Object obj, int millisecondsTimeout) in Wait() argument
159 return condition.Wait(millisecondsTimeout); in Wait()
[all …]
|
| H A D | WaitHandle.Unix.cs | 12 … private static bool WaitOneCore(IntPtr handle, int millisecondsTimeout, bool interruptible) => in WaitOneCore() argument
13 WaitSubsystem.Wait(handle, millisecondsTimeout, interruptible); in WaitOneCore()
20 int millisecondsTimeout) in WaitAnyCore() argument
22 …stem.Wait(currentThread, safeWaitHandles, waitHandles, numWaitHandles, false, millisecondsTimeout); in WaitAnyCore()
29 int millisecondsTimeout) in WaitAllCore() argument
31 …entThread, safeWaitHandles, waitHandles, waitHandles.Length, true, millisecondsTimeout) != WaitTim… in WaitAllCore()
34 …tatic bool SignalAndWaitCore(IntPtr handleToSignal, IntPtr handleToWaitOn, int millisecondsTimeout) in SignalAndWaitCore() argument
36 return WaitSubsystem.SignalAndWait(handleToSignal, handleToWaitOn, millisecondsTimeout); in SignalAndWaitCore()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Collections.Concurrent/src/System/Collections/Concurrent/ |
| H A D | BlockingCollection.cs | 351 public bool TryAdd(T item, int millisecondsTimeout) in TryAdd() argument
353 ValidateMillisecondsTimeout(millisecondsTimeout); in TryAdd()
379 ValidateMillisecondsTimeout(millisecondsTimeout); in TryAdd()
630 ValidateMillisecondsTimeout(millisecondsTimeout); in TryTake()
985 int timeout = millisecondsTimeout; in TryAddToAnyCore()
988 if (millisecondsTimeout != Timeout.Infinite) in TryAddToAnyCore()
1046 if (millisecondsTimeout != Timeout.Infinite) in TryAddToAnyCore()
1387 int timeout = millisecondsTimeout; in TryTakeFromAnyCoreSlow()
1390 if (millisecondsTimeout != Timeout.Infinite) in TryTakeFromAnyCoreSlow()
1774 if ((millisecondsTimeout < 0) && (millisecondsTimeout != Timeout.Infinite)) in ValidateMillisecondsTimeout()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/sys/system/collections/concurrent/ |
| H A D | BlockingCollection.cs | 363 public bool TryAdd(T item, int millisecondsTimeout) in TryAdd() argument
365 ValidateMillisecondsTimeout(millisecondsTimeout); in TryAdd()
391 ValidateMillisecondsTimeout(millisecondsTimeout); in TryAdd()
641 ValidateMillisecondsTimeout(millisecondsTimeout); in TryTake()
666 ValidateMillisecondsTimeout(millisecondsTimeout); in TryTake()
996 int timeout = millisecondsTimeout; in TryAddToAnyCore()
999 if (millisecondsTimeout != Timeout.Infinite) in TryAddToAnyCore()
1057 if (millisecondsTimeout != Timeout.Infinite) in TryAddToAnyCore()
1403 int timeout = millisecondsTimeout; in TryTakeFromAnyCoreSlow()
1406 if (millisecondsTimeout != Timeout.Infinite) in TryTakeFromAnyCoreSlow()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/mscorlib/system/threading/ |
| H A D | SemaphoreSlim.cs | 295 public bool Wait(int millisecondsTimeout) in Wait() argument
297 return Wait(millisecondsTimeout, new CancellationToken()); in Wait()
313 public bool Wait(int millisecondsTimeout, CancellationToken cancellationToken) in Wait() argument
318 if (millisecondsTimeout < -1) in Wait()
327 if (millisecondsTimeout != Timeout.Infinite && millisecondsTimeout > 0) in Wait()
369 asyncWaitTask = WaitAsync(millisecondsTimeout, cancellationToken); in Wait()
381 if (millisecondsTimeout == 0) in Wait()
459 if (millisecondsTimeout != Timeout.Infinite) in WaitUntilCountOrTimeout()
519 public Task<bool> WaitAsync(int millisecondsTimeout) in WaitAsync() argument
521 return WaitAsync(millisecondsTimeout, default(CancellationToken)); in WaitAsync()
[all …]
|
| H A D | SpinLock.cs | 260 public void TryEnter(int millisecondsTimeout, ref bool lockTaken) in TryEnter()
267 if (millisecondsTimeout < -1 || //invalid parameter in TryEnter()
281 private void ContinueTryEnter(int millisecondsTimeout, ref bool lockTaken) in ContinueTryEnter()
294 if (millisecondsTimeout < -1) in ContinueTryEnter()
302 if (millisecondsTimeout != Timeout.Infinite && millisecondsTimeout != 0) in ContinueTryEnter()
369 if (millisecondsTimeout == 0 || in ContinueTryEnter()
370 (millisecondsTimeout != Timeout.Infinite && in ContinueTryEnter()
371 TimeoutHelper.UpdateTimeOut(startTime, millisecondsTimeout) <= 0)) in ContinueTryEnter()
420 …if (millisecondsTimeout != Timeout.Infinite && TimeoutHelper.UpdateTimeOut(startTime, milliseconds… in ContinueTryEnter()
479 …if (millisecondsTimeout != Timeout.Infinite && TimeoutHelper.UpdateTimeOut(startTime, milliseconds… in ContinueTryEnter()
[all …]
|
| H A D | waithandle.cs | 199 public virtual bool WaitOne (int millisecondsTimeout, bool exitContext) in WaitOne() argument
201 if (millisecondsTimeout < -1) in WaitOne()
206 return WaitOne((long)millisecondsTimeout,exitContext); in WaitOne()
225 public virtual bool WaitOne(int millisecondsTimeout) in WaitOne() argument
227 return WaitOne(millisecondsTimeout, false); in WaitOne()
344 if (-1 > millisecondsTimeout) in WaitAll()
423 return WaitAll(waitHandles, millisecondsTimeout, true); in WaitAll()
457 if (-1 > millisecondsTimeout) in WaitAny()
537 return WaitAny(waitHandles, millisecondsTimeout, true); in WaitAny()
580 int millisecondsTimeout, in SignalAndWait() argument
[all …]
|
| H A D | SpinWait.cs | 247 public static bool SpinUntil(Func<bool> condition, int millisecondsTimeout) in SpinUntil()
249 if (millisecondsTimeout < Timeout.Infinite) in SpinUntil()
252 …"millisecondsTimeout", millisecondsTimeout, Environment.GetResourceString("SpinWait_SpinUntil_Time… in SpinUntil()
259 if (millisecondsTimeout != 0 && millisecondsTimeout != Timeout.Infinite) in SpinUntil()
266 if (millisecondsTimeout == 0) in SpinUntil()
273 if (millisecondsTimeout != Timeout.Infinite && spinner.NextSpinWillYield) in SpinUntil()
275 if (millisecondsTimeout <= (TimeoutHelper.GetTime() - startTime)) in SpinUntil()
|
| H A D | monitor.cs | 126 public static bool TryEnter(Object obj, int millisecondsTimeout) in TryEnter() argument
129 TryEnter(obj, millisecondsTimeout, ref lockTaken); in TryEnter()
148 public static void TryEnter(Object obj, int millisecondsTimeout, ref bool lockTaken) in TryEnter() argument
153 ReliableEnterTimeout(obj, millisecondsTimeout, ref lockTaken); in TryEnter()
202 private static extern bool ObjWait(bool exitContext, int millisecondsTimeout, Object obj); in ObjWait() argument
206 public static bool Wait(Object obj, int millisecondsTimeout, bool exitContext) in Wait() argument
210 return ObjWait(exitContext, millisecondsTimeout, obj); in Wait()
218 public static bool Wait(Object obj, int millisecondsTimeout) in Wait() argument
220 return Wait(obj, millisecondsTimeout, false); in Wait()
|
| /dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/shared/System/Threading/ |
| H A D | SpinWait.cs | 283 public static bool SpinUntil(Func<bool> condition, int millisecondsTimeout) in SpinUntil()
285 if (millisecondsTimeout < Timeout.Infinite) in SpinUntil()
288 … nameof(millisecondsTimeout), millisecondsTimeout, SR.SpinWait_SpinUntil_TimeoutWrong); in SpinUntil()
295 if (millisecondsTimeout != 0 && millisecondsTimeout != Timeout.Infinite) in SpinUntil()
302 if (millisecondsTimeout == 0) in SpinUntil()
309 if (millisecondsTimeout != Timeout.Infinite && spinner.NextSpinWillYield) in SpinUntil()
311 if (millisecondsTimeout <= (TimeoutHelper.GetTime() - startTime)) in SpinUntil()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/Common/src/CoreLib/System/Threading/ |
| H A D | SpinWait.cs | 283 public static bool SpinUntil(Func<bool> condition, int millisecondsTimeout) in SpinUntil()
285 if (millisecondsTimeout < Timeout.Infinite) in SpinUntil()
288 … nameof(millisecondsTimeout), millisecondsTimeout, SR.SpinWait_SpinUntil_TimeoutWrong); in SpinUntil()
295 if (millisecondsTimeout != 0 && millisecondsTimeout != Timeout.Infinite) in SpinUntil()
302 if (millisecondsTimeout == 0) in SpinUntil()
309 if (millisecondsTimeout != Timeout.Infinite && spinner.NextSpinWillYield) in SpinUntil()
311 if (millisecondsTimeout <= (TimeoutHelper.GetTime() - startTime)) in SpinUntil()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/System.Threading/ |
| H A D | ReaderWriterLock.cs | 85 public void AcquireReaderLock (int millisecondsTimeout) in AcquireReaderLock() argument
87 AcquireReaderLock (millisecondsTimeout, 1); in AcquireReaderLock()
90 void AcquireReaderLock (int millisecondsTimeout, int initialLockCount) in AcquireReaderLock() argument
94 AcquireWriterLock (millisecondsTimeout, initialLockCount); in AcquireReaderLock()
107 if (!Monitor.Wait (this, millisecondsTimeout)) in AcquireReaderLock()
132 public void AcquireWriterLock (int millisecondsTimeout) in AcquireWriterLock() argument
134 AcquireWriterLock (millisecondsTimeout, 1); in AcquireWriterLock()
137 void AcquireWriterLock (int millisecondsTimeout, int initialLockCount) in AcquireWriterLock() argument
149 if (!writer_queue.Wait (millisecondsTimeout)) in AcquireWriterLock()
273 public LockCookie UpgradeToWriterLock(int millisecondsTimeout) in UpgradeToWriterLock() argument
[all …]
|
| H A D | WaitHandle.cs | 50 …static int WaitMultiple(WaitHandle[] waitHandles, int millisecondsTimeout, bool exitContext, bool … in WaitMultiple() argument
79 return Wait_internal(handles, waitHandles.Length, WaitAll, millisecondsTimeout); in WaitMultiple()
93 …static int WaitOneNative (SafeHandle waitableSafeHandle, uint millisecondsTimeout, bool hasThreadA… in WaitOneNative() argument
106 return Wait_internal(&handle, 1, false, (int)millisecondsTimeout); in WaitOneNative()
122 …itHandle waitHandleToSignal,SafeWaitHandle waitHandleToWaitOn, int millisecondsTimeout, bool hasTh… in SignalAndWaitOne() argument
129 …ndleToSignal.DangerousGetHandle (), waitHandleToWaitOn.DangerousGetHandle (), millisecondsTimeout); in SignalAndWaitOne()
|
| /dports/lang/mono/mono-5.10.1.57/external/corert/src/Native/Runtime/ |
| H A D | GCHelpers.cpp | 183 COOP_PINVOKE_HELPER(Int32, RhWaitForFullGCApproach, (Int32 millisecondsTimeout))
185 ASSERT(millisecondsTimeout >= -1);
188 int timeout = millisecondsTimeout == -1 ? INFINITE : millisecondsTimeout;
189 return GCHeapUtilities::GetGCHeap()->WaitForFullGCApproach(millisecondsTimeout);
192 COOP_PINVOKE_HELPER(Int32, RhWaitForFullGCComplete, (Int32 millisecondsTimeout))
194 ASSERT(millisecondsTimeout >= -1);
197 int timeout = millisecondsTimeout == -1 ? INFINITE : millisecondsTimeout;
198 return GCHeapUtilities::GetGCHeap()->WaitForFullGCComplete(millisecondsTimeout);
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading/ref/ |
| H A D | System.Threading.cs | 65 public bool SignalAndWait(int millisecondsTimeout) { throw null; } in SignalAndWait() argument
98 public bool Wait(int millisecondsTimeout) { throw null; } in Wait() argument
219 public bool Wait(int millisecondsTimeout) { throw null; } in Wait() argument
235 public static bool TryEnter(object obj, int millisecondsTimeout) { throw null; } in TryEnter() argument
240 public static bool Wait(object obj, int millisecondsTimeout) { throw null; } in Wait() argument
261 public void AcquireReaderLock(int millisecondsTimeout) { } in AcquireReaderLock() argument
263 public void AcquireWriterLock(int millisecondsTimeout) { } in AcquireWriterLock() argument
297 public bool TryEnterReadLock(int millisecondsTimeout) { throw null; } in TryEnterReadLock() argument
301 public bool TryEnterWriteLock(int millisecondsTimeout) { throw null; } in TryEnterWriteLock() argument
332 public bool Wait(int millisecondsTimeout) { throw null; } in Wait() argument
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/Common/tests/System/Threading/Tasks/ |
| H A D | TaskTimeoutExtensions.cs | 12 public static async Task TimeoutAfter(this Task task, int millisecondsTimeout) in TimeoutAfter() argument
16 if (task == await Task.WhenAny(task, Task.Delay(millisecondsTimeout, cts.Token))) in TimeoutAfter()
27 … static async Task<TResult> TimeoutAfter<TResult>(this Task<TResult> task, int millisecondsTimeout) in TimeoutAfter() argument
31 …if (task == await Task<TResult>.WhenAny(task, Task<TResult>.Delay(millisecondsTimeout, cts.Token))) in TimeoutAfter()
42 public static async Task WhenAllOrAnyFailed(this Task[] tasks, int millisecondsTimeout) in WhenAllOrAnyFailed() argument
46 …if (task == await Task.WhenAny(task, Task.Delay(millisecondsTimeout, cts.Token)).ConfigureAwait(fa… in WhenAllOrAnyFailed()
|
| /dports/science/orthanc-postgresql/OrthancPostgreSQL-4.0/PostgreSQL/ThirdPartyDownloads/Orthanc-1.9.3/OrthancFramework/Sources/MultiThreading/ |
| H A D | SharedMessageQueue.cpp | 109 IDynamicObject* SharedMessageQueue::Dequeue(int32_t millisecondsTimeout) in Dequeue() argument
116 if (millisecondsTimeout == 0) in Dequeue()
123 (lock, boost::posix_time::milliseconds(millisecondsTimeout)); in Dequeue()
144 bool SharedMessageQueue::WaitEmpty(int32_t millisecondsTimeout) in WaitEmpty() argument
151 if (millisecondsTimeout == 0) in WaitEmpty()
158 (lock, boost::posix_time::milliseconds(millisecondsTimeout))) in WaitEmpty()
|
| /dports/science/orthanc-mysql/OrthancMySQL-4.3/MySQL/ThirdPartyDownloads/Orthanc-1.9.3/OrthancFramework/Sources/MultiThreading/ |
| H A D | SharedMessageQueue.cpp | 109 IDynamicObject* SharedMessageQueue::Dequeue(int32_t millisecondsTimeout) in Dequeue() argument
116 if (millisecondsTimeout == 0) in Dequeue()
123 (lock, boost::posix_time::milliseconds(millisecondsTimeout)); in Dequeue()
144 bool SharedMessageQueue::WaitEmpty(int32_t millisecondsTimeout) in WaitEmpty() argument
151 if (millisecondsTimeout == 0) in WaitEmpty()
158 (lock, boost::posix_time::milliseconds(millisecondsTimeout))) in WaitEmpty()
|
| /dports/science/orthanc/Orthanc-1.9.7/OrthancFramework/Sources/MultiThreading/ |
| H A D | SharedMessageQueue.cpp | 109 IDynamicObject* SharedMessageQueue::Dequeue(int32_t millisecondsTimeout) in Dequeue() argument
116 if (millisecondsTimeout == 0) in Dequeue()
123 (lock, boost::posix_time::milliseconds(millisecondsTimeout)); in Dequeue()
144 bool SharedMessageQueue::WaitEmpty(int32_t millisecondsTimeout) in WaitEmpty() argument
151 if (millisecondsTimeout == 0) in WaitEmpty()
158 (lock, boost::posix_time::milliseconds(millisecondsTimeout))) in WaitEmpty()
|
| /dports/science/orthanc-dicomweb/OrthancDicomWeb-1.7/ThirdPartyDownloads/Orthanc-1.9.3/OrthancFramework/Sources/MultiThreading/ |
| H A D | SharedMessageQueue.cpp | 109 IDynamicObject* SharedMessageQueue::Dequeue(int32_t millisecondsTimeout) in Dequeue() argument
116 if (millisecondsTimeout == 0) in Dequeue()
123 (lock, boost::posix_time::milliseconds(millisecondsTimeout)); in Dequeue()
144 bool SharedMessageQueue::WaitEmpty(int32_t millisecondsTimeout) in WaitEmpty() argument
151 if (millisecondsTimeout == 0) in WaitEmpty()
158 (lock, boost::posix_time::milliseconds(millisecondsTimeout))) in WaitEmpty()
|
| /dports/science/orthanc-webviewer/OrthancWebViewer-2.7/ThirdPartyDownloads/Orthanc-1.8.1/OrthancFramework/Sources/MultiThreading/ |
| H A D | SharedMessageQueue.cpp | 109 IDynamicObject* SharedMessageQueue::Dequeue(int32_t millisecondsTimeout) in Dequeue() argument
116 if (millisecondsTimeout == 0) in Dequeue()
123 (lock, boost::posix_time::milliseconds(millisecondsTimeout)); in Dequeue()
144 bool SharedMessageQueue::WaitEmpty(int32_t millisecondsTimeout) in WaitEmpty() argument
151 if (millisecondsTimeout == 0) in WaitEmpty()
158 (lock, boost::posix_time::milliseconds(millisecondsTimeout))) in WaitEmpty()
|