| Index: runtime/observatory/test/isolate_lifecycle_test.dart
|
| diff --git a/runtime/observatory/test/isolate_lifecycle_test.dart b/runtime/observatory/test/isolate_lifecycle_test.dart
|
| deleted file mode 100644
|
| index 08a2a1bfb46149ef200f0ab06f1814cbcd3812d2..0000000000000000000000000000000000000000
|
| --- a/runtime/observatory/test/isolate_lifecycle_test.dart
|
| +++ /dev/null
|
| @@ -1,101 +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.
|
| -// VMOptions=--compile-all --error_on_bad_type --error_on_bad_override --checked
|
| -
|
| -import 'dart:async';
|
| -import 'dart:isolate' as I;
|
| -
|
| -import 'package:observatory/service_io.dart';
|
| -import 'package:unittest/unittest.dart';
|
| -
|
| -import 'test_helper.dart';
|
| -
|
| -final spawnCount = 4;
|
| -final resumeCount = spawnCount ~/ 2;
|
| -final isolates = [];
|
| -
|
| -void spawnEntry(int i) {
|
| -}
|
| -
|
| -Future before() async {
|
| - // Spawn spawnCount long lived isolates.
|
| - for (var i = 0; i < spawnCount; i++) {
|
| - var isolate = await I.Isolate.spawn(spawnEntry, i);
|
| - isolates.add(isolate);
|
| - }
|
| - print('spawned all isolates');
|
| -}
|
| -
|
| -Future during() async {
|
| -}
|
| -
|
| -var tests = [
|
| - (VM vm) async {
|
| - expect(vm.isolates.length, spawnCount + 1);
|
| - },
|
| - (VM vm) async {
|
| - // Load each isolate.
|
| - for (var isolate in vm.isolates) {
|
| - await isolate.load();
|
| - }
|
| - },
|
| - (VM vm) async {
|
| - var pausedCount = 0;
|
| - var runningCount = 0;
|
| - for (var isolate in vm.isolates) {
|
| - if (isolate.paused) {
|
| - pausedCount++;
|
| - } else {
|
| - runningCount++;
|
| - }
|
| - }
|
| - expect(pausedCount, spawnCount);
|
| - expect(runningCount, 1);
|
| - },
|
| - (VM vm) async {
|
| - var resumedReceived = 0;
|
| - var eventsDone = processServiceEvents(vm, (event, sub, completer) {
|
| - if (event.eventType == ServiceEvent.kIsolateExit) {
|
| - resumedReceived++;
|
| - if (resumedReceived == resumeCount) {
|
| - sub.cancel();
|
| - completer.complete(null);
|
| - }
|
| - }
|
| - });
|
| - var resumesIssued = 0;
|
| - var isolateList = vm.isolates.toList();
|
| - for (var isolate in isolateList) {
|
| - if (isolate.name.endsWith('main')) {
|
| - continue;
|
| - }
|
| - try {
|
| - resumesIssued++;
|
| - await isolate.resume();
|
| - } catch(_) {}
|
| - if (resumesIssued == resumeCount) {
|
| - break;
|
| - }
|
| - }
|
| - return eventsDone;
|
| - },
|
| - (VM vm) async {
|
| - var pausedCount = 0;
|
| - var runningCount = 0;
|
| - for (var isolate in vm.isolates) {
|
| - if (isolate.paused) {
|
| - pausedCount++;
|
| - } else {
|
| - runningCount++;
|
| - }
|
| - }
|
| - expect(pausedCount, spawnCount - resumeCount);
|
| - expect(runningCount, 1);
|
| - },
|
| -];
|
| -
|
| -main(args) async => runVMTests(args, tests,
|
| - testeeBefore: before,
|
| - testeeConcurrent: during,
|
| - pause_on_exit: true);
|
|
|