OLD | NEW |
(Empty) | |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. |
| 4 |
| 5 #include "content/child/child_message_filter.h" |
| 6 |
| 7 #include "content/child/child_thread.h" |
| 8 #include "content/child/thread_safe_sender.h" |
| 9 |
| 10 namespace content { |
| 11 |
| 12 ChildMessageFilter::Internal::Internal(ChildMessageFilter* filter) |
| 13 : filter_(filter) {} |
| 14 |
| 15 ChildMessageFilter::Internal::~Internal() {} |
| 16 |
| 17 bool ChildMessageFilter::Internal::OnMessageReceived( |
| 18 const IPC::Message& message) { |
| 19 scoped_refptr<base::TaskRunner> runner = |
| 20 filter_->OverrideTaskRunnerForMessage(message); |
| 21 if (runner) { |
| 22 runner->PostTask( |
| 23 FROM_HERE, |
| 24 base::Bind(base::IgnoreResult(&ChildMessageFilter::OnMessageReceived), |
| 25 filter_, |
| 26 message)); |
| 27 return true; |
| 28 } |
| 29 |
| 30 return filter_->OnMessageReceived(message); |
| 31 } |
| 32 |
| 33 |
| 34 ChildMessageFilter::ChildMessageFilter() |
| 35 : internal_(new Internal(this)), |
| 36 thread_safe_sender_(ChildThread::current()->thread_safe_sender()) {} |
| 37 |
| 38 ChildMessageFilter::~ChildMessageFilter() {} |
| 39 |
| 40 bool ChildMessageFilter::Send(IPC::Message* message) { |
| 41 return thread_safe_sender_->Send(message); |
| 42 } |
| 43 |
| 44 base::TaskRunner* ChildMessageFilter::OverrideTaskRunnerForMessage( |
| 45 const IPC::Message& message) { |
| 46 return NULL; |
| 47 } |
| 48 |
| 49 } // namespace content |
OLD | NEW |