Lines Matching refs:TransmitKind

50 pub enum TransmitKind {  enum
93 fn completed(kind: TransmitKind, count: u32) -> Self { in completed() argument
94 Self::Completed(if let TransmitKind::Future = kind { in completed()
113 pub fn kind(&self) -> TransmitKind { in kind() argument
115 TransmitIndex::Stream(_) => TransmitKind::Stream, in kind()
116 TransmitIndex::Future(_) => TransmitKind::Future, in kind()
1226 .new_transmit(TransmitKind::Future, Producer(producer))?, in new()
1298 .set_consumer(self.id, TransmitKind::Future, Consumer(consumer)) in pipe()
1385 store.host_drop_reader(id, TransmitKind::Future) in future_close()
1613 .new_transmit(TransmitKind::Stream, producer)?, in new()
1685 .set_consumer(self.id, TransmitKind::Stream, consumer) in pipe()
1770 store.host_drop_reader(id, TransmitKind::Stream) in stream_close()
2243 fn return_code(kind: TransmitKind, state: StreamResult, guest_offset: usize) -> Result<ReturnCode> { in return_code() argument
2255 kind: TransmitKind, in pipe_from_guest() argument
2297 kind: TransmitKind, in pipe_to_guest() argument
2340 fn host_drop_reader(&mut self, id: TableId<TransmitHandle>, kind: TransmitKind) -> Result<()> { in host_drop_reader()
2389 TransmitKind::Future => Event::FutureWrite { in host_drop_reader()
2393 TransmitKind::Stream => Event::StreamWrite { in host_drop_reader()
2524 kind: TransmitKind, in new_transmit() argument
2706 kind: TransmitKind, in set_consumer() argument
2793 if let TransmitKind::Future = kind { in set_consumer()
2882 if let TransmitKind::Future = kind { in set_consumer()
2907 kind: TransmitKind, in write() argument
2941 if let TransmitKind::Future = kind { in write()
3071 kind: TransmitKind, in consume() argument
3112 kind: TransmitKind, in produce() argument
4133 TransmitIndex::Stream(_) => TransmitKind::Stream, in guest_drop_readable()
4134 TransmitIndex::Future(_) => TransmitKind::Future, in guest_drop_readable()