// Copyright (c) 2017, 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.

/// @assertion void resume(
///                    Capability resumeCapability
///                    )
///    Resumes a paused isolate.
///    Sends a message to an isolate requesting that it ends a pause that was
/// requested using the resumeCapability.
///    When all active pause requests have been cancelled, the isolate will
/// continue processing events and handling normal messages.
///
/// @description Check that isolate continue processing events only after
/// all pause requests are canceled by call to resume()
///
/// @author a.semenov@unipro.ru

import "dart:isolate";
import "dart:async";
import "../../../Utils/expect.dart";
import "IsolateUtil.dart";

Duration _500MS = new Duration(milliseconds: 500);

Future test(List<int> resumePermutation) async {
  ReceivePort receivePort = new ReceivePort();
  EchoServer server = await EchoServer.spawn(receivePort.sendPort);

  Expect.equals("hello", await server.ping("hello"));

  List<Capability> resumeCapability = [];
  resumeCapability.add(server.isolate.pause());
  Expect.equals("timeout", await server.ping("paused0", _500MS, "timeout"));

  for (int i = 1; i < resumePermutation.length; i++) {
    resumeCapability.add(server.isolate.pause(new Capability()));
    Expect.equals("timeout", await server.ping("paused$i", _500MS, "timeout"));
  }

  int i = 0;
  while (i < resumePermutation.length - 1) {
    server.isolate.resume(resumeCapability[resumePermutation[i]]);
    Expect.equals("timeout", await server.ping("resume$i", _500MS, "timeout"));
    i++;
  }
  server.isolate.resume(resumeCapability[resumePermutation[i]]);
  Expect.equals("resume", await server.ping("resume", _500MS, "timeout"));

  Expect.equals("server", await server.ping("server"));

  await server.stop();
  receivePort.close();
}

main() {
  asyncStart();
  Future.wait([
    test([0, 1, 2, 3, 4]),
    test([4, 3, 2, 1, 0]),
    test([3, 2, 0, 1, 4]),
    test([2, 0, 3, 4, 1])
  ]).then((_) => asyncEnd());
}