TextTrackLoader.cpp [plain text]
#include "config.h"
#if ENABLE(VIDEO_TRACK)
#include "TextTrackLoader.h"
#include "CachedResourceLoader.h"
#include "CachedTextTrack.h"
#include "CrossOriginAccessControl.h"
#include "Document.h"
#include "Logging.h"
#include "ResourceHandle.h"
#include "SecurityOrigin.h"
#include "SharedBuffer.h"
#include "WebVTTParser.h"
namespace WebCore {
TextTrackLoader::TextTrackLoader(TextTrackLoaderClient* client, ScriptExecutionContext* context)
: m_client(client)
, m_scriptExecutionContext(context)
, m_cueLoadTimer(this, &TextTrackLoader::cueLoadTimerFired)
, m_state(Idle)
, m_parseOffset(0)
, m_newCuesAvailable(false)
{
}
TextTrackLoader::~TextTrackLoader()
{
if (m_cachedCueData)
m_cachedCueData->removeClient(this);
}
void TextTrackLoader::cueLoadTimerFired(Timer<TextTrackLoader>* timer)
{
ASSERT_UNUSED(timer, timer == &m_cueLoadTimer);
if (m_newCuesAvailable) {
m_newCuesAvailable = false;
m_client->newCuesAvailable(this);
}
if (m_state >= Finished)
m_client->cueLoadingCompleted(this, m_state == Failed);
}
void TextTrackLoader::cancelLoad()
{
if (m_cachedCueData) {
m_cachedCueData->removeClient(this);
m_cachedCueData = 0;
}
}
void TextTrackLoader::processNewCueData(CachedResource* resource)
{
ASSERT(m_cachedCueData == resource);
if (m_state == Failed || !resource->data())
return;
SharedBuffer* buffer = resource->data();
if (m_parseOffset == buffer->size())
return;
if (!m_cueParser)
m_cueParser = WebVTTParser::create(this, m_scriptExecutionContext);
const char* data;
unsigned length;
while ((length = buffer->getSomeData(data, m_parseOffset))) {
m_cueParser->parseBytes(data, length);
m_parseOffset += length;
}
}
void TextTrackLoader::didReceiveData(CachedResource* resource)
{
ASSERT(m_cachedCueData == resource);
if (!resource->data())
return;
processNewCueData(resource);
}
void TextTrackLoader::corsPolicyPreventedLoad()
{
DEFINE_STATIC_LOCAL(String, consoleMessage, ("Cross-origin text track load denied by Cross-Origin Resource Sharing policy."));
Document* document = static_cast<Document*>(m_scriptExecutionContext);
document->addConsoleMessage(JSMessageSource, LogMessageType, ErrorMessageLevel, consoleMessage);
m_state = Failed;
}
void TextTrackLoader::notifyFinished(CachedResource* resource)
{
ASSERT(m_cachedCueData == resource);
Document* document = static_cast<Document*>(m_scriptExecutionContext);
if (!m_crossOriginMode.isNull()
&& !document->securityOrigin()->canRequest(resource->response().url())
&& !resource->passesAccessControlCheck(document->securityOrigin())) {
corsPolicyPreventedLoad();
}
if (m_state != Failed) {
processNewCueData(resource);
if (m_state != Failed)
m_state = resource->errorOccurred() ? Failed : Finished;
}
if (!m_cueLoadTimer.isActive())
m_cueLoadTimer.startOneShot(0);
cancelLoad();
}
bool TextTrackLoader::load(const KURL& url, const String& crossOriginMode)
{
cancelLoad();
if (!m_client->shouldLoadCues(this))
return false;
ASSERT(m_scriptExecutionContext->isDocument());
Document* document = static_cast<Document*>(m_scriptExecutionContext);
ResourceRequest cueRequest(document->completeURL(url));
if (!crossOriginMode.isNull()) {
m_crossOriginMode = crossOriginMode;
StoredCredentials allowCredentials = equalIgnoringCase(crossOriginMode, "use-credentials") ? AllowStoredCredentials : DoNotAllowStoredCredentials;
updateRequestForAccessControl(cueRequest, document->securityOrigin(), allowCredentials);
} else {
if (!document->securityOrigin()->canRequest(url)) {
corsPolicyPreventedLoad();
return false;
}
}
CachedResourceLoader* cachedResourceLoader = document->cachedResourceLoader();
m_cachedCueData = cachedResourceLoader->requestTextTrack(cueRequest);
if (m_cachedCueData)
m_cachedCueData->addClient(this);
m_client->cueLoadingStarted(this);
return true;
}
void TextTrackLoader::newCuesParsed()
{
if (m_cueLoadTimer.isActive())
return;
m_newCuesAvailable = true;
m_cueLoadTimer.startOneShot(0);
}
void TextTrackLoader::fileFailedToParse()
{
LOG(Media, "TextTrackLoader::fileFailedToParse");
m_state = Failed;
if (!m_cueLoadTimer.isActive())
m_cueLoadTimer.startOneShot(0);
cancelLoad();
}
void TextTrackLoader::getNewCues(Vector<RefPtr<TextTrackCue> >& outputCues)
{
ASSERT(m_cueParser);
if (m_cueParser)
m_cueParser->getNewCues(outputCues);
}
}
#endif