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.1 KiB
Dart
42 lines
1.1 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.
|
|
|
|
import 'dart:ffi';
|
|
|
|
import 'dylib_utils.dart';
|
|
|
|
final ffiTestFunctions = dlopenPlatformSpecific("ffi_test_functions");
|
|
|
|
typedef NativeAsyncCallbackTest = Void Function(Pointer);
|
|
typedef NativeAsyncCallbackTestFn = void Function(Pointer);
|
|
|
|
class AsyncCallbackTest {
|
|
final String name;
|
|
final Future<void> Function() afterCallbackChecks;
|
|
|
|
// Either a NativeCallable or a Pointer.fromFunction.
|
|
final Object callback;
|
|
|
|
AsyncCallbackTest(this.name, this.callback, this.afterCallbackChecks) {}
|
|
|
|
Future<void> run() async {
|
|
final NativeAsyncCallbackTestFn tester = ffiTestFunctions
|
|
.lookupFunction<NativeAsyncCallbackTest, NativeAsyncCallbackTestFn>(
|
|
"TestAsync$name",
|
|
);
|
|
|
|
final cb = callback;
|
|
tester(cb is NativeCallable ? cb.nativeFunction : cb as Pointer);
|
|
|
|
await afterCallbackChecks();
|
|
if (cb is NativeCallable) {
|
|
cb.close();
|
|
}
|
|
}
|
|
}
|
|
|
|
void noChecks() {}
|
|
|
|
Future<void> noChecksAsync() async {}
|