remoting/protocol/fake_stream_socket.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "remoting/protocol/fake_stream_socket.h"
   6
   7 #include "base/bind.h"
   8 #include "base/callback_helpers.h"
   9 #include "base/single_thread_task_runner.h"
  10 #include "base/thread_task_runner_handle.h"
  11 #include "net/base/address_list.h"
  12 #include "net/base/io_buffer.h"
  13 #include "net/base/net_errors.h"
  14 #include "net/base/net_util.h"
  15 #include "testing/gtest/include/gtest/gtest.h"
  16
  17 namespace remoting {
  18 namespace protocol {
  19
  20 FakeStreamSocket::FakeStreamSocket()
  21     : async_write_(false),
  22       write_pending_(false),
  23       write_limit_(0),
  24       next_write_error_(net::OK),
  25       next_read_error_(net::OK),
  26       read_buffer_size_(0),
  27       input_pos_(0),
  28       task_runner_(base::ThreadTaskRunnerHandle::Get()),
  29       weak_factory_(this) {
  30 }
  31
  32 FakeStreamSocket::~FakeStreamSocket() {
  33   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
  34 }
  35
  36 void FakeStreamSocket::AppendInputData(const std::string& data) {
  37   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
  38   input_data_.insert(input_data_.end(), data.begin(), data.end());
  39   // Complete pending read if any.
  40   if (!read_callback_.is_null()) {
  41     int result = std::min(read_buffer_size_,
  42                           static_cast<int>(input_data_.size() - input_pos_));
  43     EXPECT_GT(result, 0);
  44     memcpy(read_buffer_->data(),
  45            &(*input_data_.begin()) + input_pos_, result);
  46     input_pos_ += result;
  47     read_buffer_ = nullptr;
  48
  49     base::ResetAndReturn(&read_callback_).Run(result);
  50   }
  51 }
  52
  53 void FakeStreamSocket::AppendReadError(int error) {
  54   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
  55   // Complete pending read if any.
  56   if (!read_callback_.is_null()) {
  57     base::ResetAndReturn(&read_callback_).Run(error);
  58   } else {
  59     next_read_error_ = error;
  60   }
  61 }
  62
  63 void FakeStreamSocket::PairWith(FakeStreamSocket* peer_socket) {
  64   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
  65   peer_socket_ = peer_socket->GetWeakPtr();
  66   peer_socket->peer_socket_ = GetWeakPtr();
  67 }
  68
  69 base::WeakPtr<FakeStreamSocket> FakeStreamSocket::GetWeakPtr() {
  70   return weak_factory_.GetWeakPtr();
  71 }
  72
  73 int FakeStreamSocket::Read(net::IOBuffer* buf, int buf_len,
  74                            const net::CompletionCallback& callback) {
  75   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
  76
  77   if (input_pos_ < static_cast<int>(input_data_.size())) {
  78     int result = std::min(buf_len,
  79                           static_cast<int>(input_data_.size()) - input_pos_);
  80     memcpy(buf->data(), &(*input_data_.begin()) + input_pos_, result);
  81     input_pos_ += result;
  82     return result;
  83   } else if (next_read_error_ != net::OK) {
  84     int r = next_read_error_;
  85     next_read_error_ = net::OK;
  86     return r;
  87   } else {
  88     read_buffer_ = buf;
  89     read_buffer_size_ = buf_len;
  90     read_callback_ = callback;
  91     return net::ERR_IO_PENDING;
  92   }
  93 }
  94
  95 int FakeStreamSocket::Write(net::IOBuffer* buf, int buf_len,
  96                       const net::CompletionCallback& callback) {
  97   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
  98   EXPECT_FALSE(write_pending_);
  99
 100   if (write_limit_ > 0)
 101     buf_len = std::min(write_limit_, buf_len);
 102
 103   if (async_write_) {
 104     task_runner_->PostTask(FROM_HERE, base::Bind(
 105         &FakeStreamSocket::DoAsyncWrite, weak_factory_.GetWeakPtr(),
 106         scoped_refptr<net::IOBuffer>(buf), buf_len, callback));
 107     write_pending_ = true;
 108     return net::ERR_IO_PENDING;
 109   } else {
 110     if (next_write_error_ != net::OK) {
 111       int r = next_write_error_;
 112       next_write_error_ = net::OK;
 113       return r;
 114     }
 115
 116     DoWrite(buf, buf_len);
 117     return buf_len;
 118   }
 119 }
 120
 121 void FakeStreamSocket::DoAsyncWrite(scoped_refptr<net::IOBuffer> buf,
 122                                     int buf_len,
 123                                     const net::CompletionCallback& callback) {
 124   write_pending_ = false;
 125
 126   if (next_write_error_ != net::OK) {
 127     int r = next_write_error_;
 128     next_write_error_ = net::OK;
 129     callback.Run(r);
 130     return;
 131   }
 132
 133   DoWrite(buf.get(), buf_len);
 134   callback.Run(buf_len);
 135 }
 136
 137 void FakeStreamSocket::DoWrite(net::IOBuffer* buf, int buf_len) {
 138   written_data_.insert(written_data_.end(),
 139                        buf->data(), buf->data() + buf_len);
 140
 141   if (peer_socket_.get()) {
 142     task_runner_->PostTask(
 143         FROM_HERE,
 144         base::Bind(&FakeStreamSocket::AppendInputData,
 145                    peer_socket_,
 146                    std::string(buf->data(), buf->data() + buf_len)));
 147   }
 148 }
 149
 150 int FakeStreamSocket::SetReceiveBufferSize(int32 size) {
 151   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 152   NOTIMPLEMENTED();
 153   return net::ERR_NOT_IMPLEMENTED;
 154 }
 155
 156 int FakeStreamSocket::SetSendBufferSize(int32 size) {
 157   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 158   NOTIMPLEMENTED();
 159   return net::ERR_NOT_IMPLEMENTED;
 160 }
 161
 162 int FakeStreamSocket::Connect(const net::CompletionCallback& callback) {
 163   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 164   return net::OK;
 165 }
 166
 167 void FakeStreamSocket::Disconnect() {
 168   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 169
 170   if (peer_socket_.get()) {
 171     task_runner_->PostTask(
 172         FROM_HERE,
 173         base::Bind(&FakeStreamSocket::AppendReadError,
 174                    peer_socket_,
 175                    net::ERR_CONNECTION_CLOSED));
 176   }
 177   peer_socket_.reset();
 178 }
 179
 180 bool FakeStreamSocket::IsConnected() const {
 181   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 182   return true;
 183 }
 184
 185 bool FakeStreamSocket::IsConnectedAndIdle() const {
 186   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 187   NOTIMPLEMENTED();
 188   return false;
 189 }
 190
 191 int FakeStreamSocket::GetPeerAddress(net::IPEndPoint* address) const {
 192   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 193   net::IPAddressNumber ip(net::kIPv4AddressSize);
 194   *address = net::IPEndPoint(ip, 0);
 195   return net::OK;
 196 }
 197
 198 int FakeStreamSocket::GetLocalAddress(net::IPEndPoint* address) const {
 199   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 200   NOTIMPLEMENTED();
 201   return net::ERR_NOT_IMPLEMENTED;
 202 }
 203
 204 const net::BoundNetLog& FakeStreamSocket::NetLog() const {
 205   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 206   return net_log_;
 207 }
 208
 209 void FakeStreamSocket::SetSubresourceSpeculation() {
 210   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 211   NOTIMPLEMENTED();
 212 }
 213
 214 void FakeStreamSocket::SetOmniboxSpeculation() {
 215   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 216   NOTIMPLEMENTED();
 217 }
 218
 219 bool FakeStreamSocket::WasEverUsed() const {
 220   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 221   NOTIMPLEMENTED();
 222   return true;
 223 }
 224
 225 bool FakeStreamSocket::UsingTCPFastOpen() const {
 226   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 227   NOTIMPLEMENTED();
 228   return true;
 229 }
 230
 231 bool FakeStreamSocket::WasNpnNegotiated() const {
 232   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 233   return false;
 234 }
 235
 236 net::NextProto FakeStreamSocket::GetNegotiatedProtocol() const {
 237   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 238   NOTIMPLEMENTED();
 239   return net::kProtoUnknown;
 240 }
 241
 242 bool FakeStreamSocket::GetSSLInfo(net::SSLInfo* ssl_info) {
 243   EXPECT_TRUE(task_runner_->BelongsToCurrentThread());
 244   return false;
 245 }
 246
 247 FakeStreamChannelFactory::FakeStreamChannelFactory()
 248     : task_runner_(base::ThreadTaskRunnerHandle::Get()),
 249       asynchronous_create_(false),
 250       fail_create_(false),
 251       weak_factory_(this) {
 252 }
 253
 254 FakeStreamChannelFactory::~FakeStreamChannelFactory() {}
 255
 256 FakeStreamSocket* FakeStreamChannelFactory::GetFakeChannel(
 257     const std::string& name) {
 258   return channels_[name].get();
 259 }
 260
 261 void FakeStreamChannelFactory::CreateChannel(
 262     const std::string& name,
 263     const ChannelCreatedCallback& callback) {
 264   scoped_ptr<FakeStreamSocket> channel(new FakeStreamSocket());
 265   channels_[name] = channel->GetWeakPtr();
 266
 267   if (fail_create_)
 268     channel.reset();
 269
 270   if (asynchronous_create_) {
 271     task_runner_->PostTask(FROM_HERE, base::Bind(
 272         &FakeStreamChannelFactory::NotifyChannelCreated,
 273         weak_factory_.GetWeakPtr(), base::Passed(&channel), name, callback));
 274   } else {
 275     NotifyChannelCreated(channel.Pass(), name, callback);
 276   }
 277 }
 278
 279 void FakeStreamChannelFactory::NotifyChannelCreated(
 280     scoped_ptr<FakeStreamSocket> owned_channel,
 281     const std::string& name,
 282     const ChannelCreatedCallback& callback) {
 283   if (channels_.find(name) != channels_.end())
 284     callback.Run(owned_channel.Pass());
 285 }
 286
 287 void FakeStreamChannelFactory::CancelChannelCreation(const std::string& name) {
 288   channels_.erase(name);
 289 }
 290
 291 }  // namespace protocol
 292 }  // namespace remoting