Pass the desktop session ID to the remoting network process.

remoting/host/security_key/security_key_ipc_server_unittest.cc

 // Copyright 2016 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/host/security_key/security_key_ipc_server.h"
 
 #include <memory>
 #include <string>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/callback.h"
 #include "base/macros.h"
 #include "base/message_loop/message_loop.h"
 #include "base/run_loop.h"
 #include "ipc/ipc_channel.h"
+#include "remoting/host/client_session_details.h"
 #include "remoting/host/security_key/fake_security_key_ipc_client.h"
 #include "remoting/host/security_key/security_key_ipc_constants.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace {
 const int kTestConnectionId = 42;
 const int kInitialConnectTimeoutMs = 250;
 const int kConnectionTimeoutErrorDeltaMs = 100;
 const int kLargeMessageSizeBytes = 256 * 1024;
 }  // namespace
 
 namespace remoting {
 
-class SecurityKeyIpcServerTest : public testing::Test {
+class SecurityKeyIpcServerTest : public testing::Test,
+                                 public ClientSessionDetails {
  public:
   SecurityKeyIpcServerTest();
   ~SecurityKeyIpcServerTest() override;
 
   // Passed to the object used for testing to be called back to signal
   // completion of an IPC channel state change or reception of an IPC message.
   void OperationComplete();
 
   // Used as a callback to signal receipt of a security key request message.
   void SendRequestToClient(int connection_id, const std::string& data);
 
  protected:
   // Returns a unique IPC channel name which prevents conflicts when running
   // tests concurrently.
   std::string GetUniqueTestChannelName();
 
   // Waits until the current |run_loop_| instance is signaled, then resets it.
   void WaitForOperationComplete();
 
+  // ClientSessionControl overrides:
+  ClientSessionControl* session_control() override { return nullptr; }
+  uint32_t desktop_session_id() const override { return peer_session_id_; }
+
   // IPC tests require a valid MessageLoop to run.
   base::MessageLoopForIO message_loop_;
 
   // Used to allow |message_loop_| to run during tests.  The instance is reset
   // after each stage of the tests has been completed.
   std::unique_ptr<base::RunLoop> run_loop_;
 
   // The object under test.
   std::unique_ptr<SecurityKeyIpcServer> security_key_ipc_server_;
 
   // Used to validate the object under test uses the correct ID when
   // communicating over the IPC channel.
   int last_connection_id_received_ = -1;
 
   // Stores the contents of the last IPC message received for validation.
   std::string last_message_received_;
 
+  uint32_t peer_session_id_ = UINT32_MAX;
+
  private:
   DISALLOW_COPY_AND_ASSIGN(SecurityKeyIpcServerTest);
 };
 
 SecurityKeyIpcServerTest::SecurityKeyIpcServerTest()
     : run_loop_(new base::RunLoop()) {
-  uint32_t peer_session_id = UINT32_MAX;
 #if defined(OS_WIN)
-  EXPECT_TRUE(ProcessIdToSessionId(GetCurrentProcessId(),
-                                   reinterpret_cast<DWORD*>(&peer_session_id)));
+  EXPECT_TRUE(ProcessIdToSessionId(
+      GetCurrentProcessId(), reinterpret_cast<DWORD*>(&peer_session_id_)));
 #endif  // defined(OS_WIN)
 
   security_key_ipc_server_ = remoting::SecurityKeyIpcServer::Create(
-      kTestConnectionId, peer_session_id,
+      kTestConnectionId, this,
       base::TimeDelta::FromMilliseconds(kInitialConnectTimeoutMs),
       base::Bind(&SecurityKeyIpcServerTest::SendRequestToClient,
                  base::Unretained(this)),
       base::Bind(&SecurityKeyIpcServerTest::OperationComplete,
                  base::Unretained(this)));
 }
 
 SecurityKeyIpcServerTest::~SecurityKeyIpcServerTest() {}
 
 void SecurityKeyIpcServerTest::OperationComplete() {
@@ skipping 278 matching lines @@
   base::Time start_time(base::Time::NowFromSystemTime());
   WaitForOperationComplete();
   base::TimeDelta elapsed_time = base::Time::NowFromSystemTime() - start_time;
 
   ASSERT_NEAR(elapsed_time.InMilliseconds(), request_timeout.InMilliseconds(),
               kConnectionTimeoutErrorDeltaMs);
 }
 
 #if defined(OS_WIN)
 TEST_F(SecurityKeyIpcServerTest, IpcConnectionFailsFromInvalidSession) {
-  uint32_t peer_session_id = UINT32_MAX;
-  ASSERT_TRUE(ProcessIdToSessionId(GetCurrentProcessId(),
-                                   reinterpret_cast<DWORD*>(&peer_session_id)));
-  peer_session_id++;
-
-  // Reinitialize the object under test.
-  security_key_ipc_server_ = remoting::SecurityKeyIpcServer::Create(
-      kTestConnectionId, peer_session_id,
-      base::TimeDelta::FromMilliseconds(kInitialConnectTimeoutMs),
-      base::Bind(&SecurityKeyIpcServerTest::SendRequestToClient,
-                 base::Unretained(this)),
-      base::Bind(&base::DoNothing));
+  // Change the expected session ID to not match the current session.
+  peer_session_id_++;
 
   base::TimeDelta request_timeout(base::TimeDelta::FromMilliseconds(500));
   std::string channel_name(GetUniqueTestChannelName());
   ASSERT_TRUE(
       security_key_ipc_server_->CreateChannel(channel_name, request_timeout));
 
   // Create a fake client and attempt to connect to the IPC server channel.
   FakeSecurityKeyIpcClient fake_ipc_client(base::Bind(
       &SecurityKeyIpcServerTest::OperationComplete, base::Unretained(this)));
   ASSERT_TRUE(fake_ipc_client.ConnectViaIpc(channel_name));
   WaitForOperationComplete();
   WaitForOperationComplete();
+  WaitForOperationComplete();
 
   // Verify the connection failed.
   ASSERT_FALSE(fake_ipc_client.ipc_channel_connected());
 }
 #endif  // defined(OS_WIN)
 
 }  // namespace remoting