OLD | NEW |
1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/task_scheduler/scheduler_single_thread_task_runner_manager.h" | 5 #include "base/task_scheduler/scheduler_single_thread_task_runner_manager.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <memory> | 8 #include <memory> |
9 #include <string> | 9 #include <string> |
10 #include <utility> | 10 #include <utility> |
(...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
207 MSG msg; | 207 MSG msg; |
208 if (PeekMessage(&msg, nullptr, 0, 0, PM_REMOVE) != FALSE) { | 208 if (PeekMessage(&msg, nullptr, 0, 0, PM_REMOVE) != FALSE) { |
209 auto pump_message_task = | 209 auto pump_message_task = |
210 MakeUnique<Task>(FROM_HERE, | 210 MakeUnique<Task>(FROM_HERE, |
211 Bind( | 211 Bind( |
212 [](MSG msg) { | 212 [](MSG msg) { |
213 TranslateMessage(&msg); | 213 TranslateMessage(&msg); |
214 DispatchMessage(&msg); | 214 DispatchMessage(&msg); |
215 }, | 215 }, |
216 std::move(msg)), | 216 std::move(msg)), |
217 TaskTraits().MayBlock(), TimeDelta()); | 217 TaskTraits(MayBlock()), TimeDelta()); |
218 if (task_tracker_->WillPostTask(pump_message_task.get())) { | 218 if (task_tracker_->WillPostTask(pump_message_task.get())) { |
219 bool was_empty = | 219 bool was_empty = |
220 message_pump_sequence_->PushTask(std::move(pump_message_task)); | 220 message_pump_sequence_->PushTask(std::move(pump_message_task)); |
221 DCHECK(was_empty) << "GetWorkFromWindowsMessageQueue() does not expect " | 221 DCHECK(was_empty) << "GetWorkFromWindowsMessageQueue() does not expect " |
222 "queueing of pump tasks."; | 222 "queueing of pump tasks."; |
223 return message_pump_sequence_; | 223 return message_pump_sequence_; |
224 } | 224 } |
225 } | 225 } |
226 return nullptr; | 226 return nullptr; |
227 } | 227 } |
(...skipping 259 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
487 }); | 487 }); |
488 DCHECK(worker_iter != workers_.end()); | 488 DCHECK(worker_iter != workers_.end()); |
489 worker_to_destroy = std::move(*worker_iter); | 489 worker_to_destroy = std::move(*worker_iter); |
490 workers_.erase(worker_iter); | 490 workers_.erase(worker_iter); |
491 } | 491 } |
492 worker_to_destroy->Cleanup(); | 492 worker_to_destroy->Cleanup(); |
493 } | 493 } |
494 | 494 |
495 } // namespace internal | 495 } // namespace internal |
496 } // namespace base | 496 } // namespace base |
OLD | NEW |