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 // This contains unprivileged javascript APIs for extensions and apps. It | 5 // This contains unprivileged javascript APIs for extensions and apps. It |
6 // can be loaded by any extension-related context, such as content scripts or | 6 // can be loaded by any extension-related context, such as content scripts or |
7 // background pages. See user_script_slave.cc for script that is loaded by | 7 // background pages. See user_script_slave.cc for script that is loaded by |
8 // content scripts only. | 8 // content scripts only. |
9 | 9 |
10 // TODO(kalman): factor requiring chrome out of here. | 10 // TODO(kalman): factor requiring chrome out of here. |
(...skipping 143 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
154 if (chrome.extension) { | 154 if (chrome.extension) { |
155 requestEvent = isExternal ? chrome.extension.onRequestExternal | 155 requestEvent = isExternal ? chrome.extension.onRequestExternal |
156 : chrome.extension.onRequest; | 156 : chrome.extension.onRequest; |
157 } | 157 } |
158 } | 158 } |
159 if (!requestEvent) | 159 if (!requestEvent) |
160 return false; | 160 return false; |
161 if (!requestEvent.hasListeners()) | 161 if (!requestEvent.hasListeners()) |
162 return false; | 162 return false; |
163 var port = createPort(portId, channelName); | 163 var port = createPort(portId, channelName); |
164 port.onMessage.addListener(function(request) { | 164 |
| 165 function messageListener(request) { |
165 var responseCallbackPreserved = false; | 166 var responseCallbackPreserved = false; |
166 var responseCallback = function(response) { | 167 var responseCallback = function(response) { |
167 if (port) { | 168 if (port) { |
168 port.postMessage(response); | 169 port.postMessage(response); |
169 port.destroy_(); | 170 port.destroy_(); |
170 port = null; | 171 port = null; |
171 } else { | 172 } else { |
172 // We nulled out port when sending the response, and now the page | 173 // We nulled out port when sending the response, and now the page |
173 // is trying to send another response for the same request. | 174 // is trying to send another response for the same request. |
174 handleSendRequestError(isSendMessage, responseCallbackPreserved, | 175 handleSendRequestError(isSendMessage, responseCallbackPreserved, |
(...skipping 16 matching lines...) Expand all Loading... |
191 var rv = requestEvent.dispatch(request, sender, responseCallback); | 192 var rv = requestEvent.dispatch(request, sender, responseCallback); |
192 responseCallbackPreserved = | 193 responseCallbackPreserved = |
193 rv && rv.results && $Array.indexOf(rv.results, true) > -1; | 194 rv && rv.results && $Array.indexOf(rv.results, true) > -1; |
194 if (!responseCallbackPreserved && port) { | 195 if (!responseCallbackPreserved && port) { |
195 // If they didn't access the response callback, they're not | 196 // If they didn't access the response callback, they're not |
196 // going to send a response, so clean up the port immediately. | 197 // going to send a response, so clean up the port immediately. |
197 port.destroy_(); | 198 port.destroy_(); |
198 port = null; | 199 port = null; |
199 } | 200 } |
200 } | 201 } |
201 }); | 202 } |
| 203 |
| 204 port.onDestroy_ = function() { |
| 205 port.onMessage.removeListener(messageListener); |
| 206 }; |
| 207 port.onMessage.addListener(messageListener); |
| 208 |
202 var eventName = (isSendMessage ? | 209 var eventName = (isSendMessage ? |
203 (isExternal ? | 210 (isExternal ? |
204 "runtime.onMessageExternal" : "runtime.onMessage") : | 211 "runtime.onMessageExternal" : "runtime.onMessage") : |
205 (isExternal ? | 212 (isExternal ? |
206 "extension.onRequestExternal" : "extension.onRequest")); | 213 "extension.onRequestExternal" : "extension.onRequest")); |
207 logActivity.LogEvent(targetExtensionId, | 214 logActivity.LogEvent(targetExtensionId, |
208 eventName, | 215 eventName, |
209 [sourceExtensionId, sourceUrl]); | 216 [sourceExtensionId, sourceUrl]); |
210 return true; | 217 return true; |
211 } | 218 } |
(...skipping 151 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
363 exports.Port = Port; | 370 exports.Port = Port; |
364 exports.createPort = createPort; | 371 exports.createPort = createPort; |
365 exports.sendMessageImpl = sendMessageImpl; | 372 exports.sendMessageImpl = sendMessageImpl; |
366 exports.sendMessageUpdateArguments = sendMessageUpdateArguments; | 373 exports.sendMessageUpdateArguments = sendMessageUpdateArguments; |
367 | 374 |
368 // For C++ code to call. | 375 // For C++ code to call. |
369 exports.hasPort = hasPort; | 376 exports.hasPort = hasPort; |
370 exports.dispatchOnConnect = dispatchOnConnect; | 377 exports.dispatchOnConnect = dispatchOnConnect; |
371 exports.dispatchOnDisconnect = dispatchOnDisconnect; | 378 exports.dispatchOnDisconnect = dispatchOnDisconnect; |
372 exports.dispatchOnMessage = dispatchOnMessage; | 379 exports.dispatchOnMessage = dispatchOnMessage; |
OLD | NEW |