trap if sync->async call fails to produce a result

If the callee returns `CallbackCode.WAIT` and the event loop runs out of futures
without producing a ready waitable, we should trap.  We were doing that in other
contexts, but not for sync->async calls.

Fixes #73

Signed-off-by: Joel Dice <joel.dice@fermyon.com>

Author: dicej

crates/wasmtime/src/runtime/component/concurrent.rs

@@ -890,7 +890,7 @@ impl ComponentInstance {
                         Ok(())
                     } else {
                         // In this case, the fiber suspended while holding on to its
-                        // `*mut dyn VMStoret` instead of returning it to us.  That
+                        // `*mut dyn VMStore` instead of returning it to us.  That
                         // means we can't do anything else with the store (or self)
                         // for now; the only thing we can do is suspend _our_ fiber
                         // back up to the top level executor, which will resume us
@@ -1542,13 +1542,11 @@ impl ComponentInstance {
                     }
                     let task = instance.guest_task().unwrap();
                     if let ResultInfo::Stack { result_count } = &result_info {
-                        match result_count {
-                            0 => {}
-                            1 => {
-                                instance.get_mut(task)?.sync_result = Some(my_src[0]);
-                            }
+                        instance.get_mut(task)?.sync_result = Some(match result_count {
+                            0 => None,
+                            1 => Some(my_src[0]),
                             _ => unreachable!(),
-                        }
+                        })
                     }
                     if old_task_rep.is_some() {
                         let waitable = Waitable::Guest(task);
@@ -1576,11 +1574,6 @@ impl ComponentInstance {
 
         if let Some(old_task) = old_task {
             self.get_mut(old_task)?.subtasks.insert(guest_task);
-            log::trace!(
-                "new guest task child of {}: {}",
-                old_task.rep(),
-                guest_task.rep()
-            );
         };
 
         *self.guest_task() = Some(guest_task);
@@ -1714,7 +1707,11 @@ impl ComponentInstance {
 
         if let Some(storage) = storage {
             if let Some(result) = self.get_mut(guest_task)?.sync_result.take() {
-                storage[0] = MaybeUninit::new(result);
+                if let Some(result) = result {
+                    storage[0] = MaybeUninit::new(result);
+                }
+            } else {
+                return Err(anyhow!(crate::Trap::NoAsyncResult));
             }
             Ok(0)
         } else {
@@ -2892,7 +2889,7 @@ struct GuestTask {
     deferred: Deferred,
     should_yield: bool,
     call_context: Option<CallContext>,
-    sync_result: Option<ValRaw>,
+    sync_result: Option<Option<ValRaw>>,
     has_suspended: bool,
     context: [u32; 2],
     subtasks: HashSet<TableId<GuestTask>>,

tests/misc_testsuite/component-model-async/fused.wast

@@ -51,8 +51,7 @@
   (func (export "run") (alias export $lowerer "run"))
 )
 
-;; TODO: this requires async support in `wasmtime-wast`:
-;;(assert_return (invoke "run"))
+(assert_return (invoke "run"))
 
 ;; async lower -> async lift with callback
 (component
@@ -105,8 +104,7 @@
   (func (export "run") (alias export $lowerer "run"))
 )
 
-;; TODO: this requires async support in `wasmtime-wast`:
-;;(assert_return (invoke "run"))
+(assert_return (invoke "run"))
 
 ;; async lower -> sync lift
 (component
@@ -152,8 +150,7 @@
   (func (export "run") (alias export $lowerer "run"))
 )
 
-;; TODO: this requires async support in `wasmtime-wast`:
-;;(assert_return (invoke "run"))
+(assert_return (invoke "run"))
 
 ;; sync lower -> async lift without callback
 (component
@@ -196,8 +193,7 @@
   (func (export "run") (alias export $lowerer "run"))
 )
 
-;; TODO: this requires async support in `wasmtime-wast`:
-;;(assert_return (invoke "run"))
+(assert_return (invoke "run"))
 
 ;; sync lower -> async lift with callback
 (component
@@ -244,5 +240,4 @@
   (func (export "run") (alias export $lowerer "run"))
 )
 
-;; TODO: this requires async support in `wasmtime-wast`:
-;;(assert_return (invoke "run"))
+(assert_return (invoke "run"))