Searched refs:si (Results 1 – 4 of 4) sorted by relevance
110 pub(crate) si: u16, field125 pub(crate) fn new(si: u16) -> Self { in new()127 si, in new()137 if chunk.stream_identifier != self.si { in push()
437 let mut si = self.stream_info.lock().await; in send() localVariable438 *si = stream_info; in send()
229 for si in self.streams.keys().cloned().collect::<Vec<u16>>() { in close()230 self.unregister_stream(si); in close()1415 for (si, n_bytes_acked) in &bytes_acked_per_stream { in handle_sack()1416 if let Some(s) = self.streams.get_mut(si) { in handle_sack()1590 for (si, ssn) in &stream_map { in create_forward_tsn()1593 identifier: *si, in create_forward_tsn()
185 si: u16, in establish_session_pair()189 .open_stream(si, PayloadProtocolIdentifier::Binary) in establish_session_pair()