| /third_party/skia/third_party/externals/swiftshader/tests/VulkanWrapper/ |
| H A D | VulkanTester.hpp | 48 vk::Queue queue; member in VulkanTester
|
| /third_party/skia/tools/gpu/d3d/ |
| H A D | D3DTestUtils.cpp | 66 gr_cp<ID3D12CommandQueue> queue; in CreateD3DBackendContext() local
|
| /third_party/skia/third_party/externals/dawn/src/tests/unittests/validation/ |
| H A D | QueueWriteBufferValidationTests.cpp | 34 wgpu::Queue queue; member in QueueWriteBufferValidationTest
[all...] |
| /arkcompiler/ets_runtime/ecmascript/mem/shared_heap/ |
| H A D | shared_gc.cpp | 135 ProcessQueue *queue = sHeap_->GetWorkManager()->GetWeakReferenceQueue(i); in UpdateRecordWeakReference() local
|
| /arkcompiler/runtime_core/libpandabase/tests/ringbuf/ |
| H A D | lock_free_ring_buffer_test.cpp | 58 std::queue<size_t> queue; in TEST() local
[all...] |
| /arkcompiler/runtime_core/static_core/libpandabase/tests/ringbuf/ |
| H A D | lock_free_ring_buffer_test.cpp | 60 std::queue<size_t> queue; in TEST() local
[all...] |
| /arkcompiler/runtime_core/static_core/libpandabase/taskmanager/utils/ |
| H A D | worker_thread_local_queue.h | 96 LocalTaskQueue &queue = perPropertiesQueue_.at(priority); in Pop() local
|
| /arkcompiler/runtime_core/static_core/libpandabase/tests/taskmanager/ |
| H A D | task_utils_test.cpp | 36 internal::SPMCLockFreeQueue<int> queue; in TEST_F() local
66 internal::SPMCLockFreeQueue<int> queue; in TEST_F() local
[all...] |
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/g1/ |
| H A D | update_remset_task_queue.cpp | 25 UpdateRemsetTaskQueue(G1GC<LanguageConfig> *gc, GCG1BarrierSet::ThreadLocalCardQueues *queue, os::memory::Mutex *queueLock, size_t regionSize, bool updateConcurrent, size_t minConcurrentCardsToProcess, size_t hotCardsProcessingFrequency) UpdateRemsetTaskQueue() argument
|
| H A D | update_remset_thread.cpp | 26 UpdateRemsetThread(G1GC<LanguageConfig> *gc, GCG1BarrierSet::ThreadLocalCardQueues *queue, os::memory::Mutex *queueLock, size_t regionSize, bool updateConcurrent, size_t minConcurrentCardsToProcess, size_t hotCardsProcessingFrequency) UpdateRemsetThread() argument
|
| /arkcompiler/runtime_core/static_core/verification/jobs/ |
| H A D | service.h | 57 PandaDeque<TaskProcessor *> queue; member
|
| /base/notification/eventhandler/test/systemtest/ems_event_queue_system_test/ |
| H A D | ems_event_queue_system_test.cpp | 66 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); in HWTEST_F() local
87 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); in HWTEST_F() local
103 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); in HWTEST_F() local
115 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); HWTEST_F() local
129 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); HWTEST_F() local
[all...] |
| /base/update/sys_installer/services/module_update/service/src/ |
| H A D | module_update_consumer.cpp | 32 ModuleUpdateConsumer::ModuleUpdateConsumer(ModuleUpdateQueue &queue, in ModuleUpdateConsumer() argument
|
| /foundation/ai/ai_engine/test/common/queuepool/ |
| H A D | queuepool_test.cpp | 70 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F() local
102 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F() local
120 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
156 std::shared_ptr<Queue<int>> queue; HWTEST_F() local
179 std::shared_ptr<Queue<int>> queue; HWTEST_F() local
215 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
236 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
257 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
274 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
294 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
314 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
340 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
360 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
382 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
411 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
429 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
458 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
490 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
[all...] |
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | sync_msg_handler.cpp | 28 SyncMsgHandler::SyncMsgHandler(Queue<Task> &queue, IPlugin *pluginAlgorithm) in SyncMsgHandler() argument
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler/ |
| H A D | event_queue.h | 223 std::list<InnerEvent::Pointer> queue; global() member
[all...] |
| /foundation/multimedia/av_codec/test/unittest/decoder_filter_test/ |
| H A D | audio_decoder_filter_unit_test.h | 75 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| H A D | video_resize_filter_unit_test.h | 73 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 | subtitle_sink_filter_unit_test.cpp | 40 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta) in OnLinkedResult() argument
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | loop_api.cpp | 25 ffrt_loop_t ffrt_loop_create(ffrt_queue_t queue) in ffrt_loop_create() argument
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A D | queue_adapter.c | 26 LockFreeQueue *queue;
member
31 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)SAMGR_Malloc(sizeof(LockFreeBlockQueue));
in QUEUE_Create() local
51 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Put() local
67 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Pop() local
82 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Destroy() local
[all...] |
| /foundation/communication/dsoftbus/core/common/queue/ |
| H A D | softbus_queue.c | 32 int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum) in QueueInit() argument
77 QueueCountGet(const LockFreeQueue* queue, uint32_t* count) QueueCountGet() argument
105 LockFreeQueue *queue = (LockFreeQueue *)SoftBusCalloc(queueSize); CreateQueue() local
[all...] |
| /foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/ |
| H A D | wifi_direct_event_template_dispatcher.h | 28 WifiDirectEventTemplateDispatcher(WifiDirectEventQueue *queue, PrevDispatcher *prev, Func &&func) in WifiDirectEventTemplateDispatcher() argument
|
| /third_party/ffmpeg/libavformat/ |
| H A D | ttaenc.c | 33 PacketList queue; member
|
| /third_party/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/ |
| H A D | ICUNotifier.java | 118 private final List<EventListener[]> queue = new ArrayList<EventListener[]>(); field in ICUNotifier.NotifyThread
127 public void queue(EventListener[] list) { in queue() method in ICUNotifier.NotifyThread
|