Searched refs:ready_queue (Results 1 – 4 of 4) sorted by relevance
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | ring_gatherer.cc | 127 PCQueue ready_queue; in RunAsyncParts() local
132 ready_queue.Enqueue(&rfv_[rf_index]); in RunAsyncParts()
164 RingField* rf = ready_queue.Dequeue(); in RunAsyncParts()
172 ready_queue.Enqueue(rf); in RunAsyncParts()
179 auto requeue = [this, rf, &ready_queue, &aborted](Status s) { in RunAsyncParts()
184 ready_queue.Enqueue(rf); in RunAsyncParts()
207 auto send_complete = [this, rf, &ready_queue, &aborted](Status s) { in RunAsyncParts()
212 ready_queue.Enqueue(rf); in RunAsyncParts()
242 RingField* rf = ready_queue.Dequeue(); in RunAsyncParts()
|
| D | ring_reducer.cc | 163 PCQueue ready_queue; in RunAsyncParts() local
168 ready_queue.Enqueue(&rfv_[rf_index]); in RunAsyncParts()
200 RingField* rf = ready_queue.Dequeue(); in RunAsyncParts()
208 ready_queue.Enqueue(rf); in RunAsyncParts()
215 auto requeue = [this, rf, &ready_queue, &aborted](Status s) { in RunAsyncParts()
220 ready_queue.Enqueue(rf); in RunAsyncParts()
266 auto send_complete = [this, rf, &ready_queue, &aborted](Status s) { in RunAsyncParts()
271 ready_queue.Enqueue(rf); in RunAsyncParts()
304 RingField* rf = ready_queue.Dequeue(); in RunAsyncParts()
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | hlo_memory_scheduler.cc | 278 std::multimap<Priority, ReadyListEntry> ready_queue; in CreateSchedule() local
287 auto it = ready_queue.emplace(GetPriority(entry), std::move(entry)); in CreateSchedule()
298 while (!ready_queue.empty()) { in CreateSchedule()
301 auto best_it = ready_queue.end(); in CreateSchedule()
306 ready_queue.erase(best_it); in CreateSchedule()
357 ready_queue.emplace(new_priority, std::move(entry)); in CreateSchedule()
359 ready_queue.erase(ready_queue_it); in CreateSchedule()
|
| /external/blktrace/btt/ |
| D | globals.h | 351 int ready_queue(struct io *q_iop, struct io *c_iop);
|