X-Git-Url: https://git.subgeniuskitty.com/unix-history/.git/blobdiff_plain/2ee2174b2432f018563a11351f915c0b404e5d41..ed554bc5e4201344d7eaad78263566e79428759c:/usr/src/libexec/talkd/process.c diff --git a/usr/src/libexec/talkd/process.c b/usr/src/libexec/talkd/process.c index 0a48da51c8..dd05e6be0b 100644 --- a/usr/src/libexec/talkd/process.c +++ b/usr/src/libexec/talkd/process.c @@ -1,12 +1,39 @@ /* - * Copyright (c) 1983 Regents of the University of California. - * All rights reserved. The Berkeley software License Agreement - * specifies the terms and conditions for redistribution. + * Copyright (c) 1983, 1993 + * The Regents of the University of California. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. All advertising materials mentioning features or use of this software + * must display the following acknowledgement: + * This product includes software developed by the University of + * California, Berkeley and its contributors. + * 4. Neither the name of the University nor the names of its contributors + * may be used to endorse or promote products derived from this software + * without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE + * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. */ #ifndef lint -static char sccsid[] = "@(#)process.c 5.2 (Berkeley) %G%"; -#endif not lint +static char sccsid[] = "@(#)process.c 8.2 (Berkeley) 11/16/93"; +#endif /* not lint */ /* * process.c handles the requests, which can be of three types: @@ -16,98 +43,131 @@ static char sccsid[] = "@(#)process.c 5.2 (Berkeley) %G%"; * in the table for the local user * DELETE - delete invitation */ -#include "ctl.h" +#include #include +#include +#include +#include +#include +#include #include +#include +#include -char *strcpy(); CTL_MSG *find_request(); CTL_MSG *find_match(); -process_request(request, response) - CTL_MSG *request; - CTL_RESPONSE *response; +process_request(mp, rp) + register CTL_MSG *mp; + register CTL_RESPONSE *rp; { - CTL_MSG *ptr; - - response->type = request->type; - response->id_num = 0; - - switch (request->type) { + register CTL_MSG *ptr; + extern int debug; + + rp->vers = TALK_VERSION; + rp->type = mp->type; + rp->id_num = htonl(0); + if (mp->vers != TALK_VERSION) { + syslog(LOG_WARNING, "Bad protocol version %d", mp->vers); + rp->answer = BADVERSION; + return; + } + mp->id_num = ntohl(mp->id_num); + mp->addr.sa_family = ntohs(mp->addr.sa_family); + if (mp->addr.sa_family != AF_INET) { + syslog(LOG_WARNING, "Bad address, family %d", + mp->addr.sa_family); + rp->answer = BADADDR; + return; + } + mp->ctl_addr.sa_family = ntohs(mp->ctl_addr.sa_family); + if (mp->ctl_addr.sa_family != AF_INET) { + syslog(LOG_WARNING, "Bad control address, family %d", + mp->ctl_addr.sa_family); + rp->answer = BADCTLADDR; + return; + } + mp->pid = ntohl(mp->pid); + if (debug) + print_request("process_request", mp); + switch (mp->type) { - case ANNOUNCE : - do_announce(request, response); + case ANNOUNCE: + do_announce(mp, rp); break; - case LEAVE_INVITE : - ptr = find_request(request); - if (ptr != (CTL_MSG *) 0) { - response->id_num = ptr->id_num; - response->answer = SUCCESS; + case LEAVE_INVITE: + ptr = find_request(mp); + if (ptr != (CTL_MSG *)0) { + rp->id_num = htonl(ptr->id_num); + rp->answer = SUCCESS; } else - insert_table(request, response); + insert_table(mp, rp); break; - case LOOK_UP : - ptr = find_match(request); - if (ptr != (CTL_MSG *) 0) { - response->id_num = ptr->id_num; - response->addr = ptr->addr; - response->answer = SUCCESS; + case LOOK_UP: + ptr = find_match(mp); + if (ptr != (CTL_MSG *)0) { + rp->id_num = htonl(ptr->id_num); + rp->addr = ptr->addr; + rp->addr.sa_family = htons(ptr->addr.sa_family); + rp->answer = SUCCESS; } else - response->answer = NOT_HERE; + rp->answer = NOT_HERE; break; - case DELETE : - response->answer = delete_invite(request->id_num); + case DELETE: + rp->answer = delete_invite(mp->id_num); break; - default : - response->answer = UNKNOWN_REQUEST; + default: + rp->answer = UNKNOWN_REQUEST; break; } + if (debug) + print_response("process_request", rp); } -struct hostent *gethostbyaddr(); - -do_announce(request, response) - CTL_MSG *request; - CTL_RESPONSE *response; +do_announce(mp, rp) + register CTL_MSG *mp; + CTL_RESPONSE *rp; { struct hostent *hp; CTL_MSG *ptr; int result; /* see if the user is logged */ - result = find_user(request->r_name, request->r_tty); + result = find_user(mp->r_name, mp->r_tty); if (result != SUCCESS) { - response->answer = result; + rp->answer = result; return; } - hp = gethostbyaddr(&request->ctl_addr.sin_addr, - sizeof(struct in_addr), AF_INET); +#define satosin(sa) ((struct sockaddr_in *)(sa)) + hp = gethostbyaddr((char *)&satosin(&mp->ctl_addr)->sin_addr, + sizeof (struct in_addr), AF_INET); if (hp == (struct hostent *)0) { - response->answer = MACHINE_UNKNOWN; + rp->answer = MACHINE_UNKNOWN; return; } - ptr = find_request(request); + ptr = find_request(mp); if (ptr == (CTL_MSG *) 0) { - insert_table(request,response); - response->answer = announce(request, hp->h_name); + insert_table(mp, rp); + rp->answer = announce(mp, hp->h_name); return; } - if (request->id_num > ptr->id_num) { + if (mp->id_num > ptr->id_num) { /* - * this is an explicit re-announce, so update the id_num - * field to avoid duplicates and re-announce the talk + * This is an explicit re-announce, so update the id_num + * field to avoid duplicates and re-announce the talk. */ - ptr->id_num = response->id_num = new_id(); - response->answer = announce(request, hp->h_name); - return; + ptr->id_num = new_id(); + rp->id_num = htonl(ptr->id_num); + rp->answer = announce(mp, hp->h_name); + } else { + /* a duplicated request, so ignore it */ + rp->id_num = htonl(ptr->id_num); + rp->answer = SUCCESS; } - /* a duplicated request, so ignore it */ - response->id_num = ptr->id_num; - response->answer = SUCCESS; } #include @@ -116,37 +176,40 @@ do_announce(request, response) * Search utmp for the local user */ find_user(name, tty) - char *name; - char *tty; + char *name, *tty; { struct utmp ubuf; int status; FILE *fd; struct stat statb; - char ftty[20]; + char line[sizeof(ubuf.ut_line) + 1]; + char ftty[sizeof(_PATH_DEV) - 1 + sizeof(line)]; - if ((fd = fopen("/etc/utmp", "r")) == NULL) { - perror("Can't open /etc/utmp"); + if ((fd = fopen(_PATH_UTMP, "r")) == NULL) { + fprintf(stderr, "talkd: can't read %s.\n", _PATH_UTMP); return (FAILED); } #define SCMPN(a, b) strncmp(a, b, sizeof (a)) status = NOT_HERE; - (void) strcpy(ftty, "/dev/"); + (void) strcpy(ftty, _PATH_DEV); while (fread((char *) &ubuf, sizeof ubuf, 1, fd) == 1) if (SCMPN(ubuf.ut_name, name) == 0) { + strncpy(line, ubuf.ut_line, sizeof(ubuf.ut_line)); + line[sizeof(ubuf.ut_line)] = '\0'; if (*tty == '\0') { status = PERMISSION_DENIED; /* no particular tty was requested */ - (void) strcpy(ftty+5, ubuf.ut_line); - if (stat(ftty,&statb) == 0) { - if (!(statb.st_mode & 02)) + (void) strcpy(ftty + sizeof(_PATH_DEV) - 1, + line); + if (stat(ftty, &statb) == 0) { + if (!(statb.st_mode & 020)) continue; - (void) strcpy(tty, ubuf.ut_line); + (void) strcpy(tty, line); status = SUCCESS; break; } } - if (strcmp(ubuf.ut_line, tty) == 0) { + if (strcmp(line, tty) == 0) { status = SUCCESS; break; }