Annotation of src/usr.bin/talk/invite.c, Revision 1.8
1.8 ! millert 1: /* $OpenBSD: invite.c,v 1.7 1999/03/03 20:43:30 millert Exp $ */
1.1 deraadt 2: /* $NetBSD: invite.c,v 1.3 1994/12/09 02:14:18 jtc Exp $ */
3:
4: /*
5: * Copyright (c) 1983, 1993
6: * The Regents of the University of California. All rights reserved.
7: *
8: * Redistribution and use in source and binary forms, with or without
9: * modification, are permitted provided that the following conditions
10: * are met:
11: * 1. Redistributions of source code must retain the above copyright
12: * notice, this list of conditions and the following disclaimer.
13: * 2. Redistributions in binary form must reproduce the above copyright
14: * notice, this list of conditions and the following disclaimer in the
15: * documentation and/or other materials provided with the distribution.
16: * 3. All advertising materials mentioning features or use of this software
17: * must display the following acknowledgement:
18: * This product includes software developed by the University of
19: * California, Berkeley and its contributors.
20: * 4. Neither the name of the University nor the names of its contributors
21: * may be used to endorse or promote products derived from this software
22: * without specific prior written permission.
23: *
24: * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
25: * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
26: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
27: * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
28: * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
29: * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
30: * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
31: * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
32: * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
33: * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
34: * SUCH DAMAGE.
35: */
36:
37: #ifndef lint
38: #if 0
39: static char sccsid[] = "@(#)invite.c 8.1 (Berkeley) 6/6/93";
40: #endif
1.8 ! millert 41: static char rcsid[] = "$OpenBSD: invite.c,v 1.7 1999/03/03 20:43:30 millert Exp $";
1.1 deraadt 42: #endif /* not lint */
43:
1.5 pjanzen 44: #include "talk.h"
45: #include <arpa/inet.h>
1.1 deraadt 46: #include <sys/time.h>
1.4 pjanzen 47: #include <netdb.h>
1.1 deraadt 48: #include <errno.h>
49: #include <setjmp.h>
1.5 pjanzen 50: #include <unistd.h>
1.1 deraadt 51: #include "talk_ctl.h"
52:
1.4 pjanzen 53: #define STRING_LENGTH 158
54:
1.1 deraadt 55: /*
56: * There wasn't an invitation waiting, so send a request containing
57: * our sockt address to the remote talk daemon so it can invite
1.6 millert 58: * him
1.1 deraadt 59: */
60:
61: /*
62: * The msg.id's for the invitations
63: * on the local and remote machines.
1.6 millert 64: * These are used to delete the
1.1 deraadt 65: * invitations.
66: */
67: int local_id, remote_id;
68: jmp_buf invitebuf;
69:
1.5 pjanzen 70: void
1.1 deraadt 71: invite_remote()
72: {
1.5 pjanzen 73: int new_sockt;
1.1 deraadt 74: struct itimerval itimer;
75: CTL_RESPONSE response;
1.4 pjanzen 76: struct sockaddr rp;
77: int rplen = sizeof(struct sockaddr);
78: struct hostent *rphost;
79: char rname[STRING_LENGTH];
1.1 deraadt 80:
81: itimer.it_value.tv_sec = RING_WAIT;
82: itimer.it_value.tv_usec = 0;
83: itimer.it_interval = itimer.it_value;
84: if (listen(sockt, 5) != 0)
1.7 millert 85: quit("Error on attempt to listen for caller", 1);
1.1 deraadt 86: #ifdef MSG_EOR
87: /* copy new style sockaddr to old, swap family (short in old) */
88: msg.addr = *(struct osockaddr *)&my_addr; /* XXX new to old style*/
89: msg.addr.sa_family = htons(my_addr.sin_family);
90: #else
91: msg.addr = *(struct sockaddr *)&my_addr;
92: #endif
93: msg.id_num = htonl(-1); /* an impossible id_num */
94: invitation_waiting = 1;
95: announce_invite();
96: /*
97: * Shut off the automatic messages for a while,
1.4 pjanzen 98: * so we can use the interrupt timer to resend the invitation.
99: * We no longer turn automatic messages back on to avoid a bonus
100: * message after we've connected; this is okay even though end_msgs()
101: * gets called again in main().
1.1 deraadt 102: */
103: end_msgs();
104: setitimer(ITIMER_REAL, &itimer, (struct itimerval *)0);
105: message("Waiting for your party to respond");
106: signal(SIGALRM, re_invite);
107: (void) setjmp(invitebuf);
1.4 pjanzen 108: while ((new_sockt = accept(sockt, &rp, &rplen)) < 0) {
1.1 deraadt 109: if (errno == EINTR)
110: continue;
1.7 millert 111: quit("Unable to connect with your party", 1);
1.1 deraadt 112: }
113: close(sockt);
114: sockt = new_sockt;
115:
116: /*
117: * Have the daemons delete the invitations now that we
118: * have connected.
119: */
120: msg.id_num = htonl(local_id);
121: ctl_transact(my_machine_addr, msg, DELETE, &response);
122: msg.id_num = htonl(remote_id);
123: ctl_transact(his_machine_addr, msg, DELETE, &response);
124: invitation_waiting = 0;
1.4 pjanzen 125:
126: /*
127: * Check to see if the other guy is coming from the machine
128: * we expect.
129: */
130: if (his_machine_addr.s_addr !=
131: ((struct sockaddr_in *)&rp)->sin_addr.s_addr) {
132: rphost = gethostbyaddr((char *) &((struct sockaddr_in
133: *)&rp)->sin_addr, sizeof(struct in_addr), AF_INET);
134: if (rphost)
135: snprintf(rname, STRING_LENGTH,
136: "Answering talk request from %s@%s", msg.r_name,
137: rphost->h_name);
138: else
139: snprintf(rname, STRING_LENGTH,
140: "Answering talk request from %s@%s", msg.r_name,
141: inet_ntoa(((struct sockaddr_in *)&rp)->sin_addr));
142: message(rname);
143: }
1.1 deraadt 144: }
145:
146: /*
147: * Routine called on interupt to re-invite the callee
148: */
149: void
1.5 pjanzen 150: re_invite(dummy)
151: int dummy;
1.1 deraadt 152: {
153: message("Ringing your party again");
154: /* force a re-announce */
155: msg.id_num = htonl(remote_id + 1);
156: announce_invite();
157: longjmp(invitebuf, 1);
158: }
159:
160: static char *answers[] = {
161: "answer #0", /* SUCCESS */
162: "Your party is not logged on", /* NOT_HERE */
163: "Target machine is too confused to talk to us", /* FAILED */
164: "Target machine does not recognize us", /* MACHINE_UNKNOWN */
165: "Your party is refusing messages", /* PERMISSION_REFUSED */
166: "Target machine can not handle remote talk", /* UNKNOWN_REQUEST */
167: "Target machine indicates protocol mismatch", /* BADVERSION */
168: "Target machine indicates protocol botch (addr)",/* BADADDR */
169: "Target machine indicates protocol botch (ctl_addr)",/* BADCTLADDR */
170: };
1.5 pjanzen 171: #define NANSWERS (sizeof (answers) / sizeof (answers[0]))
1.1 deraadt 172:
173: /*
174: * Transmit the invitation and process the response
175: */
1.5 pjanzen 176: void
1.1 deraadt 177: announce_invite()
178: {
179: CTL_RESPONSE response;
180:
181: current_state = "Trying to connect to your party's talk daemon";
182: ctl_transact(his_machine_addr, msg, ANNOUNCE, &response);
183: remote_id = response.id_num;
1.7 millert 184: if (response.answer != SUCCESS)
185: quit(response.answer < NANSWERS ? answers[response.answer] : NULL, 0);
1.1 deraadt 186: /* leave the actual invitation on my talk daemon */
187: ctl_transact(my_machine_addr, msg, LEAVE_INVITE, &response);
188: local_id = response.id_num;
189: }
190:
191: /*
192: * Tell the daemon to remove your invitation
193: */
1.5 pjanzen 194: void
1.1 deraadt 195: send_delete()
196: {
197:
198: msg.type = DELETE;
199: /*
200: * This is just a extra clean up, so just send it
201: * and don't wait for an answer
202: */
203: msg.id_num = htonl(remote_id);
204: daemon_addr.sin_addr = his_machine_addr;
205: if (sendto(ctl_sockt, &msg, sizeof (msg), 0,
206: (struct sockaddr *)&daemon_addr,
207: sizeof (daemon_addr)) != sizeof(msg))
1.6 millert 208: warn("send_delete (remote)");
1.1 deraadt 209: msg.id_num = htonl(local_id);
210: daemon_addr.sin_addr = my_machine_addr;
211: if (sendto(ctl_sockt, &msg, sizeof (msg), 0,
212: (struct sockaddr *)&daemon_addr,
213: sizeof (daemon_addr)) != sizeof (msg))
1.6 millert 214: warn("send_delete (local)");
1.1 deraadt 215: }
![[BACK]](/icons/back.gif){kind=icon}
Return to invite.c CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [local] / src / usr.bin / talk