OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chrome/renderer/extensions/request_sender.h" | 5 #include "chrome/renderer/extensions/request_sender.h" |
6 | 6 |
7 #include "base/values.h" | 7 #include "base/values.h" |
8 #include "chrome/common/extensions/extension_messages.h" | 8 #include "chrome/common/extensions/extension_messages.h" |
9 #include "chrome/renderer/extensions/chrome_v8_context.h" | 9 #include "chrome/renderer/extensions/chrome_v8_context.h" |
10 #include "chrome/renderer/extensions/dispatcher.h" | 10 #include "chrome/renderer/extensions/dispatcher.h" |
11 #include "content/public/renderer/render_view.h" | 11 #include "content/public/renderer/render_view.h" |
12 #include "third_party/WebKit/public/web/WebDocument.h" | 12 #include "third_party/WebKit/public/web/WebDocument.h" |
13 #include "third_party/WebKit/public/web/WebFrame.h" | 13 #include "third_party/WebKit/public/web/WebFrame.h" |
14 #include "third_party/WebKit/public/web/WebUserGestureIndicator.h" | 14 #include "third_party/WebKit/public/web/WebUserGestureIndicator.h" |
15 | 15 |
16 namespace extensions { | 16 namespace extensions { |
17 | 17 |
18 // Contains info relevant to a pending API request. | 18 // Contains info relevant to a pending API request. |
19 struct PendingRequest { | 19 struct PendingRequest { |
20 public : | 20 public : |
21 PendingRequest(const std::string& name, RequestSender::Source* source) | 21 PendingRequest(const std::string& name, RequestSender::Source* source) |
22 : name(name), source(source) { | 22 : name(name), source(source) { |
23 } | 23 } |
24 | 24 |
25 std::string name; | 25 std::string name; |
26 RequestSender::Source* source; | 26 RequestSender::Source* source; |
27 }; | 27 }; |
28 | 28 |
29 RequestSender::RequestSender(Dispatcher* dispatcher) : dispatcher_(dispatcher) { | 29 RequestSender::ScopedTabID::ScopedTabID(RequestSender* request_sender, |
| 30 int tab_id) |
| 31 : request_sender_(request_sender), |
| 32 tab_id_(tab_id), |
| 33 previous_tab_id_(request_sender->source_tab_id_) { |
| 34 request_sender_->source_tab_id_ = tab_id; |
| 35 } |
| 36 |
| 37 RequestSender::ScopedTabID::~ScopedTabID() { |
| 38 DCHECK_EQ(tab_id_, request_sender_->source_tab_id_); |
| 39 request_sender_->source_tab_id_ = previous_tab_id_; |
| 40 } |
| 41 |
| 42 RequestSender::RequestSender(Dispatcher* dispatcher) |
| 43 : dispatcher_(dispatcher), |
| 44 source_tab_id_(-1) { |
30 } | 45 } |
31 | 46 |
32 RequestSender::~RequestSender() { | 47 RequestSender::~RequestSender() { |
33 } | 48 } |
34 | 49 |
35 void RequestSender::InsertRequest(int request_id, | 50 void RequestSender::InsertRequest(int request_id, |
36 PendingRequest* pending_request) { | 51 PendingRequest* pending_request) { |
37 DCHECK_EQ(0u, pending_requests_.count(request_id)); | 52 DCHECK_EQ(0u, pending_requests_.count(request_id)); |
38 pending_requests_[request_id].reset(pending_request); | 53 pending_requests_[request_id].reset(pending_request); |
39 } | 54 } |
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
83 if (blink::WebFrame* webframe = context->web_frame()) | 98 if (blink::WebFrame* webframe = context->web_frame()) |
84 source_url = webframe->document().url(); | 99 source_url = webframe->document().url(); |
85 | 100 |
86 InsertRequest(request_id, new PendingRequest(name, source)); | 101 InsertRequest(request_id, new PendingRequest(name, source)); |
87 | 102 |
88 ExtensionHostMsg_Request_Params params; | 103 ExtensionHostMsg_Request_Params params; |
89 params.name = name; | 104 params.name = name; |
90 params.arguments.Swap(value_args); | 105 params.arguments.Swap(value_args); |
91 params.extension_id = context->GetExtensionID(); | 106 params.extension_id = context->GetExtensionID(); |
92 params.source_url = source_url; | 107 params.source_url = source_url; |
| 108 params.source_tab_id = source_tab_id_; |
93 params.request_id = request_id; | 109 params.request_id = request_id; |
94 params.has_callback = has_callback; | 110 params.has_callback = has_callback; |
95 params.user_gesture = | 111 params.user_gesture = |
96 blink::WebUserGestureIndicator::isProcessingUserGesture(); | 112 blink::WebUserGestureIndicator::isProcessingUserGesture(); |
97 if (for_io_thread) { | 113 if (for_io_thread) { |
98 renderview->Send(new ExtensionHostMsg_RequestForIOThread( | 114 renderview->Send(new ExtensionHostMsg_RequestForIOThread( |
99 renderview->GetRoutingID(), params)); | 115 renderview->GetRoutingID(), params)); |
100 } else { | 116 } else { |
101 renderview->Send(new ExtensionHostMsg_Request( | 117 renderview->Send(new ExtensionHostMsg_Request( |
102 renderview->GetRoutingID(), params)); | 118 renderview->GetRoutingID(), params)); |
(...skipping 19 matching lines...) Expand all Loading... |
122 for (PendingRequestMap::iterator it = pending_requests_.begin(); | 138 for (PendingRequestMap::iterator it = pending_requests_.begin(); |
123 it != pending_requests_.end();) { | 139 it != pending_requests_.end();) { |
124 if (it->second->source == source) | 140 if (it->second->source == source) |
125 pending_requests_.erase(it++); | 141 pending_requests_.erase(it++); |
126 else | 142 else |
127 ++it; | 143 ++it; |
128 } | 144 } |
129 } | 145 } |
130 | 146 |
131 } // namespace extensions | 147 } // namespace extensions |
OLD | NEW |