summaryrefslogtreecommitdiffstats
path: root/device/hid/hid_connection_mac.cc
diff options
context:
space:
mode:
authorikarienator@chromium.org <ikarienator@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2014-01-30 10:41:05 +0000
committerikarienator@chromium.org <ikarienator@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2014-01-30 10:41:05 +0000
commita2c724ab72ccebb6d78e228caefd36b100e8308a (patch)
treef023f4383558055b3a41f6183983da7e9183e1ee /device/hid/hid_connection_mac.cc
parent441e25cdf56a650df64a17416314aeee1598ccff (diff)
downloadchromium_src-a2c724ab72ccebb6d78e228caefd36b100e8308a.zip
chromium_src-a2c724ab72ccebb6d78e228caefd36b100e8308a.tar.gz
chromium_src-a2c724ab72ccebb6d78e228caefd36b100e8308a.tar.bz2
HID backend
BUG=290428 Review URL: https://codereview.chromium.org/143883005 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@247926 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'device/hid/hid_connection_mac.cc')
-rw-r--r--device/hid/hid_connection_mac.cc188
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..625452a
--- /dev/null
+++ b/device/hid/hid_connection_mac.cc
@@ -0,0 +1,188 @@
+// Copyright 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