| // Copyright (c) 2012 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 COBALT_MEDIA_FILTERS_BLOCKING_URL_PROTOCOL_H_ |
| #define COBALT_MEDIA_FILTERS_BLOCKING_URL_PROTOCOL_H_ |
| |
| #include "base/basictypes.h" |
| #include "base/callback.h" |
| #include "base/synchronization/waitable_event.h" |
| #include "cobalt/media/filters/ffmpeg_glue.h" |
| #include "starboard/types.h" |
| |
| namespace cobalt { |
| namespace media { |
| |
| class DataSource; |
| |
| // An implementation of FFmpegURLProtocol that blocks until the underlying |
| // asynchronous DataSource::Read() operation completes. |
| class MEDIA_EXPORT BlockingUrlProtocol : public FFmpegURLProtocol { |
| public: |
| // Implements FFmpegURLProtocol using the given |data_source|. |error_cb| is |
| // fired any time DataSource::Read() returns an error. |
| // |
| // TODO(scherkus): After all blocking operations are isolated on a separate |
| // thread we should be able to eliminate |error_cb|. |
| BlockingUrlProtocol(DataSource* data_source, const base::Closure& error_cb); |
| virtual ~BlockingUrlProtocol(); |
| |
| // Aborts any pending reads by returning a read error. After this method |
| // returns all subsequent calls to Read() will immediately fail. |
| void Abort(); |
| |
| // FFmpegURLProtocol implementation. |
| int Read(int size, uint8_t* data) OVERRIDE; |
| bool GetPosition(int64_t* position_out) OVERRIDE; |
| bool SetPosition(int64_t position) OVERRIDE; |
| bool GetSize(int64_t* size_out) OVERRIDE; |
| bool IsStreaming() OVERRIDE; |
| |
| private: |
| // Sets |last_read_bytes_| and signals the blocked thread that the read |
| // has completed. |
| void SignalReadCompleted(int size); |
| |
| DataSource* data_source_; |
| base::Closure error_cb_; |
| |
| // Used to unblock the thread during shutdown and when reads complete. |
| base::WaitableEvent aborted_; |
| base::WaitableEvent read_complete_; |
| |
| // Cached number of bytes last read from the data source. |
| int last_read_bytes_; |
| |
| // Cached position within the data source. |
| int64_t read_position_; |
| |
| DISALLOW_IMPLICIT_CONSTRUCTORS(BlockingUrlProtocol); |
| }; |
| |
| } // namespace media |
| } // namespace cobalt |
| |
| #endif // COBALT_MEDIA_FILTERS_BLOCKING_URL_PROTOCOL_H_ |