Replace __MSG_some_name__ template within extension css/html files with local...

chrome/common/resource_dispatcher.cc

 // Copyright (c) 2006-2008 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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #include "chrome/common/resource_dispatcher.h"
 
 #include "base/basictypes.h"
 #include "base/compiler_specific.h"
 #include "base/file_path.h"
 #include "base/message_loop.h"
 #include "base/shared_memory.h"
 #include "base/string_util.h"
+#include "chrome/common/extensions/extension_message_filter_peer.h"
 #include "chrome/common/render_messages.h"
 #include "chrome/common/security_filter_peer.h"
 #include "net/base/net_errors.h"
 #include "net/base/net_util.h"
 #include "webkit/glue/resource_type.h"
 #include "webkit/glue/webkit_glue.h"
 
 // Uncomment to enable logging of request traffic
 // #define LOG_RESOURCE_REQUESTS
 
@@ skipping 147 matching lines @@
   if (request_id_ != -1) {
     NOTREACHED() << "Starting a request twice";
     return false;
   }
 
   RESOURCE_LOG("Starting request for " << url_);
 
   peer_ = peer;
 
   // generate the request ID, and append it to the message
-  request_id_ = dispatcher_->AddPendingRequest(peer_, request_.resource_type);
+  request_id_ = dispatcher_->AddPendingRequest(
+      peer_, request_.resource_type, request_.url);
 
   return dispatcher_->message_sender()->Send(
       new ViewHostMsg_RequestResource(routing_id_, request_id_, request_));
 }
 
 void IPCResourceLoaderBridge::Cancel() {
   if (request_id_ < 0) {
     NOTREACHED() << "Trying to cancel an unstarted request";
     return;
   }
@@ skipping 130 matching lines @@
   if (it == pending_requests_.end()) {
     // This might happen for kill()ed requests on the webkit end, so perhaps it
     // shouldn't be a warning...
     DLOG(WARNING) << "Got response for a nonexistant or finished request";
     return;
   }
 
   PendingRequestInfo& request_info = it->second;
   request_info.filter_policy = response_head.filter_policy;
   webkit_glue::ResourceLoaderBridge::Peer* peer = request_info.peer;
-  if (request_info.filter_policy != FilterPolicy::DONT_FILTER) {
+  webkit_glue::ResourceLoaderBridge::Peer* new_peer = NULL;
+  if (request_info.filter_policy == FilterPolicy::FILTER_EXTENSION_MESSAGES) {
+     new_peer = ExtensionMessageFilterPeer::CreateExtensionMessageFilterPeer(
+        peer,
+        message_sender(),
+        response_head.mime_type,
+        request_info.filter_policy,
+        request_info.url);
+  } else if (request_info.filter_policy != FilterPolicy::DONT_FILTER) {
     // TODO(jcampan): really pass the loader bridge.
-    webkit_glue::ResourceLoaderBridge::Peer* new_peer =
-        SecurityFilterPeer::CreateSecurityFilterPeer(
-            NULL, peer,
-            request_info.resource_type, response_head.mime_type,
-            request_info.filter_policy,
-            net::ERR_INSECURE_RESPONSE);
-    if (new_peer) {
-      request_info.peer = new_peer;
-      peer = new_peer;
-    }
+    new_peer = SecurityFilterPeer::CreateSecurityFilterPeer(
+        NULL,
+        peer,
+        request_info.resource_type,
+        response_head.mime_type,
+        request_info.filter_policy,
+        net::ERR_INSECURE_RESPONSE);
+  }
+
+  if (new_peer) {
+    request_info.peer = new_peer;
+    peer = new_peer;
   }
 
   RESOURCE_LOG("Dispatching response for " <<
       peer->GetURLForDebugging().possibly_invalid_spec());
   peer->OnReceivedResponse(response_head, false);
 }
 
 void ResourceDispatcher::OnReceivedData(const IPC::Message& message,
                                         int request_id,
                                         base::SharedMemoryHandle shm_handle,
@@ skipping 90 matching lines @@
   // The request ID will be removed from our pending list in the destructor.
   // Normally, dispatching this message causes the reference-counted request to
   // die immediately.
   peer->OnCompletedRequest(status, security_info);
 
   webkit_glue::NotifyCacheStats();
 }
 
 int ResourceDispatcher::AddPendingRequest(
     webkit_glue::ResourceLoaderBridge::Peer* callback,
-    ResourceType::Type resource_type) {
+    ResourceType::Type resource_type,
+    const GURL& request_url) {
   // Compute a unique request_id for this renderer process.
   int id = MakeRequestID();
-  pending_requests_[id] = PendingRequestInfo(callback, resource_type);
+  pending_requests_[id] =
+      PendingRequestInfo(callback, resource_type, request_url);
   return id;
 }
 
 bool ResourceDispatcher::RemovePendingRequest(int request_id) {
   PendingRequestList::iterator it = pending_requests_.find(request_id);
   if (it == pending_requests_.end())
     return false;
 
   // Iterate through the deferred message queue and clean up the messages.
   PendingRequestInfo& request_info = it->second;
@@ skipping 122 matching lines @@
   // handle or there will be a memory leak.
   if (message.type() == ViewMsg_Resource_DataReceived::ID) {
     base::SharedMemoryHandle shm_handle;
     if (IPC::ParamTraits<base::SharedMemoryHandle>::Read(&message,
                                                          &iter,
                                                          &shm_handle)) {
       base::SharedMemory::CloseHandle(shm_handle);
     }
   }
 }