diff options
Diffstat (limited to 'src/worker.rs')
| -rw-r--r-- | src/worker.rs | 5 |
1 files changed, 5 insertions, 0 deletions
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, |