cirno/plan9front
1
0
Fork 0
mirror of git://git.9front.org/plan9front/plan9front synced 2025-01-12 11:10:06 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

ip/torrent: support compact peers6 list

Browse source
This commit is contained in:
cinap_lenrek 2024-05-04 14:49:03 +00:00
parent 3ba68527b3
commit 0273db0792
1 changed files with 37 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

58
sys/src/cmd/ip/torrent.c
View file

@ -394,27 +394,21 @@ peer(int fd, int incoming, char *addr)
procsetname("peer %s: %s", addr, incoming ? "incoming" : "outgoing");
if(debug) fprint(2, "peer %s: %s connected\n", addr, incoming ? "incoming" : "outgoing");
for(i=0; i<2; i++){
if((incoming && i) || (!incoming && !i)){
if(debug) fprint(2, "peer %s: -> handshake\n", addr);
n = pack(buf, sizeof(buf), "*________**",
20, "\x13BitTorrent protocol",
sizeof(infohash), infohash,
sizeof(peerid), peerid);
if(write(fd, buf, n) != n)
return 1;
}
if((incoming && !i) || (!incoming && i)){
n = 20 + 8 + sizeof(infohash);
if(readn(fd, buf, n) != n)
return 1;
if(memcmp(buf, "\x13BitTorrent protocol", 20))
return 0;
if(memcmp(infohash, buf + 20 + 8, sizeof(infohash)))
return 0;
if(debug) fprint(2, "peer %s: <- handshake\n", addr);
}
}
if(debug) fprint(2, "peer %s: -> handshake\n", addr);
n = pack(buf, sizeof(buf), "*________**",
20, "\x13BitTorrent protocol",
sizeof(infohash), infohash,
sizeof(peerid), peerid);
if(write(fd, buf, n) != n)
return 1;
n = 20 + 8 + sizeof(infohash);
if(readn(fd, buf, n) != n)
return 1;
if(memcmp(buf, "\x13BitTorrent protocol", 20))
return 0;
if(memcmp(infohash, buf + 20 + 8, sizeof(infohash)))
return 0;
if(debug) fprint(2, "peer %s: <- handshake\n", addr);
if(readn(fd, buf, sizeof(peerid)) != sizeof(peerid))
return 1;
if(memcmp(peerid, buf, sizeof(peerid)) == 0)
@ -840,6 +834,24 @@ clients4(uchar *p, int len)
}
}
void
clients6(uchar *p, int len)
{
char ip[64], port[6];
while(len >= 18){
len -= 18;
snprint(ip, sizeof(ip), "%x:%x:%x:%x:%x:%x:%x:%x",
p[0]<<8 | p[1], p[2]<<8 | p[3],
p[4]<<8 | p[5], p[6]<<8 | p[7],
p[8]<<8 | p[9], p[10]<<8 | p[11],
p[12]<<8 | p[13], p[14]<<8 | p[15]);
snprint(port, sizeof(port), "%d", p[16]<<8 | p[17]);
p += 18;
client(ip, port);
}
}
void
webtracker(char *url)
{
@ -888,6 +900,10 @@ webtracker(char *url)
else for(; l && l->typ == 'l'; l = l->next)
client(dstr(dlook(l->val, "ip")), dstr(dlook(l->val, "port")));
}
if(l = dlook(d, "peers6")){
if(l->typ == 's')
clients6((uchar*)l->str, l->len);
}
n = 0;
if(p = dstr(dlook(d, "interval")))
n = atoi(p);