| /external/webrtc/test/network/ |
| D | fake_network_socket_server.cc | 76 absl::optional<EmulatedIpPacket> pending_ RTC_GUARDED_BY(thread_);
97 RTC_DCHECK(!pending_); in OnPacketReceived()
98 pending_ = std::move(packet); in OnPacketReceived()
104 RTC_DCHECK(!pending_); in OnPacketReceived()
193 RTC_CHECK(pending_); in RecvFrom()
195 *paddr = pending_->from; in RecvFrom()
196 size_t data_read = std::min(cb, pending_->size()); in RecvFrom()
197 memcpy(pv, pending_->cdata(), data_read); in RecvFrom()
198 *timestamp = pending_->arrival_time.us(); in RecvFrom()
203 RTC_CHECK(data_read == pending_->size()) in RecvFrom()
[all …]
|
| D | cross_traffic.cc | 143 if (pending_.empty() && in_flight_.empty()) { in SendMessage()
154 pending_.push_back(MessageFragment{ in SendMessage()
189 pending_.push_front(lost_it->second.fragment); in OnResponse()
216 while (packets_to_send-- > 0 && !pending_.empty()) { in SendPackets()
221 send.fragment = pending_.front(); in SendPackets()
222 pending_.pop_front(); in SendPackets()
236 pending_.push_front(lost->second.fragment); in HandlePacketTimeout()
|
| D | cross_traffic.h | 138 std::deque<MessageFragment> pending_; variable
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | SimpleThreadPool.h | 37 while (!pending_.empty()) { in ~SimpleThreadPoolTempl()
62 pending_.push_back(std::move(t)); in Schedule()
94 if (pending_.empty()) { in WorkerLoop()
105 t = std::move(pending_.front()); in WorkerLoop()
106 pending_.pop_front(); in WorkerLoop()
107 if (pending_.empty()) { in WorkerLoop()
140 std::deque<Task> pending_; // Queue of pending work variable
|
| /external/llvm-project/flang/runtime/ |
| D | file.cpp | 129 pending_.reset(); in Open()
160 pending_.reset(); in Predefine()
168 pending_.reset(); in Close()
325 for (Pending *p{pending_.get()}; p; p = (prev = p)->next.get()) { in Wait()
331 pending_.reset(p->next.release()); in Wait()
344 if (pending_) { in WaitAll()
345 ioStat = pending_->ioStat; in WaitAll()
346 pending_.reset(pending_->next.release()); in WaitAll()
394 pending_ = New<Pending>{terminator}(id, iostat, std::move(pending_)); in PendingResult()
|
| D | file.h | 94 OwningPtr<Pending> pending_; variable
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | simple_propagator_state.cc | 37 pending_( in SimplePropagatorState()
43 immutable_state_.copy_pending_counts(pending_.get()); in SimplePropagatorState()
93 pending_[dst_id].fetch_sub(1, std::memory_order_release); in PropagateOutputs()
101 pending_[dst_id].fetch_sub(1, std::memory_order_release); in PropagateOutputs()
110 if (pending_[node->node_id]) { in DumpState()
|
| D | executor.h | 164 : rendez_(r), done_cb_(done), pending_(num) {} in ExecutorBarrier()
179 int pending_ TF_GUARDED_BY(mu_) = 0;
206 if (--pending_ == 0) { in WhenDone()
|
| D | gradients.cc | 182 std::vector<int> pending_; member in tensorflow::SymbolicGradientBuilder
236 if (--pending_[src.node->id()] == 0) { in BackpropAlongEdge()
246 if (--pending_[src.node->id()] == 0) { in BackpropZerosAlongEdge()
253 pending_.resize(graph_->num_node_ids(), 0); in InitBackprop()
274 pending_[e->src()->id()]++; in InitBackprop()
|
| D | simple_propagator_state.h | 127 CHECK_EQ(pending_[tagged_node.node_item->node_id], 0); in GetInputTensors()
177 std::unique_ptr<std::atomic<int32>[]> pending_; variable
|
| /external/webrtc/rtc_base/ |
| D | task_queue_win.cc | 209 std::queue<std::unique_ptr<QueuedTask>> pending_
239 pending_.push(std::move(task)); in PostTask()
266 if (pending_.empty()) in RunPendingTasks()
268 task = std::move(pending_.front()); in RunPendingTasks()
269 pending_.pop(); in RunPendingTasks()
|
| D | task_queue_libevent.cc | 134 absl::InlinedVector<std::unique_ptr<QueuedTask>, 4> pending_
220 bool had_pending_tasks = !pending_.empty(); in PostTask()
221 pending_.push_back(std::move(task)); in PostTask()
286 tasks.swap(me->pending_); in OnWakeup()
|
| /external/tensorflow/tensorflow/cc/framework/ |
| D | gradients.cc | 121 std::vector<int> pending_; member in tensorflow::__anonc8091ec30111::SymbolicGradientBuilder
161 if (--pending_[src.node()->id()] == 0) { in BackpropAlongEdge()
284 pending_.resize(scope_.graph()->num_node_ids(), 0); in Initialize()
329 pending_[n->id()] = num_expected_backprops; in Initialize()
541 if (pending_[nout.node()->id()] > 0) { in AddGradients()
550 int num_requested_inputs = p.first->num_outputs() - pending_[p.first->id()]; in AddGradients()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | server.cc | 206 while (!pending_.empty()) { in ZombifyPending()
207 CallData* calld = pending_.front(); in ZombifyPending()
210 pending_.pop(); in ZombifyPending()
242 if (!pending_.empty()) { in RequestCallWithPossiblePublish()
246 pending_call.calld = pending_.front(); in RequestCallWithPossiblePublish()
247 pending_.pop(); in RequestCallWithPossiblePublish()
300 pending_.push(calld); in MatchOrQueue()
313 std::queue<CallData*> pending_; member in grpc_core::Server::RealRequestMatcher
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | master_session.cc | 504 explicit RunManyGraphs(int num) : calls_(num), pending_(num) {} in RunManyGraphs()
536 pending_.DecrementCount(); in WhenDone()
549 if (pending_.WaitFor(kCheckErrorPeriod)) { in Wait()
560 if (pending_.WaitFor(kCheckErrorPeriod)) { in Wait()
572 pending_.Wait(); in Wait()
585 BlockingCounter pending_; member in tensorflow::__anon4940402c0411::RunManyGraphs
|