/dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/Test/System.Runtime.CompilerServices/ |
H A D | TaskAwaiterTest_T.cs | 74 TaskAwaiter<int> awaiter; in GetResultFaulted() 77 awaiter = task.GetAwaiter (); in GetResultFaulted() 84 awaiter.GetResult (); in GetResultFaulted() 94 TaskAwaiter<object> awaiter; in GetResultAfterMultipleExceptions() 97 awaiter.GetResult (); in GetResultAfterMultipleExceptions() 111 awaiter.GetResult (); in CreateFaultedAwaiter() 116 awaiter.GetResult (); in CreateFaultedAwaiter() 124 TaskAwaiter<int> awaiter; in GetResultCanceled() 131 awaiter.GetResult (); in GetResultCanceled() 140 TaskAwaiter awaiter; in ContextTest() [all …]
|
H A D | TaskAwaiterTest.cs | 165 TaskAwaiter awaiter; in GetResultFaulted() 168 awaiter = task.GetAwaiter (); in GetResultFaulted() 175 awaiter.GetResult (); in GetResultFaulted() 184 TaskAwaiter awaiter; in GetResultCanceled() 188 awaiter = task.GetAwaiter (); in GetResultCanceled() 191 awaiter.GetResult (); in GetResultCanceled() 200 TaskAwaiter awaiter; in GetResultWaitOnCompletion() 203 awaiter = task.GetAwaiter (); in GetResultWaitOnCompletion() 205 awaiter.GetResult (); in GetResultWaitOnCompletion() 261 var awaiter = task.GetAwaiter (); in FinishedTaskOnCompleted() [all …]
|
H A D | AsyncVoidMethodBuilderTest.cs | 80 var awaiter = AsyncVoidMethodBuilder.Create (); in SetResult() 81 awaiter.SetResult (); in SetResult() 92 var awaiter = AsyncVoidMethodBuilder.Create (); in SetException() 99 awaiter.SetException (new ApplicationException ()); in SetException() 106 awaiter.SetResult (); in SetException()
|
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/util/concurrent/CountDownLatch/ |
H A D | Basic.java | 75 ? awaiter(latch, gate) 98 for (Awaiter awaiter : a) 99 awaiter.join(); 100 for (Awaiter awaiter : a) 101 checkException(awaiter, null); 124 for (Awaiter awaiter : a) 125 awaiter.join(); 127 Awaiter awaiter = a[i]; 157 for (Awaiter awaiter : a) 158 awaiter.join(); [all …]
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/util/concurrent/CountDownLatch/ |
H A D | Basic.java | 75 ? awaiter(latch, gate) 98 for (Awaiter awaiter : a) 99 awaiter.join(); 100 for (Awaiter awaiter : a) 101 checkException(awaiter, null); 124 for (Awaiter awaiter : a) 125 awaiter.join(); 127 Awaiter awaiter = a[i]; 157 for (Awaiter awaiter : a) 158 awaiter.join(); [all …]
|
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/util/concurrent/CountDownLatch/ |
H A D | Basic.java | 75 ? awaiter(latch, gate) 98 for (Awaiter awaiter : a) 99 awaiter.join(); 100 for (Awaiter awaiter : a) 101 checkException(awaiter, null); 124 for (Awaiter awaiter : a) 125 awaiter.join(); 127 Awaiter awaiter = a[i]; 157 for (Awaiter awaiter : a) 158 awaiter.join(); [all …]
|
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/util/concurrent/CountDownLatch/ |
H A D | Basic.java | 75 ? awaiter(latch, gate) 98 for (Awaiter awaiter : a) 99 awaiter.join(); 100 for (Awaiter awaiter : a) 101 checkException(awaiter, null); 124 for (Awaiter awaiter : a) 125 awaiter.join(); 127 Awaiter awaiter = a[i]; 157 for (Awaiter awaiter : a) 158 awaiter.join(); [all …]
|
/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/ |
H A D | ObservableAwaiterTest.cs | 48 var awaiter = default(AsyncSubject<int>); in Await() 52 scheduler.ScheduleAbsolute(100, () => awaiter = xs.GetAwaiter()); in Await() 53 …scheduler.ScheduleAbsolute(200, () => awaiter.OnCompleted(() => { t = scheduler.Clock; result = aw… in Await() 81 var awaiter = default(AsyncSubject<int>); in Await_Error() 84 scheduler.ScheduleAbsolute(100, () => awaiter = xs.GetAwaiter()); in Await_Error() 85 …ler.ScheduleAbsolute(200, () => awaiter.OnCompleted(() => { t = scheduler.Clock; ReactiveAssert.Th… in Await_Error() 109 var awaiter = default(AsyncSubject<int>); in Await_Never() 113 scheduler.ScheduleAbsolute(100, () => awaiter = xs.GetAwaiter()); in Await_Never() 114 …scheduler.ScheduleAbsolute(200, () => awaiter.OnCompleted(() => { t = scheduler.Clock; awaiter.Get… in Await_Never() 135 var awaiter = default(AsyncSubject<int>); in Await_Empty() [all …]
|
/dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/security/ |
H A D | AsyncStopTLS.cpp | 46 auto awaiter = std::exchange(awaiter_, nullptr); in endOfTLS() local 47 awaiter->stopTLSSuccess(std::move(postTLSData)); in endOfTLS() 73 auto awaiter = std::exchange(awaiter_, nullptr); in readEOF() local 74 awaiter->stopTLSError(folly::make_exception_wrapper<std::runtime_error>( in readEOF() 85 auto awaiter = std::exchange(awaiter_, nullptr); in readBufferAvailable() local 86 awaiter->stopTLSError(folly::make_exception_wrapper<std::runtime_error>( in readBufferAvailable() 97 auto awaiter = std::exchange(awaiter_, nullptr); in readErr() local 98 awaiter->stopTLSError(ex); in readErr()
|
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/coro/ |
H A D | Baton.cpp | 43 WaitOperation* awaiter = static_cast<WaitOperation*>(oldValue); in post() local 44 while (awaiter != nullptr) { in post() 45 std::exchange(awaiter, awaiter->next_)->awaitingCoroutine_.resume(); in post() 50 bool Baton::waitImpl(WaitOperation* awaiter) const noexcept { in waitImpl() 59 awaiter->next_ = static_cast<WaitOperation*>(oldValue); in waitImpl() 63 awaiter, in waitImpl()
|
/dports/games/devilutionX/devilutionX-1.2.1/3rdParty/asio/include/asio/experimental/impl/ |
H A D | co_spawn.hpp | 40 class awaiter class 45 void operator()(awaiter* a) in operator ()() 52 typedef std::unique_ptr<awaiter, deleter> ptr; 56 ~awaiter() in ~awaiter() 73 awaiter* get_return_object() in get_return_object() 92 awaiter* add_ref() in add_ref() 196 awaiter<Executor>* top() in top() 319 void attach_callees(awaiter<Executor>* a) in attach_callees() 331 awaiter<Executor>* awaiter_ = nullptr; 412 awaiter_task(awaiter<Executor>* a) in awaiter_task() [all …]
|
/dports/math/py-pystan/pystan-2.19.0.0/pystan/stan/lib/stan_math/lib/boost_1.69.0/boost/asio/experimental/impl/ |
H A D | co_spawn.hpp | 41 class awaiter class 46 void operator()(awaiter* a) in operator ()() 53 typedef std::unique_ptr<awaiter, deleter> ptr; 57 ~awaiter() in ~awaiter() 74 awaiter* get_return_object() in get_return_object() 93 awaiter* add_ref() in add_ref() 197 awaiter<Executor>* top() in top() 320 void attach_callees(awaiter<Executor>* a) in attach_callees() 332 awaiter<Executor>* awaiter_ = nullptr; 413 awaiter_task(awaiter<Executor>* a) in awaiter_task() [all …]
|
/dports/multimedia/obs-websocket/obs-websocket-4.8.0/deps/asio/asio/include/asio/experimental/impl/ |
H A D | co_spawn.hpp | 40 class awaiter class 45 void operator()(awaiter* a) in operator ()() 52 typedef std::unique_ptr<awaiter, deleter> ptr; 56 ~awaiter() in ~awaiter() 73 awaiter* get_return_object() in get_return_object() 92 awaiter* add_ref() in add_ref() 196 awaiter<Executor>* top() in top() 319 void attach_callees(awaiter<Executor>* a) in attach_callees() 331 awaiter<Executor>* awaiter_ = nullptr; 412 awaiter_task(awaiter<Executor>* a) in awaiter_task() [all …]
|
/dports/devel/sccache/sccache-0.2.15/cargo-crates/async-task-4.0.3/src/ |
H A D | raw.rs | 114 awaiter: UnsafeCell::new(None), in allocate() 455 let mut awaiter = None; in run() localVariable 457 awaiter = (*raw.header).take(None); in run() 464 if let Some(w) = awaiter { in run() 523 let mut awaiter = None; in run() localVariable 532 if let Some(w) = awaiter { in run() 574 let mut awaiter = None; in run() localVariable 583 if let Some(w) = awaiter { in run() 637 let mut awaiter = None; in run() localVariable 646 if let Some(w) = awaiter { in run() [all …]
|
/dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/async-task-4.1.0/src/ |
H A D | raw.rs | 114 awaiter: UnsafeCell::new(None), in allocate() 455 let mut awaiter = None; in run() localVariable 457 awaiter = (*raw.header).take(None); in run() 464 if let Some(w) = awaiter { in run() 523 let mut awaiter = None; in run() localVariable 532 if let Some(w) = awaiter { in run() 574 let mut awaiter = None; in run() localVariable 583 if let Some(w) = awaiter { in run() 637 let mut awaiter = None; in run() localVariable 646 if let Some(w) = awaiter { in run() [all …]
|
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/async-task-4.0.3/src/ |
H A D | raw.rs | 114 awaiter: UnsafeCell::new(None), in allocate() 455 let mut awaiter = None; in run() localVariable 457 awaiter = (*raw.header).take(None); in run() 464 if let Some(w) = awaiter { in run() 523 let mut awaiter = None; in run() localVariable 532 if let Some(w) = awaiter { in run() 574 let mut awaiter = None; in run() localVariable 583 if let Some(w) = awaiter { in run() 637 let mut awaiter = None; in run() localVariable 646 if let Some(w) = awaiter { in run() [all …]
|
/dports/www/firefox/firefox-99.0/third_party/rust/async-task/src/ |
H A D | raw.rs | 114 awaiter: UnsafeCell::new(None), in allocate() 455 let mut awaiter = None; in run() localVariable 457 awaiter = (*raw.header).take(None); in run() 464 if let Some(w) = awaiter { in run() 523 let mut awaiter = None; in run() localVariable 532 if let Some(w) = awaiter { in run() 574 let mut awaiter = None; in run() localVariable 583 if let Some(w) = awaiter { in run() 637 let mut awaiter = None; in run() localVariable 646 if let Some(w) = awaiter { in run() [all …]
|
/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/async-task-4.0.3/src/ |
H A D | raw.rs | 114 awaiter: UnsafeCell::new(None), 455 let mut awaiter = None; 457 awaiter = (*raw.header).take(None); 464 if let Some(w) = awaiter { 523 let mut awaiter = None; 532 if let Some(w) = awaiter { 574 let mut awaiter = None; 583 if let Some(w) = awaiter { 637 let mut awaiter = None; 646 if let Some(w) = awaiter { [all …]
|
/dports/textproc/jql/jql-3.0.6/cargo-crates/async-task-4.0.3/src/ |
H A D | raw.rs | 114 awaiter: UnsafeCell::new(None), in allocate() 455 let mut awaiter = None; in run() localVariable 457 awaiter = (*raw.header).take(None); in run() 464 if let Some(w) = awaiter { in run() 523 let mut awaiter = None; in run() localVariable 532 if let Some(w) = awaiter { in run() 574 let mut awaiter = None; in run() localVariable 583 if let Some(w) = awaiter { in run() 637 let mut awaiter = None; in run() localVariable 646 if let Some(w) = awaiter { in run() [all …]
|
/dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/src/System/Runtime/CompilerServices/ |
H A D | AsyncMethodBuilder.cs | 95 ref TAwaiter awaiter, ref TStateMachine stateMachine) 101 ref awaiter); 112 ref TAwaiter awaiter, ref TStateMachine stateMachine) 118 ref awaiter); 262 ref TAwaiter awaiter, ref TStateMachine stateMachine) 269 ref awaiter); 287 ref awaiter); 470 ref awaiter); 490 ref awaiter); 880 awaiter.OnCompleted(continuation); [all …]
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Extensions/src/System/Runtime/CompilerServices/ |
H A D | AsyncValueTaskMethodBuilder.cs | 81 …public void AwaitOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachine stat… 86 _methodBuilder.AwaitOnCompleted(ref awaiter, ref stateMachine); in _methodBuilder.AwaitOnCompleted() 94 …public void AwaitUnsafeOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachin… 99 _methodBuilder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine);
|
/dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/shared/System/Runtime/CompilerServices/ |
H A D | AsyncValueTaskMethodBuilder.cs | 89 …public void AwaitOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachine stat… 94 _methodBuilder.AwaitOnCompleted(ref awaiter, ref stateMachine); in _methodBuilder.AwaitOnCompleted() 103 …public void AwaitUnsafeOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachin… 108 _methodBuilder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine);
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/Common/src/CoreLib/System/Runtime/CompilerServices/ |
H A D | AsyncValueTaskMethodBuilder.cs | 89 …public void AwaitOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachine stat… 94 _methodBuilder.AwaitOnCompleted(ref awaiter, ref stateMachine); in _methodBuilder.AwaitOnCompleted() 103 …public void AwaitUnsafeOnCompleted<TAwaiter, TStateMachine>(ref TAwaiter awaiter, ref TStateMachin… 108 _methodBuilder.AwaitUnsafeOnCompleted(ref awaiter, ref stateMachine);
|
/dports/lang/mono/mono-5.10.1.57/mcs/tests/ |
H A D | test-async-94.cs | 38 …public void AwaitOnCompleted<TAwaiter, TStateMachine> (ref TAwaiter awaiter, ref TStateMachine sta… 43 …public void AwaitUnsafeOnCompleted<TAwaiter, TStateMachine> (ref TAwaiter awaiter, ref TStateMachi… 82 …public void AwaitOnCompleted<TAwaiter, TStateMachine> (ref TAwaiter awaiter, ref TStateMachine sta… 87 …public void AwaitUnsafeOnCompleted<TAwaiter, TStateMachine> (ref TAwaiter awaiter, ref TStateMachi…
|
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/java/util/concurrent/Phaser/ |
H A D | Basic.java | 149 private static Awaiter awaiter(final Phaser phaser) { 161 private static Awaiter awaiter(final Phaser phaser, 187 return awaiter(phaser); 189 return awaiter(phaser, -1, SECONDS); 191 return awaiter(phaser, 30, SECONDS); }} 203 return awaiter(phaser); 205 return awaiter(phaser, -1, SECONDS); 207 return awaiter(phaser, 30, SECONDS); }} 254 Awaiter a1 = awaiter(phaser, 30, SECONDS); a1.start(); 337 Awaiter a1 = awaiter(phaser, timeout, SECONDS); a1.start();
|