| OLD | NEW | 
|    1 // Copyright 2014 The Chromium Authors. All rights reserved. |    1 // Copyright 2014 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 "content/child/threaded_data_provider.h" |    5 #include "content/child/threaded_data_provider.h" | 
|    6  |    6  | 
|    7 #include "content/child/child_process.h" |    7 #include "content/child/child_process.h" | 
|    8 #include "content/child/child_thread.h" |    8 #include "content/child/child_thread.h" | 
|    9 #include "content/child/resource_dispatcher.h" |    9 #include "content/child/resource_dispatcher.h" | 
|   10 #include "content/child/thread_safe_sender.h" |   10 #include "content/child/thread_safe_sender.h" | 
| (...skipping 13 matching lines...) Expand all  Loading... | 
|   24       const scoped_refptr<base::MessageLoopProxy>& io_message_loop, |   24       const scoped_refptr<base::MessageLoopProxy>& io_message_loop, | 
|   25       base::MessageLoop* main_thread_message_loop, |   25       base::MessageLoop* main_thread_message_loop, | 
|   26       const WebThreadImpl& background_thread, |   26       const WebThreadImpl& background_thread, | 
|   27       const base::WeakPtr<ThreadedDataProvider>& |   27       const base::WeakPtr<ThreadedDataProvider>& | 
|   28           background_thread_resource_provider, |   28           background_thread_resource_provider, | 
|   29       const base::WeakPtr<ThreadedDataProvider>& |   29       const base::WeakPtr<ThreadedDataProvider>& | 
|   30           main_thread_resource_provider, |   30           main_thread_resource_provider, | 
|   31       int request_id); |   31       int request_id); | 
|   32  |   32  | 
|   33   // IPC::ChannelProxy::MessageFilter |   33   // IPC::ChannelProxy::MessageFilter | 
|   34   virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE FINAL; |   34   virtual void OnFilterAdded(IPC::Sender* sender) override final; | 
|   35   virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE FINAL; |   35   virtual bool OnMessageReceived(const IPC::Message& message) override final; | 
|   36  |   36  | 
|   37  private: |   37  private: | 
|   38   virtual ~DataProviderMessageFilter() { } |   38   virtual ~DataProviderMessageFilter() { } | 
|   39  |   39  | 
|   40   void OnReceivedData(int request_id, int data_offset, int data_length, |   40   void OnReceivedData(int request_id, int data_offset, int data_length, | 
|   41                       int encoded_data_length); |   41                       int encoded_data_length); | 
|   42  |   42  | 
|   43   const scoped_refptr<base::MessageLoopProxy> io_message_loop_; |   43   const scoped_refptr<base::MessageLoopProxy> io_message_loop_; | 
|   44   base::MessageLoop* main_thread_message_loop_; |   44   base::MessageLoop* main_thread_message_loop_; | 
|   45   const WebThreadImpl& background_thread_; |   45   const WebThreadImpl& background_thread_; | 
| (...skipping 234 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  280  |  280  | 
|  281   // TODO(oysteine): SiteIsolationPolicy needs to be be checked |  281   // TODO(oysteine): SiteIsolationPolicy needs to be be checked | 
|  282   // here before we pass the data to the data provider |  282   // here before we pass the data to the data provider | 
|  283   // (or earlier on the I/O thread), otherwise once SiteIsolationPolicy does |  283   // (or earlier on the I/O thread), otherwise once SiteIsolationPolicy does | 
|  284   // actual blocking as opposed to just UMA logging this will bypass it. |  284   // actual blocking as opposed to just UMA logging this will bypass it. | 
|  285   threaded_data_receiver_->acceptData(data, data_length); |  285   threaded_data_receiver_->acceptData(data, data_length); | 
|  286   ipc_channel_->Send(new ResourceHostMsg_DataReceived_ACK(request_id_)); |  286   ipc_channel_->Send(new ResourceHostMsg_DataReceived_ACK(request_id_)); | 
|  287 } |  287 } | 
|  288  |  288  | 
|  289 }  // namespace content |  289 }  // namespace content | 
| OLD | NEW |