| 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 |