| OLD | NEW |
| (Empty) |
| 1 // Copyright 2013 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_message_queue.h" | |
| 6 | |
| 7 #include <algorithm> | |
| 8 | |
| 9 #include "base/logging.h" | |
| 10 #include "media/midi/midi_message_util.h" | |
| 11 | |
| 12 namespace media { | |
| 13 namespace { | |
| 14 | |
| 15 const uint8 kSysEx = 0xf0; | |
| 16 const uint8 kEndOfSysEx = 0xf7; | |
| 17 | |
| 18 bool IsDataByte(uint8 data) { | |
| 19 return (data & 0x80) == 0; | |
| 20 } | |
| 21 | |
| 22 bool IsFirstStatusByte(uint8 data) { | |
| 23 return !IsDataByte(data) && data != kEndOfSysEx; | |
| 24 } | |
| 25 | |
| 26 bool IsSystemRealTimeMessage(uint8 data) { | |
| 27 return 0xf8 <= data && data <= 0xff; | |
| 28 } | |
| 29 | |
| 30 } // namespace | |
| 31 | |
| 32 MIDIMessageQueue::MIDIMessageQueue(bool allow_running_status) | |
| 33 : allow_running_status_(allow_running_status) {} | |
| 34 | |
| 35 MIDIMessageQueue::~MIDIMessageQueue() {} | |
| 36 | |
| 37 void MIDIMessageQueue::Add(const std::vector<uint8>& data) { | |
| 38 queue_.insert(queue_.end(), data.begin(), data.end()); | |
| 39 } | |
| 40 | |
| 41 void MIDIMessageQueue::Add(const uint8* data, size_t length) { | |
| 42 queue_.insert(queue_.end(), data, data + length); | |
| 43 } | |
| 44 | |
| 45 void MIDIMessageQueue::Get(std::vector<uint8>* message) { | |
| 46 message->clear(); | |
| 47 | |
| 48 while (true) { | |
| 49 if (queue_.empty()) | |
| 50 return; | |
| 51 | |
| 52 const uint8 next = queue_.front(); | |
| 53 queue_.pop_front(); | |
| 54 | |
| 55 // "System Real Time Messages" is a special kind of MIDI messages, which can | |
| 56 // appear at arbitrary byte position of MIDI stream. Here we reorder | |
| 57 // "System Real Time Messages" prior to |next_message_| so that each message | |
| 58 // can be clearly separated as a complete MIDI message. | |
| 59 if (IsSystemRealTimeMessage(next)) { | |
| 60 message->push_back(next); | |
| 61 return; | |
| 62 } | |
| 63 | |
| 64 // Here |next_message_[0]| may contain the previous status byte when | |
| 65 // |allow_running_status_| is true. Following condition fixes up | |
| 66 // |next_message_| if running status condition is not fulfilled. | |
| 67 if (!next_message_.empty() && | |
| 68 ((next_message_[0] == kSysEx && IsFirstStatusByte(next)) || | |
| 69 (next_message_[0] != kSysEx && !IsDataByte(next)))) { | |
| 70 // An invalid data sequence is found or running status condition is not | |
| 71 // fulfilled. | |
| 72 next_message_.clear(); | |
| 73 } | |
| 74 | |
| 75 if (next_message_.empty()) { | |
| 76 if (IsFirstStatusByte(next)) { | |
| 77 next_message_.push_back(next); | |
| 78 } else { | |
| 79 // MIDI protocol doesn't provide any error correction mechanism in | |
| 80 // physical layers, and incoming messages can be corrupted, and should | |
| 81 // be corrected here. | |
| 82 } | |
| 83 continue; | |
| 84 } | |
| 85 | |
| 86 // Here we can assume |next_message_| starts with a valid status byte. | |
| 87 const uint8 status_byte = next_message_[0]; | |
| 88 next_message_.push_back(next); | |
| 89 | |
| 90 if (status_byte == kSysEx) { | |
| 91 if (next == kEndOfSysEx) { | |
| 92 std::swap(*message, next_message_); | |
| 93 next_message_.clear(); | |
| 94 return; | |
| 95 } | |
| 96 continue; | |
| 97 } | |
| 98 | |
| 99 DCHECK(IsDataByte(next)); | |
| 100 DCHECK_NE(kSysEx, status_byte); | |
| 101 const size_t target_len = GetMIDIMessageLength(status_byte); | |
| 102 if (next_message_.size() < target_len) | |
| 103 continue; | |
| 104 if (next_message_.size() == target_len) { | |
| 105 std::swap(*message, next_message_); | |
| 106 next_message_.clear(); | |
| 107 if (allow_running_status_) { | |
| 108 // Speculatively keep the status byte in case of running status. If this | |
| 109 // assumption is not true, |next_message_| will be cleared anyway. | |
| 110 next_message_.push_back(status_byte); | |
| 111 } | |
| 112 return; | |
| 113 } | |
| 114 | |
| 115 NOTREACHED(); | |
| 116 } | |
| 117 } | |
| 118 | |
| 119 } // namespace media | |
| OLD | NEW |