Annotation of src/usr.bin/talk/invite.c, Revision 1.4
1.4 ! pjanzen 1: /* $OpenBSD: invite.c,v 1.3 1996/06/26 05:40:23 deraadt 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.4 ! pjanzen 41: static char rcsid[] = "$OpenBSD: invite.c,v 1.3 1996/06/26 05:40:23 deraadt Exp $";
1.1 deraadt 42: #endif /* not lint */
43:
44: #include <sys/types.h>
45: #include <sys/socket.h>
46: #include <sys/time.h>
47: #include <signal.h>
48: #include <netinet/in.h>
1.4 ! pjanzen 49: #include <netdb.h>
1.1 deraadt 50: #include <protocols/talkd.h>
51: #include <errno.h>
52: #include <setjmp.h>
53: #include "talk_ctl.h"
54: #include "talk.h"
55:
1.4 ! pjanzen 56: #define STRING_LENGTH 158
! 57:
1.1 deraadt 58: /*
59: * There wasn't an invitation waiting, so send a request containing
60: * our sockt address to the remote talk daemon so it can invite
61: * him
62: */
63:
64: /*
65: * The msg.id's for the invitations
66: * on the local and remote machines.
67: * These are used to delete the
68: * invitations.
69: */
70: int local_id, remote_id;
71: void re_invite();
72: jmp_buf invitebuf;
73:
74: invite_remote()
75: {
76: int nfd, read_mask, template, new_sockt;
77: struct itimerval itimer;
78: CTL_RESPONSE response;
1.4 ! pjanzen 79: struct sockaddr rp;
! 80: int rplen = sizeof(struct sockaddr);
! 81: struct hostent *rphost;
! 82: char rname[STRING_LENGTH];
1.1 deraadt 83:
84: itimer.it_value.tv_sec = RING_WAIT;
85: itimer.it_value.tv_usec = 0;
86: itimer.it_interval = itimer.it_value;
87: if (listen(sockt, 5) != 0)
88: p_error("Error on attempt to listen for caller");
89: #ifdef MSG_EOR
90: /* copy new style sockaddr to old, swap family (short in old) */
91: msg.addr = *(struct osockaddr *)&my_addr; /* XXX new to old style*/
92: msg.addr.sa_family = htons(my_addr.sin_family);
93: #else
94: msg.addr = *(struct sockaddr *)&my_addr;
95: #endif
96: msg.id_num = htonl(-1); /* an impossible id_num */
97: invitation_waiting = 1;
98: announce_invite();
99: /*
100: * Shut off the automatic messages for a while,
1.4 ! pjanzen 101: * so we can use the interrupt timer to resend the invitation.
! 102: * We no longer turn automatic messages back on to avoid a bonus
! 103: * message after we've connected; this is okay even though end_msgs()
! 104: * gets called again in main().
1.1 deraadt 105: */
106: end_msgs();
107: setitimer(ITIMER_REAL, &itimer, (struct itimerval *)0);
108: message("Waiting for your party to respond");
109: signal(SIGALRM, re_invite);
110: (void) setjmp(invitebuf);
1.4 ! pjanzen 111: while ((new_sockt = accept(sockt, &rp, &rplen)) < 0) {
1.1 deraadt 112: if (errno == EINTR)
113: continue;
114: p_error("Unable to connect with your party");
115: }
116: close(sockt);
117: sockt = new_sockt;
118:
119: /*
120: * Have the daemons delete the invitations now that we
121: * have connected.
122: */
123: msg.id_num = htonl(local_id);
124: ctl_transact(my_machine_addr, msg, DELETE, &response);
125: msg.id_num = htonl(remote_id);
126: ctl_transact(his_machine_addr, msg, DELETE, &response);
127: invitation_waiting = 0;
1.4 ! pjanzen 128:
! 129: /*
! 130: * Check to see if the other guy is coming from the machine
! 131: * we expect.
! 132: */
! 133: if (his_machine_addr.s_addr !=
! 134: ((struct sockaddr_in *)&rp)->sin_addr.s_addr) {
! 135: rphost = gethostbyaddr((char *) &((struct sockaddr_in
! 136: *)&rp)->sin_addr, sizeof(struct in_addr), AF_INET);
! 137: if (rphost)
! 138: snprintf(rname, STRING_LENGTH,
! 139: "Answering talk request from %s@%s", msg.r_name,
! 140: rphost->h_name);
! 141: else
! 142: snprintf(rname, STRING_LENGTH,
! 143: "Answering talk request from %s@%s", msg.r_name,
! 144: inet_ntoa(((struct sockaddr_in *)&rp)->sin_addr));
! 145: message(rname);
! 146: }
1.1 deraadt 147: }
148:
149: /*
150: * Routine called on interupt to re-invite the callee
151: */
152: void
153: re_invite()
154: {
155:
156: message("Ringing your party again");
157: /* force a re-announce */
158: msg.id_num = htonl(remote_id + 1);
159: announce_invite();
160: longjmp(invitebuf, 1);
161: }
162:
163: static char *answers[] = {
164: "answer #0", /* SUCCESS */
165: "Your party is not logged on", /* NOT_HERE */
166: "Target machine is too confused to talk to us", /* FAILED */
167: "Target machine does not recognize us", /* MACHINE_UNKNOWN */
168: "Your party is refusing messages", /* PERMISSION_REFUSED */
169: "Target machine can not handle remote talk", /* UNKNOWN_REQUEST */
170: "Target machine indicates protocol mismatch", /* BADVERSION */
171: "Target machine indicates protocol botch (addr)",/* BADADDR */
172: "Target machine indicates protocol botch (ctl_addr)",/* BADCTLADDR */
173: };
174: #define NANSWERS (sizeof (answers) / sizeof (answers[0]))
175:
176: /*
177: * Transmit the invitation and process the response
178: */
179: announce_invite()
180: {
181: CTL_RESPONSE response;
182:
183: current_state = "Trying to connect to your party's talk daemon";
184: ctl_transact(his_machine_addr, msg, ANNOUNCE, &response);
185: remote_id = response.id_num;
186: if (response.answer != SUCCESS) {
187: if (response.answer < NANSWERS)
188: message(answers[response.answer]);
189: quit();
190: }
191: /* leave the actual invitation on my talk daemon */
192: ctl_transact(my_machine_addr, msg, LEAVE_INVITE, &response);
193: local_id = response.id_num;
194: }
195:
196: /*
197: * Tell the daemon to remove your invitation
198: */
199: send_delete()
200: {
201:
202: msg.type = DELETE;
203: /*
204: * This is just a extra clean up, so just send it
205: * and don't wait for an answer
206: */
207: msg.id_num = htonl(remote_id);
208: daemon_addr.sin_addr = his_machine_addr;
209: if (sendto(ctl_sockt, &msg, sizeof (msg), 0,
210: (struct sockaddr *)&daemon_addr,
211: sizeof (daemon_addr)) != sizeof(msg))
212: perror("send_delete (remote)");
213: msg.id_num = htonl(local_id);
214: daemon_addr.sin_addr = my_machine_addr;
215: if (sendto(ctl_sockt, &msg, sizeof (msg), 0,
216: (struct sockaddr *)&daemon_addr,
217: sizeof (daemon_addr)) != sizeof (msg))
218: perror("send_delete (local)");
219: }
![[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