Refactor SignalStrategy so that it can be reused for multiple connections.

remoting/protocol/jingle_session_unittest.cc

 // Copyright (c) 2011 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 "base/bind.h"
 #include "base/message_loop_proxy.h"
 #include "base/time.h"
 #include "net/socket/socket.h"
 #include "net/socket/stream_socket.h"
 #include "remoting/base/constants.h"
@@ skipping 46 matching lines @@
 
 ACTION_P(QuitThreadOnCounter, counter) {
   (*counter)--;
   EXPECT_GE(*counter, 0);
   if (*counter == 0)
     QuitCurrentThread();
 }
 
 class MockSessionManagerListener : public SessionManager::Listener {
  public:
-  MOCK_METHOD0(OnSessionManagerInitialized, void());
+  MOCK_METHOD0(OnSessionManagerReady, void());
   MOCK_METHOD2(OnIncomingSession,
                void(Session*,
                     SessionManager::IncomingSessionResponse*));
 };
 
 class MockSessionCallback {
  public:
   MOCK_METHOD1(OnStateChange, void(Session::State));
 };
 
@@ skipping 42 matching lines @@
     client_session_.reset();
   }
 
   void CreateSessionManagers(int auth_round_trips,
                         FakeAuthenticator::Action auth_action) {
     host_signal_strategy_.reset(new FakeSignalStrategy(kHostJid));
     client_signal_strategy_.reset(new FakeSignalStrategy(kClientJid));
     FakeSignalStrategy::Connect(host_signal_strategy_.get(),
                                 client_signal_strategy_.get());
 
-    EXPECT_CALL(host_server_listener_, OnSessionManagerInitialized())
+    EXPECT_CALL(host_server_listener_, OnSessionManagerReady())
         .Times(1);
     host_server_.reset(new JingleSessionManager(
         base::MessageLoopProxy::current()));
     host_server_->Init(
-        kHostJid, host_signal_strategy_.get(), &host_server_listener_, false);
+        host_signal_strategy_.get(), &host_server_listener_, false);
 
     host_server_->set_authenticator_factory(
         new FakeHostAuthenticatorFactory(auth_round_trips, auth_action, true));
 
-    EXPECT_CALL(client_server_listener_, OnSessionManagerInitialized())
+    EXPECT_CALL(client_server_listener_, OnSessionManagerReady())
         .Times(1);
     client_server_.reset(new JingleSessionManager(
         base::MessageLoopProxy::current()));
     client_server_->Init(
-        kClientJid, client_signal_strategy_.get(),
-        &client_server_listener_, false);
+        client_signal_strategy_.get(), &client_server_listener_, false);
   }
 
   void CloseSessionManager() {
     if (host_server_.get()) {
       host_server_->Close();
       host_server_.reset();
     }
     if (client_server_.get()) {
       client_server_->Close();
       client_server_.reset();
@@ skipping 280 matching lines @@
 
   DatagramConnectionTester tester(
       client_socket, host_socket, kMessageSize, kMessages, kUdpWriteDelayMs);
   tester.Start();
   message_loop_.Run();
   tester.CheckResults();
 }
 
 }  // namespace protocol
 }  // namespace remoting