![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to ndcon.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv10no / dk / cmd|
Return to ndcon.c CVS log | Up to [Research Unix] / researchv10no / dk / cmd |
1.1 root 1: #include <stdio.h>
2: #include <dk.h>
3: #include <sgtty.h>
4: #include <sys/stream.h>
5: #include <errno.h>
6: #include <signal.h>
7: #include <sys/stat.h>
8:
9: /*
10: * program to connect to
11: * another cpu on Datakit w/ transparent ioctls
12: */
13:
14: int rem; /* remote file descriptor */
15: extern int mesg_ld, dkp_ld;
16: extern errno;
17: extern char *dkerror;
18: struct sgttyb sgbuf;
19: char *ttyn;
20: int perms;
21:
22: struct sigmsg {
23: struct mesg m;
24: char sig[1];
25: };
26:
27: #define msglen(mp) ((mp)->losize + ((mp)->hisize<<8))
28:
29: main(argc, argv)
30: char **argv;
31: {
32: char *host;
33: char dest[128];
34: struct stat sb;
35: extern int hupcatch();
36: char *ttyname();
37:
38: while(argc > 1 && argv[1][0] == '-'){
39: argv++;
40: argc--;
41: }
42: host = argv[1];
43:
44: if(host==0){
45: printf("usage: %s host\n", argv[0]);
46: exit(1);
47: }
48:
49: ioctl(0, TIOCGETP, &sgbuf);
50: sprintf(dest, "%s.mesgdcon", host);
51: rem = tdkdial(dest, 0);
52: if (rem<0) {
53: printf("%s: call to %s failed: %s\n", argv[0], dest, dkerror);
54: exit(1);
55: }
56: if(dkproto(rem, dkp_ld) < 0){
57: printf("%s: can't push dk line discipline\n", argv[0]);
58: exit(1);
59: }
60: if(tdklogin(rem) < 0){
61: printf("%s: can't log in\n", argv[0]);
62: exit(1);
63: }
64: signal(SIGHUP, hupcatch);
65: signal(SIGQUIT, SIG_IGN);
66: signal(SIGPIPE, SIG_IGN);
67: if ((ttyn = ttyname(0)) != NULL
68: && stat(ttyn, &sb) >= 0) {
69: perms = sb.st_mode & ~S_IFMT;
70: chmod(ttyn, 0);
71: }
72: ioctl(0, TIOCFLUSH, (char *)0); /* race with readahead still possible */
73: if(ioctl(0, FIOPUSHLD, &mesg_ld) < 0){
74: printf("%s: can't push mesg_ld\n", argv[0]);
75: finish(1);
76: }
77:
78: go(rem);
79:
80: finish(0);
81: /* NOTREACHED */
82: }
83:
84: go(fd)
85: {
86: int rbits, wbits, n;
87: char buf[4096+MSGHLEN];
88: struct mesg *mp;
89:
90: mp = (struct mesg *) buf;
91: wbits = 0;
92: while(1){
93: rbits = 1 | (1<<fd);
94: if(select(20, &rbits, &wbits, 20000) < 0){
95: if(errno != EINTR)
96: return;
97: continue;
98: }
99: if(rbits & 1){
100: n = read(0, buf, sizeof(buf));
101: if(n <= 0)
102: return;
103: if (mp->type==M_SIGNAL
104: && ((struct sigmsg *)mp)->sig[0]==SIGQUIT) {
105: dolocal(fd, buf, n);
106: continue;
107: }
108: mp->magic = MSGMAGIC; /* temp safety */
109: if(write(fd, buf, n) != n)
110: return;
111: if(mp->type == M_FLUSH) {
112: remflush();
113: rbits = 0;
114: }
115: }
116: if(rbits & (1<<fd)){
117: n = read(fd, buf, sizeof(buf));
118: if(n <= 0)
119: return;
120: if(mp->type == M_HANGUP)
121: return;
122: if(mp->type == M_IOCTL){
123: doioctl(buf, n);
124: } else {
125: mp->magic = MSGMAGIC; /* temp safety */
126: if(write(1, buf, n) != n)
127: return;
128: }
129: }
130: }
131: }
132:
133: doioctl(buf, n)
134: char *buf;
135: {
136: struct mesg *mp;
137: struct iofoo{
138: int cmd;
139: union{
140: int i;
141: char errno;
142: struct insld insld;
143: } u;
144: } *iop;
145: int cmd, ld;
146:
147: iop = (struct iofoo *)(buf + MSGHLEN);
148: mp = (struct mesg *) buf;
149:
150: cmd = iop->cmd;
151: n -= MSGHLEN;
152: n -= sizeof(iop->cmd);
153: switch(cmd){
154: case FIOLOOKLD:
155: if(n > 0)
156: ld = iop->u.i;
157: else
158: ld = 0;
159: ld++;
160: if(ioctl(1, FIOLOOKLD, &ld) < 0)
161: goto bad;
162: iop->cmd = ld;
163: n = sizeof(iop->cmd);
164: break;
165:
166: case FIOPOPLD:
167: if(n > 0)
168: ld = iop->u.i;
169: else
170: ld = 0;
171: ld++;
172: if(ioctl(1, FIOPOPLD, &ld) < 0)
173: goto bad;
174: n = 0;
175: break;
176:
177: case FIOPUSHLD:
178: iop->u.insld.level = 0;
179: /* fall through... */
180: case FIOINSLD:
181: iop->u.insld.level++;
182: if(ioctl(1, FIOINSLD, &(iop->u.insld)) < 0)
183: goto bad;
184: n = 0;
185: break;
186:
187: default:
188: mp->magic = MSGMAGIC; /* safety */
189: write(1, buf, MSGHLEN + msglen(mp));
190: return;
191: }
192: /* locally successful */
193: mp->type = M_IOCACK;
194: mp->magic = MSGMAGIC;
195: setmsgl(mp, n);
196: write(rem, buf, MSGHLEN + msglen(mp));
197: return;
198: bad:
199: mp->type = M_IOCNAK;
200: mp->magic = MSGMAGIC;
201: setmsgl(mp, sizeof(struct iofoo));
202: iop->u.errno = errno;
203: write(rem, buf, MSGHLEN + msglen(mp));
204: }
205:
206: remflush()
207: {
208: char buf[5000];
209: struct mesg *mp;
210: int n;
211:
212: mp = (struct mesg *) buf;
213: mp->type = M_IOCTL;
214: setmsgl(mp, sizeof(int));
215: mp->magic = MSGMAGIC;
216: write(rem, buf, sizeof(struct mesg) + msglen(mp));
217:
218: while((n = read(rem, buf, sizeof(buf))) > 0){
219: if(mp->type == M_IOCNAK || mp->type == M_IOCACK)
220: return;
221: }
222: }
223:
224: setmsgl(mp, n)
225: register struct mesg *mp;
226: int n;
227: {
228: mp->losize = n;
229: mp->hisize = n >> 8;
230: }
231:
232: hupcatch()
233: {
234: finish(0);
235: }
236:
237: finish(sts)
238: {
239: struct mesg m;
240:
241: if(ioctl(0, FIOLOOKLD, 0) == mesg_ld)
242: ioctl(0, FIOPOPLD, 0);
243: if (ttyn)
244: chmod(ttyn, perms);
245: if (sts == 0)
246: printf("Eof\n");
247: exit(sts);
248: }
249:
250: dolocal(fp, buf, n)
251: char *buf;
252: {
253: char lbuf[128+1];
254: register char *lp;
255: struct sgttyb nsgbuf;
256: register struct mesg *mp = (struct mesg *)buf;
257:
258: ioctl(0, FIOPOPLD, (char *)0);
259: ioctl(0, TIOCFLUSH, (char *)0);
260: ioctl(0, TIOCGETP, &nsgbuf);
261: ioctl(0, TIOCSETP, &sgbuf);
262: chmod(ttyn, perms);
263: for (;;) {
264: lp = lbuf;
265: printf( "dcon>> ");
266: fflush(stdout);
267: while (lp < &lbuf[128] && read(0, lp, 1)>0 && *lp!='\n')
268: lp++;
269: *lp = '\0';
270: if (*lbuf=='i')
271: break;
272: else if (*lbuf=='q'||*lbuf=='x'||*lbuf=='.')
273: exit(0);
274: else if (*lbuf=='!') {
275: system(lbuf+1);
276: printf("!!\n");
277: fflush(stdout);
278: mp->type = 0;
279: break;
280: } else if (*lbuf=='\0') {
281: mp->type = 0;
282: break;
283: } else {
284: printf("[qx.] to exit, i for quit signal, !cmd for shell\n");
285: fflush(stdout);
286: }
287: }
288: ioctl(0, TIOCSETP, &nsgbuf);
289: ioctl(0, FIOPUSHLD, &mesg_ld);
290: chmod(ttyn, 0);
291: if (mp->type) {
292: mp->magic = MSGMAGIC; /* safety */
293: write(fp, buf, n);
294: }
295: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.