dom/midi/MIDIMessageQueue.cpp

   1 /* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
   2 /* vim:set ts=2 sw=2 sts=2 et cindent: */
   3 /* This Source Code Form is subject to the terms of the Mozilla Public
   4  * License, v. 2.0. If a copy of the MPL was not distributed with this
   5  * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
   6
   7 #include "MIDIMessageQueue.h"
   8
   9 namespace mozilla {
  10 namespace dom {
  11
  12 MIDIMessageQueue::MIDIMessageQueue() : mMutex("MIDIMessageQueue::mMutex") {}
  13
  14 class MIDIMessageTimestampComparator {
  15  public:
  16   bool Equals(const MIDIMessage& a, const MIDIMessage& b) const {
  17     return a.timestamp() == b.timestamp();
  18   }
  19   bool LessThan(const MIDIMessage& a, const MIDIMessage& b) const {
  20     return a.timestamp() < b.timestamp();
  21   }
  22 };
  23
  24 void MIDIMessageQueue::Add(nsTArray<MIDIMessage>& aMsg) {
  25   MutexAutoLock lock(mMutex);
  26   for (auto msg : aMsg) {
  27     mMessageQueue.InsertElementSorted(msg, MIDIMessageTimestampComparator());
  28   }
  29 }
  30
  31 void MIDIMessageQueue::GetMessagesBefore(TimeStamp aTimestamp,
  32                                          nsTArray<MIDIMessage>& aMsgQueue) {
  33   MutexAutoLock lock(mMutex);
  34   int i = 0;
  35   for (auto msg : mMessageQueue) {
  36     if (aTimestamp < msg.timestamp()) {
  37       break;
  38     }
  39     aMsgQueue.AppendElement(msg);
  40     i++;
  41   }
  42   if (i > 0) {
  43     mMessageQueue.RemoveElementsAt(0, i);
  44   }
  45 }
  46
  47 void MIDIMessageQueue::GetMessages(nsTArray<MIDIMessage>& aMsgQueue) {
  48   MutexAutoLock lock(mMutex);
  49   aMsgQueue.AppendElements(mMessageQueue);
  50   mMessageQueue.Clear();
  51 }
  52
  53 void MIDIMessageQueue::Clear() {
  54   MutexAutoLock lock(mMutex);
  55   mMessageQueue.Clear();
  56 }
  57
  58 void MIDIMessageQueue::ClearAfterNow() {
  59   MutexAutoLock lock(mMutex);
  60   TimeStamp now = TimeStamp::Now();
  61   int i = 0;
  62   for (auto msg : mMessageQueue) {
  63     if (now < msg.timestamp()) {
  64       break;
  65     }
  66     i++;
  67   }
  68   if (i > 0) {
  69     mMessageQueue.RemoveElementsAt(0, i);
  70   }
  71 }
  72
  73 }  // namespace dom
  74 }  // namespace mozilla