| /third_party/python/Lib/test/support/ |
| H A D | threading_helper.py | 80 is designed to cleanup threads started by the _thread.start_new_thread()
122 started = []
127 started.append(t)
130 print("Can't start %d threads, only %d threads started" %
131 (len(threads), len(started)))
141 for t in started:
143 started = [t for t in started if t.is_alive()]
144 if not started:
148 '%d minutes' % (len(started), timeou
[all...] |
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads-smp/ |
| H A D | minimal-ws-server.c | 10 * other threads cleanly. Two other threads are started, which fill
17 * the directory it was started in.
44 static int interrupted, started; variable
119 for (started = 1; started < lws_get_count_threads(context); in system_notify_cb()
120 started++) in system_notify_cb()
121 if (pthread_create(&pthread_service[started], NULL, in system_notify_cb()
123 (void *)(lws_intptr_t)started)) in system_notify_cb()
129 while ((--started) >= 1) in system_notify_cb()
130 pthread_join(pthread_service[started], in system_notify_cb()
[all...] |
| /third_party/rust/crates/humantime/src/ |
| H A D | duration.rs | 259 fn item_plural(f: &mut fmt::Formatter, started: &mut bool, in item_plural()
264 if *started { in item_plural()
271 *started = true; in item_plural()
275 fn item(f: &mut fmt::Formatter, started: &mut bool, name: &str, value: u32) in item()
279 if *started { in item()
283 *started = true; in item()
319 let ref mut started = false; in fmt()
320 item_plural(f, started, "year", years)?; in fmt()
321 item_plural(f, started, "month", months)?; in fmt()
322 item_plural(f, started, "da in fmt()
[all...] |
| /third_party/curl/tests/unit/ |
| H A D | unit2600.c | 104 struct curltime started; member
117 struct curltime started; member
127 (int)Curl_timediff(Curl_now(), current_tr->started), ctx->id); in cf_test_destroy()
145 duration_ms = Curl_timediff(Curl_now(), ctx->started); in cf_test_connect()
195 ctx->started = Curl_now(); in cf_test_create()
212 created_at = Curl_timediff(ctx->started, current_tr->started); in cf_test_create()
239 duration_ms = Curl_timediff(tr->ended, tr->started); in check_result()
261 duration_ms = Curl_timediff(tr->ended, tr->started); in check_result()
319 tr.started in test_connect()
[all...] |
| /third_party/node/test/fixtures/wpt/streams/resources/ |
| H A D | rs-utils.js | 8 this.started = false;
20 if (!this.started) {
22 this.started = true;
56 if (this.started) {
|
| /third_party/rust/crates/rustix/tests/net/ |
| H A D | unix.rs | 44 let mut started = lock.lock().unwrap(); in server() variables
45 *started = true; in server()
75 let mut started = lock.lock().unwrap(); in client() variables
76 while !*started { in client()
77 started = cvar.wait(started).unwrap(); in client()
|
| /third_party/ffmpeg/compat/windows/ |
| H A D | makedef | 63 started=0
70 started=1
75 started=0
79 if [ ${started} = 0 ]; then
|
| /third_party/skia/tools/ |
| H A D | win_dbghelp.cpp | 99 bool started = false; in printCallstack() local
103 if (!started && strncmp(start, line, strlen(start)) == 0) { in printCallstack()
104 started = true; in printCallstack()
105 } else if (started && strncmp(stop, line, strlen(stop)) == 0) { in printCallstack()
107 } else if (started) { in printCallstack()
|
| /third_party/node/test/parallel/ |
| H A D | test-fs-read-stream-concurrent-reads.js | 17 let started = 0;
23 ++started;
31 if (started < N)
|
| /third_party/python/Lib/test/ |
| H A D | test_thread.py | 115 started = []
118 started.append(None)
124 while not started:
142 started.release()
145 started = thread.allocate_lock()
148 started.acquire()
150 started.acquire()
155 "Exception ignored in thread started by")
|
| H A D | test_threading.py | 318 print(" started worker thread")
328 print(" waiting for worker thread to get started")
742 started = _thread.allocate_lock()
744 started.acquire()
747 started.release()
750 # The tstate lock is None until the thread is started
754 started.acquire()
777 started = _thread.allocate_lock()
779 started.acquire()
782 started
[all...] |
| /third_party/node/benchmark/fs/ |
| H A D | write-stream-throughput.js | 45 let started = false;
65 if (!started) {
66 started = true;
|
| /third_party/node/test/pummel/ |
| H A D | test-regress-GH-892.js | 40 let started = false;
45 if (started) return;
46 started = true;
|
| /third_party/python/Tools/ccbench/ |
| H A D | ccbench.py | 205 started = False
215 while not started:
233 started = True
309 started = False
324 while not started:
348 started = True
441 started = False
456 while not started:
482 started = True
|
| /third_party/node/deps/openssl/openssl/apps/ |
| H A D | engine.c | 94 int started = 0, err = 0; in util_flags() local
111 started = 1; in util_flags()
120 if (started) { in util_flags()
125 started = 1; in util_flags()
128 if (started) { in util_flags()
133 started = 1; in util_flags()
140 if (started) in util_flags()
|
| /third_party/openssl/apps/ |
| H A D | engine.c | 94 int started = 0, err = 0; in util_flags() local
111 started = 1; in util_flags()
120 if (started) { in util_flags()
125 started = 1; in util_flags()
128 if (started) { in util_flags()
133 started = 1; in util_flags()
140 if (started) in util_flags()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-hugeurl/ |
| H A D | minimal-secure-streams.c | 150 char started; member
176 if (!m->started) in lws_httpbin_json_cb()
179 m->started = 1; in lws_httpbin_json_cb()
183 if (!m->started) in lws_httpbin_json_cb()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_timedwait/ |
| H A D | 2-5.c | 71 int started; /* # of threads which are already waiting */ member
92 /* Tell the parent this thread is started */ in threaded()
93 data.started++; in threaded()
295 data.started = 0; in main()
310 /* Wait for the threads to be started */ in main()
315 loc_started = data.started; in main()
|
| /third_party/skia/third_party/externals/angle2/util/ |
| H A D | test_utils_unittest.cpp | 161 EXPECT_TRUE(process->started()); in TEST()
177 EXPECT_TRUE(process->started()); in TEST()
203 EXPECT_TRUE(process->started()); in TEST()
235 EXPECT_TRUE(process->started()); in TEST()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/ap/ |
| H A D | airtime_policy.c | 148 if (!bss->started || !bss->conf->airtime_weight) in update_airtime_weights()
167 if (!bss->started || !bss->conf->airtime_weight) in update_airtime_weights()
194 if (!bss->started || !bss->conf->airtime_weight) in update_airtime_weights()
217 if (!bss->started || !bss->conf->airtime_weight) in update_airtime_weights()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/ap/ |
| H A D | airtime_policy.c | 144 if (!bss->started || !bss->conf->airtime_weight) in update_airtime_weights()
163 if (!bss->started || !bss->conf->airtime_weight) in update_airtime_weights()
190 if (!bss->started || !bss->conf->airtime_weight) in update_airtime_weights()
213 if (!bss->started || !bss->conf->airtime_weight) in update_airtime_weights()
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_server.py | 78 started = threading.Event()
82 started.wait(5)
100 started.set()
|
| /third_party/curl/lib/ |
| H A D | cf-https-connect.c | 56 struct curltime started; member
101 struct curltime started; /* when connect started */ member
120 b->started = Curl_now(); in cf_hc_baller_init()
169 winner->name, (int)Curl_timediff(Curl_now(), winner->started), in baller_connected()
216 elapsed_ms = Curl_timediff(now, ctx->started); in time_to_start_h21()
259 ctx->started = now; in cf_hc_connect()
|
| /third_party/curl/tests/http/clients/ |
| H A D | h2-download.c | 92 int started; member
249 t->started = 1; in main()
312 if(!t->started) { in main()
319 t->started = 1; in main()
325 /* all started */ in main()
|
| /third_party/mesa3d/src/tool/pps/ |
| H A D | pps_datasource.cc | 27 /// Synchronize access to started_cv and started
30 static bool started = false; member
106 started = true; in OnStart()
132 started = false; in OnStop()
138 if (!started) { in wait_started()
140 started_cv.wait(lock, [] { return started; }); in wait_started()
|