| /third_party/skia/third_party/externals/abseil-cpp/absl/strings/internal/ |
| H A 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_ in DiagnosticsGetSafeToInspectDeletedHandles()
[all...] |
| H A D | cordz_handle.h | 107 ABSL_RAW_CHECK(queue_ == &global_queue_, "ODR violation in Cord"); in ODRCheck()
112 Queue* const queue_ = &global_queue_; member in absl::cord_internal::CordzHandle
117 // analysis understands that queue_ and global_queue_ are one and the same.
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/internal/ |
| H A 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 ABSL_EXCLUSIVE_LOCKS_REQUIRED()
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/ |
| H A 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()
|
| H A D | worker-thread.cc | 14 : Thread(Options("V8 WorkerThread")), queue_(queue) { in WorkerThread()
23 while (std::unique_ptr<Task> task = queue_->GetNext()) { in Run()
|
| H A D | worker-thread.h | 33 TaskQueue* queue_; member in v8::platform::WorkerThread
|
| H A D | default-worker-threads-task-runner.h | 66 DelayedTaskQueue queue_; member in v8::platform::DefaultWorkerThreadsTaskRunner
|
| /third_party/node/deps/v8/src/wasm/ |
| H A 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_; member in v8::internal::wasm::WrapperQueue
|
| H A 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_ in PopAll()
543 std::queue<std::vector<DeserializationUnit>> queue_; global() member in v8::internal::wasm::DeserializationQueue
[all...] |
| H A 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::__anon15175::TransitiveTypeFeedbackProcessor
3857 : queue_(queue), in CompileJSToWasmWrapperJob()
3862 while (base::Optional<JSToWasmWrapperKey> key = queue_->pop()) {
3880 JSToWasmWrapperQueue* const queue_; member in v8::internal::wasm::__anon15175::__anon15180::final
|
| H A D | module-instantiate.cc | 57 queue_(queue), in CompileImportWrapperJob()
65 return std::min(flag_limit, worker_count + queue_->size());
71 queue_->pop()) {
83 ImportWrapperQueue* const queue_; member in v8::internal::wasm::__anon15189::final
|
| /third_party/node/deps/v8/src/compiler/ |
| H A 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()
|
| H A 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()
|
| H A 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_; // Queu member in v8::internal::compiler::CFGBuilder
1484 ZoneQueue<Node*> queue_; global() member in v8::internal::compiler::ScheduleEarlyNodeVisitor
[all...] |
| H A D | control-flow-optimizer.h | 51 ZoneQueue<Node*> queue_; member in v8::internal::compiler::final
|
| /third_party/skia/third_party/externals/dawn/src/dawn_node/binding/ |
| H A 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()
|
| H A D | GPUQueue.h | 55 wgpu::Queue queue_; member in wgpu::binding::final
|
| /third_party/node/deps/v8/src/torque/ |
| H A 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_; member in v8::internal::torque::Worklist
|
| /third_party/vk-gl-cts/external/amber/src/src/vulkan/ |
| H A D | device.h | 60 VkQueue GetVkQueue() const { return queue_; } in GetVkQueue()
103 VkQueue queue_ = VK_NULL_HANDLE; member in amber::vulkan::Device
|
| H A D | device.cc | 408 queue_(queue), in Device()
|
| /third_party/node/deps/v8/src/debug/wasm/gdb-server/ |
| H A 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/ |
| H A D | node_http2.cc | 1840 CHECK(!stream->queue_.empty()); in OnSendData()
1842 NgHttp2StreamWrite& write = stream->queue_.front(); in OnSendData()
1847 stream->queue_.pop(); in OnSendData()
2072 tracker->TrackField("queue", queue_); in MemoryInfo()
2151 while (!queue_.empty()) { in Destroy()
2152 NgHttp2StreamWrite& head = queue_.front(); in Destroy()
2155 queue_.pop(); in Destroy()
2400 queue_.emplace(NgHttp2StreamWrite { in DoWrite()
2495 while (!stream->queue_.empty() && stream->queue_ in OnRead()
[all...] |
| H A D | node_http2.h | 501 std::queue<NgHttp2StreamWrite> queue_; member in node::http2::Http2Stream
|
| /third_party/mesa3d/include/CL/ |
| H A D | cl2.hpp | 9769 CommandQueue queue_; member in cl::EnqueueArgs
9780 queue_(CommandQueue::getDefault()), in EnqueueArgs()
9789 queue_(CommandQueue::getDefault()), in EnqueueArgs()
9798 queue_(CommandQueue::getDefault()), in EnqueueArgs()
9807 queue_(CommandQueue::getDefault()), in EnqueueArgs()
9816 queue_(CommandQueue::getDefault()), in EnqueueArgs()
9825 queue_(CommandQueue::getDefault()), in EnqueueArgs()
9834 queue_(CommandQueue::getDefault()), in EnqueueArgs()
9844 queue_(CommandQueue::getDefault()), in EnqueueArgs()
9854 queue_(CommandQueu in EnqueueArgs()
[all...] |
| H A 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_(CommandQueu in EnqueueArgs()
[all...] |