add async to funcs that need to block in WAST tests

This anticipates the forthcoming changes to WIT/CM async and helps us get CI
green for bytecodealliance/wasmtime#12043

Signed-off-by: Joel Dice <[email protected]>

Author: dicej

test/async/async-calls-sync.wast

@@ -53,18 +53,18 @@
       (export "context.set" (func $context.set))
       (export "context.get" (func $context.get))
     ))))
-    (func (export "blocking-call") (result u32) (canon lift
+    (func (export "blocking-call") async (result u32) (canon lift
       (core func $core_async_inner "blocking-call")
       async (callback (func $core_async_inner "blocking-call-cb"))
     ))
-    (func (export "unblock") (canon lift
+    (func (export "unblock") async (canon lift
       (core func $core_async_inner "unblock")
       async (callback (func $core_async_inner "unblock-cb"))
     ))
   )
 
   (component $SyncMiddle
-    (import "blocking-call" (func $blocking-call (result u32)))
+    (import "blocking-call" (func $blocking-call async (result u32)))
     (core module $CoreSyncMiddle
       (import "" "blocking-call" (func $blocking-call (result i32)))
       (func $sync-func (export "sync-func") (result i32)
@@ -75,13 +75,13 @@
     (core instance $core_sync_middle (instantiate $CoreSyncMiddle (with "" (instance
       (export "blocking-call" (func $blocking-call'))
     ))))
-    (func (export "sync-func") (result u32) (canon lift
+    (func (export "sync-func") async (result u32) (canon lift
       (core func $core_sync_middle "sync-func")
     ))
   )
 
   (component $AsyncMiddle
-    (import "blocking-call" (func $blocking-call (result u32)))
+    (import "blocking-call" (func $blocking-call async (result u32)))
     (core module $CoreSyncMiddle
       (import "" "task.return" (func $task.return (param i32)))
       (import "" "blocking-call" (func $blocking-call (result i32)))
@@ -99,16 +99,16 @@
       (export "task.return" (func $task.return))
       (export "blocking-call" (func $blocking-call'))
     ))))
-    (func (export "sync-func") (result u32) (canon lift
+    (func (export "sync-func") async (result u32) (canon lift
       (core func $core_sync_middle "sync-func")
       async (callback (func $core_sync_middle "sync-func-cb"))
     ))
   )
 
   (component $AsyncOuter
-    (import "unblock" (func $unblock))
-    (import "sync-func1" (func $sync-func1 (result u32)))
-    (import "sync-func2" (func $sync-func2 (result u32)))
+    (import "unblock" (func $unblock async))
+    (import "sync-func1" (func $sync-func1 async (result u32)))
+    (import "sync-func2" (func $sync-func2 async (result u32)))
 
     (core module $Memory (memory (export "mem") 1))
     (core instance $memory (instantiate $Memory))
@@ -219,7 +219,7 @@
       (export "sync-func1" (func $sync-func1'))
       (export "sync-func2" (func $sync-func2'))
     ))))
-    (func (export "run") (result u32) (canon lift
+    (func (export "run") async (result u32) (canon lift
       (core func $em "run")
       async (callback (func $em "run-cb"))
     ))

test/async/cancel-stream.wast

@@ -81,20 +81,20 @@
       (export "stream.cancel-write" (func $stream.cancel-write))
       (export "stream.drop-writable" (func $stream.drop-writable))
     ))))
-    (func (export "start-stream") (result (stream u8)) (canon lift (core func $cm "start-stream")))
-    (func (export "write4") (canon lift (core func $cm "write4")))
-    (func (export "write4-and-drop") (canon lift (core func $cm "write4-and-drop")))
-    (func (export "start-blocking-write") (canon lift (core func $cm "start-blocking-write")))
-    (func (export "cancel-after-read4") (canon lift (core func $cm "cancel-after-read4")))
+    (func (export "start-stream") async (result (stream u8)) (canon lift (core func $cm "start-stream")))
+    (func (export "write4") async (canon lift (core func $cm "write4")))
+    (func (export "write4-and-drop") async (canon lift (core func $cm "write4-and-drop")))
+    (func (export "start-blocking-write") async (canon lift (core func $cm "start-blocking-write")))
+    (func (export "cancel-after-read4") async (canon lift (core func $cm "cancel-after-read4")))
   )
 
   (component $D
     (import "c" (instance $c
-      (export "start-stream" (func (result (stream u8))))
-      (export "write4" (func))
-      (export "write4-and-drop" (func))
-      (export "start-blocking-write" (func))
-      (export "cancel-after-read4" (func))
+      (export "start-stream" (func async (result (stream u8))))
+      (export "write4" (func async))
+      (export "write4-and-drop" (func async))
+      (export "start-blocking-write" (func async))
+      (export "cancel-after-read4" (func async))
     ))
 
     (core module $Memory (memory (export "mem") 1))
@@ -192,7 +192,7 @@
       (export "start-blocking-write" (func $start-blocking-write'))
       (export "cancel-after-read4" (func $cancel-after-read4'))
     ))))
-    (func (export "run") (result u32) (canon lift (core func $dm "run")))
+    (func (export "run") async (result u32) (canon lift (core func $dm "run")))
   )
 
   (instance $c (instantiate $C))

test/async/cancel-subtask.wast

@@ -70,19 +70,19 @@
       (export "waitable-set.new" (func $waitable-set.new))
       (export "waitable-set.wait" (func $waitable-set.wait))
     ))))
-    (func (export "f") (result u32) (canon lift
+    (func (export "f") async (result u32) (canon lift
       (core func $cm "f")
       async (callback (func $cm "f_cb"))
     ))
-    (func (export "g") (param "fut" $FT) (result u32) (canon lift
+    (func (export "g") async (param "fut" $FT) (result u32) (canon lift
       (core func $cm "g")
     ))
   )
 
   (component $D
     (type $FT (future))
-    (import "f" (func $f (result u32)))
-    (import "g" (func $g (param "fut" $FT) (result u32)))
+    (import "f" (func $f async (result u32)))
+    (import "g" (func $g async (param "fut" $FT) (result u32)))
 
     (core module $Memory (memory (export "mem") 1))
     (core instance $memory (instantiate $Memory))
@@ -188,7 +188,7 @@
       (export "f" (func $f'))
       (export "g" (func $g'))
     ))))
-    (func (export "run") (result u32) (canon lift (core func $dm "run")))
+    (func (export "run") async (result u32) (canon lift (core func $dm "run")))
   )
 
   (instance $c (instantiate $C))

test/async/deadlock.wast

@@ -24,14 +24,14 @@
       (export "mem" (memory $memory "mem"))
       (export "waitable-set.new" (func $waitable-set.new))
     ))))
-    (func (export "f") (result u32) (canon lift
+    (func (export "f") async (result u32) (canon lift
       (core func $cm "f")
       async (memory $memory "mem") (callback (func $cm "cb"))
     ))
   )
 
   (component $D
-    (import "f" (func $f (result u32)))
+    (import "f" (func $f async (result u32)))
 
     (core module $Memory (memory (export "mem") 1))
     (core instance $memory (instantiate $Memory))
@@ -63,7 +63,7 @@
       (export "waitable-set.wait" (func $waitable-set.wait))
       (export "f" (func $f'))
     ))))
-    (func (export "f") (result u32) (canon lift (core func $dm "g")))
+    (func (export "f") async (result u32) (canon lift (core func $dm "g")))
   )
 
   (instance $c (instantiate $C))

test/async/drop-subtask.wast

@@ -39,19 +39,19 @@
       (export "mem" (memory $memory "mem"))
       (export "task.return" (func $task.return))
     ))))
