Lines Matching refs:TransmitIndex
107 pub enum TransmitIndex { enum
112 impl TransmitIndex { implementation
115 TransmitIndex::Stream(_) => TransmitKind::Stream, in kind()
116 TransmitIndex::Future(_) => TransmitKind::Future, in kind()
124 TransmitIndex::Stream(i) => { in payload()
128 TransmitIndex::Future(i) => { in payload()
140 ty: TransmitIndex, in get_mut_by_index_from() argument
144 TransmitIndex::Stream(ty) => handle_table.stream_rep(ty, index), in get_mut_by_index_from()
145 TransmitIndex::Future(ty) => handle_table.future_rep(ty, index), in get_mut_by_index_from()
154 ty: TransmitIndex, in lower() argument
1398 .table_for_transmit(TransmitIndex::Future(src)); in lift_index_to_future()
1433 .table_for_transmit(TransmitIndex::Future(dst)) in lower_future_to_index()
1783 .table_for_transmit(TransmitIndex::Stream(src)); in lift_index_to_stream()
1810 .table_for_transmit(TransmitIndex::Stream(dst)) in lower_stream_to_index()
2139 fn guest(id: ComponentInstanceId, index: TransmitIndex) -> Self { in guest()
2141 TransmitIndex::Future(ty) => TransmitOrigin::GuestFuture(id, ty), in guest()
2142 TransmitIndex::Stream(ty) => TransmitOrigin::GuestStream(id, ty), in guest()
2161 ty: TransmitIndex,
2197 ty: TransmitIndex,
2371 TransmitIndex::Future(ty) => Event::FutureWrite { in host_drop_reader()
2375 TransmitIndex::Stream(ty) => Event::StreamWrite { in host_drop_reader()
2470 TransmitIndex::Future(ty) => Event::FutureRead { in host_drop_writer()
2474 TransmitIndex::Stream(ty) => Event::StreamRead { in host_drop_writer()
3154 ty: TransmitIndex, in guest_drop_writable() argument
3159 TransmitIndex::Future(ty) => table.future_remove_writable(ty, writer)?, in guest_drop_writable()
3160 TransmitIndex::Stream(ty) => table.stream_remove_writable(ty, writer)?, in guest_drop_writable()
3166 TransmitIndex::Stream(_) => store.host_drop_writer(id, None), in guest_drop_writable()
3167 TransmitIndex::Future(_) => store.host_drop_writer( in guest_drop_writable()
3185 write_ty: TransmitIndex, in copy() argument
3190 read_ty: TransmitIndex, in copy() argument
3248 (TransmitIndex::Future(_), TransmitIndex::Future(_)) => { in copy()
3280 (TransmitIndex::Stream(_), TransmitIndex::Stream(_)) => { in copy()
3364 ty: TransmitIndex, in check_bounds() argument
3371 TransmitIndex::Future(ty) => types[types[ty].ty] in check_bounds()
3374 TransmitIndex::Stream(ty) => types[types[ty].ty] in check_bounds()
3397 ty: TransmitIndex, in guest_write() argument
3477 if let TransmitIndex::Future(_) = ty { in guest_write()
3589 if let TransmitIndex::Future(_) = ty { in guest_write()
3605 if let TransmitIndex::Future(_) = ty { in guest_write()
3622 (ReturnCode::Dropped(_), TransmitIndex::Stream(_)) in guest_write()
3639 ty: TransmitIndex, in guest_read() argument
3720 if let TransmitIndex::Future(_) = ty { in guest_read()
3826 if let (TransmitIndex::Future(_), ReturnCode::Completed(_)) = (ty, code) { in guest_read()
3850 (ReturnCode::Dropped(_), TransmitIndex::Stream(_)) in guest_read()
4042 ty: TransmitIndex, in guest_cancel_write() argument
4083 ty: TransmitIndex, in guest_cancel_read() argument
4124 ty: TransmitIndex, in guest_drop_readable() argument
4129 TransmitIndex::Stream(ty) => table.stream_remove_readable(ty, reader)?, in guest_drop_readable()
4130 TransmitIndex::Future(ty) => table.future_remove_readable(ty, reader)?, in guest_drop_readable()
4133 TransmitIndex::Stream(_) => TransmitKind::Stream, in guest_drop_readable()
4134 TransmitIndex::Future(_) => TransmitKind::Future, in guest_drop_readable()
4234 self.guest_cancel_read(store, TransmitIndex::Future(ty), async_, reader) in future_cancel_read()
4246 self.guest_cancel_write(store, TransmitIndex::Future(ty), async_, writer) in future_cancel_write()
4258 self.guest_cancel_read(store, TransmitIndex::Stream(ty), async_, reader) in stream_cancel_read()
4270 self.guest_cancel_write(store, TransmitIndex::Stream(ty), async_, writer) in stream_cancel_write()
4281 self.guest_drop_readable(store, TransmitIndex::Future(ty), reader) in future_drop_readable()
4291 self.guest_drop_readable(store, TransmitIndex::Stream(ty), reader) in stream_drop_readable()
4297 fn guest_new(self, store: &mut StoreOpaque, ty: TransmitIndex) -> Result<ResourcePair> { in guest_new()
4304 TransmitIndex::Future(ty) => ( in guest_new()
4308 TransmitIndex::Stream(ty) => ( in guest_new()
4371 src: TransmitIndex, in guest_transfer() argument
4372 dst: TransmitIndex, in guest_transfer() argument
4377 TransmitIndex::Future(idx) => src_table.future_remove_readable(idx, src_idx)?, in guest_transfer()
4378 TransmitIndex::Stream(idx) => src_table.stream_remove_readable(idx, src_idx)?, in guest_transfer()
4385 TransmitIndex::Future(idx) => dst_table.future_insert_read(idx, rep), in guest_transfer()
4386 TransmitIndex::Stream(idx) => dst_table.stream_insert_read(idx, rep), in guest_transfer()
4402 self.guest_new(store, TransmitIndex::Future(ty)) in future_new()
4411 self.guest_new(store, TransmitIndex::Stream(ty)) in stream_new()
4426 TransmitIndex::Future(src), in future_transfer()
4427 TransmitIndex::Future(dst), in future_transfer()
4443 TransmitIndex::Stream(src), in stream_transfer()
4444 TransmitIndex::Stream(dst), in stream_transfer()
4480 fn table_for_transmit(self: Pin<&mut Self>, ty: TransmitIndex) -> &mut HandleTable { in table_for_transmit()
4483 TransmitIndex::Stream(ty) => types[ty].instance, in table_for_transmit()
4484 TransmitIndex::Future(ty) => types[ty].instance, in table_for_transmit()
4500 ty: TransmitIndex, in get_mut_by_index() argument
4510 ty: TransmitIndex, in send_write_result() argument
4519 TransmitIndex::Future(ty) => Event::FutureWrite { in send_write_result()
4523 TransmitIndex::Stream(ty) => Event::StreamWrite { in send_write_result()
4533 ty: TransmitIndex, in send_read_result() argument
4542 TransmitIndex::Future(ty) => Event::FutureRead { in send_read_result()
4546 TransmitIndex::Stream(ty) => Event::StreamRead { in send_read_result()