![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to runfs.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv10no / netfs / libnetb|
Return to runfs.c CVS log | Up to [Research Unix] / researchv10no / netfs / libnetb |
1.1 root 1: /*
2: * run and mount a netb file server,
3: * including the uid-login name handshake protocol
4: */
5: #include <stdio.h>
6: #include <signal.h>
7: #include <errno.h>
8: #include <pwd.h>
9: #include <grp.h>
10: #include <sys/types.h> /* for makedev */
11:
12: #define NBFS 4 /* for fmount */
13:
14: /*
15: * setup handshake parameters
16: */
17: #define MAXMSG 5 /* largest message 5*MSGBLOCK -- known to kernel too */
18: #define MSGBLOCK 1024
19:
20: int debug; /* debug level, for server */
21:
22: char *estr();
23:
24: main(argc, argv)
25: int argc;
26: char **argv;
27: {
28: int pfd[2];
29: int pid;
30: int sts;
31:
32: while (--argc > 0 && **++argv == '-') {
33: switch (argv[0][1]) {
34: case 'd':
35: debug = atoi(&argv[0][2]);
36: break;
37:
38: default:
39: fprintf(stderr, "unknown flag %s ignored\n", argv[0]);
40: break;
41: }
42: }
43: if (argc < 2) {
44: fprintf(stderr, "usage: runfs [-dlevel] mpoint server arg ...\n");
45: exit(1);
46: }
47: if (pipe(pfd) < 0) {
48: perror("pipe");
49: exit(1);
50: }
51: if ((pid = fork()) < 0) {
52: perror("fork");
53: exit(1);
54: }
55: /*
56: * child: run setup handshake, mount filesystem
57: */
58: if (pid == 0) {
59: close(pfd[1]); /* for clean error */
60: sts = setup(pfd[0], argv[0]);
61: exit(sts);
62: }
63: /*
64: * parent: exec server
65: */
66: close(pfd[0]);
67: dup2(pfd[1], 0);
68: dup2(pfd[1], 1);
69: close(pfd[1]);
70: execv(argv[1], &argv[1]);
71: fprintf(stderr, "exec %s: %s\n", argv[1], estr());
72: exit(1);
73: }
74:
75: /*
76: * initial protocol with server:
77: * client sends 16 bytes:
78: * max buffer size in 1024-byte units
79: * device number in use
80: * protocol letter
81: * debugging flag
82: * 12 unused
83: * server sends one byte: 1
84: * client sends a list of userids: maxsize bytes
85: * if list won't fit in one buffer, last username is `:'
86: * server acks with one byte 012; client sends more
87: * server sends one byte: 2
88: * client sends a list of groupids: maxsize bytes
89: * if list won't fit in one buffer, last groupname is `:'
90: * server acks with one byte 013; client sends more
91: * server sends one byte: 3
92: * then we mount it, and further messages come from the kernel
93: */
94:
95: #define M1LEN 16
96:
97: setup(fd, mpoint)
98: int fd;
99: char *mpoint;
100: {
101: char m[M1LEN];
102: register int n;
103:
104: signal(SIGPIPE, SIG_DFL);
105: memset(m, 0, M1LEN);
106: m[0] = MAXMSG;
107: /* m[1] = fp->devnum;. */
108: m[1] = 0; /* will this work? */
109: m[2] = 'd'; /* ignored by server? */
110: m[3] = debug;
111: alarm(600);
112: if ((n = write(fd, m, M1LEN)) != M1LEN) {
113: fprintf(stderr, "setup 1: write returned %d; %s\n", n, estr());
114: alarm(0);
115: return (-1);
116: }
117: if (getresp(fd, 1, mpoint) == 0)
118: return (-1);
119: alarm(600);
120: if (senduid(fd, mpoint) < 0) {
121: alarm(0);
122: return (-1);
123: }
124: alarm(600);
125: if (sendgid(fd, mpoint) < 0) {
126: alarm(0);
127: return (-1);
128: }
129: alarm(60);
130: alarm(60);
131: funmount(mpoint); /* bad -- might unmount wrong fs */
132: if (trymount(fd, mpoint) < 0) {
133: fprintf(stderr, "fmount: %s: %s\n", mpoint, estr());
134: alarm(0);
135: return (-1);
136: }
137: alarm(0);
138: return (0);
139: }
140:
141: /*
142: * fmount, but try to guess unique device number
143: */
144:
145: int
146: trymount(fd, mpoint)
147: int fd;
148: char *mpoint;
149: {
150: register int dev;
151:
152: for (dev = 200; dev >= 100; --dev) {
153: if (fmount(NBFS, fd, mpoint, makedev(dev, 0)) >= 0)
154: return (0);
155: if (errno != EBUSY)
156: return (-1);
157: }
158: return (-1);
159: }
160:
161: getresp(fd, id, mpoint)
162: int fd, id;
163: {
164: register int n;
165: char m;
166:
167: alarm(600);
168: n = read(fd, &m, 1);
169: alarm(0); /* assume errno untouched */
170: if (n != 1) {
171: fprintf(stderr, "setup %d: %s: read returned %d: %s\n", id, mpoint, n, estr());
172: return (0);
173: }
174: if (m != id) {
175: fprintf(stderr, "setup %d: %s: received %d (%c)\n", id, mpoint, (unsigned char)m, m);
176: return (0);
177: }
178: return (1);
179: }
180:
181: #define SLOP 50
182:
183: senduid(fd, mpoint)
184: int fd;
185: char *mpoint;
186: {
187: char idbuf[MAXMSG*MSGBLOCK+SLOP];
188: char onebuf[SLOP];
189: register char *p;
190: register struct passwd *pw;
191: register int n, wn;
192:
193: setpwent();
194: p = idbuf;
195: while ((pw = getpwent()) != NULL) {
196: sprintf(onebuf, "%s %d\n", pw->pw_name, pw->pw_uid);
197: n = strlen(onebuf);
198: if (n > &idbuf[MAXMSG*MSGBLOCK] - p - 4) { /* room for ": 1\n" */
199: strcpy(p, ": 1\n"); /* `more coming' */
200: if ((wn = write(fd, idbuf, MAXMSG*MSGBLOCK)) != MAXMSG*MSGBLOCK) {
201: fprintf(stderr, "%s: write uid: %d; %s\n", mpoint, wn, estr());
202: return (-1);
203: }
204: if (getresp(fd, 012, mpoint) == 0)
205: return (-1);
206: p = idbuf;
207: }
208: strcpy(p, onebuf);
209: p += n;
210: }
211: endpwent();
212: if ((wn = write(fd, idbuf, MAXMSG*MSGBLOCK)) != MAXMSG*MSGBLOCK) {
213: fprintf(stderr, "%s: write uid: %d; %s\n", mpoint, wn, estr());
214: return (-1);
215: }
216: if (getresp(fd, 2, mpoint) == 0)
217: return (-1);
218: return (0);
219: }
220:
221: sendgid(fd, mpoint)
222: int fd;
223: char *mpoint;
224: {
225: char idbuf[MAXMSG*MSGBLOCK+SLOP];
226: char onebuf[SLOP];
227: register char *p;
228: register struct group *gr;
229: register int n, wn;
230:
231: setgrent();
232: p = idbuf;
233: while ((gr = getgrent()) != NULL) {
234: sprintf(onebuf, "%s %d\n", gr->gr_name, gr->gr_gid);
235: n = strlen(onebuf);
236: if (n > &idbuf[MAXMSG*MSGBLOCK] - p - 4) { /* room for ": 1\n" */
237: strcpy(p, ": 1\n"); /* `more coming' */
238: if ((wn = write(fd, idbuf, MAXMSG*MSGBLOCK)) != MAXMSG*MSGBLOCK) {
239: fprintf(stderr, "%s: write gid: %d; %s\n", mpoint, wn, estr());
240: return (-1);
241: }
242: if (getresp(fd, 013, mpoint) == 0)
243: return (-1);
244: p = idbuf;
245: }
246: strcpy(p, onebuf);
247: p += n;
248: }
249: endgrent();
250: if ((wn = write(fd, idbuf, MAXMSG*MSGBLOCK)) != MAXMSG*MSGBLOCK) {
251: fprintf(stderr, "%s: write gid: %d; %s\n", mpoint, wn, estr());
252: return (-1);
253: }
254: if (getresp(fd, 3, mpoint) == 0)
255: return (-1);
256: return (0);
257: }
258:
259:
260: char *
261: estr()
262: {
263: static char buf[] = "Error -2147483648";
264:
265: if (errno < 0 || errno >= sys_nerr) {
266: sprintf(buf, "Error %d", errno);
267: return (buf);
268: }
269: return (sys_errlist[errno]);
270: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.