1 files changed, 146 insertions, 0 deletions
diff --git a/webkit/glue/media/simple_data_source.cc b/webkit/glue/media/simple_data_source.cc
new file mode 100644
index 0000000..16fbd04
--- /dev/null
+++ b/webkit/glue/media/simple_data_source.cc
@@ -0,0 +1,146 @@
+// Copyright (c) 2009 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 "base/message_loop.h"
+#include "base/process_util.h"
+#include "media/base/filter_host.h"
+#include "net/base/load_flags.h"
+#include "net/http/http_response_headers.h"
+#include "net/url_request/url_request_status.h"
+#include "webkit/glue/media/simple_data_source.h"
+#include "webkit/glue/resource_loader_bridge.h"
+#include "webkit/glue/webappcachecontext.h"
+
+namespace webkit_glue {
+
+SimpleDataSource::SimpleDataSource(MessageLoop* render_loop, int32 routing_id)
+    : routing_id_(routing_id),
+      render_loop_(render_loop),
+      size_(-1),
+      position_(0) {
+  DCHECK(render_loop);
+}
+
+SimpleDataSource::~SimpleDataSource() {
+}
+
+void SimpleDataSource::Stop() {}
+
+bool SimpleDataSource::Initialize(const std::string& url) {
+  SetURL(GURL(url));
+
+  // Validate the URL.
+  if (!url_.is_valid()) {
+    return false;
+  }
+
+  // Create our bridge and post a task to start loading the resource.
+  bridge_.reset(webkit_glue::ResourceLoaderBridge::Create(
+      "GET",
+      url_,
+      url_,
+      GURL::EmptyGURL(),  // TODO(scherkus): provide referer here.
+      "null",             // TODO(abarth): provide frame_origin
+      "null",             // TODO(abarth): provide main_frame_origin
+      "",
+      net::LOAD_BYPASS_CACHE,
+      base::GetCurrentProcId(),
+      ResourceType::MEDIA,
+      // TODO(michaeln): delegate->mediaplayer->frame->
+      //                    app_cache_context()->context_id()
+      // For now don't service media resource requests from the appcache.
+      WebAppCacheContext::kNoAppCacheContextId,
+      routing_id_));
+  render_loop_->PostTask(FROM_HERE,
+                         NewRunnableMethod(this, &SimpleDataSource::StartTask));
+  return true;
+}
+
+const media::MediaFormat& SimpleDataSource::media_format() {
+  return media_format_;
+}
+
+size_t SimpleDataSource::Read(uint8* data, size_t size) {
+  DCHECK_GE(size_, 0);
+  size_t copied = std::min(size, static_cast<size_t>(size_ - position_));
+  memcpy(data, data_.c_str() + position_, copied);
+  position_ += copied;
+  return copied;
+}
+
+bool SimpleDataSource::GetPosition(int64* position_out) {
+  *position_out = position_;
+  return true;
+}
+
+bool SimpleDataSource::SetPosition(int64 position) {
+  if (position < 0 || position > size_)
+    return false;
+  position_ = position;
+  return true;
+}
+
+bool SimpleDataSource::GetSize(int64* size_out) {
+  *size_out = size_;
+  return true;
+}
+
+bool SimpleDataSource::IsSeekable() {
+  return true;
+}
+
+void SimpleDataSource::OnDownloadProgress(uint64 position, uint64 size) {}
+
+void SimpleDataSource::OnUploadProgress(uint64 position, uint64 size) {}
+
+void SimpleDataSource::OnReceivedRedirect(const GURL& new_url) {
+  SetURL(new_url);
+}
+
+void SimpleDataSource::OnReceivedResponse(
+    const webkit_glue::ResourceLoaderBridge::ResponseInfo& info,
+    bool content_filtered) {
+  size_ = info.content_length;
+}
+
+void SimpleDataSource::OnReceivedData(const char* data, int len) {
+  data_.append(data, len);
+}
+
+void SimpleDataSource::OnCompletedRequest(const URLRequestStatus& status,
+                                          const std::string& security_info) {
+  bridge_.reset();
+  // If we don't get a content length or the request has failed, report it
+  // as a network error.
+  DCHECK(size_ == -1 || size_ == data_.length());
+  if (size_ == -1)
+    size_ = data_.length();
+  if (!status.is_success()) {
+    host_->Error(media::PIPELINE_ERROR_NETWORK);
+  } else {
+    host_->InitializationComplete();
+  }
+  host_->SetTotalBytes(size_);
+  host_->SetBufferedBytes(size_);
+  host_->InitializationComplete();
+}
+
+std::string SimpleDataSource::GetURLForDebugging() {
+  return url_.spec();
+}
+
+void SimpleDataSource::SetURL(const GURL& url) {
+  url_ = url;
+  media_format_.Clear();
+  media_format_.SetAsString(media::MediaFormat::kMimeType,
+                            media::mime_type::kApplicationOctetStream);
+  media_format_.SetAsString(media::MediaFormat::kURL, url.spec());
+}
+
+void SimpleDataSource::StartTask() {
+  DCHECK(MessageLoop::current() == render_loop_);
+  bridge_->Start(this);
+}
+
+}  // namespace webkit_glue