| // 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:async'; |
| |
| import 'package:observatory_2/service_io.dart'; |
| import 'package:test/test.dart'; |
| |
| import 'client_resume_approvals_common.dart'; |
| import 'service_test_common.dart'; |
| import 'test_helper.dart'; |
| |
| void fooBar() { |
| int i = 0; |
| print(i); |
| } |
| |
| WebSocketVM client1; |
| WebSocketVM client2; |
| WebSocketVM client3; |
| |
| final multipleClientNamesTest = <IsolateTest>[ |
| // Multiple clients, different client names. |
| (Isolate isolate) async { |
| client1 = await createClient(isolate.owner); |
| await setRequireApprovalForResume( |
| client1, |
| isolate, |
| pauseOnStart: true, |
| pauseOnExit: true, |
| ); |
| client2 = await createClient( |
| isolate.owner, |
| clientName: otherClientName, |
| ); |
| client3 = await createClient(isolate.owner, clientName: 'DummyClient'); |
| |
| final resumeFuture = waitForResume(isolate); |
| expect(await isPausedAtStart(isolate), true); |
| await resume(client2, isolate); |
| expect(await isPausedAtStart(isolate), true); |
| await resume(client1, isolate); |
| await resumeFuture; |
| expect(await isPausedAtStart(isolate), false); |
| }, |
| hasStoppedAtExit, |
| (Isolate isolate) async { |
| await setRequireApprovalForResume( |
| client2, |
| isolate, |
| pauseOnExit: true, |
| ); |
| await resume(client1, isolate); |
| expect(await isPausedAtExit(isolate), true); |
| await resume(client2, isolate); |
| await waitForTargetVMExit(isolate.vm); |
| }, |
| ]; |
| |
| Future<void> main(args) => runIsolateTests( |
| args, |
| multipleClientNamesTest, |
| testeeConcurrent: fooBar, |
| pause_on_start: true, |
| pause_on_exit: true, |
| enableService: false, |
| ); |