163afb9a5SDavid du Colombier /*
263afb9a5SDavid du Colombier * dial - connect to a service (threaded parallel version)
363afb9a5SDavid du Colombier */
463afb9a5SDavid du Colombier #include <u.h>
563afb9a5SDavid du Colombier #include <libc.h>
663afb9a5SDavid du Colombier #include <ctype.h>
763afb9a5SDavid du Colombier #include <fcall.h>
863afb9a5SDavid du Colombier #include <thread.h>
963afb9a5SDavid du Colombier #include <9p.h>
1063afb9a5SDavid du Colombier
1163afb9a5SDavid du Colombier typedef struct Conn Conn;
1263afb9a5SDavid du Colombier typedef struct Dest Dest;
1363afb9a5SDavid du Colombier typedef struct DS DS;
1463afb9a5SDavid du Colombier typedef struct Kidargs Kidargs;
1563afb9a5SDavid du Colombier typedef struct Restup Restup;
1663afb9a5SDavid du Colombier
1763afb9a5SDavid du Colombier enum
1863afb9a5SDavid du Colombier {
1963afb9a5SDavid du Colombier Noblock,
2063afb9a5SDavid du Colombier Block,
2163afb9a5SDavid du Colombier
2263afb9a5SDavid du Colombier Defstksize = 8192,
2363afb9a5SDavid du Colombier
2463afb9a5SDavid du Colombier Maxstring = 128,
2563afb9a5SDavid du Colombier Maxpath = 256,
2663afb9a5SDavid du Colombier
2763afb9a5SDavid du Colombier Maxcsreply = 64*80, /* this is probably overly generous */
2863afb9a5SDavid du Colombier /*
2963afb9a5SDavid du Colombier * this should be a plausible slight overestimate for non-interactive
3063afb9a5SDavid du Colombier * use even if it's ridiculously long for interactive use.
3163afb9a5SDavid du Colombier */
3263afb9a5SDavid du Colombier Maxconnms = 2*60*1000, /* 2 minutes */
3363afb9a5SDavid du Colombier };
3463afb9a5SDavid du Colombier
3563afb9a5SDavid du Colombier struct DS {
3663afb9a5SDavid du Colombier /* dial string */
3763afb9a5SDavid du Colombier char buf[Maxstring];
3863afb9a5SDavid du Colombier char *netdir;
3963afb9a5SDavid du Colombier char *proto;
4063afb9a5SDavid du Colombier char *rem;
4163afb9a5SDavid du Colombier
4263afb9a5SDavid du Colombier /* other args */
4363afb9a5SDavid du Colombier char *local;
4463afb9a5SDavid du Colombier char *dir;
4563afb9a5SDavid du Colombier int *cfdp;
4663afb9a5SDavid du Colombier };
4763afb9a5SDavid du Colombier
4863afb9a5SDavid du Colombier struct Conn {
4963afb9a5SDavid du Colombier int cfd;
506084a089SDavid du Colombier char dir[NETPATHLEN+1];
5163afb9a5SDavid du Colombier };
5263afb9a5SDavid du Colombier struct Dest {
5363afb9a5SDavid du Colombier DS *ds;
5463afb9a5SDavid du Colombier
5563afb9a5SDavid du Colombier Channel *reschan; /* all callprocs send results on this */
5663afb9a5SDavid du Colombier int nkid;
5763afb9a5SDavid du Colombier int kidthrids[64]; /* one per addr; ought to be enough */
5863afb9a5SDavid du Colombier
5963afb9a5SDavid du Colombier int windfd;
6063afb9a5SDavid du Colombier char err[ERRMAX];
6163afb9a5SDavid du Colombier
6263afb9a5SDavid du Colombier long oalarm;
6363afb9a5SDavid du Colombier
6463afb9a5SDavid du Colombier int naddrs;
6563afb9a5SDavid du Colombier char *nextaddr;
6663afb9a5SDavid du Colombier char addrlist[Maxcsreply];
6763afb9a5SDavid du Colombier };
6863afb9a5SDavid du Colombier
6963afb9a5SDavid du Colombier struct Kidargs { /* arguments to callproc */
7063afb9a5SDavid du Colombier Dest *dp;
7163afb9a5SDavid du Colombier int thridsme;
7263afb9a5SDavid du Colombier char *clone;
7363afb9a5SDavid du Colombier char *dest;
7463afb9a5SDavid du Colombier };
7563afb9a5SDavid du Colombier
7663afb9a5SDavid du Colombier struct Restup { /* result tuple from callproc */
7763afb9a5SDavid du Colombier int dfd;
7863afb9a5SDavid du Colombier int cfd;
7963afb9a5SDavid du Colombier char *err;
8063afb9a5SDavid du Colombier char *conndir;
8163afb9a5SDavid du Colombier };
8263afb9a5SDavid du Colombier
8363afb9a5SDavid du Colombier static int call(char*, char*, Dest*, Conn*);
8463afb9a5SDavid du Colombier static int call1(char*, char*, Dest*, Conn*);
8563afb9a5SDavid du Colombier static int csdial(DS*);
8663afb9a5SDavid du Colombier static void _dial_string_parse(char*, DS*);
8763afb9a5SDavid du Colombier
8863afb9a5SDavid du Colombier /*
8963afb9a5SDavid du Colombier * the dialstring is of the form '[/net/]proto!dest'
9063afb9a5SDavid du Colombier */
9163afb9a5SDavid du Colombier static int
dialimpl(char * dest,char * local,char * dir,int * cfdp)9263afb9a5SDavid du Colombier dialimpl(char *dest, char *local, char *dir, int *cfdp)
9363afb9a5SDavid du Colombier {
9463afb9a5SDavid du Colombier DS ds;
9563afb9a5SDavid du Colombier int rv;
9663afb9a5SDavid du Colombier char err[ERRMAX], alterr[ERRMAX];
9763afb9a5SDavid du Colombier
9863afb9a5SDavid du Colombier ds.local = local;
9963afb9a5SDavid du Colombier ds.dir = dir;
10063afb9a5SDavid du Colombier ds.cfdp = cfdp;
10163afb9a5SDavid du Colombier
10263afb9a5SDavid du Colombier _dial_string_parse(dest, &ds);
10363afb9a5SDavid du Colombier if(ds.netdir)
10463afb9a5SDavid du Colombier return csdial(&ds);
10563afb9a5SDavid du Colombier
10663afb9a5SDavid du Colombier ds.netdir = "/net";
10763afb9a5SDavid du Colombier rv = csdial(&ds);
10863afb9a5SDavid du Colombier if(rv >= 0)
10963afb9a5SDavid du Colombier return rv;
11063afb9a5SDavid du Colombier err[0] = '\0';
11163afb9a5SDavid du Colombier errstr(err, sizeof err);
11263afb9a5SDavid du Colombier if(strstr(err, "refused") != 0){
11363afb9a5SDavid du Colombier werrstr("%s", err);
11463afb9a5SDavid du Colombier return rv;
11563afb9a5SDavid du Colombier }
11663afb9a5SDavid du Colombier ds.netdir = "/net.alt";
11763afb9a5SDavid du Colombier rv = csdial(&ds);
11863afb9a5SDavid du Colombier if(rv >= 0)
11963afb9a5SDavid du Colombier return rv;
12063afb9a5SDavid du Colombier
12163afb9a5SDavid du Colombier alterr[0] = 0;
12263afb9a5SDavid du Colombier errstr(alterr, sizeof alterr);
12363afb9a5SDavid du Colombier if(strstr(alterr, "translate") || strstr(alterr, "does not exist"))
12463afb9a5SDavid du Colombier werrstr("%s", err);
12563afb9a5SDavid du Colombier else
12663afb9a5SDavid du Colombier werrstr("%s", alterr);
12763afb9a5SDavid du Colombier return rv;
12863afb9a5SDavid du Colombier }
12963afb9a5SDavid du Colombier
13063afb9a5SDavid du Colombier /*
13163afb9a5SDavid du Colombier * the thread library can't cope with rfork(RFMEM|RFPROC),
13263afb9a5SDavid du Colombier * so it must override _dial with this version of dial.
13363afb9a5SDavid du Colombier */
13463afb9a5SDavid du Colombier int (*_dial)(char *, char *, char *, int *) = dialimpl;
13563afb9a5SDavid du Colombier
13663afb9a5SDavid du Colombier int
dial(char * dest,char * local,char * dir,int * cfdp)13763afb9a5SDavid du Colombier dial(char *dest, char *local, char *dir, int *cfdp)
13863afb9a5SDavid du Colombier {
13963afb9a5SDavid du Colombier return (*_dial)(dest, local, dir, cfdp);
14063afb9a5SDavid du Colombier }
14163afb9a5SDavid du Colombier
14263afb9a5SDavid du Colombier static void
freedest(Dest * dp)14363afb9a5SDavid du Colombier freedest(Dest *dp)
14463afb9a5SDavid du Colombier {
14563afb9a5SDavid du Colombier if (dp) {
14663afb9a5SDavid du Colombier if (dp->oalarm >= 0)
14763afb9a5SDavid du Colombier alarm(dp->oalarm);
14863afb9a5SDavid du Colombier free(dp);
14963afb9a5SDavid du Colombier }
15063afb9a5SDavid du Colombier }
15163afb9a5SDavid du Colombier
15263afb9a5SDavid du Colombier static void
closeopenfd(int * fdp)15363afb9a5SDavid du Colombier closeopenfd(int *fdp)
15463afb9a5SDavid du Colombier {
15563afb9a5SDavid du Colombier if (*fdp >= 0) {
15663afb9a5SDavid du Colombier close(*fdp);
15763afb9a5SDavid du Colombier *fdp = -1;
15863afb9a5SDavid du Colombier }
15963afb9a5SDavid du Colombier }
16063afb9a5SDavid du Colombier
16163afb9a5SDavid du Colombier static int
parsecs(Dest * dp,char ** clonep,char ** destp)16263afb9a5SDavid du Colombier parsecs(Dest *dp, char **clonep, char **destp)
16363afb9a5SDavid du Colombier {
16463afb9a5SDavid du Colombier char *dest, *p;
16563afb9a5SDavid du Colombier
16663afb9a5SDavid du Colombier dest = strchr(dp->nextaddr, ' ');
16763afb9a5SDavid du Colombier if(dest == nil)
16863afb9a5SDavid du Colombier return -1;
16963afb9a5SDavid du Colombier *dest++ = '\0';
17063afb9a5SDavid du Colombier p = strchr(dest, '\n');
17163afb9a5SDavid du Colombier if(p == nil)
17263afb9a5SDavid du Colombier return -1;
17363afb9a5SDavid du Colombier *p++ = '\0';
17463afb9a5SDavid du Colombier *clonep = dp->nextaddr;
17563afb9a5SDavid du Colombier *destp = dest;
17663afb9a5SDavid du Colombier dp->nextaddr = p; /* advance to next line */
17763afb9a5SDavid du Colombier return 0;
17863afb9a5SDavid du Colombier }
17963afb9a5SDavid du Colombier
18063afb9a5SDavid du Colombier static void
pickuperr(char * besterr)18163afb9a5SDavid du Colombier pickuperr(char *besterr)
18263afb9a5SDavid du Colombier {
18363afb9a5SDavid du Colombier char err[ERRMAX];
18463afb9a5SDavid du Colombier
18563afb9a5SDavid du Colombier err[0] = '\0';
18663afb9a5SDavid du Colombier errstr(err, ERRMAX);
18763afb9a5SDavid du Colombier if(strstr(err, "does not exist") == 0)
18863afb9a5SDavid du Colombier strcpy(besterr, err);
18963afb9a5SDavid du Colombier }
19063afb9a5SDavid du Colombier
19163afb9a5SDavid du Colombier static int
catcher(void *,char * s)19263afb9a5SDavid du Colombier catcher(void *, char *s)
19363afb9a5SDavid du Colombier {
19463afb9a5SDavid du Colombier return strstr(s, "alarm") != nil;
19563afb9a5SDavid du Colombier }
19663afb9a5SDavid du Colombier
19763afb9a5SDavid du Colombier static void
callproc(void * p)19863afb9a5SDavid du Colombier callproc(void *p)
19963afb9a5SDavid du Colombier {
20063afb9a5SDavid du Colombier int dfd;
20163afb9a5SDavid du Colombier char besterr[ERRMAX];
20263afb9a5SDavid du Colombier Conn lconn;
20363afb9a5SDavid du Colombier Conn *conn;
20463afb9a5SDavid du Colombier Kidargs *args;
20563afb9a5SDavid du Colombier Restup *tup;
20663afb9a5SDavid du Colombier
20763afb9a5SDavid du Colombier threadnotify(catcher, 1); /* avoid atnotify callbacks in parent */
20863afb9a5SDavid du Colombier
20963afb9a5SDavid du Colombier conn = &lconn;
21063afb9a5SDavid du Colombier memset(conn, 0, sizeof *conn);
21163afb9a5SDavid du Colombier *besterr = '\0';
21263afb9a5SDavid du Colombier args = (Kidargs *)p;
21363afb9a5SDavid du Colombier dfd = call(args->clone, args->dest, args->dp, conn);
21463afb9a5SDavid du Colombier if(dfd < 0)
21563afb9a5SDavid du Colombier pickuperr(besterr);
21663afb9a5SDavid du Colombier
21763afb9a5SDavid du Colombier tup = (Restup *)emalloc9p(sizeof *tup);
21863afb9a5SDavid du Colombier *tup = (Restup){dfd, conn->cfd, nil, nil};
21963afb9a5SDavid du Colombier if (dfd >= 0)
22063afb9a5SDavid du Colombier tup->conndir = strdup(conn->dir);
22163afb9a5SDavid du Colombier else
22263afb9a5SDavid du Colombier tup->err = strdup(besterr);
22363afb9a5SDavid du Colombier sendp(args->dp->reschan, tup);
22463afb9a5SDavid du Colombier
22563afb9a5SDavid du Colombier args->dp->kidthrids[args->thridsme] = -1;
22663afb9a5SDavid du Colombier free(args);
22763afb9a5SDavid du Colombier threadexits(besterr); /* better be no atexit callbacks */
22863afb9a5SDavid du Colombier }
22963afb9a5SDavid du Colombier
23063afb9a5SDavid du Colombier /* interrupt all of our still-live kids */
23163afb9a5SDavid du Colombier static void
intrcallprocs(Dest * dp)23263afb9a5SDavid du Colombier intrcallprocs(Dest *dp)
23363afb9a5SDavid du Colombier {
23463afb9a5SDavid du Colombier int i;
23563afb9a5SDavid du Colombier
23663afb9a5SDavid du Colombier for (i = 0; i < nelem(dp->kidthrids); i++)
23763afb9a5SDavid du Colombier if (dp->kidthrids[i] >= 0)
23863afb9a5SDavid du Colombier threadint(dp->kidthrids[i]);
23963afb9a5SDavid du Colombier }
24063afb9a5SDavid du Colombier
24163afb9a5SDavid du Colombier static int
recvresults(Dest * dp,int block)24263afb9a5SDavid du Colombier recvresults(Dest *dp, int block)
24363afb9a5SDavid du Colombier {
24463afb9a5SDavid du Colombier DS *ds;
24563afb9a5SDavid du Colombier Restup *tup;
24663afb9a5SDavid du Colombier
24763afb9a5SDavid du Colombier for (; dp->nkid > 0; dp->nkid--) {
24863afb9a5SDavid du Colombier if (block)
24963afb9a5SDavid du Colombier tup = recvp(dp->reschan);
25063afb9a5SDavid du Colombier else
25163afb9a5SDavid du Colombier tup = nbrecvp(dp->reschan);
25263afb9a5SDavid du Colombier if (tup == nil)
25363afb9a5SDavid du Colombier break;
25463afb9a5SDavid du Colombier if (tup->dfd >= 0) /* connected? */
25563afb9a5SDavid du Colombier if (dp->windfd < 0) { /* first connection? */
25663afb9a5SDavid du Colombier ds = dp->ds;
25763afb9a5SDavid du Colombier dp->windfd = tup->dfd;
25863afb9a5SDavid du Colombier if (ds->cfdp)
25963afb9a5SDavid du Colombier *ds->cfdp = tup->cfd;
2606084a089SDavid du Colombier if (ds->dir) {
26163afb9a5SDavid du Colombier strncpy(ds->dir, tup->conndir,
26263afb9a5SDavid du Colombier NETPATHLEN);
263*6c0e6fedSDavid du Colombier ds->dir[NETPATHLEN-1] = '\0';
2646084a089SDavid du Colombier }
26563afb9a5SDavid du Colombier intrcallprocs(dp);
26663afb9a5SDavid du Colombier } else {
26763afb9a5SDavid du Colombier close(tup->dfd);
26863afb9a5SDavid du Colombier close(tup->cfd);
26963afb9a5SDavid du Colombier }
2706084a089SDavid du Colombier else if (dp->err[0] == '\0' && tup->err) {
2716084a089SDavid du Colombier strncpy(dp->err, tup->err, ERRMAX - 1);
2726084a089SDavid du Colombier dp->err[ERRMAX - 1] = '\0';
2736084a089SDavid du Colombier }
27463afb9a5SDavid du Colombier free(tup->conndir);
27563afb9a5SDavid du Colombier free(tup->err);
27663afb9a5SDavid du Colombier free(tup);
27763afb9a5SDavid du Colombier }
27863afb9a5SDavid du Colombier return dp->windfd;
27963afb9a5SDavid du Colombier }
28063afb9a5SDavid du Colombier
28163afb9a5SDavid du Colombier /*
28263afb9a5SDavid du Colombier * try all addresses in parallel and take the first one that answers;
28363afb9a5SDavid du Colombier * this helps when systems have ip v4 and v6 addresses but are
28463afb9a5SDavid du Colombier * only reachable from here on one (or some) of them.
28563afb9a5SDavid du Colombier */
28663afb9a5SDavid du Colombier static int
dialmulti(Dest * dp)28763afb9a5SDavid du Colombier dialmulti(Dest *dp)
28863afb9a5SDavid du Colombier {
28963afb9a5SDavid du Colombier int kidme;
29063afb9a5SDavid du Colombier char *clone, *dest;
29163afb9a5SDavid du Colombier Kidargs *argp;
29263afb9a5SDavid du Colombier
29363afb9a5SDavid du Colombier dp->reschan = chancreate(sizeof(void *), 0);
29463afb9a5SDavid du Colombier dp->err[0] = '\0';
29563afb9a5SDavid du Colombier dp->nkid = 0;
29663afb9a5SDavid du Colombier dp->windfd = -1;
29763afb9a5SDavid du Colombier /* if too many addresses for dp->kidthrids, ignore the last few */
29863afb9a5SDavid du Colombier while(dp->windfd < 0 && dp->nkid < nelem(dp->kidthrids) &&
29963afb9a5SDavid du Colombier *dp->nextaddr != '\0' && parsecs(dp, &clone, &dest) >= 0) {
30063afb9a5SDavid du Colombier kidme = dp->nkid++;
30163afb9a5SDavid du Colombier
30263afb9a5SDavid du Colombier argp = (Kidargs *)emalloc9p(sizeof *argp);
30363afb9a5SDavid du Colombier *argp = (Kidargs){dp, kidme, clone, dest};
30463afb9a5SDavid du Colombier
30563afb9a5SDavid du Colombier dp->kidthrids[kidme] = proccreate(callproc, argp, Defstksize);
30663afb9a5SDavid du Colombier if (dp->kidthrids[kidme] < 0)
30763afb9a5SDavid du Colombier --dp->nkid;
30863afb9a5SDavid du Colombier }
30963afb9a5SDavid du Colombier
31063afb9a5SDavid du Colombier recvresults(dp, Block);
31163afb9a5SDavid du Colombier assert(dp->nkid == 0);
31263afb9a5SDavid du Colombier
31363afb9a5SDavid du Colombier chanclose(dp->reschan);
31463afb9a5SDavid du Colombier chanfree(dp->reschan);
31563afb9a5SDavid du Colombier if(dp->windfd < 0 && dp->err[0])
31663afb9a5SDavid du Colombier werrstr("%s", dp->err);
31763afb9a5SDavid du Colombier return dp->windfd;
31863afb9a5SDavid du Colombier }
31963afb9a5SDavid du Colombier
32063afb9a5SDavid du Colombier /* call a single address and pass back cfd & conn dir after */
32163afb9a5SDavid du Colombier static int
call1(char * clone,char * rem,Dest * dp,Conn * conn)32263afb9a5SDavid du Colombier call1(char *clone, char *rem, Dest *dp, Conn *conn)
32363afb9a5SDavid du Colombier {
32463afb9a5SDavid du Colombier int dfd;
32563afb9a5SDavid du Colombier DS *ds;
32663afb9a5SDavid du Colombier
32763afb9a5SDavid du Colombier ds = dp->ds;
32863afb9a5SDavid du Colombier dfd = call(clone, rem, dp, conn);
32963afb9a5SDavid du Colombier if (dfd < 0)
33063afb9a5SDavid du Colombier return dfd;
33163afb9a5SDavid du Colombier
33263afb9a5SDavid du Colombier if (ds->cfdp)
33363afb9a5SDavid du Colombier *ds->cfdp = conn->cfd;
3346084a089SDavid du Colombier if (ds->dir) {
33563afb9a5SDavid du Colombier strncpy(ds->dir, conn->dir, NETPATHLEN);
336*6c0e6fedSDavid du Colombier ds->dir[NETPATHLEN-1] = '\0';
3376084a089SDavid du Colombier }
33863afb9a5SDavid du Colombier return dfd;
33963afb9a5SDavid du Colombier }
34063afb9a5SDavid du Colombier
34163afb9a5SDavid du Colombier static int
csdial(DS * ds)34263afb9a5SDavid du Colombier csdial(DS *ds)
34363afb9a5SDavid du Colombier {
34463afb9a5SDavid du Colombier int n, fd, dfd, addrs, bleft;
34563afb9a5SDavid du Colombier char c;
34663afb9a5SDavid du Colombier char *addrp, *clone2, *dest;
34763afb9a5SDavid du Colombier char buf[Maxstring], clone[Maxpath], besterr[ERRMAX];
34863afb9a5SDavid du Colombier Conn lconn;
34963afb9a5SDavid du Colombier Conn *conn;
35063afb9a5SDavid du Colombier Dest *dp;
35163afb9a5SDavid du Colombier
35263afb9a5SDavid du Colombier dp = mallocz(sizeof *dp, 1);
35363afb9a5SDavid du Colombier if(dp == nil)
35463afb9a5SDavid du Colombier return -1;
35563afb9a5SDavid du Colombier conn = &lconn;
35663afb9a5SDavid du Colombier memset(conn, 0, sizeof *conn);
35763afb9a5SDavid du Colombier dp->ds = ds;
35863afb9a5SDavid du Colombier if (ds->cfdp)
35963afb9a5SDavid du Colombier *ds->cfdp = -1;
36063afb9a5SDavid du Colombier if (ds->dir)
36163afb9a5SDavid du Colombier ds->dir[0] = '\0';
36263afb9a5SDavid du Colombier dp->oalarm = alarm(0);
36363afb9a5SDavid du Colombier
36463afb9a5SDavid du Colombier /*
36563afb9a5SDavid du Colombier * open connection server
36663afb9a5SDavid du Colombier */
36763afb9a5SDavid du Colombier snprint(buf, sizeof(buf), "%s/cs", ds->netdir);
36863afb9a5SDavid du Colombier fd = open(buf, ORDWR);
36963afb9a5SDavid du Colombier if(fd < 0){
37063afb9a5SDavid du Colombier /* no connection server, don't translate */
37163afb9a5SDavid du Colombier snprint(clone, sizeof(clone), "%s/%s/clone", ds->netdir, ds->proto);
37263afb9a5SDavid du Colombier dfd = call1(clone, ds->rem, dp, conn);
37363afb9a5SDavid du Colombier freedest(dp);
37463afb9a5SDavid du Colombier return dfd;
37563afb9a5SDavid du Colombier }
37663afb9a5SDavid du Colombier
37763afb9a5SDavid du Colombier /*
37863afb9a5SDavid du Colombier * ask connection server to translate
37963afb9a5SDavid du Colombier */
38063afb9a5SDavid du Colombier snprint(buf, sizeof(buf), "%s!%s", ds->proto, ds->rem);
38163afb9a5SDavid du Colombier if(write(fd, buf, strlen(buf)) < 0){
38263afb9a5SDavid du Colombier close(fd);
38363afb9a5SDavid du Colombier freedest(dp);
38463afb9a5SDavid du Colombier return -1;
38563afb9a5SDavid du Colombier }
38663afb9a5SDavid du Colombier
38763afb9a5SDavid du Colombier /*
38863afb9a5SDavid du Colombier * read all addresses from the connection server.
38963afb9a5SDavid du Colombier */
39063afb9a5SDavid du Colombier seek(fd, 0, 0);
39163afb9a5SDavid du Colombier addrs = 0;
39263afb9a5SDavid du Colombier addrp = dp->nextaddr = dp->addrlist;
39363afb9a5SDavid du Colombier bleft = sizeof dp->addrlist - 2; /* 2 is room for \n\0 */
39463afb9a5SDavid du Colombier while(bleft > 0 && (n = read(fd, addrp, bleft)) > 0) {
39563afb9a5SDavid du Colombier if (addrp[n-1] != '\n')
39663afb9a5SDavid du Colombier addrp[n++] = '\n';
39763afb9a5SDavid du Colombier addrs++;
39863afb9a5SDavid du Colombier addrp += n;
39963afb9a5SDavid du Colombier bleft -= n;
40063afb9a5SDavid du Colombier }
40163afb9a5SDavid du Colombier /*
40263afb9a5SDavid du Colombier * if we haven't read all of cs's output, assume the last line might
40363afb9a5SDavid du Colombier * have been truncated and ignore it. we really don't expect this
40463afb9a5SDavid du Colombier * to happen.
40563afb9a5SDavid du Colombier */
40663afb9a5SDavid du Colombier if (addrs > 0 && bleft <= 0 && read(fd, &c, 1) == 1)
40763afb9a5SDavid du Colombier addrs--;
40863afb9a5SDavid du Colombier close(fd);
40963afb9a5SDavid du Colombier
41063afb9a5SDavid du Colombier *besterr = 0;
41163afb9a5SDavid du Colombier dfd = -1; /* pessimistic default */
41263afb9a5SDavid du Colombier dp->naddrs = addrs;
41363afb9a5SDavid du Colombier if (addrs == 0)
41463afb9a5SDavid du Colombier werrstr("no address to dial");
41563afb9a5SDavid du Colombier else if (addrs == 1) {
41663afb9a5SDavid du Colombier /* common case: dial one address without forking */
41763afb9a5SDavid du Colombier if (parsecs(dp, &clone2, &dest) >= 0 &&
41863afb9a5SDavid du Colombier (dfd = call1(clone2, dest, dp, conn)) < 0) {
41963afb9a5SDavid du Colombier pickuperr(besterr);
42063afb9a5SDavid du Colombier werrstr("%s", besterr);
42163afb9a5SDavid du Colombier }
42263afb9a5SDavid du Colombier } else
42363afb9a5SDavid du Colombier dfd = dialmulti(dp);
42463afb9a5SDavid du Colombier
42563afb9a5SDavid du Colombier freedest(dp);
42663afb9a5SDavid du Colombier return dfd;
42763afb9a5SDavid du Colombier }
42863afb9a5SDavid du Colombier
42963afb9a5SDavid du Colombier /* returns dfd, stores cfd through cfdp */
43063afb9a5SDavid du Colombier static int
call(char * clone,char * dest,Dest * dp,Conn * conn)43163afb9a5SDavid du Colombier call(char *clone, char *dest, Dest *dp, Conn *conn)
43263afb9a5SDavid du Colombier {
43363afb9a5SDavid du Colombier int fd, cfd, n, calleralarm, oalarm;
43463afb9a5SDavid du Colombier char cname[Maxpath], name[Maxpath], data[Maxpath], *p;
43563afb9a5SDavid du Colombier DS *ds;
43663afb9a5SDavid du Colombier
43763afb9a5SDavid du Colombier /* because cs is in a different name space, replace the mount point */
43863afb9a5SDavid du Colombier if(*clone == '/'){
43963afb9a5SDavid du Colombier p = strchr(clone+1, '/');
44063afb9a5SDavid du Colombier if(p == nil)
44163afb9a5SDavid du Colombier p = clone;
44263afb9a5SDavid du Colombier else
44363afb9a5SDavid du Colombier p++;
44463afb9a5SDavid du Colombier } else
44563afb9a5SDavid du Colombier p = clone;
44663afb9a5SDavid du Colombier ds = dp->ds;
44763afb9a5SDavid du Colombier snprint(cname, sizeof cname, "%s/%s", ds->netdir, p);
44863afb9a5SDavid du Colombier
44963afb9a5SDavid du Colombier conn->cfd = cfd = open(cname, ORDWR);
45063afb9a5SDavid du Colombier if(cfd < 0)
45163afb9a5SDavid du Colombier return -1;
45263afb9a5SDavid du Colombier
45363afb9a5SDavid du Colombier /* get directory name */
45463afb9a5SDavid du Colombier n = read(cfd, name, sizeof(name)-1);
45563afb9a5SDavid du Colombier if(n < 0){
45663afb9a5SDavid du Colombier closeopenfd(&conn->cfd);
45763afb9a5SDavid du Colombier return -1;
45863afb9a5SDavid du Colombier }
45963afb9a5SDavid du Colombier name[n] = 0;
46063afb9a5SDavid du Colombier for(p = name; *p == ' '; p++)
46163afb9a5SDavid du Colombier ;
46263afb9a5SDavid du Colombier snprint(name, sizeof(name), "%ld", strtoul(p, 0, 0));
46363afb9a5SDavid du Colombier p = strrchr(cname, '/');
46463afb9a5SDavid du Colombier *p = 0;
46563afb9a5SDavid du Colombier if(ds->dir)
46663afb9a5SDavid du Colombier snprint(conn->dir, NETPATHLEN, "%s/%s", cname, name);
46763afb9a5SDavid du Colombier snprint(data, sizeof(data), "%s/%s/data", cname, name);
46863afb9a5SDavid du Colombier
46963afb9a5SDavid du Colombier /* should be no alarm pending now; re-instate caller's alarm, if any */
47063afb9a5SDavid du Colombier calleralarm = dp->oalarm > 0;
47163afb9a5SDavid du Colombier if (calleralarm)
47263afb9a5SDavid du Colombier alarm(dp->oalarm);
47363afb9a5SDavid du Colombier else if (dp->naddrs > 1) /* in a sub-process? */
47463afb9a5SDavid du Colombier alarm(Maxconnms);
47563afb9a5SDavid du Colombier
47663afb9a5SDavid du Colombier /* connect */
47763afb9a5SDavid du Colombier if(ds->local)
47863afb9a5SDavid du Colombier snprint(name, sizeof(name), "connect %s %s", dest, ds->local);
47963afb9a5SDavid du Colombier else
48063afb9a5SDavid du Colombier snprint(name, sizeof(name), "connect %s", dest);
48163afb9a5SDavid du Colombier if(write(cfd, name, strlen(name)) < 0){
48263afb9a5SDavid du Colombier closeopenfd(&conn->cfd);
48363afb9a5SDavid du Colombier return -1;
48463afb9a5SDavid du Colombier }
48563afb9a5SDavid du Colombier
48663afb9a5SDavid du Colombier oalarm = alarm(0); /* don't let alarm interrupt critical section */
48763afb9a5SDavid du Colombier if (calleralarm)
48863afb9a5SDavid du Colombier dp->oalarm = oalarm; /* time has passed, so update user's */
48963afb9a5SDavid du Colombier
49063afb9a5SDavid du Colombier /* open data connection */
49163afb9a5SDavid du Colombier fd = open(data, ORDWR);
49263afb9a5SDavid du Colombier if(fd < 0){
49363afb9a5SDavid du Colombier closeopenfd(&conn->cfd);
49463afb9a5SDavid du Colombier alarm(dp->oalarm);
49563afb9a5SDavid du Colombier return -1;
49663afb9a5SDavid du Colombier }
49763afb9a5SDavid du Colombier if(ds->cfdp == nil)
49863afb9a5SDavid du Colombier closeopenfd(&conn->cfd);
49963afb9a5SDavid du Colombier
50063afb9a5SDavid du Colombier alarm(calleralarm? dp->oalarm: 0);
50163afb9a5SDavid du Colombier return fd;
50263afb9a5SDavid du Colombier }
50363afb9a5SDavid du Colombier
50463afb9a5SDavid du Colombier /*
50563afb9a5SDavid du Colombier * assume p points at first '!' in dial string. st is start of dial string.
50663afb9a5SDavid du Colombier * there could be subdirs of the conn dirs (e.g., ssh/0) that must count as
50763afb9a5SDavid du Colombier * part of the proto string, so skip numeric components.
50863afb9a5SDavid du Colombier * returns pointer to delimiter after right-most non-numeric component.
50963afb9a5SDavid du Colombier */
51063afb9a5SDavid du Colombier static char *
backoverchans(char * st,char * p)51163afb9a5SDavid du Colombier backoverchans(char *st, char *p)
51263afb9a5SDavid du Colombier {
51363afb9a5SDavid du Colombier char *sl;
51463afb9a5SDavid du Colombier
51563afb9a5SDavid du Colombier for (sl = p; --p >= st && isascii(*p) && isdigit(*p); sl = p) {
51663afb9a5SDavid du Colombier while (--p >= st && isascii(*p) && isdigit(*p))
51763afb9a5SDavid du Colombier ;
51863afb9a5SDavid du Colombier if (p < st || *p != '/')
51963afb9a5SDavid du Colombier break; /* "net.alt2" or ran off start */
52063afb9a5SDavid du Colombier while (p > st && p[-1] == '/') /* skip runs of slashes */
52163afb9a5SDavid du Colombier p--;
52263afb9a5SDavid du Colombier }
52363afb9a5SDavid du Colombier return sl;
52463afb9a5SDavid du Colombier }
52563afb9a5SDavid du Colombier
52663afb9a5SDavid du Colombier /*
52763afb9a5SDavid du Colombier * parse a dial string
52863afb9a5SDavid du Colombier */
52963afb9a5SDavid du Colombier static void
_dial_string_parse(char * str,DS * ds)53063afb9a5SDavid du Colombier _dial_string_parse(char *str, DS *ds)
53163afb9a5SDavid du Colombier {
53263afb9a5SDavid du Colombier char *p, *p2;
53363afb9a5SDavid du Colombier
53463afb9a5SDavid du Colombier strncpy(ds->buf, str, Maxstring);
53563afb9a5SDavid du Colombier ds->buf[Maxstring-1] = 0;
53663afb9a5SDavid du Colombier
53763afb9a5SDavid du Colombier p = strchr(ds->buf, '!');
53863afb9a5SDavid du Colombier if(p == 0) {
53963afb9a5SDavid du Colombier ds->netdir = 0;
54063afb9a5SDavid du Colombier ds->proto = "net";
54163afb9a5SDavid du Colombier ds->rem = ds->buf;
54263afb9a5SDavid du Colombier } else {
54363afb9a5SDavid du Colombier if(*ds->buf != '/' && *ds->buf != '#'){
54463afb9a5SDavid du Colombier ds->netdir = 0;
54563afb9a5SDavid du Colombier ds->proto = ds->buf;
54663afb9a5SDavid du Colombier } else {
54763afb9a5SDavid du Colombier p2 = backoverchans(ds->buf, p);
54863afb9a5SDavid du Colombier
54963afb9a5SDavid du Colombier /* back over last component of netdir (proto) */
55063afb9a5SDavid du Colombier while (--p2 > ds->buf && *p2 != '/')
55163afb9a5SDavid du Colombier ;
55263afb9a5SDavid du Colombier *p2++ = 0;
55363afb9a5SDavid du Colombier ds->netdir = ds->buf;
55463afb9a5SDavid du Colombier ds->proto = p2;
55563afb9a5SDavid du Colombier }
55663afb9a5SDavid du Colombier *p = 0;
55763afb9a5SDavid du Colombier ds->rem = p + 1;
55863afb9a5SDavid du Colombier }
55963afb9a5SDavid du Colombier }
560