| /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...] |
| /kernel/linux/linux-5.10/drivers/net/wireless/ath/wil6210/ |
| H A D | p2p.c | 180 u8 started = p2p->discovery_started; in wil_p2p_stop_discovery() local
184 /* discovery not really started, only pending */ in wil_p2p_stop_discovery()
193 return started; in wil_p2p_stop_discovery()
200 u8 started; in wil_p2p_cancel_listen() local
211 started = wil_p2p_stop_discovery(vif); in wil_p2p_cancel_listen()
215 if (!started) { in wil_p2p_cancel_listen()
216 wil_err(wil, "listen not started\n"); in wil_p2p_cancel_listen()
238 u8 started; in wil_p2p_listen_expired() local
243 started = wil_p2p_stop_discovery(vif); in wil_p2p_listen_expired()
246 if (!started) in wil_p2p_listen_expired()
266 u8 started; wil_p2p_search_expired() local
[all...] |
| /kernel/linux/linux-6.6/drivers/net/wireless/ath/wil6210/ |
| H A D | p2p.c | 180 u8 started = p2p->discovery_started; in wil_p2p_stop_discovery() local
184 /* discovery not really started, only pending */ in wil_p2p_stop_discovery()
193 return started; in wil_p2p_stop_discovery()
200 u8 started; in wil_p2p_cancel_listen() local
211 started = wil_p2p_stop_discovery(vif); in wil_p2p_cancel_listen()
215 if (!started) { in wil_p2p_cancel_listen()
216 wil_err(wil, "listen not started\n"); in wil_p2p_cancel_listen()
238 u8 started; in wil_p2p_listen_expired() local
243 started = wil_p2p_stop_discovery(vif); in wil_p2p_listen_expired()
246 if (!started) in wil_p2p_listen_expired()
266 u8 started; wil_p2p_search_expired() local
[all...] |
| /foundation/resourceschedule/ffrt/src/sched/ |
| H A D | workgroup_internal.h | 39 bool started; member
126 if (wg->started) { in WorkgroupStartInterval()
129 wg->started = true; in WorkgroupStartInterval()
134 if (!wg->started) { in WorkgroupStopInterval()
137 wg->started = false; in WorkgroupStopInterval()
|
| H A D | multi_workgroup.cpp | 38 wg->started = false; in WorkgroupInit()
255 if (wg->started) { in WorkgroupStartInterval()
261 wg->started = true; in WorkgroupStartInterval()
274 if (!wg->started) { in WorkgroupStopInterval()
281 wg->started = false; in WorkgroupStopInterval()
|
| /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/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...] |
| /foundation/resourceschedule/ffrt/test/ut/ |
| H A D | multi_workgroup_test.cpp | 128 p->started = true; in HWTEST_F()
137 p->started = false; in HWTEST_F()
140 EXPECT_TRUE(p->started); in HWTEST_F()
157 p->started = false; in HWTEST_F()
166 p->started = true; in HWTEST_F()
169 EXPECT_FALSE(p->started); in HWTEST_F()
|
| /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
|
| /kernel/linux/linux-5.10/tools/virtio/ |
| H A D | virtio_test.c | 173 long started = 0, completed = 0, next_reset = reset_n; in run_test() local
189 started_before = started; in run_test()
195 while (started < bufs && in run_test()
196 (started - completed) < batch) { in run_test()
199 dev->buf + started, in run_test()
203 started > started_before) in run_test()
210 ++started; in run_test()
218 if (started >= bufs) in run_test()
251 started = completed; in run_test()
256 if (completed == completed_before && started in run_test()
[all...] |
| /kernel/linux/linux-6.6/tools/virtio/ |
| H A D | virtio_test.c | 173 long started = 0, completed = 0, next_reset = reset_n; in run_test() local
189 started_before = started; in run_test()
195 while (started < bufs && in run_test()
196 (started - completed) < batch) { in run_test()
199 dev->buf + started, in run_test()
203 started > started_before) in run_test()
210 ++started; in run_test()
218 if (started >= bufs) in run_test()
251 started = completed; in run_test()
256 if (completed == completed_before && started in run_test()
[all...] |
| /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/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/benchmark/fs/ |
| H A D | write-stream-throughput.js | 45 let started = false;
65 if (!started) {
66 started = true;
|
| /kernel/linux/linux-6.6/arch/riscv/kvm/ |
| H A D | vcpu_pmu.c | 272 if (fevent->started) in kvm_riscv_vcpu_pmu_incr_fw()
367 /* Check if the counter was already started for some reason */ in kvm_riscv_vcpu_pmu_ctr_start()
368 if (kvpmu->fw_event[fevent_code].started) { in kvm_riscv_vcpu_pmu_ctr_start()
373 kvpmu->fw_event[fevent_code].started = true; in kvm_riscv_vcpu_pmu_ctr_start()
376 if (unlikely(pmc->started)) { in kvm_riscv_vcpu_pmu_ctr_start()
382 pmc->started = true; in kvm_riscv_vcpu_pmu_ctr_start()
422 if (!kvpmu->fw_event[fevent_code].started) in kvm_riscv_vcpu_pmu_ctr_stop()
425 kvpmu->fw_event[fevent_code].started = false; in kvm_riscv_vcpu_pmu_ctr_stop()
427 if (pmc->started) { in kvm_riscv_vcpu_pmu_ctr_stop()
430 pmc->started in kvm_riscv_vcpu_pmu_ctr_stop()
[all...] |
| /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")
|
| /third_party/node/test/pummel/ |
| H A D | test-regress-GH-892.js | 40 let started = false;
45 if (started) return;
46 started = true;
|
| /kernel/linux/linux-5.10/tools/virtio/ringtest/ |
| H A D | main.c | 110 int started = 0; in run_guest() local
123 if (started < bufs && in run_guest()
124 started - completed < max_outstanding) { in run_guest()
127 ++started; in run_guest()
149 assert(started <= bufs); in run_guest()
|
| /kernel/linux/linux-6.6/tools/virtio/ringtest/ |
| H A D | main.c | 110 int started = 0; in run_guest() local
123 if (started < bufs && in run_guest()
124 started - completed < max_outstanding) { in run_guest()
127 ++started; in run_guest()
149 assert(started <= bufs); in run_guest()
|
| /kernel/linux/linux-5.10/net/mac80211/ |
| H A D | offchannel.c | 203 if (!roc->started) in ieee80211_end_finished_rocs()
242 roc->started = true; in ieee80211_handle_roc_started()
268 if (!roc->started) in ieee80211_hw_roc_start()
304 if (WARN_ON(roc->started)) in _ieee80211_start_next_roc()
336 tmp->started = true; in _ieee80211_start_next_roc()
347 tmp->started = true; in _ieee80211_start_next_roc()
352 * treat it as though the ROC operation started properly, so in _ieee80211_start_next_roc()
394 /* defer roc if driver is not started (i.e. during reconfig) */ in ieee80211_start_next_roc()
401 if (WARN_ON_ONCE(roc->started)) in ieee80211_start_next_roc()
428 if (!roc->started) { in __ieee80211_roc_work()
[all...] |
| /kernel/linux/linux-6.6/net/mac80211/ |
| H A D | offchannel.c | 205 if (!roc->started) in ieee80211_end_finished_rocs()
244 roc->started = true; in ieee80211_handle_roc_started()
270 if (!roc->started) in ieee80211_hw_roc_start()
306 if (WARN_ON(roc->started)) in _ieee80211_start_next_roc()
338 tmp->started = true; in _ieee80211_start_next_roc()
349 tmp->started = true; in _ieee80211_start_next_roc()
354 * treat it as though the ROC operation started properly, so in _ieee80211_start_next_roc()
396 /* defer roc if driver is not started (i.e. during reconfig) */ in ieee80211_start_next_roc()
403 if (WARN_ON_ONCE(roc->started)) in ieee80211_start_next_roc()
430 if (!roc->started) { in __ieee80211_roc_work()
[all...] |
| /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
|