| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 <utility> | 5 #include <utility> |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "base/macros.h" | 10 #include "base/macros.h" |
| 11 #include "mojo/application/application_runner_chromium.h" | 11 #include "mojo/application/application_runner_chromium.h" |
| 12 #include "mojo/common/binding_set.h" | 12 #include "mojo/common/binding_set.h" |
| 13 #include "mojo/public/c/system/main.h" | 13 #include "mojo/public/c/system/main.h" |
| 14 #include "mojo/public/cpp/application/application_connection.h" | 14 #include "mojo/public/cpp/application/application_connection.h" |
| 15 #include "mojo/public/cpp/application/application_delegate.h" | 15 #include "mojo/public/cpp/application/application_delegate.h" |
| 16 #include "mojo/public/cpp/application/interface_factory.h" | |
| 17 #include "mojo/services/files/interfaces/file.mojom.h" | 16 #include "mojo/services/files/interfaces/file.mojom.h" |
| 18 #include "mojo/services/files/interfaces/types.mojom.h" | 17 #include "mojo/services/files/interfaces/types.mojom.h" |
| 19 #include "mojo/services/terminal/interfaces/terminal_client.mojom.h" | 18 #include "mojo/services/terminal/interfaces/terminal_client.mojom.h" |
| 20 | 19 |
| 21 const uint32_t kMaxBytesToRead = 1000; | 20 const uint32_t kMaxBytesToRead = 1000; |
| 22 | 21 |
| 23 // Owns itself. | 22 // Owns itself. |
| 24 class TerminalEchoer { | 23 class TerminalEchoer { |
| 25 public: | 24 public: |
| 26 explicit TerminalEchoer(mojo::files::FilePtr terminal) | 25 explicit TerminalEchoer(mojo::files::FilePtr terminal) |
| (...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 91 } | 90 } |
| 92 | 91 |
| 93 mojo::files::FilePtr terminal_; | 92 mojo::files::FilePtr terminal_; |
| 94 size_t last_bytes_read_size_; | 93 size_t last_bytes_read_size_; |
| 95 | 94 |
| 96 DISALLOW_COPY_AND_ASSIGN(TerminalEchoer); | 95 DISALLOW_COPY_AND_ASSIGN(TerminalEchoer); |
| 97 }; | 96 }; |
| 98 | 97 |
| 99 class EchoTerminalApp | 98 class EchoTerminalApp |
| 100 : public mojo::ApplicationDelegate, | 99 : public mojo::ApplicationDelegate, |
| 101 public mojo::InterfaceFactory<mojo::terminal::TerminalClient>, | |
| 102 public mojo::terminal::TerminalClient { | 100 public mojo::terminal::TerminalClient { |
| 103 public: | 101 public: |
| 104 EchoTerminalApp() {} | 102 EchoTerminalApp() {} |
| 105 ~EchoTerminalApp() override {} | 103 ~EchoTerminalApp() override {} |
| 106 | 104 |
| 107 private: | 105 private: |
| 108 // |ApplicationDelegate| override: | 106 // |ApplicationDelegate| override: |
| 109 bool ConfigureIncomingConnection( | 107 bool ConfigureIncomingConnection( |
| 110 mojo::ApplicationConnection* connection) override { | 108 mojo::ApplicationConnection* connection) override { |
| 111 connection->AddService<mojo::terminal::TerminalClient>(this); | 109 connection->GetServiceProviderImpl() |
| 110 .AddService<mojo::terminal::TerminalClient>([this]( |
| 111 const mojo::ConnectionContext& connection_context, |
| 112 mojo::InterfaceRequest<mojo::terminal::TerminalClient> |
| 113 terminal_client_request) { |
| 114 terminal_clients_.AddBinding(this, terminal_client_request.Pass()); |
| 115 }); |
| 112 return true; | 116 return true; |
| 113 } | 117 } |
| 114 | 118 |
| 115 // |InterfaceFactory<mojo::terminal::TerminalClient>| implementation: | |
| 116 void Create( | |
| 117 const mojo::ConnectionContext& connection_context, | |
| 118 mojo::InterfaceRequest<mojo::terminal::TerminalClient> request) override { | |
| 119 terminal_clients_.AddBinding(this, request.Pass()); | |
| 120 } | |
| 121 | |
| 122 // |mojo::terminal::TerminalClient| implementation: | 119 // |mojo::terminal::TerminalClient| implementation: |
| 123 void ConnectToTerminal( | 120 void ConnectToTerminal( |
| 124 mojo::InterfaceHandle<mojo::files::File> terminal) override { | 121 mojo::InterfaceHandle<mojo::files::File> terminal) override { |
| 125 DCHECK(terminal); | 122 DCHECK(terminal); |
| 126 // The |TerminalEchoer| will own itself. | 123 // The |TerminalEchoer| will own itself. |
| 127 (new TerminalEchoer(mojo::files::FilePtr::Create(std::move(terminal)))) | 124 (new TerminalEchoer(mojo::files::FilePtr::Create(std::move(terminal)))) |
| 128 ->StartReading(); | 125 ->StartReading(); |
| 129 } | 126 } |
| 130 | 127 |
| 131 mojo::BindingSet<mojo::terminal::TerminalClient> terminal_clients_; | 128 mojo::BindingSet<mojo::terminal::TerminalClient> terminal_clients_; |
| 132 | 129 |
| 133 DISALLOW_COPY_AND_ASSIGN(EchoTerminalApp); | 130 DISALLOW_COPY_AND_ASSIGN(EchoTerminalApp); |
| 134 }; | 131 }; |
| 135 | 132 |
| 136 MojoResult MojoMain(MojoHandle application_request) { | 133 MojoResult MojoMain(MojoHandle application_request) { |
| 137 mojo::ApplicationRunnerChromium runner(new EchoTerminalApp()); | 134 mojo::ApplicationRunnerChromium runner(new EchoTerminalApp()); |
| 138 return runner.Run(application_request); | 135 return runner.Run(application_request); |
| 139 } | 136 } |
| OLD | NEW |