| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent b35041c commit f54ace6
3 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -233,11 +233,11 @@ static void WriteNodeReport(Isolate* isolate, | |||
| 233 | 233 | size_t expected_results = 0; | |
| 234 | 234 | ||
| 235 | 235 | env->ForEachWorker([&](Worker* w) { | |
| 236 | - expected_results += w->RequestInterrupt([&](Environment* env) { | ||
| 236 | + expected_results += w->RequestInterrupt([&, w = w](Environment* env) { | ||
| 237 | 237 | std::ostringstream os; | |
| 238 | - | ||
| 239 | - GetNodeReport( | ||
| 240 | - env, "Worker thread subreport", trigger, Local<Value>(), os); | ||
| 238 | + std::string name = | ||
| 239 | + "Worker thread subreport [" + std::string(w->name()) + "]"; | ||
| 240 | + GetNodeReport(env, name.c_str(), trigger, Local<Value>(), os); | ||
| 241 | 241 | ||
| 242 | 242 | Mutex::ScopedLock lock(workers_mutex); | |
| 243 | 243 | worker_infos.emplace_back(os.str()); | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -62,6 +62,7 @@ class Worker : public AsyncWrap { | |||
| 62 | 62 | bool is_stopped() const; | |
| 63 | 63 | const SnapshotData* snapshot_data() const { return snapshot_data_; } | |
| 64 | 64 | bool is_internal() const { return is_internal_; } | |
| 65 | + std::string_view name() const { return name_; } | ||
| 65 | 66 | ||
| 66 | 67 | static void New(const v8::FunctionCallbackInfo<v8::Value>& args); | |
| 67 | 68 | static void CloneParentEnvVars( | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -13,7 +13,7 @@ async function basic() { | |||
| 13 | 13 | parentPort.once('message', () => { | |
| 14 | 14 | /* Wait for message to stop the Worker */ | |
| 15 | 15 | }); | |
| 16 | - `, { eval: true }); | ||
| 16 | + `, { eval: true, name: 'hello' }); | ||
| 17 | 17 | ||
| 18 | 18 | await once(w, 'online'); | |
| 19 | 19 | ||
@@ -22,7 +22,9 @@ async function basic() { | |||
| 22 | 22 | assert.strictEqual(report.workers.length, 1); | |
| 23 | 23 | helper.validateContent(report.workers[0]); | |
| 24 | 24 | assert.strictEqual(report.workers[0].header.threadId, w.threadId); | |
| 25 | - | ||
| 25 | + assert.strictEqual(report.workers[0].header.event, | ||
| 26 | + 'Worker thread subreport [hello]', | ||
| 27 | + report.workers[0].header.event); | ||
| 26 | 28 | w.postMessage({}); | |
| 27 | 29 | ||
| 28 | 30 | await once(w, 'exit'); | |
| Back | FazBrowse Home | New Git URL |
0 commit comments