-    (func (export "loop") (canon lift
+    (func (export "loop") async (canon lift
       (core func $core_looper "loop")
       async (callback (func $core_looper "loop_cb"))
     ))
-    (func (export "return") (canon lift
+    (func (export "return") async (canon lift
       (core func $core_looper "return")
     ))
   )
 
   (component $Caller
     (import "looper" (instance $looper
-      (export "loop" (func))
-      (export "return" (func))
+      (export "loop" (func async))
+      (export "return" (func async))
     ))
 
     (core module $Memory (memory (export "mem") 1))
@@ -122,10 +122,10 @@
       (export "loop" (func $loop'))
       (export "return" (func $return'))
     ))))
-    (func (export "drop-after-return") (result u32) (canon lift
+    (func (export "drop-after-return") async (result u32) (canon lift
       (core func $core_caller "drop-after-return")
     ))
-    (func (export "drop-before-return") (result u32) (canon lift
+    (func (export "drop-before-return") async (result u32) (canon lift
       (core func $core_caller "drop-before-return")
     ))
   )

test/async/drop-waitable-set.wast

@@ -31,20 +31,20 @@
       (export "waitable-set.new" (func $waitable-set.new))
       (export "waitable-set.drop" (func $waitable-set.drop))
     ))))
-    (func (export "wait-on-set") (canon lift
+    (func (export "wait-on-set") async (canon lift
       (core func $core "wait-on-set")
       async (callback (func $core "unreachable-cb"))
     ))
-    (func (export "drop-while-waiting") (canon lift
+    (func (export "drop-while-waiting") async (canon lift
       (core func $core "drop-while-waiting")
       async (callback (func $core "unreachable-cb"))
     ))
   )
 
   (component $D
     (import "c" (instance $c
-      (export "wait-on-set" (func))
-      (export "drop-while-waiting" (func))
+      (export "wait-on-set" (func async))
+      (export "drop-while-waiting" (func async))
     ))
 
     (core module $Memory (memory (export "mem") 1))
@@ -74,7 +74,7 @@
       (export "wait-on-set" (func $wait-on-set'))
       (export "drop-while-waiting" (func $drop-while-waiting'))
     ))))
-    (func (export "run") (result u32) (canon lift (core func $core "run")))
+    (func (export "run") async (result u32) (canon lift (core func $core "run")))
   )
 
   (instance $c (instantiate $C))

test/async/empty-wait.wast

@@ -102,20 +102,20 @@
       (export "future.drop-readable" (func $future.drop-readable))
       (export "future.drop-writable" (func $future.drop-writable))
     ))))
-    (func (export "blocker") (result u32) (canon lift
+    (func (export "blocker") async (result u32) (canon lift
       (core func $cm "blocker")
       async (callback (func $cm "blocker_cb"))
     ))
-    (func (export "unblocker") (result u32) (canon lift
+    (func (export "unblocker") async (result u32) (canon lift
       (core func $cm "unblocker")
       async (callback (func $cm "unblocker_cb"))
     ))
   )
 
   (component $D
     (import "c" (instance $c
-      (export "blocker" (func (result u32)))
-      (export "unblocker" (func (result u32)))
+      (export "blocker" (func async (result u32)))
+      (export "unblocker" (func async (result u32)))
     ))
 
     (core module $Memory (memory (export "mem") 1))
@@ -189,7 +189,7 @@
       (export "blocker" (func $blocker'))
       (export "unblocker" (func $unblocker'))
     ))))
-    (func (export "run") (result u32) (canon lift (core func $dm "run")))
+    (func (export "run") async (result u32) (canon lift (core func $dm "run")))
   )
 
   (instance $c (instantiate $C))

test/async/partial-stream-copies.wast

@@ -121,14 +121,14 @@
       (export "stream.drop-readable" (func $stream.drop-readable))
       (export "stream.drop-writable" (func $stream.drop-writable))
     ))))
-    (func (export "transform") (param "in" (stream u8)) (result (stream u8)) (canon lift
+    (func (export "transform") async (param "in" (stream u8)) (result (stream u8)) (canon lift
       (core func $cm "transform")
       async (memory $memory "mem") (callback (func $cm "transform_cb"))
     ))
   )
 
   (component $D
-    (import "transform" (func $transform (param "in" (stream u8)) (result (stream u8))))
+    (import "transform" (func $transform async (param "in" (stream u8)) (result (stream u8))))
 
     (core module $Memory (memory (export "mem") 1))
     (core instance $memory (instantiate $Memory))
@@ -228,7 +228,7 @@
       (export "stream.drop-writable" (func $stream.drop-writable))
       (export "transform" (func $transform'))
     ))))
-    (func (export "run") (result u32) (canon lift (core func $dm "run")))
+    (func (export "run") async (result u32) (canon lift (core func $dm "run")))
   )
 
   (instance $c (instantiate $C))

