| /external/python/cpython3/Lib/test/ |
| D | test_coroutines.py | 509 async def foo():
526 async def foo():
535 async def foo():
543 async def foo():
576 async def foo():
601 async def foo():
611 async def bar():
631 async def foo():
639 async def foo():
675 async def foo():
[all …]
|
| D | test_contextlib_async.py | 28 async def test_enter(self):
30 async def __aexit__(self, *args):
36 async with manager as context:
48 async def __aenter__(self):
50 async def __aexit__(self, exc_type, exc_value, traceback):
56 async def __aexit__(self, *args):
75 async def test_contextmanager_plain(self):
78 async def woohoo():
82 async with woohoo() as x:
89 async def test_contextmanager_finally(self):
[all …]
|
| D | test_asyncgen.py | 38 async def iterate():
40 async for i in gen:
135 async def gen():
147 async def gen():
173 async def gen():
183 async def gen():
203 async def gen():
212 async def gen():
231 async def async_gen():
254 async def async_gen():
[all …]
|
| D | test_sys_settrace.py | 30 async def __aenter__(self):
33 async def __aexit__(self, *exc_info):
36 async def asynciter(iterable):
729 async def test_jump_out_of_async_for_block_forwards(output):
731 async for i in asynciter([1, 2]):
737 async def test_jump_out_of_async_for_block_backwards(output):
740 async for i in asynciter([1]):
810 async def test_jump_forwards_out_of_async_with_block(output):
811 async with asynctracecontext(output, 1):
822 async def test_jump_backwards_out_of_async_with_block(output):
[all …]
|
| /external/mockito/src/test/java/org/mockitousage/verification/ |
| D | VerificationWithAfterTest.java | 21 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 …]
|
| D | VerificationWithTimeoutTest.java | 20 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/Reactive-Extensions/RxCpp/Ix/CPP/samples/SampleCppLinq/ |
| D | data.txt | 1 {'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/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AsyncSettableFutureTest.java | 124 AsyncSettableFuture<Object> async = AsyncSettableFuture.create(); in testCancel_innerCancelsAsync() local
126 async.setFuture(inner); in testCancel_innerCancelsAsync()
128 assertTrue(async.isCancelled()); in testCancel_innerCancelsAsync()
130 async.get(); in testCancel_innerCancelsAsync()
136 AsyncSettableFuture<Object> async = AsyncSettableFuture.create(); in testCancel_resultCancelsInner_interrupted() local
138 async.setFuture(inner); in testCancel_resultCancelsInner_interrupted()
139 async.cancel(true); in testCancel_resultCancelsInner_interrupted()
149 AsyncSettableFuture<Object> async = AsyncSettableFuture.create(); in testCancel_resultCancelsInner() local
151 async.setFuture(inner); in testCancel_resultCancelsInner()
152 async.cancel(false); in testCancel_resultCancelsInner()
[all …]
|
| /external/libchrome/third_party/jinja2/ |
| D | asyncfilters.py | 7 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 …]
|
| D | asyncsupport.py | 22 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/curl/lib/ |
| D | asyn-thread.c | 149 destroy_async_data(&conn->async); in Curl_resolver_cancel()
183 return &(((struct thread_data *)conn->async.os_specific)->tsd); in conn_thread_sync_data()
346 static void destroy_async_data(struct Curl_async *async) in destroy_async_data() argument
348 if(async->os_specific) { in destroy_async_data()
349 struct thread_data *td = (struct thread_data*) async->os_specific; in destroy_async_data()
370 free(async->os_specific); in destroy_async_data()
373 async->os_specific = NULL; in destroy_async_data()
375 free(async->hostname); in destroy_async_data()
376 async->hostname = NULL; in destroy_async_data()
392 conn->async.os_specific = (void *)td; in init_resolve_thread()
[all …]
|
| D | asyn-ares.c | 189 static void destroy_async_data(struct Curl_async *async);
198 destroy_async_data(&conn->async); in Curl_resolver_cancel()
215 static void destroy_async_data(struct Curl_async *async) in destroy_async_data() argument
217 free(async->hostname); in destroy_async_data()
219 if(async->os_specific) { in destroy_async_data()
220 struct ResolverResults *res = (struct ResolverResults *)async->os_specific; in destroy_async_data()
228 async->os_specific = NULL; in destroy_async_data()
231 async->hostname = NULL; in destroy_async_data()
342 conn->async.os_specific; in Curl_resolver_is_resolved()
357 if(!conn->async.dns) { in Curl_resolver_is_resolved()
[all …]
|
| /external/libcxx/test/std/thread/futures/futures.overview/ |
| D | launch.pass.cpp | 30 … (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/python/cpython3/Lib/asyncio/ |
| D | events.py | 183 async def start_serving(self):
191 async def serve_forever(self):
198 async def wait_closed(self):
202 async def __aenter__(self):
205 async def __aexit__(self, *exc):
253 async def shutdown_asyncgens(self):
288 async def run_in_executor(self, executor, func, *args):
296 async def getaddrinfo(self, host, port, *,
300 async def getnameinfo(self, sockaddr, flags=0):
303 async def create_connection(
[all …]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_runners.py | 37 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 …]
|
| D | test_pep492.py | 50 async def test(lock):
53 async with lock as _lock:
72 async def test(lock):
97 async def reader():
99 async for line in stream:
110 async def foo(): pass
121 async def foo(): pass
138 async def bar():
140 async def foo():
153 async def start():
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | ResponseHeadersTest.cs | 65 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 …]
|
| D | ChannelTest.cs | 59 …Assert.ThrowsAsync(typeof(ArgumentException), async () => await channel.WaitForStateChangedAsync(C… in WaitForStateChangedAsync_InvalidArgument()
76 … Assert.ThrowsAsync(typeof(InvalidOperationException), async () => await channel.ShutdownAsync()); in Shutdown_AllowedOnlyOnce()
80 public async Task ShutdownTokenCancelledAfterShutdown() in ShutdownTokenCancelledAfterShutdown()
90 public async Task StateIsShutdownAfterShutdown() in StateIsShutdownAfterShutdown()
98 public async Task ShutdownFinishesWaitForStateChangedAsync() in ShutdownFinishesWaitForStateChangedAsync()
108 public async Task OperationsThrowAfterShutdown() in OperationsThrowAfterShutdown()
112 …Assert.ThrowsAsync(typeof(ObjectDisposedException), async () => await channel.WaitForStateChangedA… in OperationsThrowAfterShutdown()
114 … Assert.ThrowsAsync(typeof(TaskCanceledException), async () => await channel.ConnectAsync()); in OperationsThrowAfterShutdown()
|
| D | MarshallingErrorsTest.cs | 93 …helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, re… in ResponseParsingError_StreamingResponse()
100 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ResponseParsingError_StreamingResponse()
118 public async Task RequestParsingError_StreamingRequest() in RequestParsingError_StreamingRequest()
120 …helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStre… in RequestParsingError_StreamingRequest()
149 …Assert.ThrowsAsync<IOException>(async () => await Calls.AsyncUnaryCall(helper.CreateUnaryCall(), "… in RequestSerializationError_AsyncUnary()
153 public async Task RequestSerializationError_ClientStreaming() in RequestSerializationError_ClientStreaming()
155 …helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStre… in RequestSerializationError_ClientStreaming()
162 …Assert.ThrowsAsync<IOException>(async () => await call.RequestStream.WriteAsync("UNSERIALIZABLE_VA… in RequestSerializationError_ClientStreaming()
|
| D | ClientServerTest.cs | 58 public async Task UnaryCall() in UnaryCall()
81 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrows()
97 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrowsRpcException()
117 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrowsRpcExceptionWithTrailers()
137 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerSetsStatus()
158 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerSetsStatusAndTrailers()
166 public async Task ClientStreamingCall() in ClientStreamingCall()
168 …helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStre… in ClientStreamingCall()
189 public async Task ServerStreamingCall() in ServerStreamingCall()
191 …helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, re… in ServerStreamingCall()
[all …]
|
| D | CallCancellationTest.cs | 58 public async Task ClientStreamingCall_CancelAfterBegin() in ClientStreamingCall_CancelAfterBegin()
62 …helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStre… in ClientStreamingCall_CancelAfterBegin()
88 public async Task ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull() in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
94 …helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStre… in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
126 public async Task ClientStreamingCall_CancelServerSideRead() in ClientStreamingCall_CancelServerSideRead()
128 …helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStre… in ClientStreamingCall_CancelServerSideRead()
151 public async Task ServerStreamingCall_CancelClientSideRead() in ServerStreamingCall_CancelClientSideRead()
153 …helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, re… in ServerStreamingCall_CancelClientSideRead()
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | InteropClientServerTest.cs | 81 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/libcxx/test/std/thread/futures/futures.async/ |
| D | async_race.38682.pass.cpp | 47 std::future<int> fut = std::async(std::launch::async, worker, v); in main()
56 std::future<int&> fut = std::async(std::launch::async, worker_ref, std::ref(i)); in main()
65 std::future<void> fut = std::async(std::launch::async, worker_void); in main()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/unittests/Support/ |
| D | TaskQueueTest.cpp | 37 std::future<void> F1 = TQ.async([&] { in TEST_F()
41 std::future<void> F2 = TQ.async([&] { in TEST_F()
45 std::future<void> F3 = TQ.async([&] { in TEST_F()
79 std::future<void> F1 = TQ.async([&] { ++X; }); in TEST_F()
80 std::future<void> F2 = TQ.async([&] { ++Y; }); in TEST_F()
81 std::future<void> F3 = TQ.async([&M, &Z] { in TEST_F()
102 std::future<std::string> F1 = TQ.async([&] { return std::string("Hello"); }); in TEST_F()
103 std::future<int> F2 = TQ.async([&] { return 42; }); in TEST_F()
|
| D | ThreadPool.cpp | 93 Pool.async([this, &checked_in] { in TEST_F()
113 Pool.async(TestFunc, std::ref(checked_in), i); in TEST_F()
123 Pool.async([this, &i] { in TEST_F()
127 Pool.async([&i] { ++i; }); in TEST_F()
138 Pool.async([this, &i] { in TEST_F()
143 Pool.async([&i] { ++i; }).get(); in TEST_F()
157 Pool.async([this, &checked_in] { in TEST_F()
|