OLD | NEW |
1 // Copyright (c) 2006-2009 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2008-2009 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 // Implementation of FilterHost. | 5 // Implementation of FilterHost. |
6 | 6 |
7 #ifndef MEDIA_BASE_FILTER_HOST_IMPL_H_ | 7 #ifndef MEDIA_BASE_FILTER_HOST_IMPL_H_ |
8 #define MEDIA_BASE_FILTER_HOST_IMPL_H_ | 8 #define MEDIA_BASE_FILTER_HOST_IMPL_H_ |
9 | 9 |
10 #include "base/task.h" | 10 #include "base/task.h" |
11 #include "media/base/filter_host.h" | 11 #include "media/base/filter_host.h" |
12 #include "media/base/pipeline_impl.h" | 12 #include "media/base/pipeline_impl.h" |
13 | 13 |
14 namespace media { | 14 namespace media { |
15 | 15 |
16 class FilterHostImpl : public FilterHost { | 16 class FilterHostImpl : public FilterHost { |
17 public: | 17 public: |
18 // FilterHost interface. | 18 // FilterHost interface. |
19 virtual const PipelineStatus* GetPipelineStatus() const; | |
20 virtual void SetTimeUpdateCallback(Callback1<base::TimeDelta>::Type* cb); | |
21 virtual void ScheduleTimeUpdateCallback(base::TimeDelta time); | |
22 virtual void InitializationComplete(); | 19 virtual void InitializationComplete(); |
23 virtual void Error(PipelineError error); | 20 virtual void Error(PipelineError error); |
| 21 virtual base::TimeDelta GetTime() const; |
24 virtual void SetTime(base::TimeDelta time); | 22 virtual void SetTime(base::TimeDelta time); |
25 virtual void SetDuration(base::TimeDelta duration); | 23 virtual void SetDuration(base::TimeDelta duration); |
26 virtual void SetBufferedTime(base::TimeDelta buffered_time); | 24 virtual void SetBufferedTime(base::TimeDelta buffered_time); |
27 virtual void SetTotalBytes(int64 total_bytes); | 25 virtual void SetTotalBytes(int64 total_bytes); |
28 virtual void SetBufferedBytes(int64 buffered_bytes); | 26 virtual void SetBufferedBytes(int64 buffered_bytes); |
29 virtual void SetVideoSize(size_t width, size_t height); | 27 virtual void SetVideoSize(size_t width, size_t height); |
30 | 28 |
31 // These methods are public, but are intended for use by the | 29 // These methods are public, but are intended for use by the |
32 // PipelineThread class only. | 30 // PipelineThread class only. |
33 | 31 |
34 // Creates a FilterHostImpl object and populates the filter_type_ member | 32 // Creates a FilterHostImpl object and populates the |filter_type_| member |
35 // by calling the Filter class's static filter_type() method. This ensures | 33 // by calling the Filter class's static filter_type() method. This ensures |
36 // that the GetFilter method can safely cast the filter interface from the | 34 // that the GetFilter method can safely cast the filter interface from the |
37 // MediaFilter base class interface to the specific Filter interface. | 35 // MediaFilter base class interface to the specific Filter interface. |
38 template <class Filter> | 36 template <class Filter> |
39 FilterHostImpl(PipelineThread* pipeline_thread, Filter* filter) | 37 FilterHostImpl(PipelineThread* pipeline_thread, Filter* filter) |
40 : pipeline_thread_(pipeline_thread), | 38 : pipeline_thread_(pipeline_thread), |
41 filter_type_(Filter::filter_type()), | 39 filter_type_(Filter::filter_type()), |
42 filter_(filter), | 40 filter_(filter), |
43 scheduled_time_update_task_(NULL), | |
44 stopped_(false) { | 41 stopped_(false) { |
45 } | 42 } |
46 ~FilterHostImpl() {} | 43 ~FilterHostImpl() {} |
47 | 44 |
48 // If this FilterHost contains a filter of the specifed Filter class, then | 45 // If this FilterHost contains a filter of the specified Filter class, then |
49 // this method returns a pointer to the interface, otherwise it returns NULL | 46 // this method returns a pointer to the interface, otherwise it returns NULL |
50 // in |*filter_out|. | 47 // in |*filter_out|. |
51 template <class Filter> | 48 template <class Filter> |
52 void GetFilter(scoped_refptr<Filter>* filter_out) const { | 49 void GetFilter(scoped_refptr<Filter>* filter_out) const { |
53 *filter_out = (Filter::filter_type() == filter_type_) ? | 50 *filter_out = (Filter::filter_type() == filter_type_) ? |
54 reinterpret_cast<Filter*>(media_filter()) : NULL; | 51 reinterpret_cast<Filter*>(media_filter()) : NULL; |
55 } | 52 } |
56 | 53 |
57 // Call the filter if it has registered a time update callback if the filter | |
58 // has registered one though the FilterHost::SetTimeUpdateCallback method. | |
59 void RunTimeUpdateCallback(base::TimeDelta time); | |
60 | |
61 // Stops the filter. | 54 // Stops the filter. |
62 void Stop(); | 55 void Stop(); |
63 | 56 |
64 // Used by the PipelineThread to call Seek and SetRate methods on filters. | 57 // Used by the PipelineThread to call Seek and SetRate methods on filters. |
65 MediaFilter* media_filter() const { return filter_; } | 58 MediaFilter* media_filter() const { return filter_; } |
66 | 59 |
67 private: | 60 private: |
68 // This task class is used to schedule a time update callback for the filter. | |
69 // Because a filter may call the ScheduleTimeUpdateCallback method from any | |
70 // thread, and becuase we only want to honor the last call to that method, | |
71 // we always have only one current task. | |
72 // We are required to keep a pointer to the host and a boolean that tells | |
73 // us if the task was canceled because the cancelation could happen on one | |
74 // thread, just as the pipeline thread is calling the Run method on this task. | |
75 // So, we can't just NULL out the host_ to cancel this because it could | |
76 // fault. Once we have called the host, it needs to enter it's critical | |
77 // section and make sure that the task that has Run is, in fact, the last one | |
78 // that was scheduled. | |
79 // In the case where the filter host is Stopping (or being destroyed), it will | |
80 // be guaranteed to happen on the pipeline thread, thus making the setting | |
81 // of the |canceled_| bool thread safe since the task would only execute on | |
82 // the pipeline thread. This means that it could be possible for a task to | |
83 // hold a pointer to a |host_| that has been deleted, but it will never access | |
84 // that pointer because the task was canceled. | |
85 class TimeUpdateTask : public CancelableTask { | |
86 public: | |
87 explicit TimeUpdateTask(FilterHostImpl* host) | |
88 : host_(host), | |
89 canceled_(false) {} | |
90 | |
91 virtual void Run() { | |
92 if (!canceled_) { | |
93 host_->RunScheduledTimeUpdateCallback(this); | |
94 } | |
95 } | |
96 | |
97 virtual void Cancel() { | |
98 canceled_ = true; | |
99 } | |
100 | |
101 private: | |
102 FilterHostImpl* const host_; | |
103 bool canceled_; | |
104 | |
105 DISALLOW_COPY_AND_ASSIGN(TimeUpdateTask); | |
106 }; | |
107 | |
108 // Method used by the TimeUpdateTask to call back to the filter. | |
109 void RunScheduledTimeUpdateCallback(TimeUpdateTask* caller); | |
110 | |
111 // Useful method for getting the pipeline. | 61 // Useful method for getting the pipeline. |
112 PipelineImpl* pipeline() const { return pipeline_thread_->pipeline(); } | 62 PipelineImpl* pipeline() const { return pipeline_thread_->pipeline(); } |
113 | 63 |
114 // PipelineThread that owns this FilterHostImpl. | 64 // PipelineThread that owns this FilterHostImpl. |
115 PipelineThread* const pipeline_thread_; | 65 PipelineThread* const pipeline_thread_; |
116 | 66 |
117 // The FilterType of the filter this host contains. | 67 // The FilterType of the filter this host contains. |
118 FilterType const filter_type_; | 68 FilterType const filter_type_; |
119 | 69 |
120 // A pointer to the filter's MediaFilter base interface. | 70 // A pointer to the filter's MediaFilter base interface. |
121 scoped_refptr<MediaFilter> filter_; | 71 scoped_refptr<MediaFilter> filter_; |
122 | 72 |
123 // An optional callback that will be called when the time is updated. | |
124 scoped_ptr<Callback1<base::TimeDelta>::Type> time_update_callback_; | |
125 | |
126 // Critical section used for scheduled time update callbacks. | 73 // Critical section used for scheduled time update callbacks. |
127 Lock time_update_lock_; | 74 Lock time_update_lock_; |
128 | 75 |
129 // Pointer to the current time update callback task. | |
130 TimeUpdateTask* scheduled_time_update_task_; | |
131 | |
132 // Used to avoid calling Filter's Stop() method multiple times. | 76 // Used to avoid calling Filter's Stop() method multiple times. |
133 bool stopped_; | 77 bool stopped_; |
134 | 78 |
135 DISALLOW_COPY_AND_ASSIGN(FilterHostImpl); | 79 DISALLOW_COPY_AND_ASSIGN(FilterHostImpl); |
136 }; | 80 }; |
137 | 81 |
138 } // namespace media | 82 } // namespace media |
139 | 83 |
140 #endif // MEDIA_BASE_FILTER_HOST_IMPL_H_ | 84 #endif // MEDIA_BASE_FILTER_HOST_IMPL_H_ |
OLD | NEW |