Replace ice_connection_to_client_unittest.cc with connection_unittest.cc

remoting/protocol/fake_stream_socket.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "remoting/protocol/fake_stream_socket.h"
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
 #include "base/single_thread_task_runner.h"
 #include "base/thread_task_runner_handle.h"
@@ skipping 151 matching lines @@
       weak_factory_(this) {
 }
 
 FakeStreamChannelFactory::~FakeStreamChannelFactory() {}
 
 FakeStreamSocket* FakeStreamChannelFactory::GetFakeChannel(
     const std::string& name) {
   return channels_[name].get();
 }
 
+void FakeStreamChannelFactory::PairWith(
+    FakeStreamChannelFactory* peer_factory) {
+  peer_factory_ = peer_factory->weak_factory_.GetWeakPtr();
+  peer_factory->peer_factory_ = weak_factory_.GetWeakPtr();
+}
+
 void FakeStreamChannelFactory::CreateChannel(
     const std::string& name,
     const ChannelCreatedCallback& callback) {
   scoped_ptr<FakeStreamSocket> channel(new FakeStreamSocket());
   channels_[name] = channel->GetWeakPtr();
 
+  if (peer_factory_) {
+    FakeStreamSocket* peer_channel = peer_factory_->GetFakeChannel(name);
+    if (peer_channel)
+      channel->PairWith(peer_channel);
+  }
+
   if (fail_create_)
     channel.reset();
 
   if (asynchronous_create_) {
     task_runner_->PostTask(FROM_HERE, base::Bind(
         &FakeStreamChannelFactory::NotifyChannelCreated,
         weak_factory_.GetWeakPtr(), base::Passed(&channel), name, callback));
   } else {
     NotifyChannelCreated(channel.Pass(), name, callback);
   }
 }
 
 void FakeStreamChannelFactory::NotifyChannelCreated(
     scoped_ptr<FakeStreamSocket> owned_channel,
     const std::string& name,
     const ChannelCreatedCallback& callback) {
   if (channels_.find(name) != channels_.end())
     callback.Run(owned_channel.Pass());
 }
 
 void FakeStreamChannelFactory::CancelChannelCreation(const std::string& name) {
   channels_.erase(name);
 }
 
 }  // namespace protocol
 }  // namespace remoting