| 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 NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_ | 5 #ifndef NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_ |
| 6 #define NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_ | 6 #define NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_ |
| 7 | 7 |
| 8 #include "native_client/src/include/nacl_macros.h" | 8 #include "native_client/src/include/nacl_macros.h" |
| 9 #include "native_client/src/include/nacl_scoped_ptr.h" | 9 #include "native_client/src/include/nacl_scoped_ptr.h" |
| 10 #include "native_client/src/include/nacl_string.h" | 10 #include "native_client/src/include/nacl_string.h" |
| 11 #include "native_client/src/shared/platform/nacl_threads.h" | 11 #include "native_client/src/shared/platform/nacl_threads.h" |
| 12 #include "native_client/src/shared/platform/nacl_sync_checked.h" | 12 #include "native_client/src/shared/platform/nacl_sync_checked.h" |
| 13 #include "native_client/src/trusted/plugin/plugin_error.h" | 13 #include "native_client/src/trusted/plugin/plugin_error.h" |
| 14 #include "native_client/src/trusted/plugin/service_runtime.h" |
| 14 | 15 |
| 15 #include "ppapi/cpp/completion_callback.h" | 16 #include "ppapi/cpp/completion_callback.h" |
| 16 | 17 |
| 17 namespace nacl { | 18 namespace nacl { |
| 18 class DescWrapper; | 19 class DescWrapper; |
| 19 } | 20 } |
| 20 | 21 |
| 21 | 22 |
| 22 namespace plugin { | 23 namespace plugin { |
| 23 | 24 |
| 24 class LocalTempFile; | 25 class LocalTempFile; |
| 25 class Manifest; | 26 class Manifest; |
| 26 class NaClSubprocess; | 27 class NaClSubprocess; |
| 27 class Plugin; | 28 class Plugin; |
| 28 class PnaclResources; | 29 class PnaclResources; |
| 29 class TempFile; | 30 class TempFile; |
| 30 | 31 |
| 31 class PnaclTranslateThread { | 32 class PnaclTranslateThread { |
| 32 public: | 33 public: |
| 33 PnaclTranslateThread(); | 34 PnaclTranslateThread(); |
| 34 virtual ~PnaclTranslateThread(); | 35 virtual ~PnaclTranslateThread(); |
| 35 // TODO(jvoung/dschuff): handle surfaway issues when coordinator/plugin | 36 |
| 36 // goes away. This data may have to be refcounted not touched in that case. | |
| 37 virtual void RunTranslate(const pp::CompletionCallback& finish_callback, | 37 virtual void RunTranslate(const pp::CompletionCallback& finish_callback, |
| 38 const Manifest* manifest, | 38 const Manifest* manifest, |
| 39 const Manifest* ld_manifest, | 39 const Manifest* ld_manifest, |
| 40 TempFile* obj_file, | 40 TempFile* obj_file, |
| 41 LocalTempFile* nexe_file, | 41 LocalTempFile* nexe_file, |
| 42 ErrorInfo* error_info, | 42 ErrorInfo* error_info, |
| 43 PnaclResources* resources, | 43 PnaclResources* resources, |
| 44 Plugin* plugin) = 0; | 44 Plugin* plugin) = 0; |
| 45 // Returns true if the translate thread and subprocesses should stop. | 45 // Returns true if the translate thread and subprocesses should stop. |
| 46 bool SubprocessesShouldDie(); | 46 bool SubprocessesShouldDie(); |
| (...skipping 10 matching lines...) Expand all Loading... |
| 57 static void WINAPI DoTranslateThread(void* arg); | 57 static void WINAPI DoTranslateThread(void* arg); |
| 58 // Runs the SRPCs that control translation. Called from the helper thread. | 58 // Runs the SRPCs that control translation. Called from the helper thread. |
| 59 virtual void DoTranslate() = 0; | 59 virtual void DoTranslate() = 0; |
| 60 // Signal that Pnacl translation failed, from the translation thread only. | 60 // Signal that Pnacl translation failed, from the translation thread only. |
| 61 void TranslateFailed(const nacl::string& error_string); | 61 void TranslateFailed(const nacl::string& error_string); |
| 62 // Run the LD subprocess, returning true on success | 62 // Run the LD subprocess, returning true on success |
| 63 bool RunLdSubprocess(int is_shared_library, | 63 bool RunLdSubprocess(int is_shared_library, |
| 64 const nacl::string& soname, | 64 const nacl::string& soname, |
| 65 const nacl::string& lib_dependencies); | 65 const nacl::string& lib_dependencies); |
| 66 | 66 |
| 67 // Register a reverse service interface which will be shutdown if the |
| 68 // plugin is shutdown. The reverse service pointer must be available on the |
| 69 // main thread because the translation thread could be blocked on SRPC |
| 70 // waiting for the translator, which could be waiting on a reverse |
| 71 // service call. |
| 72 // (see also the comments in Plugin::~Plugin about ShutdownSubprocesses, |
| 73 // but that only handles the main nexe and not the translator nexes.) |
| 74 void RegisterReverseInterface(PluginReverseInterface *interface); |
| 75 |
| 67 // Callback to run when tasks are completed or an error has occurred. | 76 // Callback to run when tasks are completed or an error has occurred. |
| 68 pp::CompletionCallback report_translate_finished_; | 77 pp::CompletionCallback report_translate_finished_; |
| 69 // True if the translation thread and related subprocesses should exit. | 78 // True if the translation thread and related subprocesses should exit. |
| 70 bool subprocesses_should_die_; | 79 bool subprocesses_should_die_; |
| 71 // Used to guard and publish subprocesses_should_die_. | 80 // Used to guard and publish subprocesses_should_die_. |
| 72 struct NaClMutex subprocess_mu_; | 81 struct NaClMutex subprocess_mu_; |
| 73 | 82 |
| 74 nacl::scoped_ptr<NaClThread> translate_thread_; | 83 nacl::scoped_ptr<NaClThread> translate_thread_; |
| 75 | 84 |
| 85 // Reverse interface to shutdown on SetSubprocessesShouldDie |
| 86 PluginReverseInterface* current_rev_interface_; |
| 87 |
| 76 // Data about the translation files, owned by the coordinator | 88 // Data about the translation files, owned by the coordinator |
| 77 const Manifest* manifest_; | 89 const Manifest* manifest_; |
| 78 const Manifest* ld_manifest_; | 90 const Manifest* ld_manifest_; |
| 79 TempFile* obj_file_; | 91 TempFile* obj_file_; |
| 80 LocalTempFile* nexe_file_; | 92 LocalTempFile* nexe_file_; |
| 81 ErrorInfo* coordinator_error_info_; | 93 ErrorInfo* coordinator_error_info_; |
| 82 PnaclResources* resources_; | 94 PnaclResources* resources_; |
| 83 Plugin* plugin_; | 95 Plugin* plugin_; |
| 84 private: | 96 private: |
| 85 NACL_DISALLOW_COPY_AND_ASSIGN(PnaclTranslateThread); | 97 NACL_DISALLOW_COPY_AND_ASSIGN(PnaclTranslateThread); |
| 86 }; | 98 }; |
| 87 | 99 |
| 88 } | 100 } |
| 89 #endif // NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_ | 101 #endif // NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_ |
| OLD | NEW |