Compare commits

...

5 Commits

Author SHA1 Message Date
Adrien Gallouët
d599e545f7 Update mud 2016-10-25 09:15:34 +00:00
Frank Denis
048870e280 <linux/if.h> is not required any more (#19) 2016-10-24 11:19:43 +02:00
Frank Denis
31045456fe include <net/if.h> for the ifreq structure (#18)
Required on BSD. Doesn't break anything elsewhere.
2016-10-23 12:38:32 +02:00
Adrien Gallouët
0bb5be63b9 Get ICMP type 3 to set the next-hop MTU 2016-10-18 16:44:20 +00:00
Adrien Gallouët
c9f737197c Remove multiqueue (not used with mud) 2016-10-05 09:49:14 +00:00
4 changed files with 47 additions and 26 deletions

2
mud

Submodule mud updated: 4c34454a23...df0d941241

View File

@@ -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", &gt.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);

View File

@@ -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)

View File

@@ -2,7 +2,7 @@
#include <unistd.h>
int tun_create (char *, char **, int);
int tun_create (char *, char **);
ssize_t tun_read (int, void *, size_t);
ssize_t tun_write (int, const void *, size_t);
int tun_set_mtu (char *, int);