mirror
/
NetGuard
mirror of https://github.com/M66B/NetGuard.git
1
0
Fork 0
Code Issues Releases Wiki Activity

TCP keep alive

This commit is contained in:
M66B 2017-03-03 10:03:37 +01:00
parent 07e0a46e6e
commit 935df7491c
2 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/src/main/jni/netguard/netguard.h
View File

@ -50,10 +50,11 @@
#define UDP_KEEP_TIMEOUT 60 // seconds #define UDP_KEEP_TIMEOUT 60 // seconds
#define TCP_INIT_TIMEOUT 30 // seconds ~net.inet.tcp.keepinit #define TCP_INIT_TIMEOUT 30 // seconds ~net.inet.tcp.keepinit
#define TCP_IDLE_TIMEOUT 3600 // seconds ~net.inet.tcp.keepidle #define TCP_IDLE_TIMEOUT 29 // seconds ~net.inet.tcp.keepidle
#define TCP_CLOSE_TIMEOUT 30 // seconds #define TCP_CLOSE_TIMEOUT 30 // seconds
#define TCP_KEEP_TIMEOUT 300 // seconds #define TCP_KEEP_TIMEOUT 300 // seconds
// https://en.wikipedia.org/wiki/Maximum_segment_lifetime // https://en.wikipedia.org/wiki/Maximum_segment_lifetime
#define TCP_KEEP_ALIVE 30 // seconds
#define UID_DELAY 1 // milliseconds #define UID_DELAY 1 // milliseconds
#define UID_DELAYTRY 10 // milliseconds #define UID_DELAYTRY 10 // milliseconds

18
app/src/main/jni/netguard/tcp.c
View File

@ -128,8 +128,11 @@ int monitor_tcp_session(const struct arguments *args, struct ng_session *s, int
} }
else if (s->tcp.state == TCP_ESTABLISHED || s->tcp.state == TCP_CLOSE_WAIT) { else if (s->tcp.state == TCP_ESTABLISHED || s->tcp.state == TCP_CLOSE_WAIT) {
uint32_t rwindow = get_receive_window(s);
uint32_t swindow = get_send_window(&s->tcp);
// Check for incoming data // Check for incoming data
if (get_send_window(&s->tcp) > 0) if (swindow > 0)
events = events | EPOLLIN; events = events | EPOLLIN;
else { else {
recheck = 1; recheck = 1;
@ -153,6 +156,19 @@ int monitor_tcp_session(const struct arguments *args, struct ng_session *s, int
else else
recheck = 1; recheck = 1;
} }
// Keep alive
if (rwindow > 0 && swindow > 0) {
long long ms = get_ms();
if (s->tcp.time + TCP_KEEP_ALIVE < time(NULL) &&
ms - s->tcp.last_keep_alive > TCP_KEEP_ALIVE * 1000) {
s->tcp.last_keep_alive = ms;
log_android(ANDROID_LOG_WARN, "Sending keep alive");
s->tcp.remote_seq--;
write_ack(args, &s->tcp);
s->tcp.remote_seq++;
}
}
} }
if (events != s->ev.events) { if (events != s->ev.events) {