Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(145)

Side by Side Diff: ppapi/tests/test_udp_socket.cc

Issue 17419008: Move PPB_NetAddress out of dev. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « ppapi/tests/test_udp_socket.h ('k') | ppapi/tests/test_utils.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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 }
OLDNEW
« no previous file with comments | « ppapi/tests/test_udp_socket.h ('k') | ppapi/tests/test_utils.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698