Home
last modified time | relevance | path

Searched +defs:run +defs:queue (Results 1 – 25 of 28) sorted by relevance

12

/third_party/node/test/message/
Dstdin_messages.js28 function run(cmd, strict, cb) { function
39 const queue = variable
Deval_messages.js28 function run(cmd, strict, cb) { function
38 const queue = variable
/third_party/icu/ohos_icu4j/src/main/java/ohos/global/icu/impl/
DICUNotifier.java120 private final List<EventListener[]> queue = new ArrayList<EventListener[]>(); field in ICUNotifier.NotifyThread
129 public void queue(EventListener[] list) { in queue() method in ICUNotifier.NotifyThread
141 public void run() { in run() method in ICUNotifier.NotifyThread
/third_party/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/
DICUNotifier.java118 private final List<EventListener[]> queue = new ArrayList<EventListener[]>(); field in ICUNotifier.NotifyThread
127 public void queue(EventListener[] list) { in queue() method in ICUNotifier.NotifyThread
139 public void run() { in run() method in ICUNotifier.NotifyThread
/third_party/node/deps/npm/node_modules/promise-call-limit/dist/esm/
Dindex.js9 export const callLimit = (queue, { limit = defLimit, rejectLate } = {}) => new Promise((res, rej) =… argument
31 const run = () => { function
/third_party/rust/crates/minimal-lexical/etc/correctness/test-parse-random/
Druntests.py160 def run(test): function
191 def interact(proc, queue): argument
250 def init_worker(test, mailbox, queue, done): argument
263 def do_work(queue): argument
/third_party/python/Lib/
Dsched.py103 def run(self, blocking=True): member in scheduler
155 def queue(self): member in scheduler
/third_party/python/Lib/test/
Dtest_queue.py33 def run(self): member in _TriggerThread
251 queue = py_queue variable in PyQueueTest
256 queue = c_queue variable in CQueueTest
267 queue = py_queue variable in PyLifoQueueTest
272 queue = c_queue variable in CLifoQueueTest
283 queue = py_queue variable in PyPriorityQueueTest
288 queue = c_queue variable in CPriorityQueueTest
413 queue = py_queue variable in PyFailingQueueTest
418 queue = c_queue variable in CFailingQueueTest
603 queue = py_queue variable in PySimpleQueueTest
[all …]
D_test_multiprocessing.py88 def close_queue(queue): argument
841 def run(self): member in _UpperCaser
961 def _test_put(cls, queue, child_can_start, parent_can_continue): argument
1027 def _test_get(cls, queue, child_can_start, parent_can_continue): argument
1090 def _test_fork(cls, queue): argument
1873 def _test_wait_return_f(cls, barrier, queue): argument
5453 def _test_empty(cls, queue, child_can_start, parent_can_continue): argument
/third_party/vk-gl-cts/framework/platform/android/
DtcuAndroidRenderActivity.cpp226 void RenderThread::run (void) in run() function in tcu::Android::RenderThread
379 void RenderActivity::onInputQueueCreated (AInputQueue* queue) in onInputQueueCreated()
385 void RenderActivity::onInputQueueDestroyed (AInputQueue* queue) in onInputQueueDestroyed()
/third_party/node/deps/npm/node_modules/promise-call-limit/dist/commonjs/
Dindex.js35 const callLimit = (queue, { limit = defLimit, rejectLate } = {}) => new Promise((res, rej) => { argument
57 const run = () => { function
/third_party/ltp/testcases/kernel/fs/read_all/
Dread_all.c58 struct queue { struct
69 struct queue *q; argument
678 static void run(void) in run() function
/third_party/skia/tools/skpbench/
Dskpbench.py127 def __init__(self, queue, proc): argument
132 def run(self): member in SubprocessMonitor
/third_party/node/test/parallel/
Dtest-stream-writev.js28 const queue = []; variable
39 function run() { function
/third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/synchronization/
DvktSynchronizationInternallySynchronizedObjectsTests.cpp146 Queues& queue = m_queues[getQueueFamilyIndex(queueFamilyIndexNdx)]; in getFreeQueue() local
363 VkQueue queue; in executeComputePipeline() local
437 VkQueue queue; in executeGraphicPipeline() local
565 void run (void) in run() function in vkt::synchronization::__anon599e8fc60111::ThreadGroupThread
620 TestStatus run (void) in run() function in vkt::synchronization::__anon599e8fc60111::ThreadGroup
DvktSynchronizationTimelineSemaphoreTests.cpp111 const VkQueue queue, in deviceSignal()
177 const VkQueue queue = m_context.getUniversalQueue(); in iterate() local
296 const VkQueue queue = m_context.getUniversalQueue(); in iterate() local
423 const VkQueue queue = m_context.getUniversalQueue(); in iterate() local
531 virtual void run () in run() function in vkt::synchronization::__anon436603350111::MonotonicallyIncrementChecker
575 const VkQueue queue = context.getUniversalQueue(); in maxDifferenceValueCase() local
638 const VkQueue queue = context.getUniversalQueue(); in initialValueCase() local
805 virtual void run () in run() function in vkt::synchronization::__anon436603350111::HostCopyThread
923 const VkQueue queue = m_context.getUniversalQueue(); in iterate() local
1272 VkQueue queue; member
[all …]
/third_party/vk-gl-cts/external/vulkancts/modules/vulkan/synchronization/
DvktSynchronizationInternallySynchronizedObjectsTests.cpp146 Queues& queue = m_queues[getQueueFamilyIndex(queueFamilyIndexNdx)]; in getFreeQueue() local
363 VkQueue queue; in executeComputePipeline() local
437 VkQueue queue; in executeGraphicPipeline() local
565 void run (void) in run() function in vkt::synchronization::__anona0234e860111::ThreadGroupThread
620 TestStatus run (void) in run() function in vkt::synchronization::__anona0234e860111::ThreadGroup
DvktSynchronizationTimelineSemaphoreTests.cpp110 const VkQueue queue, in deviceSignal()
176 const VkQueue queue = m_context.getUniversalQueue(); in iterate() local
295 const VkQueue queue = m_context.getUniversalQueue(); in iterate() local
422 const VkQueue queue = m_context.getUniversalQueue(); in iterate() local
535 virtual void run () in run() function in vkt::synchronization::__anon4ac6a1f50111::MonotonicallyIncrementChecker
579 const VkQueue queue = context.getUniversalQueue(); in maxDifferenceValueCase() local
642 const VkQueue queue = context.getUniversalQueue(); in initialValueCase() local
810 virtual void run () in run() function in vkt::synchronization::__anon4ac6a1f50111::HostCopyThread
928 const VkQueue queue = m_context.getUniversalQueue(); in iterate() local
1280 VkQueue queue; member
[all …]
/third_party/vk-gl-cts/external/vulkancts/modules/vulkan/wsi/
DvktWsiPresentIdWaitTests.cpp238 const vk::VkQueue queue; member
474 …kDevice device, vk::VkSwapchainKHR swapchain, size_t swapchainSize, vk::VkQueue queue, size_t fram… in recordAndSubmitFrame()
516 …estStatus PresentIdWaitSimpleInstance::run (const vk::DeviceInterface& vkd, vk::VkDevice device, v… in run() function in vkt::wsi::__anon95333a9f0111::PresentIdWaitSimpleInstance
/third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/wsi/
DvktWsiPresentIdWaitTests.cpp238 const vk::VkQueue queue; member
474 …kDevice device, vk::VkSwapchainKHR swapchain, size_t swapchainSize, vk::VkQueue queue, size_t fram… in recordAndSubmitFrame()
516 …estStatus PresentIdWaitSimpleInstance::run (const vk::DeviceInterface& vkd, vk::VkDevice device, v… in run() function in vkt::wsi::__anon7b6c3bdf0111::PresentIdWaitSimpleInstance
/third_party/node/src/
Dnode_contextify.cc123 MicrotaskQueue* queue = in New() local
217 MicrotaskQueue* queue) { in CreateV8Context()
1072 auto run = [&]() { in EvalMachine() local
/third_party/vk-gl-cts/external/vulkancts/modules/vulkan/image/
DvktImageMutableTests.cpp840 …UploadDownloadExecutor(Context& context, VkDevice device, VkQueue queue, deUint32 queueFamilyIndex… in UploadDownloadExecutor()
1019 void UploadDownloadExecutor::run(Context& context, VkBuffer buffer) in run() function in vkt::image::UploadDownloadExecutor
1921 const VkQueue queue; member
/third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/image/
DvktImageMutableTests.cpp840 …UploadDownloadExecutor(Context& context, VkDevice device, VkQueue queue, deUint32 queueFamilyIndex… in UploadDownloadExecutor()
1019 void UploadDownloadExecutor::run(Context& context, VkBuffer buffer) in run() function in vkt::image::UploadDownloadExecutor
1921 const VkQueue queue; member
/third_party/node/lib/internal/webstreams/
Dreadablestream.js1400 async function run() { function
2324 queue: [], property
3122 queue: [], property
/third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/binding_model/
DvktBindingDescriptorCopyTests.cpp980 const VkQueue queue = context.getUniversalQueue(); in init() local
1802 tcu::TestStatus DescriptorCommands::run (Context& context) in run() function in vkt::BindingModel::__anonf75115560111::DescriptorCommands
1806 const VkQueue queue = context.getUniversalQueue(); in run() local

12