[WebMIDI] Introduce UsbMidi{Input, Output}Stream.

media/midi/usb_midi_input_stream.cc

+// 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 "media/midi/usb_midi_input_stream.h"
+
+#include <string.h>
+#include <vector>
+
+#include "base/logging.h"
+#include "media/midi/usb_midi_device.h"
+#include "media/midi/usb_midi_jack.h"
+
+namespace media {
+
+UsbMidiInputStream::JackUniqueKey::JackUniqueKey(UsbMidiDevice* device,
+                                                 int endpoint_number,
+                                                 int cable_number)
+    : device(device),
+      endpoint_number(endpoint_number),
+      cable_number(cable_number) {}
+
+bool UsbMidiInputStream::JackUniqueKey::operator==(
+    const JackUniqueKey& that) const {
+  return device == that.device &&
+      endpoint_number == that.endpoint_number &&
+      cable_number == that.cable_number;
+}
+
+size_t UsbMidiInputStream::JackHash::operator()
+    (const JackUniqueKey& key) const {
+  // Multiply by some primes and add them each other to mix hash values.
+  return std::hash<void*>()(key.device) * 17 +

[Takashi Toyoshima, 2014/01/15 12:08:40]

Please fix compile errors on using std::hash.

[yhirano, 2014/01/15 13:25:42]

Done.

+      std::hash<int>()(key.endpoint_number) * 19 +
+      std::hash<int>()(key.cable_number) * 31;
+}
+
+UsbMidiInputStream::UsbMidiInputStream(const std::vector<UsbMidiJack>& jacks,
+                                       Delegate* delegate)
+    : jacks_(jacks), delegate_(delegate) {
+  for (size_t i = 0; i < jacks.size(); ++i) {
+    jack_dictionary_.insert(
+        std::make_pair(JackUniqueKey(jacks[i].device,
+                                     jacks[i].endpoint_number(),
+                                     jacks[i].cable_number),
+                       i));
+  }
+}
+
+UsbMidiInputStream::~UsbMidiInputStream() {}
+
+void UsbMidiInputStream::OnReceivedData(UsbMidiDevice* device,
+                                        int endpoint_number,
+                                        const uint8* data,
+                                        size_t size,
+                                        double timestamp) {
+  DCHECK_EQ(0u, size % kPacketSize);
+  size_t current = 0;
+  while (current + kPacketSize <= size) {
+    ProcessOnePacket(device, endpoint_number, &data[current], timestamp);
+    current += kPacketSize;
+  }
+}
+
+void UsbMidiInputStream::ProcessOnePacket(UsbMidiDevice* device,
+                                          int endpoint_number,
+                                          const uint8* packet,
+                                          double timestamp) {
+  // The first 4 bytes of the packet is accessible here.
+  uint8 code_index = packet[0] & 0x0f;
+  uint8 cable_number = packet[0] >> 4;
+  const size_t packet_size_table[16] = {
+    0, 0, 2, 3, 3, 1, 2, 3, 3, 3, 3, 3, 2, 2, 3, 1,
+  };
+  size_t packet_size = packet_size_table[code_index];
+  if (packet_size == 0) {
+    // These CINs are reserved. Ignore them.

[Takashi Toyoshima, 2014/01/15 12:08:40]

DVLOG(1) << something_informative ?

[yhirano, 2014/01/15 13:25:42]

Done.

+    return;
+  }
+  base::hash_map<JackUniqueKey, size_t, JackHash>::const_iterator it =
+      jack_dictionary_.find(JackUniqueKey(device,
+                                          endpoint_number,
+                                          cable_number));
+  if (it != jack_dictionary_.end())
+    delegate_->OnReceivedData(it->second, &packet[1], packet_size, timestamp);
+}
+
+}  // namespace media