Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(778)

Side by Side Diff: media/base/android/access_unit_queue.h

Issue 2276343005: Delete MediaCodecPlayer, it's time! (Closed)
Patch Set: Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « media/base/android/BUILD.gn ('k') | media/base/android/access_unit_queue.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 // Copyright 2015 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 #ifndef MEDIA_BASE_ANDROID_ACCESS_UNIT_QUEUE_H_
6 #define MEDIA_BASE_ANDROID_ACCESS_UNIT_QUEUE_H_
7
8 #include <stddef.h>
9
10 #include <list>
11
12 #include "base/macros.h"
13 #include "base/synchronization/lock.h"
14 #include "media/base/android/demuxer_stream_player_params.h"
15
16 namespace media {
17
18 // The queue of incoming data for MediaCodecDecoder.
19 //
20 // The data comes in the form of access units. Each access unit has a type.
21 // If the type is |kConfigChanged| the access unit itself has no data, but
22 // is accompanied with DemuxerConfigs.
23 // The queue should be accessed on the Media thread that puts the incoming data
24 // in and on the Decoder thread that gets the next access unit and eventually
25 // removes it from the queue.
26 class AccessUnitQueue {
27 public:
28 // Information about the queue state and the access unit at the front.
29 struct Info {
30 // The unit at front. Null if the queue is empty. This pointer may be
31 // invalidated by the next Advance() or Flush() call and must be used
32 // before the caller calls these methods. The |front_unit| is owned by
33 // the queue itself - never delete it through this pointer.
34 const AccessUnit* front_unit;
35
36 // Configs for the front unit if it is |kConfigChanged|, null otherwise.
37 // The same validity rule applies: this pointer is only valid till the next
38 // Advance() or Flush() call, and |configs| is owned by the queue itself.
39 const DemuxerConfigs* configs;
40
41 // Number of access units in the queue.
42 int length;
43
44 // Number of access units in the queue excluding config units.
45 int data_length;
46
47 // Whether End Of Stream has been added to the queue. Cleared by Flush().
48 bool has_eos;
49
50 Info() : front_unit(nullptr), configs(nullptr), length(0), has_eos(false) {}
51 };
52
53 AccessUnitQueue();
54 ~AccessUnitQueue();
55
56 // Appends the incoming data to the queue.
57 void PushBack(const DemuxerData& frames);
58
59 // Advances the front position to next unit. Logically the preceding units
60 // do not exist, but they can be physically removed later.
61 void Advance();
62
63 // Clears the queue, resets the length to zero and clears EOS condition.
64 void Flush();
65
66 // Looks back for the first key frame starting from the current one (i.e.
67 // the look-back is inclusive of the current front position).
68 // If the key frame exists, sets the current access unit to it and returns
69 // true. Otherwise returns false.
70 bool RewindToLastKeyFrame();
71
72 // Returns the information about the queue.
73 // The result is invalidated by the following Advance() or Flush call.
74 // There must be only one |Info| consumer at a time.
75 Info GetInfo() const;
76
77 // For unit tests only. These methods are not thread safe.
78 size_t NumChunksForTesting() const { return chunks_.size(); }
79 void SetHistorySizeForTesting(size_t number_of_history_chunks);
80
81 private:
82 // Returns the total number of access units (total_length) and the number of
83 // units excluding configiration change requests (data_length). The number is
84 // calculated between the current one and the end, incuding the current.
85 // Logically these are units that have not been consumed.
86 void GetUnconsumedAccessUnitLength(int* total_length, int* data_length) const;
87
88 // The queue of data chunks. It owns the chunks.
89 typedef std::list<DemuxerData*> DataChunkQueue;
90 DataChunkQueue chunks_;
91
92 // The chunk that contains the current access unit.
93 DataChunkQueue::iterator current_chunk_;
94
95 // Index of the current access unit within the current chunk.
96 size_t index_in_chunk_;
97
98 // Amount of chunks before the |current_chunk_| that's kept for history.
99 size_t history_chunks_amount_;
100
101 // Indicates that a unit with End Of Stream flag has been appended.
102 bool has_eos_;
103
104 // The lock protects all fields together.
105 mutable base::Lock lock_;
106
107 DISALLOW_COPY_AND_ASSIGN(AccessUnitQueue);
108 };
109
110 } // namespace media
111
112 #endif // MEDIA_BASE_ANDROID_ACCESS_UNIT_QUEUE_H_
OLDNEW
« no previous file with comments | « media/base/android/BUILD.gn ('k') | media/base/android/access_unit_queue.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698