diff options
author | rockot@chromium.org <rockot@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-01-31 20:13:23 +0000 |
---|---|---|
committer | rockot@chromium.org <rockot@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2014-01-31 20:13:23 +0000 |
commit | 125724f2dd1b339cc6dc3f3bcf2b0d565765471f (patch) | |
tree | b6b1f0d2bd292f39161de8317338edb6076fd848 /device/hid/hid_connection_mac.cc | |
parent | 64e3d73b60bbe5d3e7808c444ae1e1e392981a41 (diff) | |
download | chromium_src-125724f2dd1b339cc6dc3f3bcf2b0d565765471f.zip chromium_src-125724f2dd1b339cc6dc3f3bcf2b0d565765471f.tar.gz chromium_src-125724f2dd1b339cc6dc3f3bcf2b0d565765471f.tar.bz2 |
HID backend.
This is a continuation of https://codereview.chromium.org/143883005.
[ps#1 here is (post-revert) ps#12 there.]
BUG=290428
TBR=miket@chromium.org
Review URL: https://codereview.chromium.org/150773004
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@248250 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'device/hid/hid_connection_mac.cc')
-rw-r--r-- | device/hid/hid_connection_mac.cc | 188 |
1 files changed, 188 insertions, 0 deletions
diff --git a/device/hid/hid_connection_mac.cc b/device/hid/hid_connection_mac.cc new file mode 100644 index 0000000..bce7113 --- /dev/null +++ b/device/hid/hid_connection_mac.cc @@ -0,0 +1,188 @@ +// Copyright (c) 2014 The Chromium Authors. All rights reserved. +// Use of this source code is governed by a BSD-style license that can be +// found in the LICENSE file. + +#include "device/hid/hid_connection_mac.h" + +#include "base/bind.h" +#include "base/callback.h" +#include "base/mac/foundation_util.h" +#include "base/threading/thread_restrictions.h" +#include "base/tuple.h" +#include "device/hid/hid_service.h" +#include "device/hid/hid_service_mac.h" +#include "net/base/io_buffer.h" + +#include <CoreFoundation/CoreFoundation.h> +#include <IOKit/hid/IOHIDManager.h> + +namespace device { + +HidConnectionMac::HidConnectionMac(HidServiceMac* service, + HidDeviceInfo device_info, + IOHIDDeviceRef device) + : HidConnection(device_info), + service_(service), + device_(device), + disconnected_(false) { + DCHECK(thread_checker_.CalledOnValidThread()); + + message_loop_ = base::MessageLoopProxy::current(); + + CFRetain(device); + inbound_buffer_.reset((uint8_t*) malloc(device_info.input_report_size + 1)); + IOHIDDeviceRegisterInputReportCallback( + device_.get(), + inbound_buffer_.get(), + device_info.input_report_size + 1, + &HidConnectionMac::InputReportCallback, + this); + IOHIDDeviceOpen(device_, kIOHIDOptionsTypeNone); +} +HidConnectionMac::~HidConnectionMac() { + DCHECK(thread_checker_.CalledOnValidThread()); + + while (read_queue_.size()) { + read_queue_.front().c.Run(false, 0); + read_queue_.pop(); + } + + IOHIDDeviceClose(device_, kIOHIDOptionsTypeNone); +} + +void HidConnectionMac::InputReportCallback(void * context, + IOReturn result, + void * sender, + IOHIDReportType type, + uint32_t reportID, + uint8_t * report, + CFIndex reportLength) { + HidConnectionMac* connection = reinterpret_cast<HidConnectionMac*>(context); + size_t length = reportLength + (reportID != 0); + scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(length)); + if (reportID) { + buffer->data()[0] = reportID; + memcpy(buffer->data() + 1, report, reportLength); + } else { + memcpy(buffer->data(), report, reportLength); + } + connection->message_loop_->PostTask( + FROM_HERE, + base::Bind(&HidConnectionMac::ProcessInputReport, + connection, + type, + buffer, + length)); +} + +void HidConnectionMac::ProcessReadQueue() { + DCHECK(thread_checker_.CalledOnValidThread()); + + while(read_queue_.size() && input_reports_.size()) { + PendingRead read = read_queue_.front(); + read_queue_.pop(); + PendingReport report = input_reports_.front(); + + if (read.b < report.second) { + read.c.Run(false, report.second); + } else { + memcpy(read.a->data(), report.first->data(), report.second); + input_reports_.pop(); + read.c.Run(true, report.second); + } + } +} + +void HidConnectionMac::ProcessInputReport(IOHIDReportType type, + scoped_refptr<net::IOBuffer> report, + CFIndex reportLength) { + DCHECK(thread_checker_.CalledOnValidThread()); + + input_reports_.push(std::make_pair(report, reportLength)); + ProcessReadQueue(); +} + +void HidConnectionMac::WriteReport(IOHIDReportType type, + scoped_refptr<net::IOBuffer> buffer, + size_t size, + const IOCallback& callback) { + DCHECK(thread_checker_.CalledOnValidThread()); + if (disconnected_ || !device_) { + callback.Run(false, 0); + return; + } + const unsigned char* data_to_send = + reinterpret_cast<const unsigned char*>(buffer->data()); + size_t length_to_send = size; + if (data_to_send[0] == 0x0) { + /* Not using numbered Reports. + Don't send the report number. */ + ++data_to_send; + --length_to_send; + } + IOReturn res = IOHIDDeviceSetReport(device_.get(), + type, + buffer->data()[0], /* Report ID*/ + data_to_send, + length_to_send); + if (res != kIOReturnSuccess) { + callback.Run(false, 0); + } else { + callback.Run(true, size); + } +} + +void HidConnectionMac::Read(scoped_refptr<net::IOBuffer> buffer, + size_t size, + const IOCallback& callback) { + DCHECK(thread_checker_.CalledOnValidThread()); + if (disconnected_ || !device_) { + callback.Run(false, 0); + return; + } + read_queue_.push(MakeTuple(buffer, size, callback)); + ProcessReadQueue(); +} + +void HidConnectionMac::Write(scoped_refptr<net::IOBuffer> buffer, + size_t size, + const IOCallback& callback) { + DCHECK(thread_checker_.CalledOnValidThread()); + WriteReport(kIOHIDReportTypeOutput, buffer, size, callback); +} + +void HidConnectionMac::SendFeatureReport(scoped_refptr<net::IOBuffer> buffer, + size_t size, + const IOCallback& callback) { + DCHECK(thread_checker_.CalledOnValidThread()); + WriteReport(kIOHIDReportTypeFeature, buffer, size, callback); +} + +void HidConnectionMac::GetFeatureReport(scoped_refptr<net::IOBuffer> buffer, + size_t size, + const IOCallback& callback) { + DCHECK(thread_checker_.CalledOnValidThread()); + if (disconnected_ || !device_ || device_info_.feature_report_size == 0) { + callback.Run(false, 0); + return; + } + + if (device_info_.feature_report_size != 0 && + device_info_.feature_report_size != size) { + callback.Run(false, 0); + return; + } + + CFIndex len = device_info_.feature_report_size; + IOReturn res = IOHIDDeviceGetReport(device_, + kIOHIDReportTypeFeature, + 0, + (uint8_t*) buffer->data(), + &len); + if (res == kIOReturnSuccess) + callback.Run(true, len); + else + callback.Run(false, 0); +} + +} // namespace device |