| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/basictypes.h" | 5 #include <stdint.h> |
| 6 |
| 6 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/macros.h" |
| 7 #include "base/memory/ref_counted.h" | 9 #include "base/memory/ref_counted.h" |
| 8 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
| 9 #include "base/win/scoped_handle.h" | 11 #include "base/win/scoped_handle.h" |
| 10 #include "base/win/scoped_process_information.h" | 12 #include "base/win/scoped_process_information.h" |
| 11 #include "ipc/ipc_channel.h" | 13 #include "ipc/ipc_channel.h" |
| 12 #include "ipc/ipc_channel_proxy.h" | 14 #include "ipc/ipc_channel_proxy.h" |
| 13 #include "ipc/ipc_listener.h" | 15 #include "ipc/ipc_listener.h" |
| 14 #include "ipc/ipc_message.h" | 16 #include "ipc/ipc_message.h" |
| 15 #include "remoting/base/auto_thread_task_runner.h" | 17 #include "remoting/base/auto_thread_task_runner.h" |
| 16 #include "remoting/host/chromoting_messages.h" | 18 #include "remoting/host/chromoting_messages.h" |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 53 private: | 55 private: |
| 54 DISALLOW_COPY_AND_ASSIGN(MockProcessLauncherDelegate); | 56 DISALLOW_COPY_AND_ASSIGN(MockProcessLauncherDelegate); |
| 55 }; | 57 }; |
| 56 | 58 |
| 57 class MockIpcDelegate : public WorkerProcessIpcDelegate { | 59 class MockIpcDelegate : public WorkerProcessIpcDelegate { |
| 58 public: | 60 public: |
| 59 MockIpcDelegate() {} | 61 MockIpcDelegate() {} |
| 60 ~MockIpcDelegate() override {} | 62 ~MockIpcDelegate() override {} |
| 61 | 63 |
| 62 // WorkerProcessIpcDelegate interface. | 64 // WorkerProcessIpcDelegate interface. |
| 63 MOCK_METHOD1(OnChannelConnected, void(int32)); | 65 MOCK_METHOD1(OnChannelConnected, void(int32_t)); |
| 64 MOCK_METHOD1(OnMessageReceived, bool(const IPC::Message&)); | 66 MOCK_METHOD1(OnMessageReceived, bool(const IPC::Message&)); |
| 65 MOCK_METHOD1(OnPermanentError, void(int)); | 67 MOCK_METHOD1(OnPermanentError, void(int)); |
| 66 | 68 |
| 67 private: | 69 private: |
| 68 DISALLOW_COPY_AND_ASSIGN(MockIpcDelegate); | 70 DISALLOW_COPY_AND_ASSIGN(MockIpcDelegate); |
| 69 }; | 71 }; |
| 70 | 72 |
| 71 class MockWorkerListener : public IPC::Listener { | 73 class MockWorkerListener : public IPC::Listener { |
| 72 public: | 74 public: |
| 73 MockWorkerListener() {} | 75 MockWorkerListener() {} |
| (...skipping 27 matching lines...) Expand all Loading... |
| 101 public IPC::Listener { | 103 public IPC::Listener { |
| 102 public: | 104 public: |
| 103 WorkerProcessLauncherTest(); | 105 WorkerProcessLauncherTest(); |
| 104 ~WorkerProcessLauncherTest() override; | 106 ~WorkerProcessLauncherTest() override; |
| 105 | 107 |
| 106 void SetUp() override; | 108 void SetUp() override; |
| 107 void TearDown() override; | 109 void TearDown() override; |
| 108 | 110 |
| 109 // IPC::Listener implementation. | 111 // IPC::Listener implementation. |
| 110 bool OnMessageReceived(const IPC::Message& message) override; | 112 bool OnMessageReceived(const IPC::Message& message) override; |
| 111 void OnChannelConnected(int32 peer_pid) override; | 113 void OnChannelConnected(int32_t peer_pid) override; |
| 112 void OnChannelError() override; | 114 void OnChannelError() override; |
| 113 | 115 |
| 114 // WorkerProcessLauncher::Delegate mocks | 116 // WorkerProcessLauncher::Delegate mocks |
| 115 void LaunchProcess( | 117 void LaunchProcess( |
| 116 WorkerProcessLauncher* event_handler); | 118 WorkerProcessLauncher* event_handler); |
| 117 void LaunchProcessAndConnect( | 119 void LaunchProcessAndConnect( |
| 118 WorkerProcessLauncher* event_handler); | 120 WorkerProcessLauncher* event_handler); |
| 119 void FailLaunchAndStopWorker( | 121 void FailLaunchAndStopWorker( |
| 120 WorkerProcessLauncher* event_handler); | 122 WorkerProcessLauncher* event_handler); |
| 121 void KillProcess(); | 123 void KillProcess(); |
| (...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 211 .Times(0); | 213 .Times(0); |
| 212 } | 214 } |
| 213 | 215 |
| 214 void WorkerProcessLauncherTest::TearDown() { | 216 void WorkerProcessLauncherTest::TearDown() { |
| 215 } | 217 } |
| 216 | 218 |
| 217 bool WorkerProcessLauncherTest::OnMessageReceived(const IPC::Message& message) { | 219 bool WorkerProcessLauncherTest::OnMessageReceived(const IPC::Message& message) { |
| 218 return event_handler_->OnMessageReceived(message); | 220 return event_handler_->OnMessageReceived(message); |
| 219 } | 221 } |
| 220 | 222 |
| 221 void WorkerProcessLauncherTest::OnChannelConnected(int32 peer_pid) { | 223 void WorkerProcessLauncherTest::OnChannelConnected(int32_t peer_pid) { |
| 222 event_handler_->OnChannelConnected(peer_pid); | 224 event_handler_->OnChannelConnected(peer_pid); |
| 223 } | 225 } |
| 224 | 226 |
| 225 void WorkerProcessLauncherTest::OnChannelError() { | 227 void WorkerProcessLauncherTest::OnChannelError() { |
| 226 event_handler_->OnChannelError(); | 228 event_handler_->OnChannelError(); |
| 227 } | 229 } |
| 228 | 230 |
| 229 void WorkerProcessLauncherTest::LaunchProcess( | 231 void WorkerProcessLauncherTest::LaunchProcess( |
| 230 WorkerProcessLauncher* event_handler) { | 232 WorkerProcessLauncher* event_handler) { |
| 231 EXPECT_FALSE(event_handler_); | 233 EXPECT_FALSE(event_handler_); |
| (...skipping 294 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 526 EXPECT_CALL(client_listener_, OnCrash(_, _, _)) | 528 EXPECT_CALL(client_listener_, OnCrash(_, _, _)) |
| 527 .Times(1) | 529 .Times(1) |
| 528 .WillOnce(InvokeWithoutArgs( | 530 .WillOnce(InvokeWithoutArgs( |
| 529 this, &WorkerProcessLauncherTest::SendFakeMessageToLauncher)); | 531 this, &WorkerProcessLauncherTest::SendFakeMessageToLauncher)); |
| 530 | 532 |
| 531 StartWorker(); | 533 StartWorker(); |
| 532 message_loop_.Run(); | 534 message_loop_.Run(); |
| 533 } | 535 } |
| 534 | 536 |
| 535 } // namespace remoting | 537 } // namespace remoting |
| OLD | NEW |