Implementation of MediaCodecPlayer stage 1

media/base/android/access_unit_queue.h

+// Copyright 2015 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.
+
+#ifndef MEDIA_BASE_ANDROID_ACCESS_UNIT_QUEUE_H_
+#define MEDIA_BASE_ANDROID_ACCESS_UNIT_QUEUE_H_
+
+#include <deque>
+
+#include "base/macros.h"
+#include "base/synchronization/lock.h"
+#include "media/base/android/demuxer_stream_player_params.h"
+
+namespace media {
+
+// The queue of incoming data for MediaCodecDecoder.
+//
+// The data comes in the form of access units. Each access unit has a type,
+// if the type is |kConfigChanged| the access unit itself has no data, but
+// is accompanied with DemuxerConfigs.
+// The queue is accessed on the Media thread that puts the incoming data in and
+// the Decoder thread that gets the next access unit and eventually removes it
+// from the queue.
+class AccessUnitQueue {
+ public:
+  // Information about the queue state and the access unit at the front.
+  struct Info {
+    // The unit at front. Null if the queue is empty.
+    const AccessUnit* front_unit;
+
+    // Configs for the front unit if it is |kConfigChanged|, null otherwise.
+    const DemuxerConfigs* configs;
+
+    // Number of access units in the queue.
+    int length;
+
+    // Whether the queue contains End Of Stream.
+    bool has_eos;
+
+    Info()
+        : front_unit(nullptr), configs(nullptr), length(0), has_eos(false) {}
+  };
+
+  AccessUnitQueue();
+  ~AccessUnitQueue();
+
+  // Appends the incoming data to the queue.
+  void PushBack(const DemuxerData& frames);
+
+  // Removes one access unit from the front.
+  void PopFront();
+
+  // Clears the queue
+  void Flush();
+
+  // Looks for the first key frame and if it exists, removes prior frames and
+  // returns true. If it does not exist returns false.
+  bool SkipToKeyFrame();
+
+  // Returns the information about the queue.
+  void GetInfo(Info* info) const;
+
+ private:
+  // The queue of access units
+  std::deque<AccessUnit> access_units_;
+
+  // The queue of corresponding configurations. Some access units has the state
+  // set to |kConfigChanged|, these units have no data and no PTS, and for each
+  // there is one entry in |demuxer_configs_|.
+  std::deque<DemuxerConfigs> demuxer_configs_;
+
+  // Indicates that a unit with End Of Stream flag has been appended.
+  bool has_eos_;
+
+  // The queue works on two threads.
+  mutable base::Lock lock_;
+
+  DISALLOW_COPY_AND_ASSIGN(AccessUnitQueue);
+};
+
+}  // namespace media
+
+#endif  // MEDIA_BASE_ANDROID_ACCESS_UNIT_QUEUE_H_