fix case where unknown packets caused the next packet to not be handled properly
This commit is contained in:
parent
74a031e10c
commit
f8af4ab3a1
@ -98,8 +98,13 @@ impl<S, R> Client<S, R> where
|
|||||||
let pkt_data = self.incoming_data.drain(..pkt_len).collect::<Vec<_>>();
|
let pkt_data = self.incoming_data.drain(..pkt_len).collect::<Vec<_>>();
|
||||||
|
|
||||||
trace!("[recv buf from {:?}] {:?}", self.id, pkt_data);
|
trace!("[recv buf from {:?}] {:?}", self.id, pkt_data);
|
||||||
let pkt = R::from_bytes(&pkt_data[..pkt_size])
|
let pkt = match R::from_bytes(&pkt_data[..pkt_size]) {
|
||||||
.map_err(|err| -> PacketNetworkError { err.into() })?;
|
Ok(p) => p,
|
||||||
|
Err(err) => {
|
||||||
|
warn!("error RecvServerPacket::from_bytes: {:?}", err);
|
||||||
|
continue
|
||||||
|
},
|
||||||
|
};
|
||||||
|
|
||||||
trace!("[recv from {:?}] {:?}", self.id, pkt);
|
trace!("[recv from {:?}] {:?}", self.id, pkt);
|
||||||
result.push(pkt);
|
result.push(pkt);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user