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

JNI receive

This commit is contained in:
M66B 2016-01-09 16:56:23 +01:00
parent f31338bceb
commit 6cdbba92b9
2 changed files with 69 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/main/java/eu/faircode/netguard/SinkholeService.java
View File

@ -119,6 +119,8 @@ public class SinkholeService extends VpnService implements SharedPreferences.OnS
private native void jni_decode(byte[] buffer);
private native void jni_receive(int fd);
static {
System.loadLibrary("netguard");
}
@ -686,6 +688,8 @@ public class SinkholeService extends VpnService implements SharedPreferences.OnS
byte[] bytes = new byte[buffer.limit()];
Log.i(TAG, "Start receiving");
//jni_receive(pfd.getFd());
while (!Thread.currentThread().isInterrupted() &&
pfd.getFileDescriptor() != null &&
pfd.getFileDescriptor().valid())

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

@ -1,10 +1,16 @@
#include <jni.h>
#include <stddef.h>
#include <malloc.h>
#include <unistd.h>
#include <android/log.h>
#include <arpa/inet.h>
#include <netinet/ip.h>
#include <netinet/ip6.h>
#include <netinet/udp.h>
#include <netinet/tcp.h>
#define TAG "NetGuard.JNI"
#define MAXPKT 32768
JNIEXPORT void JNICALL
Java_eu_faircode_netguard_SinkholeService_jni_1init(JNIEnv *env, jobject instance) {
@ -31,22 +37,65 @@ Java_eu_faircode_netguard_SinkholeService_jni_1decode(JNIEnv *env, jobject insta
(*env)->ReleaseByteArrayElements(env, buffer_, buffer, 0);
}
unsigned short checksum(unsigned short *addr, int len) {
unsigned short result;
unsigned int sum = 0;
JNIEXPORT void JNICALL
Java_eu_faircode_netguard_SinkholeService_jni_1receive(JNIEnv *env, jobject instance, jint fd) {
int len;
jbyte *buffer = malloc(MAXPKT);
while (1) {
len = read(fd, buffer, MAXPKT);
if (len < 0) {
__android_log_print(ANDROID_LOG_WARN, TAG, "Receive error %d", len);
free(buffer);
return;
while (len > 1) {
sum += *addr++;
len -= 2;
} else if (len > 0) {
jbyte version = (*buffer) >> 4;
jbyte protocol = -1;
char source[40];
char dest[40];
void *payload = NULL;
if (version == 4) {
struct iphdr *ip4hdr = buffer;
protocol = ip4hdr->protocol;
inet_ntop(AF_INET, &ip4hdr->saddr, source, sizeof(source));
inet_ntop(AF_INET, &ip4hdr->daddr, dest, sizeof(dest));
jbyte optlen = 0;
if (ip4hdr->ihl > 5)
optlen = buffer[20];
payload = buffer + 20 * sizeof(jbyte) + optlen;
}
else if (version == 6) {
struct ip6_hdr *ip6hdr = buffer;
protocol = ip6hdr->ip6_nxt;
inet_ntop(AF_INET6, &ip6hdr->ip6_src, source, sizeof(source));
inet_ntop(AF_INET6, &ip6hdr->ip6_dst, dest, sizeof(dest));
payload = buffer + 40 * sizeof(jbyte);
}
else {
__android_log_print(ANDROID_LOG_WARN, TAG, "Unknown version %d", version);
*source = 0;
*dest = 0;
}
int sport = -1;
int dport = -1;
if (protocol == IPPROTO_TCP) {
struct tcphdr *tcp = payload;
sport = ntohs(tcp->source);
dport = ntohs(tcp->dest);
} else if (protocol == IPPROTO_UDP) {
struct udphdr *udp = payload;
sport = ntohs(udp->source);
dport = ntohs(udp->dest);
}
__android_log_print(ANDROID_LOG_INFO, TAG, "%s/%d -> %s/%d",
source, sport, dest, dport);
} else
__android_log_print(ANDROID_LOG_WARN, TAG, "Nothing received");
}
if (len == 1)
sum += *(unsigned char *) addr;
sum = (sum >> 16) + (sum & 0xFFFF);
sum += (sum >> 16);
result = ~sum;
return result;
}