| 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 <fcntl.h> | 5 #include <fcntl.h> |
| 6 | 6 |
| 7 #include "base/files/file_util.h" | 7 #include "base/files/file_util.h" |
| 8 #include "base/message_loop/message_loop.h" |
| 8 #include "base/sha1.h" | 9 #include "base/sha1.h" |
| 9 #include "base/strings/string_number_conversions.h" | 10 #include "base/strings/string_number_conversions.h" |
| 10 #include "mojo/application/application_runner_chromium.h" | |
| 11 #include "mojo/application/content_handler_factory.h" | 11 #include "mojo/application/content_handler_factory.h" |
| 12 #include "mojo/data_pipe_utils/data_pipe_utils.h" | 12 #include "mojo/data_pipe_utils/data_pipe_utils.h" |
| 13 #include "mojo/file_utils/file_util.h" | 13 #include "mojo/file_utils/file_util.h" |
| 14 #include "mojo/message_pump/message_pump_mojo.h" | 14 #include "mojo/message_pump/message_pump_mojo.h" |
| 15 #include "mojo/nacl/nonsfi/file_util.h" | 15 #include "mojo/nacl/nonsfi/file_util.h" |
| 16 #include "mojo/nacl/nonsfi/nexe_launcher_nonsfi.h" | 16 #include "mojo/nacl/nonsfi/nexe_launcher_nonsfi.h" |
| 17 #include "mojo/public/c/system/main.h" | 17 #include "mojo/public/c/system/main.h" |
| 18 #include "mojo/public/cpp/application/application_delegate.h" | 18 #include "mojo/public/cpp/application/application_impl_base.h" |
| 19 #include "mojo/public/cpp/application/application_impl.h" | |
| 20 #include "mojo/public/cpp/application/connect.h" | 19 #include "mojo/public/cpp/application/connect.h" |
| 20 #include "mojo/public/cpp/application/run_application.h" |
| 21 #include "mojo/public/cpp/bindings/array.h" | 21 #include "mojo/public/cpp/bindings/array.h" |
| 22 #include "mojo/public/cpp/bindings/synchronous_interface_ptr.h" | 22 #include "mojo/public/cpp/bindings/synchronous_interface_ptr.h" |
| 23 #include "mojo/services/files/interfaces/directory.mojom-sync.h" | 23 #include "mojo/services/files/interfaces/directory.mojom-sync.h" |
| 24 #include "mojo/services/files/interfaces/files.mojom.h" | 24 #include "mojo/services/files/interfaces/files.mojom.h" |
| 25 #include "services/nacl/nonsfi/pnacl_compile.mojom-sync.h" | 25 #include "services/nacl/nonsfi/pnacl_compile.mojom-sync.h" |
| 26 #include "services/nacl/nonsfi/pnacl_link.mojom-sync.h" | 26 #include "services/nacl/nonsfi/pnacl_link.mojom-sync.h" |
| 27 | 27 |
| 28 namespace nacl { | 28 namespace nacl { |
| 29 namespace content_handler { | 29 namespace content_handler { |
| 30 | 30 |
| 31 class PexeContentHandler : public mojo::ApplicationDelegate, | 31 class PexeContentHandler : public mojo::ApplicationImplBase, |
| 32 public mojo::ContentHandlerFactory::Delegate { | 32 public mojo::ContentHandlerFactory::Delegate { |
| 33 public: | 33 public: |
| 34 PexeContentHandler() {} | 34 PexeContentHandler() {} |
| 35 | 35 |
| 36 private: | 36 private: |
| 37 // Overridden from ApplicationDelegate: | 37 // Overridden from ApplicationImplBase: |
| 38 void Initialize(mojo::ApplicationImpl* app) override { | 38 void OnInitialize() override { |
| 39 mojo::ConnectToService(app->shell(), "mojo:pnacl_compile", | 39 mojo::ConnectToService(shell(), "mojo:pnacl_compile", |
| 40 GetSynchronousProxy(&compiler_init_)); | 40 GetSynchronousProxy(&compiler_init_)); |
| 41 mojo::ConnectToService(app->shell(), "mojo:pnacl_link", | 41 mojo::ConnectToService(shell(), "mojo:pnacl_link", |
| 42 GetSynchronousProxy(&linker_init_)); | 42 GetSynchronousProxy(&linker_init_)); |
| 43 mojo::ConnectToService(app->shell(), "mojo:files", GetProxy(&files_)); | 43 mojo::ConnectToService(shell(), "mojo:files", GetProxy(&files_)); |
| 44 mojo::files::Error error = mojo::files::Error::INTERNAL; | 44 mojo::files::Error error = mojo::files::Error::INTERNAL; |
| 45 files_->OpenFileSystem("app_persistent_cache", | 45 files_->OpenFileSystem("app_persistent_cache", |
| 46 GetSynchronousProxy(&nexe_cache_directory_), | 46 GetSynchronousProxy(&nexe_cache_directory_), |
| 47 [&error](mojo::files::Error e) { error = e; }); | 47 [&error](mojo::files::Error e) { error = e; }); |
| 48 CHECK(files_.WaitForIncomingResponse()); | 48 CHECK(files_.WaitForIncomingResponse()); |
| 49 CHECK_EQ(mojo::files::Error::OK, error); | 49 CHECK_EQ(mojo::files::Error::OK, error); |
| 50 } | 50 } |
| 51 | 51 |
| 52 // Overridden from ApplicationDelegate: | 52 // Overridden from ApplicationImplBase: |
| 53 bool ConfigureIncomingConnection( | 53 bool OnAcceptConnection( |
| 54 mojo::ServiceProviderImpl* service_provider_impl) override { | 54 mojo::ServiceProviderImpl* service_provider_impl) override { |
| 55 service_provider_impl->AddService<mojo::ContentHandler>( | 55 service_provider_impl->AddService<mojo::ContentHandler>( |
| 56 mojo::ContentHandlerFactory::GetInterfaceRequestHandler(this)); | 56 mojo::ContentHandlerFactory::GetInterfaceRequestHandler(this)); |
| 57 return true; | 57 return true; |
| 58 } | 58 } |
| 59 | 59 |
| 60 int AccessFileFromCache(std::string& digest) { | 60 int AccessFileFromCache(std::string& digest) { |
| 61 mojo::files::Error error = mojo::files::Error::INTERNAL; | 61 mojo::files::Error error = mojo::files::Error::INTERNAL; |
| 62 mojo::files::FilePtr nexe_cache_file; | 62 mojo::files::FilePtr nexe_cache_file; |
| 63 CHECK(nexe_cache_directory_->OpenFile(digest, GetProxy(&nexe_cache_file), | 63 CHECK(nexe_cache_directory_->OpenFile(digest, GetProxy(&nexe_cache_file), |
| (...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 155 mojo::SynchronousInterfacePtr<mojo::nacl::PexeCompilerInit> compiler_init_; | 155 mojo::SynchronousInterfacePtr<mojo::nacl::PexeCompilerInit> compiler_init_; |
| 156 mojo::SynchronousInterfacePtr<mojo::nacl::PexeLinkerInit> linker_init_; | 156 mojo::SynchronousInterfacePtr<mojo::nacl::PexeLinkerInit> linker_init_; |
| 157 | 157 |
| 158 DISALLOW_COPY_AND_ASSIGN(PexeContentHandler); | 158 DISALLOW_COPY_AND_ASSIGN(PexeContentHandler); |
| 159 }; | 159 }; |
| 160 | 160 |
| 161 } // namespace content_handler | 161 } // namespace content_handler |
| 162 } // namespace nacl | 162 } // namespace nacl |
| 163 | 163 |
| 164 MojoResult MojoMain(MojoHandle application_request) { | 164 MojoResult MojoMain(MojoHandle application_request) { |
| 165 mojo::ApplicationRunnerChromium runner( | 165 nacl::content_handler::PexeContentHandler pexe_content_handler; |
| 166 new nacl::content_handler::PexeContentHandler()); | 166 return mojo::RunMainApplication(application_request, &pexe_content_handler); |
| 167 return runner.Run(application_request); | |
| 168 } | 167 } |
| OLD | NEW |