blob: 18d58fb3c8bca75f18e53feaf88031ee8fae513a [file] [log] [blame]
// Copyright (c) 2020, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
import "dart:io";
import "package:async_helper/async_minitest.dart";
void generateIsolateSource(String filePath, String version) {
File isolateSource = new File("$filePath");
isolateSource.writeAsStringSync('''
// @dart=$version
library SpawnUriIsolate;
main(List<String> args, replyTo) {
var data = args[0];
try {
int x = null as int;
replyTo.send(\'re: weak\');
} catch (ex) {
replyTo.send(\'re: strong\');
}
}
''');
}
void generateOutput(String sourcePath, String outPath, String type) {
var exec = Platform.resolvedExecutable;
var args = <String>[];
args.add("--snapshot-kind=$type");
args.add("--snapshot=$outPath");
args.add(sourcePath);
var result = Process.runSync(exec, args);
}
void generateKernel(String sourcePath, String outPath) {
generateOutput(sourcePath, outPath, "kernel");
}
void generateAppJIT(String sourcePath, String outPath) {
generateOutput(sourcePath, outPath, "app-jit");
}
void testNullSafetyMode(
String filePath, String version, String uri, String expected) {
File mainIsolate = new File(filePath);
mainIsolate.writeAsStringSync('''
// @dart=$version
library spawn_tests;
import \'dart:isolate\';
void main() async {
const String debugName = \'spawnedIsolate\';
final exitPort = ReceivePort();
final port = new ReceivePort();
port.listen((msg) {
print(msg);
port.close();
});
final isolate = await Isolate.spawnUri(
Uri.parse(\'$uri\'),
[\'re: hi\'],
port.sendPort,
paused: false,
debugName: debugName,
onExit: exitPort.sendPort);
// Explicitly await spawned isolate exit to enforce main isolate not
// completing (and the stand-alone runtime exiting) before the spawned
// isolate is done.
await exitPort.first;
}
''');
var exec = Platform.resolvedExecutable;
var args = <String>[];
args.add(mainIsolate.path);
var result = Process.runSync(exec, args);
expect(result.stdout.contains('$expected'), true);
}