xref: /plan9/sys/src/cmd/ssh2/dial.thread.c (revision 6c0e6fed62599342770755338f74d351b8dd2269)
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