1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// Copyright 2013 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "ppapi/proxy/udp_socket_resource.h"
#include "ppapi/shared_impl/tracked_callback.h"
#include "ppapi/thunk/enter.h"
#include "ppapi/thunk/ppb_net_address_api.h"
#include "ppapi/thunk/resource_creation_api.h"
namespace ppapi {
namespace proxy {
namespace {
typedef thunk::EnterResourceNoLock<thunk::PPB_NetAddress_API>
EnterNetAddressNoLock;
} // namespace
UDPSocketResource::UDPSocketResource(Connection connection,
PP_Instance instance)
: UDPSocketResourceBase(connection, instance, false) {
}
UDPSocketResource::~UDPSocketResource() {
}
thunk::PPB_UDPSocket_API* UDPSocketResource::AsPPB_UDPSocket_API() {
return this;
}
int32_t UDPSocketResource::Bind(PP_Resource addr,
scoped_refptr<TrackedCallback> callback) {
EnterNetAddressNoLock enter(addr, true);
if (enter.failed())
return PP_ERROR_BADARGUMENT;
return BindImpl(&enter.object()->GetNetAddressPrivate(), callback);
}
PP_Resource UDPSocketResource::GetBoundAddress() {
PP_NetAddress_Private addr_private;
if (!GetBoundAddressImpl(&addr_private))
return 0;
thunk::EnterResourceCreationNoLock enter(pp_instance());
if (enter.failed())
return 0;
return enter.functions()->CreateNetAddressFromNetAddressPrivate(
pp_instance(), addr_private);
}
int32_t UDPSocketResource::RecvFrom(char* buffer,
int32_t num_bytes,
PP_Resource* addr,
scoped_refptr<TrackedCallback> callback) {
return RecvFromImpl(buffer, num_bytes, addr, callback);
}
int32_t UDPSocketResource::SendTo(const char* buffer,
int32_t num_bytes,
PP_Resource addr,
scoped_refptr<TrackedCallback> callback) {
EnterNetAddressNoLock enter(addr, true);
if (enter.failed())
return PP_ERROR_BADARGUMENT;
return SendToImpl(buffer, num_bytes, &enter.object()->GetNetAddressPrivate(),
callback);
}
void UDPSocketResource::Close() {
CloseImpl();
}
int32_t UDPSocketResource::SetOption1_0(
PP_UDPSocket_Option name,
const PP_Var& value,
scoped_refptr<TrackedCallback> callback) {
if (name > PP_UDPSOCKET_OPTION_RECV_BUFFER_SIZE)
return PP_ERROR_BADARGUMENT;
return SetOptionImpl(name, value,
true, // Check bind() state.
callback);
}
int32_t UDPSocketResource::SetOption1_1(
PP_UDPSocket_Option name,
const PP_Var& value,
scoped_refptr<TrackedCallback> callback) {
if (name > PP_UDPSOCKET_OPTION_RECV_BUFFER_SIZE)
return PP_ERROR_BADARGUMENT;
return SetOptionImpl(name, value,
false, // Check bind() state.
callback);
}
int32_t UDPSocketResource::SetOption(
PP_UDPSocket_Option name,
const PP_Var& value,
scoped_refptr<TrackedCallback> callback) {
return SetOptionImpl(name, value,
false, // Check bind() state.
callback);
}
int32_t UDPSocketResource::JoinGroup(
PP_Resource group,
scoped_refptr<TrackedCallback> callback) {
EnterNetAddressNoLock enter(group, true);
if (enter.failed())
return PP_ERROR_BADRESOURCE;
return JoinGroupImpl(&enter.object()->GetNetAddressPrivate(),
callback);
}
int32_t UDPSocketResource::LeaveGroup(
PP_Resource group,
scoped_refptr<TrackedCallback> callback) {
EnterNetAddressNoLock enter(group, true);
if (enter.failed())
return PP_ERROR_BADRESOURCE;
return LeaveGroupImpl(&enter.object()->GetNetAddressPrivate(),
callback);
}
} // namespace proxy
} // namespace ppapi
|
