
DIRECTORY
FS,
IO,
CensusFileReader,
RefText,
Rope;

CensusFileReaderImpl: CEDAR PROGRAM IMPORTS FS, IO, RefText, Rope EXPORTS CensusFileReader  =

BEGIN OPEN CensusFileReader;


IntOutOfBuffer: PROC [b: REF TEXT, start: NAT ¬ 0, len: NAT ¬ NAT.LAST] RETURNS [i: INT ¬ 0] ~ {
anyThingFound: BOOL ¬ FALSE;
sign: INT ¬ 1;
FOR p: NAT IN [start..start+len) DO
c: CHAR ¬ RefText.Fetch[b, p];
ci: INT ¬ ORD[c] - ORD['0];
IF (ci >= 0) AND (ci <= 9) THEN {i ¬ i*10 + ci; anyThingFound ¬ TRUE; LOOP};
IF (c = '   ) AND anyThingFound THEN EXIT;
IF (c = '- ) THEN sign ¬ -1;
ENDLOOP;
i ¬ i*sign;
};

GetDIME: PUBLIC PROC [fileName: Rope.ROPE, perLine: PerLineProc] ~ {
fromFile: IO.STREAM ¬ FS.StreamOpen[fileName: fileName, streamOptions: options];
fP: INT;

filePosition: GetIntProc ~ {RETURN[fP]};

stPreDir: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 0, 2]]};
stName: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 2, 20]]};
stType: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 22, 4]]};
stSufDir: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 26, 2]]};
nonStCo: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 28, 1]]};
leftAdd1: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 56, 6]]};
leftAdd2: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 62, 6]]};
rgtAdd1: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 68, 6]]};
rgtAdd2: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 74, 6]]};
zipCoLef: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 103, 5]]};
zipCoRgt: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 108, 5]]};
fmNode: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 122, 4]]};
toNode: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 126, 5]]};
fromLat: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 204, 6]]};
fromLong: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 210, 7]]};
toLat: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 217, 6]]};
toLong: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 223, 7]]};
copyRecord: CopyRecordProc ~ {IO.PutBlock[to, buffer, 0, 300]};

buffer: REF TEXT ¬ NEW[TEXT[300]];

[] ¬ IO.GetBlock[fromFile, buffer, 0, 300];  -- throw away header record

UNTIL fromFile.EndOf[] DO
fP ¬ IO.GetIndex[fromFile];
[] ¬ IO.GetBlock[fromFile, buffer, 0, 300];
IF perLine[filePosition, stPreDir, stName, stType, stSufDir, nonStCo, leftAdd1, leftAdd2, rgtAdd1, rgtAdd2, zipCoLef, zipCoRgt, fmNode, toNode, fromLat, fromLong, toLat, toLong, copyRecord] THEN EXIT;
ENDLOOP;
fromFile.Close[];
};

GetDIMERecord: PUBLIC PROC [fileStream: IO.STREAM, postion: INT, perLine: PerLineProc] ~ {

filePosition: GetIntProc ~ {RETURN[postion]};

stPreDir: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 0, 2]]};
stName: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 2, 20]]};
stType: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 22, 4]]};
stSufDir: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 26, 2]]};
nonStCo: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 28, 1]]};
leftAdd1: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 56, 6]]};
leftAdd2: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 62, 6]]};
rgtAdd1: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 68, 6]]};
rgtAdd2: GetRopeProc ~ {RETURN[Rope.FromRefText[buffer, 74, 6]]};
zipCoLef: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 103, 5]]};
zipCoRgt: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 108, 5]]};
fmNode: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 122, 4]]};
toNode: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 126, 5]]};
fromLat: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 204, 6]]};
fromLong: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 210, 7]]};
toLat: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 217, 6]]};
toLong: GetIntProc ~ {RETURN[IntOutOfBuffer[buffer, 223, 7]]};
copyRecord: CopyRecordProc ~ {IO.PutBlock[to, buffer, 0, 300]};

buffer: REF TEXT ¬ NEW[TEXT[300]];

IO.SetIndex[fileStream, postion];
[] ¬ IO.GetBlock[fileStream, buffer, 0, 300];  -- throw away header record

