blob: 0f49f957cbb37cea767c1a643cbf8783ca10d36d [file] [log] [blame]
[email protected]1f9ed192013-08-05 11:59:421// 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 "ppapi/proxy/tcp_server_socket_private_resource.h"
6
Sebastien Marchand6d0558fd2019-01-25 16:49:377#include "base/bind.h"
[email protected]1f9ed192013-08-05 11:59:428#include "ppapi/proxy/ppapi_messages.h"
[email protected]8522332e2013-08-28 19:42:599#include "ppapi/proxy/tcp_socket_private_resource.h"
[email protected]1f9ed192013-08-05 11:59:4210
11namespace ppapi {
12namespace proxy {
13
14TCPServerSocketPrivateResource::TCPServerSocketPrivateResource(
15 Connection connection,
16 PP_Instance instance)
17 : PluginResource(connection, instance),
18 state_(STATE_BEFORE_LISTENING),
[email protected]8522332e2013-08-28 19:42:5919 local_addr_() {
[email protected]1f9ed192013-08-05 11:59:4220 SendCreate(BROWSER, PpapiHostMsg_TCPServerSocket_CreatePrivate());
[email protected]1f9ed192013-08-05 11:59:4221}
22
23TCPServerSocketPrivateResource::~TCPServerSocketPrivateResource() {
24}
25
26thunk::PPB_TCPServerSocket_Private_API*
27TCPServerSocketPrivateResource::AsPPB_TCPServerSocket_Private_API() {
28 return this;
29}
30
31int32_t TCPServerSocketPrivateResource::Listen(
32 const PP_NetAddress_Private* addr,
33 int32_t backlog,
34 scoped_refptr<TrackedCallback> callback) {
35 if (!addr)
36 return PP_ERROR_BADARGUMENT;
37 if (state_ != STATE_BEFORE_LISTENING)
38 return PP_ERROR_FAILED;
39 if (TrackedCallback::IsPending(listen_callback_))
40 return PP_ERROR_INPROGRESS;
41
42 listen_callback_ = callback;
43
44 // Send the request, the browser will call us back via ListenACK
45 Call<PpapiPluginMsg_TCPServerSocket_ListenReply>(
Anand K Mistry9182c2a72021-03-17 04:40:0846 BROWSER, PpapiHostMsg_TCPServerSocket_Listen(*addr, backlog),
47 base::BindOnce(&TCPServerSocketPrivateResource::OnPluginMsgListenReply,
48 base::Unretained(this)));
[email protected]1f9ed192013-08-05 11:59:4249 return PP_OK_COMPLETIONPENDING;
50}
51
52int32_t TCPServerSocketPrivateResource::Accept(
53 PP_Resource* tcp_socket,
54 scoped_refptr<TrackedCallback> callback) {
55 if (!tcp_socket)
56 return PP_ERROR_BADARGUMENT;
57 if (state_ != STATE_LISTENING)
58 return PP_ERROR_FAILED;
59 if (TrackedCallback::IsPending(accept_callback_))
60 return PP_ERROR_INPROGRESS;
61
62 accept_callback_ = callback;
63
64 Call<PpapiPluginMsg_TCPServerSocket_AcceptReply>(
Anand K Mistry9182c2a72021-03-17 04:40:0865 BROWSER, PpapiHostMsg_TCPServerSocket_Accept(),
66 base::BindOnce(&TCPServerSocketPrivateResource::OnPluginMsgAcceptReply,
67 base::Unretained(this), tcp_socket));
[email protected]1f9ed192013-08-05 11:59:4268 return PP_OK_COMPLETIONPENDING;
69}
70
71int32_t TCPServerSocketPrivateResource::GetLocalAddress(
72 PP_NetAddress_Private* addr) {
73 if (!addr)
74 return PP_ERROR_BADARGUMENT;
75 if (state_ != STATE_LISTENING)
76 return PP_ERROR_FAILED;
77 *addr = local_addr_;
78 return PP_OK;
79}
80
81void TCPServerSocketPrivateResource::StopListening() {
82 if (state_ == STATE_CLOSED)
83 return;
84 state_ = STATE_CLOSED;
85 Post(BROWSER, PpapiHostMsg_TCPServerSocket_StopListening());
86 if (TrackedCallback::IsPending(listen_callback_))
87 listen_callback_->PostAbort();
88 if (TrackedCallback::IsPending(accept_callback_))
89 accept_callback_->PostAbort();
90}
91
92void TCPServerSocketPrivateResource::OnPluginMsgListenReply(
93 const ResourceMessageReplyParams& params,
94 const PP_NetAddress_Private& local_addr) {
95 if (state_ != STATE_BEFORE_LISTENING ||
96 !TrackedCallback::IsPending(listen_callback_)) {
97 return;
98 }
99 if (params.result() == PP_OK) {
100 local_addr_ = local_addr;
101 state_ = STATE_LISTENING;
102 }
103 listen_callback_->Run(params.result());
104}
105
106void TCPServerSocketPrivateResource::OnPluginMsgAcceptReply(
107 PP_Resource* tcp_socket,
108 const ResourceMessageReplyParams& params,
[email protected]8522332e2013-08-28 19:42:59109 int pending_resource_id,
[email protected]1f9ed192013-08-05 11:59:42110 const PP_NetAddress_Private& local_addr,
111 const PP_NetAddress_Private& remote_addr) {
112 DCHECK(tcp_socket);
113 if (state_ != STATE_LISTENING ||
114 !TrackedCallback::IsPending(accept_callback_)) {
115 return;
116 }
117 if (params.result() == PP_OK) {
[email protected]8522332e2013-08-28 19:42:59118 *tcp_socket = (new TCPSocketPrivateResource(connection(), pp_instance(),
119 pending_resource_id,
120 local_addr,
121 remote_addr))->GetReference();
[email protected]1f9ed192013-08-05 11:59:42122 }
123 accept_callback_->Run(params.result());
124}
125
126} // namespace proxy
127} // namespace ppapi