| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 6010a91 commit 1fffda5
2 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -89,7 +89,7 @@ int RunNodeInstance(MultiIsolatePlatform* platform, | |||
| 89 | 89 | snapshot_as_file = true; | |
| 90 | 90 | } else if (arg == "--embedder-snapshot-blob") { | |
| 91 | 91 | assert(i + 1 < args.size()); | |
| 92 | - snapshot_blob_path = args[i + i]; | ||
| 92 | + snapshot_blob_path = args[i + 1]; | ||
| 93 | 93 | i++; | |
| 94 | 94 | } else { | |
| 95 | 95 | filtered_args.push_back(arg); | |
@@ -121,9 +121,10 @@ int RunNodeInstance(MultiIsolatePlatform* platform, | |||
| 121 | 121 | ||
| 122 | 122 | if (is_building_snapshot) { | |
| 123 | 123 | // It contains at least the binary path, the code to snapshot, | |
| 124 | - // and --embedder-snapshot-create. Insert an anonymous filename | ||
| 125 | - // as process.argv[1]. | ||
| 126 | - assert(filtered_args.size() >= 3); | ||
| 124 | + // and --embedder-snapshot-create (which is filtered, so at least | ||
| 125 | + // 2 arguments should remain after filtering). | ||
| 126 | + assert(filtered_args.size() >= 2); | ||
| 127 | + // Insert an anonymous filename as process.argv[1]. | ||
| 127 | 128 | filtered_args.insert(filtered_args.begin() + 1, | |
| 128 | 129 | node::GetAnonymousMainPath()); | |
| 129 | 130 | } | |
@@ -153,19 +154,26 @@ int RunNodeInstance(MultiIsolatePlatform* platform, | |||
| 153 | 154 | Context::Scope context_scope(setup->context()); | |
| 154 | 155 | ||
| 155 | 156 | MaybeLocal<Value> loadenv_ret; | |
| 156 | - if (snapshot) { | ||
| 157 | + if (snapshot) { // Deserializing snapshot | ||
| 157 | 158 | loadenv_ret = node::LoadEnvironment(env, node::StartExecutionCallback{}); | |
| 158 | - } else { | ||
| 159 | + } else if (is_building_snapshot) { | ||
| 160 | + // Environment created for snapshotting must set process.argv[1] to | ||
| 161 | + // the name of the main script, which was inserted above. | ||
| 159 | 162 | loadenv_ret = node::LoadEnvironment( | |
| 160 | 163 | env, | |
| 161 | - // Snapshots do not support userland require()s (yet) | ||
| 162 | - "if (!require('v8').startupSnapshot.isBuildingSnapshot()) {" | ||
| 163 | - " const publicRequire =" | ||
| 164 | - " require('module').createRequire(process.cwd() + '/');" | ||
| 165 | - " globalThis.require = publicRequire;" | ||
| 166 | - "} else globalThis.require = require;" | ||
| 164 | + "const assert = require('assert');" | ||
| 165 | + "assert(require('v8').startupSnapshot.isBuildingSnapshot());" | ||
| 167 | 166 | "globalThis.embedVars = { nön_ascıı: '🏳️🌈' };" | |
| 167 | + "globalThis.require = require;" | ||
| 168 | 168 | "require('vm').runInThisContext(process.argv[2]);"); | |
| 169 | + } else { | ||
| 170 | + loadenv_ret = node::LoadEnvironment( | ||
| 171 | + env, | ||
| 172 | + "const publicRequire = require('module').createRequire(process.cwd() " | ||
| 173 | + "+ '/');" | ||
| 174 | + "globalThis.require = publicRequire;" | ||
| 175 | + "globalThis.embedVars = { nön_ascıı: '🏳️🌈' };" | ||
| 176 | + "require('vm').runInThisContext(process.argv[1]);"); | ||
| 169 | 177 | } | |
| 170 | 178 | ||
| 171 | 179 | if (loadenv_ret.IsEmpty()) // There has been a JS exception. | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -3,7 +3,10 @@ const common = require('../common'); | |||
| 3 | 3 | const fixtures = require('../common/fixtures'); | |
| 4 | 4 | const tmpdir = require('../common/tmpdir'); | |
| 5 | 5 | const assert = require('assert'); | |
| 6 | - const child_process = require('child_process'); | ||
| 6 | + const { | ||
| 7 | + spawnSyncAndExit, | ||
| 8 | + spawnSyncAndExitWithoutError, | ||
| 9 | + } = require('../common/child_process'); | ||
| 7 | 10 | const path = require('path'); | |
| 8 | 11 | const fs = require('fs'); | |
| 9 | 12 | ||
@@ -21,39 +24,54 @@ function resolveBuiltBinary(bin) { | |||
| 21 | 24 | ||
| 22 | 25 | const binary = resolveBuiltBinary('embedtest'); | |
| 23 | 26 | ||
| 24 | - assert.strictEqual( | ||
| 25 | - child_process.spawnSync(binary, ['console.log(42)']) | ||
| 26 | - .stdout.toString().trim(), | ||
| 27 | - '42'); | ||
| 28 | - | ||
| 29 | - assert.strictEqual( | ||
| 30 | - child_process.spawnSync(binary, ['console.log(embedVars.nön_ascıı)']) | ||
| 31 | - .stdout.toString().trim(), | ||
| 32 | - '🏳️🌈'); | ||
| 33 | - | ||
| 34 | - assert.strictEqual( | ||
| 35 | - child_process.spawnSync(binary, ['console.log(42)']) | ||
| 36 | - .stdout.toString().trim(), | ||
| 37 | - '42'); | ||
| 27 | + spawnSyncAndExitWithoutError( | ||
| 28 | + binary, | ||
| 29 | + ['console.log(42)'], | ||
| 30 | + { | ||
| 31 | + trim: true, | ||
| 32 | + stdout: '42', | ||
| 33 | + }); | ||
| 38 | 34 | ||
| 39 | - assert.strictEqual( | ||
| 40 | - child_process.spawnSync(binary, ['throw new Error()']).status, | ||
| 41 | - 1); | ||
| 35 | + spawnSyncAndExitWithoutError( | ||
| 36 | + binary, | ||
| 37 | + ['console.log(embedVars.nön_ascıı)'], | ||
| 38 | + { | ||
| 39 | + trim: true, | ||
| 40 | + stdout: '🏳️🌈', | ||
| 41 | + }); | ||
| 42 | 42 | ||
| 43 | - // Cannot require internals anymore: | ||
| 44 | - assert.strictEqual( | ||
| 45 | - child_process.spawnSync(binary, ['require("lib/internal/test/binding")']).status, | ||
| 46 | - 1); | ||
| 43 | + spawnSyncAndExit( | ||
| 44 | + binary, | ||
| 45 | + ['throw new Error()'], | ||
| 46 | + { | ||
| 47 | + status: 1, | ||
| 48 | + signal: null, | ||
| 49 | + }); | ||
| 47 | 50 | ||
| 48 | - assert.strictEqual( | ||
| 49 | - child_process.spawnSync(binary, ['process.exitCode = 8']).status, | ||
| 50 | - 8); | ||
| 51 | + spawnSyncAndExit( | ||
| 52 | + binary, | ||
| 53 | + ['require("lib/internal/test/binding")'], | ||
| 54 | + { | ||
| 55 | + status: 1, | ||
| 56 | + signal: null, | ||
| 57 | + }); | ||
| 51 | 58 | ||
| 59 | + spawnSyncAndExit( | ||
| 60 | + binary, | ||
| 61 | + ['process.exitCode = 8'], | ||
| 62 | + { | ||
| 63 | + status: 8, | ||
| 64 | + signal: null, | ||
| 65 | + }); | ||
| 52 | 66 | ||
| 53 | 67 | const fixturePath = JSON.stringify(fixtures.path('exit.js')); | |
| 54 | - assert.strictEqual( | ||
| 55 | - child_process.spawnSync(binary, [`require(${fixturePath})`, 92]).status, | ||
| 56 | - 92); | ||
| 68 | + spawnSyncAndExit( | ||
| 69 | + binary, | ||
| 70 | + [`require(${fixturePath})`, 92], | ||
| 71 | + { | ||
| 72 | + status: 92, | ||
| 73 | + signal: null, | ||
| 74 | + }); | ||
| 57 | 75 | ||
| 58 | 76 | function getReadFileCodeForPath(path) { | |
| 59 | 77 | return `(require("fs").readFileSync(${JSON.stringify(path)}, "utf8"))`; | |
@@ -64,31 +82,49 @@ for (const extraSnapshotArgs of [[], ['--embedder-snapshot-as-file']]) { | |||
| 64 | 82 | // readSync + eval since snapshots don't support userland require() (yet) | |
| 65 | 83 | const snapshotFixture = fixtures.path('snapshot', 'echo-args.js'); | |
| 66 | 84 | const blobPath = tmpdir.resolve('embedder-snapshot.blob'); | |
| 67 | - const buildSnapshotArgs = [ | ||
| 85 | + const buildSnapshotExecArgs = [ | ||
| 68 | 86 | `eval(${getReadFileCodeForPath(snapshotFixture)})`, 'arg1', 'arg2', | |
| 87 | + ]; | ||
| 88 | + const embedTestBuildArgs = [ | ||
| 69 | 89 | '--embedder-snapshot-blob', blobPath, '--embedder-snapshot-create', | |
| 70 | 90 | ...extraSnapshotArgs, | |
| 71 | 91 | ]; | |
| 72 | - const runEmbeddedArgs = [ | ||
| 73 | - '--embedder-snapshot-blob', blobPath, ...extraSnapshotArgs, 'arg3', 'arg4', | ||
| 92 | + const buildSnapshotArgs = [ | ||
| 93 | + ...buildSnapshotExecArgs, | ||
| 94 | + ...embedTestBuildArgs, | ||
| 95 | + ]; | ||
| 96 | + | ||
| 97 | + const runSnapshotExecArgs = [ | ||
| 98 | + 'arg3', 'arg4', | ||
| 99 | + ]; | ||
| 100 | + const embedTestRunArgs = [ | ||
| 101 | + '--embedder-snapshot-blob', blobPath, | ||
| 102 | + ...extraSnapshotArgs, | ||
| 103 | + ]; | ||
| 104 | + const runSnapshotArgs = [ | ||
| 105 | + ...runSnapshotExecArgs, | ||
| 106 | + ...embedTestRunArgs, | ||
| 74 | 107 | ]; | |
| 75 | 108 | ||
| 76 | 109 | fs.rmSync(blobPath, { force: true }); | |
| 77 | - const child = child_process.spawnSync(binary, [ | ||
| 78 | - '--', ...buildSnapshotArgs, | ||
| 79 | - ], { | ||
| 80 | - cwd: tmpdir.path, | ||
| 81 | - }); | ||
| 82 | - if (child.status !== 0) { | ||
| 83 | - console.log(child.stderr.toString()); | ||
| 84 | - console.log(child.stdout.toString()); | ||
| 85 | - } | ||
| 86 | - assert.strictEqual(child.status, 0); | ||
| 87 | - const spawnResult = child_process.spawnSync(binary, ['--', ...runEmbeddedArgs]); | ||
| 88 | - assert.deepStrictEqual(JSON.parse(spawnResult.stdout), { | ||
| 89 | - originalArgv: [binary, ...buildSnapshotArgs], | ||
| 90 | - currentArgv: [binary, ...runEmbeddedArgs], | ||
| 91 | - }); | ||
| 110 | + spawnSyncAndExitWithoutError( | ||
| 111 | + binary, | ||
| 112 | + [ '--', ...buildSnapshotArgs ], | ||
| 113 | + { cwd: tmpdir.path }, | ||
| 114 | + {}); | ||
| 115 | + spawnSyncAndExitWithoutError( | ||
| 116 | + binary, | ||
| 117 | + [ '--', ...runSnapshotArgs ], | ||
| 118 | + { cwd: tmpdir.path }, | ||
| 119 | + { | ||
| 120 | + stdout(output) { | ||
| 121 | + assert.deepStrictEqual(JSON.parse(output), { | ||
| 122 | + originalArgv: [binary, '__node_anonymous_main', ...buildSnapshotExecArgs], | ||
| 123 | + currentArgv: [binary, ...runSnapshotExecArgs], | ||
| 124 | + }); | ||
| 125 | + return true; | ||
| 126 | + }, | ||
| 127 | + }); | ||
| 92 | 128 | } | |
| 93 | 129 | ||
| 94 | 130 | // Create workers and vm contexts after deserialization | |
@@ -99,14 +135,20 @@ for (const extraSnapshotArgs of [[], ['--embedder-snapshot-as-file']]) { | |||
| 99 | 135 | `eval(${getReadFileCodeForPath(snapshotFixture)})`, | |
| 100 | 136 | '--embedder-snapshot-blob', blobPath, '--embedder-snapshot-create', | |
| 101 | 137 | ]; | |
| 138 | + const runEmbeddedArgs = [ | ||
| 139 | + '--embedder-snapshot-blob', blobPath, | ||
| 140 | + ]; | ||
| 102 | 141 | ||
| 103 | 142 | fs.rmSync(blobPath, { force: true }); | |
| 104 | - assert.strictEqual(child_process.spawnSync(binary, [ | ||
| 105 | - '--', ...buildSnapshotArgs, | ||
| 106 | - ], { | ||
| 107 | - cwd: tmpdir.path, | ||
| 108 | - }).status, 0); | ||
| 109 | - assert.strictEqual( | ||
| 110 | - child_process.spawnSync(binary, ['--', '--embedder-snapshot-blob', blobPath]).status, | ||
| 111 | - 0); | ||
| 143 | + | ||
| 144 | + spawnSyncAndExitWithoutError( | ||
| 145 | + binary, | ||
| 146 | + [ '--', ...buildSnapshotArgs ], | ||
| 147 | + { cwd: tmpdir.path }, | ||
| 148 | + {}); | ||
| 149 | + spawnSyncAndExitWithoutError( | ||
| 150 | + binary, | ||
| 151 | + [ '--', ...runEmbeddedArgs ], | ||
| 152 | + { cwd: tmpdir.path }, | ||
| 153 | + {}); | ||
| 112 | 154 | } | |
| Back | FazBrowse Home | New Git URL |
0 commit comments