Add two chars from client to server for verification of data delivery

This commit is contained in:
Erik Ekman 2007-12-02 01:16:53 +00:00 committed by Erik Ekman
parent d50533e26e
commit 924f4b3759
4 changed files with 38 additions and 14 deletions

View file

@ -49,7 +49,7 @@ inline_dotify(char *buf, size_t buflen)
} }
reader = writer - dots; reader = writer - dots;
pos = (unsigned) (reader - buf) + 1; pos = (unsigned) (reader - buf);
while (dots) { while (dots) {
if (pos % 62 == 0) { if (pos % 62 == 0) {

View file

@ -46,7 +46,7 @@
static void send_ping(int fd); static void send_ping(int fd);
static void send_chunk(int fd); static void send_chunk(int fd);
static int build_hostname(char *buf, size_t buflen, static int build_hostname(char *buf, size_t buflen, size_t offset,
const char *data, const size_t datalen, const char *data, const size_t datalen,
const char *topdomain, struct encoder *encoder); const char *topdomain, struct encoder *encoder);
@ -67,6 +67,9 @@ static char userid;
/* DNS id for next packet */ /* DNS id for next packet */
static uint16_t chunkid; static uint16_t chunkid;
/* DNS id for last packet with payload from server */
static uint16_t server_id;
/* Base32 encoder used for non-data packets */ /* Base32 encoder used for non-data packets */
static struct encoder *b32; static struct encoder *b32;
@ -77,6 +80,9 @@ static struct encoder *dataenc;
/* result of case preservation check done after login */ /* result of case preservation check done after login */
static int case_preserved; static int case_preserved;
/* For easy conversion 0-F to ascii digit */
static char hex[] = "0123456789ABCDEF";
static void static void
sighandler(int sig) sighandler(int sig)
{ {
@ -103,14 +109,15 @@ send_packet(int fd, char cmd, const char *data, const size_t datalen)
{ {
char buf[4096]; char buf[4096];
build_hostname(buf, sizeof(buf), 1, data, datalen, topdomain, b32);
/* build_hostname clears buf, write command afterwards */
buf[0] = cmd; buf[0] = cmd;
build_hostname(buf + 1, sizeof(buf) - 1, data, datalen, topdomain, b32);
send_query(fd, buf); send_query(fd, buf);
} }
static int static int
build_hostname(char *buf, size_t buflen, build_hostname(char *buf, size_t buflen, size_t offset,
const char *data, const size_t datalen, const char *data, const size_t datalen,
const char *topdomain, struct encoder *encoder) const char *topdomain, struct encoder *encoder)
{ {
@ -118,14 +125,15 @@ build_hostname(char *buf, size_t buflen,
size_t space; size_t space;
char *b; char *b;
space = MIN(0xFF, buflen) - strlen(topdomain) - 2; space = MIN(0xFF, buflen) - strlen(topdomain) - 2;
if (!encoder->places_dots()) if (!encoder->places_dots())
space -= (space / 62); /* space for dots */ space -= (space / 62); /* space for dots */
memset(buf, 0, buflen); memset(buf, 0, buflen);
memset(buf, 'A', offset);
encsize = encoder->encode(buf, &space, data, datalen); b = buf + offset;
encsize = encoder->encode(b, &space, data, datalen);
if (!encoder->places_dots()) if (!encoder->places_dots())
inline_dotify(buf, buflen); inline_dotify(buf, buflen);
@ -266,7 +274,6 @@ tunnel(int tun_fd, int dns_fd)
static void static void
send_chunk(int fd) send_chunk(int fd)
{ {
char hex[] = "0123456789ABCDEF";
char buf[4096]; char buf[4096];
int avail; int avail;
int code; int code;
@ -277,7 +284,7 @@ send_chunk(int fd)
p += packet.offset; p += packet.offset;
avail = packet_len_to_send(&packet); avail = packet_len_to_send(&packet);
sentlen = build_hostname(buf + 1, sizeof(buf) - 1, p, avail, topdomain, dataenc); sentlen = build_hostname(buf, sizeof(buf), 3, p, avail, topdomain, dataenc);
packet_send_len(&packet, sentlen); packet_send_len(&packet, sentlen);
@ -289,6 +296,14 @@ send_chunk(int fd)
code |= (userid << 1); code |= (userid << 1);
buf[0] = hex[code]; buf[0] = hex[code];
/* tell server we received reply */
if (server_id != 0) {
buf[1] = hex[(server_id >> 4) & 0xf];
buf[2] = hex[(server_id >> 0) & 0xf];
} else {
buf[1] = 'N';
buf[2] = 'A';
}
send_query(fd, buf); send_query(fd, buf);
} }
@ -312,14 +327,22 @@ send_login(int fd, char *login, int len)
static void static void
send_ping(int fd) send_ping(int fd)
{ {
char data[3]; char data[5];
/* clear any packet not sent */ /* clear any packet not sent */
packet_init(&packet); packet_init(&packet);
data[0] = userid; data[0] = userid;
data[1] = (rand_seed >> 8) & 0xff; /* tell server we received reply */
data[2] = (rand_seed >> 0) & 0xff; if (server_id != 0) {
data[1] = hex[(server_id >> 4) & 0xf];
data[2] = hex[(server_id >> 0) & 0xf];
} else {
data[1] = '1';
data[2] = '1';
}
data[3] = (rand_seed >> 8) & 0xff;
data[4] = (rand_seed >> 0) & 0xff;
rand_seed++; rand_seed++;
@ -616,6 +639,7 @@ main(int argc, char **argv)
newroot = NULL; newroot = NULL;
device = NULL; device = NULL;
chunkid = 0; chunkid = 0;
server_id = 0;
b32 = get_base32_encoder(); b32 = get_base32_encoder();
dataenc = get_base32_encoder(); dataenc = get_base32_encoder();

View file

@ -255,7 +255,7 @@ tunnel_dns(int tun_fd, int dns_fd)
write_dns(dns_fd, &(dummy.q), "BADIP", 5); write_dns(dns_fd, &(dummy.q), "BADIP", 5);
} else { } else {
/* decode with this users encoding */ /* decode with this users encoding */
read = unpack_data(unpacked, sizeof(unpacked), &(in[1]), read - 1, read = unpack_data(unpacked, sizeof(unpacked), &(in[3]), read - 3,
users[userid].encoder); users[userid].encoder);
users[userid].last_pkt = time(NULL); users[userid].last_pkt = time(NULL);

View file

@ -19,7 +19,7 @@
/* This is the version of the network protocol /* This is the version of the network protocol
It is usually equal to the latest iodine version number */ It is usually equal to the latest iodine version number */
#define VERSION 0x00000402 #define VERSION 0x00000403
#endif /* _VERSION_H_ */ #endif /* _VERSION_H_ */