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 #ifndef REMOTING_HOST_WIN_WORKER_PROCESS_LAUNCHER_H_ | 5 #ifndef REMOTING_HOST_WIN_WORKER_PROCESS_LAUNCHER_H_ |
6 #define REMOTING_HOST_WIN_WORKER_PROCESS_LAUNCHER_H_ | 6 #define REMOTING_HOST_WIN_WORKER_PROCESS_LAUNCHER_H_ |
7 | 7 |
8 #include "base/basictypes.h" | 8 #include "base/basictypes.h" |
9 #include "base/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
10 #include "base/memory/ref_counted.h" | 10 #include "base/memory/ref_counted.h" |
11 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
12 #include "base/win/scoped_handle.h" | 12 #include "base/win/scoped_handle.h" |
| 13 #include "ipc/ipc_sender.h" |
13 | 14 |
14 namespace base { | 15 namespace base { |
15 class SingleThreadTaskRunner; | 16 class SingleThreadTaskRunner; |
16 } // namespace base | 17 } // namespace base |
17 | 18 |
18 namespace IPC { | 19 namespace IPC { |
| 20 class Listener; |
19 class Message; | 21 class Message; |
20 } // namespace IPC | 22 } // namespace IPC |
21 | 23 |
22 namespace remoting { | 24 namespace remoting { |
23 | 25 |
24 class WorkerProcessIpcDelegate; | 26 class WorkerProcessIpcDelegate; |
25 | 27 |
26 // Launches a worker process that is controlled via an IPC channel. All | 28 // Launches a worker process that is controlled via an IPC channel. All |
27 // interaction with the spawned process is through WorkerProcessIpcDelegate and | 29 // interaction with the spawned process is through WorkerProcessIpcDelegate and |
28 // Send() method. In case of error the channel is closed and the worker process | 30 // Send() method. In case of error the channel is closed and the worker process |
29 // is terminated. | 31 // is terminated. |
30 class WorkerProcessLauncher { | 32 class WorkerProcessLauncher { |
31 public: | 33 public: |
32 class Delegate { | 34 class Delegate : public IPC::Sender { |
33 public: | 35 public: |
34 virtual ~Delegate(); | 36 virtual ~Delegate(); |
35 | 37 |
36 // Returns the exit code of the worker process. | 38 // Returns the exit code of the worker process. |
37 virtual DWORD GetExitCode() = 0; | 39 virtual DWORD GetExitCode() = 0; |
38 | 40 |
39 // Terminates the worker process with the given exit code. | 41 // Terminates the worker process with the given exit code. Destroys the IPC |
| 42 // channel created by LaunchProcess(). |
40 virtual void KillProcess(DWORD exit_code) = 0; | 43 virtual void KillProcess(DWORD exit_code) = 0; |
41 | 44 |
42 // Starts the worker process and passes |channel_name| to it. | 45 // Starts the worker process and creates an IPC channel it can connect to. |
43 // |process_exit_event_out| receives a handle that becomes signalled once | 46 // |delegate| specifies the object that will receive notifications from |
44 // the launched process has been terminated. | 47 // the IPC channel. |process_exit_event_out| receives a handle that becomes |
| 48 // signalled once the launched process has been terminated. |
45 virtual bool LaunchProcess( | 49 virtual bool LaunchProcess( |
46 const std::string& channel_name, | 50 IPC::Listener* delegate, |
47 base::win::ScopedHandle* process_exit_event_out) = 0; | 51 base::win::ScopedHandle* process_exit_event_out) = 0; |
48 }; | 52 }; |
49 | 53 |
50 // Creates the launcher that will use |launcher_delegate| to manage the worker | 54 // Creates the launcher that will use |launcher_delegate| to manage the worker |
51 // process and |worker_delegate| to handle IPCs. The caller must ensure that | 55 // process and |worker_delegate| to handle IPCs. The caller must ensure that |
52 // |worker_delegate| remains valid until Stoppable::Stop() method has been | 56 // |worker_delegate| remains valid until Stoppable::Stop() method has been |
53 // called. | 57 // called. |
54 // | 58 // |
55 // The caller should call all the methods on this class on | 59 // The caller should call all the methods on this class on |
56 // the |caller_task_runner| thread. Methods of both delegate interfaces are | 60 // the |caller_task_runner| thread. Methods of both delegate interfaces are |
57 // called on the |caller_task_runner| thread as well. |io_task_runner| is used | 61 // called on the |caller_task_runner| thread as well. |
58 // to perform background IPC I/O. | |
59 WorkerProcessLauncher( | 62 WorkerProcessLauncher( |
60 scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner, | 63 scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner, |
61 scoped_refptr<base::SingleThreadTaskRunner> io_task_runner, | |
62 scoped_ptr<Delegate> launcher_delegate, | 64 scoped_ptr<Delegate> launcher_delegate, |
63 WorkerProcessIpcDelegate* worker_delegate, | 65 WorkerProcessIpcDelegate* worker_delegate); |
64 const std::string& pipe_security_descriptor); | |
65 ~WorkerProcessLauncher(); | 66 ~WorkerProcessLauncher(); |
66 | 67 |
67 // Sends an IPC message to the worker process. The message will be silently | 68 // Sends an IPC message to the worker process. The message will be silently |
68 // dropped if Send() is called before Start() or after stutdown has been | 69 // dropped if Send() is called before Start() or after stutdown has been |
69 // initiated. | 70 // initiated. |
70 void Send(IPC::Message* message); | 71 void Send(IPC::Message* message); |
71 | 72 |
72 private: | 73 private: |
73 // The actual implementation resides in WorkerProcessLauncher::Core class. | 74 // The actual implementation resides in WorkerProcessLauncher::Core class. |
74 class Core; | 75 class Core; |
75 scoped_refptr<Core> core_; | 76 scoped_refptr<Core> core_; |
76 | 77 |
77 DISALLOW_COPY_AND_ASSIGN(WorkerProcessLauncher); | 78 DISALLOW_COPY_AND_ASSIGN(WorkerProcessLauncher); |
78 }; | 79 }; |
79 | 80 |
80 } // namespace remoting | 81 } // namespace remoting |
81 | 82 |
82 #endif // REMOTING_HOST_WIN_WORKER_PROCESS_LAUNCHER_H_ | 83 #endif // REMOTING_HOST_WIN_WORKER_PROCESS_LAUNCHER_H_ |
OLD | NEW |