From a4c3c05c69a4f9de76e41980594d180ec9ffe03b Mon Sep 17 00:00:00 2001
From: Lizzy Fleckenstein <eliasfleckenstein@web.de>
Date: Sun, 26 Feb 2023 03:02:06 +0100
Subject: Implement sending splits

---
 src/worker.rs | 5 +++++
 1 file changed, 5 insertions(+)

(limited to 'src/worker.rs')

diff --git a/src/worker.rs b/src/worker.rs
index 8210e63..daec64e 100644
--- a/src/worker.rs
+++ b/src/worker.rs
@@ -82,6 +82,7 @@ impl<S: UdpSender, R: UdpReceiver> Worker<S, R> {
                     self.sender
                         .send_rudp_type(
                             PktType::Ctl,
+                            None,
                             Pkt {
                                 unrel: true,
                                 chan: 0,
@@ -121,6 +122,7 @@ impl<S: UdpSender, R: UdpReceiver> Worker<S, R> {
                     self.sender
                         .send_rudp_type(
                             PktType::Ctl,
+                            None,
                             Pkt {
                                 chan: 0,
                                 unrel: false,
@@ -260,6 +262,8 @@ impl<S: UdpSender, R: UdpReceiver> Worker<S, R> {
                 let seqnum = cursor.read_u16::<BigEndian>()?;
                 self.chans[ch].packets[to_seqnum(seqnum)].replace(cursor.remaining_slice().into());
 
+                println!("{seqnum}");
+
                 let mut ack_data = Vec::with_capacity(3);
                 ack_data.write_u8(CtlType::Ack as u8)?;
                 ack_data.write_u16::<BigEndian>(seqnum)?;
@@ -267,6 +271,7 @@ impl<S: UdpSender, R: UdpReceiver> Worker<S, R> {
                 self.sender
                     .send_rudp_type(
                         PktType::Ctl,
+                        None,
                         Pkt {
                             chan,
                             unrel: true,
-- 
cgit v1.2.3