| /third_party/skia/third_party/externals/abseil-cpp/absl/strings/internal/ |
| D | cordz_handle.cc | 31 SpinLockHolder lock(&queue_->mutex); in CordzHandle()
32 CordzHandle* dq_tail = queue_->dq_tail.load(std::memory_order_acquire); in CordzHandle()
37 queue_->dq_tail.store(this, std::memory_order_release); in CordzHandle()
46 SpinLockHolder lock(&queue_->mutex); in ~CordzHandle()
62 queue_->dq_tail.store(dq_prev_, std::memory_order_release); in ~CordzHandle()
72 return is_snapshot_ || queue_->IsEmpty(); in SafeToDelete()
79 Queue* const queue = handle->queue_; in Delete()
111 SpinLockHolder lock(&queue_->mutex); in DiagnosticsHandleIsSafeToInspect()
112 for (const CordzHandle* p = queue_->dq_tail; p; p = p->dq_prev_) { in DiagnosticsHandleIsSafeToInspect()
128 SpinLockHolder lock(&queue_->mutex); in DiagnosticsGetSafeToInspectDeletedHandles()
|
| D | cordz_handle.h | 107 ABSL_RAW_CHECK(queue_ == &global_queue_, "ODR violation in Cord"); in ODRCheck()
112 Queue* const queue_ = &global_queue_; variable
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/internal/ |
| D | thread_pool.h | 48 queue_.push(nullptr); // Shutdown signal. in ~ThreadPool()
60 queue_.push(std::move(func)); in Schedule()
65 return !queue_.empty(); in WorkAvailable()
74 func = std::move(queue_.front()); in WorkLoop()
75 queue_.pop(); in WorkLoop()
85 std::queue<std::function<void()>> queue_ ABSL_GUARDED_BY(mu_);
|
| /third_party/node/deps/v8/src/libplatform/ |
| D | default-worker-threads-task-runner.cc | 14 : queue_(time_function), time_function_(time_function) { in DefaultWorkerThreadsTaskRunner()
29 queue_.Terminate(); in Terminate()
37 queue_.Append(std::move(task)); in PostTask()
44 queue_.AppendDelayed(std::move(task), delay_in_seconds); in PostDelayedTask()
59 return queue_.GetNext(); in GetNext()
|
| D | worker-thread.cc | 14 : Thread(Options("V8 WorkerThread")), queue_(queue) { in WorkerThread()
23 while (std::unique_ptr<Task> task = queue_->GetNext()) { in Run()
|
| D | worker-thread.h | 33 TaskQueue* queue_; in NON_EXPORTED_BASE()
|
| D | default-worker-threads-task-runner.h | 66 DelayedTaskQueue queue_; in NON_EXPORTED_BASE() local
|
| /third_party/opencl-headers/ |
| D | README_zh.md | 54 queue_ = clCreateCommandQueueWithProperties(context_, device_id, 0, &err);
68 err = clEnqueueNDRangeKernel(queue_, kernel_, 2, NULL, global,local, 0, NULL, NULL);
70 clFinish(queue_);
72 err = clEnqueueReadBuffer(queue_, cl_errs, CL_TRUE, 0, pixmap.size(), errs, 0, NULL, NULL);
77 clReleaseCommandQueue(queue_);
|
| /third_party/skia/third_party/externals/dawn/src/dawn_node/binding/ |
| D | GPUQueue.cpp | 30 : queue_(std::move(queue)), async_(std::move(async)) { in GPUQueue()
45 queue_.Submit(bufs_size, bufs.data()); in submit()
57 queue_.OnSubmittedWorkDone( in onSubmittedWorkDone()
94 queue_.WriteBuffer(buf, bufferOffset, src.data, src.size); in writeBuffer()
114 queue_.WriteTexture(&dst, src.data, src.size, &layout, &sz); in writeTexture()
|
| D | GPUQueue.h | 55 wgpu::Queue queue_;
|
| /third_party/node/deps/v8/src/wasm/ |
| D | module-compiler.h | 93 auto it = queue_.begin(); in pop()
94 if (it != queue_.end()) { in pop()
96 queue_.erase(it); in pop()
104 bool insert(const Key& key) { return queue_.insert(key).second; } in insert()
108 return queue_.size(); in size()
113 std::unordered_set<Key, Hash> queue_; variable
|
| D | wasm-serialization.cc | 512 queue_.emplace(std::move(batch)); in Add()
517 if (queue_.empty()) return {}; in Pop()
518 auto batch = std::move(queue_.front()); in Pop()
519 queue_.pop(); in Pop()
525 if (queue_.empty()) return {}; in PopAll()
526 auto units = std::move(queue_.front()); in PopAll()
527 queue_.pop(); in PopAll()
528 while (!queue_.empty()) { in PopAll()
529 units.insert(units.end(), std::make_move_iterator(queue_.front().begin()), in PopAll()
530 std::make_move_iterator(queue_.front().end())); in PopAll()
[all …]
|
| D | module-compiler.cc | 1255 queue_.insert(func_index); in TransitiveTypeFeedbackProcessor()
1256 while (!queue_.empty()) { in TransitiveTypeFeedbackProcessor()
1257 auto next = queue_.cbegin(); in TransitiveTypeFeedbackProcessor()
1259 queue_.erase(next); in TransitiveTypeFeedbackProcessor()
1280 queue_.insert(func); in EnqueueCallees()
1286 std::unordered_set<int> queue_; member in v8::internal::wasm::TransitiveTypeFeedbackProcessor
3857 : queue_(queue), in CompileJSToWasmWrapperJob()
3862 while (base::Optional<JSToWasmWrapperKey> key = queue_->pop()) { in Run()
3880 JSToWasmWrapperQueue* const queue_; member in v8::internal::wasm::__anon54d755100711::CompileJSToWasmWrapperJob
|
| /third_party/node/deps/v8/src/compiler/ |
| D | control-flow-optimizer.cc | 25 queue_(zone), in ControlFlowOptimizer()
32 while (!queue_.empty()) { in Optimize()
34 Node* node = queue_.front(); in Optimize()
35 queue_.pop(); in Optimize()
53 queue_.push(node); in Enqueue()
|
| D | loop-analysis.cc | 69 queue_(zone), in LoopFinderImpl()
122 NodeDeque queue_; member in v8::internal::compiler::LoopFinderImpl
199 while (!queue_.empty()) { in PropagateBackward()
201 Node* node = queue_.front(); in PropagateBackward()
203 queue_.pop_front(); in PropagateBackward()
326 while (!queue_.empty()) { in PropagateForward()
328 Node* node = queue_.front(); in PropagateForward()
329 queue_.pop_front(); in PropagateForward()
372 queue_.push_back(node); in Queue()
|
| D | scheduler.cc | 244 queue_(zone), in CFGBuilder()
257 while (!queue_.empty()) { // Breadth-first backwards traversal. in Run()
259 Node* node = queue_.front(); in Run()
260 queue_.pop(); in Run()
283 while (!queue_.empty()) { // Breadth-first backwards traversal. in Run()
285 Node* node = queue_.front(); in Run()
286 queue_.pop(); in Run()
322 queue_.push(node); in Queue()
626 DCHECK(queue_.empty()); in ResetDataStructures()
634 ZoneQueue<Node*> queue_; // Queue used for breadth-first traversal. member in v8::internal::compiler::CFGBuilder
[all …]
|
| D | control-flow-optimizer.h | 51 ZoneQueue<Node*> queue_; variable
|
| /third_party/node/deps/v8/src/torque/ |
| D | utils.h | 501 DCHECK_EQ(queue_.size(), contained_.size()); in IsEmpty()
502 return queue_.empty(); in IsEmpty()
507 queue_.push(value); in Enqueue()
509 DCHECK_EQ(queue_.size(), contained_.size()); in Enqueue()
515 T value = queue_.front(); in Dequeue()
516 queue_.pop(); in Dequeue()
518 DCHECK_EQ(queue_.size(), contained_.size()); in Dequeue()
523 std::queue<T> queue_;
|
| /third_party/vk-gl-cts/external/amber/src/src/vulkan/ |
| D | device.h | 60 VkQueue GetVkQueue() const { return queue_; } in GetVkQueue()
103 VkQueue queue_ = VK_NULL_HANDLE; variable
|
| /third_party/cef/libcef/browser/ |
| D | browser_info.cc | 367 notification_state_lock_->queue_.push(std::move(pending_action)); in MaybeExecuteFrameNotification()
537 if (!queue_.empty()) { in ~NotificationStateLock()
545 while (!queue_.empty()) { in ~NotificationStateLock()
546 std::move(queue_.front()).Run(frame_handler_); in ~NotificationStateLock()
547 queue_.pop(); in ~NotificationStateLock()
|
| D | browser_info.h | 221 std::queue<FrameNotifyOnceAction> queue_; variable
|
| /third_party/node/deps/v8/src/debug/wasm/gdb-server/ |
| D | gdb-server.cc | 83 queue_.Enqueue(std::make_shared<Task>(ready_semaphore, task)); in Append()
90 if (queue_.IsEmpty()) { in GetNext()
95 if (queue_.Dequeue(&task)) { in GetNext()
102 LockedQueue<std::shared_ptr<Task>> queue_; member in v8::internal::wasm::gdb_server::TaskRunner
|
| /third_party/node/src/ |
| D | node_http2.cc | 1834 CHECK(!stream->queue_.empty()); in OnSendData()
1836 NgHttp2StreamWrite& write = stream->queue_.front(); in OnSendData()
1841 stream->queue_.pop(); in OnSendData()
2066 tracker->TrackField("queue", queue_); in MemoryInfo()
2145 while (!queue_.empty()) { in Destroy()
2146 NgHttp2StreamWrite& head = queue_.front(); in Destroy()
2149 queue_.pop(); in Destroy()
2394 queue_.emplace(NgHttp2StreamWrite { in DoWrite()
2489 while (!stream->queue_.empty() && stream->queue_.front().buf.len == 0) { in OnRead()
2491 std::move(stream->queue_.front().req_wrap); in OnRead()
[all …]
|
| /third_party/mesa3d/include/CL/ |
| D | cl2.hpp | 9769 CommandQueue queue_;
9780 queue_(CommandQueue::getDefault()),
9789 queue_(CommandQueue::getDefault()),
9798 queue_(CommandQueue::getDefault()),
9807 queue_(CommandQueue::getDefault()),
9816 queue_(CommandQueue::getDefault()),
9825 queue_(CommandQueue::getDefault()),
9834 queue_(CommandQueue::getDefault()),
9844 queue_(CommandQueue::getDefault()),
9854 queue_(CommandQueue::getDefault()),
[all …]
|
| D | cl.hpp | 7221 CommandQueue queue_; member
7228 queue_(CommandQueue::getDefault()), in EnqueueArgs()
7237 queue_(CommandQueue::getDefault()), in EnqueueArgs()
7246 queue_(CommandQueue::getDefault()), in EnqueueArgs()
7255 queue_(CommandQueue::getDefault()), in EnqueueArgs()
7264 queue_(CommandQueue::getDefault()), in EnqueueArgs()
7273 queue_(CommandQueue::getDefault()), in EnqueueArgs()
7282 queue_(CommandQueue::getDefault()), in EnqueueArgs()
7292 queue_(CommandQueue::getDefault()), in EnqueueArgs()
7302 queue_(CommandQueue::getDefault()), in EnqueueArgs()
[all …]
|