media/midi/midi_manager_usb.cc

   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
   3 // found in the LICENSE file.
   4
   5 #include "media/midi/midi_manager_usb.h"
   6
   7 #include "base/callback.h"
   8 #include "base/logging.h"
   9 #include "base/memory/scoped_ptr.h"
  10 #include "base/message_loop/message_loop.h"
  11 #include "base/strings/stringprintf.h"
  12 #include "media/midi/midi_scheduler.h"
  13 #include "media/midi/usb_midi_descriptor_parser.h"
  14 #include "media/midi/usb_midi_device.h"
  15 #include "media/midi/usb_midi_input_stream.h"
  16 #include "media/midi/usb_midi_jack.h"
  17 #include "media/midi/usb_midi_output_stream.h"
  18
  19 namespace media {
  20 namespace midi {
  21
  22 MidiManagerUsb::MidiManagerUsb(scoped_ptr<UsbMidiDevice::Factory> factory)
  23     : device_factory_(factory.Pass()) {
  24 }
  25
  26 MidiManagerUsb::~MidiManagerUsb() {
  27 }
  28
  29 void MidiManagerUsb::StartInitialization() {
  30   Initialize(
  31       base::Bind(&MidiManager::CompleteInitialization, base::Unretained(this)));
  32 }
  33
  34 void MidiManagerUsb::Initialize(
  35     base::Callback<void(MidiResult result)> callback) {
  36   initialize_callback_ = callback;
  37   scheduler_.reset(new MidiScheduler(this));
  38   // This is safe because EnumerateDevices cancels the operation on destruction.
  39   device_factory_->EnumerateDevices(
  40       this,
  41       base::Bind(&MidiManagerUsb::OnEnumerateDevicesDone,
  42                  base::Unretained(this)));
  43 }
  44
  45 void MidiManagerUsb::DispatchSendMidiData(MidiManagerClient* client,
  46                                           uint32_t port_index,
  47                                           const std::vector<uint8>& data,
  48                                           double timestamp) {
  49   if (port_index >= output_streams_.size()) {
  50     // |port_index| is provided by a renderer so we can't believe that it is
  51     // in the valid range.
  52     return;
  53   }
  54   // output_streams_[port_index] is alive unless MidiManagerUsb is deleted.
  55   // The task posted to the MidiScheduler will be disposed safely on deleting
  56   // the scheduler.
  57   scheduler_->PostSendDataTask(
  58       client, data.size(), timestamp,
  59       base::Bind(&UsbMidiOutputStream::Send,
  60                  base::Unretained(output_streams_[port_index]), data));
  61 }
  62
  63 void MidiManagerUsb::ReceiveUsbMidiData(UsbMidiDevice* device,
  64                                         int endpoint_number,
  65                                         const uint8* data,
  66                                         size_t size,
  67                                         base::TimeTicks time) {
  68   if (!input_stream_)
  69     return;
  70   input_stream_->OnReceivedData(device,
  71                                 endpoint_number,
  72                                 data,
  73                                 size,
  74                                 time);
  75 }
  76
  77 void MidiManagerUsb::OnDeviceAttached(scoped_ptr<UsbMidiDevice> device) {
  78   int device_id = static_cast<int>(devices_.size());
  79   devices_.push_back(device.release());
  80   AddPorts(devices_.back(), device_id);
  81 }
  82
  83 void MidiManagerUsb::OnDeviceDetached(size_t index) {
  84   if (index >= devices_.size()) {
  85     return;
  86   }
  87   UsbMidiDevice* device = devices_[index];
  88   for (size_t i = 0; i < output_streams_.size(); ++i) {
  89     if (output_streams_[i]->jack().device == device) {
  90       SetOutputPortState(static_cast<uint32>(i), MIDI_PORT_DISCONNECTED);
  91     }
  92   }
  93   const std::vector<UsbMidiJack>& input_jacks = input_stream_->jacks();
  94   for (size_t i = 0; i < input_jacks.size(); ++i) {
  95     if (input_jacks[i].device == device) {
  96       SetInputPortState(static_cast<uint32>(i), MIDI_PORT_DISCONNECTED);
  97     }
  98   }
  99 }
 100
 101 void MidiManagerUsb::OnReceivedData(size_t jack_index,
 102                                     const uint8* data,
 103                                     size_t size,
 104                                     base::TimeTicks time) {
 105   ReceiveMidiData(static_cast<uint32>(jack_index), data, size, time);
 106 }
 107
 108
 109 void MidiManagerUsb::OnEnumerateDevicesDone(bool result,
 110                                             UsbMidiDevice::Devices* devices) {
 111   if (!result) {
 112     initialize_callback_.Run(MIDI_INITIALIZATION_ERROR);
 113     return;
 114   }
 115   input_stream_.reset(new UsbMidiInputStream(this));
 116   devices->swap(devices_);
 117   for (size_t i = 0; i < devices_.size(); ++i) {
 118     if (!AddPorts(devices_[i], static_cast<int>(i))) {
 119       initialize_callback_.Run(MIDI_INITIALIZATION_ERROR);
 120       return;
 121     }
 122   }
 123   initialize_callback_.Run(MIDI_OK);
 124 }
 125
 126 bool MidiManagerUsb::AddPorts(UsbMidiDevice* device, int device_id) {
 127   UsbMidiDescriptorParser parser;
 128   std::vector<uint8> descriptor = device->GetDescriptors();
 129   const uint8* data = descriptor.size() > 0 ? &descriptor[0] : NULL;
 130   std::vector<UsbMidiJack> jacks;
 131   bool parse_result = parser.Parse(device,
 132                                    data,
 133                                    descriptor.size(),
 134                                    &jacks);
 135   if (!parse_result)
 136     return false;
 137
 138   std::string manufacturer(device->GetManufacturer());
 139   std::string product_name(device->GetProductName());
 140   std::string version(device->GetDeviceVersion());
 141
 142   for (size_t j = 0; j < jacks.size(); ++j) {
 143     // Port ID must be unique in a MIDI manager. This ID setting is
 144     // sufficiently unique although there is no user-friendly meaning.
 145     // TODO(yhirano): Use a hashed string as ID.
 146     std::string id(
 147         base::StringPrintf("port-%d-%ld", device_id, static_cast<long>(j)));
 148     if (jacks[j].direction() == UsbMidiJack::DIRECTION_OUT) {
 149       output_streams_.push_back(new UsbMidiOutputStream(jacks[j]));
 150       AddOutputPort(MidiPortInfo(id, manufacturer, product_name, version,
 151                                  MIDI_PORT_OPENED));
 152     } else {
 153       DCHECK_EQ(jacks[j].direction(), UsbMidiJack::DIRECTION_IN);
 154       input_stream_->Add(jacks[j]);
 155       AddInputPort(MidiPortInfo(id, manufacturer, product_name, version,
 156                                 MIDI_PORT_OPENED));
 157     }
 158   }
 159   return true;
 160 }
 161
 162 }  // namespace midi
 163 }  // namespace media