Home
last modified time | relevance | path

Searched refs:awaiter (Results 1 – 25 of 308) sorted by relevance

12345678910>>...13

/dports/lang/mono/mono-5.10.1.57/mcs/class/corlib/Test/System.Runtime.CompilerServices/
H A DTaskAwaiterTest_T.cs74 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 DTaskAwaiterTest.cs165 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 DAsyncVoidMethodBuilderTest.cs80 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 DBasic.java75 ? 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 DBasic.java75 ? 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 DBasic.java75 ? 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 DBasic.java75 ? 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 DObservableAwaiterTest.cs48 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 DAsyncStopTLS.cpp46 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 DBaton.cpp43 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 Dco_spawn.hpp40 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 Dco_spawn.hpp41 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 Dco_spawn.hpp40 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 Draw.rs114 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 Draw.rs114 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 Draw.rs114 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 Draw.rs114 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 Draw.rs114 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 Draw.rs114 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 DAsyncMethodBuilder.cs95 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 DAsyncValueTaskMethodBuilder.cs81 …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 DAsyncValueTaskMethodBuilder.cs89 …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 DAsyncValueTaskMethodBuilder.cs89 …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 Dtest-async-94.cs38 …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 DBasic.java149 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();

12345678910>>...13