xref: /illumos-gate/usr/src/cmd/bnu/gio.c (revision 3b296559ccf4430268fec1fbbb543f59c9a7113b)
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 2005 Sun Microsystems, Inc.  All rights reserved.
24  * Use is subject to license terms.
25  */
26 
27 /*	Copyright (c) 1984, 1986, 1987, 1988, 1989 AT&T	*/
28 /*	  All Rights Reserved  	*/
29 
30 
31 #include "uucp.h"
32 
33 #include "pk.h"
34 
35 struct pack *Pk;
36 extern int pkread(), pkwrite();
37 extern void pkclose();
38 
39 static int grdblk(char *, int);
40 static int gwrblk(char *, int);
41 
42 extern int packsize, xpacksize;
43 
44 jmp_buf Getjbuf, Gfailbuf;
45 
46 static void (*gsig)();
47 
48 /* ARGSUSED */
49 static void
galarm(sig)50 galarm(sig)
51 int sig;
52 {
53 	signal(SIGALRM, galarm);
54 	longjmp(Getjbuf, 1);
55 }
56 
57 void
pkfail()58 pkfail()
59 {
60 	longjmp(Gfailbuf, 1);
61 }
62 
63 int
gturnon()64 gturnon()
65 {
66 	struct pack *pkopen();
67 	if (setjmp(Gfailbuf))
68 		return(FAIL);
69 	gsig=signal(SIGALRM, galarm);
70 	if (Debug > 4)
71 		pkdebug = 1;
72 	Pk = pkopen(Ifn, Ofn);
73 	if (Pk == NULL)
74 		return(FAIL);
75 	return(0);
76 }
77 
78 int
gturnoff()79 gturnoff()
80 {
81 	if(setjmp(Gfailbuf))
82 		return(FAIL);
83 	pkclose();
84 	(void) signal(SIGALRM, gsig);
85 	return(0);
86 }
87 
88 /*ARGSUSED*/
89 int
gwrmsg(char type,char * str,int fn)90 gwrmsg(char type, char *str, int fn)
91 {
92 	char bufr[BUFSIZ], *s;
93 	int len, i;
94 
95 	if(setjmp(Gfailbuf))
96 		return(FAIL);
97 	bufr[0] = type;
98 	s = &bufr[1];
99 	while (*str)
100 		*s++ = *str++;
101 	*s = '\0';
102 	if (*(--s) == '\n')
103 		*s = '\0';
104 	len = strlen(bufr) + 1;
105 	if ((i = len % xpacksize) != 0) {
106 		len = len + xpacksize - i;
107 		bufr[len - 1] = '\0';
108 	}
109 	gwrblk(bufr, len);
110 	return(0);
111 }
112 
113 
114 /*ARGSUSED*/
115 int
grdmsg(char * str,int fn)116 grdmsg(char *str, int fn)
117 {
118 	unsigned len;
119 
120 	if(setjmp(Gfailbuf))
121 		return(FAIL);
122 	for (;;) {
123 		len = pkread(str, packsize);
124 		if (len == 0)
125 			continue;
126 		str += len;
127 		if (*(str - 1) == '\0')
128 			break;
129 	}
130 	return(0);
131 }
132 
133 
134 /*ARGSUSED*/
135 int
gwrdata(FILE * fp1,int fn)136 gwrdata(FILE *fp1, int fn)
137 {
138 	char bufr[BUFSIZ];
139 	int fd1;
140 	int len;
141 	int ret;
142 	unsigned long bytes;
143 
144 	if(setjmp(Gfailbuf))
145 		return(FAIL);
146 	bytes = 0L;
147 	fd1 = fileno( fp1 );
148 	while ((len = read( fd1, bufr, BUFSIZ )) > 0) {
149 		bytes += len;
150 		putfilesize(bytes);
151 		ret = gwrblk(bufr, len);
152 		if (ret != len) {
153 			return(FAIL);
154 		}
155 		if (len != BUFSIZ)
156 			break;
157 	}
158 	ret = gwrblk(bufr, 0);
159 	return(0);
160 }
161 
162 /*ARGSUSED*/
163 int
grddata(int fn,FILE * fp2)164 grddata(int fn, FILE *fp2)
165 {
166 	int ret = SUCCESS;
167 	int fd2;
168 	int len;
169 	char bufr[BUFSIZ];
170 	unsigned long bytes;
171 
172 	if(setjmp(Gfailbuf))
173 		return(FAIL);
174 	bytes = 0L;
175 	fd2 = fileno( fp2 );
176 	for (;;) {
177 		len = grdblk(bufr, BUFSIZ);
178 		if (len < 0) {
179 			return(FAIL);
180 		}
181 		bytes += len;
182 		putfilesize(bytes);
183 		if ( ret == SUCCESS && write( fd2, bufr, len ) != len) {
184 			ret = errno;
185 			DEBUG(7, "grddata: write to file failed, errno %d\n", errno);
186 		}
187 		if (len < BUFSIZ)
188 			break;
189 	}
190 	return(ret);
191 }
192 
193 
194 static
195 int
grdblk(char * blk,int len)196 grdblk(char *blk, int len)
197 {
198 	int i, ret;
199 
200 	for (i = 0; i < len; i += ret) {
201 		ret = pkread(blk, len - i);
202 		if (ret < 0)
203 			return(FAIL);
204 		blk += ret;
205 		if (ret == 0)
206 			return(i);
207 	}
208 	return(i);
209 }
210 
211 
212 static int
gwrblk(char * blk,int len)213 gwrblk(char *blk, int len)
214 {
215 	return(pkwrite(blk, len));
216 }
217