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

Side by Side Diff: net/socket/tcp_server_socket_unittest.cc

Issue 8824006: Migrate net/socket/socket.h, net/socket/stream_socket.h to base::Bind(). (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebased Created 9 years 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 | « net/socket/tcp_client_socket_win.cc ('k') | net/socket/transport_client_socket_pool.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 (c) 2011 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2011 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 "net/socket/tcp_server_socket.h" 5 #include "net/socket/tcp_server_socket.h"
6 6
7 #include <string> 7 #include <string>
8 8
9 #include "base/compiler_specific.h" 9 #include "base/compiler_specific.h"
10 #include "base/memory/scoped_ptr.h" 10 #include "base/memory/scoped_ptr.h"
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after
70 local_address_.address(), local_address_.port()); 70 local_address_.address(), local_address_.port());
71 } 71 }
72 72
73 TCPServerSocket socket_; 73 TCPServerSocket socket_;
74 IPEndPoint local_address_; 74 IPEndPoint local_address_;
75 }; 75 };
76 76
77 TEST_F(TCPServerSocketTest, Accept) { 77 TEST_F(TCPServerSocketTest, Accept) {
78 ASSERT_NO_FATAL_FAILURE(SetUpIPv4()); 78 ASSERT_NO_FATAL_FAILURE(SetUpIPv4());
79 79
80 TestOldCompletionCallback connect_callback; 80 TestCompletionCallback connect_callback;
81 TCPClientSocket connecting_socket(local_address_list(), 81 TCPClientSocket connecting_socket(local_address_list(),
82 NULL, NetLog::Source()); 82 NULL, NetLog::Source());
83 connecting_socket.Connect(&connect_callback); 83 connecting_socket.Connect(connect_callback.callback());
84 84
85 TestCompletionCallback accept_callback; 85 TestCompletionCallback accept_callback;
86 scoped_ptr<StreamSocket> accepted_socket; 86 scoped_ptr<StreamSocket> accepted_socket;
87 int result = socket_.Accept(&accepted_socket, accept_callback.callback()); 87 int result = socket_.Accept(&accepted_socket, accept_callback.callback());
88 if (result == ERR_IO_PENDING) 88 if (result == ERR_IO_PENDING)
89 result = accept_callback.WaitForResult(); 89 result = accept_callback.WaitForResult();
90 ASSERT_EQ(OK, result); 90 ASSERT_EQ(OK, result);
91 91
92 ASSERT_TRUE(accepted_socket.get() != NULL); 92 ASSERT_TRUE(accepted_socket.get() != NULL);
93 93
94 // Both sockets should be on the loopback network interface. 94 // Both sockets should be on the loopback network interface.
95 EXPECT_EQ(GetPeerAddress(accepted_socket.get()).address(), 95 EXPECT_EQ(GetPeerAddress(accepted_socket.get()).address(),
96 local_address_.address()); 96 local_address_.address());
97 97
98 EXPECT_EQ(OK, connect_callback.WaitForResult()); 98 EXPECT_EQ(OK, connect_callback.WaitForResult());
99 } 99 }
100 100
101 // Test Accept() callback. 101 // Test Accept() callback.
102 TEST_F(TCPServerSocketTest, AcceptAsync) { 102 TEST_F(TCPServerSocketTest, AcceptAsync) {
103 ASSERT_NO_FATAL_FAILURE(SetUpIPv4()); 103 ASSERT_NO_FATAL_FAILURE(SetUpIPv4());
104 104
105 TestCompletionCallback accept_callback; 105 TestCompletionCallback accept_callback;
106 scoped_ptr<StreamSocket> accepted_socket; 106 scoped_ptr<StreamSocket> accepted_socket;
107 107
108 ASSERT_EQ(ERR_IO_PENDING, 108 ASSERT_EQ(ERR_IO_PENDING,
109 socket_.Accept(&accepted_socket, accept_callback.callback())); 109 socket_.Accept(&accepted_socket, accept_callback.callback()));
110 110
111 TestOldCompletionCallback connect_callback; 111 TestCompletionCallback connect_callback;
112 TCPClientSocket connecting_socket(local_address_list(), 112 TCPClientSocket connecting_socket(local_address_list(),
113 NULL, NetLog::Source()); 113 NULL, NetLog::Source());
114 connecting_socket.Connect(&connect_callback); 114 connecting_socket.Connect(connect_callback.callback());
115 115
116 EXPECT_EQ(OK, connect_callback.WaitForResult()); 116 EXPECT_EQ(OK, connect_callback.WaitForResult());
117 EXPECT_EQ(OK, accept_callback.WaitForResult()); 117 EXPECT_EQ(OK, accept_callback.WaitForResult());
118 118
119 EXPECT_TRUE(accepted_socket != NULL); 119 EXPECT_TRUE(accepted_socket != NULL);
120 120
121 // Both sockets should be on the loopback network interface. 121 // Both sockets should be on the loopback network interface.
122 EXPECT_EQ(GetPeerAddress(accepted_socket.get()).address(), 122 EXPECT_EQ(GetPeerAddress(accepted_socket.get()).address(),
123 local_address_.address()); 123 local_address_.address());
124 } 124 }
125 125
126 // Accept two connections simultaneously. 126 // Accept two connections simultaneously.
127 TEST_F(TCPServerSocketTest, Accept2Connections) { 127 TEST_F(TCPServerSocketTest, Accept2Connections) {
128 ASSERT_NO_FATAL_FAILURE(SetUpIPv4()); 128 ASSERT_NO_FATAL_FAILURE(SetUpIPv4());
129 129
130 TestCompletionCallback accept_callback; 130 TestCompletionCallback accept_callback;
131 scoped_ptr<StreamSocket> accepted_socket; 131 scoped_ptr<StreamSocket> accepted_socket;
132 132
133 ASSERT_EQ(ERR_IO_PENDING, 133 ASSERT_EQ(ERR_IO_PENDING,
134 socket_.Accept(&accepted_socket, accept_callback.callback())); 134 socket_.Accept(&accepted_socket, accept_callback.callback()));
135 135
136 TestOldCompletionCallback connect_callback; 136 TestCompletionCallback connect_callback;
137 TCPClientSocket connecting_socket(local_address_list(), 137 TCPClientSocket connecting_socket(local_address_list(),
138 NULL, NetLog::Source()); 138 NULL, NetLog::Source());
139 connecting_socket.Connect(&connect_callback); 139 connecting_socket.Connect(connect_callback.callback());
140 140
141 TestOldCompletionCallback connect_callback2; 141 TestCompletionCallback connect_callback2;
142 TCPClientSocket connecting_socket2(local_address_list(), 142 TCPClientSocket connecting_socket2(local_address_list(),
143 NULL, NetLog::Source()); 143 NULL, NetLog::Source());
144 connecting_socket2.Connect(&connect_callback2); 144 connecting_socket2.Connect(connect_callback2.callback());
145 145
146 EXPECT_EQ(OK, accept_callback.WaitForResult()); 146 EXPECT_EQ(OK, accept_callback.WaitForResult());
147 147
148 TestCompletionCallback accept_callback2; 148 TestCompletionCallback accept_callback2;
149 scoped_ptr<StreamSocket> accepted_socket2; 149 scoped_ptr<StreamSocket> accepted_socket2;
150 int result = socket_.Accept(&accepted_socket2, accept_callback2.callback()); 150 int result = socket_.Accept(&accepted_socket2, accept_callback2.callback());
151 if (result == ERR_IO_PENDING) 151 if (result == ERR_IO_PENDING)
152 result = accept_callback2.WaitForResult(); 152 result = accept_callback2.WaitForResult();
153 ASSERT_EQ(OK, result); 153 ASSERT_EQ(OK, result);
154 154
155 EXPECT_EQ(OK, connect_callback.WaitForResult()); 155 EXPECT_EQ(OK, connect_callback.WaitForResult());
156 156
157 EXPECT_TRUE(accepted_socket != NULL); 157 EXPECT_TRUE(accepted_socket != NULL);
158 EXPECT_TRUE(accepted_socket2 != NULL); 158 EXPECT_TRUE(accepted_socket2 != NULL);
159 EXPECT_NE(accepted_socket.get(), accepted_socket2.get()); 159 EXPECT_NE(accepted_socket.get(), accepted_socket2.get());
160 160
161 EXPECT_EQ(GetPeerAddress(accepted_socket.get()).address(), 161 EXPECT_EQ(GetPeerAddress(accepted_socket.get()).address(),
162 local_address_.address()); 162 local_address_.address());
163 EXPECT_EQ(GetPeerAddress(accepted_socket2.get()).address(), 163 EXPECT_EQ(GetPeerAddress(accepted_socket2.get()).address(),
164 local_address_.address()); 164 local_address_.address());
165 } 165 }
166 166
167 TEST_F(TCPServerSocketTest, AcceptIPv6) { 167 TEST_F(TCPServerSocketTest, AcceptIPv6) {
168 bool initialized = false; 168 bool initialized = false;
169 ASSERT_NO_FATAL_FAILURE(SetUpIPv6(&initialized)); 169 ASSERT_NO_FATAL_FAILURE(SetUpIPv6(&initialized));
170 if (!initialized) 170 if (!initialized)
171 return; 171 return;
172 172
173 TestOldCompletionCallback connect_callback; 173 TestCompletionCallback connect_callback;
174 TCPClientSocket connecting_socket(local_address_list(), 174 TCPClientSocket connecting_socket(local_address_list(),
175 NULL, NetLog::Source()); 175 NULL, NetLog::Source());
176 connecting_socket.Connect(&connect_callback); 176 connecting_socket.Connect(connect_callback.callback());
177 177
178 TestCompletionCallback accept_callback; 178 TestCompletionCallback accept_callback;
179 scoped_ptr<StreamSocket> accepted_socket; 179 scoped_ptr<StreamSocket> accepted_socket;
180 int result = socket_.Accept(&accepted_socket, accept_callback.callback()); 180 int result = socket_.Accept(&accepted_socket, accept_callback.callback());
181 if (result == ERR_IO_PENDING) 181 if (result == ERR_IO_PENDING)
182 result = accept_callback.WaitForResult(); 182 result = accept_callback.WaitForResult();
183 ASSERT_EQ(OK, result); 183 ASSERT_EQ(OK, result);
184 184
185 ASSERT_TRUE(accepted_socket.get() != NULL); 185 ASSERT_TRUE(accepted_socket.get() != NULL);
186 186
187 // Both sockets should be on the loopback network interface. 187 // Both sockets should be on the loopback network interface.
188 EXPECT_EQ(GetPeerAddress(accepted_socket.get()).address(), 188 EXPECT_EQ(GetPeerAddress(accepted_socket.get()).address(),
189 local_address_.address()); 189 local_address_.address());
190 190
191 EXPECT_EQ(OK, connect_callback.WaitForResult()); 191 EXPECT_EQ(OK, connect_callback.WaitForResult());
192 } 192 }
193 193
194 } // namespace 194 } // namespace
195 195
196 } // namespace net 196 } // namespace net
OLDNEW
« no previous file with comments | « net/socket/tcp_client_socket_win.cc ('k') | net/socket/transport_client_socket_pool.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698