Home | History | Annotate | Download | only in plugin 
      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
      3 // found in the LICENSE file.
      4 
      5 #ifndef NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_
      6 #define NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_
      7 
      8 #include <deque>
      9 #include <vector>
     10 
     11 #include "native_client/src/include/nacl_macros.h"
     12 #include "native_client/src/include/nacl_scoped_ptr.h"
     13 #include "native_client/src/include/nacl_string.h"
     14 #include "native_client/src/shared/platform/nacl_threads.h"
     15 #include "native_client/src/shared/platform/nacl_sync_checked.h"
     16 
     17 #include "ppapi/cpp/completion_callback.h"
     18 
     19 #include "ppapi/native_client/src/trusted/plugin/plugin_error.h"
     20 #include "ppapi/native_client/src/trusted/plugin/service_runtime.h"
     21 
     22 namespace nacl {
     23 class DescWrapper;
     24 }
     25 
     26 
     27 namespace plugin {
     28 
     29 class Manifest;
     30 class NaClSubprocess;
     31 class Plugin;
     32 class PnaclCoordinator;
     33 class PnaclOptions;
     34 class PnaclResources;
     35 class TempFile;
     36 
     37 struct PnaclTimeStats {
     38   int64_t pnacl_llc_load_time;
     39   int64_t pnacl_compile_time;
     40   int64_t pnacl_ld_load_time;
     41   int64_t pnacl_link_time;
     42 };
     43 
     44 class PnaclTranslateThread {
     45  public:
     46   PnaclTranslateThread();
     47   ~PnaclTranslateThread();
     48 
     49   // Start the translation process. It will continue to run and consume data
     50   // as it is passed in with PutBytes.
     51   void RunTranslate(const pp::CompletionCallback& finish_callback,
     52                     const Manifest* manifest,
     53                     TempFile* obj_file,
     54                     TempFile* nexe_file,
     55                     ErrorInfo* error_info,
     56                     PnaclResources* resources,
     57                     PnaclOptions* pnacl_options,
     58                     PnaclCoordinator* coordinator,
     59                     Plugin* plugin);
     60 
     61   // Kill the llc and/or ld subprocesses. This happens by closing the command
     62   // channel on the plugin side, which causes the trusted code in the nexe to
     63   // exit, which will cause any pending SRPCs to error. Because this is called
     64   // on the main thread, the translation thread must not use the subprocess
     65   // objects without the lock, other than InvokeSrpcMethod, which does not
     66   // race with service runtime shutdown.
     67   void AbortSubprocesses();
     68 
     69   // Send bitcode bytes to the translator. Called from the main thread.
     70   void PutBytes(std::vector<char>* data, int count);
     71 
     72   const PnaclTimeStats& GetTimeStats() const { return time_stats_; }
     73 
     74  private:
     75   // Starts an individual llc or ld subprocess used for translation.
     76   NaClSubprocess* StartSubprocess(const nacl::string& url,
     77                                   const Manifest* manifest,
     78                                   ErrorInfo* error_info);
     79   // Helper thread entry point for translation. Takes a pointer to
     80   // PnaclTranslateThread and calls DoTranslate().
     81   static void WINAPI DoTranslateThread(void* arg);
     82   // Runs the streaming translation. Called from the helper thread.
     83   void DoTranslate() ;
     84   // Signal that Pnacl translation failed, from the translation thread only.
     85   void TranslateFailed(enum PluginErrorCode err_code,
     86                        const nacl::string& error_string);
     87   // Run the LD subprocess, returning true on success
     88   bool RunLdSubprocess(int is_shared_library,
     89                        const nacl::string& soname,
     90                        const nacl::string& lib_dependencies);
     91 
     92 
     93   // Callback to run when tasks are completed or an error has occurred.
     94   pp::CompletionCallback report_translate_finished_;
     95 
     96   nacl::scoped_ptr<NaClThread> translate_thread_;
     97 
     98   // Used to guard llc_subprocess and ld_subprocess
     99   struct NaClMutex subprocess_mu_;
    100   nacl::scoped_ptr<NaClSubprocess> llc_subprocess_;
    101   nacl::scoped_ptr<NaClSubprocess> ld_subprocess_;
    102   // Used to ensure the subprocesses don't get shutdown more than once.
    103   bool llc_subprocess_active_;
    104   bool ld_subprocess_active_;
    105 
    106   // Condition variable to synchronize communication with the SRPC thread.
    107   // SRPC thread waits on this condvar if data_buffers_ is empty (meaning
    108   // there is no bitcode to send to the translator), and the main thread
    109   // appends to data_buffers_ and signals it when it receives bitcode.
    110   struct NaClCondVar buffer_cond_;
    111   // Mutex for buffer_cond_.
    112   struct NaClMutex cond_mu_;
    113   // Data buffers from FileDownloader are enqueued here to pass from the
    114   // main thread to the SRPC thread. Protected by cond_mu_
    115   std::deque<std::vector<char> > data_buffers_;
    116   // Whether all data has been downloaded and copied to translation thread.
    117   // Associated with buffer_cond_
    118   bool done_;
    119 
    120   PnaclTimeStats time_stats_;
    121 
    122   // Data about the translation files, owned by the coordinator
    123   const Manifest* manifest_;
    124   TempFile* obj_file_;
    125   TempFile* nexe_file_;
    126   ErrorInfo* coordinator_error_info_;
    127   PnaclResources* resources_;
    128   PnaclOptions* pnacl_options_;
    129   PnaclCoordinator* coordinator_;
    130   Plugin* plugin_;
    131  private:
    132   NACL_DISALLOW_COPY_AND_ASSIGN(PnaclTranslateThread);
    133 };
    134 
    135 }
    136 #endif // NATIVE_CLIENT_SRC_TRUSTED_PLUGIN_PNACL_TRANSLATE_THREAD_H_
    137