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
3 // found in the LICENSE file.
4
5 #include "ppapi/proxy/broker_dispatcher.h"
6
7 #include "base/sync_socket.h"
8 #include "ppapi/c/pp_errors.h"
9 #include "ppapi/proxy/ppapi_messages.h"
10 #include "ppapi/shared_impl/platform_file.h"
11
12 namespace ppapi {
13 namespace proxy {
14
BrokerDispatcher(PP_ConnectInstance_Func connect_instance)15 BrokerDispatcher::BrokerDispatcher(PP_ConnectInstance_Func connect_instance)
16 : connect_instance_(connect_instance) {
17 }
18
~BrokerDispatcher()19 BrokerDispatcher::~BrokerDispatcher() {
20 }
21
InitBrokerWithChannel(ProxyChannel::Delegate * delegate,base::ProcessId peer_pid,const IPC::ChannelHandle & channel_handle,bool is_client)22 bool BrokerDispatcher::InitBrokerWithChannel(
23 ProxyChannel::Delegate* delegate,
24 base::ProcessId peer_pid,
25 const IPC::ChannelHandle& channel_handle,
26 bool is_client) {
27 return ProxyChannel::InitWithChannel(delegate, peer_pid, channel_handle,
28 is_client);
29 }
30
OnMessageReceived(const IPC::Message & msg)31 bool BrokerDispatcher::OnMessageReceived(const IPC::Message& msg) {
32 // Control messages.
33 if (msg.routing_id() == MSG_ROUTING_CONTROL) {
34 bool handled = true;
35 IPC_BEGIN_MESSAGE_MAP(BrokerDispatcher, msg)
36 IPC_MESSAGE_HANDLER(PpapiMsg_ConnectToPlugin, OnMsgConnectToPlugin)
37 IPC_MESSAGE_UNHANDLED(handled = false)
38 IPC_END_MESSAGE_MAP()
39 return handled;
40 }
41 return false;
42 }
43
44 // Transfers ownership of the handle to the broker module.
OnMsgConnectToPlugin(PP_Instance instance,IPC::PlatformFileForTransit handle,int32_t * result)45 void BrokerDispatcher::OnMsgConnectToPlugin(
46 PP_Instance instance,
47 IPC::PlatformFileForTransit handle,
48 int32_t* result) {
49 if (handle == IPC::InvalidPlatformFileForTransit()) {
50 *result = PP_ERROR_FAILED;
51 } else {
52 base::SyncSocket::Handle socket_handle =
53 IPC::PlatformFileForTransitToPlatformFile(handle);
54
55 if (connect_instance_) {
56 *result = connect_instance_(instance,
57 ppapi::PlatformFileToInt(socket_handle));
58 } else {
59 *result = PP_ERROR_FAILED;
60 // Close the handle since there is no other owner.
61 // The easiest way to clean it up is to just put it in an object
62 // and then close them. This failure case is not performance critical.
63 base::SyncSocket temp_socket(socket_handle);
64 }
65 }
66 }
67
BrokerHostDispatcher()68 BrokerHostDispatcher::BrokerHostDispatcher()
69 : BrokerDispatcher(NULL) {
70 }
71
OnChannelError()72 void BrokerHostDispatcher::OnChannelError() {
73 DVLOG(1) << "BrokerHostDispatcher::OnChannelError()";
74 BrokerDispatcher::OnChannelError(); // Stop using the channel.
75
76 // Tell the host about the crash so it can clean up and display notification.
77 // TODO(ddorwin): Add BrokerCrashed() to PPB_Proxy_Private and call it.
78 // ppb_proxy_->BrokerCrashed(pp_module());
79 }
80
BrokerSideDispatcher(PP_ConnectInstance_Func connect_instance)81 BrokerSideDispatcher::BrokerSideDispatcher(
82 PP_ConnectInstance_Func connect_instance)
83 : BrokerDispatcher(connect_instance) {
84 }
85
OnChannelError()86 void BrokerSideDispatcher::OnChannelError() {
87 DVLOG(1) << "BrokerSideDispatcher::OnChannelError()";
88 BrokerDispatcher::OnChannelError();
89
90 // The renderer has crashed or exited. This channel and all instances
91 // associated with it are no longer valid.
92 // TODO(ddorwin): This causes the broker process to exit, which may not be
93 // desirable in some use cases.
94 delete this;
95 }
96
97
98 } // namespace proxy
99 } // namespace ppapi
100