| Index: media/base/composite_filter.cc
|
| diff --git a/media/base/composite_filter.cc b/media/base/composite_filter.cc
|
| index 3e7b60c372d979995831bb7f2c74c19128764138..d08eacb03ab6b1dbddf5a7eae947203941002390 100644
|
| --- a/media/base/composite_filter.cc
|
| +++ b/media/base/composite_filter.cc
|
| @@ -17,7 +17,7 @@ class CompositeFilter::FilterHostImpl : public FilterHost {
|
| FilterHost* host();
|
|
|
| // media::FilterHost methods.
|
| - virtual void SetError(PipelineError error);
|
| + virtual void SetError(PipelineStatus error);
|
| virtual base::TimeDelta GetTime() const;
|
| virtual base::TimeDelta GetDuration() const;
|
| virtual void SetTime(base::TimeDelta time);
|
| @@ -45,7 +45,7 @@ CompositeFilter::CompositeFilter(MessageLoop* message_loop)
|
| : state_(kCreated),
|
| sequence_index_(0),
|
| message_loop_(message_loop),
|
| - error_(PIPELINE_OK) {
|
| + status_(PIPELINE_OK) {
|
| DCHECK(message_loop);
|
| runnable_factory_.reset(
|
| new ScopedRunnableMethodFactory<CompositeFilter>(this));
|
| @@ -228,7 +228,7 @@ void CompositeFilter::ChangeState(State new_state) {
|
|
|
| void CompositeFilter::StartSerialCallSequence() {
|
| DCHECK_EQ(message_loop_, MessageLoop::current());
|
| - error_ = PIPELINE_OK;
|
| + status_ = PIPELINE_OK;
|
|
|
| if (!filters_.empty()) {
|
| sequence_index_ = 0;
|
| @@ -242,7 +242,7 @@ void CompositeFilter::StartSerialCallSequence() {
|
|
|
| void CompositeFilter::StartParallelCallSequence() {
|
| DCHECK_EQ(message_loop_, MessageLoop::current());
|
| - error_ = PIPELINE_OK;
|
| + status_ = PIPELINE_OK;
|
|
|
| if (!filters_.empty()) {
|
| sequence_index_ = 0;
|
| @@ -329,10 +329,10 @@ CompositeFilter::State CompositeFilter::GetNextState(State state) const {
|
|
|
| void CompositeFilter::SerialCallback() {
|
| DCHECK_EQ(message_loop_, MessageLoop::current());
|
| - if (error_ != PIPELINE_OK) {
|
| + if (status_ != PIPELINE_OK) {
|
| // We encountered an error. Terminate the sequence now.
|
| ChangeState(kError);
|
| - HandleError(error_);
|
| + HandleError(status_);
|
| return;
|
| }
|
|
|
| @@ -360,10 +360,10 @@ void CompositeFilter::ParallelCallback() {
|
| sequence_index_++;
|
|
|
| if (sequence_index_ == filters_.size()) {
|
| - if (error_ != PIPELINE_OK) {
|
| + if (status_ != PIPELINE_OK) {
|
| // We encountered an error.
|
| ChangeState(kError);
|
| - HandleError(error_);
|
| + HandleError(status_);
|
| return;
|
| }
|
|
|
| @@ -391,16 +391,14 @@ void CompositeFilter::OnCallSequenceDone() {
|
| }
|
| }
|
|
|
| -void CompositeFilter::SendErrorToHost(PipelineError error) {
|
| +void CompositeFilter::SendErrorToHost(PipelineStatus error) {
|
| if (host_impl_.get())
|
| host_impl_.get()->host()->SetError(error);
|
| }
|
|
|
| -void CompositeFilter::HandleError(PipelineError error) {
|
| - if (error != PIPELINE_OK) {
|
| - SendErrorToHost(error);
|
| - }
|
| -
|
| +void CompositeFilter::HandleError(PipelineStatus error) {
|
| + DCHECK_NE(error, PIPELINE_OK);
|
| + SendErrorToHost(error);
|
| DispatchPendingCallback();
|
| }
|
|
|
| @@ -435,7 +433,7 @@ bool CompositeFilter::CanForwardError() {
|
| return (state_ == kCreated) || (state_ == kPlaying) || (state_ == kPaused);
|
| }
|
|
|
| -void CompositeFilter::SetError(PipelineError error) {
|
| +void CompositeFilter::SetError(PipelineStatus error) {
|
| // TODO(acolwell): Temporary hack to handle errors that occur
|
| // during filter initialization. In this case we just forward
|
| // the error to the host even if it is on the wrong thread. We
|
| @@ -461,7 +459,7 @@ void CompositeFilter::SetError(PipelineError error) {
|
| if (state_ == kStopPending || state_ == kStopped)
|
| return;
|
|
|
| - error_ = error;
|
| + status_ = error;
|
| if (CanForwardError())
|
| SendErrorToHost(error);
|
| }
|
| @@ -477,7 +475,7 @@ FilterHost* CompositeFilter::FilterHostImpl::host() {
|
| }
|
|
|
| // media::FilterHost methods.
|
| -void CompositeFilter::FilterHostImpl::SetError(PipelineError error) {
|
| +void CompositeFilter::FilterHostImpl::SetError(PipelineStatus error) {
|
| parent_->SetError(error);
|
| }
|
|
|
|
|