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), |