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

Native socket activity

This commit is contained in:
M66B 2016-01-20 12:40:26 +01:00
parent 517d79b78e
commit 8c55f53e85
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
app/src/main/jni/netguard/netguard.c
View File

@ -252,7 +252,8 @@ void handle_events(void *a) {
ts.tv_nsec = 0; ts.tv_nsec = 0;
sigemptyset(&emptyset); sigemptyset(&emptyset);
int max = get_selects(args, usock, &rfds, &wfds, &efds); int max = get_selects(args, usock, &rfds, &wfds, &efds);
int ready = pselect(max + 1, &rfds, &wfds, &efds, tcp_session == NULL ? NULL : &ts, &emptyset); int ready = pselect(max + 1, &rfds, &wfds, &efds,
tcp_session == NULL ? NULL : &ts, &emptyset);
if (ready < 0) { if (ready < 0) {
if (errno == EINTR) { if (errno == EINTR) {
if (signaled) { ; if (signaled) { ;
@ -529,6 +530,8 @@ void check_sockets(const struct arguments *args, fd_set *rfds, fd_set *wfds, fd_
uint32_t oldremote = cur->remote_seq; uint32_t oldremote = cur->remote_seq;
if (FD_ISSET(cur->socket, efds)) { if (FD_ISSET(cur->socket, efds)) {
cur->time = time(NULL);
// Socket error // Socket error
int serr = 0; int serr = 0;
socklen_t optlen = sizeof(int); socklen_t optlen = sizeof(int);
@ -547,6 +550,8 @@ void check_sockets(const struct arguments *args, fd_set *rfds, fd_set *wfds, fd_
if (cur->state == TCP_LISTEN) { if (cur->state == TCP_LISTEN) {
// Check socket connect // Check socket connect
if (FD_ISSET(cur->socket, wfds)) { if (FD_ISSET(cur->socket, wfds)) {
cur->time = time(NULL);
// Log // Log
char dest[20]; char dest[20];
inet_ntop(AF_INET, &(cur->daddr), dest, sizeof(dest)); inet_ntop(AF_INET, &(cur->daddr), dest, sizeof(dest));
@ -566,6 +571,8 @@ void check_sockets(const struct arguments *args, fd_set *rfds, fd_set *wfds, fd_
cur->state == TCP_CLOSE_WAIT) { cur->state == TCP_CLOSE_WAIT) {
// Check socket read // Check socket read
if (FD_ISSET(cur->socket, rfds)) { if (FD_ISSET(cur->socket, rfds)) {
cur->time = time(NULL);
// TODO window size // TODO window size
uint8_t buffer[MAX_DATASIZE4]; uint8_t buffer[MAX_DATASIZE4];
ssize_t bytes = recv(cur->socket, buffer, sizeof(buffer), 0); ssize_t bytes = recv(cur->socket, buffer, sizeof(buffer), 0);