/* file_c.c -- File cache management */ #include "autoconf.h" #include "copyright.h" #ifndef lint static char RCSid[] = "$Id: file_c.c,v 1.7 1995/03/21 00:00:15 ambar Exp $"; USE(RCSid); #endif #include "config.h" #include "interface.h" #include "mudconf.h" #include "command.h" #include "file_c.h" #include "alloc.h" typedef struct filecache_hdr FCACHE; typedef struct filecache_block_hdr FBLKHDR; typedef struct filecache_block FBLOCK; struct filecache_hdr { char *filename; FBLOCK *fileblock; const char *desc; }; struct filecache_block { struct filecache_block_hdr { struct filecache_block *nxt; int nchars; } hdr; char data[MBUF_SIZE - sizeof(FBLKHDR)]; }; #define FBLOCK_SIZE (MBUF_SIZE - sizeof(FBLKHDR)) FCACHE fcache[] = { {mudconf.conn_file, NULL, "Conn"}, {mudconf.site_file, NULL, "Conn/Badsite"}, {mudconf.down_file, NULL, "Conn/Down"}, {mudconf.full_file, NULL, "Conn/Full"}, {mudconf.guest_file, NULL, "Conn/Guest"}, {mudconf.creg_file, NULL, "Conn/Reg"}, {mudconf.crea_file, NULL, "Crea/Newuser"}, {mudconf.regf_file, NULL, "Crea/RegFaill"}, {mudconf.motd_file, NULL, "Motd"}, {mudconf.wizmotd_file, NULL, "Wizmotd"}, {mudconf.quit_file, NULL, "Quit"}, #ifdef PUEBLO_SUPPORT {mudconf.htmlconn_file, NULL, "Conn/Html"}, #endif /* PUEBLO_SUPPORT */ {NULL, NULL, NULL}}; NAMETAB list_files[] = { {(char *) "badsite_connect", 1, CA_WIZARD, FC_CONN_SITE}, {(char *) "connect", 2, CA_WIZARD, FC_CONN}, {(char *) "create_register", 2, CA_WIZARD, FC_CREA_REG}, {(char *) "down", 1, CA_WIZARD, FC_CONN_DOWN}, {(char *) "full", 1, CA_WIZARD, FC_CONN_FULL}, {(char *) "guest_motd", 1, CA_WIZARD, FC_CONN_GUEST}, #ifdef PUEBLO_SUPPORT {(char *) "html_connect", 1, CA_WIZARD, FC_CONN_HTML}, #endif /* PUEBLO_SUPPORT */ {(char *) "motd", 1, CA_WIZARD, FC_MOTD}, {(char *) "newuser", 1, CA_WIZARD, FC_CREA_NEW}, {(char *) "quit", 1, CA_WIZARD, FC_QUIT}, {(char *) "register_connect", 1, CA_WIZARD, FC_CONN_REG}, {(char *) "wizard_motd", 1, CA_WIZARD, FC_WIZMOTD}, {NULL, 0, 0, 0}}; void do_list_file(player, cause, extra, arg) dbref player, cause; int extra; char *arg; { int flagvalue; flagvalue = search_nametab(player, list_files, arg); if (flagvalue < 0) { display_nametab(player, list_files, (char *) "Unknown file. Use one of:", 1); return; } fcache_send(player, flagvalue); } static FBLOCK * fcache_fill(fp, ch) FBLOCK *fp; char ch; { FBLOCK *tfp; if (fp->hdr.nchars >= (MBUF_SIZE - sizeof(FBLKHDR))) { /* We filled the current buffer. Go get a new one. */ tfp = fp; fp = (FBLOCK *) alloc_mbuf("fcache_fill"); fp->hdr.nxt = NULL; fp->hdr.nchars = 0; tfp->hdr.nxt = fp; } fp->data[fp->hdr.nchars++] = ch; return fp; } static int fcache_read(cp, filename) FBLOCK **cp; char *filename; { int n, nmax, tchars, fd; char *buff; FBLOCK *fp, *tfp; /* Free a prior buffer chain */ fp = *cp; while (fp != NULL) { tfp = fp->hdr.nxt; free_mbuf(fp); fp = tfp; } *cp = NULL; /* Read the text file into a new chain */ if ((fd = tf_open(filename, O_RDONLY)) == -1) { /* Failure: log the event */ STARTLOG(LOG_PROBLEMS, "FIL", "OPEN") buff = alloc_mbuf("fcache_read.LOG"); sprintf(buff, "Couldn't open file '%s'.", filename); log_text(buff); free_mbuf(buff); ENDLOG tf_close(fd); return -1; } buff = alloc_lbuf("fcache_read.temp"); /* Set up the initial cache buffer to make things easier */ fp = (FBLOCK *) alloc_mbuf("fcache_read.first"); fp->hdr.nxt = NULL; fp->hdr.nchars = 0; *cp = fp; tchars = 0; /* Process the file, one lbuf at a time */ nmax = read(fd, buff, LBUF_SIZE); while (nmax > 0) { for (n = 0; n < nmax; n++) { switch (buff[n]) { case '\n': fp = fcache_fill(fp, '\r'); fp = fcache_fill(fp, '\n'); tchars += 2; case '\0': case '\r': break; default: fp = fcache_fill(fp, buff[n]); tchars++; } } nmax = read(fd, buff, LBUF_SIZE); } free_lbuf(buff); tf_close(fd); /* If we didn't read anything in, toss the initial buffer */ if (fp->hdr.nchars == 0) { *cp = NULL; free_mbuf(fp); } return tchars; } void fcache_rawdump(fd, num) int fd, num; { int cnt, remaining; char *start; FBLOCK *fp; if ((num < 0) || (num > FC_LAST)) return; fp = fcache[num].fileblock; while (fp != NULL) { start = fp->data; remaining = fp->hdr.nchars; while (remaining > 0) { cnt = WRITE(fd, start, remaining); if (cnt < 0) return; remaining -= cnt; start += cnt; } fp = fp->hdr.nxt; } return; } void fcache_dump(d, num) DESC *d; int num; { FBLOCK *fp; if ((num < 0) || (num > FC_LAST)) return; fp = fcache[num].fileblock; while (fp != NULL) { queue_write(d, fp->data, fp->hdr.nchars); fp = fp->hdr.nxt; } } void fcache_send(player, num) dbref player; int num; { DESC *d; DESC_ITER_PLAYER(player, d) { fcache_dump(d, num); } } void fcache_load(player) dbref player; { FCACHE *fp; char *buff, *bufc, *sbuf; int i; buff = bufc = alloc_lbuf("fcache_load.lbuf"); sbuf = alloc_sbuf("fcache_load.sbuf"); for (fp = fcache; fp->filename; fp++) { i = fcache_read(&fp->fileblock, fp->filename); if ((player != NOTHING) && !Quiet(player)) { ltos(sbuf, i); if (fp == fcache) safe_str((char *) "File sizes: ", buff, &bufc); else safe_str((char *) " ", buff, &bufc); safe_str((char *) fp->desc, buff, &bufc); safe_str((char *) "...", buff, &bufc); safe_str(sbuf, buff, &bufc); } } *bufc = '\0'; if ((player != NOTHING) && !Quiet(player)) { notify(player, buff); } free_lbuf(buff); free_sbuf(sbuf); } void NDECL(fcache_init) { FCACHE *fp; for (fp = fcache; fp->filename; fp++) { fp->fileblock = NULL; } fcache_load(NOTHING); }