1ea022d16SRodney W. Grimes /* 2ea022d16SRodney W. Grimes * Copyright (c) 1983, 1993 3ea022d16SRodney W. Grimes * The Regents of the University of California. All rights reserved. 4ea022d16SRodney W. Grimes * 5ea022d16SRodney W. Grimes * Redistribution and use in source and binary forms, with or without 6ea022d16SRodney W. Grimes * modification, are permitted provided that the following conditions 7ea022d16SRodney W. Grimes * are met: 8ea022d16SRodney W. Grimes * 1. Redistributions of source code must retain the above copyright 9ea022d16SRodney W. Grimes * notice, this list of conditions and the following disclaimer. 10ea022d16SRodney W. Grimes * 2. Redistributions in binary form must reproduce the above copyright 11ea022d16SRodney W. Grimes * notice, this list of conditions and the following disclaimer in the 12ea022d16SRodney W. Grimes * documentation and/or other materials provided with the distribution. 13ea022d16SRodney W. Grimes * 3. All advertising materials mentioning features or use of this software 14ea022d16SRodney W. Grimes * must display the following acknowledgement: 15ea022d16SRodney W. Grimes * This product includes software developed by the University of 16ea022d16SRodney W. Grimes * California, Berkeley and its contributors. 17ea022d16SRodney W. Grimes * 4. Neither the name of the University nor the names of its contributors 18ea022d16SRodney W. Grimes * may be used to endorse or promote products derived from this software 19ea022d16SRodney W. Grimes * without specific prior written permission. 20ea022d16SRodney W. Grimes * 21ea022d16SRodney W. Grimes * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 22ea022d16SRodney W. Grimes * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 23ea022d16SRodney W. Grimes * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 24ea022d16SRodney W. Grimes * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 25ea022d16SRodney W. Grimes * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 26ea022d16SRodney W. Grimes * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 27ea022d16SRodney W. Grimes * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 28ea022d16SRodney W. Grimes * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 29ea022d16SRodney W. Grimes * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 30ea022d16SRodney W. Grimes * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 31ea022d16SRodney W. Grimes * SUCH DAMAGE. 32ea022d16SRodney W. Grimes */ 33ea022d16SRodney W. Grimes 34ea022d16SRodney W. Grimes #ifndef lint 35ea022d16SRodney W. Grimes static char sccsid[] = "@(#)process.c 8.2 (Berkeley) 11/16/93"; 36ea022d16SRodney W. Grimes #endif /* not lint */ 37ea022d16SRodney W. Grimes 38ea022d16SRodney W. Grimes /* 39ea022d16SRodney W. Grimes * process.c handles the requests, which can be of three types: 40ea022d16SRodney W. Grimes * ANNOUNCE - announce to a user that a talk is wanted 41ea022d16SRodney W. Grimes * LEAVE_INVITE - insert the request into the table 42ea022d16SRodney W. Grimes * LOOK_UP - look up to see if a request is waiting in 43ea022d16SRodney W. Grimes * in the table for the local user 44ea022d16SRodney W. Grimes * DELETE - delete invitation 45ea022d16SRodney W. Grimes */ 46ea022d16SRodney W. Grimes #include <sys/param.h> 47ea022d16SRodney W. Grimes #include <sys/stat.h> 48ea022d16SRodney W. Grimes #include <sys/socket.h> 49ea022d16SRodney W. Grimes #include <netinet/in.h> 50ea022d16SRodney W. Grimes #include <protocols/talkd.h> 51ea022d16SRodney W. Grimes #include <netdb.h> 52ea022d16SRodney W. Grimes #include <syslog.h> 53ea022d16SRodney W. Grimes #include <stdio.h> 54ea022d16SRodney W. Grimes #include <string.h> 55ea022d16SRodney W. Grimes #include <paths.h> 56ea022d16SRodney W. Grimes 57ea022d16SRodney W. Grimes CTL_MSG *find_request(); 58ea022d16SRodney W. Grimes CTL_MSG *find_match(); 59ea022d16SRodney W. Grimes 60ea022d16SRodney W. Grimes process_request(mp, rp) 61ea022d16SRodney W. Grimes register CTL_MSG *mp; 62ea022d16SRodney W. Grimes register CTL_RESPONSE *rp; 63ea022d16SRodney W. Grimes { 64ea022d16SRodney W. Grimes register CTL_MSG *ptr; 65ea022d16SRodney W. Grimes extern int debug; 66ea022d16SRodney W. Grimes 67ea022d16SRodney W. Grimes rp->vers = TALK_VERSION; 68ea022d16SRodney W. Grimes rp->type = mp->type; 69ea022d16SRodney W. Grimes rp->id_num = htonl(0); 70ea022d16SRodney W. Grimes if (mp->vers != TALK_VERSION) { 71ea022d16SRodney W. Grimes syslog(LOG_WARNING, "Bad protocol version %d", mp->vers); 72ea022d16SRodney W. Grimes rp->answer = BADVERSION; 73ea022d16SRodney W. Grimes return; 74ea022d16SRodney W. Grimes } 75ea022d16SRodney W. Grimes mp->id_num = ntohl(mp->id_num); 76ea022d16SRodney W. Grimes mp->addr.sa_family = ntohs(mp->addr.sa_family); 77ea022d16SRodney W. Grimes if (mp->addr.sa_family != AF_INET) { 78ea022d16SRodney W. Grimes syslog(LOG_WARNING, "Bad address, family %d", 79ea022d16SRodney W. Grimes mp->addr.sa_family); 80ea022d16SRodney W. Grimes rp->answer = BADADDR; 81ea022d16SRodney W. Grimes return; 82ea022d16SRodney W. Grimes } 83ea022d16SRodney W. Grimes mp->ctl_addr.sa_family = ntohs(mp->ctl_addr.sa_family); 84ea022d16SRodney W. Grimes if (mp->ctl_addr.sa_family != AF_INET) { 85ea022d16SRodney W. Grimes syslog(LOG_WARNING, "Bad control address, family %d", 86ea022d16SRodney W. Grimes mp->ctl_addr.sa_family); 87ea022d16SRodney W. Grimes rp->answer = BADCTLADDR; 88ea022d16SRodney W. Grimes return; 89ea022d16SRodney W. Grimes } 90ea022d16SRodney W. Grimes mp->pid = ntohl(mp->pid); 91ea022d16SRodney W. Grimes if (debug) 92ea022d16SRodney W. Grimes print_request("process_request", mp); 93ea022d16SRodney W. Grimes switch (mp->type) { 94ea022d16SRodney W. Grimes 95ea022d16SRodney W. Grimes case ANNOUNCE: 96ea022d16SRodney W. Grimes do_announce(mp, rp); 97ea022d16SRodney W. Grimes break; 98ea022d16SRodney W. Grimes 99ea022d16SRodney W. Grimes case LEAVE_INVITE: 100ea022d16SRodney W. Grimes ptr = find_request(mp); 101ea022d16SRodney W. Grimes if (ptr != (CTL_MSG *)0) { 102ea022d16SRodney W. Grimes rp->id_num = htonl(ptr->id_num); 103ea022d16SRodney W. Grimes rp->answer = SUCCESS; 104ea022d16SRodney W. Grimes } else 105ea022d16SRodney W. Grimes insert_table(mp, rp); 106ea022d16SRodney W. Grimes break; 107ea022d16SRodney W. Grimes 108ea022d16SRodney W. Grimes case LOOK_UP: 109ea022d16SRodney W. Grimes ptr = find_match(mp); 110ea022d16SRodney W. Grimes if (ptr != (CTL_MSG *)0) { 111ea022d16SRodney W. Grimes rp->id_num = htonl(ptr->id_num); 112ea022d16SRodney W. Grimes rp->addr = ptr->addr; 113ea022d16SRodney W. Grimes rp->addr.sa_family = htons(ptr->addr.sa_family); 114ea022d16SRodney W. Grimes rp->answer = SUCCESS; 115ea022d16SRodney W. Grimes } else 116ea022d16SRodney W. Grimes rp->answer = NOT_HERE; 117ea022d16SRodney W. Grimes break; 118ea022d16SRodney W. Grimes 119ea022d16SRodney W. Grimes case DELETE: 120ea022d16SRodney W. Grimes rp->answer = delete_invite(mp->id_num); 121ea022d16SRodney W. Grimes break; 122ea022d16SRodney W. Grimes 123ea022d16SRodney W. Grimes default: 124ea022d16SRodney W. Grimes rp->answer = UNKNOWN_REQUEST; 125ea022d16SRodney W. Grimes break; 126ea022d16SRodney W. Grimes } 127ea022d16SRodney W. Grimes if (debug) 128ea022d16SRodney W. Grimes print_response("process_request", rp); 129ea022d16SRodney W. Grimes } 130ea022d16SRodney W. Grimes 131ea022d16SRodney W. Grimes do_announce(mp, rp) 132ea022d16SRodney W. Grimes register CTL_MSG *mp; 133ea022d16SRodney W. Grimes CTL_RESPONSE *rp; 134ea022d16SRodney W. Grimes { 135ea022d16SRodney W. Grimes struct hostent *hp; 136ea022d16SRodney W. Grimes CTL_MSG *ptr; 137ea022d16SRodney W. Grimes int result; 138ea022d16SRodney W. Grimes 139ea022d16SRodney W. Grimes /* see if the user is logged */ 140ea022d16SRodney W. Grimes result = find_user(mp->r_name, mp->r_tty); 141ea022d16SRodney W. Grimes if (result != SUCCESS) { 142ea022d16SRodney W. Grimes rp->answer = result; 143ea022d16SRodney W. Grimes return; 144ea022d16SRodney W. Grimes } 145ea022d16SRodney W. Grimes #define satosin(sa) ((struct sockaddr_in *)(sa)) 146ea022d16SRodney W. Grimes hp = gethostbyaddr((char *)&satosin(&mp->ctl_addr)->sin_addr, 147ea022d16SRodney W. Grimes sizeof (struct in_addr), AF_INET); 148ea022d16SRodney W. Grimes if (hp == (struct hostent *)0) { 149ea022d16SRodney W. Grimes rp->answer = MACHINE_UNKNOWN; 150ea022d16SRodney W. Grimes return; 151ea022d16SRodney W. Grimes } 152ea022d16SRodney W. Grimes ptr = find_request(mp); 153ea022d16SRodney W. Grimes if (ptr == (CTL_MSG *) 0) { 154ea022d16SRodney W. Grimes insert_table(mp, rp); 155ea022d16SRodney W. Grimes rp->answer = announce(mp, hp->h_name); 156ea022d16SRodney W. Grimes return; 157ea022d16SRodney W. Grimes } 158ea022d16SRodney W. Grimes if (mp->id_num > ptr->id_num) { 159ea022d16SRodney W. Grimes /* 160ea022d16SRodney W. Grimes * This is an explicit re-announce, so update the id_num 161ea022d16SRodney W. Grimes * field to avoid duplicates and re-announce the talk. 162ea022d16SRodney W. Grimes */ 163ea022d16SRodney W. Grimes ptr->id_num = new_id(); 164ea022d16SRodney W. Grimes rp->id_num = htonl(ptr->id_num); 165ea022d16SRodney W. Grimes rp->answer = announce(mp, hp->h_name); 166ea022d16SRodney W. Grimes } else { 167ea022d16SRodney W. Grimes /* a duplicated request, so ignore it */ 168ea022d16SRodney W. Grimes rp->id_num = htonl(ptr->id_num); 169ea022d16SRodney W. Grimes rp->answer = SUCCESS; 170ea022d16SRodney W. Grimes } 171ea022d16SRodney W. Grimes } 172ea022d16SRodney W. Grimes 173ea022d16SRodney W. Grimes #include <utmp.h> 174ea022d16SRodney W. Grimes 175ea022d16SRodney W. Grimes /* 176ea022d16SRodney W. Grimes * Search utmp for the local user 177ea022d16SRodney W. Grimes */ 178ea022d16SRodney W. Grimes find_user(name, tty) 179ea022d16SRodney W. Grimes char *name, *tty; 180ea022d16SRodney W. Grimes { 181ea022d16SRodney W. Grimes struct utmp ubuf; 182ea022d16SRodney W. Grimes int status; 183ea022d16SRodney W. Grimes FILE *fd; 184ea022d16SRodney W. Grimes struct stat statb; 185ea022d16SRodney W. Grimes char line[sizeof(ubuf.ut_line) + 1]; 186ea022d16SRodney W. Grimes char ftty[sizeof(_PATH_DEV) - 1 + sizeof(line)]; 187ea022d16SRodney W. Grimes 188ea022d16SRodney W. Grimes if ((fd = fopen(_PATH_UTMP, "r")) == NULL) { 189ea022d16SRodney W. Grimes fprintf(stderr, "talkd: can't read %s.\n", _PATH_UTMP); 190ea022d16SRodney W. Grimes return (FAILED); 191ea022d16SRodney W. Grimes } 192ea022d16SRodney W. Grimes #define SCMPN(a, b) strncmp(a, b, sizeof (a)) 193ea022d16SRodney W. Grimes status = NOT_HERE; 194ea022d16SRodney W. Grimes (void) strcpy(ftty, _PATH_DEV); 195ea022d16SRodney W. Grimes while (fread((char *) &ubuf, sizeof ubuf, 1, fd) == 1) 196ea022d16SRodney W. Grimes if (SCMPN(ubuf.ut_name, name) == 0) { 197ea022d16SRodney W. Grimes strncpy(line, ubuf.ut_line, sizeof(ubuf.ut_line)); 198ea022d16SRodney W. Grimes line[sizeof(ubuf.ut_line)] = '\0'; 199ea022d16SRodney W. Grimes if (*tty == '\0') { 200ea022d16SRodney W. Grimes status = PERMISSION_DENIED; 201ea022d16SRodney W. Grimes /* no particular tty was requested */ 202ea022d16SRodney W. Grimes (void) strcpy(ftty + sizeof(_PATH_DEV) - 1, 203ea022d16SRodney W. Grimes line); 204ea022d16SRodney W. Grimes if (stat(ftty, &statb) == 0) { 205ea022d16SRodney W. Grimes if (!(statb.st_mode & 020)) 206ea022d16SRodney W. Grimes continue; 207ea022d16SRodney W. Grimes (void) strcpy(tty, line); 208ea022d16SRodney W. Grimes status = SUCCESS; 209ea022d16SRodney W. Grimes break; 210ea022d16SRodney W. Grimes } 211ea022d16SRodney W. Grimes } 212ea022d16SRodney W. Grimes if (strcmp(line, tty) == 0) { 213ea022d16SRodney W. Grimes status = SUCCESS; 214ea022d16SRodney W. Grimes break; 215ea022d16SRodney W. Grimes } 216ea022d16SRodney W. Grimes } 217ea022d16SRodney W. Grimes fclose(fd); 218ea022d16SRodney W. Grimes return (status); 219ea022d16SRodney W. Grimes } 220