Compare commits

...

8 Commits

Author SHA1 Message Date
Adrien Gallouët
6df1f9e243 Update mud 2016-09-05 09:31:34 +00:00
Adrien Gallouët
73ce84ccf7 Fixes #15 2016-08-26 11:19:52 +00:00
Adrien Gallouët
91bb0b1231 Forward tos/tclass to mud 2016-07-25 15:15:27 +00:00
Adrien Gallouët
84156a9eba Update mud 2016-07-20 15:15:11 +00:00
Adrien Gallouët
b13501b9fb Update mud 2016-07-19 16:53:53 +00:00
Adrien Gallouët
3363e219a7 Update mud 2016-07-15 18:45:36 +00:00
Adrien Gallouët
00ee23b0b6 Allow IPv4 and IPv6 only on Linux 2016-07-15 18:42:28 +00:00
Adrien Gallouët
1286b0f69e Update mud 2016-07-15 17:35:45 +00:00
3 changed files with 31 additions and 7 deletions

2
mud

Submodule mud updated: 67f1f6abc2...1659caa7ca

View File

@@ -4,6 +4,7 @@
struct ip_common { struct ip_common {
uint8_t version; uint8_t version;
uint8_t tc;
uint8_t proto; uint8_t proto;
uint8_t hdr_size; uint8_t hdr_size;
uint16_t size; uint16_t size;
@@ -24,11 +25,13 @@ static inline int ip_get_common (struct ip_common *ic, const uint8_t *data, size
switch (ic->version) { switch (ic->version) {
case 4: case 4:
ic->tc = data[1];
ic->proto = data[9]; ic->proto = data[9];
ic->hdr_size = (data[0]&0xF)<<2; ic->hdr_size = (data[0]&0xF)<<2;
ic->size = ((data[2]<<8)|data[3]); ic->size = ((data[2]<<8)|data[3]);
return 0; return 0;
case 6: case 6:
ic->tc = ((data[0]&0xF)<<4)|(data[1]>>4);
ic->proto = data[6]; ic->proto = data[6];
ic->hdr_size = 40; ic->hdr_size = 40;
ic->size = ((data[4]<<8)|data[5])+40; ic->size = ((data[4]<<8)|data[5])+40;

View File

@@ -252,7 +252,11 @@ int main (int argc, char **argv)
long time_tolerance = 0; long time_tolerance = 0;
int v4 = 1; int v4 = 1;
int v6 = 1; int v6 = 0;
#ifdef __linux__
v6 = 1;
#endif
struct option opts[] = { struct option opts[] = {
{ "host", &host, option_str }, { "host", &host, option_str },
@@ -281,13 +285,18 @@ int main (int argc, char **argv)
return 0; return 0;
} }
if (option_is_set(opts, "v4only")) if (option_is_set(opts, "v4only")) {
v4 = 1;
v6 = 0; v6 = 0;
}
if (option_is_set(opts, "v6only")) if (option_is_set(opts, "v6only")) {
v4 = 0; v4 = 0;
v6 = 1;
}
if (!v4 && !v6) { if (option_is_set(opts, "v4only") &&
option_is_set(opts, "v6only")) {
gt_log("v4only and v6only are both set\n"); gt_log("v4only and v6only are both set\n");
return 1; return 1;
} }
@@ -375,6 +384,8 @@ int main (int argc, char **argv)
size_t send_size = 0; size_t send_size = 0;
size_t send_limit = 0; size_t send_limit = 0;
int send_tc = 0;
int send_next_tc = 0;
while (!gt.quit) { while (!gt.quit) {
FD_SET(tun_fd, &rfds); FD_SET(tun_fd, &rfds);
@@ -429,16 +440,26 @@ int main (int argc, char **argv)
send_size += r; send_size += r;
if (send_size<=mtu) int update_tc = (ic.tc&0xFC)>(send_tc&0xFC);
if (send_size<=mtu) {
send_limit = send_size; send_limit = send_size;
if ((ic.tc&0xFC)>(send_tc&0xFC))
send_tc = ic.tc;
} else {
if ((ic.tc&0xFC)>(send_next_tc&0xFC))
send_next_tc = ic.tc;
}
} }
} }
if (send_limit && mud_send(mud, send.buf, send_limit)==send_limit) { if (send_limit && mud_send(mud, send.buf, send_limit, send_tc)==send_limit) {
if (send_size>send_limit) if (send_size>send_limit)
memmove(&send.buf[0], &send.buf[send_limit], send_size-send_limit); memmove(&send.buf[0], &send.buf[send_limit], send_size-send_limit);
send_size -= send_limit; send_size -= send_limit;
send_limit = send_size; send_limit = send_size;
send_tc = send_next_tc;
send_next_tc = 0;
} }
mud_push(mud); mud_push(mud);