Index: net/udp/udp_socket_unittest.cc |
diff --git a/net/udp/udp_socket_unittest.cc b/net/udp/udp_socket_unittest.cc |
index bfb1ec5a04adb6d4ff0adfccaea4093af3d5b2ec..21ac91811f03fb5a7b96194af2b46e3815e82327 100644 |
--- a/net/udp/udp_socket_unittest.cc |
+++ b/net/udp/udp_socket_unittest.cc |
@@ -21,6 +21,7 @@ |
#include "net/base/net_errors.h" |
#include "net/base/test_completion_callback.h" |
#include "net/log/net_log_event_type.h" |
+#include "net/log/net_log_source.h" |
#include "net/log/test_net_log.h" |
#include "net/log/test_net_log_entry.h" |
#include "net/log/test_net_log_util.h" |
@@ -170,7 +171,7 @@ void UDPSocketTest::ConnectTest(bool use_nonblocking_io) { |
CreateUDPAddress("127.0.0.1", kPort, &bind_address); |
TestNetLog server_log; |
std::unique_ptr<UDPServerSocket> server( |
- new UDPServerSocket(&server_log, NetLog::Source())); |
+ new UDPServerSocket(&server_log, NetLogSource())); |
if (use_nonblocking_io) |
server->UseNonBlockingIO(); |
server->AllowAddressReuse(); |
@@ -183,7 +184,7 @@ void UDPSocketTest::ConnectTest(bool use_nonblocking_io) { |
TestNetLog client_log; |
std::unique_ptr<UDPClientSocket> client( |
new UDPClientSocket(DatagramSocket::DEFAULT_BIND, RandIntCallback(), |
- &client_log, NetLog::Source())); |
+ &client_log, NetLogSource())); |
if (use_nonblocking_io) |
client->UseNonBlockingIO(); |
@@ -301,9 +302,9 @@ TEST_F(UDPSocketTest, Broadcast) { |
TestNetLog server1_log, server2_log; |
std::unique_ptr<UDPServerSocket> server1( |
- new UDPServerSocket(&server1_log, NetLog::Source())); |
+ new UDPServerSocket(&server1_log, NetLogSource())); |
std::unique_ptr<UDPServerSocket> server2( |
- new UDPServerSocket(&server2_log, NetLog::Source())); |
+ new UDPServerSocket(&server2_log, NetLogSource())); |
server1->AllowAddressReuse(); |
server1->AllowBroadcast(); |
server2->AllowAddressReuse(); |
@@ -371,11 +372,8 @@ TEST_F(UDPSocketTest, ConnectRandomBind) { |
// Create and connect sockets and save port numbers. |
std::deque<int> used_ports; |
for (int i = 0; i < kBindRetries; ++i) { |
- UDPClientSocket* socket = |
- new UDPClientSocket(DatagramSocket::DEFAULT_BIND, |
- RandIntCallback(), |
- NULL, |
- NetLog::Source()); |
+ UDPClientSocket* socket = new UDPClientSocket( |
+ DatagramSocket::DEFAULT_BIND, RandIntCallback(), NULL, NetLogSource()); |
sockets.push_back(base::WrapUnique(socket)); |
EXPECT_THAT(socket->Connect(peer_address), IsOk()); |
@@ -393,7 +391,7 @@ TEST_F(UDPSocketTest, ConnectRandomBind) { |
// Create a socket with random binding policy and connect. |
std::unique_ptr<UDPClientSocket> test_socket(new UDPClientSocket( |
- DatagramSocket::RANDOM_BIND, rand_int_cb, NULL, NetLog::Source())); |
+ DatagramSocket::RANDOM_BIND, rand_int_cb, NULL, NetLogSource())); |
EXPECT_THAT(test_socket->Connect(peer_address), IsOk()); |
// Make sure that the last port number in the |used_ports| was used. |
@@ -421,7 +419,7 @@ TEST_F(UDPSocketTest, MAYBE_ConnectFail) { |
std::unique_ptr<UDPSocket> socket(new UDPSocket(DatagramSocket::RANDOM_BIND, |
base::Bind(&PrivilegedRand), |
- NULL, NetLog::Source())); |
+ NULL, NetLogSource())); |
int rv = socket->Open(peer_address.GetFamily()); |
EXPECT_THAT(rv, IsOk()); |
rv = socket->Connect(peer_address); |
@@ -448,14 +446,14 @@ TEST_F(UDPSocketTest, VerifyConnectBindsAddr) { |
// Setup the first server to listen. |
IPEndPoint bind_address; |
CreateUDPAddress("127.0.0.1", kPort1, &bind_address); |
- UDPServerSocket server1(NULL, NetLog::Source()); |
+ UDPServerSocket server1(NULL, NetLogSource()); |
server1.AllowAddressReuse(); |
int rv = server1.Listen(bind_address); |
ASSERT_THAT(rv, IsOk()); |
// Setup the second server to listen. |
CreateUDPAddress("127.0.0.1", kPort2, &bind_address); |
- UDPServerSocket server2(NULL, NetLog::Source()); |
+ UDPServerSocket server2(NULL, NetLogSource()); |
server2.AllowAddressReuse(); |
rv = server2.Listen(bind_address); |
ASSERT_THAT(rv, IsOk()); |
@@ -463,10 +461,8 @@ TEST_F(UDPSocketTest, VerifyConnectBindsAddr) { |
// Setup the client, connected to server 1. |
IPEndPoint server_address; |
CreateUDPAddress("127.0.0.1", kPort1, &server_address); |
- UDPClientSocket client(DatagramSocket::DEFAULT_BIND, |
- RandIntCallback(), |
- NULL, |
- NetLog::Source()); |
+ UDPClientSocket client(DatagramSocket::DEFAULT_BIND, RandIntCallback(), NULL, |
+ NetLogSource()); |
rv = client.Connect(server_address); |
EXPECT_THAT(rv, IsOk()); |
@@ -523,10 +519,8 @@ TEST_F(UDPSocketTest, ClientGetLocalPeerAddresses) { |
EXPECT_TRUE(ip_address.AssignFromIPLiteral(tests[i].local_address)); |
IPEndPoint local_address(ip_address, 80); |
- UDPClientSocket client(DatagramSocket::DEFAULT_BIND, |
- RandIntCallback(), |
- NULL, |
- NetLog::Source()); |
+ UDPClientSocket client(DatagramSocket::DEFAULT_BIND, RandIntCallback(), |
+ NULL, NetLogSource()); |
int rv = client.Connect(remote_address); |
if (tests[i].may_fail && rv == ERR_ADDRESS_UNREACHABLE) { |
// Connect() may return ERR_ADDRESS_UNREACHABLE for IPv6 |
@@ -557,7 +551,7 @@ TEST_F(UDPSocketTest, ClientGetLocalPeerAddresses) { |
TEST_F(UDPSocketTest, ServerGetLocalAddress) { |
IPEndPoint bind_address; |
CreateUDPAddress("127.0.0.1", 0, &bind_address); |
- UDPServerSocket server(NULL, NetLog::Source()); |
+ UDPServerSocket server(NULL, NetLogSource()); |
int rv = server.Listen(bind_address); |
EXPECT_THAT(rv, IsOk()); |
@@ -573,7 +567,7 @@ TEST_F(UDPSocketTest, ServerGetLocalAddress) { |
TEST_F(UDPSocketTest, ServerGetPeerAddress) { |
IPEndPoint bind_address; |
CreateUDPAddress("127.0.0.1", 0, &bind_address); |
- UDPServerSocket server(NULL, NetLog::Source()); |
+ UDPServerSocket server(NULL, NetLogSource()); |
int rv = server.Listen(bind_address); |
EXPECT_THAT(rv, IsOk()); |
@@ -586,7 +580,7 @@ TEST_F(UDPSocketTest, ClientSetDoNotFragment) { |
for (std::string ip : {"127.0.0.1", "::1"}) { |
LOG(INFO) << "ip: " << ip; |
UDPClientSocket client(DatagramSocket::DEFAULT_BIND, RandIntCallback(), |
- nullptr, NetLog::Source()); |
+ nullptr, NetLogSource()); |
IPAddress ip_address; |
EXPECT_TRUE(ip_address.AssignFromIPLiteral(ip)); |
IPEndPoint remote_address(ip_address, 80); |
@@ -610,7 +604,7 @@ TEST_F(UDPSocketTest, ServerSetDoNotFragment) { |
LOG(INFO) << "ip: " << ip; |
IPEndPoint bind_address; |
CreateUDPAddress(ip, 0, &bind_address); |
- UDPServerSocket server(nullptr, NetLog::Source()); |
+ UDPServerSocket server(nullptr, NetLogSource()); |
int rv = server.Listen(bind_address); |
// May fail on IPv6 is IPv6 is not configure |
if (bind_address.address().IsIPv6() && rv == ERR_ADDRESS_INVALID) |
@@ -630,7 +624,7 @@ TEST_F(UDPSocketTest, ServerSetDoNotFragment) { |
TEST_F(UDPSocketTest, CloseWithPendingRead) { |
IPEndPoint bind_address; |
CreateUDPAddress("127.0.0.1", 0, &bind_address); |
- UDPServerSocket server(NULL, NetLog::Source()); |
+ UDPServerSocket server(NULL, NetLogSource()); |
int rv = server.Listen(bind_address); |
EXPECT_THAT(rv, IsOk()); |
@@ -662,10 +656,8 @@ TEST_F(UDPSocketTest, MAYBE_JoinMulticastGroup) { |
IPAddress group_ip; |
EXPECT_TRUE(group_ip.AssignFromIPLiteral(kGroup)); |
- UDPSocket socket(DatagramSocket::DEFAULT_BIND, |
- RandIntCallback(), |
- NULL, |
- NetLog::Source()); |
+ UDPSocket socket(DatagramSocket::DEFAULT_BIND, RandIntCallback(), NULL, |
+ NetLogSource()); |
EXPECT_THAT(socket.Open(bind_address.GetFamily()), IsOk()); |
EXPECT_THAT(socket.Bind(bind_address), IsOk()); |
EXPECT_THAT(socket.JoinGroup(group_ip), IsOk()); |
@@ -683,10 +675,8 @@ TEST_F(UDPSocketTest, MulticastOptions) { |
IPEndPoint bind_address; |
CreateUDPAddress("0.0.0.0", kPort, &bind_address); |
- UDPSocket socket(DatagramSocket::DEFAULT_BIND, |
- RandIntCallback(), |
- NULL, |
- NetLog::Source()); |
+ UDPSocket socket(DatagramSocket::DEFAULT_BIND, RandIntCallback(), NULL, |
+ NetLogSource()); |
// Before binding. |
EXPECT_THAT(socket.SetMulticastLoopbackMode(false), IsOk()); |
EXPECT_THAT(socket.SetMulticastLoopbackMode(true), IsOk()); |
@@ -710,10 +700,8 @@ TEST_F(UDPSocketTest, MulticastOptions) { |
TEST_F(UDPSocketTest, SetDSCP) { |
// Setup the server to listen. |
IPEndPoint bind_address; |
- UDPSocket client(DatagramSocket::DEFAULT_BIND, |
- RandIntCallback(), |
- NULL, |
- NetLog::Source()); |
+ UDPSocket client(DatagramSocket::DEFAULT_BIND, RandIntCallback(), NULL, |
+ NetLogSource()); |
// We need a real IP, but we won't actually send anything to it. |
CreateUDPAddress("8.8.8.8", 9999, &bind_address); |
int rv = client.Open(bind_address.GetFamily()); |
@@ -738,7 +726,7 @@ TEST_F(UDPSocketTest, SetDSCP) { |
TEST_F(UDPSocketTest, TestBindToNetwork) { |
UDPSocket socket(DatagramSocket::RANDOM_BIND, base::Bind(&PrivilegedRand), |
- NULL, NetLog::Source()); |
+ NULL, NetLogSource()); |
ASSERT_EQ(OK, socket.Open(ADDRESS_FAMILY_IPV4)); |
// Test unsuccessful binding, by attempting to bind to a bogus NetworkHandle. |
int rv = socket.BindToNetwork(65536); |
@@ -867,10 +855,8 @@ TEST_F(UDPSocketTest, SetDSCPFake) { |
IPEndPoint bind_address; |
// We need a real IP, but we won't actually send anything to it. |
CreateUDPAddress("8.8.8.8", 9999, &bind_address); |
- UDPSocket client(DatagramSocket::DEFAULT_BIND, |
- RandIntCallback(), |
- NULL, |
- NetLog::Source()); |
+ UDPSocket client(DatagramSocket::DEFAULT_BIND, RandIntCallback(), NULL, |
+ NetLogSource()); |
int rv = client.SetDiffServCodePoint(DSCP_AF41); |
EXPECT_THAT(rv, IsError(ERR_SOCKET_NOT_CONNECTED)); |