/third_party/libwebsockets/minimal-examples/ws-client/minimal-ws-client-spam/ |
D | minimal-ws-client-spam.c | 41 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 + 1); in main()
|
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-cpp/ |
D | main.cxx | 17 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() 79 for (int n = 0; n < concurrent; n++) { in main()
|
/third_party/python/Lib/asyncio/ |
D | futures.py | 7 import concurrent.futures 317 if exc_class is concurrent.futures.CancelledError: 319 elif exc_class is concurrent.futures.TimeoutError: 321 elif exc_class is concurrent.futures.InvalidStateError: 327 def _set_concurrent_future_state(concurrent, source): argument 331 concurrent.cancel() 332 if not concurrent.set_running_or_notify_cancel(): 336 concurrent.set_exception(_convert_future_exc(exception)) 339 concurrent.set_result(result) 370 concurrent.futures.Future): [all …]
|
D | __main__.py | 4 import concurrent.futures 23 future = concurrent.futures.Future()
|
/third_party/benchmark/test/ |
D | benchmark_setup_teardown_test.cc | 43 namespace concurrent { namespace 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/python/Doc/library/ |
D | concurrent.futures.rst | 1 :mod:`concurrent.futures` --- Launching parallel tasks 4 .. module:: concurrent.futures 9 **Source code:** :source:`Lib/concurrent/futures/thread.py` 10 and :source:`Lib/concurrent/futures/process.py` 14 The :mod:`concurrent.futures` module provides a high-level interface for 50 The returned iterator raises a :exc:`concurrent.futures.TimeoutError` 155 pending jobs will raise a :exc:`~concurrent.futures.thread.BrokenThreadPool`, 190 import concurrent.futures 205 with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor: 208 for future in concurrent.futures.as_completed(future_to_url): [all …]
|
D | concurrency.rst | 7 The modules described in this chapter provide support for concurrent 19 concurrent.rst 20 concurrent.futures.rst
|
D | concurrent.rst | 1 The :mod:`concurrent` package 6 * :mod:`concurrent.futures` -- Launching parallel tasks
|
D | asyncio-future.rst | 70 Wrap a :class:`concurrent.futures.Future` object in a 257 :class:`concurrent.futures.Future`. Key differences include: 259 - unlike asyncio Futures, :class:`concurrent.futures.Future` 274 :func:`concurrent.futures.wait` and 275 :func:`concurrent.futures.as_completed` functions. 278 but :func:`concurrent.futures.cancel` does not.
|
/third_party/node/benchmark/fs/ |
D | readfile.js | 20 concurrent: [1, 10], property 23 function main({ len, duration, concurrent, encoding }) { property 69 while (concurrent--) read();
|
D | readfile-promises.js | 27 concurrent: [1, 10], property 30 function main({ len, duration, concurrent, encoding }) { property 78 while (concurrent--) read();
|
D | readfile-partitioned.js | 23 concurrent: [1, 10], property 26 function main({ len, duration, concurrent, encoding }) { property 89 while (concurrent-- > 0) read();
|
D | writefile-promises.js | 20 concurrent: [1, 10], property 23 function main({ encodingType, duration, concurrent, size }) { property 79 while (concurrent--) write();
|
/third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-stress/ |
D | README.md | 3 This is the same as minimal-secure-streams, except you can have it perform concurrent 6 It basically forks as many times as `-c <concurrent>` and each fork does `--budget <count>` 20 -c <concurrent>|Fork this many times on init|
|
D | minimal-secure-streams.c | 559 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/test/com/google/i18n/phonenumbers/metadata/source/ |
D | BlockingMetadataBootstrappingGuardTest.java | 32 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/ |
D | ns-tcpserver.c | 74 int concurrent; /* if non-zero, act as a concurrent server */ member 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/python/Lib/test/test_importlib/partial/ |
D | cfimport.py | 13 from concurrent.futures import ThreadPoolExecutor 20 from concurrent.futures.thread import ThreadPoolExecutor
|
/third_party/node/deps/v8/include/cppgc/ |
D | README.md | 9 - Incremental and concurrent marking; 10 - Incremental and concurrent sweeping; 14 - Non-incremental and non-concurrent compaction for selected spaces; 56 ## Atomic, incremental and concurrent garbage collection 75 Using concurrent GC allows the mutator thread to spend less time on GC and more on the actual mutat… 90 With incremental/concurrent marking, step 1 is executed in a short pause after which the mutator re… 122 With incremental/concurrent sweeping, step 2 is interleaved with mutator. 123 Incremental/concurrent sweeping can be atomically finalized in case it is needed to trigger another… 124 Even with concurrent sweeping, destructors are guaranteed to run on the thread the object has been …
|
/third_party/libphonenumber/java/libphonenumber/src/com/google/i18n/phonenumbers/metadata/source/ |
D | MapBackedMetadataContainer.java | 20 import java.util.concurrent.ConcurrentHashMap; 21 import java.util.concurrent.ConcurrentMap;
|
/third_party/nghttp2/doc/bash_completion/ |
D | nghttp | 11 …concurrent-streams --header-table-size --encoder-header-table-size --padding --har --color --conti…
|
/third_party/cef/tools/yapf/yapf/ |
D | __init__.py | 223 import concurrent.futures # pylint: disable=g-import-not-at-top 225 with concurrent.futures.ProcessPoolExecutor(workers) as executor: 231 for future in concurrent.futures.as_completed(future_formats):
|
/third_party/nghttp2/doc/sources/ |
D | h2load-howto.rst | 28 The number of concurrent clients. Default: 1 31 The max concurrent streams to issue per client. Default: 1 41 using total 100000 requests, 100 concurrent clients and 10 max 42 concurrent streams:
|
/third_party/skia/platform_tools/android/apps/skottie/skottielib/src/main/java/org/skia/skottie/ |
D | SkottieRunner.java | 20 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/ |
D | Protobuf.java | 36 import java.util.concurrent.ConcurrentHashMap; 37 import java.util.concurrent.ConcurrentMap;
|