| Index: content/browser/gamepad/xbox_data_fetcher_mac.cc
|
| diff --git a/content/browser/gamepad/xbox_data_fetcher_mac.cc b/content/browser/gamepad/xbox_data_fetcher_mac.cc
|
| deleted file mode 100644
|
| index 7ef35318d1847cea3fc16d818564430f16229e7f..0000000000000000000000000000000000000000
|
| --- a/content/browser/gamepad/xbox_data_fetcher_mac.cc
|
| +++ /dev/null
|
| @@ -1,809 +0,0 @@
|
| -// Copyright 2013 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 "content/browser/gamepad/xbox_data_fetcher_mac.h"
|
| -
|
| -#include <algorithm>
|
| -#include <cmath>
|
| -#include <limits>
|
| -
|
| -#include <CoreFoundation/CoreFoundation.h>
|
| -#include <IOKit/IOCFPlugIn.h>
|
| -#include <IOKit/IOKitLib.h>
|
| -#include <IOKit/usb/IOUSBLib.h>
|
| -#include <IOKit/usb/USB.h>
|
| -
|
| -#include "base/logging.h"
|
| -#include "base/mac/foundation_util.h"
|
| -
|
| -namespace {
|
| -const int kVendorMicrosoft = 0x045e;
|
| -const int kProductXbox360Controller = 0x028e;
|
| -const int kProductXboxOneController = 0x02d1;
|
| -
|
| -const int kXbox360ReadEndpoint = 1;
|
| -const int kXbox360ControlEndpoint = 2;
|
| -
|
| -const int kXboxOneReadEndpoint = 2;
|
| -const int kXboxOneControlEndpoint = 1;
|
| -
|
| -enum {
|
| - STATUS_MESSAGE_BUTTONS = 0,
|
| - STATUS_MESSAGE_LED = 1,
|
| -
|
| - // Apparently this message tells you if the rumble pack is disabled in the
|
| - // controller. If the rumble pack is disabled, vibration control messages
|
| - // have no effect.
|
| - STATUS_MESSAGE_RUMBLE = 3,
|
| -};
|
| -
|
| -enum {
|
| - XBOX_ONE_STATUS_MESSAGE_BUTTONS = 0x20,
|
| -};
|
| -
|
| -enum {
|
| - CONTROL_MESSAGE_SET_RUMBLE = 0,
|
| - CONTROL_MESSAGE_SET_LED = 1,
|
| -};
|
| -
|
| -#pragma pack(push, 1)
|
| -struct Xbox360ButtonData {
|
| - bool dpad_up : 1;
|
| - bool dpad_down : 1;
|
| - bool dpad_left : 1;
|
| - bool dpad_right : 1;
|
| -
|
| - bool start : 1;
|
| - bool back : 1;
|
| - bool stick_left_click : 1;
|
| - bool stick_right_click : 1;
|
| -
|
| - bool bumper_left : 1;
|
| - bool bumper_right : 1;
|
| - bool guide : 1;
|
| - bool dummy1 : 1; // Always 0.
|
| -
|
| - bool a : 1;
|
| - bool b : 1;
|
| - bool x : 1;
|
| - bool y : 1;
|
| -
|
| - uint8_t trigger_left;
|
| - uint8_t trigger_right;
|
| -
|
| - int16_t stick_left_x;
|
| - int16_t stick_left_y;
|
| - int16_t stick_right_x;
|
| - int16_t stick_right_y;
|
| -
|
| - // Always 0.
|
| - uint32_t dummy2;
|
| - uint16_t dummy3;
|
| -};
|
| -
|
| -struct XboxOneButtonData {
|
| - bool sync : 1;
|
| - bool dummy1 : 1; // Always 0.
|
| - bool start : 1;
|
| - bool back : 1;
|
| -
|
| - bool a : 1;
|
| - bool b : 1;
|
| - bool x : 1;
|
| - bool y : 1;
|
| -
|
| - bool dpad_up : 1;
|
| - bool dpad_down : 1;
|
| - bool dpad_left : 1;
|
| - bool dpad_right : 1;
|
| -
|
| - bool bumper_left : 1;
|
| - bool bumper_right : 1;
|
| - bool stick_left_click : 1;
|
| - bool stick_right_click : 1;
|
| -
|
| - uint16_t trigger_left;
|
| - uint16_t trigger_right;
|
| -
|
| - int16_t stick_left_x;
|
| - int16_t stick_left_y;
|
| - int16_t stick_right_x;
|
| - int16_t stick_right_y;
|
| -};
|
| -#pragma pack(pop)
|
| -
|
| -static_assert(sizeof(Xbox360ButtonData) == 18, "xbox button data wrong size");
|
| -static_assert(sizeof(XboxOneButtonData) == 14, "xbox button data wrong size");
|
| -
|
| -// From MSDN:
|
| -// http://msdn.microsoft.com/en-us/library/windows/desktop/ee417001(v=vs.85).aspx#dead_zone
|
| -const int16_t kLeftThumbDeadzone = 7849;
|
| -const int16_t kRightThumbDeadzone = 8689;
|
| -const uint8_t kXbox360TriggerDeadzone = 30;
|
| -const uint16_t kXboxOneTriggerMax = 1023;
|
| -const uint16_t kXboxOneTriggerDeadzone = 120;
|
| -
|
| -void NormalizeAxis(int16_t x,
|
| - int16_t y,
|
| - int16_t deadzone,
|
| - float* x_out,
|
| - float* y_out) {
|
| - float x_val = x;
|
| - float y_val = y;
|
| -
|
| - // Determine how far the stick is pushed.
|
| - float real_magnitude = std::sqrt(x_val * x_val + y_val * y_val);
|
| -
|
| - // Check if the controller is outside a circular dead zone.
|
| - if (real_magnitude > deadzone) {
|
| - // Clip the magnitude at its expected maximum value.
|
| - float magnitude = std::min(32767.0f, real_magnitude);
|
| -
|
| - // Adjust magnitude relative to the end of the dead zone.
|
| - magnitude -= deadzone;
|
| -
|
| - // Normalize the magnitude with respect to its expected range giving a
|
| - // magnitude value of 0.0 to 1.0
|
| - float ratio = (magnitude / (32767 - deadzone)) / real_magnitude;
|
| -
|
| - // Y is negated because xbox controllers have an opposite sign from
|
| - // the 'standard controller' recommendations.
|
| - *x_out = x_val * ratio;
|
| - *y_out = -y_val * ratio;
|
| - } else {
|
| - // If the controller is in the deadzone zero out the magnitude.
|
| - *x_out = *y_out = 0.0f;
|
| - }
|
| -}
|
| -
|
| -float NormalizeTrigger(uint8_t value) {
|
| - return value < kXbox360TriggerDeadzone
|
| - ? 0
|
| - : static_cast<float>(value - kXbox360TriggerDeadzone) /
|
| - (std::numeric_limits<uint8_t>::max() -
|
| - kXbox360TriggerDeadzone);
|
| -}
|
| -
|
| -float NormalizeXboxOneTrigger(uint16_t value) {
|
| - return value < kXboxOneTriggerDeadzone ? 0 :
|
| - static_cast<float>(value - kXboxOneTriggerDeadzone) /
|
| - (kXboxOneTriggerMax - kXboxOneTriggerDeadzone);
|
| -}
|
| -
|
| -void NormalizeXbox360ButtonData(const Xbox360ButtonData& data,
|
| - XboxController::Data* normalized_data) {
|
| - normalized_data->buttons[0] = data.a;
|
| - normalized_data->buttons[1] = data.b;
|
| - normalized_data->buttons[2] = data.x;
|
| - normalized_data->buttons[3] = data.y;
|
| - normalized_data->buttons[4] = data.bumper_left;
|
| - normalized_data->buttons[5] = data.bumper_right;
|
| - normalized_data->buttons[6] = data.back;
|
| - normalized_data->buttons[7] = data.start;
|
| - normalized_data->buttons[8] = data.stick_left_click;
|
| - normalized_data->buttons[9] = data.stick_right_click;
|
| - normalized_data->buttons[10] = data.dpad_up;
|
| - normalized_data->buttons[11] = data.dpad_down;
|
| - normalized_data->buttons[12] = data.dpad_left;
|
| - normalized_data->buttons[13] = data.dpad_right;
|
| - normalized_data->buttons[14] = data.guide;
|
| - normalized_data->triggers[0] = NormalizeTrigger(data.trigger_left);
|
| - normalized_data->triggers[1] = NormalizeTrigger(data.trigger_right);
|
| - NormalizeAxis(data.stick_left_x,
|
| - data.stick_left_y,
|
| - kLeftThumbDeadzone,
|
| - &normalized_data->axes[0],
|
| - &normalized_data->axes[1]);
|
| - NormalizeAxis(data.stick_right_x,
|
| - data.stick_right_y,
|
| - kRightThumbDeadzone,
|
| - &normalized_data->axes[2],
|
| - &normalized_data->axes[3]);
|
| -}
|
| -
|
| -void NormalizeXboxOneButtonData(const XboxOneButtonData& data,
|
| - XboxController::Data* normalized_data) {
|
| - normalized_data->buttons[0] = data.a;
|
| - normalized_data->buttons[1] = data.b;
|
| - normalized_data->buttons[2] = data.x;
|
| - normalized_data->buttons[3] = data.y;
|
| - normalized_data->buttons[4] = data.bumper_left;
|
| - normalized_data->buttons[5] = data.bumper_right;
|
| - normalized_data->buttons[6] = data.back;
|
| - normalized_data->buttons[7] = data.start;
|
| - normalized_data->buttons[8] = data.stick_left_click;
|
| - normalized_data->buttons[9] = data.stick_right_click;
|
| - normalized_data->buttons[10] = data.dpad_up;
|
| - normalized_data->buttons[11] = data.dpad_down;
|
| - normalized_data->buttons[12] = data.dpad_left;
|
| - normalized_data->buttons[13] = data.dpad_right;
|
| - normalized_data->buttons[14] = data.sync;
|
| - normalized_data->triggers[0] = NormalizeXboxOneTrigger(data.trigger_left);
|
| - normalized_data->triggers[1] = NormalizeXboxOneTrigger(data.trigger_right);
|
| - NormalizeAxis(data.stick_left_x,
|
| - data.stick_left_y,
|
| - kLeftThumbDeadzone,
|
| - &normalized_data->axes[0],
|
| - &normalized_data->axes[1]);
|
| - NormalizeAxis(data.stick_right_x,
|
| - data.stick_right_y,
|
| - kRightThumbDeadzone,
|
| - &normalized_data->axes[2],
|
| - &normalized_data->axes[3]);
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -XboxController::XboxController(Delegate* delegate)
|
| - : device_(NULL),
|
| - interface_(NULL),
|
| - device_is_open_(false),
|
| - interface_is_open_(false),
|
| - read_buffer_size_(0),
|
| - led_pattern_(LED_NUM_PATTERNS),
|
| - location_id_(0),
|
| - delegate_(delegate),
|
| - controller_type_(UNKNOWN_CONTROLLER),
|
| - read_endpoint_(0),
|
| - control_endpoint_(0) {
|
| -}
|
| -
|
| -XboxController::~XboxController() {
|
| - if (source_)
|
| - CFRunLoopSourceInvalidate(source_);
|
| - if (interface_ && interface_is_open_)
|
| - (*interface_)->USBInterfaceClose(interface_);
|
| - if (device_ && device_is_open_)
|
| - (*device_)->USBDeviceClose(device_);
|
| -}
|
| -
|
| -bool XboxController::OpenDevice(io_service_t service) {
|
| - IOCFPlugInInterface **plugin;
|
| - SInt32 score; // Unused, but required for IOCreatePlugInInterfaceForService.
|
| - kern_return_t kr =
|
| - IOCreatePlugInInterfaceForService(service,
|
| - kIOUSBDeviceUserClientTypeID,
|
| - kIOCFPlugInInterfaceID,
|
| - &plugin,
|
| - &score);
|
| - if (kr != KERN_SUCCESS)
|
| - return false;
|
| - base::mac::ScopedIOPluginInterface<IOCFPlugInInterface> plugin_ref(plugin);
|
| -
|
| - HRESULT res =
|
| - (*plugin)->QueryInterface(plugin,
|
| - CFUUIDGetUUIDBytes(kIOUSBDeviceInterfaceID320),
|
| - (LPVOID *)&device_);
|
| - if (!SUCCEEDED(res) || !device_)
|
| - return false;
|
| -
|
| - UInt16 vendor_id;
|
| - kr = (*device_)->GetDeviceVendor(device_, &vendor_id);
|
| - if (kr != KERN_SUCCESS || vendor_id != kVendorMicrosoft)
|
| - return false;
|
| -
|
| - UInt16 product_id;
|
| - kr = (*device_)->GetDeviceProduct(device_, &product_id);
|
| - if (kr != KERN_SUCCESS)
|
| - return false;
|
| -
|
| - IOUSBFindInterfaceRequest request;
|
| - switch (product_id) {
|
| - case kProductXbox360Controller:
|
| - controller_type_ = XBOX_360_CONTROLLER;
|
| - read_endpoint_ = kXbox360ReadEndpoint;
|
| - control_endpoint_ = kXbox360ControlEndpoint;
|
| - request.bInterfaceClass = 255;
|
| - request.bInterfaceSubClass = 93;
|
| - request.bInterfaceProtocol = 1;
|
| - request.bAlternateSetting = kIOUSBFindInterfaceDontCare;
|
| - break;
|
| - case kProductXboxOneController:
|
| - controller_type_ = XBOX_ONE_CONTROLLER;
|
| - read_endpoint_ = kXboxOneReadEndpoint;
|
| - control_endpoint_ = kXboxOneControlEndpoint;
|
| - request.bInterfaceClass = 255;
|
| - request.bInterfaceSubClass = 71;
|
| - request.bInterfaceProtocol = 208;
|
| - request.bAlternateSetting = kIOUSBFindInterfaceDontCare;
|
| - break;
|
| - default:
|
| - return false;
|
| - }
|
| -
|
| - // Open the device and configure it.
|
| - kr = (*device_)->USBDeviceOpen(device_);
|
| - if (kr != KERN_SUCCESS)
|
| - return false;
|
| - device_is_open_ = true;
|
| -
|
| - // Xbox controllers have one configuration option which has configuration
|
| - // value 1. Try to set it and fail if it couldn't be configured.
|
| - IOUSBConfigurationDescriptorPtr config_desc;
|
| - kr = (*device_)->GetConfigurationDescriptorPtr(device_, 0, &config_desc);
|
| - if (kr != KERN_SUCCESS)
|
| - return false;
|
| - kr = (*device_)->SetConfiguration(device_, config_desc->bConfigurationValue);
|
| - if (kr != KERN_SUCCESS)
|
| - return false;
|
| -
|
| - // The device has 4 interfaces. They are as follows:
|
| - // Protocol 1:
|
| - // - Endpoint 1 (in) : Controller events, including button presses.
|
| - // - Endpoint 2 (out): Rumble pack and LED control
|
| - // Protocol 2 has a single endpoint to read from a connected ChatPad device.
|
| - // Protocol 3 is used by a connected headset device.
|
| - // The device also has an interface on subclass 253, protocol 10 with no
|
| - // endpoints. It is unused.
|
| - //
|
| - // We don't currently support the ChatPad or headset, so protocol 1 is the
|
| - // only protocol we care about.
|
| - //
|
| - // For more detail, see
|
| - // https://github.com/Grumbel/xboxdrv/blob/master/PROTOCOL
|
| - io_iterator_t iter;
|
| - kr = (*device_)->CreateInterfaceIterator(device_, &request, &iter);
|
| - if (kr != KERN_SUCCESS)
|
| - return false;
|
| - base::mac::ScopedIOObject<io_iterator_t> iter_ref(iter);
|
| -
|
| - // There should be exactly one USB interface which matches the requested
|
| - // settings.
|
| - io_service_t usb_interface = IOIteratorNext(iter);
|
| - if (!usb_interface)
|
| - return false;
|
| -
|
| - // We need to make an InterfaceInterface to communicate with the device
|
| - // endpoint. This is the same process as earlier: first make a
|
| - // PluginInterface from the io_service then make the InterfaceInterface from
|
| - // that.
|
| - IOCFPlugInInterface **plugin_interface;
|
| - kr = IOCreatePlugInInterfaceForService(usb_interface,
|
| - kIOUSBInterfaceUserClientTypeID,
|
| - kIOCFPlugInInterfaceID,
|
| - &plugin_interface,
|
| - &score);
|
| - if (kr != KERN_SUCCESS || !plugin_interface)
|
| - return false;
|
| - base::mac::ScopedIOPluginInterface<IOCFPlugInInterface> interface_ref(
|
| - plugin_interface);
|
| -
|
| - // Release the USB interface, and any subsequent interfaces returned by the
|
| - // iterator. (There shouldn't be any, but in case a future device does
|
| - // contain more interfaces, this will serve to avoid memory leaks.)
|
| - do {
|
| - IOObjectRelease(usb_interface);
|
| - } while ((usb_interface = IOIteratorNext(iter)));
|
| -
|
| - // Actually create the interface.
|
| - res = (*plugin_interface)->QueryInterface(
|
| - plugin_interface,
|
| - CFUUIDGetUUIDBytes(kIOUSBInterfaceInterfaceID300),
|
| - (LPVOID *)&interface_);
|
| -
|
| - if (!SUCCEEDED(res) || !interface_)
|
| - return false;
|
| -
|
| - // Actually open the interface.
|
| - kr = (*interface_)->USBInterfaceOpen(interface_);
|
| - if (kr != KERN_SUCCESS)
|
| - return false;
|
| - interface_is_open_ = true;
|
| -
|
| - CFRunLoopSourceRef source_ref;
|
| - kr = (*interface_)->CreateInterfaceAsyncEventSource(interface_, &source_ref);
|
| - if (kr != KERN_SUCCESS || !source_ref)
|
| - return false;
|
| - source_.reset(source_ref);
|
| - CFRunLoopAddSource(CFRunLoopGetCurrent(), source_, kCFRunLoopDefaultMode);
|
| -
|
| - // The interface should have two pipes. Pipe 1 with direction kUSBIn and pipe
|
| - // 2 with direction kUSBOut. Both pipes should have type kUSBInterrupt.
|
| - uint8_t num_endpoints;
|
| - kr = (*interface_)->GetNumEndpoints(interface_, &num_endpoints);
|
| - if (kr != KERN_SUCCESS || num_endpoints < 2)
|
| - return false;
|
| -
|
| - for (int i = 1; i <= 2; i++) {
|
| - uint8_t direction;
|
| - uint8_t number;
|
| - uint8_t transfer_type;
|
| - uint16_t max_packet_size;
|
| - uint8_t interval;
|
| -
|
| - kr = (*interface_)->GetPipeProperties(interface_,
|
| - i,
|
| - &direction,
|
| - &number,
|
| - &transfer_type,
|
| - &max_packet_size,
|
| - &interval);
|
| - if (kr != KERN_SUCCESS || transfer_type != kUSBInterrupt) {
|
| - return false;
|
| - }
|
| - if (i == read_endpoint_) {
|
| - if (direction != kUSBIn)
|
| - return false;
|
| - read_buffer_.reset(new uint8_t[max_packet_size]);
|
| - read_buffer_size_ = max_packet_size;
|
| - QueueRead();
|
| - } else if (i == control_endpoint_) {
|
| - if (direction != kUSBOut)
|
| - return false;
|
| - if (controller_type_ == XBOX_ONE_CONTROLLER)
|
| - WriteXboxOneInit();
|
| - }
|
| - }
|
| -
|
| - // The location ID is unique per controller, and can be used to track
|
| - // controllers through reconnections (though if a controller is detached from
|
| - // one USB hub and attached to another, the location ID will change).
|
| - kr = (*device_)->GetLocationID(device_, &location_id_);
|
| - if (kr != KERN_SUCCESS)
|
| - return false;
|
| -
|
| - return true;
|
| -}
|
| -
|
| -void XboxController::SetLEDPattern(LEDPattern pattern) {
|
| - led_pattern_ = pattern;
|
| - const UInt8 length = 3;
|
| -
|
| - // This buffer will be released in WriteComplete when WritePipeAsync
|
| - // finishes.
|
| - UInt8* buffer = new UInt8[length];
|
| - buffer[0] = static_cast<UInt8>(CONTROL_MESSAGE_SET_LED);
|
| - buffer[1] = length;
|
| - buffer[2] = static_cast<UInt8>(pattern);
|
| - kern_return_t kr = (*interface_)->WritePipeAsync(interface_,
|
| - control_endpoint_,
|
| - buffer,
|
| - (UInt32)length,
|
| - WriteComplete,
|
| - buffer);
|
| - if (kr != KERN_SUCCESS) {
|
| - delete[] buffer;
|
| - IOError();
|
| - return;
|
| - }
|
| -}
|
| -
|
| -int XboxController::GetVendorId() const {
|
| - return kVendorMicrosoft;
|
| -}
|
| -
|
| -int XboxController::GetProductId() const {
|
| - if (controller_type_ == XBOX_360_CONTROLLER)
|
| - return kProductXbox360Controller;
|
| - else
|
| - return kProductXboxOneController;
|
| -}
|
| -
|
| -XboxController::ControllerType XboxController::GetControllerType() const {
|
| - return controller_type_;
|
| -}
|
| -
|
| -void XboxController::WriteComplete(void* context, IOReturn result, void* arg0) {
|
| - UInt8* buffer = static_cast<UInt8*>(context);
|
| - delete[] buffer;
|
| -
|
| - // Ignoring any errors sending data, because they will usually only occur
|
| - // when the device is disconnected, in which case it really doesn't matter if
|
| - // the data got to the controller or not.
|
| - if (result != kIOReturnSuccess)
|
| - return;
|
| -}
|
| -
|
| -void XboxController::GotData(void* context, IOReturn result, void* arg0) {
|
| - size_t bytes_read = reinterpret_cast<size_t>(arg0);
|
| - XboxController* controller = static_cast<XboxController*>(context);
|
| -
|
| - if (result != kIOReturnSuccess) {
|
| - // This will happen if the device was disconnected. The gamepad has
|
| - // probably been destroyed by a meteorite.
|
| - controller->IOError();
|
| - return;
|
| - }
|
| -
|
| - if (controller->GetControllerType() == XBOX_360_CONTROLLER)
|
| - controller->ProcessXbox360Packet(bytes_read);
|
| - else
|
| - controller->ProcessXboxOnePacket(bytes_read);
|
| -
|
| - // Queue up another read.
|
| - controller->QueueRead();
|
| -}
|
| -
|
| -void XboxController::ProcessXbox360Packet(size_t length) {
|
| - if (length < 2)
|
| - return;
|
| - DCHECK(length <= read_buffer_size_);
|
| - if (length > read_buffer_size_) {
|
| - IOError();
|
| - return;
|
| - }
|
| - uint8_t* buffer = read_buffer_.get();
|
| -
|
| - if (buffer[1] != length)
|
| - // Length in packet doesn't match length reported by USB.
|
| - return;
|
| -
|
| - uint8_t type = buffer[0];
|
| - buffer += 2;
|
| - length -= 2;
|
| - switch (type) {
|
| - case STATUS_MESSAGE_BUTTONS: {
|
| - if (length != sizeof(Xbox360ButtonData))
|
| - return;
|
| - Xbox360ButtonData* data = reinterpret_cast<Xbox360ButtonData*>(buffer);
|
| - Data normalized_data;
|
| - NormalizeXbox360ButtonData(*data, &normalized_data);
|
| - delegate_->XboxControllerGotData(this, normalized_data);
|
| - break;
|
| - }
|
| - case STATUS_MESSAGE_LED:
|
| - if (length != 3)
|
| - return;
|
| - // The controller sends one of these messages every time the LED pattern
|
| - // is set, as well as once when it is plugged in.
|
| - if (led_pattern_ == LED_NUM_PATTERNS && buffer[0] < LED_NUM_PATTERNS)
|
| - led_pattern_ = static_cast<LEDPattern>(buffer[0]);
|
| - break;
|
| - default:
|
| - // Unknown packet: ignore!
|
| - break;
|
| - }
|
| -}
|
| -
|
| -void XboxController::ProcessXboxOnePacket(size_t length) {
|
| - if (length < 2)
|
| - return;
|
| - DCHECK(length <= read_buffer_size_);
|
| - if (length > read_buffer_size_) {
|
| - IOError();
|
| - return;
|
| - }
|
| - uint8_t* buffer = read_buffer_.get();
|
| -
|
| - uint8_t type = buffer[0];
|
| - buffer += 4;
|
| - length -= 4;
|
| - switch (type) {
|
| - case XBOX_ONE_STATUS_MESSAGE_BUTTONS: {
|
| - if (length != sizeof(XboxOneButtonData))
|
| - return;
|
| - XboxOneButtonData* data = reinterpret_cast<XboxOneButtonData*>(buffer);
|
| - Data normalized_data;
|
| - NormalizeXboxOneButtonData(*data, &normalized_data);
|
| - delegate_->XboxControllerGotData(this, normalized_data);
|
| - break;
|
| - }
|
| - default:
|
| - // Unknown packet: ignore!
|
| - break;
|
| - }
|
| -}
|
| -
|
| -void XboxController::QueueRead() {
|
| - kern_return_t kr = (*interface_)->ReadPipeAsync(interface_,
|
| - read_endpoint_,
|
| - read_buffer_.get(),
|
| - read_buffer_size_,
|
| - GotData,
|
| - this);
|
| - if (kr != KERN_SUCCESS)
|
| - IOError();
|
| -}
|
| -
|
| -void XboxController::IOError() {
|
| - delegate_->XboxControllerError(this);
|
| -}
|
| -
|
| -void XboxController::WriteXboxOneInit() {
|
| - const UInt8 length = 2;
|
| -
|
| - // This buffer will be released in WriteComplete when WritePipeAsync
|
| - // finishes.
|
| - UInt8* buffer = new UInt8[length];
|
| - buffer[0] = 0x05;
|
| - buffer[1] = 0x20;
|
| - kern_return_t kr = (*interface_)->WritePipeAsync(interface_,
|
| - control_endpoint_,
|
| - buffer,
|
| - (UInt32)length,
|
| - WriteComplete,
|
| - buffer);
|
| - if (kr != KERN_SUCCESS) {
|
| - delete[] buffer;
|
| - IOError();
|
| - return;
|
| - }
|
| -}
|
| -
|
| -//-----------------------------------------------------------------------------
|
| -
|
| -XboxDataFetcher::XboxDataFetcher(Delegate* delegate)
|
| - : delegate_(delegate),
|
| - listening_(false),
|
| - source_(NULL),
|
| - port_(NULL) {
|
| -}
|
| -
|
| -XboxDataFetcher::~XboxDataFetcher() {
|
| - while (!controllers_.empty()) {
|
| - RemoveController(*controllers_.begin());
|
| - }
|
| - UnregisterFromNotifications();
|
| -}
|
| -
|
| -void XboxDataFetcher::DeviceAdded(void* context, io_iterator_t iterator) {
|
| - DCHECK(context);
|
| - XboxDataFetcher* fetcher = static_cast<XboxDataFetcher*>(context);
|
| - io_service_t ref;
|
| - while ((ref = IOIteratorNext(iterator))) {
|
| - base::mac::ScopedIOObject<io_service_t> scoped_ref(ref);
|
| - XboxController* controller = new XboxController(fetcher);
|
| - if (controller->OpenDevice(ref)) {
|
| - fetcher->AddController(controller);
|
| - } else {
|
| - delete controller;
|
| - }
|
| - }
|
| -}
|
| -
|
| -void XboxDataFetcher::DeviceRemoved(void* context, io_iterator_t iterator) {
|
| - DCHECK(context);
|
| - XboxDataFetcher* fetcher = static_cast<XboxDataFetcher*>(context);
|
| - io_service_t ref;
|
| - while ((ref = IOIteratorNext(iterator))) {
|
| - base::mac::ScopedIOObject<io_service_t> scoped_ref(ref);
|
| - base::ScopedCFTypeRef<CFNumberRef> number(
|
| - base::mac::CFCastStrict<CFNumberRef>(
|
| - IORegistryEntryCreateCFProperty(ref,
|
| - CFSTR(kUSBDevicePropertyLocationID),
|
| - kCFAllocatorDefault,
|
| - kNilOptions)));
|
| - UInt32 location_id = 0;
|
| - CFNumberGetValue(number, kCFNumberSInt32Type, &location_id);
|
| - fetcher->RemoveControllerByLocationID(location_id);
|
| - }
|
| -}
|
| -
|
| -bool XboxDataFetcher::RegisterForNotifications() {
|
| - if (listening_)
|
| - return true;
|
| - port_ = IONotificationPortCreate(kIOMasterPortDefault);
|
| - if (!port_)
|
| - return false;
|
| - source_ = IONotificationPortGetRunLoopSource(port_);
|
| - if (!source_)
|
| - return false;
|
| - CFRunLoopAddSource(CFRunLoopGetCurrent(), source_, kCFRunLoopDefaultMode);
|
| -
|
| - listening_ = true;
|
| -
|
| - if (!RegisterForDeviceNotifications(
|
| - kVendorMicrosoft, kProductXboxOneController,
|
| - &xbox_one_device_added_iter_,
|
| - &xbox_one_device_removed_iter_))
|
| - return false;
|
| -
|
| - if (!RegisterForDeviceNotifications(
|
| - kVendorMicrosoft, kProductXbox360Controller,
|
| - &xbox_360_device_added_iter_,
|
| - &xbox_360_device_removed_iter_))
|
| - return false;
|
| -
|
| - return true;
|
| -}
|
| -
|
| -bool XboxDataFetcher::RegisterForDeviceNotifications(
|
| - int vendor_id,
|
| - int product_id,
|
| - base::mac::ScopedIOObject<io_iterator_t>* added_iter,
|
| - base::mac::ScopedIOObject<io_iterator_t>* removed_iter) {
|
| - base::ScopedCFTypeRef<CFNumberRef> vendor_cf(CFNumberCreate(
|
| - kCFAllocatorDefault, kCFNumberSInt32Type, &vendor_id));
|
| - base::ScopedCFTypeRef<CFNumberRef> product_cf(CFNumberCreate(
|
| - kCFAllocatorDefault, kCFNumberSInt32Type, &product_id));
|
| - base::ScopedCFTypeRef<CFMutableDictionaryRef> matching_dict(
|
| - IOServiceMatching(kIOUSBDeviceClassName));
|
| - if (!matching_dict)
|
| - return false;
|
| - CFDictionarySetValue(matching_dict, CFSTR(kUSBVendorID), vendor_cf);
|
| - CFDictionarySetValue(matching_dict, CFSTR(kUSBProductID), product_cf);
|
| -
|
| - // IOServiceAddMatchingNotification() releases the dictionary when it's done.
|
| - // Retain it before each call to IOServiceAddMatchingNotification to keep
|
| - // things balanced.
|
| - CFRetain(matching_dict);
|
| - io_iterator_t device_added_iter;
|
| - IOReturn ret;
|
| - ret = IOServiceAddMatchingNotification(port_,
|
| - kIOFirstMatchNotification,
|
| - matching_dict,
|
| - DeviceAdded,
|
| - this,
|
| - &device_added_iter);
|
| - added_iter->reset(device_added_iter);
|
| - if (ret != kIOReturnSuccess) {
|
| - LOG(ERROR) << "Error listening for Xbox controller add events: " << ret;
|
| - return false;
|
| - }
|
| - DeviceAdded(this, added_iter->get());
|
| -
|
| - CFRetain(matching_dict);
|
| - io_iterator_t device_removed_iter;
|
| - ret = IOServiceAddMatchingNotification(port_,
|
| - kIOTerminatedNotification,
|
| - matching_dict,
|
| - DeviceRemoved,
|
| - this,
|
| - &device_removed_iter);
|
| - removed_iter->reset(device_removed_iter);
|
| - if (ret != kIOReturnSuccess) {
|
| - LOG(ERROR) << "Error listening for Xbox controller remove events: " << ret;
|
| - return false;
|
| - }
|
| - DeviceRemoved(this, removed_iter->get());
|
| - return true;
|
| -}
|
| -
|
| -void XboxDataFetcher::UnregisterFromNotifications() {
|
| - if (!listening_)
|
| - return;
|
| - listening_ = false;
|
| - if (source_)
|
| - CFRunLoopSourceInvalidate(source_);
|
| - if (port_)
|
| - IONotificationPortDestroy(port_);
|
| - port_ = NULL;
|
| -}
|
| -
|
| -XboxController* XboxDataFetcher::ControllerForLocation(UInt32 location_id) {
|
| - for (std::set<XboxController*>::iterator i = controllers_.begin();
|
| - i != controllers_.end();
|
| - ++i) {
|
| - if ((*i)->location_id() == location_id)
|
| - return *i;
|
| - }
|
| - return NULL;
|
| -}
|
| -
|
| -void XboxDataFetcher::AddController(XboxController* controller) {
|
| - DCHECK(!ControllerForLocation(controller->location_id()))
|
| - << "Controller with location ID " << controller->location_id()
|
| - << " already exists in the set of controllers.";
|
| - controllers_.insert(controller);
|
| - delegate_->XboxDeviceAdd(controller);
|
| -}
|
| -
|
| -void XboxDataFetcher::RemoveController(XboxController* controller) {
|
| - delegate_->XboxDeviceRemove(controller);
|
| - controllers_.erase(controller);
|
| - delete controller;
|
| -}
|
| -
|
| -void XboxDataFetcher::RemoveControllerByLocationID(uint32_t location_id) {
|
| - XboxController* controller = NULL;
|
| - for (std::set<XboxController*>::iterator i = controllers_.begin();
|
| - i != controllers_.end();
|
| - ++i) {
|
| - if ((*i)->location_id() == location_id) {
|
| - controller = *i;
|
| - break;
|
| - }
|
| - }
|
| - if (controller)
|
| - RemoveController(controller);
|
| -}
|
| -
|
| -void XboxDataFetcher::XboxControllerGotData(XboxController* controller,
|
| - const XboxController::Data& data) {
|
| - delegate_->XboxValueChanged(controller, data);
|
| -}
|
| -
|
| -void XboxDataFetcher::XboxControllerError(XboxController* controller) {
|
| - RemoveController(controller);
|
| -}
|
|
|