OLD | NEW |
1 /* | 1 /* |
2 * This file is part of Adblock Plus <https://adblockplus.org/>, | 2 * This file is part of Adblock Plus <https://adblockplus.org/>, |
3 * Copyright (C) 2006-2016 Eyeo GmbH | 3 * Copyright (C) 2006-2016 Eyeo GmbH |
4 * | 4 * |
5 * Adblock Plus is free software: you can redistribute it and/or modify | 5 * Adblock Plus is free software: you can redistribute it and/or modify |
6 * it under the terms of the GNU General Public License version 3 as | 6 * it under the terms of the GNU General Public License version 3 as |
7 * published by the Free Software Foundation. | 7 * published by the Free Software Foundation. |
8 * | 8 * |
9 * Adblock Plus is distributed in the hope that it will be useful, | 9 * Adblock Plus is distributed in the hope that it will be useful, |
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of | 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of |
(...skipping 17 matching lines...) Expand all Loading... |
28 #include "Utils.h" | 28 #include "Utils.h" |
29 | 29 |
30 using namespace AdblockPlus; | 30 using namespace AdblockPlus; |
31 | 31 |
32 namespace | 32 namespace |
33 { | 33 { |
34 class IoThread : public Thread | 34 class IoThread : public Thread |
35 { | 35 { |
36 public: | 36 public: |
37 IoThread(JsEnginePtr jsEngine, JsValuePtr callback) | 37 IoThread(JsEnginePtr jsEngine, JsValuePtr callback) |
38 : Thread(true), jsEngine(jsEngine), fileSystem(jsEngine->GetFileSystem()), | 38 : Thread(true) |
39 callback(callback) | 39 , m_jsEngine(jsEngine) |
| 40 , fileSystem(jsEngine->GetFileSystem()) |
| 41 , callback(callback) |
40 { | 42 { |
41 } | 43 } |
42 | 44 |
43 protected: | 45 protected: |
44 JsEnginePtr jsEngine; | 46 std::weak_ptr<JsEngine> m_jsEngine; |
45 FileSystemPtr fileSystem; | 47 FileSystemPtr fileSystem; |
46 JsValuePtr callback; | 48 JsValuePtr callback; |
47 }; | 49 }; |
48 | 50 |
49 class ReadThread : public IoThread | 51 class ReadThread : public IoThread |
50 { | 52 { |
51 public: | 53 public: |
52 ReadThread(JsEnginePtr jsEngine, JsValuePtr callback, | 54 ReadThread(JsEnginePtr jsEngine, JsValuePtr callback, |
53 const std::string& path) | 55 const std::string& path) |
54 : IoThread(jsEngine, callback), path(path) | 56 : IoThread(jsEngine, callback), path(path) |
(...skipping 11 matching lines...) Expand all Loading... |
66 } | 68 } |
67 catch (std::exception& e) | 69 catch (std::exception& e) |
68 { | 70 { |
69 error = e.what(); | 71 error = e.what(); |
70 } | 72 } |
71 catch (...) | 73 catch (...) |
72 { | 74 { |
73 error = "Unknown error while reading from " + path; | 75 error = "Unknown error while reading from " + path; |
74 } | 76 } |
75 | 77 |
76 const JsContext context(jsEngine); | 78 JsContext context(m_jsEngine); |
77 JsValuePtr result = jsEngine->NewObject(); | 79 JsValuePtr result = context.jsEngine().NewObject(); |
78 result->SetProperty("content", content); | 80 result->SetProperty("content", content); |
79 result->SetProperty("error", error); | 81 result->SetProperty("error", error); |
80 JsValueList params; | 82 JsValueList params; |
81 params.push_back(result); | 83 params.push_back(result); |
82 callback->Call(params); | 84 callback->Call(params); |
83 } | 85 } |
84 | 86 |
85 private: | 87 private: |
86 std::string path; | 88 std::string path; |
87 }; | 89 }; |
(...skipping 18 matching lines...) Expand all Loading... |
106 } | 108 } |
107 catch (std::exception& e) | 109 catch (std::exception& e) |
108 { | 110 { |
109 error = e.what(); | 111 error = e.what(); |
110 } | 112 } |
111 catch (...) | 113 catch (...) |
112 { | 114 { |
113 error = "Unknown error while writing to " + path; | 115 error = "Unknown error while writing to " + path; |
114 } | 116 } |
115 | 117 |
116 const JsContext context(jsEngine); | 118 JsContext context(m_jsEngine); |
117 JsValuePtr errorValue = jsEngine->NewValue(error); | 119 JsValuePtr errorValue = context.jsEngine().NewValue(error); |
118 JsValueList params; | 120 JsValueList params; |
119 params.push_back(errorValue); | 121 params.push_back(errorValue); |
120 callback->Call(params); | 122 callback->Call(params); |
121 } | 123 } |
122 | 124 |
123 private: | 125 private: |
124 std::string path; | 126 std::string path; |
125 std::string content; | 127 std::string content; |
126 }; | 128 }; |
127 | 129 |
(...skipping 15 matching lines...) Expand all Loading... |
143 } | 145 } |
144 catch (std::exception& e) | 146 catch (std::exception& e) |
145 { | 147 { |
146 error = e.what(); | 148 error = e.what(); |
147 } | 149 } |
148 catch (...) | 150 catch (...) |
149 { | 151 { |
150 error = "Unknown error while moving " + fromPath + " to " + toPath; | 152 error = "Unknown error while moving " + fromPath + " to " + toPath; |
151 } | 153 } |
152 | 154 |
153 const JsContext context(jsEngine); | 155 JsContext context(m_jsEngine); |
154 JsValuePtr errorValue = jsEngine->NewValue(error); | 156 JsValuePtr errorValue = context.jsEngine().NewValue(error); |
155 JsValueList params; | 157 JsValueList params; |
156 params.push_back(errorValue); | 158 params.push_back(errorValue); |
157 callback->Call(params); | 159 callback->Call(params); |
158 } | 160 } |
159 | 161 |
160 private: | 162 private: |
161 std::string fromPath; | 163 std::string fromPath; |
162 std::string toPath; | 164 std::string toPath; |
163 }; | 165 }; |
164 | 166 |
(...skipping 15 matching lines...) Expand all Loading... |
180 } | 182 } |
181 catch (std::exception& e) | 183 catch (std::exception& e) |
182 { | 184 { |
183 error = e.what(); | 185 error = e.what(); |
184 } | 186 } |
185 catch (...) | 187 catch (...) |
186 { | 188 { |
187 error = "Unknown error while removing " + path; | 189 error = "Unknown error while removing " + path; |
188 } | 190 } |
189 | 191 |
190 const JsContext context(jsEngine); | 192 JsContext context(m_jsEngine); |
191 JsValuePtr errorValue = jsEngine->NewValue(error); | 193 JsValuePtr errorValue = context.jsEngine().NewValue(error); |
192 JsValueList params; | 194 JsValueList params; |
193 params.push_back(errorValue); | 195 params.push_back(errorValue); |
194 callback->Call(params); | 196 callback->Call(params); |
195 } | 197 } |
196 | 198 |
197 private: | 199 private: |
198 std::string path; | 200 std::string path; |
199 }; | 201 }; |
200 | 202 |
201 | 203 |
(...skipping 16 matching lines...) Expand all Loading... |
218 } | 220 } |
219 catch (std::exception& e) | 221 catch (std::exception& e) |
220 { | 222 { |
221 error = e.what(); | 223 error = e.what(); |
222 } | 224 } |
223 catch (...) | 225 catch (...) |
224 { | 226 { |
225 error = "Unknown error while calling stat on " + path; | 227 error = "Unknown error while calling stat on " + path; |
226 } | 228 } |
227 | 229 |
228 const JsContext context(jsEngine); | 230 JsContext context(m_jsEngine); |
229 JsValuePtr result = jsEngine->NewObject(); | 231 JsValuePtr result = context.jsEngine().NewObject(); |
230 result->SetProperty("exists", statResult.exists); | 232 result->SetProperty("exists", statResult.exists); |
231 result->SetProperty("isFile", statResult.isFile); | 233 result->SetProperty("isFile", statResult.isFile); |
232 result->SetProperty("isDirectory", statResult.isDirectory); | 234 result->SetProperty("isDirectory", statResult.isDirectory); |
233 result->SetProperty("lastModified", statResult.lastModified); | 235 result->SetProperty("lastModified", statResult.lastModified); |
234 result->SetProperty("error", error); | 236 result->SetProperty("error", error); |
235 | 237 |
236 JsValueList params; | 238 JsValueList params; |
237 params.push_back(result); | 239 params.push_back(result); |
238 callback->Call(params); | 240 callback->Call(params); |
239 } | 241 } |
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
353 JsValuePtr FileSystemJsObject::Setup(JsEnginePtr jsEngine, JsValuePtr obj) | 355 JsValuePtr FileSystemJsObject::Setup(JsEnginePtr jsEngine, JsValuePtr obj) |
354 { | 356 { |
355 obj->SetProperty("read", jsEngine->NewCallback(::ReadCallback)); | 357 obj->SetProperty("read", jsEngine->NewCallback(::ReadCallback)); |
356 obj->SetProperty("write", jsEngine->NewCallback(::WriteCallback)); | 358 obj->SetProperty("write", jsEngine->NewCallback(::WriteCallback)); |
357 obj->SetProperty("move", jsEngine->NewCallback(::MoveCallback)); | 359 obj->SetProperty("move", jsEngine->NewCallback(::MoveCallback)); |
358 obj->SetProperty("remove", jsEngine->NewCallback(::RemoveCallback)); | 360 obj->SetProperty("remove", jsEngine->NewCallback(::RemoveCallback)); |
359 obj->SetProperty("stat", jsEngine->NewCallback(::StatCallback)); | 361 obj->SetProperty("stat", jsEngine->NewCallback(::StatCallback)); |
360 obj->SetProperty("resolve", jsEngine->NewCallback(::ResolveCallback)); | 362 obj->SetProperty("resolve", jsEngine->NewCallback(::ResolveCallback)); |
361 return obj; | 363 return obj; |
362 } | 364 } |
OLD | NEW |