xfnw/plan9fox
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

sshfs: start sendproc and recvproc in the sane notegroup as the fs process so theadexitsall() works on sshfs: ending.

Browse source
This commit is contained in:
cinap_lenrek 2017-08-29 19:49:38 +02:00
parent e44bf536af
commit 3e3d8880d1
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
sys/src/cmd/sshfs.c
View file

@ -1176,6 +1176,13 @@ sshfsdestroyreq(Req *r)
free(r->aux); free(r->aux);
} }
void
sshfsstart(Srv *)
{
proccreate(sendproc, nil, mainstacksize);
proccreate(recvproc, nil, mainstacksize);
}
void void
sshfsend(Srv *) sshfsend(Srv *)
{ {
@ -1184,6 +1191,7 @@ sshfsend(Srv *)
} }
Srv sshfssrv = { Srv sshfssrv = {
.start sshfsstart,
.attach sshfsattach, .attach sshfsattach,
.walk sshfswalk, .walk sshfswalk,
.open submitreq, .open submitreq,
@ -1195,7 +1203,7 @@ Srv sshfssrv = {
.remove submitreq, .remove submitreq,
.destroyfid sshfsdestroyfid, .destroyfid sshfsdestroyfid,
.destroyreq sshfsdestroyreq, .destroyreq sshfsdestroyreq,
.end sshfsend .end sshfsend,
}; };
char * char *
@ -1368,7 +1376,5 @@ threadmain(int argc, char **argv)
passwdparse(uidtab, readfile(uidfile)); passwdparse(uidtab, readfile(uidfile));
passwdparse(gidtab, readfile(gidfile)); passwdparse(gidtab, readfile(gidfile));
procrfork(sendproc, 0, mainstacksize, RFNOTEG);
procrfork(recvproc, 0, mainstacksize, RFNOTEG);
threadpostmountsrv(&sshfssrv, svc, mtpt, MCREATE | mflag); threadpostmountsrv(&sshfssrv, svc, mtpt, MCREATE | mflag);
} }