mirrors/iodine
1
0
Fork 0
mirror of https://github.com/yarrick/iodine.git synced 2024-11-16 04:43:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

#7, handle special case, remove up to 1 second pause when doing bulk download

Browse source
This commit is contained in:
Erik Ekman 2009-01-05 17:08:34 +00:00
parent 20cfb002c3
commit 78aaf26369
1 changed files with 37 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

50
src/iodine.c
View file

@ -61,6 +61,8 @@ static char *topdomain;
static uint16_t rand_seed; static uint16_t rand_seed;
static int downstream_seqno; static int downstream_seqno;
static int downstream_fragment; static int downstream_fragment;
static int down_ack_seqno;
static int down_ack_fragment;
/* Current IP packet */ /* Current IP packet */
static struct packet outpkt; static struct packet outpkt;
@ -175,22 +177,36 @@ read_dns(int fd, char *buf, int buflen)
rv = dns_decode(buf, buflen, &q, QR_ANSWER, data, r); rv = dns_decode(buf, buflen, &q, QR_ANSWER, data, r);
/* decode the data header, update seqno and frag before next request */ /* decode the data header, update seqno and frag before next request */
if (rv > 2) { if (rv >= 2) {
downstream_seqno = (buf[1] >> 5) & 7; downstream_seqno = (buf[1] >> 5) & 7;
downstream_fragment = (buf[1] >> 1) & 15; downstream_fragment = (buf[1] >> 1) & 15;
} }
if (is_sending() && chunkid == q.id) {
/* Got ACK on sent packet */ if (is_sending()) {
outpkt.offset += outpkt.sentlen; if (chunkid == q.id) {
if (outpkt.offset == outpkt.len) { /* Got ACK on sent packet */
/* Packet completed */ outpkt.offset += outpkt.sentlen;
outpkt.offset = 0; if (outpkt.offset == outpkt.len) {
outpkt.len = 0; /* Packet completed */
outpkt.sentlen = 0; outpkt.offset = 0;
} else { outpkt.len = 0;
/* More to send */ outpkt.sentlen = 0;
send_chunk(fd);
/* If the ack contains unacked frag number but no data,
* send a ping to ack the frag number and get more data*/
if (rv == 2 && (
downstream_seqno != down_ack_seqno ||
downstream_fragment != down_ack_fragment
)) {
send_ping(fd);
}
} else {
/* More to send */
send_chunk(fd);
}
} }
} }
return rv; return rv;
@ -340,7 +356,10 @@ send_chunk(int fd)
buf[2] = b32_5to8(code); /* Third byte is 2 bits lower fragment count, 3 bits downstream packet seqno */ buf[2] = b32_5to8(code); /* Third byte is 2 bits lower fragment count, 3 bits downstream packet seqno */
code = ((downstream_fragment & 15) << 1) | (outpkt.sentlen == avail); code = ((downstream_fragment & 15) << 1) | (outpkt.sentlen == avail);
buf[3] = b32_5to8(code); /* Fourth byte is 4 bits downstream fragment count, 1 bit compression flag */ buf[3] = b32_5to8(code); /* Fourth byte is 4 bits downstream fragment count, 1 bit last frag flag */
down_ack_seqno = downstream_seqno;
down_ack_fragment = downstream_fragment;
outpkt.fragment++; outpkt.fragment++;
send_query(fd, buf); send_query(fd, buf);
@ -379,6 +398,9 @@ send_ping(int fd)
data[2] = (rand_seed >> 8) & 0xff; data[2] = (rand_seed >> 8) & 0xff;
data[3] = (rand_seed >> 0) & 0xff; data[3] = (rand_seed >> 0) & 0xff;
down_ack_seqno = downstream_seqno;
down_ack_fragment = downstream_fragment;
rand_seed++; rand_seed++;
send_packet(fd, 'P', data, sizeof(data)); send_packet(fd, 'P', data, sizeof(data));
@ -867,6 +889,8 @@ main(int argc, char **argv)
downstream_seqno = 0; downstream_seqno = 0;
downstream_fragment = 0; downstream_fragment = 0;
down_ack_seqno = 0;
down_ack_fragment = 0;
tunnel(tun_fd, dns_fd); tunnel(tun_fd, dns_fd);