TRACE wasmtime::runtime::component::concurrent: queueing call QualifiedThreadId(1, 2) TRACE wasmtime::runtime::component::concurrent: push high priority: GuestCall(GuestCall { thread: QualifiedThreadId(1, 2), kind: StartImplicit }) TRACE wasmtime::runtime::component::concurrent: handle work item GuestCall(GuestCall { thread: QualifiedThreadId(1, 2), kind: StartImplicit }) TRACE wasmtime::runtime::component::concurrent: call GuestCall { thread: QualifiedThreadId(1, 2), kind: StartImplicit } ready? true (do_not_enter: false; backpressure: 0) TRACE wasmtime::runtime::component::concurrent: resume_fiber: save current thread None TRACE wasmtime::runtime::component::concurrent: stackless call: replaced None with QualifiedThreadId(1, 2) as current thread TRACE wasmtime::runtime::component::concurrent: push call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(1, 2) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(1, 2) slot 0 val 0x1060c0 TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(1, 2) slot 0 val 0x1060c0 TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(1, 2) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent::futures_and_streams: new transmit: state TransmitState(3); write TransmitHandle(4); read TransmitHandle(5) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: new transmit: state TransmitState(6); write TransmitHandle(7); read TransmitHandle(8) TRACE wasmtime::runtime::component::concurrent: pushed GuestTask(10):GuestThread(11) as current thread; old thread was Some(QualifiedThreadId(1, 2)) TRACE wasmtime::runtime::component::concurrent: push high priority: GuestCall(GuestCall { thread: QualifiedThreadId(10, 11), kind: StartImplicit }) TRACE wasmtime::runtime::component::concurrent: waitable GuestTask(10) join set Some(WaitableSet(0)) TRACE wasmtime::runtime::component::concurrent: suspend fiber: Waiting { set: WaitableSet(0), thread: QualifiedThreadId(1, 2) } TRACE wasmtime::runtime::component::concurrent: pop call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: resume_fiber: restore current thread None TRACE wasmtime::runtime::component::concurrent: resume_fiber: suspend reason Some(Waiting { set: WaitableSet(0), thread: QualifiedThreadId(1, 2) }) TRACE wasmtime::runtime::component::concurrent: handle work item GuestCall(GuestCall { thread: QualifiedThreadId(10, 11), kind: StartImplicit }) TRACE wasmtime::runtime::component::concurrent: call GuestCall { thread: QualifiedThreadId(10, 11), kind: StartImplicit } ready? true (do_not_enter: false; backpressure: 0) TRACE wasmtime::runtime::component::concurrent: resume_fiber: save current thread None TRACE wasmtime::runtime::component::concurrent: stackless call: replaced None with QualifiedThreadId(10, 11) as current thread TRACE wasmtime::runtime::component::concurrent: push call context for GuestTask(10) TRACE wasmtime::runtime::component::concurrent: set event for GuestTask(10): Some(Subtask { status: Started }) TRACE wasmtime::runtime::component::concurrent: push high priority: ResumeFiber TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(10, 11) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(10, 11) slot 0 val 0x105cf0 TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(10, 11) slot 0 val 0x105cf0 TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(10, 11) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_read 1 from TransmitHandle(5) (handle 2; state TransmitState(3)); Open TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_read result for TransmitHandle(5) (handle 2; state TransmitState(3)): Blocked TRACE wasmtime::runtime::component::concurrent: new waitable set WaitableSet(12) (handle 4) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(5) (handle 2) join set Some(WaitableSet(12)) (handle 4) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(5) join set Some(WaitableSet(12)) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_read 1 from TransmitHandle(8) (handle 3; state TransmitState(6)); Open TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_read result for TransmitHandle(8) (handle 3; state TransmitState(6)): Blocked TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(8) (handle 3) join set Some(WaitableSet(12)) (handle 4) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(8) join set Some(WaitableSet(12)) TRACE wasmtime::runtime::component::concurrent: waitable check for QualifiedThreadId(10, 11); set Some(WaitableSet(12)) TRACE wasmtime::runtime::component::concurrent: suspend fiber: Yielding { thread: QualifiedThreadId(10, 11) } TRACE wasmtime::runtime::component::concurrent: pop call context for GuestTask(10) TRACE wasmtime::runtime::component::concurrent: resume_fiber: restore current thread None TRACE wasmtime::runtime::component::concurrent: resume_fiber: suspend reason Some(Yielding { thread: QualifiedThreadId(10, 11) }) TRACE wasmtime::runtime::component::concurrent: push low priority: ResumeFiber TRACE wasmtime::runtime::component::concurrent: handle work item ResumeFiber TRACE wasmtime::runtime::component::concurrent: resume_fiber: save current thread None TRACE wasmtime::runtime::component::concurrent: push call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: taking event for GuestTask(10) TRACE wasmtime::runtime::component::concurrent: status Started for GuestTask(10) TRACE wasmtime::runtime::component::concurrent: waitable GuestTask(10) join set None TRACE wasmtime::runtime::component::concurrent: popped current thread QualifiedThreadId(10, 11); new thread is QualifiedThreadId(1, 2) TRACE wasmtime::runtime::component::concurrent: new waitable set WaitableSet(13) (handle 2) TRACE wasmtime::runtime::component::concurrent: waitable GuestTask(10) (handle 4) join set Some(WaitableSet(13)) (handle 2) TRACE wasmtime::runtime::component::concurrent: waitable GuestTask(10) join set Some(WaitableSet(13)) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_write 1 to TransmitHandle(7) (handle 5; state TransmitState(6)); GuestReady TRACE wasmtime::runtime::component::concurrent: set event for TransmitHandle(8): Some(FutureRead { code: Completed(0), pending: Some((TypeFutureTableIndex(1), 3)) }) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_write result for TransmitHandle(7) (handle 5; state TransmitState(6)): Completed(0) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_drop_writable: drop writer TransmitHandle(7) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_writer state TransmitState(6); write state Open read state Open TRACE wasmtime::runtime::component::concurrent: set event for TransmitHandle(8): Some(FutureRead { code: Completed(0), pending: Some((TypeFutureTableIndex(1), 3)) }) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_write 1 to TransmitHandle(4) (handle 3; state TransmitState(3)); GuestReady TRACE wasmtime::runtime::component::concurrent: set event for TransmitHandle(5): Some(FutureRead { code: Completed(0), pending: Some((TypeFutureTableIndex(0), 2)) }) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_write result for TransmitHandle(4) (handle 3; state TransmitState(3)): Completed(0) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_drop_writable: drop writer TransmitHandle(4) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_writer state TransmitState(3); write state Open read state Open TRACE wasmtime::runtime::component::concurrent: set event for TransmitHandle(5): Some(FutureRead { code: Completed(0), pending: Some((TypeFutureTableIndex(0), 2)) }) TRACE wasmtime::runtime::component::concurrent: waitable check for QualifiedThreadId(1, 2); set Some(WaitableSet(13)) TRACE wasmtime::runtime::component::concurrent: suspend fiber: Yielding { thread: QualifiedThreadId(1, 2) } TRACE wasmtime::runtime::component::concurrent: pop call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: resume_fiber: restore current thread None TRACE wasmtime::runtime::component::concurrent: resume_fiber: suspend reason Some(Yielding { thread: QualifiedThreadId(1, 2) }) TRACE wasmtime::runtime::component::concurrent: push low priority: ResumeFiber TRACE wasmtime::runtime::component::concurrent: handle work item ResumeFiber TRACE wasmtime::runtime::component::concurrent: resume_fiber: save current thread None TRACE wasmtime::runtime::component::concurrent: push call context for GuestTask(10) TRACE wasmtime::runtime::component::concurrent: waitable check for QualifiedThreadId(10, 11); set Some(WaitableSet(12)) TRACE wasmtime::runtime::component::concurrent: waitable check for QualifiedThreadId(10, 11); set Some(WaitableSet(12)), part two TRACE wasmtime::runtime::component::concurrent: deliver event FutureRead { code: Completed(0), pending: Some((TypeFutureTableIndex(0), 2)) } to GuestTask(10) for TransmitHandle(5) (handle 2); set WaitableSet(12) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(5) (handle 2) join set None (handle 0) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(5) join set None TRACE wasmtime::runtime::component::concurrent::futures_and_streams: new transmit: state TransmitState(14); write TransmitHandle(15); read TransmitHandle(16) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_read 1 from TransmitHandle(16) (handle 5; state TransmitState(14)); Open TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_read result for TransmitHandle(16) (handle 5; state TransmitState(14)): Blocked TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(16) (handle 5) join set Some(WaitableSet(12)) (handle 4) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(16) join set Some(WaitableSet(12)) TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(10, 11) slot 0 val 0x105cf0 TRACE wasmtime::runtime::component::concurrent: pop call context for GuestTask(10) TRACE wasmtime::runtime::component::concurrent: stackless call: restored None as current thread TRACE wasmtime::runtime::component::concurrent: received callback code from QualifiedThreadId(10, 11): 2 (set: 4) TRACE wasmtime::runtime::component::concurrent: push high priority: GuestCall(GuestCall { thread: QualifiedThreadId(10, 11), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: Some(WaitableSet(12)) } }) TRACE wasmtime::runtime::component::concurrent: suspend fiber: NeedWork TRACE wasmtime::runtime::component::concurrent: resume_fiber: restore current thread None TRACE wasmtime::runtime::component::concurrent: resume_fiber: suspend reason Some(NeedWork) TRACE wasmtime::runtime::component::concurrent: handle work item ResumeFiber TRACE wasmtime::runtime::component::concurrent: resume_fiber: save current thread None TRACE wasmtime::runtime::component::concurrent: push call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: waitable check for QualifiedThreadId(1, 2); set Some(WaitableSet(13)) TRACE wasmtime::runtime::component::concurrent: waitable check for QualifiedThreadId(1, 2); set Some(WaitableSet(13)), part two TRACE wasmtime::runtime::component::concurrent: no events ready to deliver via waitable-set.poll to GuestTask(1); set WaitableSet(13) TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(1, 2) slot 0 val 0x1060c0 TRACE wasmtime::runtime::component::concurrent: pop call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: stackless call: restored None as current thread TRACE wasmtime::runtime::component::concurrent: received callback code from QualifiedThreadId(1, 2): 1 (set: 0) TRACE wasmtime::runtime::component::concurrent: push low priority: GuestCall(GuestCall { thread: QualifiedThreadId(1, 2), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: None } }) TRACE wasmtime::runtime::component::concurrent: suspend fiber: NeedWork TRACE wasmtime::runtime::component::concurrent: resume_fiber: restore current thread None TRACE wasmtime::runtime::component::concurrent: resume_fiber: suspend reason Some(NeedWork) TRACE wasmtime::runtime::component::concurrent: handle work item GuestCall(GuestCall { thread: QualifiedThreadId(10, 11), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: Some(WaitableSet(12)) } }) TRACE wasmtime::runtime::component::concurrent: call GuestCall { thread: QualifiedThreadId(10, 11), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: Some(WaitableSet(12)) } } ready? true (do_not_enter: false; backpressure: 0) TRACE wasmtime::runtime::component::concurrent: resume_fiber: save current thread None TRACE wasmtime::runtime::component::concurrent: deliver event FutureRead { code: Completed(0), pending: Some((TypeFutureTableIndex(1), 3)) } to GuestTask(10) for TransmitHandle(8) (handle 3); set WaitableSet(12) TRACE wasmtime::runtime::component::concurrent: use callback to deliver event FutureRead { code: Completed(0), pending: Some((TypeFutureTableIndex(1), 3)) } to QualifiedThreadId(10, 11) for Some((TransmitHandle(8), 3)) TRACE wasmtime::runtime::component::concurrent: GuestCallKind::DeliverEvent: replaced None with QualifiedThreadId(10, 11) as current thread TRACE wasmtime::runtime::component::concurrent: push call context for GuestTask(10) TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(10, 11) slot 0 val 0x105cf0 TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(10, 11) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(8) (handle 3) join set None (handle 0) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(8) join set None TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest cancel read TransmitHandle(16) (handle 5) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_cancel_read state TransmitState(14); read state GuestReady write state Open TRACE wasmtime::runtime::component::concurrent::futures_and_streams: cancelled read TransmitState(14): Cancelled(0) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(16) (handle 5) join set None (handle 0) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(16) join set None TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_drop_readable: drop reader TransmitHandle(8) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_reader state TransmitState(6); read state Open write state Dropped TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_reader delete TransmitState(6) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: delete transmit: state TransmitState(6); write TransmitHandle(7); read TransmitHandle(8) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_drop_readable: drop reader TransmitHandle(5) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_reader state TransmitState(3); read state Open write state Dropped TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_reader delete TransmitState(3) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: delete transmit: state TransmitState(3); write TransmitHandle(4); read TransmitHandle(5) TRACE wasmtime::runtime::component::concurrent: task.return for QualifiedThreadId(10, 11) TRACE wasmtime::runtime::component::concurrent: set event for GuestTask(10): Some(Subtask { status: Returned }) TRACE wasmtime::runtime::component::concurrent: drop waitable set 12 (handle 4) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_drop_writable: drop writer TransmitHandle(15) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_writer state TransmitState(14); write state Open read state Open TRACE wasmtime::runtime::component::concurrent: set event for TransmitHandle(16): Some(StreamRead { code: Dropped(0), pending: None }) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_drop_readable: drop reader TransmitHandle(16) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_reader state TransmitState(14); read state Open write state Dropped TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_reader delete TransmitState(14) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: delete transmit: state TransmitState(14); write TransmitHandle(15); read TransmitHandle(16) TRACE wasmtime::runtime::component::concurrent: received callback code from QualifiedThreadId(10, 11): 0 (set: 0) TRACE wasmtime::runtime::component::concurrent: implicit thread QualifiedThreadId(10, 11) completed TRACE wasmtime::runtime::component::concurrent: GuestCallKind::DeliverEvent: restored None as current thread TRACE wasmtime::runtime::component::concurrent: suspend fiber: NeedWork TRACE wasmtime::runtime::component::concurrent: resume_fiber: restore current thread None TRACE wasmtime::runtime::component::concurrent: resume_fiber: suspend reason Some(NeedWork) TRACE wasmtime::runtime::component::concurrent: handle work item GuestCall(GuestCall { thread: QualifiedThreadId(1, 2), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: None } }) TRACE wasmtime::runtime::component::concurrent: call GuestCall { thread: QualifiedThreadId(1, 2), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: None } } ready? true (do_not_enter: false; backpressure: 0) TRACE wasmtime::runtime::component::concurrent: resume_fiber: save current thread None TRACE wasmtime::runtime::component::concurrent: deliver event None to GuestTask(1) TRACE wasmtime::runtime::component::concurrent: use callback to deliver event None to QualifiedThreadId(1, 2) for None TRACE wasmtime::runtime::component::concurrent: GuestCallKind::DeliverEvent: replaced None with QualifiedThreadId(1, 2) as current thread TRACE wasmtime::runtime::component::concurrent: push call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(1, 2) slot 0 val 0x1060c0 TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(1, 2) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent::futures_and_streams: new transmit: state TransmitState(11); write TransmitHandle(16); read TransmitHandle(15) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_read 1 from TransmitHandle(15) (handle 3; state TransmitState(11)); Open TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_read result for TransmitHandle(15) (handle 3; state TransmitState(11)): Blocked TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(15) (handle 3) join set Some(WaitableSet(13)) (handle 2) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(15) join set Some(WaitableSet(13)) TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(1, 2) slot 0 val 0x1060c0 TRACE wasmtime::runtime::component::concurrent: pop call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: received callback code from QualifiedThreadId(1, 2): 2 (set: 2) TRACE wasmtime::runtime::component::concurrent: push high priority: GuestCall(GuestCall { thread: QualifiedThreadId(1, 2), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: Some(WaitableSet(13)) } }) TRACE wasmtime::runtime::component::concurrent: GuestCallKind::DeliverEvent: restored None as current thread TRACE wasmtime::runtime::component::concurrent: suspend fiber: NeedWork TRACE wasmtime::runtime::component::concurrent: resume_fiber: restore current thread None TRACE wasmtime::runtime::component::concurrent: resume_fiber: suspend reason Some(NeedWork) TRACE wasmtime::runtime::component::concurrent: handle work item GuestCall(GuestCall { thread: QualifiedThreadId(1, 2), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: Some(WaitableSet(13)) } }) TRACE wasmtime::runtime::component::concurrent: call GuestCall { thread: QualifiedThreadId(1, 2), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(9), instance: ComponentInstanceId(0) } }, set: Some(WaitableSet(13)) } } ready? true (do_not_enter: false; backpressure: 0) TRACE wasmtime::runtime::component::concurrent: resume_fiber: save current thread None TRACE wasmtime::runtime::component::concurrent: deliver event Subtask { status: Returned } to GuestTask(1) for GuestTask(10) (handle 4); set WaitableSet(13) TRACE wasmtime::runtime::component::concurrent: use callback to deliver event Subtask { status: Returned } to QualifiedThreadId(1, 2) for Some((GuestTask(10), 4)) TRACE wasmtime::runtime::component::concurrent: GuestCallKind::DeliverEvent: replaced None with QualifiedThreadId(1, 2) as current thread TRACE wasmtime::runtime::component::concurrent: push call context for GuestTask(1) TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(1, 2) slot 0 val 0x1060c0 TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(1, 2) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent: waitable GuestTask(10) (handle 4) join set None (handle 0) TRACE wasmtime::runtime::component::concurrent: waitable GuestTask(10) join set None TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest cancel read TransmitHandle(15) (handle 3) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_cancel_read state TransmitState(11); read state GuestReady write state Open TRACE wasmtime::runtime::component::concurrent::futures_and_streams: cancelled read TransmitState(11): Cancelled(0) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(15) (handle 3) join set None (handle 0) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(15) join set None TRACE wasmtime::runtime::component::concurrent: waitable GuestTask(10) (handle 4) join set None (handle 0) TRACE wasmtime::runtime::component::concurrent: waitable GuestTask(10) join set None TRACE wasmtime::runtime::component::concurrent: delete guest task GuestTask(10) TRACE wasmtime::runtime::component::concurrent: subtask_drop GuestTask(10) (handle 4) TRACE wasmtime::runtime::component::concurrent: task.return for QualifiedThreadId(1, 2) TRACE wasmtime::runtime::component::concurrent: drop waitable set 13 (handle 2) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_drop_writable: drop writer TransmitHandle(16) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_writer state TransmitState(11); write state Open read state Open TRACE wasmtime::runtime::component::concurrent: set event for TransmitHandle(15): Some(StreamRead { code: Dropped(0), pending: None }) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_drop_readable: drop reader TransmitHandle(15) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_reader state TransmitState(11); read state Open write state Dropped TRACE wasmtime::runtime::component::concurrent::futures_and_streams: host_drop_reader delete TransmitState(11) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: delete transmit: state TransmitState(11); write TransmitHandle(16); read TransmitHandle(15) TRACE wasmtime::runtime::component::concurrent: received callback code from QualifiedThreadId(1, 2): 0 (set: 0) TRACE wasmtime::runtime::component::concurrent: implicit thread QualifiedThreadId(1, 2) completed TRACE wasmtime::runtime::component::concurrent: ready to delete? true (threads_completed: true, has_sync_result: false, pending_completion_event: false, host_future_state: NotApplicable) TRACE wasmtime::runtime::component::concurrent: delete guest task GuestTask(1) TRACE wasmtime::runtime::component::concurrent: GuestCallKind::DeliverEvent: restored None as current thread TRACE wasmtime::runtime::component::concurrent: suspend fiber: NeedWork TRACE wasmtime::runtime::component::concurrent: resume_fiber: restore current thread None TRACE wasmtime::runtime::component::concurrent: resume_fiber: suspend reason Some(NeedWork) ()