| 24 |
|
extern const char BIGEND[]; |
| 25 |
|
extern const char FMTSTR[]; |
| 26 |
|
|
| 27 |
< |
extern int contrib; /* computing contributions? */ |
| 28 |
< |
extern int lim_dist; /* limit distance? */ |
| 27 |
> |
int contrib = 0; // computing contributions? |
| 28 |
|
|
| 29 |
+ |
int xres = 0; // horizontal (scan) size |
| 30 |
+ |
int yres = 0; // vertical resolution |
| 31 |
+ |
|
| 32 |
|
// new/exclusive, overwrite if exists, or recover data |
| 33 |
|
int RSDOflags[] = {RDSwrite|RDSexcl|RDSextend, RDSwrite|RDSextend, |
| 34 |
|
RDSread|RDSwrite}; |
| 51 |
|
} |
| 52 |
|
}; |
| 53 |
|
|
| 54 |
< |
// used to assign record calc to child |
| 54 |
> |
// Struct used to assign record calculation to child |
| 55 |
|
struct RowAssignment { |
| 56 |
|
uint32 row; // row to do |
| 57 |
|
uint32 ac; // accumulation count |
| 289 |
|
return true; |
| 290 |
|
} |
| 291 |
|
|
| 290 |
– |
// Run through current list of output struct's |
| 291 |
– |
int |
| 292 |
– |
RcontribSimulManager::GetOutputs(RoutputShareF *osF, void *cd) const |
| 293 |
– |
{ |
| 294 |
– |
int cnt = 0; |
| 295 |
– |
|
| 296 |
– |
for (const RcontribOutput *op = outList; op; op = op->next) { |
| 297 |
– |
int rv = 1; |
| 298 |
– |
if (osF && (rv = (*osF)(op, cd)) < 0) |
| 299 |
– |
return rv; |
| 300 |
– |
cnt += rv; |
| 301 |
– |
} |
| 302 |
– |
return cnt; |
| 303 |
– |
} |
| 304 |
– |
|
| 292 |
|
// Prepare output channels and return # completed rows |
| 293 |
|
int |
| 294 |
|
RcontribSimulManager::PrepOutput() |
| 328 |
|
!op->rData->Resize(op->begData + op->nRows*op->rowBytes)) |
| 329 |
|
return -1; // calls error() for us |
| 330 |
|
} |
| 344 |
– |
if (lim_dist) // XXX where else to put this? |
| 345 |
– |
rtFlags |= RTlimDist; |
| 346 |
– |
else |
| 347 |
– |
rtFlags &= ~RTlimDist; |
| 348 |
– |
|
| 331 |
|
rowsDone.NewBitMap(outList->nRows); // create row completion map |
| 332 |
|
rowsDone.ClearBits(0, rInPos, true); |
| 333 |
|
return rInPos; |
| 443 |
|
return -1; |
| 444 |
|
} |
| 445 |
|
// check format |
| 446 |
< |
if (!(cp = findArgs(hdr, FMTSTR, begData)) || strcmp(cp, formstr(etyp))) { |
| 446 |
> |
if (!(cp = findArgs(hdr, FMTSTR, begData)) || |
| 447 |
> |
strncmp(cp, formstr(etyp), strlen(formstr(etyp)))) { |
| 448 |
|
sprintf(errmsg, "expected %s%s in '%s'", FMTSTR, formstr(etyp), GetName()); |
| 449 |
|
error(USER, errmsg); |
| 450 |
|
return -1; |
| 633 |
|
FD_ISSET(kid[n].w, &writeset) | |
| 634 |
|
FD_ISSET(kid[n].w, &errset)) { |
| 635 |
|
// update output row counts |
| 636 |
< |
UpdateRowsDone(kidRow[n]); |
| 636 |
> |
if (!FD_ISSET(kid[n].w, &errset)) |
| 637 |
> |
UpdateRowsDone(kidRow[n]); |
| 638 |
|
kidRow[n] = -1; // flag it available |
| 639 |
|
pn = n; |
| 640 |
|
} |
| 718 |
|
close(kid[nkids].w); |
| 719 |
|
free(kid); free(kidRow); |
| 720 |
|
kid = NULL; kidRow = NULL; |
| 737 |
– |
rowsDone.NewBitMap(0); |
| 721 |
|
RunChild(); // should never return |
| 722 |
|
_exit(1); |
| 723 |
|
} |