Index: net/socket/tcp_socket_unittest.cc |
diff --git a/net/socket/tcp_socket_unittest.cc b/net/socket/tcp_socket_unittest.cc |
index 198138860fc9d1a1df53ea2e7e3ae943c906cb49..a623bfbc117c28f923545486b0df0d19f9cabfb5 100644 |
--- a/net/socket/tcp_socket_unittest.cc |
+++ b/net/socket/tcp_socket_unittest.cc |
@@ -27,8 +27,7 @@ const int kListenBacklog = 5; |
class TCPSocketTest : public PlatformTest { |
protected: |
- TCPSocketTest() : socket_(NULL, NetLog::Source()) { |
- } |
+ TCPSocketTest() : socket_(NULL, NetLog::Source()) {} |
void SetUpListenIPv4() { |
IPEndPoint address; |
@@ -46,10 +45,9 @@ class TCPSocketTest : public PlatformTest { |
ParseAddress("::1", 0, &address); |
if (socket_.Open(ADDRESS_FAMILY_IPV6) != OK || |
- socket_.Bind(address) != OK || |
- socket_.Listen(kListenBacklog) != OK) { |
+ socket_.Bind(address) != OK || socket_.Listen(kListenBacklog) != OK) { |
LOG(ERROR) << "Failed to listen on ::1 - probably because IPv6 is " |
- "disabled. Skipping the test"; |
+ "disabled. Skipping the test"; |
return; |
} |
ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); |
@@ -68,13 +66,14 @@ class TCPSocketTest : public PlatformTest { |
TestCompletionCallback accept_callback; |
scoped_ptr<TCPSocket> accepted_socket; |
IPEndPoint accepted_address; |
- ASSERT_EQ(ERR_IO_PENDING, |
- socket_.Accept(&accepted_socket, &accepted_address, |
- accept_callback.callback())); |
+ ASSERT_EQ( |
+ ERR_IO_PENDING, |
+ socket_.Accept( |
+ &accepted_socket, &accepted_address, accept_callback.callback())); |
TestCompletionCallback connect_callback; |
- TCPClientSocket connecting_socket(local_address_list(), |
- NULL, NetLog::Source()); |
+ TCPClientSocket connecting_socket( |
+ local_address_list(), NULL, NetLog::Source()); |
connecting_socket.Connect(connect_callback.callback()); |
EXPECT_EQ(OK, connect_callback.WaitForResult()); |
@@ -86,9 +85,7 @@ class TCPSocketTest : public PlatformTest { |
EXPECT_EQ(accepted_address.address(), local_address_.address()); |
} |
- AddressList local_address_list() const { |
- return AddressList(local_address_); |
- } |
+ AddressList local_address_list() const { return AddressList(local_address_); } |
TCPSocket socket_; |
IPEndPoint local_address_; |
@@ -101,15 +98,15 @@ TEST_F(TCPSocketTest, Accept) { |
TestCompletionCallback connect_callback; |
// TODO(yzshen): Switch to use TCPSocket when it supports client socket |
// operations. |
- TCPClientSocket connecting_socket(local_address_list(), |
- NULL, NetLog::Source()); |
+ TCPClientSocket connecting_socket( |
+ local_address_list(), NULL, NetLog::Source()); |
connecting_socket.Connect(connect_callback.callback()); |
TestCompletionCallback accept_callback; |
scoped_ptr<TCPSocket> accepted_socket; |
IPEndPoint accepted_address; |
- int result = socket_.Accept(&accepted_socket, &accepted_address, |
- accept_callback.callback()); |
+ int result = socket_.Accept( |
+ &accepted_socket, &accepted_address, accept_callback.callback()); |
if (result == ERR_IO_PENDING) |
result = accept_callback.WaitForResult(); |
ASSERT_EQ(OK, result); |
@@ -156,18 +153,19 @@ TEST_F(TCPSocketTest, Accept2Connections) { |
scoped_ptr<TCPSocket> accepted_socket; |
IPEndPoint accepted_address; |
- ASSERT_EQ(ERR_IO_PENDING, |
- socket_.Accept(&accepted_socket, &accepted_address, |
- accept_callback.callback())); |
+ ASSERT_EQ( |
+ ERR_IO_PENDING, |
+ socket_.Accept( |
+ &accepted_socket, &accepted_address, accept_callback.callback())); |
TestCompletionCallback connect_callback; |
- TCPClientSocket connecting_socket(local_address_list(), |
- NULL, NetLog::Source()); |
+ TCPClientSocket connecting_socket( |
+ local_address_list(), NULL, NetLog::Source()); |
connecting_socket.Connect(connect_callback.callback()); |
TestCompletionCallback connect_callback2; |
- TCPClientSocket connecting_socket2(local_address_list(), |
- NULL, NetLog::Source()); |
+ TCPClientSocket connecting_socket2( |
+ local_address_list(), NULL, NetLog::Source()); |
connecting_socket2.Connect(connect_callback2.callback()); |
EXPECT_EQ(OK, accept_callback.WaitForResult()); |
@@ -176,8 +174,8 @@ TEST_F(TCPSocketTest, Accept2Connections) { |
scoped_ptr<TCPSocket> accepted_socket2; |
IPEndPoint accepted_address2; |
- int result = socket_.Accept(&accepted_socket2, &accepted_address2, |
- accept_callback2.callback()); |
+ int result = socket_.Accept( |
+ &accepted_socket2, &accepted_address2, accept_callback2.callback()); |
if (result == ERR_IO_PENDING) |
result = accept_callback2.WaitForResult(); |
ASSERT_EQ(OK, result); |
@@ -201,15 +199,15 @@ TEST_F(TCPSocketTest, AcceptIPv6) { |
return; |
TestCompletionCallback connect_callback; |
- TCPClientSocket connecting_socket(local_address_list(), |
- NULL, NetLog::Source()); |
+ TCPClientSocket connecting_socket( |
+ local_address_list(), NULL, NetLog::Source()); |
connecting_socket.Connect(connect_callback.callback()); |
TestCompletionCallback accept_callback; |
scoped_ptr<TCPSocket> accepted_socket; |
IPEndPoint accepted_address; |
- int result = socket_.Accept(&accepted_socket, &accepted_address, |
- accept_callback.callback()); |
+ int result = socket_.Accept( |
+ &accepted_socket, &accepted_address, accept_callback.callback()); |
if (result == ERR_IO_PENDING) |
result = accept_callback.WaitForResult(); |
ASSERT_EQ(OK, result); |
@@ -234,8 +232,8 @@ TEST_F(TCPSocketTest, ReadWrite) { |
TestCompletionCallback accept_callback; |
scoped_ptr<TCPSocket> accepted_socket; |
IPEndPoint accepted_address; |
- result = socket_.Accept(&accepted_socket, &accepted_address, |
- accept_callback.callback()); |
+ result = socket_.Accept( |
+ &accepted_socket, &accepted_address, accept_callback.callback()); |
ASSERT_EQ(OK, accept_callback.GetResult(result)); |
ASSERT_TRUE(accepted_socket.get()); |
@@ -252,7 +250,8 @@ TEST_F(TCPSocketTest, ReadWrite) { |
while (bytes_written < message.size()) { |
scoped_refptr<IOBufferWithSize> write_buffer( |
new IOBufferWithSize(message.size() - bytes_written)); |
- memmove(write_buffer->data(), message.data() + bytes_written, |
+ memmove(write_buffer->data(), |
+ message.data() + bytes_written, |
message.size() - bytes_written); |
TestCompletionCallback write_callback; |