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/talk_resource.h"
6
7 #include "base/bind.h"
8 #include "ppapi/proxy/ppapi_messages.h"
9
10 namespace ppapi {
11 namespace proxy {
12
TalkResource(Connection connection,PP_Instance instance)13 TalkResource::TalkResource(Connection connection, PP_Instance instance)
14 : PluginResource(connection, instance),
15 event_callback_(NULL),
16 event_callback_user_data_(NULL) {
17 SendCreate(BROWSER, PpapiHostMsg_Talk_Create());
18 }
19
~TalkResource()20 TalkResource::~TalkResource() {
21 }
22
AsPPB_Talk_Private_API()23 thunk::PPB_Talk_Private_API* TalkResource::AsPPB_Talk_Private_API() {
24 return this;
25 }
26
RequestPermission(PP_TalkPermission permission,scoped_refptr<TrackedCallback> callback)27 int32_t TalkResource::RequestPermission(
28 PP_TalkPermission permission,
29 scoped_refptr<TrackedCallback> callback) {
30 if (TrackedCallback::IsPending(permission_callback_))
31 return PP_ERROR_INPROGRESS;
32
33 permission_callback_ = callback;
34
35 Call<PpapiPluginMsg_Talk_RequestPermissionReply>(
36 BROWSER,
37 PpapiHostMsg_Talk_RequestPermission(permission),
38 base::Bind(&TalkResource::OnRequestPermissionReply,
39 base::Unretained(this)));
40 return PP_OK_COMPLETIONPENDING;
41 }
42
StartRemoting(PP_TalkEventCallback event_callback,void * user_data,scoped_refptr<TrackedCallback> callback)43 int32_t TalkResource::StartRemoting(PP_TalkEventCallback event_callback,
44 void* user_data,
45 scoped_refptr<TrackedCallback> callback) {
46 if (TrackedCallback::IsPending(start_callback_) ||
47 event_callback_ != NULL)
48 return PP_ERROR_INPROGRESS;
49
50 start_callback_ = callback;
51 event_callback_ = event_callback;
52 event_callback_user_data_ = user_data;
53
54 Call<PpapiPluginMsg_Talk_StartRemotingReply>(
55 BROWSER,
56 PpapiHostMsg_Talk_StartRemoting(),
57 base::Bind(&TalkResource::OnStartRemotingReply,
58 base::Unretained(this)));
59 return PP_OK_COMPLETIONPENDING;
60 }
61
StopRemoting(scoped_refptr<TrackedCallback> callback)62 int32_t TalkResource::StopRemoting(scoped_refptr<TrackedCallback> callback) {
63 if (TrackedCallback::IsPending(stop_callback_))
64 return PP_ERROR_INPROGRESS;
65
66 if (event_callback_ == NULL)
67 return PP_ERROR_FAILED;
68
69 stop_callback_ = callback;
70
71 Call<PpapiPluginMsg_Talk_StopRemotingReply>(
72 BROWSER,
73 PpapiHostMsg_Talk_StopRemoting(),
74 base::Bind(&TalkResource::OnStopRemotingReply,
75 base::Unretained(this)));
76 return PP_OK_COMPLETIONPENDING;
77 }
78
OnReplyReceived(const ResourceMessageReplyParams & params,const IPC::Message & msg)79 void TalkResource::OnReplyReceived(const ResourceMessageReplyParams& params,
80 const IPC::Message& msg) {
81 PPAPI_BEGIN_MESSAGE_MAP(TalkResource, msg)
82 PPAPI_DISPATCH_PLUGIN_RESOURCE_CALL(
83 PpapiPluginMsg_Talk_NotifyEvent,
84 OnNotifyEvent)
85 PPAPI_DISPATCH_PLUGIN_RESOURCE_CALL_UNHANDLED(
86 PluginResource::OnReplyReceived(params, msg))
87 PPAPI_END_MESSAGE_MAP()
88 }
89
OnNotifyEvent(const ResourceMessageReplyParams & params,PP_TalkEvent event)90 void TalkResource::OnNotifyEvent(const ResourceMessageReplyParams& params,
91 PP_TalkEvent event) {
92 if (event_callback_ != NULL)
93 event_callback_(event_callback_user_data_, event);
94 }
95
OnRequestPermissionReply(const ResourceMessageReplyParams & params)96 void TalkResource::OnRequestPermissionReply(
97 const ResourceMessageReplyParams& params) {
98 permission_callback_->Run(params.result());
99 }
100
OnStartRemotingReply(const ResourceMessageReplyParams & params)101 void TalkResource::OnStartRemotingReply(
102 const ResourceMessageReplyParams& params) {
103 start_callback_->Run(params.result());
104 }
105
OnStopRemotingReply(const ResourceMessageReplyParams & params)106 void TalkResource::OnStopRemotingReply(
107 const ResourceMessageReplyParams& params) {
108 event_callback_ = NULL;
109 event_callback_user_data_ = NULL;
110 stop_callback_->Run(params.result());
111 }
112
113 } // namespace proxy
114 } // namespace ppapi
115