diff options
| author | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2022-12-29 03:44:11 +0100 |
|---|---|---|
| committer | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2022-12-29 03:44:11 +0100 |
| commit | b011620dbb4243d4a0d9febb89e438a2dd517a61 (patch) | |
| tree | c7f267b3d454bd607f58c49c9332696e1865d549 /src/recv_worker.rs | |
| parent | 944c16adfb83976149701086e20146797d4330df (diff) | |
| download | mt_rudp-b011620dbb4243d4a0d9febb89e438a2dd517a61.tar.xz | |
finish receiver
Diffstat (limited to 'src/recv_worker.rs')
| -rw-r--r-- | src/recv_worker.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/recv_worker.rs b/src/recv_worker.rs index f83e8ef..316bb48 100644 --- a/src/recv_worker.rs +++ b/src/recv_worker.rs @@ -133,7 +133,10 @@ impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> { match cursor.read_u8()?.try_into()? { PktType::Ctl => match cursor.read_u8()?.try_into()? { - CtlType::Ack => { /* TODO */ } + CtlType::Ack => { + let seqnum = cursor.read_u16::<BigEndian>()?; + self.share.ack_chans.lock().await.remove(&seqnum); + } CtlType::SetPeerID => { let mut id = self.share.remote_id.write().await; |