diff options
| author | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-02-26 03:02:06 +0100 |
|---|---|---|
| committer | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-02-26 03:02:11 +0100 |
| commit | a4c3c05c69a4f9de76e41980594d180ec9ffe03b (patch) | |
| tree | ec693be8e4f30bfc927b8e5aef329fbea969cc56 /src/worker.rs | |
| parent | 1954496f73f0a22ff173e2869ed187b6f74d8777 (diff) | |
| download | mt_rudp-a4c3c05c69a4f9de76e41980594d180ec9ffe03b.tar.xz | |
Implement sending splits
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, |