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 #include "content/renderer/pepper/pepper_in_process_router.h" | 5 #include "content/renderer/pepper/pepper_in_process_router.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
9 #include "content/public/renderer/render_thread.h" | 9 #include "content/public/renderer/render_thread.h" |
10 #include "content/public/renderer/render_view.h" | 10 #include "content/public/renderer/render_view.h" |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
103 // the message. | 103 // the message. |
104 if (resource) | 104 if (resource) |
105 resource->OnReplyReceived(reply_params, nested_msg); | 105 resource->OnReplyReceived(reply_params, nested_msg); |
106 return true; | 106 return true; |
107 } | 107 } |
108 | 108 |
109 bool PepperInProcessRouter::SendToHost(IPC::Message* msg) { | 109 bool PepperInProcessRouter::SendToHost(IPC::Message* msg) { |
110 scoped_ptr<IPC::Message> message(msg); | 110 scoped_ptr<IPC::Message> message(msg); |
111 | 111 |
112 if (!message->is_sync()) { | 112 if (!message->is_sync()) { |
113 bool result = host_impl_->GetPpapiHost()->OnMessageReceived(*message); | 113 // If this is a resource destroyed message, post a task to dispatch it. |
114 DCHECK(result) << "The message was not handled by the host."; | 114 // Dispatching it synchronously can cause the host to re-enter the proxy |
115 return true; | 115 // code while we're still in the resource destructor, leading to a crash. |
| 116 // http://crbug.com/276368. |
| 117 // This won't cause message reordering problems because the resource |
| 118 // destroyed message is always the last one sent for a resource. |
| 119 if (message->type() == PpapiHostMsg_ResourceDestroyed::ID) { |
| 120 base::MessageLoop::current()->PostTask( |
| 121 FROM_HERE, |
| 122 base::Bind(&PepperInProcessRouter::DispatchHostMsg, |
| 123 weak_factory_.GetWeakPtr(), |
| 124 base::Owned(message.release()))); |
| 125 return true; |
| 126 } else { |
| 127 bool result = host_impl_->GetPpapiHost()->OnMessageReceived(*message); |
| 128 DCHECK(result) << "The message was not handled by the host."; |
| 129 return true; |
| 130 } |
116 } | 131 } |
117 | 132 |
118 pending_message_id_ = IPC::SyncMessage::GetMessageId(*message); | 133 pending_message_id_ = IPC::SyncMessage::GetMessageId(*message); |
119 reply_deserializer_.reset( | 134 reply_deserializer_.reset( |
120 static_cast<IPC::SyncMessage*>(message.get())->GetReplyDeserializer()); | 135 static_cast<IPC::SyncMessage*>(message.get())->GetReplyDeserializer()); |
121 reply_result_ = false; | 136 reply_result_ = false; |
122 | 137 |
123 bool result = host_impl_->GetPpapiHost()->OnMessageReceived(*message); | 138 bool result = host_impl_->GetPpapiHost()->OnMessageReceived(*message); |
124 DCHECK(result) << "The message was not handled by the host."; | 139 DCHECK(result) << "The message was not handled by the host."; |
125 | 140 |
(...skipping 13 matching lines...) Expand all Loading... |
139 // Dispatch plugin messages from the message loop. | 154 // Dispatch plugin messages from the message loop. |
140 base::MessageLoop::current()->PostTask( | 155 base::MessageLoop::current()->PostTask( |
141 FROM_HERE, | 156 FROM_HERE, |
142 base::Bind(&PepperInProcessRouter::DispatchPluginMsg, | 157 base::Bind(&PepperInProcessRouter::DispatchPluginMsg, |
143 weak_factory_.GetWeakPtr(), | 158 weak_factory_.GetWeakPtr(), |
144 base::Owned(message.release()))); | 159 base::Owned(message.release()))); |
145 } | 160 } |
146 return true; | 161 return true; |
147 } | 162 } |
148 | 163 |
| 164 void PepperInProcessRouter::DispatchHostMsg(IPC::Message* msg) { |
| 165 bool handled = host_impl_->GetPpapiHost()->OnMessageReceived(*msg); |
| 166 DCHECK(handled); |
| 167 } |
| 168 |
149 void PepperInProcessRouter::DispatchPluginMsg(IPC::Message* msg) { | 169 void PepperInProcessRouter::DispatchPluginMsg(IPC::Message* msg) { |
150 bool handled = OnPluginMsgReceived(*msg); | 170 bool handled = OnPluginMsgReceived(*msg); |
151 DCHECK(handled); | 171 DCHECK(handled); |
152 } | 172 } |
153 | 173 |
154 bool PepperInProcessRouter::SendToBrowser(IPC::Message *msg) { | 174 bool PepperInProcessRouter::SendToBrowser(IPC::Message *msg) { |
155 return RenderThread::Get()->Send(msg); | 175 return RenderThread::Get()->Send(msg); |
156 } | 176 } |
157 | 177 |
158 } // namespace content | 178 } // namespace content |
OLD | NEW |