OLD | NEW |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef MEDIA_BASE_COMPOSITE_FILTER_H_ | 5 #ifndef MEDIA_BASE_COMPOSITE_FILTER_H_ |
6 #define MEDIA_BASE_COMPOSITE_FILTER_H_ | 6 #define MEDIA_BASE_COMPOSITE_FILTER_H_ |
7 | 7 |
8 #include "base/threading/thread.h" | 8 #include "base/task.h" |
9 #include "media/base/filter_host.h" | 9 #include "media/base/filter_host.h" |
10 #include "media/base/filters.h" | 10 #include "media/base/filters.h" |
11 | 11 |
| 12 class MessageLoop; |
| 13 |
12 namespace media { | 14 namespace media { |
13 | 15 |
14 class CompositeFilter : public Filter { | 16 class CompositeFilter : public Filter { |
15 public: | 17 public: |
16 typedef base::Thread* (*ThreadFactoryFunction)(const char* thread_name); | 18 explicit CompositeFilter(MessageLoop* message_loop); |
17 | |
18 CompositeFilter(MessageLoop* message_loop); | |
19 | |
20 // Constructor that allows the default thread creation strategy to be | |
21 // overridden. | |
22 CompositeFilter(MessageLoop* message_loop, | |
23 ThreadFactoryFunction thread_factory); | |
24 | 19 |
25 // Adds a filter to the composite. This is only allowed after set_host() | 20 // Adds a filter to the composite. This is only allowed after set_host() |
26 // is called and before the first state changing operation such as Play(), | 21 // is called and before the first state changing operation such as Play(), |
27 // Flush(), Stop(), or Seek(). True is returned if the filter was successfully | 22 // Flush(), Stop(), or Seek(). True is returned if the filter was successfully |
28 // added to the composite. False is returned if the filter couldn't be added | 23 // added to the composite. False is returned if the filter couldn't be added |
29 // because the composite is in the wrong state or the filter needed a thread | 24 // because the composite is in the wrong state. |
30 // and the composite was unable to create one. | |
31 bool AddFilter(scoped_refptr<Filter> filter); | 25 bool AddFilter(scoped_refptr<Filter> filter); |
32 | 26 |
33 // media::Filter methods. | 27 // media::Filter methods. |
34 virtual const char* major_mime_type() const; | 28 virtual const char* major_mime_type() const; |
35 virtual void set_host(FilterHost* host); | 29 virtual void set_host(FilterHost* host); |
36 virtual FilterHost* host(); | 30 virtual FilterHost* host(); |
37 virtual bool requires_message_loop() const; | |
38 virtual const char* message_loop_name() const; | |
39 virtual void set_message_loop(MessageLoop* message_loop); | |
40 virtual MessageLoop* message_loop(); | |
41 virtual void Play(FilterCallback* play_callback); | 31 virtual void Play(FilterCallback* play_callback); |
42 virtual void Pause(FilterCallback* pause_callback); | 32 virtual void Pause(FilterCallback* pause_callback); |
43 virtual void Flush(FilterCallback* flush_callback); | 33 virtual void Flush(FilterCallback* flush_callback); |
44 virtual void Stop(FilterCallback* stop_callback); | 34 virtual void Stop(FilterCallback* stop_callback); |
45 virtual void SetPlaybackRate(float playback_rate); | 35 virtual void SetPlaybackRate(float playback_rate); |
46 virtual void Seek(base::TimeDelta time, FilterCallback* seek_callback); | 36 virtual void Seek(base::TimeDelta time, FilterCallback* seek_callback); |
47 virtual void OnAudioRendererDisabled(); | 37 virtual void OnAudioRendererDisabled(); |
48 | 38 |
49 protected: | 39 protected: |
50 virtual ~CompositeFilter(); | 40 virtual ~CompositeFilter(); |
51 | 41 |
52 /// Default thread factory strategy. | |
53 static base::Thread* DefaultThreadFactory(const char* thread_name); | |
54 | |
55 void SetError(PipelineError error); | 42 void SetError(PipelineError error); |
56 | 43 |
57 private: | 44 private: |
58 class FilterHostImpl; | 45 class FilterHostImpl; |
59 | 46 |
60 enum State { | 47 enum State { |
61 kInvalid, | 48 kInvalid, |
62 kCreated, | 49 kCreated, |
63 kPaused, | 50 kPaused, |
64 kPlayPending, | 51 kPlayPending, |
65 kStopWhilePlayPending, | 52 kStopWhilePlayPending, |
66 kPlaying, | 53 kPlaying, |
67 kPausePending, | 54 kPausePending, |
68 kStopWhilePausePending, | 55 kStopWhilePausePending, |
69 kFlushPending, | 56 kFlushPending, |
70 kStopWhileFlushPending, | 57 kStopWhileFlushPending, |
71 kSeekPending, | 58 kSeekPending, |
72 kStopWhileSeekPending, | 59 kStopWhileSeekPending, |
73 kStopPending, | 60 kStopPending, |
74 kStopped, | 61 kStopped, |
75 kError | 62 kError |
76 }; | 63 }; |
77 | 64 |
78 // Initialization method called by constructors. | |
79 void Init(MessageLoop* message_loop, ThreadFactoryFunction thread_factory); | |
80 | |
81 // Transition to a new state. | 65 // Transition to a new state. |
82 void ChangeState(State new_state); | 66 void ChangeState(State new_state); |
83 | 67 |
84 // Start calling filters in a sequence. | 68 // Start calling filters in a sequence. |
85 void StartSerialCallSequence(); | 69 void StartSerialCallSequence(); |
86 | 70 |
87 // Call filters in parallel. | 71 // Call filters in parallel. |
88 void StartParallelCallSequence(); | 72 void StartParallelCallSequence(); |
89 | 73 |
90 // Call the filter based on the current value of state_. | 74 // Call the filter based on the current value of state_. |
(...skipping 26 matching lines...) Expand all Loading... |
117 | 101 |
118 // Helper function used by NewThreadSafeCallback() to make sure the | 102 // Helper function used by NewThreadSafeCallback() to make sure the |
119 // method gets called on the right thread. | 103 // method gets called on the right thread. |
120 static void OnCallback(MessageLoop* message_loop, | 104 static void OnCallback(MessageLoop* message_loop, |
121 CancelableTask* task); | 105 CancelableTask* task); |
122 | 106 |
123 // Helper function that indicates whether SetError() calls can be forwarded | 107 // Helper function that indicates whether SetError() calls can be forwarded |
124 // to the host of this filter. | 108 // to the host of this filter. |
125 bool CanForwardError(); | 109 bool CanForwardError(); |
126 | 110 |
127 // Vector of threads owned by the composite and used by filters in |filters_|. | |
128 typedef std::vector<base::Thread*> FilterThreadVector; | |
129 FilterThreadVector filter_threads_; | |
130 | |
131 // Vector of the filters added to the composite. | 111 // Vector of the filters added to the composite. |
132 typedef std::vector<scoped_refptr<Filter> > FilterVector; | 112 typedef std::vector<scoped_refptr<Filter> > FilterVector; |
133 FilterVector filters_; | 113 FilterVector filters_; |
134 | 114 |
135 // Factory function used to create filter threads. | |
136 ThreadFactoryFunction thread_factory_; | |
137 | |
138 // Callback for the pending request. | 115 // Callback for the pending request. |
139 scoped_ptr<FilterCallback> callback_; | 116 scoped_ptr<FilterCallback> callback_; |
140 | 117 |
141 // Time parameter for the pending Seek() request. | 118 // Time parameter for the pending Seek() request. |
142 base::TimeDelta pending_seek_time_; | 119 base::TimeDelta pending_seek_time_; |
143 | 120 |
144 // Current state of this filter. | 121 // Current state of this filter. |
145 State state_; | 122 State state_; |
146 | 123 |
147 // The index of the filter currently processing a request. | 124 // The index of the filter currently processing a request. |
(...skipping 10 matching lines...) Expand all Loading... |
158 PipelineError error_; | 135 PipelineError error_; |
159 | 136 |
160 scoped_ptr<ScopedRunnableMethodFactory<CompositeFilter> > runnable_factory_; | 137 scoped_ptr<ScopedRunnableMethodFactory<CompositeFilter> > runnable_factory_; |
161 | 138 |
162 DISALLOW_COPY_AND_ASSIGN(CompositeFilter); | 139 DISALLOW_COPY_AND_ASSIGN(CompositeFilter); |
163 }; | 140 }; |
164 | 141 |
165 } // namespace media | 142 } // namespace media |
166 | 143 |
167 #endif // MEDIA_BASE_COMPOSITE_FILTER_H_ | 144 #endif // MEDIA_BASE_COMPOSITE_FILTER_H_ |
OLD | NEW |