Chromium Code Reviews| Index: media/midi/midi_message_queue.h |
| diff --git a/media/midi/midi_message_queue.h b/media/midi/midi_message_queue.h |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..14865d167915eb5ba9cc792d67bdabe5f386abb9 |
| --- /dev/null |
| +++ b/media/midi/midi_message_queue.h |
| @@ -0,0 +1,74 @@ |
| +// Copyright (c) 2013 The Chromium Authors. All rights reserved. |
|
Takashi Toyoshima
2013/11/19 01:08:37
Any reason to keep it having in not content/browse
yukawa
2013/11/19 09:41:41
Because it was originally written for media/midi/m
Takashi Toyoshima
2013/11/19 12:49:59
If you don't have a plan to use this file in media
yukawa
2013/11/19 14:49:31
Yeah, I'm planning to use it from media/midi/midi_
Takashi Toyoshima
2013/11/20 10:04:58
sgtm
|
| +// Use of this source code is governed by a BSD-style license that can be |
| +// found in the LICENSE file. |
| + |
| +#ifndef MEDIA_MIDI_MIDI_MESSAGE_QUEUE_H_ |
| +#define MEDIA_MIDI_MIDI_MESSAGE_QUEUE_H_ |
| + |
| +#include <deque> |
| +#include <vector> |
| + |
| +#include "base/basictypes.h" |
| +#include "media/base/media_export.h" |
| + |
| +namespace media { |
| + |
| +// A simple message splitter for possibly unsafe MIDI data stream. This class |
| +// allows you to |
| +// - maintain fragmented MIDI message. |
| +// - skip any invalid data sequence. |
| +// - reorder MIDI messages so that "System Real Time Message", which can be |
| +// inserted at any point of the byte stream, is placed at the boundary of |
| +// complete MIDI messages. |
| +// - (Optional) reconstruct complete MIDI messages from data stream that is |
| +// compressed with "running status". |
| +// |
| +// Example (pseudo message loop): |
| +// MIDIMessageQueue queue(true); // true to support "running status" |
| +// while (true) { |
| +// if (is_incomming_midi_data_available()) { |
| +// std::vector<uint8> incomming_data; |
| +// read_incomming_midi_data(&incomming_data) |
| +// queue.Add(incomming_data); |
| +// } |
| +// while (true) { |
| +// std::vector<uint8> next_message; |
| +// queue.Get(&next_message); |
| +// if (!next_message.empty()) |
| +// dispatch(next_message); |
| +// } |
| +// } |
| +class MEDIA_EXPORT MIDIMessageQueue { |
| + public: |
| + // Initializes the queue. Set true to |allow_running_status| to enable |
| + // "MIDI running status" reconstruction. |
| + explicit MIDIMessageQueue(bool allow_running_status); |
| + ~MIDIMessageQueue(); |
| + |
| + // Enqueues |data| to the internal buffer. |
| + void Add(const std::vector<uint8>& data); |
| + // Enqueues |data| to the internal buffer. |data| must be valid until |
| + // this method returns. |
| + void Add(const uint8* data, size_t length); |
| + |
| + // Fills the next complete MIDI message into |message|. If |message| is |
| + // not empty, the data sequence falls into one of the following types of |
| + // MIDI message. |
| + // - Single "Channel Voice Message" (w/o "System Real Time Messages") |
| + // - Single "Channel Mode Message" (w/o "System Real Time Messages") |
| + // - Single "System Exclusive Message" (w/o "System Real Time Messages") |
| + // - Single "System Common Message" (w/o "System Real Time Messages") |
| + // - Single "System Real Time message" |
| + // |message| is empty if there is no complete MIDI message any more. |
| + void Get(std::vector<uint8>* message); |
| + |
| + private: |
| + std::deque<uint8> queue_; |
| + std::vector<uint8> next_message_; |
| + const bool allow_running_status_; |
| + DISALLOW_COPY_AND_ASSIGN(MIDIMessageQueue); |
| +}; |
| + |
| +} // namespace media |
| + |
| +#endif // MEDIA_MIDI_MIDI_MESSAGE_QUEUE_H_ |