Chromium Code Reviews| Index: remoting/protocol/fake_stream_socket.cc |
| diff --git a/remoting/protocol/fake_stream_socket.cc b/remoting/protocol/fake_stream_socket.cc |
| index fc7f31e52dfecaf6f35266a9992f4e6159c2b7dc..859d52f669a45c008483eff409d5077b1f419b7b 100644 |
| --- a/remoting/protocol/fake_stream_socket.cc |
| +++ b/remoting/protocol/fake_stream_socket.cc |
| @@ -31,6 +31,11 @@ FakeStreamSocket::FakeStreamSocket() |
| FakeStreamSocket::~FakeStreamSocket() { |
| EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| + if (peer_socket_.get()) { |
|
Wez
2015/06/22 15:49:07
nit: Remove .get()
Sergey Ulanov
2015/07/10 00:49:54
Done.
|
| + task_runner_->PostTask( |
| + FROM_HERE, base::Bind(&FakeStreamSocket::AppendReadError, peer_socket_, |
| + net::ERR_CONNECTION_CLOSED)); |
| + } |
| } |
| void FakeStreamSocket::AppendInputData(const std::string& data) { |
| @@ -159,97 +164,6 @@ int FakeStreamSocket::SetSendBufferSize(int32 size) { |
| return net::ERR_NOT_IMPLEMENTED; |
| } |
| -int FakeStreamSocket::Connect(const net::CompletionCallback& callback) { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - return net::OK; |
| -} |
| - |
| -void FakeStreamSocket::Disconnect() { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - |
| - if (peer_socket_.get()) { |
| - task_runner_->PostTask( |
| - FROM_HERE, |
| - base::Bind(&FakeStreamSocket::AppendReadError, |
| - peer_socket_, |
| - net::ERR_CONNECTION_CLOSED)); |
| - } |
| - peer_socket_.reset(); |
| -} |
| - |
| -bool FakeStreamSocket::IsConnected() const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - return true; |
| -} |
| - |
| -bool FakeStreamSocket::IsConnectedAndIdle() const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - NOTIMPLEMENTED(); |
| - return false; |
| -} |
| - |
| -int FakeStreamSocket::GetPeerAddress(net::IPEndPoint* address) const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - net::IPAddressNumber ip(net::kIPv4AddressSize); |
| - *address = net::IPEndPoint(ip, 0); |
| - return net::OK; |
| -} |
| - |
| -int FakeStreamSocket::GetLocalAddress(net::IPEndPoint* address) const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - NOTIMPLEMENTED(); |
| - return net::ERR_NOT_IMPLEMENTED; |
| -} |
| - |
| -const net::BoundNetLog& FakeStreamSocket::NetLog() const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - return net_log_; |
| -} |
| - |
| -void FakeStreamSocket::SetSubresourceSpeculation() { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - NOTIMPLEMENTED(); |
| -} |
| - |
| -void FakeStreamSocket::SetOmniboxSpeculation() { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - NOTIMPLEMENTED(); |
| -} |
| - |
| -bool FakeStreamSocket::WasEverUsed() const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - NOTIMPLEMENTED(); |
| - return true; |
| -} |
| - |
| -bool FakeStreamSocket::UsingTCPFastOpen() const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - NOTIMPLEMENTED(); |
| - return true; |
| -} |
| - |
| -bool FakeStreamSocket::WasNpnNegotiated() const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - return false; |
| -} |
| - |
| -net::NextProto FakeStreamSocket::GetNegotiatedProtocol() const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - NOTIMPLEMENTED(); |
| - return net::kProtoUnknown; |
| -} |
| - |
| -bool FakeStreamSocket::GetSSLInfo(net::SSLInfo* ssl_info) { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - return false; |
| -} |
| - |
| -void FakeStreamSocket::GetConnectionAttempts( |
| - net::ConnectionAttempts* out) const { |
| - EXPECT_TRUE(task_runner_->BelongsToCurrentThread()); |
| - out->clear(); |
| -} |
| - |
| FakeStreamChannelFactory::FakeStreamChannelFactory() |
| : task_runner_(base::ThreadTaskRunnerHandle::Get()), |
| asynchronous_create_(false), |