rexec.c revision 722:636b850d4ee9
1/*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License, Version 1.0 only
6 * (the "License").  You may not use this file except in compliance
7 * with the License.
8 *
9 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
10 * or http://www.opensolaris.org/os/licensing.
11 * See the License for the specific language governing permissions
12 * and limitations under the License.
13 *
14 * When distributing Covered Code, include this CDDL HEADER in each
15 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
16 * If applicable, add the following below this CDDL HEADER, with the
17 * fields enclosed by brackets "[]" replaced with your own identifying
18 * information: Portions Copyright [yyyy] [name of copyright owner]
19 *
20 * CDDL HEADER END
21 */
22/*
23 * Copyright 1989 Sun Microsystems, Inc.  All rights reserved.
24 * Use is subject to license terms.
25 */
26
27#pragma ident	"%Z%%M%	%I%	%E% SMI"
28
29#include <sys/types.h>
30#include <sys/socket.h>
31
32#include <netinet/in.h>
33
34#include <stdio.h>
35#include <netdb.h>
36#include <errno.h>
37#include <strings.h>
38#include <unistd.h>
39
40
41char	*getpass();
42
43int
44rexec(
45	char **ahost,
46	unsigned short rport,
47	char *name,
48	char *pass,
49	char *cmd,
50	int *fd2p)
51{
52	int s, timo = 1, s3;
53	struct sockaddr_in sin, sin2, from;
54	char c;
55	u_short port;
56	struct hostent *hp;
57
58	hp = gethostbyname(*ahost);
59	if (hp == 0) {
60		fprintf(stderr, "%s: unknown host\n", *ahost);
61		return (-1);
62	}
63	*ahost = hp->h_name;
64	_ruserpass(hp->h_name, &name, &pass);
65retry:
66	s = socket(AF_INET, SOCK_STREAM, 0);
67	if (s < 0) {
68		perror("rexec: socket");
69		return (-1);
70	}
71	sin.sin_family = hp->h_addrtype;
72	sin.sin_port = rport;
73	bcopy(hp->h_addr, (caddr_t)&sin.sin_addr, hp->h_length);
74	if (connect(s, &sin, sizeof(sin)) < 0) {
75		if (errno == ECONNREFUSED && timo <= 16) {
76			(void) close(s);
77			sleep(timo);
78			timo *= 2;
79			goto retry;
80		}
81		perror(hp->h_name);
82		(void) close(s);
83		return (-1);
84	}
85	if (fd2p == 0) {
86		(void) write(s, "", 1);
87		port = 0;
88	} else {
89		char num[8];
90		int s2, sin2len;
91
92		s2 = socket(AF_INET, SOCK_STREAM, 0);
93		if (s2 < 0) {
94			(void) close(s);
95			return (-1);
96		}
97		listen(s2, 1);
98		sin2len = sizeof (sin2);
99		if (getsockname(s2, (char *)&sin2, &sin2len) < 0 ||
100		  sin2len != sizeof (sin2)) {
101			perror("getsockname");
102			(void) close(s2);
103			goto bad;
104		}
105		port = ntohs((u_short)sin2.sin_port);
106		(void) sprintf(num, "%u", port);
107		(void) write(s, num, strlen(num)+1);
108		{ int len = sizeof (from);
109		  s3 = accept(s2, &from, &len);
110		  close(s2);
111		  if (s3 < 0) {
112			perror("accept");
113			port = 0;
114			goto bad;
115		  }
116		}
117		*fd2p = s3;
118	}
119	(void) write(s, name, strlen(name) + 1);
120	/* should public key encypt the password here */
121	(void) write(s, pass, strlen(pass) + 1);
122	(void) write(s, cmd, strlen(cmd) + 1);
123	if (read(s, &c, 1) != 1) {
124		perror(*ahost);
125		goto bad;
126	}
127	if (c != 0) {
128		while (read(s, &c, 1) == 1) {
129			(void) write(2, &c, 1);
130			if (c == '\n')
131				break;
132		}
133		goto bad;
134	}
135	return (s);
136bad:
137	if (port)
138		(void) close(*fd2p);
139	(void) close(s);
140	return (-1);
141}
142