| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/transport_client_socket_pool.h" | 5 #include "net/socket/transport_client_socket_pool.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/callback.h" | 9 #include "base/callback.h" |
| 10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
| (...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 138 | 138 |
| 139 // Socket implementation. | 139 // Socket implementation. |
| 140 virtual int Read(IOBuffer* buf, int buf_len, | 140 virtual int Read(IOBuffer* buf, int buf_len, |
| 141 const CompletionCallback& callback) OVERRIDE { | 141 const CompletionCallback& callback) OVERRIDE { |
| 142 return ERR_FAILED; | 142 return ERR_FAILED; |
| 143 } | 143 } |
| 144 virtual int Write(IOBuffer* buf, int buf_len, | 144 virtual int Write(IOBuffer* buf, int buf_len, |
| 145 const CompletionCallback& callback) OVERRIDE { | 145 const CompletionCallback& callback) OVERRIDE { |
| 146 return ERR_FAILED; | 146 return ERR_FAILED; |
| 147 } | 147 } |
| 148 virtual bool SetReceiveBufferSize(int32 size) OVERRIDE { return true; } | 148 virtual int SetReceiveBufferSize(int32 size) OVERRIDE { return OK; } |
| 149 virtual bool SetSendBufferSize(int32 size) OVERRIDE { return true; } | 149 virtual int SetSendBufferSize(int32 size) OVERRIDE { return OK; } |
| 150 | 150 |
| 151 private: | 151 private: |
| 152 bool connected_; | 152 bool connected_; |
| 153 const AddressList addrlist_; | 153 const AddressList addrlist_; |
| 154 BoundNetLog net_log_; | 154 BoundNetLog net_log_; |
| 155 | 155 |
| 156 DISALLOW_COPY_AND_ASSIGN(MockClientSocket); | 156 DISALLOW_COPY_AND_ASSIGN(MockClientSocket); |
| 157 }; | 157 }; |
| 158 | 158 |
| 159 class MockFailingClientSocket : public StreamSocket { | 159 class MockFailingClientSocket : public StreamSocket { |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 203 // Socket implementation. | 203 // Socket implementation. |
| 204 virtual int Read(IOBuffer* buf, int buf_len, | 204 virtual int Read(IOBuffer* buf, int buf_len, |
| 205 const CompletionCallback& callback) OVERRIDE { | 205 const CompletionCallback& callback) OVERRIDE { |
| 206 return ERR_FAILED; | 206 return ERR_FAILED; |
| 207 } | 207 } |
| 208 | 208 |
| 209 virtual int Write(IOBuffer* buf, int buf_len, | 209 virtual int Write(IOBuffer* buf, int buf_len, |
| 210 const CompletionCallback& callback) OVERRIDE { | 210 const CompletionCallback& callback) OVERRIDE { |
| 211 return ERR_FAILED; | 211 return ERR_FAILED; |
| 212 } | 212 } |
| 213 virtual bool SetReceiveBufferSize(int32 size) OVERRIDE { return true; } | 213 virtual int SetReceiveBufferSize(int32 size) OVERRIDE { return OK; } |
| 214 virtual bool SetSendBufferSize(int32 size) OVERRIDE { return true; } | 214 virtual int SetSendBufferSize(int32 size) OVERRIDE { return OK; } |
| 215 | 215 |
| 216 private: | 216 private: |
| 217 const AddressList addrlist_; | 217 const AddressList addrlist_; |
| 218 BoundNetLog net_log_; | 218 BoundNetLog net_log_; |
| 219 | 219 |
| 220 DISALLOW_COPY_AND_ASSIGN(MockFailingClientSocket); | 220 DISALLOW_COPY_AND_ASSIGN(MockFailingClientSocket); |
| 221 }; | 221 }; |
| 222 | 222 |
| 223 class MockPendingClientSocket : public StreamSocket { | 223 class MockPendingClientSocket : public StreamSocket { |
| 224 public: | 224 public: |
| (...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 292 // Socket implementation. | 292 // Socket implementation. |
| 293 virtual int Read(IOBuffer* buf, int buf_len, | 293 virtual int Read(IOBuffer* buf, int buf_len, |
| 294 const CompletionCallback& callback) OVERRIDE { | 294 const CompletionCallback& callback) OVERRIDE { |
| 295 return ERR_FAILED; | 295 return ERR_FAILED; |
| 296 } | 296 } |
| 297 | 297 |
| 298 virtual int Write(IOBuffer* buf, int buf_len, | 298 virtual int Write(IOBuffer* buf, int buf_len, |
| 299 const CompletionCallback& callback) OVERRIDE { | 299 const CompletionCallback& callback) OVERRIDE { |
| 300 return ERR_FAILED; | 300 return ERR_FAILED; |
| 301 } | 301 } |
| 302 virtual bool SetReceiveBufferSize(int32 size) OVERRIDE { return true; } | 302 virtual int SetReceiveBufferSize(int32 size) OVERRIDE { return OK; } |
| 303 virtual bool SetSendBufferSize(int32 size) OVERRIDE { return true; } | 303 virtual int SetSendBufferSize(int32 size) OVERRIDE { return OK; } |
| 304 | 304 |
| 305 private: | 305 private: |
| 306 void DoCallback(const CompletionCallback& callback) { | 306 void DoCallback(const CompletionCallback& callback) { |
| 307 if (should_stall_) | 307 if (should_stall_) |
| 308 return; | 308 return; |
| 309 | 309 |
| 310 if (should_connect_) { | 310 if (should_connect_) { |
| 311 is_connected_ = true; | 311 is_connected_ = true; |
| 312 callback.Run(OK); | 312 callback.Run(OK); |
| 313 } else { | 313 } else { |
| (...skipping 1052 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1366 EXPECT_TRUE(handle.socket()); | 1366 EXPECT_TRUE(handle.socket()); |
| 1367 IPEndPoint endpoint; | 1367 IPEndPoint endpoint; |
| 1368 handle.socket()->GetLocalAddress(&endpoint); | 1368 handle.socket()->GetLocalAddress(&endpoint); |
| 1369 EXPECT_EQ(kIPv4AddressSize, endpoint.address().size()); | 1369 EXPECT_EQ(kIPv4AddressSize, endpoint.address().size()); |
| 1370 EXPECT_EQ(1, client_socket_factory_.allocation_count()); | 1370 EXPECT_EQ(1, client_socket_factory_.allocation_count()); |
| 1371 } | 1371 } |
| 1372 | 1372 |
| 1373 } // namespace | 1373 } // namespace |
| 1374 | 1374 |
| 1375 } // namespace net | 1375 } // namespace net |
| OLD | NEW |