![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to process.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSD / etc / talkd|
Return to process.c CVS log | Up to [CSRG BSD Unix] / 43BSD / etc / talkd |
1.1 ! root 1: /* ! 2: * Copyright (c) 1983 Regents of the University of California. ! 3: * All rights reserved. The Berkeley software License Agreement ! 4: * specifies the terms and conditions for redistribution. ! 5: */ ! 6: ! 7: #ifndef lint ! 8: static char sccsid[] = "@(#)process.c 5.4 (Berkeley) 3/13/86"; ! 9: #endif not lint ! 10: ! 11: /* ! 12: * process.c handles the requests, which can be of three types: ! 13: * ANNOUNCE - announce to a user that a talk is wanted ! 14: * LEAVE_INVITE - insert the request into the table ! 15: * LOOK_UP - look up to see if a request is waiting in ! 16: * in the table for the local user ! 17: * DELETE - delete invitation ! 18: */ ! 19: #include <sys/types.h> ! 20: #include <sys/stat.h> ! 21: #include <stdio.h> ! 22: #include <syslog.h> ! 23: #include <netdb.h> ! 24: #include <netinet/in.h> ! 25: ! 26: #include <protocols/talkd.h> ! 27: ! 28: char *strcpy(); ! 29: CTL_MSG *find_request(); ! 30: CTL_MSG *find_match(); ! 31: ! 32: process_request(mp, rp) ! 33: register CTL_MSG *mp; ! 34: register CTL_RESPONSE *rp; ! 35: { ! 36: register CTL_MSG *ptr; ! 37: extern int debug; ! 38: ! 39: rp->vers = TALK_VERSION; ! 40: rp->type = mp->type; ! 41: rp->id_num = htonl(0); ! 42: if (mp->vers != TALK_VERSION) { ! 43: syslog(LOG_WARNING, "Bad protocol version %d", mp->vers); ! 44: rp->answer = BADVERSION; ! 45: return; ! 46: } ! 47: mp->id_num = ntohl(mp->id_num); ! 48: mp->addr.sa_family = ntohs(mp->addr.sa_family); ! 49: if (mp->addr.sa_family != AF_INET) { ! 50: syslog(LOG_WARNING, "Bad address, family %d", ! 51: mp->addr.sa_family); ! 52: rp->answer = BADADDR; ! 53: return; ! 54: } ! 55: mp->ctl_addr.sa_family = ntohs(mp->ctl_addr.sa_family); ! 56: if (mp->ctl_addr.sa_family != AF_INET) { ! 57: syslog(LOG_WARNING, "Bad control address, family %d", ! 58: mp->ctl_addr.sa_family); ! 59: rp->answer = BADCTLADDR; ! 60: return; ! 61: } ! 62: mp->pid = ntohl(mp->pid); ! 63: if (debug) ! 64: print_request("process_request", mp); ! 65: switch (mp->type) { ! 66: ! 67: case ANNOUNCE: ! 68: do_announce(mp, rp); ! 69: break; ! 70: ! 71: case LEAVE_INVITE: ! 72: ptr = find_request(mp); ! 73: if (ptr != (CTL_MSG *)0) { ! 74: rp->id_num = htonl(ptr->id_num); ! 75: rp->answer = SUCCESS; ! 76: } else ! 77: insert_table(mp, rp); ! 78: break; ! 79: ! 80: case LOOK_UP: ! 81: ptr = find_match(mp); ! 82: if (ptr != (CTL_MSG *)0) { ! 83: rp->id_num = htonl(ptr->id_num); ! 84: rp->addr = ptr->addr; ! 85: rp->addr.sa_family = htons(ptr->addr.sa_family); ! 86: rp->answer = SUCCESS; ! 87: } else ! 88: rp->answer = NOT_HERE; ! 89: break; ! 90: ! 91: case DELETE: ! 92: rp->answer = delete_invite(mp->id_num); ! 93: break; ! 94: ! 95: default: ! 96: rp->answer = UNKNOWN_REQUEST; ! 97: break; ! 98: } ! 99: if (debug) ! 100: print_response("process_request", rp); ! 101: } ! 102: ! 103: do_announce(mp, rp) ! 104: register CTL_MSG *mp; ! 105: CTL_RESPONSE *rp; ! 106: { ! 107: struct hostent *hp; ! 108: CTL_MSG *ptr; ! 109: int result; ! 110: ! 111: /* see if the user is logged */ ! 112: result = find_user(mp->r_name, mp->r_tty); ! 113: if (result != SUCCESS) { ! 114: rp->answer = result; ! 115: return; ! 116: } ! 117: #define satosin(sa) ((struct sockaddr_in *)(sa)) ! 118: hp = gethostbyaddr(&satosin(&mp->ctl_addr)->sin_addr, ! 119: sizeof (struct in_addr), AF_INET); ! 120: if (hp == (struct hostent *)0) { ! 121: rp->answer = MACHINE_UNKNOWN; ! 122: return; ! 123: } ! 124: ptr = find_request(mp); ! 125: if (ptr == (CTL_MSG *) 0) { ! 126: insert_table(mp, rp); ! 127: rp->answer = announce(mp, hp->h_name); ! 128: return; ! 129: } ! 130: if (mp->id_num > ptr->id_num) { ! 131: /* ! 132: * This is an explicit re-announce, so update the id_num ! 133: * field to avoid duplicates and re-announce the talk. ! 134: */ ! 135: ptr->id_num = new_id(); ! 136: rp->id_num = htonl(ptr->id_num); ! 137: rp->answer = announce(mp, hp->h_name); ! 138: } else { ! 139: /* a duplicated request, so ignore it */ ! 140: rp->id_num = htonl(ptr->id_num); ! 141: rp->answer = SUCCESS; ! 142: } ! 143: } ! 144: ! 145: #include <utmp.h> ! 146: ! 147: /* ! 148: * Search utmp for the local user ! 149: */ ! 150: find_user(name, tty) ! 151: char *name, *tty; ! 152: { ! 153: struct utmp ubuf; ! 154: int status; ! 155: FILE *fd; ! 156: struct stat statb; ! 157: char ftty[20]; ! 158: ! 159: if ((fd = fopen("/etc/utmp", "r")) == NULL) { ! 160: perror("Can't open /etc/utmp"); ! 161: return (FAILED); ! 162: } ! 163: #define SCMPN(a, b) strncmp(a, b, sizeof (a)) ! 164: status = NOT_HERE; ! 165: (void) strcpy(ftty, "/dev/"); ! 166: while (fread((char *) &ubuf, sizeof ubuf, 1, fd) == 1) ! 167: if (SCMPN(ubuf.ut_name, name) == 0) { ! 168: if (*tty == '\0') { ! 169: status = PERMISSION_DENIED; ! 170: /* no particular tty was requested */ ! 171: (void) strcpy(ftty+5, ubuf.ut_line); ! 172: if (stat(ftty,&statb) == 0) { ! 173: if (!(statb.st_mode & 020)) ! 174: continue; ! 175: (void) strcpy(tty, ubuf.ut_line); ! 176: status = SUCCESS; ! 177: break; ! 178: } ! 179: } ! 180: if (strcmp(ubuf.ut_line, tty) == 0) { ! 181: status = SUCCESS; ! 182: break; ! 183: } ! 184: } ! 185: fclose(fd); ! 186: return (status); ! 187: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.