--- ray/src/hd/rholo.c 1997/11/03 18:33:12 3.4 +++ ray/src/hd/rholo.c 1997/11/11 11:31:54 3.9 @@ -33,6 +33,8 @@ time_t starttime; /* time we got started */ time_t endtime; /* time we should end by */ time_t reporttime; /* time for next report */ +long maxdisk; /* maximum file space (bytes) */ + int rtargc = 1; /* rtrace command */ char *rtargv[128] = {"rtrace", NULL}; @@ -132,13 +134,21 @@ initrholo() /* get our holodeck running */ disp_open(outdev); else if (ncprocs > 0) /* else use global ray feed */ init_global(); + /* record disk space limit */ + if (!vdef(DISKSPACE)) + maxdisk = 0; + else + maxdisk = 1024.*1024.*vflt(DISKSPACE); /* record end time */ if (!vdef(TIME) || vflt(TIME) <= FTINY) endtime = 0; else endtime = starttime + vflt(TIME)*3600.; /* set up memory cache */ - hdcachesize = 1024.*1024.*vflt(CACHE); + if (outdev == NULL) + hdcachesize = 0; /* manual flushing */ + else if (vdef(CACHE)) + hdcachesize = 1024.*1024.*vflt(CACHE); /* open report file */ if (vdef(REPORT)) { register char *s = sskip2(vval(REPORT), 1); @@ -195,14 +205,17 @@ rholo() /* holodeck main loop */ if (ncprocs <= 0) return(1); /* check file size */ - if ((l = 1024.*1024.*vflt(DISKSPACE)) > 0 && - hdfiluse(hdlist[0]->fd, 0) + hdmemuse(0) >= l) + if (maxdisk > 0 && hdfilen(hdlist[0]->fd) >= maxdisk) { + error(WARNING, "file limit exceeded"); return(0); + } /* check time */ if (endtime > 0 || reporttime > 0) t = time(NULL); - if (endtime > 0 && t >= endtime) + if (endtime > 0 && t >= endtime) { + error(WARNING, "time limit exceeded"); return(0); + } if (reporttime > 0 && t >= reporttime) report(t); /* get packets to process */ @@ -287,22 +300,6 @@ register HDGRID *gp; sprintf(vval(OCTREE), "%s.oct", froot); vdef(OCTREE)++; } - if (!vdef(DISKSPACE)) { - sprintf(errmsg, - "no %s setting, assuming 100 Mbytes available", - vnam(DISKSPACE)); - error(WARNING, errmsg); - vval(DISKSPACE) = "100"; - vdef(DISKSPACE)++; - } - if (!vdef(CACHE)) { - sprintf(errmsg, - "no %s setting, assuming 10 Mbytes available", - vnam(CACHE)); - error(WARNING, errmsg); - vval(CACHE) = "10"; - vdef(CACHE)++; - } if (!vdef(OBSTRUCTIONS)) { vval(OBSTRUCTIONS) = "T"; vdef(OBSTRUCTIONS)++; @@ -394,6 +391,7 @@ loadholo() /* start loading a holodeck from fname */ done_packets(pl) /* handle finished packets */ PACKET *pl; { + static int nunflushed = 0; register PACKET *p; while (pl != NULL) { @@ -403,21 +401,27 @@ PACKET *pl; (char *)hdnewrays(hdlist[p->hd],p->bi,p->nr), p->nr*sizeof(RAYVAL)); if (outdev != NULL) /* display it */ - disp_packet(p); + disp_packet((PACKHEAD *)p); + else + nunflushed += p->nr; + nraysdone += p->nr; + npacksdone++; } - nraysdone += p->nr; - npacksdone++; p->nr = 0; /* push onto free list */ p->next = freepacks; freepacks = p; } + if (nunflushed >= 256*RPACKSIZ) { + hdflush(NULL); /* flush holodeck buffers */ + nunflushed = 0; + } } getradfile(rfargs) /* run rad and get needed variables */ char *rfargs; { - static short mvar[] = {VIEW,OCTREE,EXPOSURE,-1}; + static short mvar[] = {OCTREE,EXPOSURE,-1}; static char tf1[] = TEMPLATE; char tf2[64]; char combuf[256]; @@ -526,7 +530,7 @@ int ec; if (vdef(REPORT)) { long fsiz, fuse; report(0); - fsiz = lseek(hdlist[0]->fd, 0L, 2); + fsiz = hdfilen(hdlist[0]->fd); fuse = hdfiluse(hdlist[0]->fd, 1); fprintf(stderr, "%s: %.1f Mbyte holodeck file, %.1f%% fragmentation\n",