Daco Harkes
38e250b4d5
Includes all the files which required no manual treatment. Change-Id: I3d493bcbc238a2016579a0f804d32f4829efb87b Cq-Include-Trybots: dart/try:vm-aot-android-release-arm_x64-try,vm-aot-linux-debug-x64-try,vm-aot-linux-debug-x64c-try,vm-aot-mac-release-arm64-try,vm-aot-mac-release-x64-try,vm-aot-win-debug-x64c-try,vm-checked-mac-release-arm64-try,vm-ffi-qemu-linux-release-arm-try,vm-ffi-qemu-linux-release-riscv64-try,vm-linux-debug-ia32-try,vm-linux-debug-x64-try,vm-linux-debug-x64c-try,vm-mac-debug-arm64-try,vm-reload-linux-debug-x64-try,vm-reload-rollback-linux-debug-x64-try,vm-win-release-ia32-try Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/399102 Reviewed-by: Bob Nystrom <rnystrom@google.com> Commit-Queue: Daco Harkes <dacoharkes@google.com>
42 lines
1.2 KiB
Dart
42 lines
1.2 KiB
Dart
// Copyright (c) 2023, 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.
|
|
|
|
// SharedObjects=ffi_test_functions
|
|
|
|
import 'dart:async';
|
|
import 'dart:isolate';
|
|
import 'dart:ffi';
|
|
|
|
import 'callback_tests_utils.dart';
|
|
|
|
typedef SimpleAdditionType = Int32 Function(Int32, Int32);
|
|
int simpleAddition(int x, int y) {
|
|
print("simpleAddition($x, $y)");
|
|
return x + y;
|
|
}
|
|
|
|
void main() async {
|
|
// The main isolate is very special and cannot be suspended (due to having an
|
|
// active api scope throughout it's lifetime), so we run this test in a helper
|
|
// isolate.
|
|
const int count = 50;
|
|
final futures = <Future>[];
|
|
for (int i = 0; i < count; ++i) {
|
|
futures.add(
|
|
Isolate.run(() async {
|
|
// First make the callback pointer.
|
|
final callbackFunctionPointer =
|
|
Pointer.fromFunction<SimpleAdditionType>(simpleAddition, 0);
|
|
|
|
// Then cause suspenion of [Thread].
|
|
await Future.delayed(const Duration(seconds: 1));
|
|
|
|
// Then make use of callback.
|
|
CallbackTest("SimpleAddition", callbackFunctionPointer).run();
|
|
}),
|
|
);
|
|
}
|
|
await Future.wait(futures);
|
|
}
|