Index: lib/src/runner/vm/isolate_test.dart |
diff --git a/lib/src/runner/vm/isolate_test.dart b/lib/src/runner/vm/isolate_test.dart |
deleted file mode 100644 |
index c0aae7fff1e88606110c0527df8b6559a4f89ca4..0000000000000000000000000000000000000000 |
--- a/lib/src/runner/vm/isolate_test.dart |
+++ /dev/null |
@@ -1,93 +0,0 @@ |
-// Copyright (c) 2015, 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:async'; |
-import 'dart:isolate'; |
- |
-import '../../backend/group.dart'; |
-import '../../backend/live_test.dart'; |
-import '../../backend/live_test_controller.dart'; |
-import '../../backend/metadata.dart'; |
-import '../../backend/operating_system.dart'; |
-import '../../backend/state.dart'; |
-import '../../backend/suite.dart'; |
-import '../../backend/test.dart'; |
-import '../../backend/test_platform.dart'; |
-import '../../util/remote_exception.dart'; |
-import '../../utils.dart'; |
- |
-/// A test in another isolate. |
-class IsolateTest extends Test { |
- final String name; |
- final Metadata metadata; |
- |
- /// The port on which to communicate with the remote test. |
- final SendPort _sendPort; |
- |
- IsolateTest(this.name, this.metadata, this._sendPort); |
- |
- LiveTest load(Suite suite, {Iterable<Group> groups}) { |
- var controller; |
- |
- // We get a new send port for communicating with the live test, since |
- // [_sendPort] is only for communicating with the non-live test. This will |
- // be non-null once the test starts running. |
- var sendPortCompleter; |
- |
- var receivePort; |
- controller = new LiveTestController(suite, this, () { |
- controller.setState(const State(Status.running, Result.success)); |
- |
- sendPortCompleter = new Completer(); |
- receivePort = new ReceivePort(); |
- _sendPort.send({ |
- 'command': 'run', |
- 'reply': receivePort.sendPort |
- }); |
- |
- receivePort.listen((message) { |
- if (message['type'] == 'started') { |
- sendPortCompleter.complete(message['reply']); |
- } else if (message['type'] == 'error') { |
- var asyncError = RemoteException.deserialize(message['error']); |
- controller.addError(asyncError.error, asyncError.stackTrace); |
- } else if (message['type'] == 'state-change') { |
- controller.setState( |
- new State( |
- new Status.parse(message['status']), |
- new Result.parse(message['result']))); |
- } else if (message['type'] == 'print') { |
- controller.print(message['line']); |
- } else { |
- assert(message['type'] == 'complete'); |
- controller.completer.complete(); |
- } |
- }); |
- }, () { |
- // If the test has finished running, just disconnect the receive port. The |
- // Dart process won't terminate if there are any live receive ports open. |
- if (controller.completer.isCompleted) { |
- receivePort.close(); |
- return; |
- } |
- |
- invoke(() async { |
- // If the test is still running, send it a message telling it to shut |
- // down ASAP. This causes the [Invoker] to eagerly throw exceptions |
- // whenever the test touches it. |
- var sendPort = await sendPortCompleter.future; |
- sendPort.send({'command': 'close'}); |
- await controller.completer.future; |
- receivePort.close(); |
- }); |
- }, groups: groups); |
- return controller.liveTest; |
- } |
- |
- Test forPlatform(TestPlatform platform, {OperatingSystem os}) { |
- if (!metadata.testOn.evaluate(platform, os: os)) return null; |
- return new IsolateTest( |
- name, metadata.forPlatform(platform, os: os), _sendPort); |
- } |
-} |