Index: chrome/renderer/extensions/request_sender.cc |
diff --git a/chrome/renderer/extensions/request_sender.cc b/chrome/renderer/extensions/request_sender.cc |
deleted file mode 100644 |
index 597f3fbccbadaa06a4e94dc37603410ea5cbc2a5..0000000000000000000000000000000000000000 |
--- a/chrome/renderer/extensions/request_sender.cc |
+++ /dev/null |
@@ -1,147 +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 "chrome/renderer/extensions/request_sender.h" |
- |
-#include "base/values.h" |
-#include "chrome/renderer/extensions/chrome_v8_context.h" |
-#include "chrome/renderer/extensions/dispatcher.h" |
-#include "content/public/renderer/render_view.h" |
-#include "extensions/common/extension_messages.h" |
-#include "third_party/WebKit/public/web/WebDocument.h" |
-#include "third_party/WebKit/public/web/WebFrame.h" |
-#include "third_party/WebKit/public/web/WebUserGestureIndicator.h" |
- |
-namespace extensions { |
- |
-// Contains info relevant to a pending API request. |
-struct PendingRequest { |
- public : |
- PendingRequest(const std::string& name, RequestSender::Source* source) |
- : name(name), source(source) { |
- } |
- |
- std::string name; |
- RequestSender::Source* source; |
-}; |
- |
-RequestSender::ScopedTabID::ScopedTabID(RequestSender* request_sender, |
- int tab_id) |
- : request_sender_(request_sender), |
- tab_id_(tab_id), |
- previous_tab_id_(request_sender->source_tab_id_) { |
- request_sender_->source_tab_id_ = tab_id; |
-} |
- |
-RequestSender::ScopedTabID::~ScopedTabID() { |
- DCHECK_EQ(tab_id_, request_sender_->source_tab_id_); |
- request_sender_->source_tab_id_ = previous_tab_id_; |
-} |
- |
-RequestSender::RequestSender(Dispatcher* dispatcher) |
- : dispatcher_(dispatcher), |
- source_tab_id_(-1) { |
-} |
- |
-RequestSender::~RequestSender() { |
-} |
- |
-void RequestSender::InsertRequest(int request_id, |
- PendingRequest* pending_request) { |
- DCHECK_EQ(0u, pending_requests_.count(request_id)); |
- pending_requests_[request_id].reset(pending_request); |
-} |
- |
-linked_ptr<PendingRequest> RequestSender::RemoveRequest(int request_id) { |
- PendingRequestMap::iterator i = pending_requests_.find(request_id); |
- if (i == pending_requests_.end()) |
- return linked_ptr<PendingRequest>(); |
- linked_ptr<PendingRequest> result = i->second; |
- pending_requests_.erase(i); |
- return result; |
-} |
- |
-int RequestSender::GetNextRequestId() const { |
- static int next_request_id = 0; |
- return next_request_id++; |
-} |
- |
-void RequestSender::StartRequest(Source* source, |
- const std::string& name, |
- int request_id, |
- bool has_callback, |
- bool for_io_thread, |
- base::ListValue* value_args) { |
- ChromeV8Context* context = source->GetContext(); |
- if (!context) |
- return; |
- |
- // Get the current RenderView so that we can send a routed IPC message from |
- // the correct source. |
- content::RenderView* renderview = context->GetRenderView(); |
- if (!renderview) |
- return; |
- |
- const std::set<std::string>& function_names = dispatcher_->function_names(); |
- if (function_names.find(name) == function_names.end()) { |
- NOTREACHED() << "Unexpected function " << name << |
- ". Did you remember to register it with ExtensionFunctionRegistry?"; |
- return; |
- } |
- |
- // TODO(koz): See if we can make this a CHECK. |
- if (!dispatcher_->CheckContextAccessToExtensionAPI(name, context)) |
- return; |
- |
- GURL source_url; |
- if (blink::WebFrame* webframe = context->web_frame()) |
- source_url = webframe->document().url(); |
- |
- InsertRequest(request_id, new PendingRequest(name, source)); |
- |
- ExtensionHostMsg_Request_Params params; |
- params.name = name; |
- params.arguments.Swap(value_args); |
- params.extension_id = context->GetExtensionID(); |
- params.source_url = source_url; |
- params.source_tab_id = source_tab_id_; |
- params.request_id = request_id; |
- params.has_callback = has_callback; |
- params.user_gesture = |
- blink::WebUserGestureIndicator::isProcessingUserGesture(); |
- if (for_io_thread) { |
- renderview->Send(new ExtensionHostMsg_RequestForIOThread( |
- renderview->GetRoutingID(), params)); |
- } else { |
- renderview->Send(new ExtensionHostMsg_Request( |
- renderview->GetRoutingID(), params)); |
- } |
-} |
- |
-void RequestSender::HandleResponse(int request_id, |
- bool success, |
- const base::ListValue& response, |
- const std::string& error) { |
- linked_ptr<PendingRequest> request = RemoveRequest(request_id); |
- |
- if (!request.get()) { |
- // This can happen if a context is destroyed while a request is in flight. |
- return; |
- } |
- |
- request->source->OnResponseReceived(request->name, request_id, success, |
- response, error); |
-} |
- |
-void RequestSender::InvalidateSource(Source* source) { |
- for (PendingRequestMap::iterator it = pending_requests_.begin(); |
- it != pending_requests_.end();) { |
- if (it->second->source == source) |
- pending_requests_.erase(it++); |
- else |
- ++it; |
- } |
-} |
- |
-} // namespace extensions |