Searched refs:ready_queue (Results 1 – 4 of 4) sorted by relevance
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | ring_gatherer.cc | 132 PCQueue ready_queue; in RunAsyncParts() local
137 ready_queue.Enqueue(&rfv_[rf_index]); in RunAsyncParts()
173 RingField* rf = ready_queue.Dequeue(); in RunAsyncParts()
181 ready_queue.Enqueue(rf); in RunAsyncParts()
188 auto requeue = [this, rf, &ready_queue, &aborted](Status s) { in RunAsyncParts()
193 ready_queue.Enqueue(rf); in RunAsyncParts()
216 auto send_complete = [this, rf, &ready_queue, in RunAsyncParts()
222 ready_queue.Enqueue(rf); in RunAsyncParts()
252 RingField* rf = ready_queue.Dequeue(); in RunAsyncParts()
|
| D | ring_reducer.cc | 182 PCQueue ready_queue; in RunAsyncParts() local
187 ready_queue.Enqueue(&rfv_[rf_index]); in RunAsyncParts()
223 RingField* rf = ready_queue.Dequeue(); in RunAsyncParts()
231 ready_queue.Enqueue(rf); in RunAsyncParts()
238 auto requeue = [this, rf, &ready_queue, &aborted](Status s) { in RunAsyncParts()
243 ready_queue.Enqueue(rf); in RunAsyncParts()
289 auto send_complete = [this, rf, &ready_queue, in RunAsyncParts()
295 ready_queue.Enqueue(rf); in RunAsyncParts()
328 RingField* rf = ready_queue.Dequeue(); in RunAsyncParts()
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | hlo_memory_scheduler.cc | 290 std::multimap<Priority, ReadyListEntry> ready_queue; in CreateSchedule() local
299 auto it = ready_queue.emplace(GetPriority(entry), std::move(entry)); in CreateSchedule()
310 while (!ready_queue.empty()) { in CreateSchedule()
313 auto best_it = ready_queue.end(); in CreateSchedule()
318 ready_queue.erase(best_it); in CreateSchedule()
369 ready_queue.emplace(new_priority, std::move(entry)); in CreateSchedule()
371 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);
|