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/ppb_flash_message_loop_proxy.h"
6
7 #include "base/bind.h"
8 #include "ppapi/c/pp_errors.h"
9 #include "ppapi/c/private/ppb_flash_message_loop.h"
10 #include "ppapi/proxy/enter_proxy.h"
11 #include "ppapi/proxy/plugin_dispatcher.h"
12 #include "ppapi/proxy/ppapi_messages.h"
13 #include "ppapi/shared_impl/resource.h"
14 #include "ppapi/thunk/enter.h"
15 #include "ppapi/thunk/ppb_flash_message_loop_api.h"
16 #include "ppapi/thunk/resource_creation_api.h"
17
18 using ppapi::thunk::PPB_Flash_MessageLoop_API;
19
20 namespace ppapi {
21 namespace proxy {
22 namespace {
23
24 class FlashMessageLoop : public PPB_Flash_MessageLoop_API, public Resource {
25 public:
26 explicit FlashMessageLoop(const HostResource& resource);
27 virtual ~FlashMessageLoop();
28
29 // Resource overrides.
30 virtual PPB_Flash_MessageLoop_API* AsPPB_Flash_MessageLoop_API() OVERRIDE;
31
32 // PPB_Flash_MesssageLoop_API implementation.
33 virtual int32_t Run() OVERRIDE;
34 virtual void Quit() OVERRIDE;
35 virtual void RunFromHostProxy(
36 const RunFromHostProxyCallback& callback) OVERRIDE;
37
38 private:
39 DISALLOW_COPY_AND_ASSIGN(FlashMessageLoop);
40 };
41
FlashMessageLoop(const HostResource & resource)42 FlashMessageLoop::FlashMessageLoop(const HostResource& resource)
43 : Resource(OBJECT_IS_PROXY, resource) {
44 }
45
~FlashMessageLoop()46 FlashMessageLoop::~FlashMessageLoop() {
47 }
48
AsPPB_Flash_MessageLoop_API()49 PPB_Flash_MessageLoop_API* FlashMessageLoop::AsPPB_Flash_MessageLoop_API() {
50 return this;
51 }
52
Run()53 int32_t FlashMessageLoop::Run() {
54 int32_t result = PP_ERROR_FAILED;
55 IPC::SyncMessage* msg = new PpapiHostMsg_PPBFlashMessageLoop_Run(
56 API_ID_PPB_FLASH_MESSAGELOOP, host_resource(), &result);
57 msg->EnableMessagePumping();
58 PluginDispatcher::GetForResource(this)->Send(msg);
59 return result;
60 }
61
Quit()62 void FlashMessageLoop::Quit() {
63 PluginDispatcher::GetForResource(this)->Send(
64 new PpapiHostMsg_PPBFlashMessageLoop_Quit(
65 API_ID_PPB_FLASH_MESSAGELOOP, host_resource()));
66 }
67
RunFromHostProxy(const RunFromHostProxyCallback & callback)68 void FlashMessageLoop::RunFromHostProxy(
69 const RunFromHostProxyCallback& callback) {
70 // This should never be called on the plugin side.
71 NOTREACHED();
72 }
73
74 } // namespace
75
PPB_Flash_MessageLoop_Proxy(Dispatcher * dispatcher)76 PPB_Flash_MessageLoop_Proxy::PPB_Flash_MessageLoop_Proxy(Dispatcher* dispatcher)
77 : InterfaceProxy(dispatcher) {
78 }
79
~PPB_Flash_MessageLoop_Proxy()80 PPB_Flash_MessageLoop_Proxy::~PPB_Flash_MessageLoop_Proxy() {
81 }
82
83 // static
CreateProxyResource(PP_Instance instance)84 PP_Resource PPB_Flash_MessageLoop_Proxy::CreateProxyResource(
85 PP_Instance instance) {
86 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance);
87 if (!dispatcher)
88 return 0;
89
90 HostResource result;
91 dispatcher->Send(new PpapiHostMsg_PPBFlashMessageLoop_Create(
92 API_ID_PPB_FLASH_MESSAGELOOP, instance, &result));
93 if (result.is_null())
94 return 0;
95 return (new FlashMessageLoop(result))->GetReference();
96 }
97
OnMessageReceived(const IPC::Message & msg)98 bool PPB_Flash_MessageLoop_Proxy::OnMessageReceived(const IPC::Message& msg) {
99 if (!dispatcher()->permissions().HasPermission(PERMISSION_FLASH))
100 return false;
101
102 bool handled = true;
103 IPC_BEGIN_MESSAGE_MAP(PPB_Flash_MessageLoop_Proxy, msg)
104 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFlashMessageLoop_Create,
105 OnMsgCreate)
106 // We cannot use IPC_MESSAGE_HANDLER here. Because it tries to send the sync
107 // message reply after the handler returns. However, in this case, the
108 // PPB_Flash_MessageLoop_Proxy object may be destroyed before the handler
109 // returns.
110 IPC_MESSAGE_HANDLER_DELAY_REPLY(PpapiHostMsg_PPBFlashMessageLoop_Run,
111 OnMsgRun)
112 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFlashMessageLoop_Quit,
113 OnMsgQuit)
114 IPC_MESSAGE_UNHANDLED(handled = false)
115 IPC_END_MESSAGE_MAP()
116 return handled;
117 }
118
OnMsgCreate(PP_Instance instance,HostResource * result)119 void PPB_Flash_MessageLoop_Proxy::OnMsgCreate(PP_Instance instance,
120 HostResource* result) {
121 if (!dispatcher()->permissions().HasPermission(PERMISSION_FLASH))
122 return;
123 thunk::EnterResourceCreation enter(instance);
124 if (enter.succeeded()) {
125 result->SetHostResource(
126 instance, enter.functions()->CreateFlashMessageLoop(instance));
127 }
128 }
129
OnMsgRun(const HostResource & flash_message_loop,IPC::Message * reply)130 void PPB_Flash_MessageLoop_Proxy::OnMsgRun(
131 const HostResource& flash_message_loop,
132 IPC::Message* reply) {
133 if (!dispatcher()->permissions().HasPermission(PERMISSION_FLASH))
134 return;
135
136 PPB_Flash_MessageLoop_API::RunFromHostProxyCallback callback =
137 base::Bind(&PPB_Flash_MessageLoop_Proxy::WillQuitSoon, AsWeakPtr(),
138 base::Passed(scoped_ptr<IPC::Message>(reply)));
139
140 EnterHostFromHostResource<PPB_Flash_MessageLoop_API>
141 enter(flash_message_loop);
142 if (enter.succeeded())
143 enter.object()->RunFromHostProxy(callback);
144 else
145 callback.Run(PP_ERROR_BADRESOURCE);
146 }
147
OnMsgQuit(const ppapi::HostResource & flash_message_loop)148 void PPB_Flash_MessageLoop_Proxy::OnMsgQuit(
149 const ppapi::HostResource& flash_message_loop) {
150 EnterHostFromHostResource<PPB_Flash_MessageLoop_API>
151 enter(flash_message_loop);
152 if (enter.succeeded())
153 enter.object()->Quit();
154 }
155
WillQuitSoon(scoped_ptr<IPC::Message> reply_message,int32_t result)156 void PPB_Flash_MessageLoop_Proxy::WillQuitSoon(
157 scoped_ptr<IPC::Message> reply_message,
158 int32_t result) {
159 PpapiHostMsg_PPBFlashMessageLoop_Run::WriteReplyParams(reply_message.get(),
160 result);
161 Send(reply_message.release());
162 }
163
164 } // namespace proxy
165 } // namespace ppapi
166