qconnection 0.5.0

Encapsulation of QUIC connections, a part of dquic
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use qbase::{Epoch, net::tx::Signals};
use qcongestion::Transport;
use tokio::time::Duration;

use crate::{path::PathDeactivated, tls::ArcTlsHandshake};

impl super::Path {
    pub async fn drive(&self, tls_handshake: ArcTlsHandshake) -> Result<(), PathDeactivated> {
        loop {
            tokio::time::sleep(Duration::from_millis(10)).await;
            if matches!(tls_handshake.is_finished(), Ok(true)) {
                self.max_idle_timer.run_out(self.cc.get_pto(Epoch::Data))?;
            }
            if self.heartbeat.need_trigger() {
                self.tx_waker.wake_by(Signals::TRANSPORT);
            }
            self.cc.do_tick()?;
        }
    }
}