languages/dart-sdk
languages/dart-sdk
1
0
Fork 0
mirror of https://github.com/dart-lang/sdk synced 2024-11-02 15:01:30 +00:00
Code Issues Projects Releases Packages Wiki Activity

[vm] Deflake async callbacks test

Browse source 
Change-Id: Ia12ac5380f90760a23297b449d24e324f6156daa
Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/311800
Auto-Submit: Liam Appelbe <liama@google.com>
Commit-Queue: Liam Appelbe <liama@google.com>
Reviewed-by: Daco Harkes <dacoharkes@google.com>
Commit-Queue: Daco Harkes <dacoharkes@google.com>
This commit is contained in:
Liam Appelbe 2023-06-28 10:26:21 +00:00 committed by Commit Queue
parent 53c9cf1c46
commit c3a532bc36
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
tests/ffi/async_void_function_callbacks_test.dart
View file

@ -310,7 +310,7 @@ class ManyCallsBetweenIsolates extends TestCase {
@override
Future<void> runOnIsoA(IsolateA iso) async {
print("ManyCallsBetweenIsolates.runOnIsoA sending messages.");
await Future.wait(List.filled(1000, null).map((_) async {
await Future.wait(List.filled(100, null).map((_) async {
final result = iso.atm.call((responseId) => iso.natLib
.callFunctionOnSameThread(
responseId, Pointer.fromAddress(iso.fnPtrsB.addGlobalVarPtr)));
@ -321,7 +321,7 @@ class ManyCallsBetweenIsolates extends TestCase {
@override
Future<void> runOnIsoB(IsolateB iso) async {
print("ManyCallsBetweenIsolates.runOnIsoB sending messages.");
await Future.wait(List.filled(1000, null).map((_) async {
await Future.wait(List.filled(100, null).map((_) async {
final result = iso.atm.call((responseId) => iso.natLib
.callFunctionOnSameThread(
responseId, Pointer.fromAddress(iso.fnPtrsA.addGlobalVarPtr)));
@ -341,7 +341,7 @@ class ManyCallsBetweenIsolatesViaNewThreadBlocking extends TestCase {
Future<void> runOnIsoA(IsolateA iso) async {
print(
"ManyCallsBetweenIsolatesViaNewThreadBlocking.runOnIsoA sending messages.");
await Future.wait(List.filled(1000, null).map((_) async {
await Future.wait(List.filled(100, null).map((_) async {
final result = iso.atm.call((responseId) => iso.natLib
.callFunctionOnNewThreadBlocking(
responseId, Pointer.fromAddress(iso.fnPtrsB.addGlobalVarPtr)));
@ -353,7 +353,7 @@ class ManyCallsBetweenIsolatesViaNewThreadBlocking extends TestCase {
Future<void> runOnIsoB(IsolateB iso) async {
print(
"ManyCallsBetweenIsolatesViaNewThreadBlocking.runOnIsoB sending messages.");
await Future.wait(List.filled(1000, null).map((_) async {
await Future.wait(List.filled(100, null).map((_) async {
final result = iso.atm.call((responseId) => iso.natLib
.callFunctionOnNewThreadBlocking(
responseId, Pointer.fromAddress(iso.fnPtrsA.addGlobalVarPtr)));
@ -373,7 +373,7 @@ class ManyCallsBetweenIsolatesViaNewThreadNonBlocking extends TestCase {
Future<void> runOnIsoA(IsolateA iso) async {
print(
"ManyCallsBetweenIsolatesViaNewThreadNonBlocking.runOnIsoA sending messages.");
await Future.wait(List.filled(1000, null).map((_) async {
await Future.wait(List.filled(100, null).map((_) async {
final result = iso.atm.call((responseId) => iso.natLib
.callFunctionOnNewThreadNonBlocking(
responseId, Pointer.fromAddress(iso.fnPtrsB.addGlobalVarPtr)));
@ -385,7 +385,7 @@ class ManyCallsBetweenIsolatesViaNewThreadNonBlocking extends TestCase {
Future<void> runOnIsoB(IsolateB iso) async {
print(
"ManyCallsBetweenIsolatesViaNewThreadNonBlocking.runOnIsoB sending messages.");
await Future.wait(List.filled(1000, null).map((_) async {
await Future.wait(List.filled(100, null).map((_) async {
final result = iso.atm.call((responseId) => iso.natLib
.callFunctionOnNewThreadNonBlocking(
responseId, Pointer.fromAddress(iso.fnPtrsA.addGlobalVarPtr)));