diff options
Diffstat (limited to 'webkit/media/simple_data_source.cc')
| -rw-r--r-- | webkit/media/simple_data_source.cc | 319 |
1 files changed, 0 insertions, 319 deletions
diff --git a/webkit/media/simple_data_source.cc b/webkit/media/simple_data_source.cc deleted file mode 100644 index 3761148..0000000 --- a/webkit/media/simple_data_source.cc +++ /dev/null @@ -1,319 +0,0 @@ -// 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. - -#include "webkit/media/simple_data_source.h" - -#include "base/bind.h" -#include "base/message_loop.h" -#include "base/process_util.h" -#include "media/base/media_log.h" -#include "net/base/data_url.h" -#include "net/base/load_flags.h" -#include "net/http/http_request_headers.h" -#include "net/url_request/url_request_status.h" -#include "third_party/WebKit/Source/WebKit/chromium/public/WebKit.h" -#include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebKitPlatformSupport.h" -#include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebString.h" -#include "third_party/WebKit/Source/WebKit/chromium/public/WebURLLoaderOptions.h" - -using WebKit::WebString; -using WebKit::WebURLLoaderOptions; - -namespace webkit_media { - -static const char kDataScheme[] = "data"; - -SimpleDataSource::SimpleDataSource( - MessageLoop* render_loop, - WebKit::WebFrame* frame) - : render_loop_(render_loop), - frame_(frame), - size_(-1), - single_origin_(true), - state_(UNINITIALIZED), - keep_test_loader_(false) { - DCHECK(render_loop); -} - -SimpleDataSource::~SimpleDataSource() { - base::AutoLock auto_lock(lock_); - DCHECK(state_ == UNINITIALIZED || state_ == STOPPED); -} - -void SimpleDataSource::set_host(media::DataSourceHost* host) { - DataSource::set_host(host); - - base::AutoLock auto_lock(lock_); - if (state_ == INITIALIZED) { - UpdateHostState(); - } -} - -void SimpleDataSource::Stop(const base::Closure& callback) { - base::AutoLock auto_lock(lock_); - state_ = STOPPED; - if (!callback.is_null()) - callback.Run(); - - // Post a task to the render thread to cancel loading the resource. - render_loop_->PostTask(FROM_HERE, - base::Bind(&SimpleDataSource::CancelTask, this)); -} - -void SimpleDataSource::Initialize( - const GURL& url, - const media::PipelineStatusCB& status_cb) { - DCHECK(MessageLoop::current() == render_loop_); - DCHECK(!status_cb.is_null()); - - // Reference to prevent destruction while inside the |initialize_cb_| - // call. This is a temporary fix to prevent crashes caused by holding the - // lock and running the destructor. - scoped_refptr<SimpleDataSource> destruction_guard(this); - { - base::AutoLock auto_lock(lock_); - DCHECK_EQ(state_, UNINITIALIZED); - state_ = INITIALIZING; - initialize_cb_ = status_cb; - - // Validate the URL. - url_ = url; - if (!url_.is_valid()) { - DoneInitialization_Locked(false); - return; - } - - // If |url_| contains a data:// scheme we can decode it immediately. - if (url_.SchemeIs(kDataScheme)) { - std::string mime_type, charset; - bool success = net::DataURL::Parse(url_, &mime_type, &charset, &data_); - - // Don't care about the mime-type just proceed if decoding was successful. - size_ = data_.length(); - DoneInitialization_Locked(success); - return; - } - - // For all other schemes issue a request for the full resource. - WebKit::WebURLRequest request(url_); - request.setTargetType(WebKit::WebURLRequest::TargetIsMedia); - - frame_->setReferrerForRequest(request, WebKit::WebURL()); - - // Disable compression, compression for audio/video doesn't make sense. - request.setHTTPHeaderField( - WebString::fromUTF8(net::HttpRequestHeaders::kAcceptEncoding), - WebString::fromUTF8("identity;q=1, *;q=0")); - - // This flag is for unittests as we don't want to reset |url_loader| - if (!keep_test_loader_) { - WebURLLoaderOptions options; - options.allowCredentials = true; - options.crossOriginRequestPolicy = - WebURLLoaderOptions::CrossOriginRequestPolicyAllow; - url_loader_.reset(frame_->createAssociatedURLLoader(options)); - } - - // Start the resource loading. - url_loader_->loadAsynchronously(request, this); - } -} - -void SimpleDataSource::Read(int64 position, - size_t size, - uint8* data, - const DataSource::ReadCB& read_cb) { - DCHECK_GE(size_, 0); - if (position >= size_) { - read_cb.Run(0); - } else { - size_t copied = std::min(size, static_cast<size_t>(size_ - position)); - memcpy(data, data_.c_str() + position, copied); - read_cb.Run(copied); - } -} - -bool SimpleDataSource::GetSize(int64* size_out) { - *size_out = size_; - return true; -} - -bool SimpleDataSource::IsStreaming() { - return false; -} - -void SimpleDataSource::SetPreload(media::Preload preload) { -} - -void SimpleDataSource::SetBitrate(int bitrate) { -} - -void SimpleDataSource::SetURLLoaderForTest(WebKit::WebURLLoader* mock_loader) { - url_loader_.reset(mock_loader); - keep_test_loader_ = true; -} - -void SimpleDataSource::willSendRequest( - WebKit::WebURLLoader* loader, - WebKit::WebURLRequest& newRequest, - const WebKit::WebURLResponse& redirectResponse) { - DCHECK(MessageLoop::current() == render_loop_); - base::AutoLock auto_lock(lock_); - - // Only allow |single_origin_| if we haven't seen a different origin yet. - if (single_origin_) - single_origin_ = url_.GetOrigin() == GURL(newRequest.url()).GetOrigin(); - - url_ = newRequest.url(); -} - -void SimpleDataSource::didSendData( - WebKit::WebURLLoader* loader, - unsigned long long bytesSent, - unsigned long long totalBytesToBeSent) { - NOTIMPLEMENTED(); -} - -void SimpleDataSource::didReceiveResponse( - WebKit::WebURLLoader* loader, - const WebKit::WebURLResponse& response) { - DCHECK(MessageLoop::current() == render_loop_); - size_ = response.expectedContentLength(); -} - -void SimpleDataSource::didDownloadData( - WebKit::WebURLLoader* loader, - int dataLength) { - NOTIMPLEMENTED(); -} - -void SimpleDataSource::didReceiveData( - WebKit::WebURLLoader* loader, - const char* data, - int data_length, - int encoded_data_length) { - DCHECK(MessageLoop::current() == render_loop_); - data_.append(data, data_length); -} - -void SimpleDataSource::didReceiveCachedMetadata( - WebKit::WebURLLoader* loader, - const char* data, - int dataLength) { - NOTIMPLEMENTED(); -} - -void SimpleDataSource::didFinishLoading( - WebKit::WebURLLoader* loader, - double finishTime) { - DCHECK(MessageLoop::current() == render_loop_); - // Reference to prevent destruction while inside the |initialize_cb_| - // call. This is a temporary fix to prevent crashes caused by holding the - // lock and running the destructor. - scoped_refptr<SimpleDataSource> destruction_guard(this); - { - base::AutoLock auto_lock(lock_); - // It's possible this gets called after Stop(), in which case |host_| is no - // longer valid. - if (state_ == STOPPED) - return; - - // Otherwise we should be initializing and have created a WebURLLoader. - DCHECK_EQ(state_, INITIALIZING); - - // If we don't get a content length or the request has failed, report it - // as a network error. - if (size_ == -1) - size_ = data_.length(); - DCHECK(static_cast<size_t>(size_) == data_.length()); - - DoneInitialization_Locked(true); - } -} - -void SimpleDataSource::didFail( - WebKit::WebURLLoader* loader, - const WebKit::WebURLError& error) { - DCHECK(MessageLoop::current() == render_loop_); - // Reference to prevent destruction while inside the |initialize_cb_| - // call. This is a temporary fix to prevent crashes caused by holding the - // lock and running the destructor. - scoped_refptr<SimpleDataSource> destruction_guard(this); - { - base::AutoLock auto_lock(lock_); - // It's possible this gets called after Stop(), in which case |host_| is no - // longer valid. - if (state_ == STOPPED) - return; - - // Otherwise we should be initializing and have created a WebURLLoader. - DCHECK_EQ(state_, INITIALIZING); - - // If we don't get a content length or the request has failed, report it - // as a network error. - if (size_ == -1) - size_ = data_.length(); - DCHECK(static_cast<size_t>(size_) == data_.length()); - - DoneInitialization_Locked(false); - } -} - -bool SimpleDataSource::HasSingleOrigin() { - DCHECK(MessageLoop::current() == render_loop_); - return single_origin_; -} - -void SimpleDataSource::Abort() { - DCHECK(MessageLoop::current() == render_loop_); - base::AutoLock auto_lock(lock_); - state_ = STOPPED; - initialize_cb_.Reset(); - CancelTask_Locked(); - frame_ = NULL; -} - -void SimpleDataSource::CancelTask() { - DCHECK(MessageLoop::current() == render_loop_); - base::AutoLock auto_lock(lock_); - CancelTask_Locked(); -} - -void SimpleDataSource::CancelTask_Locked() { - DCHECK(MessageLoop::current() == render_loop_); - lock_.AssertAcquired(); - DCHECK_EQ(state_, STOPPED); - - // Cancel any pending requests. - if (url_loader_.get()) { - url_loader_->cancel(); - url_loader_.reset(); - } -} - -void SimpleDataSource::DoneInitialization_Locked(bool success) { - lock_.AssertAcquired(); - media::PipelineStatus status = media::PIPELINE_ERROR_NETWORK; - if (success) { - state_ = INITIALIZED; - - UpdateHostState(); - status = media::PIPELINE_OK; - } else { - state_ = UNINITIALIZED; - url_loader_.reset(); - } - - initialize_cb_.Run(status); - initialize_cb_.Reset(); -} - -void SimpleDataSource::UpdateHostState() { - if (host()) { - host()->SetTotalBytes(size_); - host()->SetBufferedBytes(size_); - } -} - -} // namespace webkit_media |