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