StephenDev0/idevice
1
0
Fork 0
mirror of https://github.com/jkcoxson/idevice.git synced 2026-03-02 14:36:16 +01:00
Code Issues Packages Projects Releases Wiki Activity

Respond to TCP keep-alive probes

Browse Source
This commit is contained in:
Jackson Coxson
2025-08-15 20:12:32 -06:00
parent 46635e162a
commit 2d528ae21c
1 changed files with 18 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
idevice/src/tcp/adapter.rs
View File

@@ -62,7 +62,7 @@
use std::{collections::HashMap, io::ErrorKind, net::IpAddr, path::Path, sync::Arc}; use std::{collections::HashMap, io::ErrorKind, net::IpAddr, path::Path, sync::Arc};
use log::trace; use log::{debug, trace, warn};
use tokio::{io::AsyncWriteExt, sync::Mutex}; use tokio::{io::AsyncWriteExt, sync::Mutex};
use crate::ReadWrite; use crate::ReadWrite;
@@ -542,6 +542,22 @@ impl Adapter {
let ip_packet = self.read_ip_packet().await?; let ip_packet = self.read_ip_packet().await?;
let res = TcpPacket::parse(&ip_packet)?; let res = TcpPacket::parse(&ip_packet)?;
let mut ack_me = None; let mut ack_me = None;
if let Some(state) = self.states.get(&res.destination_port) {
// A keep-alive probe: ACK set, no payload, and seq == RCV.NXT - 1
let is_keepalive = res.flags.ack
&& res.payload.is_empty()
&& res.sequence_number.wrapping_add(1) == state.ack;
if is_keepalive {
// Don't update any seq/ack state; just ACK what we already expect.
debug!("responding to keep-alive probe");
let port = res.destination_port;
self.ack(port).await?;
break;
}
}
if let Some(state) = self.states.get_mut(&res.destination_port) { if let Some(state) = self.states.get_mut(&res.destination_port) {
if state.peer_seq > res.sequence_number { if state.peer_seq > res.sequence_number {
// ignore retransmission // ignore retransmission
@@ -560,6 +576,7 @@ impl Adapter {
state.read_buffer.extend(res.payload); state.read_buffer.extend(res.payload);
} }
if res.flags.rst { if res.flags.rst {
warn!("stream rst");
state.status = ConnectionStatus::Error(ErrorKind::ConnectionReset); state.status = ConnectionStatus::Error(ErrorKind::ConnectionReset);
} }
if res.flags.fin { if res.flags.fin {