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/pass_ref.h" | 9 #include "ppapi/cpp/pass_ref.h" |
10 #include "ppapi/cpp/tcp_socket.h" | 10 #include "ppapi/cpp/tcp_socket.h" |
(...skipping 29 matching lines...) Expand all Loading... |
40 } | 40 } |
41 default: { | 41 default: { |
42 PP_NOTREACHED(); | 42 PP_NOTREACHED(); |
43 } | 43 } |
44 } | 44 } |
45 return pp::NetAddress(); | 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) |
| 51 : TestCase(instance), |
| 52 socket_interface_1_0_(NULL), |
| 53 socket_interface_1_1_(NULL) { |
51 } | 54 } |
52 | 55 |
53 bool TestUDPSocket::Init() { | 56 bool TestUDPSocket::Init() { |
54 bool tcp_socket_is_available = pp::TCPSocket::IsAvailable(); | 57 bool tcp_socket_is_available = pp::TCPSocket::IsAvailable(); |
55 if (!tcp_socket_is_available) | 58 if (!tcp_socket_is_available) |
56 instance_->AppendError("PPB_TCPSocket interface not available"); | 59 instance_->AppendError("PPB_TCPSocket interface not available"); |
57 | 60 |
58 bool udp_socket_is_available = pp::UDPSocket::IsAvailable(); | 61 bool udp_socket_is_available = pp::UDPSocket::IsAvailable(); |
59 if (!udp_socket_is_available) | 62 if (!udp_socket_is_available) |
60 instance_->AppendError("PPB_UDPSocket interface not available"); | 63 instance_->AppendError("PPB_UDPSocket interface not available"); |
61 | 64 |
62 bool net_address_is_available = pp::NetAddress::IsAvailable(); | 65 bool net_address_is_available = pp::NetAddress::IsAvailable(); |
63 if (!net_address_is_available) | 66 if (!net_address_is_available) |
64 instance_->AppendError("PPB_NetAddress interface not available"); | 67 instance_->AppendError("PPB_NetAddress interface not available"); |
65 | 68 |
66 std::string host; | 69 std::string host; |
67 uint16_t port = 0; | 70 uint16_t port = 0; |
68 bool init_address = | 71 bool init_address = |
69 GetLocalHostPort(instance_->pp_instance(), &host, &port) && | 72 GetLocalHostPort(instance_->pp_instance(), &host, &port) && |
70 ResolveHost(instance_->pp_instance(), host, port, &address_); | 73 ResolveHost(instance_->pp_instance(), host, port, &address_); |
71 if (!init_address) | 74 if (!init_address) |
72 instance_->AppendError("Can't init address"); | 75 instance_->AppendError("Can't init address"); |
73 | 76 |
| 77 socket_interface_1_0_ = |
| 78 static_cast<const PPB_UDPSocket_1_0*>( |
| 79 pp::Module::Get()->GetBrowserInterface(PPB_UDPSOCKET_INTERFACE_1_0)); |
| 80 if (!socket_interface_1_0_) |
| 81 instance_->AppendError("PPB_UDPSocket_1_0 interface not available"); |
| 82 |
| 83 socket_interface_1_1_ = |
| 84 static_cast<const PPB_UDPSocket_1_1*>( |
| 85 pp::Module::Get()->GetBrowserInterface(PPB_UDPSOCKET_INTERFACE_1_1)); |
| 86 if (!socket_interface_1_1_) |
| 87 instance_->AppendError("PPB_UDPSocket_1_1 interface not available"); |
| 88 |
74 return tcp_socket_is_available && | 89 return tcp_socket_is_available && |
75 udp_socket_is_available && | 90 udp_socket_is_available && |
76 net_address_is_available && | 91 net_address_is_available && |
77 init_address && | 92 init_address && |
78 CheckTestingInterface() && | 93 CheckTestingInterface() && |
79 EnsureRunningOverHTTP(); | 94 EnsureRunningOverHTTP() && |
| 95 socket_interface_1_0_ != NULL && |
| 96 socket_interface_1_1_ != NULL; |
80 } | 97 } |
81 | 98 |
82 void TestUDPSocket::RunTests(const std::string& filter) { | 99 void TestUDPSocket::RunTests(const std::string& filter) { |
83 RUN_CALLBACK_TEST(TestUDPSocket, ReadWrite, filter); | 100 RUN_CALLBACK_TEST(TestUDPSocket, ReadWrite, filter); |
84 RUN_CALLBACK_TEST(TestUDPSocket, Broadcast, filter); | 101 RUN_CALLBACK_TEST(TestUDPSocket, Broadcast, filter); |
| 102 RUN_CALLBACK_TEST(TestUDPSocket, SetOption_1_0, filter); |
| 103 RUN_CALLBACK_TEST(TestUDPSocket, SetOption_1_1, filter); |
85 RUN_CALLBACK_TEST(TestUDPSocket, SetOption, filter); | 104 RUN_CALLBACK_TEST(TestUDPSocket, SetOption, filter); |
86 RUN_CALLBACK_TEST(TestUDPSocket, ParallelSend, filter); | 105 RUN_CALLBACK_TEST(TestUDPSocket, ParallelSend, filter); |
| 106 RUN_CALLBACK_TEST(TestUDPSocket, Multicast, filter); |
87 } | 107 } |
88 | 108 |
89 std::string TestUDPSocket::GetLocalAddress(pp::NetAddress* address) { | 109 std::string TestUDPSocket::GetLocalAddress(pp::NetAddress* address) { |
90 pp::TCPSocket socket(instance_); | 110 pp::TCPSocket socket(instance_); |
91 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); | 111 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); |
92 callback.WaitForResult(socket.Connect(address_, callback.GetCallback())); | 112 callback.WaitForResult(socket.Connect(address_, callback.GetCallback())); |
93 CHECK_CALLBACK_BEHAVIOR(callback); | 113 CHECK_CALLBACK_BEHAVIOR(callback); |
94 ASSERT_EQ(PP_OK, callback.result()); | 114 ASSERT_EQ(PP_OK, callback.result()); |
95 *address = socket.GetLocalAddress(); | 115 *address = socket.GetLocalAddress(); |
96 ASSERT_NE(0, address->pp_resource()); | 116 ASSERT_NE(0, address->pp_resource()); |
(...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
181 &str)); | 201 &str)); |
182 | 202 |
183 callback.WaitForResult(rv); | 203 callback.WaitForResult(rv); |
184 CHECK_CALLBACK_BEHAVIOR(callback); | 204 CHECK_CALLBACK_BEHAVIOR(callback); |
185 ASSERT_FALSE(callback.result() < 0); | 205 ASSERT_FALSE(callback.result() < 0); |
186 ASSERT_EQ(message.size(), static_cast<size_t>(callback.result())); | 206 ASSERT_EQ(message.size(), static_cast<size_t>(callback.result())); |
187 ASSERT_EQ(message, str); | 207 ASSERT_EQ(message, str); |
188 PASS(); | 208 PASS(); |
189 } | 209 } |
190 | 210 |
| 211 std::string TestUDPSocket::SetMulticastOptions(pp::UDPSocket* socket) { |
| 212 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); |
| 213 callback.WaitForResult(socket->SetOption( |
| 214 PP_UDPSOCKET_OPTION_MULTICAST_LOOP, pp::Var(true), |
| 215 callback.GetCallback())); |
| 216 CHECK_CALLBACK_BEHAVIOR(callback); |
| 217 ASSERT_EQ(PP_OK, callback.result()); |
| 218 |
| 219 callback.WaitForResult(socket->SetOption( |
| 220 PP_UDPSOCKET_OPTION_MULTICAST_TTL, pp::Var(1), callback.GetCallback())); |
| 221 CHECK_CALLBACK_BEHAVIOR(callback); |
| 222 ASSERT_EQ(PP_OK, callback.result()); |
| 223 |
| 224 PASS(); |
| 225 } |
| 226 |
191 std::string TestUDPSocket::TestReadWrite() { | 227 std::string TestUDPSocket::TestReadWrite() { |
192 pp::UDPSocket server_socket(instance_), client_socket(instance_); | 228 pp::UDPSocket server_socket(instance_), client_socket(instance_); |
193 pp::NetAddress server_address, client_address; | 229 pp::NetAddress server_address, client_address; |
194 | 230 |
195 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&server_socket, | 231 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&server_socket, |
196 &server_address)); | 232 &server_address)); |
197 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&client_socket, | 233 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&client_socket, |
198 &client_address)); | 234 &client_address)); |
199 const std::string message = "Simple message that will be sent via UDP"; | 235 const std::string message = "Simple message that will be sent via UDP"; |
200 pp::NetAddress recvfrom_address; | 236 pp::NetAddress recvfrom_address; |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
251 // |second_message| was also received by |server1|. | 287 // |second_message| was also received by |server1|. |
252 ASSERT_SUBTEST_SUCCESS(ReadSocket(&server1, &recvfrom_address, | 288 ASSERT_SUBTEST_SUCCESS(ReadSocket(&server1, &recvfrom_address, |
253 second_message.size(), &message)); | 289 second_message.size(), &message)); |
254 ASSERT_EQ(second_message, message); | 290 ASSERT_EQ(second_message, message); |
255 | 291 |
256 server1.Close(); | 292 server1.Close(); |
257 server2.Close(); | 293 server2.Close(); |
258 PASS(); | 294 PASS(); |
259 } | 295 } |
260 | 296 |
| 297 int32_t TestUDPSocket::SetOptionValue(UDPSocketSetOption func, |
| 298 PP_Resource socket, |
| 299 PP_UDPSocket_Option option, |
| 300 const PP_Var& value) { |
| 301 PP_TimeTicks start_time(NowInTimeTicks()); |
| 302 TestCompletionCallback cb(instance_->pp_instance(), callback_type()); |
| 303 cb.WaitForResult(func(socket, option, value, |
| 304 cb.GetCallback().pp_completion_callback())); |
| 305 |
| 306 // Expanded from CHECK_CALLBACK_BEHAVIOR macro. |
| 307 if (cb.failed()) { |
| 308 std::string msg = MakeFailureMessage(__FILE__, __LINE__, |
| 309 cb.errors().c_str()); |
| 310 |
| 311 instance_->LogTest("SetOptionValue", msg, start_time); |
| 312 return PP_ERROR_FAILED; |
| 313 } |
| 314 return cb.result(); |
| 315 } |
| 316 |
| 317 std::string TestUDPSocket::TestSetOption_1_0() { |
| 318 PP_Resource socket = socket_interface_1_0_->Create(instance_->pp_instance()); |
| 319 ASSERT_NE(0, socket); |
| 320 |
| 321 // Multicast options are not supported in interface 1.0. |
| 322 ASSERT_EQ(PP_ERROR_BADARGUMENT, |
| 323 SetOptionValue(socket_interface_1_0_->SetOption, |
| 324 socket, |
| 325 PP_UDPSOCKET_OPTION_MULTICAST_LOOP, |
| 326 PP_MakeBool(PP_TRUE))); |
| 327 |
| 328 ASSERT_EQ(PP_ERROR_BADARGUMENT, |
| 329 SetOptionValue(socket_interface_1_0_->SetOption, |
| 330 socket, |
| 331 PP_UDPSOCKET_OPTION_MULTICAST_TTL, |
| 332 PP_MakeInt32(1))); |
| 333 |
| 334 socket_interface_1_0_->Close(socket); |
| 335 pp::Module::Get()->core()->ReleaseResource(socket); |
| 336 |
| 337 PASS(); |
| 338 } |
| 339 |
| 340 std::string TestUDPSocket::TestSetOption_1_1() { |
| 341 PP_Resource socket = socket_interface_1_1_->Create(instance_->pp_instance()); |
| 342 ASSERT_NE(0, socket); |
| 343 |
| 344 // Multicast options are not supported in interface 1.1. |
| 345 ASSERT_EQ(PP_ERROR_BADARGUMENT, |
| 346 SetOptionValue(socket_interface_1_1_->SetOption, |
| 347 socket, |
| 348 PP_UDPSOCKET_OPTION_MULTICAST_LOOP, |
| 349 PP_MakeBool(PP_TRUE))); |
| 350 |
| 351 ASSERT_EQ(PP_ERROR_BADARGUMENT, |
| 352 SetOptionValue(socket_interface_1_1_->SetOption, |
| 353 socket, |
| 354 PP_UDPSOCKET_OPTION_MULTICAST_TTL, |
| 355 PP_MakeInt32(1))); |
| 356 |
| 357 socket_interface_1_1_->Close(socket); |
| 358 pp::Module::Get()->core()->ReleaseResource(socket); |
| 359 |
| 360 PASS(); |
| 361 } |
| 362 |
261 std::string TestUDPSocket::TestSetOption() { | 363 std::string TestUDPSocket::TestSetOption() { |
262 pp::UDPSocket socket(instance_); | 364 pp::UDPSocket socket(instance_); |
263 | 365 |
264 ASSERT_SUBTEST_SUCCESS(SetBroadcastOptions(&socket)); | 366 ASSERT_SUBTEST_SUCCESS(SetBroadcastOptions(&socket)); |
| 367 ASSERT_SUBTEST_SUCCESS(SetMulticastOptions(&socket)); |
265 | 368 |
266 // Try to pass incorrect option value's type. | 369 // Try to pass incorrect option value's type. |
267 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); | 370 TestCompletionCallback callback(instance_->pp_instance(), callback_type()); |
268 callback.WaitForResult(socket.SetOption( | 371 callback.WaitForResult(socket.SetOption( |
269 PP_UDPSOCKET_OPTION_ADDRESS_REUSE, pp::Var(1), callback.GetCallback())); | 372 PP_UDPSOCKET_OPTION_ADDRESS_REUSE, pp::Var(1), callback.GetCallback())); |
270 CHECK_CALLBACK_BEHAVIOR(callback); | 373 CHECK_CALLBACK_BEHAVIOR(callback); |
271 ASSERT_EQ(PP_ERROR_BADARGUMENT, callback.result()); | 374 ASSERT_EQ(PP_ERROR_BADARGUMENT, callback.result()); |
272 | 375 |
| 376 // Invalid multicast TTL values (less than 0 and greater than 255). |
| 377 callback.WaitForResult(socket.SetOption( |
| 378 PP_UDPSOCKET_OPTION_MULTICAST_TTL, pp::Var(-1), callback.GetCallback())); |
| 379 CHECK_CALLBACK_BEHAVIOR(callback); |
| 380 ASSERT_EQ(PP_ERROR_BADARGUMENT, callback.result()); |
| 381 |
| 382 callback.WaitForResult(socket.SetOption( |
| 383 PP_UDPSOCKET_OPTION_MULTICAST_TTL, pp::Var(256), callback.GetCallback())); |
| 384 CHECK_CALLBACK_BEHAVIOR(callback); |
| 385 ASSERT_EQ(PP_ERROR_BADARGUMENT, callback.result()); |
| 386 |
273 callback.WaitForResult(socket.SetOption( | 387 callback.WaitForResult(socket.SetOption( |
274 PP_UDPSOCKET_OPTION_BROADCAST, pp::Var(false), callback.GetCallback())); | 388 PP_UDPSOCKET_OPTION_BROADCAST, pp::Var(false), callback.GetCallback())); |
275 CHECK_CALLBACK_BEHAVIOR(callback); | 389 CHECK_CALLBACK_BEHAVIOR(callback); |
276 ASSERT_EQ(PP_OK, callback.result()); | 390 ASSERT_EQ(PP_OK, callback.result()); |
277 | 391 |
278 callback.WaitForResult(socket.SetOption( | 392 callback.WaitForResult(socket.SetOption( |
279 PP_UDPSOCKET_OPTION_SEND_BUFFER_SIZE, pp::Var(4096), | 393 PP_UDPSOCKET_OPTION_SEND_BUFFER_SIZE, pp::Var(4096), |
280 callback.GetCallback())); | 394 callback.GetCallback())); |
281 CHECK_CALLBACK_BEHAVIOR(callback); | 395 CHECK_CALLBACK_BEHAVIOR(callback); |
282 ASSERT_EQ(PP_OK, callback.result()); | 396 ASSERT_EQ(PP_OK, callback.result()); |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
381 ASSERT_SUBTEST_SUCCESS( | 495 ASSERT_SUBTEST_SUCCESS( |
382 ReadSocket(&server_socket, &recvfrom_address, message.size(), &str)); | 496 ReadSocket(&server_socket, &recvfrom_address, message.size(), &str)); |
383 ASSERT_EQ(message, str); | 497 ASSERT_EQ(message, str); |
384 } | 498 } |
385 | 499 |
386 server_socket.Close(); | 500 server_socket.Close(); |
387 client_socket.Close(); | 501 client_socket.Close(); |
388 | 502 |
389 PASS(); | 503 PASS(); |
390 } | 504 } |
| 505 |
| 506 std::string TestUDPSocket::TestMulticast() { |
| 507 pp::UDPSocket server1(instance_), server2(instance_); |
| 508 |
| 509 ASSERT_SUBTEST_SUCCESS(SetMulticastOptions(&server1)); |
| 510 ASSERT_SUBTEST_SUCCESS(SetMulticastOptions(&server2)); |
| 511 |
| 512 server1.Close(); |
| 513 server2.Close(); |
| 514 |
| 515 PASS(); |
| 516 } |
OLD | NEW |