Decouple IPC::MessageFilter from IPC::Channel

content/child/threaded_data_provider.cc

 // Copyright 2014 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 "content/child/threaded_data_provider.h"
 
 #include "content/child/child_process.h"
 #include "content/child/child_thread.h"
 #include "content/child/resource_dispatcher.h"
 #include "content/child/thread_safe_sender.h"
@@ skipping 13 matching lines @@
       const scoped_refptr<base::MessageLoopProxy>& io_message_loop,
       base::MessageLoop* main_thread_message_loop,
       const WebThreadImpl& background_thread,
       const base::WeakPtr<ThreadedDataProvider>&
           background_thread_resource_provider,
       const base::WeakPtr<ThreadedDataProvider>&
           main_thread_resource_provider,
       int request_id);
 
   // IPC::ChannelProxy::MessageFilter
-  virtual void OnFilterAdded(IPC::Channel* channel) OVERRIDE FINAL;
+  virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE FINAL;
   virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE FINAL;
 
  private:
   virtual ~DataProviderMessageFilter() { }
 
   void OnReceivedData(int request_id, int data_offset, int data_length,
                       int encoded_data_length);
 
   const scoped_refptr<base::MessageLoopProxy> io_message_loop_;
   base::MessageLoop* main_thread_message_loop_;
@@ skipping 18 matching lines @@
     int request_id)
     : io_message_loop_(io_message_loop),
       main_thread_message_loop_(main_thread_message_loop),
       background_thread_(background_thread),
       background_thread_resource_provider_(background_thread_resource_provider),
       main_thread_resource_provider_(main_thread_resource_provider),
       request_id_(request_id) {
   DCHECK(main_thread_message_loop != NULL);
 }
 
-void DataProviderMessageFilter::OnFilterAdded(IPC::Channel* channel) {
+void DataProviderMessageFilter::OnFilterAdded(IPC::Sender* sender) {
   DCHECK(io_message_loop_->BelongsToCurrentThread());
 
   main_thread_message_loop_->PostTask(FROM_HERE,
       base::Bind(
           &ThreadedDataProvider::OnResourceMessageFilterAddedMainThread,
           main_thread_resource_provider_));
 }
 
 bool DataProviderMessageFilter::OnMessageReceived(
     const IPC::Message& message) {
@@ skipping 185 matching lines @@
 
   // TODO(oysteine): SiteIsolationPolicy needs to be be checked
   // here before we pass the data to the data provider
   // (or earlier on the I/O thread), otherwise once SiteIsolationPolicy does
   // actual blocking as opposed to just UMA logging this will bypass it.
   threaded_data_receiver_->acceptData(data, data_length);
   ipc_channel_->Send(new ResourceHostMsg_DataReceived_ACK(request_id_));
 }
 
 }  // namespace content