![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to pipe.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / quipu / dish|
Return to pipe.c CVS log | Up to [CSRG BSD Unix] / 43BSDReno / contrib / isode-beta / quipu / dish |
1.1 root 1: /* pipe.c - */
2:
3: #ifndef lint
4: static char *rcsid = "$Header: /f/osi/quipu/dish/RCS/pipe.c,v 7.1 90/07/09 14:47:21 mrose Exp $";
5: #endif
6:
7: /*
8: * $Header: /f/osi/quipu/dish/RCS/pipe.c,v 7.1 90/07/09 14:47:21 mrose Exp $
9: *
10: *
11: * $Log: pipe.c,v $
12: * Revision 7.1 90/07/09 14:47:21 mrose
13: * sync
14: *
15: * Revision 7.0 89/11/23 22:20:17 mrose
16: * Release 6.0
17: *
18: */
19:
20: /*
21: * NOTICE
22: *
23: * Acquisition, use, and distribution of this module and related
24: * materials are subject to the restrictions of a license agreement.
25: * Consult the Preface in the User's Manual for the full terms of
26: * this agreement.
27: *
28: */
29:
30:
31: #include <signal.h>
32: #include <stdio.h>
33: #include <errno.h>
34: #include "general.h"
35:
36: #ifdef SOCKETS
37: #include "internet.h"
38: #endif
39: #include <sys/ioctl.h>
40: #ifdef BSD42
41: #include <sys/file.h>
42: #endif
43: #ifdef SYS5
44: #include <fcntl.h>
45: #endif
46: #include <sys/stat.h>
47: #include "tailor.h"
48:
49: #ifdef SOCKETS
50: int sd, sd_current;
51: #else
52: char retpipe[LINESIZE];
53: int fd, wfd;
54: #endif
55:
56: #ifndef MIN
57: #define MIN(a,b) (( (b) < (a) ) ? (b) : (a) )
58: #endif
59:
60: int parent_pid;
61: extern int errno;
62:
63: init_pipe ()
64: {
65: char parent [BUFSIZ];
66: char *cp;
67:
68: #ifdef SOCKETS
69: struct sockaddr_in sin_buf;
70: struct sockaddr_in *sin = &sin_buf;
71: #else
72: #endif
73:
74: if ((cp = getenv ("DISHPARENT")) == NULLCP) {
75: (void) sprintf (parent, "%d", getppid ());
76: (void) setenv ("DISHPARENT", cp = parent);
77: }
78:
79:
80: if (sscanf (cp, "%d", &parent_pid) != 1) {
81: (void) fprintf (stderr,"DISHPARENT malformed");
82: return (NOTOK);
83: }
84:
85: #ifdef SOCKETS
86: if (get_dish_sock (sin) != 0)
87: return (NOTOK);
88:
89: if ((sd = start_tcp_server (sin, SOMAXCONN, 0, 0)) == NOTOK) {
90: perror ("start_tcp_server");
91: return NOTOK;
92: }
93: #ifdef FIOCLEX
94: (void) ioctl (sd, FIOCLEX, NULLCP);
95: #endif
96: #else
97:
98: if ((cp = getenv ("DISHPROC")) == NULL) {
99: (void) fprintf (stderr, "no DISHPROC in environment\n");
100: return (NOTOK);
101: }
102:
103: (void) strcpy (retpipe, cp);
104: (void) umask (0);
105:
106: if ((fd = open (retpipe, O_RDONLY)) < 0) {
107: (void) mknod (retpipe, S_IFIFO | 0600, 0);
108: if ((fd = open (retpipe, O_RDONLY)) < 0) {
109: (void) fprintf (stderr, "ropen failed\n");
110: (void) unlink (retpipe);
111: return (NOTOK);
112: }
113: }
114:
115: if ((wfd = open (retpipe, O_WRONLY)) < 0) {
116: (void) fprintf (stderr, "wr open failed\n");
117: (void) unlink (retpipe);
118: (void) close (fd);
119: return (NOTOK);
120: }
121: #endif
122:
123: #ifdef SETSID
124: (void) setsid ();
125: #endif
126: #ifdef TIOCNOTTY
127: {
128: int xsd;
129:
130: if ((xsd = open ("/dev/tty", O_RDWR)) != NOTOK) {
131: (void) ioctl (xsd, TIOCNOTTY, NULLCP);
132: (void) close (xsd);
133: }
134: }
135: #else
136: #ifdef SYS5
137: (void) setpgrp ();
138: (void) signal (SIGINT, SIG_IGN);
139: (void) signal (SIGQUIT, SIG_IGN);
140: #endif
141: #endif
142: return (OK);
143: }
144:
145: exit_pipe ()
146: {
147: #ifdef SOCKETS
148: (void) close_tcp_socket (sd);
149: #else
150: (void) close (fd);
151: (void) close (wfd);
152: (void) unlink (retpipe);
153: #endif
154: }
155:
156: read_pipe (buf,len)
157: char * buf;
158: int len;
159: {
160: #ifdef SOCKETS
161: struct sockaddr_in sock;
162:
163: while ((sd_current = join_tcp_client (sd, &sock)) == NOTOK) {
164: if (errno != EINTR) {
165: perror("join_tcp_client");
166: return (-1);
167: }
168: }
169: #ifdef FIOCLEX
170: (void) ioctl (sd_current, FIOCLEX, NULLCP);
171: #endif
172: #endif
173: return (read_pipe_aux(buf,len));
174: }
175:
176:
177: read_pipe_aux (buf,len)
178: char * buf;
179: int len;
180: {
181: int res;
182:
183: *buf = '\0';
184: #ifdef SOCKETS
185: if((res = recv(sd_current, buf, len, 0)) == -1) {
186: perror ("recv");
187: (void) close (sd_current);
188: return (-1);
189: }
190: #else
191: if ((res = read (fd, buf, len)) <= 0) {
192: perror ("read error");
193: reopen_ret ();
194: return (-1);
195: }
196: #endif
197:
198: *(buf + res) = 0;
199: return (res);
200: }
201:
202:
203:
204:
205: #ifndef SOCKETS
206: send_pipe (buf)
207: char * buf;
208: {
209: send_pipe_aux (buf);
210:
211: (void) close (file);
212: reopen_ret ();
213: }
214: #endif
215:
216: send_pipe_aux (buf)
217: char * buf;
218: {
219: int res,i;
220:
221: i = strlen (buf);
222:
223: #ifndef SOCKETS
224: if ((file = open (inbuf, O_WRONLY)) <= 0) {
225: (void) fprintf (stderr, "error %s on %s\n",sys_errname (errno), inbuf);
226: reopen_ret ();
227: return;
228: }
229: #endif
230:
231: while (i > 0) {
232: #ifdef SOCKETS
233: if ( (res= send(sd_current, buf, i, 0)) == -1) {
234: perror("send");
235: (void) close (sd_current);
236: return;
237: }
238: #else
239: if ((res = write (file, buf, MIN (BUFSIZ,i))) == -1 ) {
240: (void) fprintf (stderr,"result write error (2)\n");
241: reopen_ret ();
242: return;
243: }
244: #endif
245: buf += res, i -= res;
246: }
247: }
248:
249:
250: #ifdef SOCKETS
251: get_dish_sock (isock)
252: struct sockaddr_in *isock;
253: {
254: char * getenv ();
255: char * ptr;
256: char buffer [BUFSIZ];
257: int portno;
258: char *dp;
259: register struct hostent *hp;
260:
261: if ((ptr = getenv ("DISHPROC")) == NULLCP) {
262: #ifdef notanymore
263: char *cp,
264: #endif
265: portno = (getppid () & 0xffff) | 0x8000;
266: #ifdef notanymore
267: if ((hp = gethostbystring (cp = getlocalhost ())) == NULL) {
268: (void) fprintf (stderr,"%s: unknown host", cp);
269: return (-1);
270: }
271: (void) sprintf (buffer, "%s %d",
272: inet_ntoa (*(struct in_addr *) hp -> h_addr),
273: portno);
274: #else
275: (void) sprintf (buffer, "127.0.0.1 %d", portno);
276: #endif
277: (void) setenv ("DISHPROC", ptr = buffer);
278: }
279:
280: if ((dp = index (ptr, ' ')) == NULLCP || sscanf (dp + 1, "%d", &portno) != 1) {
281: (void) fprintf (stderr,"DISHPROC malformed");
282: return (-1);
283: }
284: *dp = NULL;
285:
286: if ((hp = gethostbystring (ptr)) == NULL) {
287: (void) fprintf (stderr,"%s: unknown host in DISHPROC", ptr);
288: return (-1);
289: }
290: *dp = ' ';
291:
292: bzero ((char *) isock, sizeof *isock);
293: isock -> sin_family = hp -> h_addrtype;
294: isock -> sin_port = htons ((u_short) portno);
295: inaddr_copy (hp, isock);
296:
297: return (0);
298:
299: }
300:
301: #else
302:
303: reopen_ret ()
304: {
305: (void) close (fd);
306: (void) close (wfd);
307:
308: if ((fd = open (retpipe, O_RDONLY)) < 0) {
309: if ( errno == EINTR ) {
310: reopen_ret ();
311: return;
312: }
313: (void) fprintf (stderr, "re-ropen failed\n");
314: (void) unlink (retpipe);
315: exit (-72);
316: }
317: if ((wfd = open (retpipe, O_WRONLY)) < 0) {
318: (void) fprintf (stderr, "re-wr open failed\n");
319: (void) unlink (retpipe);
320: (void) close (fd);
321: exit (-73);
322: }
323: }
324: #endif
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.