#ifndef SourceBuffer_h
#define SourceBuffer_h
#include "bindings/v8/ScriptWrappable.h"
#include "core/dom/ActiveDOMObject.h"
#include "core/events/EventTarget.h"
#include "core/fileapi/FileReaderLoaderClient.h"
#include "platform/AsyncMethodRunner.h"
#include "platform/weborigin/KURL.h"
#include "wtf/OwnPtr.h"
#include "wtf/PassOwnPtr.h"
#include "wtf/PassRefPtr.h"
#include "wtf/RefCounted.h"
#include "wtf/RefPtr.h"
#include "wtf/text/WTFString.h"
namespace blink {
class WebSourceBuffer;
}
namespace WebCore {
class ExceptionState;
class FileReaderLoader;
class GenericEventQueue;
class MediaSource;
class Stream;
class TimeRanges;
class SourceBuffer FINAL : public RefCountedWillBeRefCountedGarbageCollected<SourceBuffer>, public ActiveDOMObject, public EventTargetWithInlineData, public ScriptWrappable, public FileReaderLoaderClient {
DEFINE_EVENT_TARGET_REFCOUNTING(RefCountedWillBeRefCountedGarbageCollected<SourceBuffer>);
public:
static PassRefPtrWillBeRawPtr<SourceBuffer> create(PassOwnPtr<blink::WebSourceBuffer>, MediaSource*, GenericEventQueue*);
static const AtomicString& segmentsKeyword();
static const AtomicString& sequenceKeyword();
virtual ~SourceBuffer();
const AtomicString& mode() const { return m_mode; }
void setMode(const AtomicString&, ExceptionState&);
bool updating() const { return m_updating; }
PassRefPtr<TimeRanges> buffered(ExceptionState&) const;
double timestampOffset() const;
void setTimestampOffset(double, ExceptionState&);
void appendBuffer(PassRefPtr<ArrayBuffer> data, ExceptionState&);
void appendBuffer(PassRefPtr<ArrayBufferView> data, ExceptionState&);
void appendStream(PassRefPtrWillBeRawPtr<Stream>, ExceptionState&);
void appendStream(PassRefPtrWillBeRawPtr<Stream>, unsigned long long maxSize, ExceptionState&);
void abort(ExceptionState&);
void remove(double start, double end, ExceptionState&);
double appendWindowStart() const;
void setAppendWindowStart(double, ExceptionState&);
double appendWindowEnd() const;
void setAppendWindowEnd(double, ExceptionState&);
void abortIfUpdating();
void removedFromMediaSource();
virtual bool hasPendingActivity() const OVERRIDE;
virtual void suspend() OVERRIDE;
virtual void resume() OVERRIDE;
virtual void stop() OVERRIDE;
virtual ExecutionContext* executionContext() const OVERRIDE;
virtual const AtomicString& interfaceName() const OVERRIDE;
void trace(Visitor*);
private:
SourceBuffer(PassOwnPtr<blink::WebSourceBuffer>, MediaSource*, GenericEventQueue*);
bool isRemoved() const;
void scheduleEvent(const AtomicString& eventName);
void appendBufferInternal(const unsigned char*, unsigned, ExceptionState&);
void appendBufferAsyncPart();
void removeAsyncPart();
void appendStreamInternal(PassRefPtrWillBeRawPtr<Stream>, ExceptionState&);
void appendStreamAsyncPart();
void appendStreamDone(bool success);
void clearAppendStreamState();
virtual void didStartLoading() OVERRIDE;
virtual void didReceiveDataForClient(const char* data, unsigned dataLength) OVERRIDE;
virtual void didFinishLoading() OVERRIDE;
virtual void didFail(FileError::ErrorCode) OVERRIDE;
OwnPtr<blink::WebSourceBuffer> m_webSourceBuffer;
RawPtrWillBeMember<MediaSource> m_source;
GenericEventQueue* m_asyncEventQueue;
AtomicString m_mode;
bool m_updating;
double m_timestampOffset;
double m_appendWindowStart;
double m_appendWindowEnd;
Vector<unsigned char> m_pendingAppendData;
AsyncMethodRunner<SourceBuffer> m_appendBufferAsyncPartRunner;
double m_pendingRemoveStart;
double m_pendingRemoveEnd;
AsyncMethodRunner<SourceBuffer> m_removeAsyncPartRunner;
bool m_streamMaxSizeValid;
unsigned long long m_streamMaxSize;
AsyncMethodRunner<SourceBuffer> m_appendStreamAsyncPartRunner;
RefPtrWillBeMember<Stream> m_stream;
OwnPtr<FileReaderLoader> m_loader;
};
}
#endif