]> git.saurik.com Git - apple/network_cmds.git/blob - talk.tproj/look_up.c
network_cmds-201.tar.gz
[apple/network_cmds.git] / talk.tproj / look_up.c
1 /*
2 * Copyright (c) 1999 Apple Computer, Inc. All rights reserved.
3 *
4 * @APPLE_LICENSE_HEADER_START@
5 *
6 * Copyright (c) 1999-2003 Apple Computer, Inc. All Rights Reserved.
7 *
8 * This file contains Original Code and/or Modifications of Original Code
9 * as defined in and that are subject to the Apple Public Source License
10 * Version 2.0 (the 'License'). You may not use this file except in
11 * compliance with the License. Please obtain a copy of the License at
12 * http://www.opensource.apple.com/apsl/ and read it before using this
13 * file.
14 *
15 * The Original Code and all software distributed under the License are
16 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
17 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
18 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
19 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
20 * Please see the License for the specific language governing rights and
21 * limitations under the License.
22 *
23 * @APPLE_LICENSE_HEADER_END@
24 */
25 /*
26 * Copyright (c) 1983, 1993
27 * The Regents of the University of California. All rights reserved.
28 *
29 * Redistribution and use in source and binary forms, with or without
30 * modification, are permitted provided that the following conditions
31 * are met:
32 * 1. Redistributions of source code must retain the above copyright
33 * notice, this list of conditions and the following disclaimer.
34 * 2. Redistributions in binary form must reproduce the above copyright
35 * notice, this list of conditions and the following disclaimer in the
36 * documentation and/or other materials provided with the distribution.
37 * 3. All advertising materials mentioning features or use of this software
38 * must display the following acknowledgement:
39 * This product includes software developed by the University of
40 * California, Berkeley and its contributors.
41 * 4. Neither the name of the University nor the names of its contributors
42 * may be used to endorse or promote products derived from this software
43 * without specific prior written permission.
44 *
45 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
46 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
47 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
48 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
49 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
50 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
51 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
52 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
53 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
54 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
55 * SUCH DAMAGE.
56 */
57
58
59 #include <sys/types.h>
60 #include <sys/socket.h>
61 #include <netinet/in.h>
62 #include <protocols/talkd.h>
63 #include <errno.h>
64 #include "talk_ctl.h"
65 #include "talk.h"
66
67 /*
68 * See if the local daemon has an invitation for us.
69 */
70 check_local()
71 {
72 CTL_RESPONSE response;
73 register CTL_RESPONSE *rp = &response;
74
75 /* the rest of msg was set up in get_names */
76 #ifdef MSG_EOR
77 /* copy new style sockaddr to old, swap family (short in old) */
78 msg.ctl_addr = *(struct osockaddr *)&ctl_addr;
79 msg.ctl_addr.sa_family = htons(ctl_addr.sin_family);
80 #else
81 msg.ctl_addr = *(struct sockaddr *)&ctl_addr;
82 #endif
83 /* must be initiating a talk */
84 if (!look_for_invite(rp))
85 return (0);
86 /*
87 * There was an invitation waiting for us,
88 * so connect with the other (hopefully waiting) party
89 */
90 current_state = "Waiting to connect with caller";
91 do {
92 if (rp->addr.sa_family != AF_INET)
93 p_error("Response uses invalid network address");
94 errno = 0;
95 if (connect(sockt,
96 (struct sockaddr *)&rp->addr, sizeof (rp->addr)) != -1)
97 return (1);
98 } while (errno == EINTR);
99 if (errno == ECONNREFUSED) {
100 /*
101 * The caller gave up, but his invitation somehow
102 * was not cleared. Clear it and initiate an
103 * invitation. (We know there are no newer invitations,
104 * the talkd works LIFO.)
105 */
106 ctl_transact(his_machine_addr, msg, DELETE, rp);
107 close(sockt);
108 open_sockt();
109 return (0);
110 }
111 p_error("Unable to connect with initiator");
112 /*NOTREACHED*/
113 }
114
115 /*
116 * Look for an invitation on 'machine'
117 */
118 look_for_invite(rp)
119 CTL_RESPONSE *rp;
120 {
121 struct in_addr machine_addr;
122
123 current_state = "Checking for invitation on caller's machine";
124 ctl_transact(his_machine_addr, msg, LOOK_UP, rp);
125 /* the switch is for later options, such as multiple invitations */
126 switch (rp->answer) {
127
128 case SUCCESS:
129 msg.id_num = htonl(rp->id_num);
130 return (1);
131
132 default:
133 /* there wasn't an invitation waiting for us */
134 return (0);
135 }
136 }