Index: trunk/src/media/midi/midi_message_queue.cc |
=================================================================== |
--- trunk/src/media/midi/midi_message_queue.cc (revision 237659) |
+++ trunk/src/media/midi/midi_message_queue.cc (working copy) |
@@ -1,119 +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 "media/midi/midi_message_queue.h" |
- |
-#include <algorithm> |
- |
-#include "base/logging.h" |
-#include "media/midi/midi_message_util.h" |
- |
-namespace media { |
-namespace { |
- |
-const uint8 kSysEx = 0xf0; |
-const uint8 kEndOfSysEx = 0xf7; |
- |
-bool IsDataByte(uint8 data) { |
- return (data & 0x80) == 0; |
-} |
- |
-bool IsFirstStatusByte(uint8 data) { |
- return !IsDataByte(data) && data != kEndOfSysEx; |
-} |
- |
-bool IsSystemRealTimeMessage(uint8 data) { |
- return 0xf8 <= data && data <= 0xff; |
-} |
- |
-} // namespace |
- |
-MIDIMessageQueue::MIDIMessageQueue(bool allow_running_status) |
- : allow_running_status_(allow_running_status) {} |
- |
-MIDIMessageQueue::~MIDIMessageQueue() {} |
- |
-void MIDIMessageQueue::Add(const std::vector<uint8>& data) { |
- queue_.insert(queue_.end(), data.begin(), data.end()); |
-} |
- |
-void MIDIMessageQueue::Add(const uint8* data, size_t length) { |
- queue_.insert(queue_.end(), data, data + length); |
-} |
- |
-void MIDIMessageQueue::Get(std::vector<uint8>* message) { |
- message->clear(); |
- |
- while (true) { |
- if (queue_.empty()) |
- return; |
- |
- const uint8 next = queue_.front(); |
- queue_.pop_front(); |
- |
- // "System Real Time Messages" is a special kind of MIDI messages, which can |
- // appear at arbitrary byte position of MIDI stream. Here we reorder |
- // "System Real Time Messages" prior to |next_message_| so that each message |
- // can be clearly separated as a complete MIDI message. |
- if (IsSystemRealTimeMessage(next)) { |
- message->push_back(next); |
- return; |
- } |
- |
- // Here |next_message_[0]| may contain the previous status byte when |
- // |allow_running_status_| is true. Following condition fixes up |
- // |next_message_| if running status condition is not fulfilled. |
- if (!next_message_.empty() && |
- ((next_message_[0] == kSysEx && IsFirstStatusByte(next)) || |
- (next_message_[0] != kSysEx && !IsDataByte(next)))) { |
- // An invalid data sequence is found or running status condition is not |
- // fulfilled. |
- next_message_.clear(); |
- } |
- |
- if (next_message_.empty()) { |
- if (IsFirstStatusByte(next)) { |
- next_message_.push_back(next); |
- } else { |
- // MIDI protocol doesn't provide any error correction mechanism in |
- // physical layers, and incoming messages can be corrupted, and should |
- // be corrected here. |
- } |
- continue; |
- } |
- |
- // Here we can assume |next_message_| starts with a valid status byte. |
- const uint8 status_byte = next_message_[0]; |
- next_message_.push_back(next); |
- |
- if (status_byte == kSysEx) { |
- if (next == kEndOfSysEx) { |
- std::swap(*message, next_message_); |
- next_message_.clear(); |
- return; |
- } |
- continue; |
- } |
- |
- DCHECK(IsDataByte(next)); |
- DCHECK_NE(kSysEx, status_byte); |
- const size_t target_len = GetMIDIMessageLength(status_byte); |
- if (next_message_.size() < target_len) |
- continue; |
- if (next_message_.size() == target_len) { |
- std::swap(*message, next_message_); |
- next_message_.clear(); |
- if (allow_running_status_) { |
- // Speculatively keep the status byte in case of running status. If this |
- // assumption is not true, |next_message_| will be cleared anyway. |
- next_message_.push_back(status_byte); |
- } |
- return; |
- } |
- |
- NOTREACHED(); |
- } |
-} |
- |
-} // namespace media |