112 |
|
const char *modname[MAXMODLIST]; /* ordered modifier name list */ |
113 |
|
int nmods = 0; /* number of modifiers */ |
114 |
|
|
115 |
+ |
#define queue_length() (lastray - lastdone) |
116 |
+ |
|
117 |
|
MODCONT *addmodifier(char *modn, char *outf, char *binv); |
118 |
|
void addmodfile(char *fname, char *outf, char *binv); |
119 |
|
|
130 |
|
void add_contrib(const char *modn); |
131 |
|
void done_contrib(void); |
132 |
|
|
133 |
+ |
/* return number of open rtrace processes */ |
134 |
+ |
static int |
135 |
+ |
nrtprocs(void) |
136 |
+ |
{ |
137 |
+ |
int nrtp = 0; |
138 |
+ |
struct rtproc *rtp; |
139 |
+ |
|
140 |
+ |
for (rtp = &rt0; rtp != NULL; rtp = rtp->next) |
141 |
+ |
nrtp += rtp->pd.running; |
142 |
+ |
return(nrtp); |
143 |
+ |
} |
144 |
+ |
|
145 |
|
/* set input/output format */ |
146 |
|
static void |
147 |
|
setformat(const char *fmt) |
970 |
|
struct rtproc *rtp; |
971 |
|
/* loop over input */ |
972 |
|
while ((iblen = getinp(inpbuf, fin)) > 0) { |
973 |
< |
if (lastray+1 < lastray) { /* counter rollover? */ |
973 |
> |
if (lastray+1 < lastray || /* need reset? */ |
974 |
> |
queue_length() > 5*nrtprocs()) { |
975 |
|
while (wait_rproc() != NULL) |
976 |
|
process_queue(); |
977 |
|
lastdone = lastray = 0; |