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::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::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: context_get QualifiedThreadId(10, 11) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent: new waitable set WaitableSet(12) (handle 6) TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(10, 11) slot 0 val 0x3bfa30 TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(5) (handle 2) join set Some(WaitableSet(12)) (handle 6) 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: context_get QualifiedThreadId(10, 11) slot 0 val 0x3bfa30 TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(8) (handle 3) join set Some(WaitableSet(12)) (handle 6) TRACE wasmtime::runtime::component::concurrent: waitable TransmitHandle(8) join set Some(WaitableSet(12)) TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(10, 11) slot 0 val 0x3bfa30 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: 6) 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: 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: context_get QualifiedThreadId(1, 2) slot 0 val 0x0 TRACE wasmtime::runtime::component::concurrent: new waitable set WaitableSet(13) (handle 4) TRACE wasmtime::runtime::component::concurrent: context_set QualifiedThreadId(1, 2) slot 0 val 0x3bf250 TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_write 1 to TransmitHandle(7) (handle 7; 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: push high priority: GuestCall(GuestCall { thread: QualifiedThreadId(10, 11), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(11), instance: ComponentInstanceId(0) } }, set: Some(WaitableSet(12)) } }) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_write result for TransmitHandle(7) (handle 7; state TransmitState(6)): Completed(0) TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest_write 1 to TransmitHandle(4) (handle 5; 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 5; state TransmitState(3)): Completed(0) TRACE wasmtime::runtime::component::concurrent: context_get QualifiedThreadId(1, 2) slot 0 val 0x3bf250 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): 2 (set: 4) 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(11), 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(11), 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(0), 2)) } to GuestTask(10) for TransmitHandle(5) (handle 2); set WaitableSet(12) TRACE wasmtime::runtime::component::concurrent: use callback to deliver event FutureRead { code: Completed(0), pending: Some((TypeFutureTableIndex(0), 2)) } to QualifiedThreadId(10, 11) for Some((TransmitHandle(5), 2)) 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 0x3bfa30 TRACE wasmtime::runtime::component::concurrent: pop call context for GuestTask(10) TRACE wasmtime::runtime::component::concurrent: received callback code from QualifiedThreadId(10, 11): 2 (set: 6) TRACE wasmtime::runtime::component::concurrent: push high priority: GuestCall(GuestCall { thread: QualifiedThreadId(10, 11), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(11), instance: ComponentInstanceId(0) } }, set: Some(WaitableSet(12)) } }) 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(10, 11), kind: DeliverEvent { instance: Instance { id: StoreComponentInstanceId { store_id: StoreId(11), 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(11), 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 0x3bfa30 TRACE wasmtime::runtime::component::concurrent::futures_and_streams: guest cancel read TransmitHandle(5) (handle 2)