courier.c revision 1.4 1 /* $NetBSD: courier.c,v 1.4 1994/12/08 09:31:35 jtc Exp $ */
2
3 /*
4 * Copyright (c) 1986, 1993
5 * The Regents of the University of California. All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 * 1. Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 * 3. All advertising materials mentioning features or use of this software
16 * must display the following acknowledgement:
17 * This product includes software developed by the University of
18 * California, Berkeley and its contributors.
19 * 4. Neither the name of the University nor the names of its contributors
20 * may be used to endorse or promote products derived from this software
21 * without specific prior written permission.
22 *
23 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
33 * SUCH DAMAGE.
34 */
35
36 #ifndef lint
37 #if 0
38 static char sccsid[] = "@(#)courier.c 8.1 (Berkeley) 6/6/93";
39 #endif
40 static char rcsid[] = "$NetBSD: courier.c,v 1.4 1994/12/08 09:31:35 jtc Exp $";
41 #endif /* not lint */
42
43 /*
44 * Routines for calling up on a Courier modem.
45 * Derived from Hayes driver.
46 */
47 #include "tip.h"
48 #include <stdio.h>
49
50 #define MAXRETRY 5
51
52 static void sigALRM();
53 static int timeout = 0;
54 static int connected = 0;
55 static jmp_buf timeoutbuf, intbuf;
56 static int coursync();
57
58 cour_dialer(num, acu)
59 register char *num;
60 char *acu;
61 {
62 register char *cp;
63 #ifdef ACULOG
64 char line[80];
65 #endif
66 static int cour_connect(), cour_swallow();
67
68 if (boolean(value(VERBOSE)))
69 printf("Using \"%s\"\n", acu);
70
71 ioctl(FD, TIOCHPCL, 0);
72 /*
73 * Get in synch.
74 */
75 if (!coursync()) {
76 badsynch:
77 printf("can't synchronize with courier\n");
78 #ifdef ACULOG
79 logent(value(HOST), num, "courier", "can't synch up");
80 #endif
81 return (0);
82 }
83 cour_write(FD, "AT E0\r", 6); /* turn off echoing */
84 sleep(1);
85 #ifdef DEBUG
86 if (boolean(value(VERBOSE)))
87 cour_verbose_read();
88 #endif
89 ioctl(FD, TIOCFLUSH, 0); /* flush any clutter */
90 cour_write(FD, "AT C1 E0 H0 Q0 X6 V1\r", 21);
91 if (!cour_swallow("\r\nOK\r\n"))
92 goto badsynch;
93 fflush(stdout);
94 cour_write(FD, "AT D", 4);
95 for (cp = num; *cp; cp++)
96 if (*cp == '=')
97 *cp = ',';
98 cour_write(FD, num, strlen(num));
99 cour_write(FD, "\r", 1);
100 connected = cour_connect();
101 #ifdef ACULOG
102 if (timeout) {
103 sprintf(line, "%d second dial timeout",
104 number(value(DIALTIMEOUT)));
105 logent(value(HOST), num, "cour", line);
106 }
107 #endif
108 if (timeout)
109 cour_disconnect();
110 return (connected);
111 }
112
113 cour_disconnect()
114 {
115 /* first hang up the modem*/
116 ioctl(FD, TIOCCDTR, 0);
117 sleep(1);
118 ioctl(FD, TIOCSDTR, 0);
119 coursync(); /* reset */
120 close(FD);
121 }
122
123 cour_abort()
124 {
125 cour_write(FD, "\r", 1); /* send anything to abort the call */
126 cour_disconnect();
127 }
128
129 static void
130 sigALRM()
131 {
132 printf("\07timeout waiting for reply\n");
133 timeout = 1;
134 longjmp(timeoutbuf, 1);
135 }
136
137 static int
138 cour_swallow(match)
139 register char *match;
140 {
141 sig_t f;
142 char c;
143
144 f = signal(SIGALRM, sigALRM);
145 timeout = 0;
146 do {
147 if (*match =='\0') {
148 signal(SIGALRM, f);
149 return (1);
150 }
151 if (setjmp(timeoutbuf)) {
152 signal(SIGALRM, f);
153 return (0);
154 }
155 alarm(number(value(DIALTIMEOUT)));
156 read(FD, &c, 1);
157 alarm(0);
158 c &= 0177;
159 #ifdef DEBUG
160 if (boolean(value(VERBOSE)))
161 putchar(c);
162 #endif
163 } while (c == *match++);
164 #ifdef DEBUG
165 if (boolean(value(VERBOSE)))
166 fflush(stdout);
167 #endif
168 signal(SIGALRM, SIG_DFL);
169 return (0);
170 }
171
172 struct baud_msg {
173 char *msg;
174 int baud;
175 } baud_msg[] = {
176 "", B300,
177 " 1200", B1200,
178 " 2400", B2400,
179 " 9600", B9600,
180 " 9600/ARQ", B9600,
181 0, 0,
182 };
183
184 static int
185 cour_connect()
186 {
187 char c;
188 int nc, nl, n;
189 struct sgttyb sb;
190 char dialer_buf[64];
191 struct baud_msg *bm;
192 sig_t f;
193
194 if (cour_swallow("\r\n") == 0)
195 return (0);
196 f = signal(SIGALRM, sigALRM);
197 again:
198 nc = 0; nl = sizeof(dialer_buf)-1;
199 bzero(dialer_buf, sizeof(dialer_buf));
200 timeout = 0;
201 for (nc = 0, nl = sizeof(dialer_buf)-1 ; nl > 0 ; nc++, nl--) {
202 if (setjmp(timeoutbuf))
203 break;
204 alarm(number(value(DIALTIMEOUT)));
205 n = read(FD, &c, 1);
206 alarm(0);
207 if (n <= 0)
208 break;
209 c &= 0x7f;
210 if (c == '\r') {
211 if (cour_swallow("\n") == 0)
212 break;
213 if (!dialer_buf[0])
214 goto again;
215 if (strcmp(dialer_buf, "RINGING") == 0 &&
216 boolean(value(VERBOSE))) {
217 #ifdef DEBUG
218 printf("%s\r\n", dialer_buf);
219 #endif
220 goto again;
221 }
222 if (strncmp(dialer_buf, "CONNECT",
223 sizeof("CONNECT")-1) != 0)
224 break;
225 for (bm = baud_msg ; bm->msg ; bm++)
226 if (strcmp(bm->msg,
227 dialer_buf+sizeof("CONNECT")-1) == 0) {
228 if (ioctl(FD, TIOCGETP, &sb) < 0) {
229 perror("TIOCGETP");
230 goto error;
231 }
232 sb.sg_ispeed = sb.sg_ospeed = bm->baud;
233 if (ioctl(FD, TIOCSETP, &sb) < 0) {
234 perror("TIOCSETP");
235 goto error;
236 }
237 signal(SIGALRM, f);
238 #ifdef DEBUG
239 if (boolean(value(VERBOSE)))
240 printf("%s\r\n", dialer_buf);
241 #endif
242 return (1);
243 }
244 break;
245 }
246 dialer_buf[nc] = c;
247 #ifdef notdef
248 if (boolean(value(VERBOSE)))
249 putchar(c);
250 #endif
251 }
252 error1:
253 printf("%s\r\n", dialer_buf);
254 error:
255 signal(SIGALRM, f);
256 return (0);
257 }
258
259 /*
260 * This convoluted piece of code attempts to get
261 * the courier in sync.
262 */
263 static int
264 coursync()
265 {
266 int already = 0;
267 int len;
268 char buf[40];
269
270 while (already++ < MAXRETRY) {
271 ioctl(FD, TIOCFLUSH, 0); /* flush any clutter */
272 cour_write(FD, "\rAT Z\r", 6); /* reset modem */
273 bzero(buf, sizeof(buf));
274 sleep(1);
275 ioctl(FD, FIONREAD, &len);
276 if (len) {
277 len = read(FD, buf, sizeof(buf));
278 #ifdef DEBUG
279 buf[len] = '\0';
280 printf("coursync: (\"%s\")\n\r", buf);
281 #endif
282 if (index(buf, '0') ||
283 (index(buf, 'O') && index(buf, 'K')))
284 return(1);
285 }
286 /*
287 * If not strapped for DTR control,
288 * try to get command mode.
289 */
290 sleep(1);
291 cour_write(FD, "+++", 3);
292 sleep(1);
293 /*
294 * Toggle DTR to force anyone off that might have left
295 * the modem connected.
296 */
297 ioctl(FD, TIOCCDTR, 0);
298 sleep(1);
299 ioctl(FD, TIOCSDTR, 0);
300 }
301 cour_write(FD, "\rAT Z\r", 6);
302 return (0);
303 }
304
305 cour_write(fd, cp, n)
306 int fd;
307 char *cp;
308 int n;
309 {
310 struct sgttyb sb;
311 #ifdef notdef
312 if (boolean(value(VERBOSE)))
313 write(1, cp, n);
314 #endif
315 ioctl(fd, TIOCGETP, &sb);
316 ioctl(fd, TIOCSETP, &sb);
317 cour_nap();
318 for ( ; n-- ; cp++) {
319 write(fd, cp, 1);
320 ioctl(fd, TIOCGETP, &sb);
321 ioctl(fd, TIOCSETP, &sb);
322 cour_nap();
323 }
324 }
325
326 #ifdef DEBUG
327 cour_verbose_read()
328 {
329 int n = 0;
330 char buf[BUFSIZ];
331
332 if (ioctl(FD, FIONREAD, &n) < 0)
333 return;
334 if (n <= 0)
335 return;
336 if (read(FD, buf, n) != n)
337 return;
338 write(1, buf, n);
339 }
340 #endif
341
342 /*
343 * Code stolen from /usr/src/lib/libc/gen/sleep.c
344 */
345 #define mask(s) (1<<((s)-1))
346 #define setvec(vec, a) \
347 vec.sv_handler = a; vec.sv_mask = vec.sv_onstack = 0
348
349 static napms = 50; /* Give the courier 50 milliseconds between characters */
350
351 static int ringring;
352
353 cour_nap()
354 {
355
356 static void cour_napx();
357 int omask;
358 struct itimerval itv, oitv;
359 register struct itimerval *itp = &itv;
360 struct sigvec vec, ovec;
361
362 timerclear(&itp->it_interval);
363 timerclear(&itp->it_value);
364 if (setitimer(ITIMER_REAL, itp, &oitv) < 0)
365 return;
366 setvec(ovec, SIG_DFL);
367 omask = sigblock(mask(SIGALRM));
368 itp->it_value.tv_sec = napms/1000;
369 itp->it_value.tv_usec = ((napms%1000)*1000);
370 setvec(vec, cour_napx);
371 ringring = 0;
372 (void) sigvec(SIGALRM, &vec, &ovec);
373 (void) setitimer(ITIMER_REAL, itp, (struct itimerval *)0);
374 while (!ringring)
375 sigpause(omask &~ mask(SIGALRM));
376 (void) sigvec(SIGALRM, &ovec, (struct sigvec *)0);
377 (void) setitimer(ITIMER_REAL, &oitv, (struct itimerval *)0);
378 (void) sigsetmask(omask);
379 }
380
381 static void
382 cour_napx()
383 {
384 ringring = 1;
385 }
386