Compare commits
118 Commits
v0.0.12
...
v0.0.39-mu
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
babe14d544 | ||
|
|
278fc69789 | ||
|
|
99262777fc | ||
|
|
b0f60caab2 | ||
|
|
efd5e0bb36 | ||
|
|
ade4617d53 | ||
|
|
64a5fd8227 | ||
|
|
eba968797c | ||
|
|
d60f28a7fe | ||
|
|
32069eb104 | ||
|
|
a6adcefc25 | ||
|
|
743b0ee0da | ||
|
|
ba06a6fc10 | ||
|
|
80d4c2814f | ||
|
|
b0d5007bfb | ||
|
|
d2046eb00b | ||
|
|
d04acc9c0f | ||
|
|
03cd87df1c | ||
|
|
8e8ad7178d | ||
|
|
0e26b4def7 | ||
|
|
f800985766 | ||
|
|
7b88c28a45 | ||
|
|
194dfe17d3 | ||
|
|
664160e0cc | ||
|
|
1dd760e382 | ||
|
|
05219b81f7 | ||
|
|
0bb7e4f1d0 | ||
|
|
a7fbf806fb | ||
|
|
e750c46665 | ||
|
|
935111cfea | ||
|
|
c4b2512df4 | ||
|
|
27970e24fb | ||
|
|
acc3ee3461 | ||
|
|
eefa7722c5 | ||
|
|
17547f555d | ||
|
|
ec9c59ce69 | ||
|
|
679927a684 | ||
|
|
2999faf5d7 | ||
|
|
219384b7e5 | ||
|
|
3649e46b03 | ||
|
|
88f314bc75 | ||
|
|
e2b3dc1b46 | ||
|
|
1815ea519f | ||
|
|
33356d5d35 | ||
|
|
4a5d07ec45 | ||
|
|
a50882e1ac | ||
|
|
b2cb8ebcbe | ||
|
|
6fd6cf8c4a | ||
|
|
f0fc2751e5 | ||
|
|
81cab007d0 | ||
|
|
606396839f | ||
|
|
a8e37bafb9 | ||
|
|
87a38012cd | ||
|
|
f04816e9a5 | ||
|
|
7107d036b1 | ||
|
|
30502e05ec | ||
|
|
905673ecec | ||
|
|
cfbb77c710 | ||
|
|
13dcdc5afb | ||
|
|
56ec81bf92 | ||
|
|
f1024381e0 | ||
|
|
3f3b21f08d | ||
|
|
40dd5ce18a | ||
|
|
5efb379251 | ||
|
|
2eb6521f9c | ||
|
|
bfd81e9666 | ||
|
|
8fa2322314 | ||
|
|
8982f27220 | ||
|
|
a5f97fcc8c | ||
|
|
35a9bf27df | ||
|
|
ba0af8cc20 | ||
|
|
ec85be5c6a | ||
|
|
fe989851ab | ||
|
|
46842dd200 | ||
|
|
e5eb30598d | ||
|
|
c81ad0a7c6 | ||
|
|
97641d6dda | ||
|
|
e48dac775c | ||
|
|
6282f36ac7 | ||
|
|
cf022af4a9 | ||
|
|
597c586657 | ||
|
|
fc7f9aa0c8 | ||
|
|
7492f977b6 | ||
|
|
38b7333533 | ||
|
|
1ab854f058 | ||
|
|
c59def90fb | ||
|
|
347a3ecce7 | ||
|
|
98d13ef510 | ||
|
|
35b95001c4 | ||
|
|
75c12b36d6 | ||
|
|
db01c8b33f | ||
|
|
fb4f6f6cb9 | ||
|
|
a86aea431d | ||
|
|
1a128a6d92 | ||
|
|
ddae22a3d9 | ||
|
|
893de45272 | ||
|
|
78ba4c9a59 | ||
|
|
ffa549e444 | ||
|
|
6040f17e1c | ||
|
|
da30c9110a | ||
|
|
05de7b8109 | ||
|
|
7cc6d08d7a | ||
|
|
d526a3cfa5 | ||
|
|
0e319b068d | ||
|
|
c82026cfd7 | ||
|
|
109f70c208 | ||
|
|
23cdc37ea8 | ||
|
|
7688209093 | ||
|
|
52a3a4b853 | ||
|
|
4cf0e7bc68 | ||
|
|
f36fde5054 | ||
|
|
e08eb73f98 | ||
|
|
f3143eff83 | ||
|
|
ea1fa120eb | ||
|
|
be29a12842 | ||
|
|
113f1ae58d | ||
|
|
73fff34bfe | ||
|
|
84ae6dae32 |
3
.gitmodules
vendored
Normal file
3
.gitmodules
vendored
Normal file
@@ -0,0 +1,3 @@
|
||||
[submodule "mud"]
|
||||
path = mud
|
||||
url = https://github.com/angt/mud.git
|
||||
15
.travis.yml
15
.travis.yml
@@ -18,3 +18,18 @@ before_script:
|
||||
|
||||
script:
|
||||
- ./configure --disable-dependency-tracking && make distcheck
|
||||
|
||||
deploy:
|
||||
provider: releases
|
||||
api_key:
|
||||
secure: Ira1jd3j+17QVFbJ7KlkytTNp0oMZLTqCWPQLxNHLEt32PVY/IPs/16BcvTbFpKrY+Ma7E3KCihfufTVG8T+jRlZ5hFO7HNpoQMgi7L7yZZAGScYO5pnMQvsr8O9hf7jzSi1DjFXgFHznbPJJ3lOSwegcqzSrbZflokiCR50GTLLWewHoPpfs+1gJ5XbtVyRhZlmXhMPC0NEH2sh33X2WdUiKUJUMOnlYC0atPBL+4n12qxnugF9YA9wPK5NHJSLiPHue7I2rHlSrOLX5NkN3vqnEvusiuIFQX1y0NuKtkpOscFD9n1CLHThGLuzMvPlwpdQfzRMVxwjYFGu6Ma5alf64ksFnMKl8Oo0yCXEA7WvHXz+qUai/a1gzYZLTGuasHtjrHN/mgKxM4QRSiHo8t5hj3CczUW+OFglytawZQyGjyUUiKdwx2kvlO96RVDIYEhUD4DeHzHR8rhvDLmlMlGAWqUPXq7d4D+bExqKmqWCCSkhrbubq5B1kChRmgw7/gly4SryqGy+R0xsC4oq9jUUxd7Sl801BIKcYDb5r5gFSw+hEhOzBb+uE2xJYFNO2KZ+eG69lkFeG3oNJMTy8afs8fRRUXq0poQJ39wFWerps3Md7h8Sxs61YLIAKHvLJJMfoMI+AORTcjnnpqujMhgWGWt8wLhJZdxaSycoQkU=
|
||||
skip_cleanup: true
|
||||
file_glob: true
|
||||
file: glorytun-*.tar.gz
|
||||
on:
|
||||
tags: true
|
||||
repo: angt/glorytun
|
||||
condition: "${TRAVIS_OS_NAME}-${CC} == linux-gcc"
|
||||
|
||||
after_deploy:
|
||||
- md5sum glorytun-*.tar.gz
|
||||
|
||||
2
LICENSE
2
LICENSE
@@ -1,4 +1,4 @@
|
||||
Copyright (c) 2015, angt
|
||||
Copyright (c) 2015-2016, angt
|
||||
All rights reserved.
|
||||
|
||||
Redistribution and use in source and binary forms, with or without
|
||||
|
||||
25
Makefile.am
25
Makefile.am
@@ -6,17 +6,28 @@ glorytun_CFLAGS = $(libsodium_CFLAGS)
|
||||
glorytun_LDADD = $(libsodium_LIBS)
|
||||
glorytun_SOURCES = \
|
||||
src/common.h \
|
||||
src/common-static.h \
|
||||
src/common.c \
|
||||
src/ip-static.h \
|
||||
src/buffer.h \
|
||||
src/ip.h \
|
||||
src/str.h \
|
||||
src/main.c \
|
||||
src/option.c \
|
||||
src/option.h \
|
||||
src/tun.c \
|
||||
src/tun.h
|
||||
src/tun.h \
|
||||
src/db.c \
|
||||
src/db.h \
|
||||
src/state.c \
|
||||
src/state.h
|
||||
|
||||
glorytun_CFLAGS += -I$(srcdir)/mud
|
||||
glorytun_SOURCES += \
|
||||
mud/mud.h \
|
||||
mud/mud.c
|
||||
|
||||
EXTRA_DIST = \
|
||||
LICENSE \
|
||||
README.md \
|
||||
autogen.sh \
|
||||
version.sh
|
||||
LICENSE \
|
||||
README.md \
|
||||
VERSION \
|
||||
autogen.sh \
|
||||
version.sh
|
||||
|
||||
17
README.md
17
README.md
@@ -1,22 +1,23 @@
|
||||
# Glorytun
|
||||
# π₁(Glorytun)=ℤ²
|
||||
|
||||
Small, Simple and Stupid **TCP** VPN.
|
||||
Small, Simple and Stupid VPN over [mud](https://github.com/angt/mud).
|
||||
|
||||
**Work In Progress:** Do not touch! This code will probably format your harddisk!
|
||||
#### Work In Progress
|
||||
|
||||
This code will probably format your harddisk!
|
||||
|
||||
#### Build and Install
|
||||
|
||||
Glorytun depends on [libsodium](https://github.com/jedisct1/libsodium) version >= 1.0.4
|
||||
and needs an AES-NI capable CPU.
|
||||
|
||||
To build and install the latest version:
|
||||
|
||||
$ git clone https://github.com/angt/glorytun
|
||||
$ git clone https://github.com/angt/glorytun --recursive --branch mud
|
||||
$ cd glorytun
|
||||
$ ./autogen.sh
|
||||
$ ./configure
|
||||
$ make
|
||||
# make install
|
||||
|
||||
To create and use a new secret key:
|
||||
|
||||
$ dd if=/dev/urandom of=glorytun.key bs=32 count=1
|
||||
# glorytun keyfile glorytun.key [...]
|
||||
For feature requests and bug reports, please create an [issue](https://github.com/angt/glorytun/issues).
|
||||
|
||||
@@ -4,6 +4,7 @@ AC_INIT([glorytun],
|
||||
[https://github.com/angt/glorytun/issues],
|
||||
[glorytun],
|
||||
[https://github.com/angt/glorytun])
|
||||
AC_DEFINE_UNQUOTED([VERSION_MAJOR], [m4_esyscmd([./version.sh major])])
|
||||
AC_CONFIG_SRCDIR([src/common.h])
|
||||
AC_CONFIG_AUX_DIR([build-aux])
|
||||
AC_CONFIG_MACRO_DIR([m4])
|
||||
|
||||
1
mud
Submodule
1
mud
Submodule
Submodule mud added at 04c8495fe6
66
src/buffer.h
Normal file
66
src/buffer.h
Normal file
@@ -0,0 +1,66 @@
|
||||
#pragma once
|
||||
|
||||
#include "common.h"
|
||||
|
||||
typedef struct buffer buffer_t;
|
||||
|
||||
struct buffer {
|
||||
uint8_t *data;
|
||||
uint8_t *read;
|
||||
uint8_t *write;
|
||||
uint8_t *end;
|
||||
};
|
||||
|
||||
static inline void buffer_setup (buffer_t *buffer, void *data, size_t size)
|
||||
{
|
||||
if (!data)
|
||||
data = malloc(ALIGN(size));
|
||||
|
||||
buffer->data = data;
|
||||
buffer->read = data;
|
||||
buffer->write = data;
|
||||
buffer->end = data;
|
||||
buffer->end += size;
|
||||
}
|
||||
|
||||
static inline void buffer_format (buffer_t *buffer)
|
||||
{
|
||||
buffer->write = buffer->data;
|
||||
buffer->read = buffer->data;
|
||||
}
|
||||
|
||||
_pure_
|
||||
static inline size_t buffer_size (buffer_t *buffer)
|
||||
{
|
||||
return buffer->end-buffer->data;
|
||||
}
|
||||
|
||||
_pure_
|
||||
static inline size_t buffer_write_size (buffer_t *buffer)
|
||||
{
|
||||
return buffer->end-buffer->write;
|
||||
}
|
||||
|
||||
_pure_
|
||||
static inline size_t buffer_read_size (buffer_t *buffer)
|
||||
{
|
||||
return buffer->write-buffer->read;
|
||||
}
|
||||
|
||||
static inline void buffer_shift (buffer_t *buffer)
|
||||
{
|
||||
if (buffer->read==buffer->data)
|
||||
return;
|
||||
|
||||
if (buffer->read==buffer->write) {
|
||||
buffer_format(buffer);
|
||||
return;
|
||||
}
|
||||
|
||||
const size_t size = buffer_read_size(buffer);
|
||||
|
||||
memmove(buffer->data, buffer->read, size);
|
||||
|
||||
buffer->read = buffer->data;
|
||||
buffer->write = buffer->data+size;
|
||||
}
|
||||
@@ -1,142 +0,0 @@
|
||||
#pragma once
|
||||
|
||||
#include "common.h"
|
||||
|
||||
#include <unistd.h>
|
||||
#include <errno.h>
|
||||
|
||||
static inline void byte_set (void *dst, const char value, size_t size)
|
||||
{
|
||||
if (!dst)
|
||||
return;
|
||||
|
||||
char *restrict d = dst;
|
||||
|
||||
while (size--)
|
||||
*d++ = value;
|
||||
}
|
||||
|
||||
static inline void byte_cpy (void *dst, const void *src, size_t size)
|
||||
{
|
||||
if (!dst || !src)
|
||||
return;
|
||||
|
||||
char *restrict d = dst;
|
||||
const char *restrict s = src;
|
||||
|
||||
while (size--)
|
||||
*d++ = *s++;
|
||||
}
|
||||
|
||||
static inline size_t str_cpy (char *restrict dst, const char *restrict src, size_t len)
|
||||
{
|
||||
if (!dst || !src)
|
||||
return 0;
|
||||
|
||||
size_t i;
|
||||
|
||||
for (i=0; i<len && src[i]; i++)
|
||||
dst[i] = src[i];
|
||||
|
||||
dst[i] = 0;
|
||||
|
||||
return i;
|
||||
}
|
||||
|
||||
static inline int str_cmp (const char *restrict sa, const char *restrict sb)
|
||||
{
|
||||
if (!sa || !sb)
|
||||
return 1;
|
||||
|
||||
while (*sa==*sb++)
|
||||
if (!*sa++)
|
||||
return 0;
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
static inline size_t str_len (const char *restrict str)
|
||||
{
|
||||
if (!str)
|
||||
return 0;
|
||||
|
||||
size_t i = 0;
|
||||
|
||||
while (str[i])
|
||||
i++;
|
||||
|
||||
return i;
|
||||
}
|
||||
|
||||
static inline char *str_cat (const char *const strs[], size_t count)
|
||||
{
|
||||
size_t size = 1;
|
||||
|
||||
for (size_t i=0; i<count; i++)
|
||||
size += str_len(strs[i]);
|
||||
|
||||
char *str = malloc(size);
|
||||
|
||||
if (!str)
|
||||
return NULL;
|
||||
|
||||
char *p = str;
|
||||
|
||||
for (size_t i=0; i<count; i++) {
|
||||
size_t len = str_len(strs[i]);
|
||||
byte_cpy(p, strs[i], len);
|
||||
p += len;
|
||||
}
|
||||
|
||||
p[0] = 0;
|
||||
|
||||
return str;
|
||||
}
|
||||
|
||||
static inline void buffer_setup (buffer_t *buffer, void *data, size_t size)
|
||||
{
|
||||
if (!data)
|
||||
data = malloc(ALIGN(size));
|
||||
|
||||
buffer->data = data;
|
||||
buffer->read = data;
|
||||
buffer->write = data;
|
||||
buffer->end = data;
|
||||
buffer->end += size;
|
||||
}
|
||||
|
||||
static inline void buffer_format (buffer_t *buffer)
|
||||
{
|
||||
buffer->write = buffer->data;
|
||||
buffer->read = buffer->data;
|
||||
}
|
||||
|
||||
static inline size_t buffer_size (buffer_t *buffer)
|
||||
{
|
||||
return buffer->end-buffer->data;
|
||||
}
|
||||
|
||||
static inline size_t buffer_write_size (buffer_t *buffer)
|
||||
{
|
||||
return buffer->end-buffer->write;
|
||||
}
|
||||
|
||||
static inline size_t buffer_read_size (buffer_t *buffer)
|
||||
{
|
||||
return buffer->write-buffer->read;
|
||||
}
|
||||
|
||||
static inline void buffer_shift (buffer_t *buffer)
|
||||
{
|
||||
if (buffer->read==buffer->write) {
|
||||
buffer_format(buffer);
|
||||
} else {
|
||||
const uint8_t *src = PALIGN_DOWN(buffer->read);
|
||||
const size_t size = ALIGN(buffer->write-src);
|
||||
if (buffer->data+size<src) {
|
||||
byte_cpy(buffer->data, src, size);
|
||||
buffer->read -= src-buffer->data;
|
||||
buffer->write -= src-buffer->data;
|
||||
}
|
||||
}
|
||||
}
|
||||
58
src/common.c
58
src/common.c
@@ -36,5 +36,61 @@ void gt_fatal (const char *fmt, ...)
|
||||
|
||||
void gt_na (const char *name)
|
||||
{
|
||||
gt_log("%s is not available on your platform!\n", name);
|
||||
gt_log("%s is not available on your platform\n", name);
|
||||
}
|
||||
|
||||
int gt_tohex (char *dst, size_t dst_size, const uint8_t *src, size_t src_size)
|
||||
{
|
||||
if _0_(!dst_size)
|
||||
return -1;
|
||||
|
||||
if _0_(((dst_size-1)/2)<src_size)
|
||||
return -1;
|
||||
|
||||
static const char tbl[] = "0123456789ABCDEF";
|
||||
|
||||
for (size_t i=0; i<src_size; i++) {
|
||||
*dst++ = tbl[0xF&(src[i]>>4)];
|
||||
*dst++ = tbl[0xF&(src[i])];
|
||||
}
|
||||
|
||||
*dst = 0;
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
_const_
|
||||
static inline int fromhex (const char c)
|
||||
{
|
||||
if (c>='0' && c<='9')
|
||||
return c-'0';
|
||||
|
||||
if (c>='A' && c<='F')
|
||||
return c-'A'+10;
|
||||
|
||||
if (c>='a' && c<='f')
|
||||
return c-'a'+10;
|
||||
|
||||
return -1;
|
||||
}
|
||||
|
||||
int gt_fromhex (uint8_t *dst, size_t dst_size, const char *src, size_t src_size)
|
||||
{
|
||||
if _0_(src_size&1)
|
||||
return -1;
|
||||
|
||||
if _0_(dst_size<(src_size/2))
|
||||
return -1;
|
||||
|
||||
for (size_t i=0; i<src_size; i+=2) {
|
||||
const int a = fromhex(src[i]);
|
||||
const int b = fromhex(src[i+1]);
|
||||
|
||||
if _0_(a==-1 || b==-1)
|
||||
return -1;
|
||||
|
||||
*dst++ = (a<<4)|b;
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
27
src/common.h
27
src/common.h
@@ -2,8 +2,11 @@
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <stdint.h>
|
||||
#include <string.h>
|
||||
#include <unistd.h>
|
||||
#include <errno.h>
|
||||
|
||||
#define COUNT(x) (sizeof(x)/sizeof(x[0]))
|
||||
#define COUNT(x) (sizeof(x)/sizeof(x[0]))
|
||||
|
||||
#define ALIGN_SIZE (1<<4)
|
||||
#define ALIGN_MASK (ALIGN_SIZE-1)
|
||||
@@ -17,21 +20,19 @@
|
||||
#define _1_(x) (__builtin_expect((x), 1))
|
||||
#define _0_(x) (__builtin_expect((x), 0))
|
||||
|
||||
#define _printf_(A,B) __attribute__((format(printf,A,B)))
|
||||
#define _noreturn_ __attribute__((noreturn))
|
||||
#define _unused_ __attribute__((unused))
|
||||
#define _align_(...) __attribute__((aligned(__VA_ARGS__)))
|
||||
#define CLZ(x) (__builtin_clz(x))
|
||||
|
||||
typedef struct buffer buffer_t;
|
||||
|
||||
struct buffer {
|
||||
uint8_t *data;
|
||||
uint8_t *read;
|
||||
uint8_t *write;
|
||||
uint8_t *end;
|
||||
};
|
||||
#define _printf_(A,B) __attribute__ ((format(printf,A,B)))
|
||||
#define _noreturn_ __attribute__ ((noreturn))
|
||||
#define _unused_ __attribute__ ((unused))
|
||||
#define _pure_ __attribute__ ((pure))
|
||||
#define _const_ __attribute__ ((const))
|
||||
#define _align_(...) __attribute__ ((aligned(__VA_ARGS__)))
|
||||
|
||||
int gt_print (const char *, ...) _printf_(1,2);
|
||||
void gt_log (const char *, ...) _printf_(1,2);
|
||||
void gt_fatal (const char *, ...) _printf_(1,2) _noreturn_;
|
||||
void gt_na (const char *);
|
||||
|
||||
int gt_tohex (char *, size_t, const uint8_t *, size_t);
|
||||
int gt_fromhex (uint8_t *, size_t, const char *, size_t);
|
||||
|
||||
155
src/db.c
Normal file
155
src/db.c
Normal file
@@ -0,0 +1,155 @@
|
||||
#include "common.h"
|
||||
|
||||
#include "db.h"
|
||||
#include "str.h"
|
||||
|
||||
#define CBIT(X) (1&(intptr_t)(X))
|
||||
#define CBIT_PTR(X) (uint8_t *)(1|(intptr_t)(X))
|
||||
#define CBIT_NODE(X) (struct node *)(1^(intptr_t)(X))
|
||||
|
||||
struct node {
|
||||
uint8_t *child[2];
|
||||
uint32_t point;
|
||||
};
|
||||
|
||||
_pure_
|
||||
static inline size_t db_size (const uint8_t *a)
|
||||
{
|
||||
return (a[0]?:str_len((char *)a+1))+1;
|
||||
}
|
||||
|
||||
_pure_
|
||||
static inline size_t db_cmp (const uint8_t *a, const uint8_t *b)
|
||||
{
|
||||
const size_t size = a[0];
|
||||
|
||||
if (size!=b[0])
|
||||
return 1;
|
||||
|
||||
if (!size) {
|
||||
size_t i = str_cmp((char *)a+1, (char *)b+1);
|
||||
return i?i+1:0;
|
||||
}
|
||||
|
||||
for (size_t i=1; i<=size; i++) {
|
||||
if (a[i]!=b[i])
|
||||
return i+1;
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
_pure_
|
||||
static inline int db_dir (const uint32_t point, uint8_t *data, const size_t size)
|
||||
{
|
||||
const size_t pos = point>>8;
|
||||
|
||||
if (pos>=size)
|
||||
return 0;
|
||||
|
||||
return ((point|data[pos])&255)==255;
|
||||
}
|
||||
|
||||
uint8_t *db_search (uint8_t **p, uint8_t *data)
|
||||
{
|
||||
if _0_(!*p)
|
||||
return NULL;
|
||||
|
||||
uint8_t *r = *p;
|
||||
const size_t size = db_size(data);
|
||||
|
||||
while (CBIT(r)) {
|
||||
struct node *node = CBIT_NODE(r);
|
||||
r = node->child[db_dir(node->point, data, size)];
|
||||
}
|
||||
|
||||
if (!db_cmp(r, data))
|
||||
return r;
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
uint8_t *db_insert (uint8_t **p, uint8_t *data)
|
||||
{
|
||||
if _0_(CBIT(data))
|
||||
return NULL;
|
||||
|
||||
if _0_(!*p) {
|
||||
*p = data;
|
||||
return data;
|
||||
}
|
||||
|
||||
uint8_t *r = *p;
|
||||
size_t size = db_size(data);
|
||||
|
||||
while (CBIT(r)) {
|
||||
struct node *node = CBIT_NODE(r);
|
||||
r = node->child[db_dir(node->point, data, size)];
|
||||
}
|
||||
|
||||
const size_t diff = db_cmp(r, data);
|
||||
|
||||
if _0_(!diff)
|
||||
return r;
|
||||
|
||||
const size_t pos = diff-1;
|
||||
const uint8_t mask = ~((1u<<31)>>CLZ(r[pos]^data[pos]));
|
||||
const size_t point = (pos<<8)|mask;
|
||||
|
||||
while (CBIT(*p)) {
|
||||
struct node *node = CBIT_NODE(*p);
|
||||
|
||||
if (node->point>point)
|
||||
break;
|
||||
|
||||
p = node->child+db_dir(node->point, data, size);
|
||||
}
|
||||
|
||||
struct node *node = malloc(sizeof(struct node));
|
||||
|
||||
if _0_(!node)
|
||||
return NULL;
|
||||
|
||||
const int dir = (mask|r[pos])==255;
|
||||
|
||||
node->child[dir] = *p;
|
||||
node->child[1-dir] = data;
|
||||
node->point = point;
|
||||
|
||||
*p = CBIT_PTR(node);
|
||||
|
||||
return data;
|
||||
}
|
||||
|
||||
uint8_t *db_remove (uint8_t **p, uint8_t *data)
|
||||
{
|
||||
if _0_(!*p)
|
||||
return NULL;
|
||||
|
||||
const size_t size = db_size(data);
|
||||
|
||||
uint8_t **p_old = NULL;
|
||||
struct node *node = NULL;
|
||||
int dir = 0;
|
||||
|
||||
while (CBIT(*p)) {
|
||||
p_old = p;
|
||||
node = CBIT_NODE(*p);
|
||||
dir = db_dir(node->point, data, size);
|
||||
p = node->child+dir;
|
||||
}
|
||||
|
||||
if _0_(db_cmp(data, *p))
|
||||
return NULL;
|
||||
|
||||
uint8_t *r = *p;
|
||||
|
||||
if (p_old) {
|
||||
*p_old = node->child[1-dir];
|
||||
free(node);
|
||||
} else {
|
||||
*p = NULL;
|
||||
}
|
||||
|
||||
return r;
|
||||
}
|
||||
7
src/db.h
Normal file
7
src/db.h
Normal file
@@ -0,0 +1,7 @@
|
||||
#pragma once
|
||||
|
||||
#include <stdint.h>
|
||||
|
||||
uint8_t *db_search (uint8_t **, uint8_t *);
|
||||
uint8_t *db_insert (uint8_t **, uint8_t *);
|
||||
uint8_t *db_remove (uint8_t **, uint8_t *);
|
||||
@@ -1,39 +0,0 @@
|
||||
#pragma once
|
||||
|
||||
#include <stdint.h>
|
||||
|
||||
static inline int ip_get_version (const uint8_t *data, size_t size)
|
||||
{
|
||||
if (size<20) // XXX
|
||||
return -1; // XXX
|
||||
|
||||
return data[0]>>4;
|
||||
}
|
||||
|
||||
static inline void ip_set_size (uint8_t *data, size_t size)
|
||||
{
|
||||
data[2] = 0xFF&(size>>8);
|
||||
data[3] = 0xFF&(size);
|
||||
}
|
||||
|
||||
static inline ssize_t ip_get_size (const uint8_t *data, size_t size)
|
||||
{
|
||||
switch (ip_get_version(data, size)) {
|
||||
case 4:
|
||||
return (data[2]<<8)|data[3];
|
||||
case -1:
|
||||
return -1;
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static inline int ip_get_dscp (const uint8_t *data, size_t size)
|
||||
{
|
||||
switch (ip_get_version(data, size)) {
|
||||
case 4:
|
||||
return data[1]>>2;
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
39
src/ip.h
Normal file
39
src/ip.h
Normal file
@@ -0,0 +1,39 @@
|
||||
#pragma once
|
||||
|
||||
#include <stdint.h>
|
||||
|
||||
struct ip_common {
|
||||
uint8_t version;
|
||||
uint8_t proto;
|
||||
uint8_t hdr_size;
|
||||
uint16_t size;
|
||||
};
|
||||
|
||||
_pure_
|
||||
static inline uint8_t ip_get_version (const uint8_t *data, size_t size)
|
||||
{
|
||||
if (size<20)
|
||||
return 0;
|
||||
|
||||
return data[0]>>4;
|
||||
}
|
||||
|
||||
static inline int ip_get_common (struct ip_common *ic, const uint8_t *data, size_t size)
|
||||
{
|
||||
ic->version = ip_get_version(data, size);
|
||||
|
||||
switch (ic->version) {
|
||||
case 4:
|
||||
ic->proto = data[9];
|
||||
ic->hdr_size = (data[0]&0xF)<<2;
|
||||
ic->size = ((data[2]<<8)|data[3]);
|
||||
return 0;
|
||||
case 6:
|
||||
ic->proto = data[6];
|
||||
ic->hdr_size = 40;
|
||||
ic->size = ((data[4]<<8)|data[5])+40;
|
||||
return 0;
|
||||
}
|
||||
|
||||
return -1;
|
||||
}
|
||||
1013
src/main.c
1013
src/main.c
File diff suppressed because it is too large
Load Diff
14
src/option.c
14
src/option.c
@@ -1,25 +1,23 @@
|
||||
#include "common-static.h"
|
||||
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include "common.h"
|
||||
|
||||
#include "option.h"
|
||||
#include "str.h"
|
||||
|
||||
int option_str (void *data, int argc, char **argv)
|
||||
{
|
||||
if (argc<2 || !argv[1]) {
|
||||
if (argc<2 || str_empty(argv[1])) {
|
||||
gt_print("option `%s' need a string argument\n", argv[0]);
|
||||
return -1;
|
||||
}
|
||||
|
||||
byte_cpy(data, &argv[1], sizeof(argv[1]));
|
||||
memcpy(data, &argv[1], sizeof(argv[1]));
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
int option_long (void *data, int argc, char **argv)
|
||||
{
|
||||
if (argc<2 || !argv[1]) {
|
||||
if (argc<2 || str_empty(argv[1])) {
|
||||
gt_print("option `%s' need an integer argument\n", argv[0]);
|
||||
return -1;
|
||||
}
|
||||
@@ -33,7 +31,7 @@ int option_long (void *data, int argc, char **argv)
|
||||
return -1;
|
||||
}
|
||||
|
||||
byte_cpy(data, &val, sizeof(val));
|
||||
memcpy(data, &val, sizeof(val));
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
61
src/state.c
Normal file
61
src/state.c
Normal file
@@ -0,0 +1,61 @@
|
||||
#include "common.h"
|
||||
|
||||
#include "state.h"
|
||||
#include "str.h"
|
||||
|
||||
#include <stdio.h>
|
||||
#include <fcntl.h>
|
||||
#include <sys/stat.h>
|
||||
|
||||
static int state_fd = -1;
|
||||
|
||||
int state_init (const char *filename)
|
||||
{
|
||||
if (str_empty(filename))
|
||||
return 0;
|
||||
|
||||
state_fd = open(filename, O_WRONLY);
|
||||
|
||||
if (state_fd==-1) {
|
||||
if (errno!=EINTR)
|
||||
perror("open");
|
||||
return -1;
|
||||
}
|
||||
|
||||
struct stat st = {0};
|
||||
|
||||
if (fstat(state_fd, &st)==-1) {
|
||||
perror("fstat");
|
||||
close(state_fd);
|
||||
state_fd = -1;
|
||||
return -1;
|
||||
}
|
||||
|
||||
if (!S_ISFIFO(st.st_mode)) {
|
||||
gt_log("`%s' is not a fifo\n", filename);
|
||||
close(state_fd);
|
||||
state_fd = -1;
|
||||
return -1;
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
void state (const char *state, const char *info)
|
||||
{
|
||||
if (str_empty(state))
|
||||
return;
|
||||
|
||||
const char *strs[] = { state, " ", info, "\n" };
|
||||
char *str = str_cat(strs, COUNT(strs));
|
||||
|
||||
if (!str)
|
||||
return;
|
||||
|
||||
if (state_fd==-1) {
|
||||
gt_print("%s", str);
|
||||
} else {
|
||||
if (write(state_fd, str, str_len(str))==-1 && errno!=EINTR)
|
||||
perror("write");
|
||||
}
|
||||
}
|
||||
4
src/state.h
Normal file
4
src/state.h
Normal file
@@ -0,0 +1,4 @@
|
||||
#pragma once
|
||||
|
||||
int state_init (const char *);
|
||||
void state (const char *, const char *);
|
||||
73
src/str.h
Normal file
73
src/str.h
Normal file
@@ -0,0 +1,73 @@
|
||||
#pragma once
|
||||
|
||||
#include "common.h"
|
||||
|
||||
static inline size_t str_cpy (char *restrict dst, const char *restrict src, size_t len)
|
||||
{
|
||||
if (!dst || !src)
|
||||
return 0;
|
||||
|
||||
size_t i;
|
||||
|
||||
for (i=0; i<len && src[i]; i++)
|
||||
dst[i] = src[i];
|
||||
|
||||
dst[i] = 0;
|
||||
|
||||
return i;
|
||||
}
|
||||
|
||||
_pure_
|
||||
static inline int str_empty (const char *restrict str)
|
||||
{
|
||||
return !str || !str[0];
|
||||
}
|
||||
|
||||
_pure_
|
||||
static inline size_t str_cmp (const char *restrict sa, const char *restrict sb)
|
||||
{
|
||||
if (!sa || !sb)
|
||||
return 1;
|
||||
|
||||
size_t i = 0;
|
||||
|
||||
while (sa[i]==sb[i])
|
||||
if (!sa[i++])
|
||||
return 0;
|
||||
|
||||
return i+1;
|
||||
}
|
||||
|
||||
_pure_
|
||||
static inline size_t str_len (const char *restrict str)
|
||||
{
|
||||
if (!str)
|
||||
return 0;
|
||||
|
||||
return strlen(str);
|
||||
}
|
||||
|
||||
static inline char *str_cat (const char **strs, size_t count)
|
||||
{
|
||||
size_t size = 1;
|
||||
|
||||
for (size_t i=0; i<count; i++)
|
||||
size += str_len(strs[i]);
|
||||
|
||||
char *str = malloc(size);
|
||||
|
||||
if (!str)
|
||||
return NULL;
|
||||
|
||||
char *p = str;
|
||||
|
||||
for (size_t i=0; i<count; i++) {
|
||||
size_t len = str_len(strs[i]);
|
||||
memcpy(p, strs[i], len);
|
||||
p += len;
|
||||
}
|
||||
|
||||
p[0] = 0;
|
||||
|
||||
return str;
|
||||
}
|
||||
177
src/tun.c
177
src/tun.c
@@ -1,7 +1,8 @@
|
||||
#include "common-static.h"
|
||||
#include "ip-static.h"
|
||||
#include "common.h"
|
||||
|
||||
#include "tun.h"
|
||||
#include "str.h"
|
||||
#include "ip.h"
|
||||
|
||||
#include <stdio.h>
|
||||
#include <fcntl.h>
|
||||
@@ -11,116 +12,148 @@
|
||||
#include <sys/uio.h>
|
||||
|
||||
#ifdef __linux__
|
||||
# include <linux/if.h>
|
||||
# include <linux/if_tun.h>
|
||||
#include <linux/if.h>
|
||||
#include <linux/if_tun.h>
|
||||
#endif
|
||||
|
||||
#ifdef __APPLE__
|
||||
# include <sys/sys_domain.h>
|
||||
# include <sys/kern_control.h>
|
||||
# include <net/if_utun.h>
|
||||
#include <sys/sys_domain.h>
|
||||
#include <sys/kern_control.h>
|
||||
#include <net/if_utun.h>
|
||||
#endif
|
||||
|
||||
#if defined(__APPLE__) || defined(__OpenBSD__)
|
||||
# define GT_BSD_TUN 1
|
||||
#define GT_BSD_TUN
|
||||
#endif
|
||||
|
||||
#ifdef __APPLE__
|
||||
|
||||
static int tun_create_by_id (char *name, size_t size, unsigned id, _unused_ int mq)
|
||||
{
|
||||
int fd = socket(PF_SYSTEM, SOCK_DGRAM, SYSPROTO_CONTROL);
|
||||
|
||||
if (fd==-1)
|
||||
return -1;
|
||||
|
||||
struct ctl_info ci;
|
||||
|
||||
memset(&ci, 0, sizeof(ci));
|
||||
str_cpy(ci.ctl_name, UTUN_CONTROL_NAME, sizeof(ci.ctl_name)-1);
|
||||
|
||||
if (ioctl(fd, CTLIOCGINFO, &ci)) {
|
||||
close(fd);
|
||||
return -1;
|
||||
}
|
||||
|
||||
struct sockaddr_ctl sc = {
|
||||
.sc_id = ci.ctl_id,
|
||||
.sc_len = sizeof(sc),
|
||||
.sc_family = AF_SYSTEM,
|
||||
.ss_sysaddr = AF_SYS_CONTROL,
|
||||
.sc_unit = id+1,
|
||||
};
|
||||
|
||||
if (connect(fd, (struct sockaddr *)&sc, sizeof(sc))) {
|
||||
close(fd);
|
||||
return -1;
|
||||
}
|
||||
|
||||
snprintf(name, size, "utun%u", id);
|
||||
|
||||
return fd;
|
||||
}
|
||||
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name, int mq)
|
||||
{
|
||||
unsigned id = 0;
|
||||
|
||||
if (sscanf(dev_name, "utun%u", &id)!=1)
|
||||
return -1;
|
||||
|
||||
return tun_create_by_id(name, size, id, mq);
|
||||
}
|
||||
|
||||
#else /* not __APPLE__ */
|
||||
|
||||
#ifdef __linux__
|
||||
int tun_create (char *name, int multiqueue)
|
||||
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name, int mq)
|
||||
{
|
||||
int fd = open("/dev/net/tun", O_RDWR);
|
||||
|
||||
if (fd<0) {
|
||||
perror("open /dev/net/tun");
|
||||
if (fd==-1)
|
||||
return -1;
|
||||
}
|
||||
|
||||
struct ifreq ifr = {
|
||||
.ifr_flags = IFF_TUN|IFF_NO_PI,
|
||||
};
|
||||
|
||||
if (multiqueue) {
|
||||
if (mq) {
|
||||
#ifdef IFF_MULTI_QUEUE
|
||||
ifr.ifr_flags |= IFF_MULTI_QUEUE;
|
||||
#else
|
||||
gt_na("IFF_MULTI_QUEUE");
|
||||
#endif
|
||||
}
|
||||
|
||||
str_cpy(ifr.ifr_name, name, IFNAMSIZ-1);
|
||||
str_cpy(ifr.ifr_name, dev_name, IFNAMSIZ-1);
|
||||
|
||||
int ret = ioctl(fd, TUNSETIFF, &ifr);
|
||||
|
||||
if (ret<0) {
|
||||
perror("ioctl TUNSETIFF");
|
||||
if (ioctl(fd, TUNSETIFF, &ifr)) {
|
||||
close(fd);
|
||||
return -1;
|
||||
}
|
||||
|
||||
gt_log("tun name: %s\n", ifr.ifr_name);
|
||||
str_cpy(name, ifr.ifr_name, size-1);
|
||||
|
||||
return fd;
|
||||
}
|
||||
#elif defined(__APPLE__)
|
||||
int tun_create (_unused_ char *name, _unused_ int mq)
|
||||
|
||||
#else /* not __linux__ not __APPLE__ */
|
||||
|
||||
static int tun_create_by_name (char *name, size_t size, char *dev_name, _unused_ int mq)
|
||||
{
|
||||
for (unsigned dev_id = 0; dev_id < 32; dev_id++) {
|
||||
struct ctl_info ci;
|
||||
char path[64];
|
||||
|
||||
byte_set(&ci, 0, sizeof(ci));
|
||||
str_cpy(ci.ctl_name, UTUN_CONTROL_NAME, sizeof(ci.ctl_name)-1);
|
||||
snprintf(path, sizeof(path), "/dev/%s", dev_name);
|
||||
str_cpy(name, dev_name, size-1);
|
||||
|
||||
int fd = socket(PF_SYSTEM, SOCK_DGRAM, SYSPROTO_CONTROL);
|
||||
|
||||
if (fd==-1)
|
||||
return -1;
|
||||
|
||||
if (ioctl(fd, CTLIOCGINFO, &ci)==-1) {
|
||||
close(fd);
|
||||
continue;
|
||||
}
|
||||
|
||||
struct sockaddr_ctl sc = {
|
||||
.sc_id = ci.ctl_id,
|
||||
.sc_len = sizeof(sc),
|
||||
.sc_family = AF_SYSTEM,
|
||||
.ss_sysaddr = AF_SYS_CONTROL,
|
||||
.sc_unit = dev_id+1,
|
||||
};
|
||||
|
||||
if (connect(fd, (struct sockaddr *)&sc, sizeof(sc))==-1) {
|
||||
close(fd);
|
||||
continue;
|
||||
}
|
||||
|
||||
gt_log("tun name: /dev/utun%u\n", dev_id);
|
||||
|
||||
return fd;
|
||||
}
|
||||
|
||||
return -1;
|
||||
return open(path, O_RDWR);
|
||||
}
|
||||
#else
|
||||
int tun_create (_unused_ char *name, _unused_ int mq)
|
||||
|
||||
#endif /* not __APPLE__ */
|
||||
|
||||
static int tun_create_by_id (char *name, size_t size, unsigned id, int mq)
|
||||
{
|
||||
for (unsigned dev_id = 0; dev_id < 32; dev_id++) {
|
||||
char dev_path[11];
|
||||
char dev_name[64];
|
||||
|
||||
snprintf(dev_path, sizeof(dev_path), "/dev/tun%u", dev_id);
|
||||
snprintf(dev_name, sizeof(dev_name), "tun%u", id);
|
||||
|
||||
int fd = open(dev_path, O_RDWR);
|
||||
|
||||
if (fd==-1)
|
||||
continue;
|
||||
|
||||
gt_log("tun name: %s\n", dev_path);
|
||||
|
||||
return fd;
|
||||
}
|
||||
|
||||
return -1;
|
||||
return tun_create_by_name(name, size, dev_name, mq);
|
||||
}
|
||||
|
||||
#endif
|
||||
|
||||
int tun_create (char *dev_name, char **ret_name, int mq)
|
||||
{
|
||||
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);
|
||||
} else {
|
||||
fd = tun_create_by_name(name, sizeof(name), dev_name, mq);
|
||||
}
|
||||
|
||||
if (fd!=-1 && ret_name)
|
||||
*ret_name = strdup(name);
|
||||
|
||||
return fd;
|
||||
}
|
||||
|
||||
ssize_t tun_read (int fd, void *data, size_t size)
|
||||
{
|
||||
if (!size)
|
||||
|
||||
@@ -2,6 +2,6 @@
|
||||
|
||||
#include <unistd.h>
|
||||
|
||||
int tun_create (char *, int);
|
||||
int tun_create (char *, char **, int);
|
||||
ssize_t tun_read (int, void *, size_t);
|
||||
ssize_t tun_write (int, const void *, size_t);
|
||||
|
||||
12
version.sh
12
version.sh
@@ -1,9 +1,13 @@
|
||||
#!/bin/sh
|
||||
|
||||
[ -z "${VERSION}" ] && VERSION=`git describe --tags --always 2>/dev/null` \
|
||||
[ -z "${VERSION}" ] && VERSION=`git describe --tags --match='v[0-9].*' 2>/dev/null` \
|
||||
&& VERSION=${VERSION#v}
|
||||
|
||||
[ -z "${VERSION}" ] && VERSION=`basename \`pwd\`` \
|
||||
&& VERSION=${VERSION#*-}
|
||||
[ -z "${VERSION}" ] && VERSION=`cat VERSION 2>/dev/null`
|
||||
|
||||
echo -n ${VERSION}
|
||||
[ -z "${VERSION}" ] && VERSION=0.0.0
|
||||
|
||||
[ "$1" = "major" ] && printf ${VERSION%%.*} \
|
||||
&& exit 0
|
||||
|
||||
printf ${VERSION} | tee VERSION
|
||||
|
||||
Reference in New Issue
Block a user