/third_party/python/Lib/test/test_asyncio/ |
H A D | test_queues.py | 144 started = asyncio.Event() 149 started.set() 155 await started.wait() 228 started = asyncio.Event() 233 started.set() 241 await started.wait()
|
H A D | test_waitfor.py | 99 started = loop.create_future() 104 started.set_result(None) 112 await started
|
/third_party/node/src/api/ |
H A D | hooks.cc | 96 bool started = false; member 143 info->started = true; in RunAsyncCleanupHook() 164 if (handle->info->started) return; in RemoveEnvironmentCleanupHookInternal()
|
/third_party/node/test/parallel/ |
H A D | test-net-connect-options-allowhalfopen.js | 42 `server connection ${srvConn} is started by client ${this.clientId}`); 100 console.log(`Server started listening at ${host}:${port}`);
|
H A D | test-whatwg-transformstream.js | 54 this.started = true; 69 assert(transform.started);
|
/third_party/icu/tools/unicodetools/com/ibm/rbm/ |
H A D | RBManager.java | 239 boolean started = false; in RBManager() 242 if (!started && array[i] != ' ' && array[i] != '\t') started = true; in RBManager() 243 if (started && (array[i] == '=' || array[i] == ':' || array[i] == ' ' || array[i] == '\t')) { in RBManager() 341 boolean started = false; in RBManager() 344 if (!started && array[j] != ' ' && array[j] != '\t') started = true; in RBManager() 345 if (started && (array[j] == '=' || array[j] == ':' || array[j] == ' ' || array[j] == '\t')) { in RBManager()
|
/third_party/python/Lib/test/ |
H A D | test_contextlib.py | 440 started = False variable in mycontext 445 self.started = True 466 self.assertTrue(context.started) 494 self.assertTrue(context.started) 505 self.assertTrue(context.started) 570 started = False variable in TestContextDecorator.test_contextdecorator_as_mixin.somecontext 574 self.started = True 587 self.assertTrue(context.started)
|
/third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/vulkan/ |
H A D | ContextVk.h | 515 ASSERT(mRenderPassCommands->started()); in onImageRenderPassRead() 526 ASSERT(mRenderPassCommands->started()); in onImageRenderPassWrite() 535 ASSERT(mRenderPassCommands->started()); in onColorDraw() 545 ASSERT(mRenderPassCommands->started()); in onDepthStencilDraw() 552 if (mRenderPassCommands->started()) in finalizeImageLayout() 576 // Only returns true if we have a started RP and we've run setupDraw. 580 return mRenderPassCommandBuffer && mRenderPassCommands->started(); in hasStartedRenderPass() 596 ASSERT(mRenderPassCommands->started()); in getStartedRenderPassCommands() 688 // Dirty bits that must be processed before the render pass is started. The handlers for 698 // Dirty bits that must be processed after the render pass is started [all...] |
/third_party/backends/backend/ |
H A D | cardscan.c | 879 if ( s->started ) { in sane_control_option() 936 * a scan has been started (sane_start() has been called) and the 941 * Calling this function before a scan has actually started allows, 980 * Called by SANE when a page acquisition operation is to be started. 991 if(s->started){ in sane_start() 998 s->started=1; in sane_start() 1174 if(!s->started){ in sane_read() 1381 s->started = 0; in sane_cancel()
|
H A D | kodak.c | 1376 if ( s->started ) { in sane_control_option() 1534 * a scan has been started (sane_start() has been called) and the 1539 * Calling this function before a scan has actually started allows, 1561 /* started? get param data from image header */ in sane_get_parameters() 1562 if(s->started){ in sane_get_parameters() 1621 /* not started? get param data from user input */ in sane_get_parameters() 1677 * Called by SANE when a page acquisition operation is to be started. 1683 * hence, we spend a lot of time playing with s->started, etc. 1693 DBG (15, "started=%d, source=%d\n", s->started, in sane_start() [all...] |
H A D | cardscan.h | 98 int started; member
|
/third_party/ffmpeg/libavcodec/ |
H A D | mediacodecdec_common.h | 50 int started; member
|
/third_party/skia/third_party/externals/angle2/util/ |
H A D | test_utils.h | 65 virtual bool started() = 0; 122 // On success, returns a Process pointer with started() == true. 123 // On failure, returns a Process pointer with started() == false.
|
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/ap/ |
H A D | bss_load.c | 49 if (!(hapd->beacon_set_done && hapd->started)) in update_channel_utilization()
|
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/ap/ |
H A D | bss_load.c | 49 if (!(hapd->beacon_set_done && hapd->started)) in update_channel_utilization()
|
/third_party/curl/lib/ |
H A D | connect.c | 345 struct curltime started; /* start of current attempt */ member 351 BIT(has_started); /* attempts have started */ 372 struct curltime started; member 492 * could be created and the non-blocking connect started. 505 baller->started = Curl_now(); in baller_start() 562 else if(Curl_timediff(*now, baller->started) >= baller->timeoutms) { in baller_connect() 638 /* next attempt was started */ in is_connected() 671 Curl_timediff(now, ctx->started) >= baller->delay_ms) { in is_connected() 702 CURL_TRC_CF(data, cf, "%s assess started=%d, result=%d", in is_connected() 760 ctx->started in start_connect() [all...] |
/third_party/libinput/src/ |
H A D | evdev-mt-touchpad-gestures.c | 155 if (tp->gesture.started) in tp_gesture_start() 189 tp->gesture.started = true; in tp_gesture_start() 1352 if (!tp->gesture.started) { in tp_gesture_end() 1388 tp->gesture.started = false; in tp_gesture_end() 1401 if (tp->gesture.started && tp->gesture.state != GESTURE_STATE_HOLD) in tp_gesture_cancel_motion_gestures() 1442 } else if (!tp->gesture.started) { in tp_gesture_handle_state()
|
/third_party/python/Lib/ |
H A D | difflib.py | 480 # the dummy we started with), and make the second block the 1137 started = False 1139 if not started: 1140 started = True 1226 started = False 1228 if not started: 1229 started = True
|
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/wps/ |
H A D | wps_upnp.c | 749 "WPS UPnP: Subscription %p (SID %s) started with %s", in subscription_start() 979 if (!sm || !sm->started) in upnp_wps_device_stop() 999 sm->started = 0; in upnp_wps_device_stop() 1014 if (sm->started) in upnp_wps_device_start() 1019 sm->started = 1; in upnp_wps_device_start()
|
H A D | wps_upnp_i.h | 127 int started; /* nonzero if we are active */ member
|
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/wps/ |
H A D | wps_upnp.c | 771 "WPS UPnP: Subscription %p (SID %s) started with %s", in subscription_start() 1015 if (!sm || !sm->started) in upnp_wps_device_stop() 1035 sm->started = 0; in upnp_wps_device_stop() 1050 if (sm->started) in upnp_wps_device_start() 1055 sm->started = 1; in upnp_wps_device_start()
|
H A D | wps_upnp_i.h | 127 int started; /* nonzero if we are active */ member
|
/third_party/FreeBSD/sys/dev/usb/ |
H A D | usb_core.h | 100 uint8_t started:1; /* keeps track of started or stopped */ member
|
/third_party/mesa3d/.gitlab-ci/common/ |
H A D | init-stage2.sh | 31 # Space separated values with the PIDS of the processes started in the 119 echo "touch /xorg-started; sleep 100000" > /xorg-script 126 if [ -e /xorg-started ]; then
|
/third_party/skia/third_party/externals/abseil-cpp/absl/time/internal/cctz/src/ |
H A D | time_zone_lookup_test.cc | 674 auto load_zones = [ready_future](std::promise<void>* started, in TEST() 676 started->set_value(); in TEST() 693 std::promise<void> started; in TEST() local 694 threads.emplace_back(load_zones, &started, &thread_failures[i]); in TEST() 695 started.get_future().wait(); in TEST()
|