match cursor.read_u8()?.try_into()? {
PktType::Ctl => match cursor.read_u8()?.try_into()? {
CtlType::Ack => {
- println!("Ack");
+ // println!("Ack");
let seqnum = cursor.read_u16::<BigEndian>()?;
if let Some(ack) = self.share.chans[chan.num as usize]
}
}
CtlType::SetPeerID => {
- println!("SetPeerID");
+ // println!("SetPeerID");
let mut id = self.share.remote_id.write().await;
*id = cursor.read_u16::<BigEndian>()?;
}
CtlType::Ping => {
- println!("Ping");
+ // println!("Ping");
}
CtlType::Disco => {
- println!("Disco");
+ // println!("Disco");
return Err(RemoteDisco(false));
}
},
PktType::Orig => {
- println!("Orig");
+ // println!("Orig");
self.pkt_tx.send(Ok(Pkt {
chan: chan.num,
}))?;
}
PktType::Split => {
- println!("Split");
+ // println!("Split");
let seqnum = cursor.read_u16::<BigEndian>()?;
let chunk_index = cursor.read_u16::<BigEndian>()? as usize;
}
}
PktType::Rel => {
- println!("Rel");
+ // println!("Rel");
let seqnum = cursor.read_u16::<BigEndian>()?;
chan.packets[to_seqnum(seqnum)].replace(cursor.remaining_slice().into());