Searched refs:recv_window (Results 1 – 2 of 2) sorted by relevance
22 recv_window: RecvWindow, field29 recv_window: RecvWindow::new(conn_recv_window as i32), in new()35 self.recv_window.check_window_update(0) in check_conn_recv_window_update()40 let actual = self.recv_window.actual_size() as u32; in setup_recv_window()43 self.recv_window.increase_actual(extra); in setup_recv_window()46 self.recv_window.reduce_actual(extra); in setup_recv_window()59 self.recv_window.notification_available() in recv_notification_size_available()67 self.recv_window.recv_data(size) in recv_data()
116 pub(crate) recv_window: RecvWindow,251 stream.recv_window.increase_notification(extra); in apply_recv_initial_window_size()252 stream.recv_window.increase_actual(extra); in apply_recv_initial_window_size()257 stream.recv_window.reduce_notification(current - size); in apply_recv_initial_window_size()266 if stream.recv_window.notification_available() < size { in release_stream_recv_window()269 stream.recv_window.recv_data(size); in release_stream_recv_window()270 if stream.recv_window.unreleased_size().is_some() { in release_stream_recv_window()303 let recv_window = RecvWindow::new(self.stream_recv_window_size as i32); in insert() localVariable305 let stream = Stream::new(recv_window, send_window, request.header, request.data); in insert()732 recv_window: RecvWindow, in new()[all …]