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 |