![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to serve.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDTahoe / new / nntp / server|
Return to serve.c CVS log | Up to [CSRG BSD Unix] / 43BSDTahoe / new / nntp / server |
1.1 ! root 1: #ifndef lint ! 2: static char *sccsid = "@(#)serve.c 1.24 (Berkeley) 10/15/87"; ! 3: #endif ! 4: ! 5: /* ! 6: * Main server routine ! 7: */ ! 8: ! 9: #include "common.h" ! 10: #include <signal.h> ! 11: #include <sys/time.h> ! 12: ! 13: #ifdef LOG ! 14: #include <sys/resource.h> ! 15: #endif ! 16: ! 17: extern int ahbs(), group(), help(), ihave(); ! 18: extern int list(), newgroups(), newnews(), nextlast(), post(); ! 19: extern int slave(), stat(), xhdr(); ! 20: ! 21: static struct cmdent { ! 22: char *cmd_name; ! 23: int (*cmd_fctn)(); ! 24: } cmdtbl[] = { ! 25: "article", ahbs, ! 26: "body", ahbs, ! 27: "group", group, ! 28: "head", ahbs, ! 29: "help", help, ! 30: "ihave", ihave, ! 31: "last", nextlast, ! 32: "list", list, ! 33: "newgroups", newgroups, ! 34: "newnews", newnews, ! 35: "next", nextlast, ! 36: "post", post, ! 37: "slave", slave, ! 38: "stat", ahbs, ! 39: #ifdef XHDR ! 40: "xhdr", xhdr, ! 41: #endif XHDR ! 42: }; ! 43: #define NUMCMDS (sizeof(cmdtbl) / sizeof(struct cmdent)) ! 44: ! 45: ! 46: /* ! 47: * serve -- given a connection on stdin/stdout, serve ! 48: * a client, executing commands until the client ! 49: * says goodbye. ! 50: * ! 51: * Parameters: None. ! 52: * ! 53: * Returns: Exits. ! 54: * ! 55: * Side effects: Talks to client, does a lot of ! 56: * stuff. ! 57: */ ! 58: ! 59: serve() ! 60: { ! 61: char line[MAX_STRLEN]; ! 62: char host[MAX_STRLEN]; ! 63: char gdbuf[MAX_STRLEN]; ! 64: char **argp; ! 65: char *timeptr, *cp; ! 66: int argnum, i; ! 67: struct timeval clock, now; ! 68: extern char *ctime(); ! 69: #ifdef POSTER ! 70: struct passwd *pp; ! 71: #endif ! 72: #ifdef TIMEOUT ! 73: void timeout(); ! 74: #endif ! 75: #ifdef LOG ! 76: struct rusage me, children; ! 77: ! 78: grps_acsd = arts_acsd = 0; ! 79: #endif ! 80: ! 81: /* Not all systems pass fd's 1 and 2 from inetd ... */ ! 82: ! 83: (void) close(1); ! 84: (void) close(2); ! 85: (void) dup(0); ! 86: (void) dup(0); ! 87: ! 88: /* If we're ALONE, then we've already opened syslog */ ! 89: ! 90: #ifndef ALONE ! 91: # ifdef SYSLOG ! 92: # ifdef BSD_42 ! 93: openlog("nntpd", LOG_PID); ! 94: # else ! 95: openlog("nntpd", LOG_PID, SYSLOG); ! 96: # endif ! 97: # endif ! 98: #endif ! 99: ! 100: #ifdef ALONE ! 101: (void) signal(SIGCHLD, SIG_IGN); ! 102: #endif ! 103: ! 104: /* Ignore SIGPIPE, since we'll see closed connections with read */ ! 105: ! 106: (void) signal(SIGPIPE, SIG_IGN); ! 107: ! 108: /* Get permissions and see if we can talk to this client */ ! 109: ! 110: host_access(&canread, &canpost, &canxfer, gdbuf); ! 111: ! 112: if (gethostname(host, sizeof(host)) < 0) ! 113: (void) strcpy(host, "Amnesiac"); ! 114: ! 115: if (!canread && !canxfer) { ! 116: printf("%d %s NNTP server can't talk to you. Goodbye.\r\n", ! 117: ERR_ACCESS, host); ! 118: (void) fflush(stdout); ! 119: #ifdef LOG ! 120: syslog(LOG_INFO, "%s refused connection", hostname); ! 121: #endif ! 122: exit(1); ! 123: } ! 124: ! 125: /* If we can talk, proceed with initialization */ ! 126: ! 127: ngpermcount = get_nglist(&ngpermlist, gdbuf); ! 128: ! 129: #ifdef POSTER ! 130: pp = getpwnam(POSTER); ! 131: if (pp != NULL) { ! 132: uid_poster = pp->pw_uid; ! 133: gid_poster = pp->pw_gid; ! 134: } else ! 135: #endif ! 136: uid_poster = gid_poster = 0; ! 137: ! 138: #ifndef FASTFORK ! 139: num_groups = 0; ! 140: num_groups = read_groups(); /* Read in the active file */ ! 141: #else ! 142: signal(SIGALRM, SIG_IGN); /* Children don't deal with */ ! 143: /* these things */ ! 144: #endif ! 145: ! 146: art_fp = NULL; ! 147: argp = (char **) NULL; /* for first time */ ! 148: ! 149: (void) gettimeofday(&clock, (struct timezone *)NULL); ! 150: timeptr = ctime(&clock.tv_sec); ! 151: if ((cp = index(timeptr, '\n')) != NULL) ! 152: *cp = '\0'; ! 153: else ! 154: timeptr = "Unknown date"; ! 155: ! 156: printf("%d %s NNTP server version %s ready at %s (%s).\r\n", ! 157: canpost ? OK_CANPOST : OK_NOPOST, ! 158: host, nntp_version, ! 159: timeptr, ! 160: canpost ? "posting ok" : "no posting"); ! 161: (void) fflush(stdout); ! 162: ! 163: /* ! 164: * Now get commands one at a time and execute the ! 165: * appropriate routine to deal with them. ! 166: */ ! 167: ! 168: #ifdef TIMEOUT ! 169: (void) signal(SIGALRM, timeout); ! 170: (void) alarm(TIMEOUT); ! 171: #endif TIMEOUT ! 172: ! 173: while (fgets(line, sizeof(line), stdin) != NULL) { ! 174: #ifdef TIMEOUT ! 175: (void) alarm(0); ! 176: #endif TIMEOUT ! 177: ! 178: cp = index(line, '\r'); /* Zap CR-LF */ ! 179: if (cp != NULL) ! 180: *cp = '\0'; ! 181: else { ! 182: cp = index(line, '\n'); ! 183: if (cp != NULL) ! 184: *cp = '\0'; ! 185: } ! 186: ! 187: if ((argnum = parsit(line, &argp)) == 0) ! 188: continue; /* Null command */ ! 189: else { ! 190: for (i = 0; i < NUMCMDS; ++i) ! 191: if (streql(cmdtbl[i].cmd_name, argp[0])) ! 192: break; ! 193: if (i < NUMCMDS) ! 194: (*cmdtbl[i].cmd_fctn)(argnum, argp); ! 195: else { ! 196: if (streql(argp[0], "quit")) ! 197: break; ! 198: #ifdef LOG ! 199: syslog(LOG_INFO, "%s unrecognized %s", ! 200: hostname, ! 201: line); ! 202: #endif ! 203: printf("%d Command unrecognized.\r\n", ! 204: ERR_COMMAND); ! 205: (void) fflush(stdout); ! 206: } ! 207: } ! 208: #ifdef TIMEOUT ! 209: (void) alarm(TIMEOUT); ! 210: #endif TIMEOUT ! 211: } ! 212: ! 213: printf("%d %s closing connection. Goodbye.\r\n", OK_GOODBYE, host); ! 214: (void) fflush(stdout); ! 215: ! 216: ! 217: #ifdef LOG ! 218: if (ferror(stdout)) ! 219: syslog(LOG_ERR, "%s disconnect: %m", hostname); ! 220: ! 221: if (getrusage(RUSAGE_SELF, &me) < 0) { ! 222: syslog(LOG_ERR, "getrusage RUSAGE_SELF: %m"); ! 223: if (grps_acsd) ! 224: syslog(LOG_INFO, "%s exit %d articles %d groups", ! 225: hostname, arts_acsd, grps_acsd); ! 226: exit(1); ! 227: } ! 228: if (getrusage(RUSAGE_CHILDREN, &children) < 0) { ! 229: syslog(LOG_ERR, "getrusage RUSAGE_CHILDREN: %m"); ! 230: if (grps_acsd) ! 231: syslog(LOG_INFO, "%s exit %d articles %d groups", ! 232: hostname, arts_acsd, grps_acsd); ! 233: exit(1); ! 234: } ! 235: if (grps_acsd) ! 236: syslog(LOG_INFO, "%s exit %d articles %d groups", ! 237: hostname, arts_acsd, grps_acsd); ! 238: if (nn_told) ! 239: syslog(LOG_INFO, "%s newnews_stats told %d took %d", ! 240: hostname, nn_told, nn_took); ! 241: if (ih_accepted || ih_rejected || ih_failed) ! 242: syslog(LOG_INFO, ! 243: "%s ihave_stats accepted %d rejected %d failed %d", ! 244: hostname, ! 245: ih_accepted, ! 246: ih_rejected, ! 247: ih_failed); ! 248: (void) gettimeofday(&now, (struct timezone *)NULL); ! 249: (void) sprintf(line, "user %.1f system %.1f elapsed %.1f", ! 250: (float) me.ru_utime.tv_sec + ! 251: (float) me.ru_utime.tv_usec/1000000.0 + ! 252: (float) children.ru_utime.tv_sec + ! 253: (float) children.ru_utime.tv_usec/1000000.0, ! 254: (float) me.ru_stime.tv_sec + ! 255: (float) me.ru_stime.tv_usec/1000000.0 + ! 256: (float) children.ru_stime.tv_sec + ! 257: (float) children.ru_stime.tv_usec/1000000.0, ! 258: (float) (now.tv_sec - clock.tv_sec) + ! 259: (float) now.tv_usec/1000000.0 - ! 260: (float) clock.tv_usec/1000000.0); ! 261: ! 262: syslog(LOG_INFO, "%s times %s", hostname, line); ! 263: #endif ! 264: ! 265: #ifdef PROFILE ! 266: profile(); ! 267: #endif ! 268: ! 269: exit(0); ! 270: } ! 271: ! 272: ! 273: #ifdef TIMEOUT ! 274: /* ! 275: * No activity for TIMEOUT seconds, so print an error message ! 276: * and close the connection. ! 277: */ ! 278: ! 279: void ! 280: timeout() ! 281: { ! 282: printf("%d Timeout after %d seconds, closing connection.\r\n", ! 283: ERR_FAULT, TIMEOUT); ! 284: (void) fflush(stdout); ! 285: ! 286: #ifdef LOG ! 287: syslog(LOG_ERR, "%s timeout", hostname); ! 288: #endif LOG ! 289: ! 290: exit(1); ! 291: } ! 292: #endif TIMEOUT
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.