Home
last modified time | relevance | path

Searched refs:async (Results 1 – 25 of 534) sorted by relevance

12345678910>>...22

/external/python/cpython3/Lib/test/
Dtest_coroutines.py508 async def foo():
525 async def foo():
534 async def foo():
542 async def foo():
575 async def foo():
600 async def foo():
610 async def bar():
630 async def foo():
638 async def foo():
674 async def foo():
[all …]
Dtest_contextlib_async.py28 async def test_enter(self):
30 async def __aexit__(self, *args):
36 async with manager as context:
40 async def test_async_gen_propagates_generator_exit(self):
44 async def ctx():
47 async def gen():
48 async with ctx():
54 async with ctx():
55 async for val in gen():
70 async def __aenter__(self):
[all …]
Dtest_asyncgen.py38 async def iterate():
40 async for i in gen:
142 async def gen():
154 async def gen():
183 async def gen():
193 async def gen():
214 async def gen():
223 async def gen():
242 async def async_gen():
265 async def async_gen():
[all …]
/external/mockito/src/test/java/org/mockitousage/verification/
DVerificationWithAfterTest.java21 import org.mockitoutil.async.AsyncTesting;
42 private AsyncTesting async = new AsyncTesting(); field in VerificationWithAfterTest
46 async.cleanUp(); in tearDown()
52 async.runAfter(10, callMock); in should_verify_with_after()
53 async.runAfter(1000, callMock); in should_verify_with_after()
62 async.runAfter(10, callMock); in should_verify_with_after_and_fail()
63 async.runAfter(40, callMock); in should_verify_with_after_and_fail()
77 async.runAfter(10, callMock); in should_verify_with_time_x()
78 async.runAfter(50, callMock); in should_verify_with_time_x()
79 async.runAfter(600, callMock); in should_verify_with_time_x()
[all …]
DVerificationWithTimeoutTest.java20 import org.mockitoutil.async.AsyncTesting;
38 private AsyncTesting async; field in VerificationWithTimeoutTest
42 async = new AsyncTesting(); in setUp()
47 async.cleanUp(); in tearDown()
53 async.runAfter(50, callMock('c')); in should_verify_with_timeout()
54 async.runAfter(500, callMock('c')); in should_verify_with_timeout()
64 async.runAfter(200, callMock('c')); in should_verify_with_timeout_and_fail()
99 async.runAfter(50, callMock('c')); in should_verify_with_times_x()
100 async.runAfter(100, callMock('c')); in should_verify_with_times_x()
101 async.runAfter(600, callMock('c')); in should_verify_with_times_x()
[all …]
/external/python/cpython3/Lib/unittest/test/
Dtest_async_case.py18 async def asyncSetUp(self):
22 async def test_func(self):
28 async def asyncTearDown(self):
41 async def on_cleanup(self):
62 async def asyncSetUp(self):
66 async def test_func(self):
70 async def asyncTearDown(self):
73 async def on_cleanup(self):
85 async def asyncSetUp(self):
88 async def test_func(self):
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/
DAwaitTest.kt14 val d = async { in <lambda>()
19 val d2 = async { in <lambda>()
39 val d = async(start = CoroutineStart.LAZY) { in <lambda>()
43 val d2 = async(start = CoroutineStart.LAZY) { in <lambda>()
53 val d1 = async { 1L } in <lambda>()
54 val d2 = async { "" } in <lambda>()
55 val d3 = async { } in <lambda>()
65 val d = async { in <lambda>()
70 val d2 = async(NonCancellable) { in <lambda>()
75 val d3 = async { in <lambda>()
[all …]
DAsyncTest.kt17 val d = async { in <lambda>()
33 val d = async(start = CoroutineStart.UNDISPATCHED) { in testUndispatched()
46 val d = async { in <lambda>()
57 val d = async(NonCancellable, start = CoroutineStart.ATOMIC) { in <lambda>()
74 val deferred = async(Job()) { in <lambda>()
86 val deferred = async(NonCancellable) { in <lambda>()
87 val decomposed = async(NonCancellable) { in <lambda>()
103 val deferred = async(NonCancellable) { in <lambda>()
105 val decomposed = async { // inherits parent job! in <lambda>()
127 val deferred = async(NonCancellable) { in <lambda>()
[all …]
/external/Reactive-Extensions/RxCpp/Ix/CPP/samples/SampleCppLinq/
Ddata.txt1 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22437888.0, '…
2 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22626304.0, '…
3 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22503424.0, '…
4 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22667264.0, '…
5 {'var': [('concurrency', 1), ('args', '-test async-gated')], 'result': {'workingset': 22323200.0, '…
11 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22626304.0, '…
12 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22806528.0, '…
13 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22556672.0, '…
14 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22609920.0, '…
15 {'var': [('concurrency', 2), ('args', '-test async-gated')], 'result': {'workingset': 22573056.0, '…
[all …]
/external/libchrome/third_party/jinja2/
Dasyncfilters.py7 async def auto_to_seq(value):
10 async for item in value:
18 async def async_select_or_reject(args, kwargs, modfunc, lookup_attr):
22 async for item in auto_aiter(seq):
62 async def do_first(environment, seq):
70 async def do_groupby(environment, value, attribute):
78 async def do_join(eval_ctx, value, d=u'', attribute=None):
83 async def do_list(value):
88 async def do_reject(*args, **kwargs):
93 async def do_rejectattr(*args, **kwargs):
[all …]
Dasyncsupport.py22 async def concat_async(async_gen):
24 async def collect():
25 async for event in async_gen:
31 async def generate_async(self, *args, **kwargs):
34 async for event in self.root_render_func(self.new_context(vars)):
58 async def render_async(self, *args, **kwargs):
84 async def async_call(self):
101 async def async_invoke(self, arguments, autoescape):
116 async def get_default_module_async(self):
133 async def make_module_async(self, vars=None, shared=False, locals=None):
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DSettableFutureTest.java171 SettableFuture<Object> async = SettableFuture.create(); in testCancel_innerCancelsAsync() local
173 async.setFuture(inner); in testCancel_innerCancelsAsync()
175 assertTrue(async.isCancelled()); in testCancel_innerCancelsAsync()
177 async.get(); in testCancel_innerCancelsAsync()
185 SettableFuture<Object> async = SettableFuture.create(); in testCancel_resultCancelsInner_interrupted() local
187 async.setFuture(inner); in testCancel_resultCancelsInner_interrupted()
188 async.cancel(true); in testCancel_resultCancelsInner_interrupted()
200 SettableFuture<Object> async = SettableFuture.create(); in testCancel_resultCancelsInner() local
202 async.setFuture(inner); in testCancel_resultCancelsInner()
203 async.cancel(false); in testCancel_resultCancelsInner()
[all …]
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DSettableFutureTest.java171 SettableFuture<Object> async = SettableFuture.create(); in testCancel_innerCancelsAsync() local
173 async.setFuture(inner); in testCancel_innerCancelsAsync()
175 assertTrue(async.isCancelled()); in testCancel_innerCancelsAsync()
177 async.get(); in testCancel_innerCancelsAsync()
185 SettableFuture<Object> async = SettableFuture.create(); in testCancel_resultCancelsInner_interrupted() local
187 async.setFuture(inner); in testCancel_resultCancelsInner_interrupted()
188 async.cancel(true); in testCancel_resultCancelsInner_interrupted()
200 SettableFuture<Object> async = SettableFuture.create(); in testCancel_resultCancelsInner() local
202 async.setFuture(inner); in testCancel_resultCancelsInner()
203 async.cancel(false); in testCancel_resultCancelsInner()
[all …]
/external/curl/lib/
Dasyn-thread.c151 destroy_async_data(&conn->async); in Curl_resolver_cancel()
189 return &(((struct thread_data *)conn->async.os_specific)->tsd); in conn_thread_sync_data()
382 static void destroy_async_data(struct Curl_async *async) in destroy_async_data() argument
384 if(async->os_specific) { in destroy_async_data()
385 struct thread_data *td = (struct thread_data*) async->os_specific; in destroy_async_data()
410 free(async->os_specific); in destroy_async_data()
422 async->os_specific = NULL; in destroy_async_data()
424 free(async->hostname); in destroy_async_data()
425 async->hostname = NULL; in destroy_async_data()
441 conn->async.os_specific = (void *)td; in init_resolve_thread()
[all …]
Dasyn-ares.c201 static void destroy_async_data(struct Curl_async *async);
210 destroy_async_data(&conn->async); in Curl_resolver_cancel()
227 static void destroy_async_data(struct Curl_async *async) in destroy_async_data() argument
229 free(async->hostname); in destroy_async_data()
231 if(async->os_specific) { in destroy_async_data()
232 struct ResolverResults *res = (struct ResolverResults *)async->os_specific; in destroy_async_data()
240 async->os_specific = NULL; in destroy_async_data()
243 async->hostname = NULL; in destroy_async_data()
352 conn->async.os_specific; in Curl_resolver_is_resolved()
390 if(!conn->async.dns) { in Curl_resolver_is_resolved()
[all …]
/external/libcxx/test/std/thread/futures/futures.overview/
Dlaunch.pass.cpp30 … (static_cast<int>(std::launch::async) | static_cast<int>(std::launch::deferred)), ""); in main()
32 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async | std::launch::deferred), ""); in main()
33 static_assert(std::launch(0) == (std::launch::async & std::launch::deferred), ""); in main()
34 LIBCPP_STATIC_ASSERT(std::launch::any == (std::launch::async ^ std::launch::deferred), ""); in main()
35 LIBCPP_STATIC_ASSERT(std::launch::deferred == ~std::launch::async, ""); in main()
36 std::launch x = std::launch::async; in main()
39 x = std::launch::async; in main()
43 assert(x == std::launch::async); in main()
45 static_assert(static_cast<int>(std::launch::async) == 1, ""); in main()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DThreadLocalTest.kt27 val deferred = async(Dispatchers.Default + stringThreadLocal.asContextElement("value")) { in <lambda>()
49 val deferred = async(Dispatchers.Default + intThreadLocal.asContextElement(239)) { in <lambda>()
67 val deferred = async(Dispatchers.Default in <lambda>()
92 val deferred = GlobalScope.async(intThreadLocal.asContextElement(1)) { in <lambda>()
101 val deferred = async(intThreadLocal.asContextElement(53)) { in <lambda>()
108 val deferred2 = GlobalScope.async(executor) { in <lambda>()
124 val deferred = async(Dispatchers.Default in <lambda>()
134 val deferred = async(stringThreadLocal.asContextElement("async")) { in <lambda>()
156 val deferred = async(Dispatchers.Default in <lambda>()
168 val deferred = async(myCounterLocal.asContextElement(Counter(31))) { in <lambda>()
[all …]
DAwaitStressTest.kt26 val d1 = async(ctx) { in <lambda>()
30 val d2 = async(ctx) { in <lambda>()
34 val d3 = async(ctx) { in <lambda>()
54 val d1 = async(pool) { in <lambda>()
58 val d2 = async(pool) { in <lambda>()
75 val d1 = async(pool) { in <lambda>()
81 val d2 = async(pool) { in <lambda>()
105 deferreds += async(pool) { in <lambda>()
110 deferreds += async(pool) { in <lambda>()
115 deferreds += async(pool) { in <lambda>()
/external/mesa3d/bin/pick/
Dcore_test.py250 async def mock(self, *_, **__):
254 async def communicate(self) -> typing.Tuple[bytes, bytes]:
258 async def wait(self) -> int:
262 async def return_true(*_, **__) -> bool:
266 async def return_false(*_, **__) -> bool:
270 async def test_fix_is_nominated(self):
282 async def test_fix_is_not_nominated(self):
294 async def test_cc_is_nominated(self):
305 async def test_cc_is_nominated2(self):
316 async def test_cc_is_not_nominated(self):
[all …]
/external/python/cpython3/Lib/asyncio/
Devents.py178 async def start_serving(self):
186 async def serve_forever(self):
193 async def wait_closed(self):
197 async def __aenter__(self):
200 async def __aexit__(self, *exc):
248 async def shutdown_asyncgens(self):
283 async def run_in_executor(self, executor, func, *args):
291 async def getaddrinfo(self, host, port, *,
295 async def getnameinfo(self, sockaddr, flags=0):
298 async def create_connection(
[all …]
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_runners.py37 async def shutdown_asyncgens():
62 async def main():
69 async def main():
84 async def main(expected):
92 async def main():
106 async def leftover():
109 async def main():
121 async def leftover():
127 async def main():
151 async def fidget():
[all …]
Dtest_pep492.py54 async def test(lock):
57 async with lock as _lock:
77 async def test(lock):
102 async def reader():
104 async for line in stream:
115 async def foo(): pass
126 async def foo(): pass
144 async def bar():
146 async def foo():
159 async def start():
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DResponseHeadersTest.cs65 public async Task ResponseHeadersAsync_UnaryCall() in ResponseHeadersAsync_UnaryCall()
67 helper.UnaryHandler = new UnaryServerMethod<string, string>(async (request, context) => in ResponseHeadersAsync_UnaryCall()
84 public async Task ResponseHeadersAsync_ClientStreamingCall() in ResponseHeadersAsync_ClientStreamingCall()
86 …helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStre… in ResponseHeadersAsync_ClientStreamingCall()
101 public async Task ResponseHeadersAsync_ServerStreamingCall() in ResponseHeadersAsync_ServerStreamingCall()
103 …helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, re… in ResponseHeadersAsync_ServerStreamingCall()
117 public async Task ResponseHeadersAsync_DuplexStreamingCall() in ResponseHeadersAsync_DuplexStreamingCall()
119 …helper.DuplexStreamingHandler = new DuplexStreamingServerMethod<string, string>(async (requestStre… in ResponseHeadersAsync_DuplexStreamingCall()
143 …Assert.ThrowsAsync(typeof(ArgumentNullException), async () => await context.WriteResponseHeadersAs… in WriteResponseHeaders_NullNotAllowed()
153 helper.UnaryHandler = new UnaryServerMethod<string, string>(async (request, context) => in WriteResponseHeaders_AllowedOnlyOnce()
[all …]
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DInteropClientServerTest.cs81 public async Task ClientStreaming() in ClientStreaming()
87 public async Task ServerStreaming() in ServerStreaming()
93 public async Task PingPong() in PingPong()
99 public async Task EmptyStream() in EmptyStream()
105 public async Task CancelAfterBegin() in CancelAfterBegin()
111 public async Task CancelAfterFirstResponse() in CancelAfterFirstResponse()
117 public async Task TimeoutOnSleepingServer() in TimeoutOnSleepingServer()
123 public async Task CustomMetadata() in CustomMetadata()
129 public async Task StatusCodeAndMessage() in StatusCodeAndMessage()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/
DBlockingCoroutineDispatcherStressTest.kt28 async(limitingDispatcher) { in <lambda>()
64 async(dispatcher) { in <lambda>()
66 blockingTasks += async(blockingDispatcher) { blockingBarrier.await() } in <lambda>()
67 blockingTasks += async(blockingDispatcher) { blockingBarrier.await() } in <lambda>()
71 cpuTasks += async(dispatcher) { cpuBarrier.await() } in <lambda>()
74 blockingTasks += async(blockingDispatcher) { blockingBarrier.await() } in <lambda>()
98 val tasks = (1..blockingLimit).map { async(blocking) { barrier.await() } } in <lambda>()
114 val cpuTasks = (1..CORES_COUNT).map { async(dispatcher) { while (true) delay(1) } } in <lambda>()
118 val tasks = (1..blockingLimit).map { async(blocking) { barrier.await() } } in <lambda>()

12345678910>>...22