| 3152 | } |
| 3153 | |
| 3154 | void Task::testingVisitDrivers(const std::function<void(Driver*)>& callback) { |
| 3155 | std::lock_guard<std::timed_mutex> l(mutex_); |
| 3156 | for (int i = 0; i < drivers_.size(); ++i) { |
| 3157 | if (drivers_[i] != nullptr) { |
| 3158 | callback(drivers_[i].get()); |
| 3159 | } |
| 3160 | } |
| 3161 | } |
| 3162 | |
| 3163 | std::unique_ptr<memory::MemoryReclaimer> Task::MemoryReclaimer::create( |
| 3164 | const std::shared_ptr<Task>& task, |