test/async/passing-resources.wast

@@ -91,18 +91,18 @@
       (export "stream.drop-writable" (func $stream.drop-writable))
     ))))
     (export $R' "R" (type $R))
-    (func (export "[method]R.foo") (param "self" (borrow $R')) (result u32) (canon lift (core func $core "R.foo")))
-    (func (export "start-stream") (result (stream (own $R'))) (canon lift (core func $core "start-stream")))
-    (func (export "cancel-write") (canon lift (core func $core "cancel-write")))
-    (func (export "fail-accessing-res1") (canon lift (core func $core "fail-accessing-res1")))
+    (func (export "[method]R.foo") async (param "self" (borrow $R')) (result u32) (canon lift (core func $core "R.foo")))
+    (func (export "start-stream") async (result (stream (own $R'))) (canon lift (core func $core "start-stream")))
+    (func (export "cancel-write") async (canon lift (core func $core "cancel-write")))
+    (func (export "fail-accessing-res1") async (canon lift (core func $core "fail-accessing-res1")))
   )
 
   (component $Consumer
     (import "producer" (instance $producer
       (export "R" (type $R (sub resource)))
-      (export "[method]R.foo" (func (param "self" (borrow $R)) (result u32)))
-      (export "start-stream" (func (result (stream (own $R)))))
-      (export "cancel-write" (func))
+      (export "[method]R.foo" (func async (param "self" (borrow $R)) (result u32)))
+      (export "start-stream" (func async (result (stream (own $R)))))
+      (export "cancel-write" (func async))
     ))
 
     (core module $Memory (memory (export "mem") 1))
@@ -162,7 +162,7 @@
       (export "start-stream" (func $start-stream'))
       (export "cancel-write" (func $cancel-write'))
     ))))
-    (func (export "run") (result u32) (canon lift
+    (func (export "run") async (result u32) (canon lift
       (core func $core "run")
     ))
   )

test/async/trap-if-done.wast

@@ -115,25 +115,25 @@
       (export "stream.write" (func $stream.write))
       (export "stream.drop-writable" (func $stream.drop-writable))
     ))))
-    (func (export "start-future") (result (future u8)) (canon lift (core func $cm "start-future")))
-    (func (export "future-write") (result u32) (canon lift (core func $cm "future-write")))
-    (func (export "acknowledge-future-write") (canon lift (core func $cm "acknowledge-future-write")))
-    (func (export "future-drop-writable") (canon lift (core func $cm "future-drop-writable")))
-    (func (export "start-stream") (result (stream u8)) (canon lift (core func $cm "start-stream")))
-    (func (export "stream-write") (result u32) (canon lift (core func $cm "stream-write")))
-    (func (export "acknowledge-stream-write") (canon lift (core func $cm "acknowledge-stream-write")))
-    (func (export "stream-drop-writable") (canon lift (core func $cm "stream-drop-writable")))
+    (func (export "start-future") async (result (future u8)) (canon lift (core func $cm "start-future")))
+    (func (export "future-write") async (result u32) (canon lift (core func $cm "future-write")))
+    (func (export "acknowledge-future-write") async (canon lift (core func $cm "acknowledge-future-write")))
+    (func (export "future-drop-writable") async (canon lift (core func $cm "future-drop-writable")))
+    (func (export "start-stream") async (result (stream u8)) (canon lift (core func $cm "start-stream")))
+    (func (export "stream-write") async (result u32) (canon lift (core func $cm "stream-write")))
+    (func (export "acknowledge-stream-write") async (canon lift (core func $cm "acknowledge-stream-write")))
+    (func (export "stream-drop-writable") async (canon lift (core func $cm "stream-drop-writable")))
   )
   (component $D
     (import "c" (instance $c
-      (export "start-future" (func (result (future u8))))
-      (export "future-write" (func (result u32)))
-      (export "acknowledge-future-write" (func))
-      (export "future-drop-writable" (func))
-      (export "start-stream" (func (result (stream u8))))
-      (export "stream-write" (func (result u32)))
-      (export "acknowledge-stream-write" (func))
-      (export "stream-drop-writable" (func))
+      (export "start-future" (func async (result (future u8))))
+      (export "future-write" (func async (result u32)))
+      (export "acknowledge-future-write" (func async))
+      (export "future-drop-writable" (func async))
+      (export "start-stream" (func async (result (stream u8))))
+      (export "stream-write" (func async (result u32)))
+      (export "acknowledge-stream-write" (func async))
+      (export "stream-drop-writable" (func async))
     ))
 
     (core module $Memory (memory (export "mem") 1))
@@ -417,15 +417,15 @@
       (export "acknowledge-stream-write" (func $acknowledge-stream-write'))
       (export "stream-drop-writable" (func $stream-drop-writable'))
     ))))
-    (func (export "trap-after-future-eager-write") (canon lift (core func $core "trap-after-future-eager-write")))
-    (func (export "trap-after-future-async-write") (canon lift (core func $core "trap-after-future-async-write")))
-    (func (export "trap-after-future-reader-dropped") (canon lift (core func $core "trap-after-future-reader-dropped")))
-    (func (export "trap-after-future-eager-read") (param "bool" bool) (result $FT) (canon lift (core func $core "trap-after-future-eager-read")))
-    (func (export "trap-after-future-async-read") (param "bool" bool) (result $FT) (canon lift (core func $core "trap-after-future-async-read")))
-    (func (export "trap-after-stream-reader-eager-dropped") (canon lift (core func $core "trap-after-stream-reader-eager-dropped")))
-    (func (export "trap-after-stream-reader-async-dropped") (canon lift (core func $core "trap-after-stream-reader-async-dropped")))
-    (func (export "trap-after-stream-writer-eager-dropped") (param "bool" bool) (result $ST) (canon lift (core func $core "trap-after-stream-writer-eager-dropped")))
-    (func (export "trap-after-stream-writer-async-dropped") (param "bool" bool) (result $ST) (canon lift (core func $core "trap-after-stream-writer-async-dropped")))
+    (func (export "trap-after-future-eager-write") async (canon lift (core func $core "trap-after-future-eager-write")))
+    (func (export "trap-after-future-async-write") async (canon lift (core func $core "trap-after-future-async-write")))
+    (func (export "trap-after-future-reader-dropped") async (canon lift (core func $core "trap-after-future-reader-dropped")))
+    (func (export "trap-after-future-eager-read") async (param "bool" bool) (result $FT) (canon lift (core func $core "trap-after-future-eager-read")))
+    (func (export "trap-after-future-async-read") async (param "bool" bool) (result $FT) (canon lift (core func $core "trap-after-future-async-read")))
+    (func (export "trap-after-stream-reader-eager-dropped") async (canon lift (core func $core "trap-after-stream-reader-eager-dropped")))
+    (func (export "trap-after-stream-reader-async-dropped") async (canon lift (core func $core "trap-after-stream-reader-async-dropped")))
+    (func (export "trap-after-stream-writer-eager-dropped") async (param "bool" bool) (result $ST) (canon lift (core func $core "trap-after-stream-writer-eager-dropped")))
+    (func (export "trap-after-stream-writer-async-dropped") async (param "bool" bool) (result $ST) (canon lift (core func $core "trap-after-stream-writer-async-dropped")))
   )
   (instance $c (instantiate $C))
   (instance $d (instantiate $D (with "c" (instance $c))))