Home
last modified time | relevance | path

Searched refs:concurrent (Results 1 - 25 of 95) sorted by relevance

1234

/third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-spam/
H A Dminimal-ws-client-spam.c41 static int concurrent = 3, conn, tries, est, errors, closed, sent, limit = 15; variable
95 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
105 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
141 for (n = 0; n < concurrent; n++) { in callback_minimal_spam()
149 if (n == concurrent) in callback_minimal_spam()
241 concurrent = atoi(p); in main()
248 if (concurrent < 0 || in main()
249 concurrent > (int)LWS_ARRAY_SIZE(clients)) { in main()
251 concurrent, (int)LWS_ARRAY_SIZE(clients)); in main()
263 info.fd_limit_per_thread = (unsigned int)(1 + concurrent in main()
[all...]
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-cpp/
H A Dmain.cxx17 static int interrupted, bad = 1, concurrent = 1, completed; variable
31 if (++completed == concurrent) { in lss_completion()
57 concurrent = atoi(p); in main()
59 if (concurrent > 12) in main()
60 concurrent = 12; in main()
63 "[-d<verb>] [-c<concurrent>]\n"); in main()
79 for (int n = 0; n < concurrent; n++) { in main()
/third_party/python/Lib/asyncio/
H A Dfutures.py7 import concurrent.futures namespace
31 """This class is *almost* compatible with concurrent.futures.Future.
44 methods in the concurrent.futures package.
320 if exc_class is concurrent.futures.CancelledError:
322 elif exc_class is concurrent.futures.TimeoutError:
324 elif exc_class is concurrent.futures.InvalidStateError:
330 def _set_concurrent_future_state(concurrent, source):
331 """Copy state from a future to a concurrent.futures.Future."""
334 concurrent.cancel()
335 if not concurrent
[all...]
H A D__main__.py4 import concurrent.futures namespace
23 future = concurrent.futures.Future()
H A Dtasks.py12 import concurrent.futures namespace
384 FIRST_COMPLETED = concurrent.futures.FIRST_COMPLETED
385 FIRST_EXCEPTION = concurrent.futures.FIRST_EXCEPTION
386 ALL_COMPLETED = concurrent.futures.ALL_COMPLETED
910 Return a concurrent.futures.Future to access the result.
914 future = concurrent.futures.Future()
/third_party/benchmark/test/
H A Dbenchmark_setup_teardown_test.cc43 namespace concurrent { namespace
47 } // namespace concurrent
50 concurrent::setup_call.fetch_add(1, std::memory_order_acquire); in DoSetup2()
55 concurrent::teardown_call.fetch_add(1, std::memory_order_acquire); in DoTeardown2()
62 concurrent::func_call.fetch_add(1, std::memory_order_acquire); in BM_concurrent()
141 assert(concurrent::setup_call.load(std::memory_order_relaxed) == 3); in main()
142 assert(concurrent::teardown_call.load(std::memory_order_relaxed) == 3); in main()
144 concurrent::func_call.load(std::memory_order_relaxed)); in main()
/third_party/node/benchmark/fs/
H A Dwritefile-promises.js20 concurrent: [1, 10],
23 function main({ encodingType, duration, concurrent, size }) {
79 while (concurrent--) write();
H A Dreadfile-promises.js27 concurrent: [1, 10],
30 function main({ len, duration, concurrent, encoding }) {
78 while (concurrent--) read();
H A Dreadfile.js20 concurrent: [1, 10],
23 function main({ len, duration, concurrent, encoding }) {
69 while (concurrent--) read();
H A Dreadfile-partitioned.js23 concurrent: [1, 10],
26 function main({ len, duration, concurrent, encoding }) {
89 while (concurrent-- > 0) read();
/third_party/python/Lib/test/test_importlib/partial/
H A Dcfimport.py13 from concurrent.futures import ThreadPoolExecutor
20 from concurrent.futures.thread import ThreadPoolExecutor
34 sys.modules.pop('concurrent.futures', None)
35 sys.modules.pop('concurrent.futures.thread', None)
/third_party/libphonenumber/java/libphonenumber/test/com/google/i18n/phonenumbers/metadata/source/
H A DBlockingMetadataBootstrappingGuardTest.java32 import java.util.concurrent.Callable;
33 import java.util.concurrent.ExecutorService;
34 import java.util.concurrent.Executors;
/third_party/ltp/testcases/network/stress/ns-tools/
H A Dns-tcpserver.c74 int concurrent; /* if non-zero, act as a concurrent server */ member
108 "\t-c\twork in the concurrent server mode\n" in usage()
433 if (info_p->concurrent) in handle_client()
462 if (info_p->concurrent) { /* concurrent server. */ in handle_client()
516 if (info_p->concurrent) in handle_client()
580 server.concurrent = 1; in main()
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-stress/
H A Dminimal-secure-streams.c559 int n = 0, expected = 0, concurrent = 1; in main() local
569 concurrent = atoi(p); in main()
571 if (concurrent < 0 || concurrent > 100) in main()
579 for (n = 0; n < concurrent - 1; n++) { in main()
/third_party/libphonenumber/java/libphonenumber/src/com/google/i18n/phonenumbers/metadata/source/
H A DMapBackedMetadataContainer.java20 import java.util.concurrent.ConcurrentHashMap;
21 import java.util.concurrent.ConcurrentMap;
/third_party/skia/platform_tools/android/apps/skottie/skottielib/src/main/java/org/skia/skottie/
H A DSkottieRunner.java20 import java.util.concurrent.CountDownLatch;
21 import java.util.concurrent.TimeUnit;
22 import java.util.concurrent.TimeoutException;
/third_party/protobuf/java/core/src/main/java/com/google/protobuf/
H A DProtobuf.java36 import java.util.concurrent.ConcurrentHashMap;
37 import java.util.concurrent.ConcurrentMap;
/third_party/protobuf/objectivec/DevTools/
H A Dfull_mac_build.sh271 -disable-concurrent-testing
280 -disable-concurrent-testing
289 -disable-concurrent-destination-testing
/third_party/skia/platform_tools/android/apps/skottie/src/main/java/org/skia/skottie/
H A DSkottieActivity.java24 import java.util.concurrent.CountDownLatch;
25 import java.util.concurrent.TimeUnit;
26 import java.util.concurrent.TimeoutException;
/third_party/python/Lib/concurrent/futures/
H A D__init__.py8 from concurrent.futures._base import (FIRST_COMPLETED,
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/java/com/mobileer/miditools/
H A DMidiDispatcher.java23 import java.util.concurrent.CopyOnWriteArrayList;
/third_party/python/Lib/test/test_asyncio/
H A Dtest_futures.py3 import concurrent.futures namespace
479 ex = concurrent.futures.ThreadPoolExecutor(1)
496 ex = concurrent.futures.ThreadPoolExecutor(1)
505 ex = concurrent.futures.ThreadPoolExecutor(1)
519 ex = concurrent.futures.ThreadPoolExecutor(1)
526 f1 = concurrent.futures.Future()
534 f1 = concurrent.futures.Future()
/third_party/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/
H A DSoftCache.java11 import java.util.concurrent.ConcurrentHashMap;
/third_party/icu/ohos_icu4j/src/main/java/ohos/global/icu/impl/
H A DSoftCache.java12 import java.util.concurrent.ConcurrentHashMap;
/third_party/qrcodegen/java-fast/io/nayuki/fastqrcodegen/
H A DMemoizer.java30 import java.util.concurrent.ConcurrentHashMap;

Completed in 10 milliseconds

1234