Compare commits
5 Commits
v0.0.67-mu
...
v0.0.68-mu
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d599e545f7 | ||
|
|
048870e280 | ||
|
|
31045456fe | ||
|
|
0bb5be63b9 | ||
|
|
c9f737197c |
2
mud
2
mud
Submodule mud updated: 4c34454a23...df0d941241
35
src/main.c
35
src/main.c
@@ -266,7 +266,6 @@ int main (int argc, char **argv)
|
||||
{ "dev", &dev, option_str },
|
||||
{ "mtu", &mtu, option_long },
|
||||
{ "keyfile", &keyfile, option_str },
|
||||
{ "multiqueue", NULL, option_option },
|
||||
{ "statefile", &statefile, option_str },
|
||||
{ "timeout", >.timeout, option_long },
|
||||
{ "time-tolerance", &time_tolerance, option_long },
|
||||
@@ -311,6 +310,15 @@ int main (int argc, char **argv)
|
||||
return 1;
|
||||
}
|
||||
|
||||
int icmp_fd = -1;
|
||||
|
||||
if (v4) {
|
||||
icmp_fd = socket(AF_INET, SOCK_RAW, IPPROTO_ICMP);
|
||||
|
||||
if (icmp_fd==-1)
|
||||
gt_log("couldn't create ICMP socket\n");
|
||||
}
|
||||
|
||||
gt.state_fd = state_create(statefile);
|
||||
|
||||
if (statefile && gt.state_fd==-1)
|
||||
@@ -318,7 +326,7 @@ int main (int argc, char **argv)
|
||||
|
||||
char *tun_name = NULL;
|
||||
|
||||
int tun_fd = tun_create(dev, &tun_name, option_is_set(opts, "multiqueue"));
|
||||
int tun_fd = tun_create(dev, &tun_name);
|
||||
|
||||
if (tun_fd==-1) {
|
||||
gt_log("couldn't create tun device\n");
|
||||
@@ -395,6 +403,9 @@ int main (int argc, char **argv)
|
||||
while (!gt.quit) {
|
||||
FD_SET(tun_fd, &rfds);
|
||||
|
||||
if (icmp_fd!=-1)
|
||||
FD_SET(icmp_fd, &rfds);
|
||||
|
||||
if (mud_can_pull(mud)) {
|
||||
FD_SET(mud_fd, &rfds);
|
||||
} else {
|
||||
@@ -415,6 +426,26 @@ int main (int argc, char **argv)
|
||||
return 1;
|
||||
}
|
||||
|
||||
if (icmp_fd!=-1 && FD_ISSET(icmp_fd, &rfds)) {
|
||||
uint8_t buf[1024];
|
||||
struct sockaddr_storage ss;
|
||||
socklen_t sl = sizeof(ss);
|
||||
ssize_t r = recvfrom(icmp_fd, buf, sizeof(buf), 0, (struct sockaddr *)&ss, &sl);
|
||||
if (r>=8) {
|
||||
struct ip_common ic;
|
||||
if (!ip_get_common(&ic, buf, r) && ic.proto==1) {
|
||||
unsigned char *data = &buf[ic.hdr_size];
|
||||
if (data[0]==3) {
|
||||
int new_mtu = (data[6]<<8)|data[7];
|
||||
if (new_mtu) {
|
||||
gt_log("received MTU from ICMP: %i\n", new_mtu);
|
||||
mud_set_mtu(mud, new_mtu-50);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (mud_is_up(mud)) {
|
||||
if (!started) {
|
||||
state_send(gt.state_fd, "STARTED", tun_name);
|
||||
|
||||
34
src/tun.c
34
src/tun.c
@@ -11,8 +11,9 @@
|
||||
#include <sys/socket.h>
|
||||
#include <sys/uio.h>
|
||||
|
||||
#include <net/if.h>
|
||||
|
||||
#ifdef __linux__
|
||||
#include <linux/if.h>
|
||||
#include <linux/if_tun.h>
|
||||
#endif
|
||||
|
||||
@@ -28,7 +29,7 @@
|
||||
|
||||
#ifdef __APPLE__
|
||||
|
||||
static int tun_create_by_id (char *name, size_t size, unsigned id, _unused_ int mq)
|
||||
static int tun_create_by_id (char *name, size_t size, unsigned id)
|
||||
{
|
||||
int fd = socket(PF_SYSTEM, SOCK_DGRAM, SYSPROTO_CONTROL);
|
||||
|
||||
@@ -63,21 +64,21 @@ static int tun_create_by_id (char *name, size_t size, unsigned id, _unused_ int
|
||||
return fd;
|
||||
}
|
||||
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name, int mq)
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name)
|
||||
{
|
||||
unsigned id = 0;
|
||||
|
||||
if (sscanf(dev_name, "utun%u", &id)!=1)
|
||||
return -1;
|
||||
|
||||
return tun_create_by_id(name, size, id, mq);
|
||||
return tun_create_by_id(name, size, id);
|
||||
}
|
||||
|
||||
#else /* not __APPLE__ */
|
||||
|
||||
#ifdef __linux__
|
||||
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name, int mq)
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name)
|
||||
{
|
||||
int fd = open("/dev/net/tun", O_RDWR);
|
||||
|
||||
@@ -88,12 +89,6 @@ static int tun_create_by_name (char *name, size_t size, char *dev_name, int mq)
|
||||
.ifr_flags = IFF_TUN|IFF_NO_PI,
|
||||
};
|
||||
|
||||
if (mq) {
|
||||
#ifdef IFF_MULTI_QUEUE
|
||||
ifr.ifr_flags |= IFF_MULTI_QUEUE;
|
||||
#endif
|
||||
}
|
||||
|
||||
str_cpy(ifr.ifr_name, dev_name, IFNAMSIZ-1);
|
||||
|
||||
if (ioctl(fd, TUNSETIFF, &ifr)) {
|
||||
@@ -108,7 +103,7 @@ static int tun_create_by_name (char *name, size_t size, char *dev_name, int mq)
|
||||
|
||||
#else /* not __linux__ not __APPLE__ */
|
||||
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name, _unused_ int mq)
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name)
|
||||
{
|
||||
char path[64];
|
||||
|
||||
@@ -120,32 +115,27 @@ static int tun_create_by_name (char *name, size_t size, char *dev_name, _unused_
|
||||
|
||||
#endif /* not __APPLE__ */
|
||||
|
||||
static int tun_create_by_id (char *name, size_t size, unsigned id, int mq)
|
||||
static int tun_create_by_id (char *name, size_t size, unsigned id)
|
||||
{
|
||||
char dev_name[64];
|
||||
|
||||
snprintf(dev_name, sizeof(dev_name), "tun%u", id);
|
||||
|
||||
return tun_create_by_name(name, size, dev_name, mq);
|
||||
return tun_create_by_name(name, size, dev_name);
|
||||
}
|
||||
|
||||
#endif
|
||||
|
||||
int tun_create (char *dev_name, char **ret_name, int mq)
|
||||
int tun_create (char *dev_name, char **ret_name)
|
||||
{
|
||||
char name[64] = {0};
|
||||
int fd = -1;
|
||||
|
||||
#ifndef IFF_MULTI_QUEUE
|
||||
if (mq)
|
||||
gt_na("IFF_MULTI_QUEUE");
|
||||
#endif
|
||||
|
||||
if (str_empty(dev_name)) {
|
||||
for (unsigned id=0; id<32 && fd==-1; id++)
|
||||
fd = tun_create_by_id(name, sizeof(name), id, mq);
|
||||
fd = tun_create_by_id(name, sizeof(name), id);
|
||||
} else {
|
||||
fd = tun_create_by_name(name, sizeof(name), dev_name, mq);
|
||||
fd = tun_create_by_name(name, sizeof(name), dev_name);
|
||||
}
|
||||
|
||||
if (fd!=-1 && ret_name)
|
||||
|
||||
Reference in New Issue
Block a user