blob: 60f15c3f0fae9740ad2d7e74203fe77ea8c2ac32 [file] [log] [blame]
/*
* Copyright (C) 2013 Google Inc. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are
* met:
*
* * Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* * Redistributions in binary form must reproduce the above
* copyright notice, this list of conditions and the following disclaimer
* in the documentation and/or other materials provided with the
* distribution.
* * Neither the name of Google Inc. nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#ifndef SourceBuffer_h
#define SourceBuffer_h
#include "core/dom/ActiveDOMObject.h"
#include "core/fileapi/FileReaderLoaderClient.h"
#include "modules/EventTargetModules.h"
#include "platform/AsyncMethodRunner.h"
#include "platform/weborigin/KURL.h"
#include "wtf/Forward.h"
#include "wtf/RefCounted.h"
#include "wtf/text/WTFString.h"
namespace blink {
class ExceptionState;
class FileReaderLoader;
class GenericEventQueue;
class MediaSource;
class Stream;
class TimeRanges;
class WebSourceBuffer;
class SourceBuffer FINAL : public RefCountedGarbageCollectedWillBeGarbageCollectedFinalized<SourceBuffer>, public ActiveDOMObject, public EventTargetWithInlineData, public FileReaderLoaderClient {
DEFINE_EVENT_TARGET_REFCOUNTING_WILL_BE_REMOVED(RefCountedGarbageCollected<SourceBuffer>);
WILL_BE_USING_GARBAGE_COLLECTED_MIXIN(SourceBuffer);
public:
static SourceBuffer* create(PassOwnPtr<WebSourceBuffer>, MediaSource*, GenericEventQueue*);
static const AtomicString& segmentsKeyword();
static const AtomicString& sequenceKeyword();
virtual ~SourceBuffer();
// SourceBuffer.idl methods
const AtomicString& mode() const { return m_mode; }
void setMode(const AtomicString&, ExceptionState&);
bool updating() const { return m_updating; }
PassRefPtrWillBeRawPtr<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();
// ActiveDOMObject interface
virtual bool hasPendingActivity() const OVERRIDE;
virtual void suspend() OVERRIDE;
virtual void resume() OVERRIDE;
virtual void stop() OVERRIDE;
// EventTarget interface
virtual ExecutionContext* executionContext() const OVERRIDE;
virtual const AtomicString& interfaceName() const OVERRIDE;
virtual void trace(Visitor*) OVERRIDE;
private:
SourceBuffer(PassOwnPtr<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();
// FileReaderLoaderClient interface
virtual void didStartLoading() OVERRIDE;
virtual void didReceiveDataForClient(const char* data, unsigned dataLength) OVERRIDE;
virtual void didFinishLoading() OVERRIDE;
virtual void didFail(FileError::ErrorCode) OVERRIDE;
OwnPtr<WebSourceBuffer> m_webSourceBuffer;
Member<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;
size_t m_pendingAppendDataOffset;
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;
};
} // namespace blink
#endif