| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "remoting/host/it2me/it2me_native_messaging_host_main.h" | 5 #include "remoting/host/it2me/it2me_native_messaging_host_main.h" |
| 6 | 6 |
| 7 #include "base/at_exit.h" | 7 #include "base/at_exit.h" |
| 8 #include "base/command_line.h" | 8 #include "base/command_line.h" |
| 9 #include "base/i18n/icu_util.h" | 9 #include "base/i18n/icu_util.h" |
| 10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
| (...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 102 // The files are automatically closed. | 102 // The files are automatically closed. |
| 103 base::File read_file(STDIN_FILENO); | 103 base::File read_file(STDIN_FILENO); |
| 104 base::File write_file(STDOUT_FILENO); | 104 base::File write_file(STDOUT_FILENO); |
| 105 #else | 105 #else |
| 106 #error Not implemented. | 106 #error Not implemented. |
| 107 #endif | 107 #endif |
| 108 | 108 |
| 109 base::MessageLoopForUI message_loop; | 109 base::MessageLoopForUI message_loop; |
| 110 base::RunLoop run_loop; | 110 base::RunLoop run_loop; |
| 111 | 111 |
| 112 scoped_refptr<AutoThreadTaskRunner> task_runner = | |
| 113 new remoting::AutoThreadTaskRunner(message_loop.message_loop_proxy(), | |
| 114 run_loop.QuitClosure()); | |
| 115 | |
| 116 scoped_ptr<It2MeHostFactory> factory(new It2MeHostFactory()); | 112 scoped_ptr<It2MeHostFactory> factory(new It2MeHostFactory()); |
| 117 | 113 |
| 118 scoped_ptr<NativeMessagingPipe> native_messaging_pipe( | 114 scoped_ptr<NativeMessagingPipe> native_messaging_pipe( |
| 119 new NativeMessagingPipe()); | 115 new NativeMessagingPipe()); |
| 120 | 116 |
| 121 // Set up the native messaging channel. | 117 // Set up the native messaging channel. |
| 122 scoped_ptr<extensions::NativeMessagingChannel> channel( | 118 scoped_ptr<extensions::NativeMessagingChannel> channel( |
| 123 new PipeMessagingChannel(read_file.Pass(), write_file.Pass())); | 119 new PipeMessagingChannel(read_file.Pass(), write_file.Pass())); |
| 124 | 120 |
| 125 scoped_ptr<extensions::NativeMessageHost> host(new It2MeNativeMessagingHost( | 121 scoped_ptr<ChromotingHostContext> context = |
| 126 ChromotingHostContext::Create(task_runner), factory.Pass())); | 122 ChromotingHostContext::Create(new remoting::AutoThreadTaskRunner( |
| 123 message_loop.message_loop_proxy(), run_loop.QuitClosure())); |
| 124 scoped_ptr<extensions::NativeMessageHost> host( |
| 125 new It2MeNativeMessagingHost(context.Pass(), factory.Pass())); |
| 127 | 126 |
| 128 host->Start(native_messaging_pipe.get()); | 127 host->Start(native_messaging_pipe.get()); |
| 129 | 128 |
| 130 native_messaging_pipe->Start( | 129 native_messaging_pipe->Start(host.Pass(), channel.Pass()); |
| 131 host.Pass(), channel.Pass(), run_loop.QuitClosure()); | |
| 132 | 130 |
| 133 // Run the loop until channel is alive. | 131 // Run the loop until channel is alive. |
| 134 run_loop.Run(); | 132 run_loop.Run(); |
| 135 | 133 |
| 136 return kSuccessExitCode; | 134 return kSuccessExitCode; |
| 137 } | 135 } |
| 138 | 136 |
| 139 int It2MeNativeMessagingHostMain(int argc, char** argv) { | 137 int It2MeNativeMessagingHostMain(int argc, char** argv) { |
| 140 // This object instance is required by Chrome code (such as MessageLoop). | 138 // This object instance is required by Chrome code (such as MessageLoop). |
| 141 base::AtExitManager exit_manager; | 139 base::AtExitManager exit_manager; |
| 142 | 140 |
| 143 base::CommandLine::Init(argc, argv); | 141 base::CommandLine::Init(argc, argv); |
| 144 remoting::InitHostLogging(); | 142 remoting::InitHostLogging(); |
| 145 | 143 |
| 146 return StartIt2MeNativeMessagingHost(); | 144 return StartIt2MeNativeMessagingHost(); |
| 147 } | 145 } |
| 148 | 146 |
| 149 } // namespace remoting | 147 } // namespace remoting |
| OLD | NEW |