| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "device/bluetooth/bluetooth_task_manager_win.h" | 5 #include "device/bluetooth/bluetooth_task_manager_win.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 #include <winsock2.h> | 8 #include <winsock2.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| (...skipping 239 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 250 } | 250 } |
| 251 | 251 |
| 252 void BluetoothTaskManagerWin::RemoveObserver(Observer* observer) { | 252 void BluetoothTaskManagerWin::RemoveObserver(Observer* observer) { |
| 253 DCHECK(observer); | 253 DCHECK(observer); |
| 254 DCHECK(ui_task_runner_->RunsTasksOnCurrentThread()); | 254 DCHECK(ui_task_runner_->RunsTasksOnCurrentThread()); |
| 255 observers_.RemoveObserver(observer); | 255 observers_.RemoveObserver(observer); |
| 256 } | 256 } |
| 257 | 257 |
| 258 void BluetoothTaskManagerWin::Initialize() { | 258 void BluetoothTaskManagerWin::Initialize() { |
| 259 DCHECK(ui_task_runner_->RunsTasksOnCurrentThread()); | 259 DCHECK(ui_task_runner_->RunsTasksOnCurrentThread()); |
| 260 worker_pool_ = new base::SequencedWorkerPool(kNumThreadsInWorkerPool, | 260 worker_pool_ = new base::SequencedWorkerPool( |
| 261 kBluetoothThreadName); | 261 kNumThreadsInWorkerPool, kBluetoothThreadName, |
| 262 base::TaskPriority::USER_VISIBLE); |
| 262 InitializeWithBluetoothTaskRunner( | 263 InitializeWithBluetoothTaskRunner( |
| 263 worker_pool_->GetSequencedTaskRunnerWithShutdownBehavior( | 264 worker_pool_->GetSequencedTaskRunnerWithShutdownBehavior( |
| 264 worker_pool_->GetSequenceToken(), | 265 worker_pool_->GetSequenceToken(), |
| 265 base::SequencedWorkerPool::CONTINUE_ON_SHUTDOWN)); | 266 base::SequencedWorkerPool::CONTINUE_ON_SHUTDOWN)); |
| 266 } | 267 } |
| 267 | 268 |
| 268 void BluetoothTaskManagerWin::InitializeWithBluetoothTaskRunner( | 269 void BluetoothTaskManagerWin::InitializeWithBluetoothTaskRunner( |
| 269 scoped_refptr<base::SequencedTaskRunner> bluetooth_task_runner) { | 270 scoped_refptr<base::SequencedTaskRunner> bluetooth_task_runner) { |
| 270 DCHECK(ui_task_runner_->RunsTasksOnCurrentThread()); | 271 DCHECK(ui_task_runner_->RunsTasksOnCurrentThread()); |
| 271 bluetooth_task_runner_ = bluetooth_task_runner; | 272 bluetooth_task_runner_ = bluetooth_task_runner; |
| (...skipping 761 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1033 void BluetoothTaskManagerWin::PostUnregisterGattCharacteristicValueChangedEvent( | 1034 void BluetoothTaskManagerWin::PostUnregisterGattCharacteristicValueChangedEvent( |
| 1034 PVOID event_handle) { | 1035 PVOID event_handle) { |
| 1035 DCHECK(ui_task_runner_->RunsTasksOnCurrentThread()); | 1036 DCHECK(ui_task_runner_->RunsTasksOnCurrentThread()); |
| 1036 bluetooth_task_runner_->PostTask( | 1037 bluetooth_task_runner_->PostTask( |
| 1037 FROM_HERE, base::Bind(&BluetoothTaskManagerWin:: | 1038 FROM_HERE, base::Bind(&BluetoothTaskManagerWin:: |
| 1038 UnregisterGattCharacteristicValueChangedEvent, | 1039 UnregisterGattCharacteristicValueChangedEvent, |
| 1039 this, event_handle)); | 1040 this, event_handle)); |
| 1040 } | 1041 } |
| 1041 | 1042 |
| 1042 } // namespace device | 1043 } // namespace device |
| OLD | NEW |