Implement sending splits

[mt_rudp.git] / src / worker.rs

diff --git a/src/worker.rs b/src/worker.rs
index 8210e632fecf0cad57db30a1074de94d91fa525a..daec64e156322d95e563c04f857be4feb75e0ff2 100644 (file)
--- 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,