1*7c478bd9Sstevel@tonic-gate /*
2*7c478bd9Sstevel@tonic-gate * CDDL HEADER START
3*7c478bd9Sstevel@tonic-gate *
4*7c478bd9Sstevel@tonic-gate * The contents of this file are subject to the terms of the
5*7c478bd9Sstevel@tonic-gate * Common Development and Distribution License, Version 1.0 only
6*7c478bd9Sstevel@tonic-gate * (the "License"). You may not use this file except in compliance
7*7c478bd9Sstevel@tonic-gate * with the License.
8*7c478bd9Sstevel@tonic-gate *
9*7c478bd9Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
10*7c478bd9Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing.
11*7c478bd9Sstevel@tonic-gate * See the License for the specific language governing permissions
12*7c478bd9Sstevel@tonic-gate * and limitations under the License.
13*7c478bd9Sstevel@tonic-gate *
14*7c478bd9Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each
15*7c478bd9Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
16*7c478bd9Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the
17*7c478bd9Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying
18*7c478bd9Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner]
19*7c478bd9Sstevel@tonic-gate *
20*7c478bd9Sstevel@tonic-gate * CDDL HEADER END
21*7c478bd9Sstevel@tonic-gate */
22*7c478bd9Sstevel@tonic-gate /*
23*7c478bd9Sstevel@tonic-gate * Copyright 1997 Sun Microsystems, Inc. All rights reserved.
24*7c478bd9Sstevel@tonic-gate * Use is subject to license terms.
25*7c478bd9Sstevel@tonic-gate */
26*7c478bd9Sstevel@tonic-gate
27*7c478bd9Sstevel@tonic-gate /* Copyright (c) 1983, 1984, 1985, 1986, 1987, 1988, 1989 AT&T */
28*7c478bd9Sstevel@tonic-gate /* All Rights Reserved */
29*7c478bd9Sstevel@tonic-gate
30*7c478bd9Sstevel@tonic-gate /*
31*7c478bd9Sstevel@tonic-gate * University Copyright- Copyright (c) 1982, 1986, 1988
32*7c478bd9Sstevel@tonic-gate * The Regents of the University of California
33*7c478bd9Sstevel@tonic-gate * All Rights Reserved
34*7c478bd9Sstevel@tonic-gate *
35*7c478bd9Sstevel@tonic-gate * University Acknowledgment- Portions of this document are derived from
36*7c478bd9Sstevel@tonic-gate * software developed by the University of California, Berkeley, and its
37*7c478bd9Sstevel@tonic-gate * contributors.
38*7c478bd9Sstevel@tonic-gate */
39*7c478bd9Sstevel@tonic-gate
40*7c478bd9Sstevel@tonic-gate #include "talk_ctl.h"
41*7c478bd9Sstevel@tonic-gate #include <sys/time.h>
42*7c478bd9Sstevel@tonic-gate #include <libintl.h>
43*7c478bd9Sstevel@tonic-gate
44*7c478bd9Sstevel@tonic-gate #define CTL_WAIT 2
45*7c478bd9Sstevel@tonic-gate /* the amount of time to wait for a response, in seconds */
46*7c478bd9Sstevel@tonic-gate
47*7c478bd9Sstevel@tonic-gate
48*7c478bd9Sstevel@tonic-gate /*
49*7c478bd9Sstevel@tonic-gate * SOCKDGRAM is unreliable, so we must repeat messages if we have
50*7c478bd9Sstevel@tonic-gate * not recieved an acknowledgement within a reasonable amount of time
51*7c478bd9Sstevel@tonic-gate */
52*7c478bd9Sstevel@tonic-gate
53*7c478bd9Sstevel@tonic-gate void
ctl_transact(target,msg,type,response)54*7c478bd9Sstevel@tonic-gate ctl_transact(target, msg, type, response)
55*7c478bd9Sstevel@tonic-gate struct in_addr target;
56*7c478bd9Sstevel@tonic-gate CTL_MSG msg;
57*7c478bd9Sstevel@tonic-gate int type;
58*7c478bd9Sstevel@tonic-gate CTL_RESPONSE *response;
59*7c478bd9Sstevel@tonic-gate {
60*7c478bd9Sstevel@tonic-gate struct sockaddr junk;
61*7c478bd9Sstevel@tonic-gate int read_mask;
62*7c478bd9Sstevel@tonic-gate int ctl_mask;
63*7c478bd9Sstevel@tonic-gate int nready;
64*7c478bd9Sstevel@tonic-gate int cc;
65*7c478bd9Sstevel@tonic-gate socklen_t junk_size;
66*7c478bd9Sstevel@tonic-gate struct timeval wait;
67*7c478bd9Sstevel@tonic-gate
68*7c478bd9Sstevel@tonic-gate wait.tv_sec = CTL_WAIT;
69*7c478bd9Sstevel@tonic-gate wait.tv_usec = 0;
70*7c478bd9Sstevel@tonic-gate
71*7c478bd9Sstevel@tonic-gate msg.type = type;
72*7c478bd9Sstevel@tonic-gate
73*7c478bd9Sstevel@tonic-gate daemon_addr.sin_addr = target;
74*7c478bd9Sstevel@tonic-gate daemon_addr.sin_port = daemon_port;
75*7c478bd9Sstevel@tonic-gate
76*7c478bd9Sstevel@tonic-gate ctl_mask = 1 << ctl_sockt;
77*7c478bd9Sstevel@tonic-gate
78*7c478bd9Sstevel@tonic-gate /*
79*7c478bd9Sstevel@tonic-gate * keep sending the message until a response of the right
80*7c478bd9Sstevel@tonic-gate * type is obtained
81*7c478bd9Sstevel@tonic-gate */
82*7c478bd9Sstevel@tonic-gate
83*7c478bd9Sstevel@tonic-gate do {
84*7c478bd9Sstevel@tonic-gate /* keep sending the message until a response is obtained */
85*7c478bd9Sstevel@tonic-gate
86*7c478bd9Sstevel@tonic-gate do {
87*7c478bd9Sstevel@tonic-gate cc = sendto(ctl_sockt,
88*7c478bd9Sstevel@tonic-gate (char *)&msg, sizeof (CTL_MSG), 0,
89*7c478bd9Sstevel@tonic-gate (struct sockaddr *)&daemon_addr, sizeof (daemon_addr));
90*7c478bd9Sstevel@tonic-gate
91*7c478bd9Sstevel@tonic-gate if (cc != sizeof (CTL_MSG)) {
92*7c478bd9Sstevel@tonic-gate if (errno == EINTR) {
93*7c478bd9Sstevel@tonic-gate /* we are returning from an interupt */
94*7c478bd9Sstevel@tonic-gate continue;
95*7c478bd9Sstevel@tonic-gate } else {
96*7c478bd9Sstevel@tonic-gate p_error(
97*7c478bd9Sstevel@tonic-gate gettext("Error on write to talk daemon"));
98*7c478bd9Sstevel@tonic-gate }
99*7c478bd9Sstevel@tonic-gate }
100*7c478bd9Sstevel@tonic-gate
101*7c478bd9Sstevel@tonic-gate read_mask = ctl_mask;
102*7c478bd9Sstevel@tonic-gate
103*7c478bd9Sstevel@tonic-gate while ((nready = select(32, (fd_set *)&read_mask,
104*7c478bd9Sstevel@tonic-gate 0, 0, &wait)) < 0) {
105*7c478bd9Sstevel@tonic-gate if (errno == EINTR) {
106*7c478bd9Sstevel@tonic-gate /* we are returning from an interupt */
107*7c478bd9Sstevel@tonic-gate continue;
108*7c478bd9Sstevel@tonic-gate } else {
109*7c478bd9Sstevel@tonic-gate p_error(
110*7c478bd9Sstevel@tonic-gate gettext("Error on waiting for response from daemon"));
111*7c478bd9Sstevel@tonic-gate }
112*7c478bd9Sstevel@tonic-gate }
113*7c478bd9Sstevel@tonic-gate } while (nready == 0);
114*7c478bd9Sstevel@tonic-gate
115*7c478bd9Sstevel@tonic-gate /*
116*7c478bd9Sstevel@tonic-gate * keep reading while there are queued messages
117*7c478bd9Sstevel@tonic-gate * (this is not necessary, it just saves extra
118*7c478bd9Sstevel@tonic-gate * request/acknowledgements being sent)
119*7c478bd9Sstevel@tonic-gate */
120*7c478bd9Sstevel@tonic-gate
121*7c478bd9Sstevel@tonic-gate do {
122*7c478bd9Sstevel@tonic-gate
123*7c478bd9Sstevel@tonic-gate junk_size = (socklen_t)sizeof (junk);
124*7c478bd9Sstevel@tonic-gate cc = recvfrom(ctl_sockt, (char *)response,
125*7c478bd9Sstevel@tonic-gate sizeof (CTL_RESPONSE), 0, &junk, &junk_size);
126*7c478bd9Sstevel@tonic-gate if (cc < 0) {
127*7c478bd9Sstevel@tonic-gate if (errno == EINTR) {
128*7c478bd9Sstevel@tonic-gate continue;
129*7c478bd9Sstevel@tonic-gate }
130*7c478bd9Sstevel@tonic-gate p_error(gettext("Error on read from talk daemon"));
131*7c478bd9Sstevel@tonic-gate }
132*7c478bd9Sstevel@tonic-gate
133*7c478bd9Sstevel@tonic-gate read_mask = ctl_mask;
134*7c478bd9Sstevel@tonic-gate
135*7c478bd9Sstevel@tonic-gate /* an immediate poll */
136*7c478bd9Sstevel@tonic-gate
137*7c478bd9Sstevel@tonic-gate timerclear(&wait);
138*7c478bd9Sstevel@tonic-gate nready = select(32, (fd_set *)&read_mask, 0, 0, &wait);
139*7c478bd9Sstevel@tonic-gate
140*7c478bd9Sstevel@tonic-gate } while (nready > 0 && response->type != type);
141*7c478bd9Sstevel@tonic-gate
142*7c478bd9Sstevel@tonic-gate } while (response->type != type);
143*7c478bd9Sstevel@tonic-gate }
144