Lines Matching refs:fin
649 if buf.fin() && fin_off != buf.max_off() { in push()
655 if buf.fin() && buf.max_off() < self.len { in push()
667 if buf.fin() && buf.is_empty() && self.fin_off.is_some() { in push()
671 if buf.fin() { in push()
676 if !buf.fin() && buf.is_empty() { in push()
920 &mut self, mut data: &[u8], mut fin: bool, in push_slice()
931 let buf = RangeBuf::from(&[], self.off, fin); in push_slice()
942 fin = false; in push_slice()
945 let buf = RangeBuf::from(data, self.off, fin); in push_slice()
962 if buf.max_off() == fin_off && !buf.fin() { in push()
971 if buf.fin() { in push()
1043 out.fin = self.fin_off == Some(out.max_off()); in pop()
1153 fin: bool, field
1158 pub(crate) fn from(buf: &[u8], off: u64, fin: bool) -> RangeBuf { in from()
1163 fin, in from()
1168 pub fn fin(&self) -> bool { in fin() method
1169 self.fin in fin()
1203 fin: self.fin, in split_off()
1206 self.fin = false; in split_off()
1342 let (len, fin) = recv.pop(&mut buf).unwrap(); in ordered_read()
1344 assert_eq!(fin, true); in ordered_read()
1370 let (len, fin) = recv.pop(&mut buf[..10]).unwrap(); in split_read()
1372 assert_eq!(fin, false); in split_read()
1377 let (len, fin) = recv.pop(&mut buf[..5]).unwrap(); in split_read()
1379 assert_eq!(fin, false); in split_read()
1384 let (len, fin) = recv.pop(&mut buf[..10]).unwrap(); in split_read()
1386 assert_eq!(fin, true); in split_read()
1412 let (len, fin) = recv.pop(&mut buf).unwrap(); in incomplete_read()
1414 assert_eq!(fin, true); in incomplete_read()
1440 let (len, fin) = recv.pop(&mut buf).unwrap(); in zero_len_read()
1442 assert_eq!(fin, true); in zero_len_read()
1465 let (len, fin) = recv.pop(&mut buf).unwrap(); in past_read()
1467 assert_eq!(fin, false); in past_read()
1507 let (len, fin) = recv.pop(&mut buf).unwrap(); in fully_overlapping_read()
1509 assert_eq!(fin, false); in fully_overlapping_read()
1538 let (len, fin) = recv.pop(&mut buf).unwrap(); in fully_overlapping_read2()
1540 assert_eq!(fin, false); in fully_overlapping_read2()
1569 let (len, fin) = recv.pop(&mut buf).unwrap(); in fully_overlapping_read3()
1571 assert_eq!(fin, false); in fully_overlapping_read3()
1606 let (len, fin) = recv.pop(&mut buf).unwrap(); in fully_overlapping_read_multi()
1608 assert_eq!(fin, false); in fully_overlapping_read_multi()
1637 let (len, fin) = recv.pop(&mut buf).unwrap(); in overlapping_start_read()
1639 assert_eq!(fin, true); in overlapping_start_read()
1667 let (len, fin) = recv.pop(&mut buf).unwrap(); in overlapping_end_read()
1669 assert_eq!(fin, true); in overlapping_end_read()
1703 let (len, fin) = recv.pop(&mut buf).unwrap(); in partially_multi_overlapping_reordered_read()
1705 assert_eq!(fin, true); in partially_multi_overlapping_reordered_read()
1758 let (len, fin) = recv.pop(&mut buf).unwrap(); in partially_multi_overlapping_reordered_read2()
1760 assert_eq!(fin, false); in partially_multi_overlapping_reordered_read2()
1776 assert_eq!(write.fin(), false); in empty_write()
1795 assert_eq!(write.fin(), true); in multi_write()
1817 assert_eq!(write.fin(), false); in split_write()
1824 assert_eq!(write.fin(), false); in split_write()
1831 assert_eq!(write.fin(), true); in split_write()
1854 assert_eq!(write1.fin(), false); in resend()
1862 assert_eq!(write2.fin(), false); in resend()
1870 assert_eq!(write3.fin(), false); in resend()
1886 assert_eq!(write4.fin(), false); in resend()
1894 assert_eq!(write5.fin(), true); in resend()
1925 assert_eq!(write.fin(), false); in write_blocked_by_off()
1932 assert_eq!(write.fin(), false); in write_blocked_by_off()
1947 assert_eq!(write.fin(), false); in write_blocked_by_off()
1959 assert_eq!(write.fin(), true); in write_blocked_by_off()
1980 assert_eq!(write.fin(), true); in zero_len_write()
2002 let (len, fin) = stream.recv.pop(&mut buf).unwrap(); in recv_flow_control()
2004 assert_eq!(fin, false); in recv_flow_control()
2041 let (len, fin) = stream.recv.pop(&mut buf).unwrap(); in recv_fin_dup()
2043 assert_eq!(fin, true); in recv_fin_dup()
2083 let (len, fin) = stream.recv.pop(&mut buf).unwrap(); in recv_fin_flow_control()
2085 assert_eq!(fin, true); in recv_fin_flow_control()
2151 assert_eq!(write.fin(), false); in send_flow_control()
2157 assert_eq!(write.fin(), false); in send_flow_control()
2166 assert_eq!(write.fin(), false); in send_flow_control()
2172 assert_eq!(write.fin(), false); in send_flow_control()
2227 assert_eq!(write.fin(), true); in send_fin_max_data_match()
2242 assert_eq!(write.fin(), true); in send_fin_zero_length()
2258 assert_eq!(write.fin(), false); in send_ack()
2268 assert_eq!(write.fin(), true); in send_ack()
2284 assert_eq!(write1.fin(), false); in send_ack_reordering()
2290 assert_eq!(write2.fin(), false); in send_ack_reordering()
2302 assert_eq!(write.fin(), true); in send_ack_reordering()
2316 let (len, fin) = stream.recv.pop(&mut buf).unwrap(); in recv_data_below_off()
2318 assert_eq!(fin, false); in recv_data_below_off()
2323 let (len, fin) = stream.recv.pop(&mut buf).unwrap(); in recv_data_below_off()
2325 assert_eq!(fin, true); in recv_data_below_off()
2379 assert_eq!(write.fin(), false); in send_fin_zero_length_output()
2388 assert_eq!(write.fin(), true); in send_fin_zero_length_output()