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: allow seeding files from read-only contexts.

Browse source 
Makes 'auth/none ip/torrent -s ...' work without making
the files world writable iff we already have all pieces
of the torrent.
This commit is contained in:
Jacob Moody 2023-11-26 20:23:45 +00:00
parent cbf003434b
commit 1633e20b32
1 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -29,7 +29,8 @@ struct File
{
File *next;
char *name;
int fd;
int rfd;
int wfd;
vlong off;
vlong len;
};
@ -204,7 +205,7 @@ rwpiece(int wr, int index, uchar *data, int len, int poff)
break;
off -= f->off;
n = ((off + len) > f->len) ? f->len - off : len;
if((n = (wr ? pwrite(f->fd, data, n, off) : pread(f->fd, data, n, off))) <= 0)
if((n = (wr ? pwrite(f->wfd, data, n, off) : pread(f->rfd, data, n, off))) <= 0)
return -1;
if((m = rwpiece(wr, index, data + n, len - n, poff + n)) < 0)
return -1;
@ -1292,6 +1293,7 @@ main(int argc, char *argv[])
f = mallocz(sizeof(*f), 1);
f->len = atoll(s);
f->name = dstr(dlook(info, "name"));
f->rfd = f->wfd = -1;
for(di = dlook(d->val, "path"); di && di->typ == 'l'; di = di->next)
if(s = dstr(di->val))
f->name = f->name ? smprint("%s/%s", f->name, s) : s;
@ -1302,6 +1304,7 @@ main(int argc, char *argv[])
f = mallocz(sizeof(*f), 1);
f->len = atoll(s);
f->name = dstr(dlook(info, "name"));
f->rfd = f->wfd = -1;
*fp = f;
}
len = 0;
@ -1310,10 +1313,10 @@ main(int argc, char *argv[])
sysfatal("bogus file entry in meta info");
s = fixnamedup(f->name);
if(vflag) fprint(pflag ? 2 : 1, "%s\n", s);
if((f->fd = open(s, ORDWR)) < 0){
if((f->rfd = open(s, OREAD)) < 0){
if(mkdirs(s) < 0)
sysfatal("mkdirs: %r");
if((f->fd = create(s, ORDWR, 0666)) < 0)
if((f->wfd = f->rfd = create(s, ORDWR, 0666)) < 0)
sysfatal("create: %r");
}
f->off = len;
@ -1358,8 +1361,12 @@ main(int argc, char *argv[])
while(waitpid() >= 0)
;
if(finished() && !sflag)
exits(0);
if(finished()){
if(!sflag)
exits(nil);
} else for(f = files; f; f = f->next)
if(f->wfd < 0 && (open(fixnamedup(f->name), OWRITE) < 0))
sysfatal("create: %r");
srand(truerand());
atnotify(catch, 1);