OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/usb/usb_device_handle_impl.h" | 5 #include "device/usb/usb_device_handle_impl.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <memory> | 8 #include <memory> |
9 #include <numeric> | 9 #include <numeric> |
10 #include <utility> | 10 #include <utility> |
(...skipping 594 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
605 configuration_value, callback)); | 605 configuration_value, callback)); |
606 } | 606 } |
607 | 607 |
608 void UsbDeviceHandleImpl::ClaimInterface(int interface_number, | 608 void UsbDeviceHandleImpl::ClaimInterface(int interface_number, |
609 const ResultCallback& callback) { | 609 const ResultCallback& callback) { |
610 DCHECK(thread_checker_.CalledOnValidThread()); | 610 DCHECK(thread_checker_.CalledOnValidThread()); |
611 if (!device_) { | 611 if (!device_) { |
612 callback.Run(false); | 612 callback.Run(false); |
613 return; | 613 return; |
614 } | 614 } |
615 if (ContainsKey(claimed_interfaces_, interface_number)) { | 615 if (base::ContainsKey(claimed_interfaces_, interface_number)) { |
616 callback.Run(true); | 616 callback.Run(true); |
617 return; | 617 return; |
618 } | 618 } |
619 | 619 |
620 blocking_task_runner_->PostTask( | 620 blocking_task_runner_->PostTask( |
621 FROM_HERE, | 621 FROM_HERE, |
622 base::Bind(&UsbDeviceHandleImpl::ClaimInterfaceOnBlockingThread, this, | 622 base::Bind(&UsbDeviceHandleImpl::ClaimInterfaceOnBlockingThread, this, |
623 interface_number, callback)); | 623 interface_number, callback)); |
624 } | 624 } |
625 | 625 |
626 void UsbDeviceHandleImpl::ReleaseInterface(int interface_number, | 626 void UsbDeviceHandleImpl::ReleaseInterface(int interface_number, |
627 const ResultCallback& callback) { | 627 const ResultCallback& callback) { |
628 DCHECK(thread_checker_.CalledOnValidThread()); | 628 DCHECK(thread_checker_.CalledOnValidThread()); |
629 if (!device_ || !ContainsKey(claimed_interfaces_, interface_number)) { | 629 if (!device_ || !base::ContainsKey(claimed_interfaces_, interface_number)) { |
630 task_runner_->PostTask(FROM_HERE, base::Bind(callback, false)); | 630 task_runner_->PostTask(FROM_HERE, base::Bind(callback, false)); |
631 return; | 631 return; |
632 } | 632 } |
633 | 633 |
634 // Cancel all the transfers on that interface. | 634 // Cancel all the transfers on that interface. |
635 InterfaceClaimer* interface_claimer = | 635 InterfaceClaimer* interface_claimer = |
636 claimed_interfaces_[interface_number].get(); | 636 claimed_interfaces_[interface_number].get(); |
637 for (Transfer* transfer : transfers_) { | 637 for (Transfer* transfer : transfers_) { |
638 if (transfer->claimed_interface() == interface_claimer) { | 638 if (transfer->claimed_interface() == interface_claimer) { |
639 transfer->Cancel(); | 639 transfer->Cancel(); |
640 } | 640 } |
641 } | 641 } |
642 interface_claimer->AddRef(); | 642 interface_claimer->AddRef(); |
643 interface_claimer->set_release_callback(callback); | 643 interface_claimer->set_release_callback(callback); |
644 blocking_task_runner_->ReleaseSoon(FROM_HERE, interface_claimer); | 644 blocking_task_runner_->ReleaseSoon(FROM_HERE, interface_claimer); |
645 claimed_interfaces_.erase(interface_number); | 645 claimed_interfaces_.erase(interface_number); |
646 | 646 |
647 RefreshEndpointMap(); | 647 RefreshEndpointMap(); |
648 } | 648 } |
649 | 649 |
650 void UsbDeviceHandleImpl::SetInterfaceAlternateSetting( | 650 void UsbDeviceHandleImpl::SetInterfaceAlternateSetting( |
651 int interface_number, | 651 int interface_number, |
652 int alternate_setting, | 652 int alternate_setting, |
653 const ResultCallback& callback) { | 653 const ResultCallback& callback) { |
654 DCHECK(thread_checker_.CalledOnValidThread()); | 654 DCHECK(thread_checker_.CalledOnValidThread()); |
655 if (!device_ || !ContainsKey(claimed_interfaces_, interface_number)) { | 655 if (!device_ || !base::ContainsKey(claimed_interfaces_, interface_number)) { |
656 callback.Run(false); | 656 callback.Run(false); |
657 return; | 657 return; |
658 } | 658 } |
659 | 659 |
660 blocking_task_runner_->PostTask( | 660 blocking_task_runner_->PostTask( |
661 FROM_HERE, | 661 FROM_HERE, |
662 base::Bind( | 662 base::Bind( |
663 &UsbDeviceHandleImpl::SetInterfaceAlternateSettingOnBlockingThread, | 663 &UsbDeviceHandleImpl::SetInterfaceAlternateSettingOnBlockingThread, |
664 this, interface_number, alternate_setting, callback)); | 664 this, interface_number, alternate_setting, callback)); |
665 } | 665 } |
(...skipping 440 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1106 // object holds a weak reference. | 1106 // object holds a weak reference. |
1107 transfers_.insert(transfer.get()); | 1107 transfers_.insert(transfer.get()); |
1108 blocking_task_runner_->PostTask( | 1108 blocking_task_runner_->PostTask( |
1109 FROM_HERE, | 1109 FROM_HERE, |
1110 base::Bind(&Transfer::Submit, base::Unretained(transfer.release()))); | 1110 base::Bind(&Transfer::Submit, base::Unretained(transfer.release()))); |
1111 } | 1111 } |
1112 | 1112 |
1113 void UsbDeviceHandleImpl::TransferComplete(Transfer* transfer, | 1113 void UsbDeviceHandleImpl::TransferComplete(Transfer* transfer, |
1114 const base::Closure& callback) { | 1114 const base::Closure& callback) { |
1115 DCHECK(thread_checker_.CalledOnValidThread()); | 1115 DCHECK(thread_checker_.CalledOnValidThread()); |
1116 DCHECK(ContainsKey(transfers_, transfer)) << "Missing transfer completed"; | 1116 DCHECK(base::ContainsKey(transfers_, transfer)) |
| 1117 << "Missing transfer completed"; |
1117 transfers_.erase(transfer); | 1118 transfers_.erase(transfer); |
1118 | 1119 |
1119 if (transfer->callback_task_runner()->RunsTasksOnCurrentThread()) { | 1120 if (transfer->callback_task_runner()->RunsTasksOnCurrentThread()) { |
1120 callback.Run(); | 1121 callback.Run(); |
1121 } else { | 1122 } else { |
1122 transfer->callback_task_runner()->PostTask(FROM_HERE, callback); | 1123 transfer->callback_task_runner()->PostTask(FROM_HERE, callback); |
1123 } | 1124 } |
1124 | 1125 |
1125 // libusb_free_transfer races with libusb_submit_transfer and only work- | 1126 // libusb_free_transfer races with libusb_submit_transfer and only work- |
1126 // around is to make sure to call them on the same thread. | 1127 // around is to make sure to call them on the same thread. |
1127 blocking_task_runner_->DeleteSoon(FROM_HERE, transfer); | 1128 blocking_task_runner_->DeleteSoon(FROM_HERE, transfer); |
1128 } | 1129 } |
1129 | 1130 |
1130 } // namespace device | 1131 } // namespace device |
OLD | NEW |