OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "ppapi/tests/test_udp_socket.h" | 5 #include "ppapi/tests/test_udp_socket.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "ppapi/cpp/dev/tcp_socket_dev.h" | 9 #include "ppapi/cpp/dev/tcp_socket_dev.h" |
10 #include "ppapi/cpp/dev/udp_socket_dev.h" | 10 #include "ppapi/cpp/dev/udp_socket_dev.h" |
11 #include "ppapi/cpp/pass_ref.h" | 11 #include "ppapi/cpp/pass_ref.h" |
12 #include "ppapi/cpp/var.h" | 12 #include "ppapi/cpp/var.h" |
13 #include "ppapi/tests/test_utils.h" | 13 #include "ppapi/tests/test_utils.h" |
14 #include "ppapi/tests/testing_instance.h" | 14 #include "ppapi/tests/testing_instance.h" |
15 | 15 |
16 REGISTER_TEST_CASE(UDPSocket); | 16 REGISTER_TEST_CASE(UDPSocket); |
17 | 17 |
18 namespace { | 18 namespace { |
19 | 19 |
20 const uint16_t kPortScanFrom = 1024; | 20 const uint16_t kPortScanFrom = 1024; |
21 const uint16_t kPortScanTo = 4096; | 21 const uint16_t kPortScanTo = 4096; |
22 | 22 |
23 pp::NetAddress_Dev ReplacePort(const pp::InstanceHandle& instance, | 23 pp::NetAddress ReplacePort(const pp::InstanceHandle& instance, |
24 const pp::NetAddress_Dev& addr, | 24 const pp::NetAddress& addr, |
25 uint16_t port) { | 25 uint16_t port) { |
26 switch (addr.GetFamily()) { | 26 switch (addr.GetFamily()) { |
27 case PP_NETADDRESS_FAMILY_IPV4: { | 27 case PP_NETADDRESS_FAMILY_IPV4: { |
28 PP_NetAddress_IPv4_Dev ipv4_addr; | 28 PP_NetAddress_IPv4 ipv4_addr; |
29 if (!addr.DescribeAsIPv4Address(&ipv4_addr)) | 29 if (!addr.DescribeAsIPv4Address(&ipv4_addr)) |
30 break; | 30 break; |
31 ipv4_addr.port = ConvertToNetEndian16(port); | 31 ipv4_addr.port = ConvertToNetEndian16(port); |
32 return pp::NetAddress_Dev(instance, ipv4_addr); | 32 return pp::NetAddress(instance, ipv4_addr); |
33 } | 33 } |
34 case PP_NETADDRESS_FAMILY_IPV6: { | 34 case PP_NETADDRESS_FAMILY_IPV6: { |
35 PP_NetAddress_IPv6_Dev ipv6_addr; | 35 PP_NetAddress_IPv6 ipv6_addr; |
36 if (!addr.DescribeAsIPv6Address(&ipv6_addr)) | 36 if (!addr.DescribeAsIPv6Address(&ipv6_addr)) |
37 break; | 37 break; |
38 ipv6_addr.port = ConvertToNetEndian16(port); | 38 ipv6_addr.port = ConvertToNetEndian16(port); |
39 return pp::NetAddress_Dev(instance, ipv6_addr); | 39 return pp::NetAddress(instance, ipv6_addr); |
40 } | 40 } |
41 default: { | 41 default: { |
42 PP_NOTREACHED(); | 42 PP_NOTREACHED(); |
43 } | 43 } |
44 } | 44 } |
45 return pp::NetAddress_Dev(); | 45 return pp::NetAddress(); |
46 } | 46 } |
47 | 47 |
48 } // namespace | 48 } // namespace |
49 | 49 |
50 TestUDPSocket::TestUDPSocket(TestingInstance* instance) : TestCase(instance) { | 50 TestUDPSocket::TestUDPSocket(TestingInstance* instance) : TestCase(instance) { |
51 } | 51 } |
52 | 52 |
53 bool TestUDPSocket::Init() { | 53 bool TestUDPSocket::Init() { |
54 bool tcp_socket_is_available = pp::TCPSocket_Dev::IsAvailable(); | 54 bool tcp_socket_is_available = pp::TCPSocket_Dev::IsAvailable(); |
55 if (!tcp_socket_is_available) | 55 if (!tcp_socket_is_available) |
56 instance_->AppendError("PPB_TCPSocket interface not available"); | 56 instance_->AppendError("PPB_TCPSocket interface not available"); |
57 | 57 |
58 bool udp_socket_is_available = pp::UDPSocket_Dev::IsAvailable(); | 58 bool udp_socket_is_available = pp::UDPSocket_Dev::IsAvailable(); |
59 if (!udp_socket_is_available) | 59 if (!udp_socket_is_available) |
60 instance_->AppendError("PPB_UDPSocket interface not available"); | 60 instance_->AppendError("PPB_UDPSocket interface not available"); |
61 | 61 |
62 bool net_address_is_available = pp::NetAddress_Dev::IsAvailable(); | 62 bool net_address_is_available = pp::NetAddress::IsAvailable(); |
63 if (!net_address_is_available) | 63 if (!net_address_is_available) |
64 instance_->AppendError("PPB_NetAddress interface not available"); | 64 instance_->AppendError("PPB_NetAddress interface not available"); |
65 | 65 |
66 std::string host; | 66 std::string host; |
67 uint16_t port = 0; | 67 uint16_t port = 0; |
68 bool init_address = | 68 bool init_address = |
69 GetLocalHostPort(instance_->pp_instance(), &host, &port) && | 69 GetLocalHostPort(instance_->pp_instance(), &host, &port) && |
70 ResolveHost(instance_->pp_instance(), host, port, &address_); | 70 ResolveHost(instance_->pp_instance(), host, port, &address_); |
71 if (!init_address) | 71 if (!init_address) |
72 instance_->AppendError("Can't init address"); | 72 instance_->AppendError("Can't init address"); |
73 | 73 |
74 return tcp_socket_is_available && | 74 return tcp_socket_is_available && |
75 udp_socket_is_available && | 75 udp_socket_is_available && |
76 net_address_is_available && | 76 net_address_is_available && |
77 init_address && | 77 init_address && |
78 CheckTestingInterface() && | 78 CheckTestingInterface() && |
79 EnsureRunningOverHTTP(); | 79 EnsureRunningOverHTTP(); |
80 } | 80 } |
81 | 81 |
82 void TestUDPSocket::RunTests(const std::string& filter) { | 82 void TestUDPSocket::RunTests(const std::string& filter) { |
83 RUN_CALLBACK_TEST(TestUDPSocket, ReadWrite, filter); | 83 RUN_CALLBACK_TEST(TestUDPSocket, ReadWrite, filter); |
84 RUN_CALLBACK_TEST(TestUDPSocket, Broadcast, filter); | 84 RUN_CALLBACK_TEST(TestUDPSocket, Broadcast, filter); |
85 RUN_CALLBACK_TEST(TestUDPSocket, SetOption, filter); | 85 RUN_CALLBACK_TEST(TestUDPSocket, SetOption, filter); |
86 } | 86 } |
87 | 87 |
88 std::string TestUDPSocket::GetLocalAddress(pp::NetAddress_Dev* address) { | 88 std::string TestUDPSocket::GetLocalAddress(pp::NetAddress* address) { |
89 pp::TCPSocket_Dev socket(instance_); | 89 pp::TCPSocket_Dev socket(instance_); |
90 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); | 90 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); |
91 callback.WaitForResult(socket.Connect(address_, callback.GetCallback())); | 91 callback.WaitForResult(socket.Connect(address_, callback.GetCallback())); |
92 CHECK_CALLBACK_BEHAVIOR(callback); | 92 CHECK_CALLBACK_BEHAVIOR(callback); |
93 ASSERT_EQ(PP_OK, callback.result()); | 93 ASSERT_EQ(PP_OK, callback.result()); |
94 *address = socket.GetLocalAddress(); | 94 *address = socket.GetLocalAddress(); |
95 ASSERT_NE(0, address->pp_resource()); | 95 ASSERT_NE(0, address->pp_resource()); |
96 socket.Close(); | 96 socket.Close(); |
97 PASS(); | 97 PASS(); |
98 } | 98 } |
99 | 99 |
100 std::string TestUDPSocket::SetBroadcastOptions(pp::UDPSocket_Dev* socket) { | 100 std::string TestUDPSocket::SetBroadcastOptions(pp::UDPSocket_Dev* socket) { |
101 TestCompletionCallback callback_1(instance_->pp_instance(), callback_type()); | 101 TestCompletionCallback callback_1(instance_->pp_instance(), callback_type()); |
102 callback_1.WaitForResult(socket->SetOption( | 102 callback_1.WaitForResult(socket->SetOption( |
103 PP_UDPSOCKET_OPTION_ADDRESS_REUSE, pp::Var(true), | 103 PP_UDPSOCKET_OPTION_ADDRESS_REUSE, pp::Var(true), |
104 callback_1.GetCallback())); | 104 callback_1.GetCallback())); |
105 CHECK_CALLBACK_BEHAVIOR(callback_1); | 105 CHECK_CALLBACK_BEHAVIOR(callback_1); |
106 ASSERT_EQ(PP_OK, callback_1.result()); | 106 ASSERT_EQ(PP_OK, callback_1.result()); |
107 | 107 |
108 TestCompletionCallback callback_2(instance_->pp_instance(), callback_type()); | 108 TestCompletionCallback callback_2(instance_->pp_instance(), callback_type()); |
109 callback_2.WaitForResult(socket->SetOption( | 109 callback_2.WaitForResult(socket->SetOption( |
110 PP_UDPSOCKET_OPTION_BROADCAST, pp::Var(true), callback_2.GetCallback())); | 110 PP_UDPSOCKET_OPTION_BROADCAST, pp::Var(true), callback_2.GetCallback())); |
111 CHECK_CALLBACK_BEHAVIOR(callback_2); | 111 CHECK_CALLBACK_BEHAVIOR(callback_2); |
112 ASSERT_EQ(PP_OK, callback_2.result()); | 112 ASSERT_EQ(PP_OK, callback_2.result()); |
113 | 113 |
114 PASS(); | 114 PASS(); |
115 } | 115 } |
116 | 116 |
117 std::string TestUDPSocket::BindUDPSocket(pp::UDPSocket_Dev* socket, | 117 std::string TestUDPSocket::BindUDPSocket(pp::UDPSocket_Dev* socket, |
118 const pp::NetAddress_Dev& address) { | 118 const pp::NetAddress& address) { |
119 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); | 119 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); |
120 callback.WaitForResult(socket->Bind(address, callback.GetCallback())); | 120 callback.WaitForResult(socket->Bind(address, callback.GetCallback())); |
121 CHECK_CALLBACK_BEHAVIOR(callback); | 121 CHECK_CALLBACK_BEHAVIOR(callback); |
122 ASSERT_EQ(PP_OK, callback.result()); | 122 ASSERT_EQ(PP_OK, callback.result()); |
123 PASS(); | 123 PASS(); |
124 } | 124 } |
125 | 125 |
126 std::string TestUDPSocket::LookupPortAndBindUDPSocket( | 126 std::string TestUDPSocket::LookupPortAndBindUDPSocket( |
127 pp::UDPSocket_Dev* socket, | 127 pp::UDPSocket_Dev* socket, |
128 pp::NetAddress_Dev* address) { | 128 pp::NetAddress* address) { |
129 pp::NetAddress_Dev base_address; | 129 pp::NetAddress base_address; |
130 ASSERT_SUBTEST_SUCCESS(GetLocalAddress(&base_address)); | 130 ASSERT_SUBTEST_SUCCESS(GetLocalAddress(&base_address)); |
131 | 131 |
132 bool is_free_port_found = false; | 132 bool is_free_port_found = false; |
133 for (uint16_t port = kPortScanFrom; port < kPortScanTo; ++port) { | 133 for (uint16_t port = kPortScanFrom; port < kPortScanTo; ++port) { |
134 pp::NetAddress_Dev new_address = ReplacePort(instance_, base_address, port); | 134 pp::NetAddress new_address = ReplacePort(instance_, base_address, port); |
135 ASSERT_NE(0, new_address.pp_resource()); | 135 ASSERT_NE(0, new_address.pp_resource()); |
136 if (BindUDPSocket(socket, new_address).empty()) { | 136 if (BindUDPSocket(socket, new_address).empty()) { |
137 is_free_port_found = true; | 137 is_free_port_found = true; |
138 break; | 138 break; |
139 } | 139 } |
140 } | 140 } |
141 if (!is_free_port_found) | 141 if (!is_free_port_found) |
142 return "Can't find available port"; | 142 return "Can't find available port"; |
143 | 143 |
144 *address = socket->GetBoundAddress(); | 144 *address = socket->GetBoundAddress(); |
145 ASSERT_NE(0, address->pp_resource()); | 145 ASSERT_NE(0, address->pp_resource()); |
146 | 146 |
147 PASS(); | 147 PASS(); |
148 } | 148 } |
149 | 149 |
150 std::string TestUDPSocket::ReadSocket(pp::UDPSocket_Dev* socket, | 150 std::string TestUDPSocket::ReadSocket(pp::UDPSocket_Dev* socket, |
151 pp::NetAddress_Dev* address, | 151 pp::NetAddress* address, |
152 size_t size, | 152 size_t size, |
153 std::string* message) { | 153 std::string* message) { |
154 std::vector<char> buffer(size); | 154 std::vector<char> buffer(size); |
155 TestCompletionCallbackWithOutput<pp::NetAddress_Dev> callback( | 155 TestCompletionCallbackWithOutput<pp::NetAddress> callback( |
156 instance_->pp_instance(), callback_type()); | 156 instance_->pp_instance(), callback_type()); |
157 callback.WaitForResult( | 157 callback.WaitForResult( |
158 socket->RecvFrom(&buffer[0], size, callback.GetCallback())); | 158 socket->RecvFrom(&buffer[0], size, callback.GetCallback())); |
159 CHECK_CALLBACK_BEHAVIOR(callback); | 159 CHECK_CALLBACK_BEHAVIOR(callback); |
160 ASSERT_FALSE(callback.result() < 0); | 160 ASSERT_FALSE(callback.result() < 0); |
161 ASSERT_EQ(size, static_cast<size_t>(callback.result())); | 161 ASSERT_EQ(size, static_cast<size_t>(callback.result())); |
162 *address = callback.output(); | 162 *address = callback.output(); |
163 message->assign(buffer.begin(), buffer.end()); | 163 message->assign(buffer.begin(), buffer.end()); |
164 PASS(); | 164 PASS(); |
165 } | 165 } |
166 | 166 |
167 std::string TestUDPSocket::PassMessage(pp::UDPSocket_Dev* target, | 167 std::string TestUDPSocket::PassMessage(pp::UDPSocket_Dev* target, |
168 pp::UDPSocket_Dev* source, | 168 pp::UDPSocket_Dev* source, |
169 const pp::NetAddress_Dev& target_address, | 169 const pp::NetAddress& target_address, |
170 const std::string& message, | 170 const std::string& message, |
171 pp::NetAddress_Dev* recvfrom_address) { | 171 pp::NetAddress* recvfrom_address) { |
172 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); | 172 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); |
173 int32_t rv = source->SendTo(message.c_str(), message.size(), | 173 int32_t rv = source->SendTo(message.c_str(), message.size(), |
174 target_address, | 174 target_address, |
175 callback.GetCallback()); | 175 callback.GetCallback()); |
176 std::string str; | 176 std::string str; |
177 ASSERT_SUBTEST_SUCCESS(ReadSocket(target, recvfrom_address, message.size(), | 177 ASSERT_SUBTEST_SUCCESS(ReadSocket(target, recvfrom_address, message.size(), |
178 &str)); | 178 &str)); |
179 | 179 |
180 callback.WaitForResult(rv); | 180 callback.WaitForResult(rv); |
181 CHECK_CALLBACK_BEHAVIOR(callback); | 181 CHECK_CALLBACK_BEHAVIOR(callback); |
182 ASSERT_FALSE(callback.result() < 0); | 182 ASSERT_FALSE(callback.result() < 0); |
183 ASSERT_EQ(message.size(), static_cast<size_t>(callback.result())); | 183 ASSERT_EQ(message.size(), static_cast<size_t>(callback.result())); |
184 ASSERT_EQ(message, str); | 184 ASSERT_EQ(message, str); |
185 PASS(); | 185 PASS(); |
186 } | 186 } |
187 | 187 |
188 std::string TestUDPSocket::TestReadWrite() { | 188 std::string TestUDPSocket::TestReadWrite() { |
189 pp::UDPSocket_Dev server_socket(instance_), client_socket(instance_); | 189 pp::UDPSocket_Dev server_socket(instance_), client_socket(instance_); |
190 pp::NetAddress_Dev server_address, client_address; | 190 pp::NetAddress server_address, client_address; |
191 | 191 |
192 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&server_socket, | 192 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&server_socket, |
193 &server_address)); | 193 &server_address)); |
194 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&client_socket, | 194 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&client_socket, |
195 &client_address)); | 195 &client_address)); |
196 const std::string message = "Simple message that will be sent via UDP"; | 196 const std::string message = "Simple message that will be sent via UDP"; |
197 pp::NetAddress_Dev recvfrom_address; | 197 pp::NetAddress recvfrom_address; |
198 ASSERT_SUBTEST_SUCCESS(PassMessage(&server_socket, &client_socket, | 198 ASSERT_SUBTEST_SUCCESS(PassMessage(&server_socket, &client_socket, |
199 server_address, message, | 199 server_address, message, |
200 &recvfrom_address)); | 200 &recvfrom_address)); |
201 ASSERT_TRUE(EqualNetAddress(recvfrom_address, client_address)); | 201 ASSERT_TRUE(EqualNetAddress(recvfrom_address, client_address)); |
202 | 202 |
203 server_socket.Close(); | 203 server_socket.Close(); |
204 client_socket.Close(); | 204 client_socket.Close(); |
205 | 205 |
206 if (server_socket.GetBoundAddress().pp_resource() != 0) | 206 if (server_socket.GetBoundAddress().pp_resource() != 0) |
207 return "PPB_UDPSocket::GetBoundAddress: expected failure"; | 207 return "PPB_UDPSocket::GetBoundAddress: expected failure"; |
208 | 208 |
209 PASS(); | 209 PASS(); |
210 } | 210 } |
211 | 211 |
212 std::string TestUDPSocket::TestBroadcast() { | 212 std::string TestUDPSocket::TestBroadcast() { |
213 pp::UDPSocket_Dev server1(instance_), server2(instance_); | 213 pp::UDPSocket_Dev server1(instance_), server2(instance_); |
214 | 214 |
215 ASSERT_SUBTEST_SUCCESS(SetBroadcastOptions(&server1)); | 215 ASSERT_SUBTEST_SUCCESS(SetBroadcastOptions(&server1)); |
216 ASSERT_SUBTEST_SUCCESS(SetBroadcastOptions(&server2)); | 216 ASSERT_SUBTEST_SUCCESS(SetBroadcastOptions(&server2)); |
217 | 217 |
218 PP_NetAddress_IPv4_Dev any_ipv4_address = { 0, { 0, 0, 0, 0 } }; | 218 PP_NetAddress_IPv4 any_ipv4_address = { 0, { 0, 0, 0, 0 } }; |
219 pp::NetAddress_Dev any_address(instance_, any_ipv4_address); | 219 pp::NetAddress any_address(instance_, any_ipv4_address); |
220 ASSERT_SUBTEST_SUCCESS(BindUDPSocket(&server1, any_address)); | 220 ASSERT_SUBTEST_SUCCESS(BindUDPSocket(&server1, any_address)); |
221 // Fill port field of |server_address|. | 221 // Fill port field of |server_address|. |
222 pp::NetAddress_Dev server_address = server1.GetBoundAddress(); | 222 pp::NetAddress server_address = server1.GetBoundAddress(); |
223 ASSERT_NE(0, server_address.pp_resource()); | 223 ASSERT_NE(0, server_address.pp_resource()); |
224 ASSERT_SUBTEST_SUCCESS(BindUDPSocket(&server2, server_address)); | 224 ASSERT_SUBTEST_SUCCESS(BindUDPSocket(&server2, server_address)); |
225 | 225 |
226 PP_NetAddress_IPv4_Dev server_ipv4_address; | 226 PP_NetAddress_IPv4 server_ipv4_address; |
227 ASSERT_TRUE(server_address.DescribeAsIPv4Address(&server_ipv4_address)); | 227 ASSERT_TRUE(server_address.DescribeAsIPv4Address(&server_ipv4_address)); |
228 | 228 |
229 PP_NetAddress_IPv4_Dev broadcast_ipv4_address = { | 229 PP_NetAddress_IPv4 broadcast_ipv4_address = { |
230 server_ipv4_address.port, { 0xff, 0xff, 0xff, 0xff } | 230 server_ipv4_address.port, { 0xff, 0xff, 0xff, 0xff } |
231 }; | 231 }; |
232 pp::NetAddress_Dev broadcast_address(instance_, broadcast_ipv4_address); | 232 pp::NetAddress broadcast_address(instance_, broadcast_ipv4_address); |
233 | 233 |
234 std::string message; | 234 std::string message; |
235 const std::string first_message = "first message"; | 235 const std::string first_message = "first message"; |
236 const std::string second_message = "second_message"; | 236 const std::string second_message = "second_message"; |
237 | 237 |
238 pp::NetAddress_Dev recvfrom_address; | 238 pp::NetAddress recvfrom_address; |
239 ASSERT_SUBTEST_SUCCESS(PassMessage(&server1, &server2, broadcast_address, | 239 ASSERT_SUBTEST_SUCCESS(PassMessage(&server1, &server2, broadcast_address, |
240 first_message, &recvfrom_address)); | 240 first_message, &recvfrom_address)); |
241 // |first_message| was also received by |server2|. | 241 // |first_message| was also received by |server2|. |
242 ASSERT_SUBTEST_SUCCESS(ReadSocket(&server2, &recvfrom_address, | 242 ASSERT_SUBTEST_SUCCESS(ReadSocket(&server2, &recvfrom_address, |
243 first_message.size(), &message)); | 243 first_message.size(), &message)); |
244 ASSERT_EQ(first_message, message); | 244 ASSERT_EQ(first_message, message); |
245 | 245 |
246 ASSERT_SUBTEST_SUCCESS(PassMessage(&server2, &server1, broadcast_address, | 246 ASSERT_SUBTEST_SUCCESS(PassMessage(&server2, &server1, broadcast_address, |
247 second_message, &recvfrom_address)); | 247 second_message, &recvfrom_address)); |
248 // |second_message| was also received by |server1|. | 248 // |second_message| was also received by |server1|. |
(...skipping 30 matching lines...) Expand all Loading... |
279 callback.GetCallback())); | 279 callback.GetCallback())); |
280 CHECK_CALLBACK_BEHAVIOR(callback); | 280 CHECK_CALLBACK_BEHAVIOR(callback); |
281 ASSERT_EQ(PP_ERROR_FAILED, callback.result()); | 281 ASSERT_EQ(PP_ERROR_FAILED, callback.result()); |
282 | 282 |
283 callback.WaitForResult(socket.SetOption( | 283 callback.WaitForResult(socket.SetOption( |
284 PP_UDPSOCKET_OPTION_RECV_BUFFER_SIZE, pp::Var(512), | 284 PP_UDPSOCKET_OPTION_RECV_BUFFER_SIZE, pp::Var(512), |
285 callback.GetCallback())); | 285 callback.GetCallback())); |
286 CHECK_CALLBACK_BEHAVIOR(callback); | 286 CHECK_CALLBACK_BEHAVIOR(callback); |
287 ASSERT_EQ(PP_ERROR_FAILED, callback.result()); | 287 ASSERT_EQ(PP_ERROR_FAILED, callback.result()); |
288 | 288 |
289 pp::NetAddress_Dev address; | 289 pp::NetAddress address; |
290 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&socket, &address)); | 290 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&socket, &address)); |
291 | 291 |
292 // ADDRESS_REUSE and BROADCAST won't take effect after the socket is bound. | 292 // ADDRESS_REUSE and BROADCAST won't take effect after the socket is bound. |
293 callback.WaitForResult(socket.SetOption( | 293 callback.WaitForResult(socket.SetOption( |
294 PP_UDPSOCKET_OPTION_ADDRESS_REUSE, pp::Var(true), | 294 PP_UDPSOCKET_OPTION_ADDRESS_REUSE, pp::Var(true), |
295 callback.GetCallback())); | 295 callback.GetCallback())); |
296 CHECK_CALLBACK_BEHAVIOR(callback); | 296 CHECK_CALLBACK_BEHAVIOR(callback); |
297 ASSERT_EQ(PP_ERROR_FAILED, callback.result()); | 297 ASSERT_EQ(PP_ERROR_FAILED, callback.result()); |
298 | 298 |
299 callback.WaitForResult(socket.SetOption( | 299 callback.WaitForResult(socket.SetOption( |
300 PP_UDPSOCKET_OPTION_BROADCAST, pp::Var(true), callback.GetCallback())); | 300 PP_UDPSOCKET_OPTION_BROADCAST, pp::Var(true), callback.GetCallback())); |
301 CHECK_CALLBACK_BEHAVIOR(callback); | 301 CHECK_CALLBACK_BEHAVIOR(callback); |
302 ASSERT_EQ(PP_ERROR_FAILED, callback.result()); | 302 ASSERT_EQ(PP_ERROR_FAILED, callback.result()); |
303 | 303 |
304 // SEND_BUFFER_SIZE and RECV_BUFFER_SIZE can be set after the socket is bound. | 304 // SEND_BUFFER_SIZE and RECV_BUFFER_SIZE can be set after the socket is bound. |
305 callback.WaitForResult(socket.SetOption( | 305 callback.WaitForResult(socket.SetOption( |
306 PP_UDPSOCKET_OPTION_SEND_BUFFER_SIZE, pp::Var(2048), | 306 PP_UDPSOCKET_OPTION_SEND_BUFFER_SIZE, pp::Var(2048), |
307 callback.GetCallback())); | 307 callback.GetCallback())); |
308 CHECK_CALLBACK_BEHAVIOR(callback); | 308 CHECK_CALLBACK_BEHAVIOR(callback); |
309 ASSERT_EQ(PP_OK, callback.result()); | 309 ASSERT_EQ(PP_OK, callback.result()); |
310 | 310 |
311 callback.WaitForResult(socket.SetOption( | 311 callback.WaitForResult(socket.SetOption( |
312 PP_UDPSOCKET_OPTION_RECV_BUFFER_SIZE, pp::Var(1024), | 312 PP_UDPSOCKET_OPTION_RECV_BUFFER_SIZE, pp::Var(1024), |
313 callback.GetCallback())); | 313 callback.GetCallback())); |
314 CHECK_CALLBACK_BEHAVIOR(callback); | 314 CHECK_CALLBACK_BEHAVIOR(callback); |
315 ASSERT_EQ(PP_OK, callback.result()); | 315 ASSERT_EQ(PP_OK, callback.result()); |
316 | 316 |
317 PASS(); | 317 PASS(); |
318 } | 318 } |
OLD | NEW |