[] ¬ perLine[filePosition, stPreDir, stName, stType, stSufDir, nonStCo, leftAdd1, leftAdd2, rgtAdd1, rgtAdd2, zipCoLef, zipCoRgt, fmNode, toNode, fromLat, fromLong, toLat, toLong, copyRecord];
};

FilterDIME: PUBLIC PROC [from: Rope.ROPE, to: Rope.ROPE, smallLat, smallLong, largeLat, largeLong: INT] ~ {
toFile: IO.STREAM ¬ FS.StreamOpen[to, $create];
Check: PerLineProc ~ {
IF (fromLat[] >= smallLat) AND (fromLong[] >= smallLong)  AND (fromLat[] < largeLat) AND (fromLong[] < largeLong) THEN copyRecord[toFile];
};
buffer: REF TEXT ¬ NEW[TEXT[300]];
IO.PutBlock[toFile, buffer, 0, 300];
GetDIME[from, Check];
toFile.Close[];
};

options: FS.StreamOptions ¬ FS.defaultStreamOptions;

options[tiogaRead] ¬ FALSE;

END.
   €  
CensusFileReaderImpl.mesa
Copyright س 1992 by Xerox Corporation.  All rights reserved.
Greene, June 25, 1990 3:38 pm PDT
‌تأ  •NewlineDelimiter
–(cedarcode) style™ J™xIcodeک Kڑدk	œ‌œ‌œ#ک3Kڑدnœ‌œ‌œ‌œ‌œ‌œ‌œک]Kک Kڑ‌œ‌œکKک Kک ڑ‍œ‌œ‌œ‌œ	‌œ‌œ‌œ‌œ‌œ‌œ	ک`Kڑœ‌œ‌œکKڑœ‌œکڑ‌œ‌œ‌œ‌ک#Kڑœ‌œکKڑœ‌œ‌œ‌œکKڑ
‌œ‌œ‌œ!‌œ‌œکLKڑ‌œ‌œ‌œ‌œک*Kڑ‌œ‌œکKڑ‌œک—KکKک—Kک ڑ‍œ‌œ‌œ‌œکDKڑœ
‌œ‌œ‌œ8کPKڑœ‌œکKک Kڑœ‌œک(Kک Kڑœ‌œ"کAKڑœ‌œ#ک@Kڑœ‌œ#ک@Kڑœ‌œ#کBKڑœ‌œ#کAKڑœ‌œ#کBKڑœ‌œ#کBKڑœ‌œ#کAKڑœ‌œ#کAKڑœ‌œ"ک@Kڑœ‌œ"ک@Kڑœ‌œ"ک>Kڑœ‌œ"ک>Kڑœ‌œ"ک?Kڑœ‌œ"ک@Kڑœ‌œ"ک=Kڑœ‌œ"ک>Kڑœ‌œک?Kک Kڑ	œ‌œ‌œ‌œ‌œک"Kک Kڑœ‌œ&دcکHKک ڑ‌œ‌کKڑœ‌œکKڑœ‌œ$ک+Kڑ‌œ¼‌œ‌œکبKڑ‌œک—KکKک—Kک ڑ‍œ‌œ‌œ‌œ‌œ‌œکZKک Kڑœ‌œک-Kک Kڑœ‌œ"کAKڑœ‌œ#ک@Kڑœ‌œ#ک@Kڑœ‌œ#کBKڑœ‌œ#کAKڑœ‌œ#کBKڑœ‌œ#کBKڑœ‌œ#کAKڑœ‌œ#کAKڑœ‌œ"ک@Kڑœ‌œ"ک@Kڑœ‌œ"ک>Kڑœ‌œ"ک>Kڑœ‌œ"ک?Kڑœ‌œ"ک@Kڑœ‌œ"ک=Kڑœ‌œ"ک>Kڑœ‌œک?Kک Kڑ	œ‌œ‌œ‌œ‌œک"Kک Kڑ‌œک!Kڑœ‌œ(ںکJKک KکہKک—Kک ڑ‍
œ‌œ‌œ‌œ‌œ,‌œکkKڑœ‌œ‌œ‌œک/ڑ‍œکKڑ
‌œ‌œ‌œ‌œ‌œکٹKک—Kڑ	œ‌œ‌œ‌œ‌œک"Kڑ‌œ"ک$KڑœکKکKک—Kک Kڑœ	‌œ‌œک4Kک Kڑœ‌œکKک Kڑ‌œک— …—    à  #  