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; |