The worker process launcher can now ask the worker to crash.

remoting/host/win/worker_process_launcher_unittest.cc

 // Copyright (c) 2012 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/basictypes.h"
 #include "base/bind.h"
 #include "base/memory/ref_counted.h"
 #include "base/message_loop.h"
 #include "base/win/scoped_handle.h"
 #include "ipc/ipc_channel.h"
 #include "ipc/ipc_channel_proxy.h"
 #include "ipc/ipc_listener.h"
 #include "ipc/ipc_message.h"
 #include "remoting/base/auto_thread_task_runner.h"
+#include "remoting/host/chromoting_messages.h"
 #include "remoting/host/host_exit_codes.h"
 #include "remoting/host/win/launch_process_with_token.h"
 #include "remoting/host/win/worker_process_launcher.h"
 #include "remoting/host/worker_process_ipc_delegate.h"
+#include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gmock_mutant.h"
-#include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using base::win::ScopedHandle;
 using testing::_;
 using testing::AnyNumber;
 using testing::CreateFunctor;
 using testing::DoAll;
 using testing::Expectation;
 using testing::Invoke;
 using testing::InvokeWithoutArgs;
 using testing::Return;
 using testing::ReturnPointee;
 
 namespace remoting {
 
 namespace {
 
 const char kIpcSecurityDescriptor[] = "D:(A;;GA;;;AU)";
 
-class MockProcessLauncherDelegate
-    : public WorkerProcessLauncher::Delegate {
+class MockProcessLauncherDelegate : public WorkerProcessLauncher::Delegate {
  public:
   MockProcessLauncherDelegate() {}
   virtual ~MockProcessLauncherDelegate() {}
 
-  virtual DWORD GetProcessId() const OVERRIDE {
-    return const_cast<MockProcessLauncherDelegate*>(this)->GetProcessId();
-  }
-
-  virtual bool IsPermanentError(int failure_count) const OVERRIDE {
-    return const_cast<MockProcessLauncherDelegate*>(this)->IsPermanentError(
-        failure_count);
-  }
-
   // IPC::Sender implementation.
   MOCK_METHOD1(Send, bool(IPC::Message*));
 
-  // WorkerProcessLauncher::Delegate implementation
-  MOCK_METHOD0(GetProcessId, DWORD());
-  MOCK_METHOD1(IsPermanentError, bool(int));
+  // WorkerProcessLauncher::Delegate interface.
+  MOCK_METHOD0(CloseChannel, void());
+  MOCK_CONST_METHOD0(GetProcessId, DWORD());
+  MOCK_CONST_METHOD1(IsPermanentError, bool(int));
   MOCK_METHOD1(KillProcess, void(DWORD));
   MOCK_METHOD2(LaunchProcess, bool(IPC::Listener*, ScopedHandle*));
 
  private:
   DISALLOW_COPY_AND_ASSIGN(MockProcessLauncherDelegate);
 };
 
-class MockIpcDelegate
-    : public WorkerProcessIpcDelegate {
+class MockIpcDelegate : public WorkerProcessIpcDelegate {
  public:
   MockIpcDelegate() {}
   virtual ~MockIpcDelegate() {}
 
-  // WorkerProcessIpcDelegate implementation
+  // WorkerProcessIpcDelegate interface.
   MOCK_METHOD1(OnChannelConnected, void(int32));
   MOCK_METHOD1(OnMessageReceived, bool(const IPC::Message&));
   MOCK_METHOD0(OnPermanentError, void());
 
  private:
   DISALLOW_COPY_AND_ASSIGN(MockIpcDelegate);
 };
 
+class MockWorkerListener : public IPC::Listener {
+ public:
+  MockWorkerListener() {}
+  virtual ~MockWorkerListener() {}
+
+  MOCK_METHOD3(OnCrash, void(const std::string&, const std::string&, int));
+
+  // IPC::Listener implementation
+  virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
+
+ private:
+  DISALLOW_COPY_AND_ASSIGN(MockWorkerListener);
+};
+
+bool MockWorkerListener::OnMessageReceived(const IPC::Message& message) {
+  bool handled = true;
+  IPC_BEGIN_MESSAGE_MAP(MockWorkerListener, message)
+    IPC_MESSAGE_HANDLER(ChromotingDaemonMsg_Crash, OnCrash)
+    IPC_MESSAGE_UNHANDLED(handled = false)
+  IPC_END_MESSAGE_MAP()
+
+  EXPECT_TRUE(handled);
+
+  return handled;
+}
+
 }  // namespace
 
-class WorkerProcessLauncherTest
-    : public testing::Test,
-      public IPC::Listener {
+class WorkerProcessLauncherTest : public testing::Test {
  public:
   WorkerProcessLauncherTest();
   virtual ~WorkerProcessLauncherTest();
 
   virtual void SetUp() OVERRIDE;
   virtual void TearDown() OVERRIDE;
 
-  // IPC::Listener implementation
-  virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
-
   // WorkerProcessLauncher::Delegate mocks
   void KillProcess(DWORD exit_code);
   bool LaunchProcess(IPC::Listener* delegate,
                      ScopedHandle* process_exit_event_out);
   bool LaunchProcessAndConnect(IPC::Listener* delegate,
                                ScopedHandle* process_exit_event_out);
   bool FailLaunchAndStopWorker(IPC::Listener* delegate,
                                ScopedHandle* process_exit_event_out);
 
-  void ConnectChannel();
-  void DisconnectChannel();
+  // Connects the client end of the channel (the worker process's end).
+  void ConnectClient();
+
+  // Disconnects the client end of the channel.
+  void DisconnectClient();
+
+  // Disconnects the server end of the channel (the launcher's end).
+  void DisconnectServer();
+
+  // Sends a message to the worker process.
+  bool SendToProcess(IPC::Message* message);
+
+  // Sends a fake message to the launcher.
+  void SendFakeMessageToLauncher();
+
+  // Requests the worker to crash.
+  void CrashWorker();
 
   // Starts the worker.
   void StartWorker();
 
   // Stops the worker.
   void StopWorker();
 
   // Quits |message_loop_|.
   void QuitMainMessageLoop();
 
  protected:
   MessageLoop message_loop_;
   scoped_refptr<AutoThreadTaskRunner> task_runner_;
 
-  MockIpcDelegate ipc_delegate_;
+  // Receives mesages sent to the worker process.

[Wez, 2013/03/07 01:54:35]

typo

[alexeypa (please no reviews), 2013/03/07 21:28:30]

Done.

+  MockWorkerListener client_listener_;
+
+  // Receives messages sent from the worker process.
+  MockIpcDelegate server_listener_;
+
+  // Implements WorkerProcessLauncher::Delegate.
   scoped_ptr<MockProcessLauncherDelegate> launcher_delegate_;
 
   // The name of the IPC channel.
   std::string channel_name_;
 
   // Client and server ends of the IPC channel.
   scoped_ptr<IPC::ChannelProxy> channel_client_;
   scoped_ptr<IPC::ChannelProxy> channel_server_;
 
   // Returned as the worker process PID to the launcher.
@@ skipping 22 matching lines @@
 void WorkerProcessLauncherTest::SetUp() {
   task_runner_ = new AutoThreadTaskRunner(
       message_loop_.message_loop_proxy(),
       base::Bind(&WorkerProcessLauncherTest::QuitMainMessageLoop,
                  base::Unretained(this)));
 
   // Set up process launcher delegate
   launcher_delegate_.reset(new MockProcessLauncherDelegate());
   EXPECT_CALL(*launcher_delegate_, Send(_))
       .Times(AnyNumber())
-      .WillRepeatedly(Return(false));
+      .WillRepeatedly(Invoke(this, &WorkerProcessLauncherTest::SendToProcess));
+  EXPECT_CALL(*launcher_delegate_, CloseChannel())
+      .Times(AnyNumber())
+      .WillRepeatedly(Invoke(this,
+                             &WorkerProcessLauncherTest::DisconnectServer));
   EXPECT_CALL(*launcher_delegate_, GetProcessId())
       .Times(AnyNumber())
       .WillRepeatedly(ReturnPointee(&client_pid_));
   EXPECT_CALL(*launcher_delegate_, IsPermanentError(_))
       .Times(AnyNumber())
       .WillRepeatedly(ReturnPointee(&permanent_error_));
   EXPECT_CALL(*launcher_delegate_, KillProcess(_))
       .Times(AnyNumber())
       .WillRepeatedly(Invoke(this, &WorkerProcessLauncherTest::KillProcess));
 
   // Set up IPC delegate.
-  EXPECT_CALL(ipc_delegate_, OnMessageReceived(_))
-      .Times(AnyNumber())
-      .WillRepeatedly(Return(false));
+  EXPECT_CALL(server_listener_, OnMessageReceived(_))
+      .Times(0);
 }
 
 void WorkerProcessLauncherTest::TearDown() {
 }
 
-bool WorkerProcessLauncherTest::OnMessageReceived(const IPC::Message& message) {
-  return false;
-}
-
 void WorkerProcessLauncherTest::KillProcess(DWORD exit_code) {
   BOOL result = SetEvent(process_exit_event_);
   EXPECT_TRUE(result);
 }
 
 bool WorkerProcessLauncherTest::LaunchProcess(
     IPC::Listener* delegate,
     ScopedHandle* process_exit_event_out) {
   process_exit_event_.Set(CreateEvent(NULL, TRUE, FALSE, NULL));
   if (!process_exit_event_.IsValid())
@@ skipping 22 matching lines @@
 }
 
 bool WorkerProcessLauncherTest::LaunchProcessAndConnect(
     IPC::Listener* delegate,
     ScopedHandle* process_exit_event_out) {
   if (!LaunchProcess(delegate, process_exit_event_out))
     return false;
 
   task_runner_->PostTask(
       FROM_HERE,
-      base::Bind(&WorkerProcessLauncherTest::ConnectChannel,
+      base::Bind(&WorkerProcessLauncherTest::ConnectClient,
                  base::Unretained(this)));
   return true;
 }
 
 bool WorkerProcessLauncherTest::FailLaunchAndStopWorker(
     IPC::Listener* delegate,
     ScopedHandle* process_exit_event_out) {
   task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&WorkerProcessLauncherTest::StopWorker,
                  base::Unretained(this)));
   return false;
 }
 
-void WorkerProcessLauncherTest::ConnectChannel() {
+void WorkerProcessLauncherTest::ConnectClient() {
   channel_client_.reset(new IPC::ChannelProxy(
       IPC::ChannelHandle(channel_name_),
       IPC::Channel::MODE_CLIENT,
-      this,
+      &client_listener_,
       task_runner_));
 }
 
-void WorkerProcessLauncherTest::DisconnectChannel() {
+void WorkerProcessLauncherTest::DisconnectClient() {
   channel_client_.reset();
 }
 
+void WorkerProcessLauncherTest::DisconnectServer() {
+  channel_server_.reset();
+}
+
+bool WorkerProcessLauncherTest::SendToProcess(IPC::Message* message) {
+  if (channel_server_)
+    return channel_server_->Send(message);
+
+  delete message;
+  return false;
+}
+
+void WorkerProcessLauncherTest::SendFakeMessageToLauncher() {
+  if (channel_client_)
+    channel_client_->Send(new ChromotingDesktopNetworkMsg_DisconnectSession());
+}
+
+void WorkerProcessLauncherTest::CrashWorker() {
+  launcher_->Crash(FROM_HERE);
+}
+
 void WorkerProcessLauncherTest::StartWorker() {
   launcher_.reset(new WorkerProcessLauncher(
-      task_runner_, launcher_delegate_.Pass(), &ipc_delegate_));
+      task_runner_, launcher_delegate_.Pass(), &server_listener_));
 }
 
 void WorkerProcessLauncherTest::StopWorker() {
   launcher_.reset();
-  DisconnectChannel();
+  DisconnectClient();
   channel_name_.clear();
   channel_server_.reset();
   task_runner_ = NULL;
 }
 
 void WorkerProcessLauncherTest::QuitMainMessageLoop() {
   message_loop_.PostTask(FROM_HERE, MessageLoop::QuitClosure());
 }
 
 TEST_F(WorkerProcessLauncherTest, Start) {
   EXPECT_CALL(*launcher_delegate_, LaunchProcess(_, _))
       .Times(1)
       .WillRepeatedly(Invoke(this, &WorkerProcessLauncherTest::LaunchProcess));
 
-  EXPECT_CALL(ipc_delegate_, OnChannelConnected(_))
+  EXPECT_CALL(server_listener_, OnChannelConnected(_))
       .Times(0);
-  EXPECT_CALL(ipc_delegate_, OnPermanentError())
+  EXPECT_CALL(server_listener_, OnPermanentError())
       .Times(0);
 
   StartWorker();
   StopWorker();
   message_loop_.Run();
 }
 
 // Starts and connects to the worker process. Expect OnChannelConnected to be
 // called.
 TEST_F(WorkerProcessLauncherTest, StartAndConnect) {
   EXPECT_CALL(*launcher_delegate_, LaunchProcess(_, _))
       .Times(1)
       .WillRepeatedly(Invoke(
           this, &WorkerProcessLauncherTest::LaunchProcessAndConnect));
 
-  EXPECT_CALL(ipc_delegate_, OnChannelConnected(_))
+  EXPECT_CALL(server_listener_, OnChannelConnected(_))
       .Times(1)
       .WillOnce(InvokeWithoutArgs(this,
                                   &WorkerProcessLauncherTest::StopWorker));
-  EXPECT_CALL(ipc_delegate_, OnPermanentError())
+  EXPECT_CALL(server_listener_, OnPermanentError())
       .Times(0);
 
   StartWorker();
   message_loop_.Run();
 }
 
 // Kills the worker process after the 1st connect and expects it to be
 // restarted.
 TEST_F(WorkerProcessLauncherTest, Restart) {
   EXPECT_CALL(*launcher_delegate_, LaunchProcess(_, _))
       .Times(2)
       .WillRepeatedly(Invoke(
           this, &WorkerProcessLauncherTest::LaunchProcessAndConnect));
   Expectation first_connect =
-      EXPECT_CALL(ipc_delegate_, OnChannelConnected(_))
+      EXPECT_CALL(server_listener_, OnChannelConnected(_))
           .Times(2)
           .WillOnce(InvokeWithoutArgs(CreateFunctor(
               this, &WorkerProcessLauncherTest::KillProcess, CONTROL_C_EXIT)))
           .WillOnce(InvokeWithoutArgs(this,
                                       &WorkerProcessLauncherTest::StopWorker));
 
-  EXPECT_CALL(ipc_delegate_, OnPermanentError())
+  EXPECT_CALL(server_listener_, OnPermanentError())
       .Times(0);
 
   StartWorker();
   message_loop_.Run();
 }
 
 // Drops the IPC channel to the worker process after the 1st connect and expects
 // the worker process to be restarted.
 TEST_F(WorkerProcessLauncherTest, DropIpcChannel) {
   EXPECT_CALL(*launcher_delegate_, LaunchProcess(_, _))
       .Times(2)
       .WillRepeatedly(Invoke(
           this, &WorkerProcessLauncherTest::LaunchProcessAndConnect));
 
   Expectation first_connect =
-      EXPECT_CALL(ipc_delegate_, OnChannelConnected(_))
+      EXPECT_CALL(server_listener_, OnChannelConnected(_))
           .Times(2)
           .WillOnce(InvokeWithoutArgs(
-              this, &WorkerProcessLauncherTest::DisconnectChannel))
+              this, &WorkerProcessLauncherTest::DisconnectClient))
           .WillOnce(InvokeWithoutArgs(
               this, &WorkerProcessLauncherTest::StopWorker));
 
-  EXPECT_CALL(ipc_delegate_, OnPermanentError())
+  EXPECT_CALL(server_listener_, OnPermanentError())
       .Times(0);
 
   StartWorker();
   message_loop_.Run();
 }
 
 // Returns a permanent error exit code and expects OnPermanentError() to be
 // invoked.
 TEST_F(WorkerProcessLauncherTest, PermanentError) {
   EXPECT_CALL(*launcher_delegate_, LaunchProcess(_, _))
       .Times(1)
       .WillRepeatedly(Invoke(
           this, &WorkerProcessLauncherTest::LaunchProcessAndConnect));
 
-  EXPECT_CALL(ipc_delegate_, OnChannelConnected(_))
+  EXPECT_CALL(server_listener_, OnChannelConnected(_))
       .Times(1)
       .WillOnce(InvokeWithoutArgs(CreateFunctor(
           this, &WorkerProcessLauncherTest::KillProcess, CONTROL_C_EXIT)));
-  EXPECT_CALL(ipc_delegate_, OnPermanentError())
+  EXPECT_CALL(server_listener_, OnPermanentError())
       .Times(1)
       .WillOnce(InvokeWithoutArgs(this,
                                   &WorkerProcessLauncherTest::StopWorker));
 
   permanent_error_ = true;
   StartWorker();
   message_loop_.Run();
 }
 
 // Returns invalid client PID and expects the connection to be rejected.
 TEST_F(WorkerProcessLauncherTest, InvalidClientPid) {
   EXPECT_CALL(*launcher_delegate_, LaunchProcess(_, _))
       .Times(2)
       .WillOnce(Invoke(
           this, &WorkerProcessLauncherTest::LaunchProcessAndConnect))
       .WillOnce(Invoke(
           this, &WorkerProcessLauncherTest::FailLaunchAndStopWorker));
 
-  EXPECT_CALL(ipc_delegate_, OnChannelConnected(_))
+  EXPECT_CALL(server_listener_, OnChannelConnected(_))
       .Times(0);
-  EXPECT_CALL(ipc_delegate_, OnPermanentError())
+  EXPECT_CALL(server_listener_, OnPermanentError())
       .Times(0);
 
   client_pid_ = GetCurrentProcessId() + 4;
   StartWorker();
   message_loop_.Run();
 }
 
+// Requests the worker to crash and expects it to honor the request.
+TEST_F(WorkerProcessLauncherTest, Crash) {
+  EXPECT_CALL(*launcher_delegate_, LaunchProcess(_, _))
+      .Times(2)
+      .WillRepeatedly(Invoke(
+          this, &WorkerProcessLauncherTest::LaunchProcessAndConnect));
+
+  EXPECT_CALL(server_listener_, OnChannelConnected(_))
+      .Times(2)
+      .WillOnce(InvokeWithoutArgs(this,
+                                  &WorkerProcessLauncherTest::CrashWorker))
+      .WillOnce(InvokeWithoutArgs(this,
+                                  &WorkerProcessLauncherTest::StopWorker));
+
+  EXPECT_CALL(client_listener_, OnCrash(_, _, _))
+      .Times(1)
+      .WillOnce(InvokeWithoutArgs(CreateFunctor(
+          this, &WorkerProcessLauncherTest::KillProcess,
+          EXCEPTION_BREAKPOINT)));
+
+  StartWorker();
+  message_loop_.Run();
+}
+
+// Requests the worker to crash and terminates the worker even if it does not
+// comply.

[Wez, 2013/03/07 01:54:35]

How - are we relying on the timeout? i.e. will this test always take 5s?

[alexeypa (please no reviews), 2013/03/07 21:28:30]

Good point. I added reduced the delay to 1ms when running the test.

[Wez, 2013/03/08 01:45:15]

nit: Could that be zero ms, i.e. kill it as soon as the message is processed?

[alexeypa (please no reviews), 2013/03/08 17:43:19]

Done.

+TEST_F(WorkerProcessLauncherTest, CrashAnyway) {
+  EXPECT_CALL(*launcher_delegate_, LaunchProcess(_, _))
+      .Times(2)
+      .WillRepeatedly(Invoke(
+          this, &WorkerProcessLauncherTest::LaunchProcessAndConnect));
+
+  EXPECT_CALL(server_listener_, OnChannelConnected(_))
+      .Times(2)
+      .WillOnce(InvokeWithoutArgs(this,
+                                  &WorkerProcessLauncherTest::CrashWorker))
+      .WillOnce(InvokeWithoutArgs(this,
+                                  &WorkerProcessLauncherTest::StopWorker));
+
+  // Ignore the crash request and try send another message to the launcher.
+  EXPECT_CALL(client_listener_, OnCrash(_, _, _))
+      .Times(1)
+      .WillOnce(InvokeWithoutArgs(
+          this, &WorkerProcessLauncherTest::SendFakeMessageToLauncher));
+
+  StartWorker();
+  message_loop_.Run();
+}
+
 }  // namespace remoting