| /third_party/python/Lib/concurrent/futures/ |
| H A D | thread.py | 10 import queue namespace
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/ |
| H A D | containers.h | 61 MARL_NO_EXPORT inline T take(deque<T>& queue) { in take() argument
|
| /third_party/spirv-tools/source/fuzz/ |
| H A D | call_graph.cpp | 106 std::queue<uint32_t> queue; in ComputeTopologicalOrderOfFunctions() local
167 std::queue<uint32_t> queue; GetIndirectCallees() local
[all...] |
| /third_party/skia/third_party/externals/dawn/src/tests/unittests/validation/ |
| H A D | BufferValidationTests.cpp | 67 wgpu::Queue queue; member in BufferValidationTest
[all...] |
| H A D | ExternalTextureTests.cpp | 53 wgpu::Queue queue; member in __anon20580::ExternalTextureTest
[all...] |
| H A D | VideoViewsValidationTests.cpp | 315 wgpu::Queue queue = device.GetQueue(); in TEST_F() local
333 wgpu::Queue queue = device.GetQueue(); in TEST_F() local
|
| /third_party/skia/third_party/externals/dawn/src/tests/unittests/wire/ |
| H A D | WireTest.h | 132 WGPUQueue queue; member in WireTest
|
| /third_party/python/Modules/clinic/ |
| H A D | termios.c.h | 169 int queue; in termios_tcflush() local
[all...] |
| /third_party/vk-gl-cts/external/vulkancts/modules_no_buildgn/vulkan/protected_memory/ |
| H A D | vktProtectedMemImageValidator.cpp | 138 const vk::VkQueue queue = ctx.getQueue(); in validateImage() local
|
| /foundation/ai/intelligent_voice_framework/services/intell_voice_engine/server/wakeup/ |
| H A D | wakeup_source_process.cpp | 43 auto queue = std::make_unique<Uint8ArrayBufferQueue>(); in Init() local
[all...] |
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | engine_manager.cpp | 211 std::shared_ptr<Queue<Task>> queue = queuePool->Pop(); in CreateEngine() local
|
| /foundation/graphic/graphic_3d/lume/LumeRender/src/vulkan/ |
| H A D | render_backend_vk.cpp | 140 RenderBackendVk( Device& dev, GpuResourceManager& gpuResourceManager, const CORE_NS::IParallelTaskQueue::Ptr& queue) RenderBackendVk() argument
[all...] |
| /foundation/multimedia/av_codec/test/unittest/decoder_filter_test/ |
| H A D | surface_encoder_filter_unit_test.h | 78 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| /foundation/multimedia/av_codec/test/unittest/filter_test/ |
| H A D | video_capture_filter_unit_test.h | 103 void OnLinkedResult(const sptr<AVBufferQueueProducer> &queue, std::shared_ptr<Meta> &meta) in OnLinkedResult() argument
|
| H A D | audio_capture_filter_unit_test.cpp | 333 sptr<AVBufferQueueProducer> queue = new MockOutputBufferQueue(); in HWTEST_F() local
|
| H A D | muxer_filter_unit_test.h | 46 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, in OnLinkedResult() argument
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | cpuworker_manager.cpp | 119 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(iter->first)->localFifo); in StealTaskBatch() local
|
| H A D | scpuworker_manager.cpp | 186 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(thread)->localFifo); in PickUpTaskBatch() local
|
| /foundation/communication/dsoftbus/core/common/include/ |
| H A D | softbus_queue.h | 73 static inline int32_t QueueIsEmpty(LockFreeQueue* queue) in QueueIsEmpty() argument
94 QueueSingleProducerEnqueue(LockFreeQueue *queue, const void *node) QueueSingleProducerEnqueue() argument
143 QueueMultiProducerEnqueue(LockFreeQueue* queue, const void* node) QueueMultiProducerEnqueue() argument
207 QueueSingleConsumerDequeue(LockFreeQueue* queue, void** node) QueueSingleConsumerDequeue() argument
260 QueueMultiConsumerDequeue(LockFreeQueue *queue, void **node) QueueMultiConsumerDequeue() argument
[all...] |
| /foundation/communication/dsoftbus/core/connection/br/src/ |
| H A D | softbus_conn_br_send_queue.c | 37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBrQueue() local
58 DestroyBrQueue(ConnectionQueue *queue) DestroyBrQueue() argument
[all...] |
| /foundation/communication/dsoftbus/core/connection/ble/src/ |
| H A D | softbus_conn_ble_send_queue.c | 37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBleQueue() local
58 DestroyBleQueue(ConnectionQueue *queue) DestroyBleQueue() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | executor.h | 65 void Bind(PriorityQueue<InnerTask, Time, TaskId> *queue, std::function<bool(std::shared_ptr<Executor>)> idle, in Bind() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | task_pool_impl.cpp | 163 Task TaskPoolImpl::ReapTask(TaskQueue *&queue) in ReapTask() argument
187 void TaskPoolImpl::GetTask(Task &task, TaskQueue *&queue) in GetTask() argument
|
| /foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor.h | 79 void Bind(PriorityQueue<InnerTask, Time, TaskId> *queue, std::function<bool(std::shared_ptr<Executor>)> idle, in Bind() argument
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_thread.c | 36 Queue *queue; member
84 Queue *queue; member
106 static void RunAllTaskInQueue(Queue *queue) in RunAllTaskInQueue() argument
123 FreeProcessingQueue(void *queue) FreeProcessingQueue() argument
139 BtmProcessingQueue *queue = NULL; FindProcessingQueueById() local
191 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); BTM_CreateProcessingQueue() local
210 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); BTM_DeleteProcessingQueue() local
234 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); BTM_RunTaskInProcessingQueue() local
[all...] |