Home
last modified time | relevance | path

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

1234567

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAsyncSettableFutureTest.java124 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/curl/lib/
Dasyn-thread.c145 destroy_async_data(&conn->async); in Curl_resolver_cancel()
179 return &(((struct thread_data *)conn->async.os_specific)->tsd); in conn_thread_sync_data()
182 #define CONN_THREAD_SYNC_DATA(conn) &(((conn)->async.os_specific)->tsd);
337 static void destroy_async_data (struct Curl_async *async) in destroy_async_data() argument
339 if(async->os_specific) { in destroy_async_data()
340 struct thread_data *td = (struct thread_data*) async->os_specific; in destroy_async_data()
361 free(async->os_specific); in destroy_async_data()
364 async->os_specific = NULL; in destroy_async_data()
366 free(async->hostname); in destroy_async_data()
367 async->hostname = NULL; in destroy_async_data()
[all …]
Dasyn-ares.c172 static void destroy_async_data (struct Curl_async *async);
181 destroy_async_data(&conn->async); in Curl_resolver_cancel()
187 static void destroy_async_data (struct Curl_async *async) in destroy_async_data() argument
189 free(async->hostname); in destroy_async_data()
191 if(async->os_specific) { in destroy_async_data()
192 struct ResolverResults *res = (struct ResolverResults *)async->os_specific; in destroy_async_data()
200 async->os_specific = NULL; in destroy_async_data()
203 async->hostname = NULL; in destroy_async_data()
314 conn->async.os_specific; in Curl_resolver_is_resolved()
326 if(!conn->async.dns) { in Curl_resolver_is_resolved()
[all …]
Dhostasyn.c76 conn->async.status = status; in Curl_addrinfo_callback()
86 conn->async.hostname, in Curl_addrinfo_callback()
87 conn->async.port); in Curl_addrinfo_callback()
102 conn->async.dns = dns; in Curl_addrinfo_callback()
107 conn->async.done = TRUE; in Curl_addrinfo_callback()
124 if(conn->async.dns) { in Curl_async_resolved()
125 conn->dns_entry = conn->async.dns; in Curl_async_resolved()
126 conn->async.dns = NULL; in Curl_async_resolved()
/external/libcxx/test/std/thread/futures/futures.overview/
Dlaunch.pass.cpp28 … (static_cast<int>(std::launch::async) | static_cast<int>(std::launch::deferred)), ""); in main()
30 static_assert(std::launch::any == (std::launch::async | std::launch::deferred), ""); in main()
31 static_assert(std::launch(0) == (std::launch::async & std::launch::deferred), ""); in main()
32 static_assert(std::launch::any == (std::launch::async ^ std::launch::deferred), ""); in main()
33 static_assert(std::launch::deferred == ~std::launch::async, ""); in main()
34 std::launch x = std::launch::async; in main()
37 x = std::launch::async; in main()
41 assert(x == std::launch::async); in main()
43 static_assert(static_cast<int>(std::launch::async) == 1, ""); in main()
/external/libcxx/test/std/thread/futures/futures.async/
Dasync.pass.cpp70 std::future<int> f = std::async(f0); in main()
78 std::future<int> f = std::async(std::launch::async, f0); in main()
86 std::future<int> f = std::async(std::launch::any, f0); in main()
94 std::future<int> f = std::async(std::launch::deferred, f0); in main()
103 std::future<int&> f = std::async(f1); in main()
111 std::future<int&> f = std::async(std::launch::async, f1); in main()
119 std::future<int&> f = std::async(std::launch::any, f1); in main()
127 std::future<int&> f = std::async(std::launch::deferred, f1); in main()
136 std::future<void> f = std::async(f2); in main()
144 std::future<void> f = std::async(std::launch::async, f2); in main()
[all …]
Dasync_race.pass.cpp47 std::future<int> f = std::async(f_async); in test_each()
52 std::future<int> f = std::async(std::launch::async, f_async); in test_each()
58 std::future<int> f = std::async(std::launch::deferred, f_deferred); in test_each()
/external/llvm/unittests/Support/
DThreadPool.cpp95 Pool.async([this, &checked_in, i] { in TEST_F()
115 Pool.async(TestFunc, std::ref(checked_in), i); in TEST_F()
125 Pool.async([this, &i] { in TEST_F()
129 Pool.async([&i] { ++i; }); in TEST_F()
140 Pool.async([this, &i] { in TEST_F()
145 Pool.async([&i] { ++i; }).get(); in TEST_F()
159 Pool.async([this, &checked_in, i] { in TEST_F()
/external/libgdx/backends/gdx-backends-gwt/src/com/badlogic/gdx/backends/gwt/emu/com/badlogic/gdx/utils/async/
DAsyncResult.java17 package com.badlogic.gdx.utils.async;
22 import com.badlogic.gdx.utils.async.AsyncExecutor;
23 import com.badlogic.gdx.utils.async.AsyncTask;
DAsyncTask.java17 package com.badlogic.gdx.utils.async;
19 import com.badlogic.gdx.utils.async.AsyncExecutor;
DThreadUtils.java17 package com.badlogic.gdx.utils.async;
/external/google-breakpad/src/client/windows/crash_generation/
DReadMe.txt20 CONNECTING | Get the result of async connection request.
31 READING | Get the result of async read request.
41 WRITING | Get the result of the async write request.
50 READING_ACK | Get the result of the async read request.
/external/avahi/avahi-daemon/
DAndroid.mk24 dbus-async-address-resolver.c \
25 dbus-async-host-name-resolver.c \
26 dbus-async-service-resolver.c \
/external/parameter-framework/upstream/remote-processor/
DBackgroundRemoteProcessorServer.cpp45 mServerSuccess = std::async(std::launch::async, &CRemoteProcessorServer::process, in start()
/external/autotest/client/cros/
Dcryptohome.py437 def mount(self, user, password, create=False, async=True): argument
444 if async:
474 def migrate(self, user, oldkey, newkey, async=True): argument
476 if async:
482 def remove(self, user, async=True): argument
483 if async:
/external/boringssl/src/ssl/test/
Dbssl_shim.cc320 if (config->async) { in InstallCertificate()
386 if (config->async) { in SelectCertificateCallback()
757 if (config->async && config->is_server) { in SetupCtx()
846 if (config->async) { in RetryAsync()
850 if (config->async) { in RetryAsync()
902 if (config->async) { in DoRead()
909 if (config->async) { in DoRead()
912 } while (config->async && RetryAsync(ssl, ret)); in DoRead()
927 } while ((config->async && RetryAsync(ssl, ret)) || (ret > 0 && in_len > 0)); in WriteAll()
938 } while (config->async && RetryAsync(ssl, ret)); in DoShutdown()
[all …]
/external/llvm/include/llvm/Support/
DThreadPool.h77 inline std::shared_future<VoidTy> async(Function &&F, Args &&... ArgList) { in async() function
95 inline std::shared_future<VoidTy> async(Function &&F) { in async() function
/external/libgdx/gdx/src/com/badlogic/gdx/assets/
DAssetLoadingTask.java27 import com.badlogic.gdx.utils.async.AsyncExecutor;
28 import com.badlogic.gdx.utils.async.AsyncResult;
29 import com.badlogic.gdx.utils.async.AsyncTask;
/external/llvm/lib/Support/
DThreadPool.cpp139 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl()
144 auto Future = std::async(std::launch::deferred, std::move(Task), false).share(); in asyncImpl()
/external/jetty/src/java/org/eclipse/jetty/server/
DServer.java381 final AsyncContinuation async = connection.getRequest().getAsyncContinuation(); in handleAsync() local
382 final AsyncContinuation.AsyncEventState state = async.getAsyncEventState(); in handleAsync()
400 final HttpServletRequest request=(HttpServletRequest)async.getRequest(); in handleAsync()
401 final HttpServletResponse response=(HttpServletResponse)async.getResponse(); in handleAsync()
/external/jetty/src/java/org/eclipse/jetty/server/handler/
DContextHandlerCollection.java187 AsyncContinuation async = baseRequest.getAsyncContinuation(); in handle()
188 if (async.isAsync()) in handle()
190 ContextHandler context=async.getContextHandler(); in handle()
/external/valgrind/none/tests/
Dasync-sigs.vgtest1 prog: async-sigs
/external/libgdx/gdx/src/com/badlogic/gdx/utils/async/
DThreadUtils.java17 package com.badlogic.gdx.utils.async;
DAsyncTask.java17 package com.badlogic.gdx.utils.async;
/external/jetty/src/java/org/eclipse/jetty/webapp/
DStandardDescriptorProcessor.java479 String async=node.getString("async-supported",false,true); in visitServlet() local
480 if (async!=null) in visitServlet()
482 boolean val = async.length()==0||Boolean.valueOf(async); in visitServlet()
509 …throw new IllegalStateException("Conflicting async-supported="+async+" for servlet "+servlet_name+… in visitServlet()
1779 String async=node.getString("async-supported",false,true); in visitFilter() local
1780 if (async!=null) in visitFilter()
1781 holder.setAsyncSupported(async.length()==0||Boolean.valueOf(async)); in visitFilter()
1782 if (async!=null) in visitFilter()
1784 boolean val = async.length()==0||Boolean.valueOf(async); in visitFilter()
1811 …throw new IllegalStateException("Conflicting async-supported="+async+" for filter "+name+" in "+de… in visitFilter()

1234567