blob: dd2bed49a51c7a14515948813fc1235f95c367fa [file] [log] [blame]
* 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 ping(
* SendPort responsePort, {
* Object response,
* int priority: IMMEDIATE
* })
* Request that the isolate send response on the responsePort.
* If the isolate is alive, it will eventually send response (defaulting
* to null) on the response port.
* The priority must be one of IMMEDIATE or BEFORE_NEXT_EVENT. The response
* is sent at different times depending on the ping type:
* * IMMEDIATE: The isolate responds as soon as it receives the control
* message. This is after any previous control message from the same isolate
* has been received, but may be during execution of another event.
* * BEFORE_NEXT_EVENT: The response is scheduled for the next time control
* returns to the event loop of the receiving isolate, after the current event,
* and any already scheduled control events, are completed.
* If response cannot be sent to the isolate, then the request is ignored.
* It is recommended to only use simple values that can be sent to all isolates,
* like null, booleans, numbers or strings.
* @description Check that continuously running isolate never responds
* to ping() call with BEFORE_NEXT_EVENT priority.
* @author
import "dart:isolate";
import "dart:math";
import "dart:async";
import "../../../Utils/expect.dart";
import "IsolateUtil.dart";
Random random = new Random();
int s = 0;
while (true){
s = -s + random.nextInt(100);
test() async {
ReceivePort onExit = new ReceivePort();
Isolate isolate = await Isolate.spawn(
null, // message
// check
ReceivePort pingPort = new ReceivePort();, priority:Isolate.beforeNextEvent);
Future pingResponse = pingPort.first.timeout(TWO_SECONDS, onTimeout: () {
return "timeout";
Expect.equals("timeout", await pingResponse);
// clean up
await onExit.first;
main() {