DIRECTORY
BcdDefs:
TYPE
USING [
Base, Link, MTIndex, MTRecord, SGIndex, VersionStamp, FTSelf, SGNull, VersionID],
BcdOps: TYPE USING [BcdBase, NameString],
CommandUtil: TYPE USING [PairList, FreePairList, KeyValue],
ConvertUnsafe: TYPE USING [AppendRope, EqualSubStrings, SubString, SubStringToRope, ToRope],
FS: TYPE USING [Create, Close, Error, Read, nullOpenFile, Open, OpenFile, read, SameFile, write],
FileParms:
TYPE
USING [
ActualId, BindingProc, Name, Ops, SymbolSpace, nullActual, nullSymbolSpace],
FileParmOps: TYPE USING [],
FileSegment: TYPE USING [Span, nullSpan],
Rope: TYPE USING [ROPE],
TimeStamp: TYPE USING [Stamp],
VM: TYPE USING [Allocate, Free, Interval, Map, nullInterval, PageNumberToAddress];
FSFileParmPack:
PROGRAM
IMPORTS CommandUtil, ConvertUnsafe, FS, VM
EXPORTS FileParmOps = {
Name: TYPE = FileParms.Name;
ActualId: TYPE = FileParms.ActualId;
nullActual: ActualId = FileParms.nullActual;
FileIndex: TYPE = NAT;
nullFileIndex: FileIndex = FileIndex.LAST;
primary operations for read-only access
Binding:
PROC [
formalId, formalType: Name,
defaultLocator: LONG STRING,
binder: FileParms.BindingProc] = {
i: FileIndex;
name: LONG STRING ← FileName[@formalId, defaultLocator];
type: LONG STRING ← CopyName[@formalType];
IF name = NIL THEN i ← nullFileIndex
ELSE {
file: FS.OpenFile ← FS.nullOpenFile;
FOR i
IN [0 .. nextFile)
DO
IF EquivalentStrings[name, fileTable[i].name]
THEN {
IF EquivalentStrings[type, fileTable[i].type] THEN GO TO found;
file ← fileTable[i].file};
REPEAT
found => {zone.FREE[@name]; zone.FREE[@type]};
FINISHED => {
version: TimeStamp.Stamp;
span: FileSegment.Span;
IF file = FS.nullOpenFile THEN file ← CreateFile[name];
IF file = FS.nullOpenFile THEN i ← nullFileIndex
ELSE {
[version, span] ← ReadHeader[file, @formalType];
i ← SearchCache[version];
IF i = nullFileIndex
AND version # nullActual.version
THEN {
i ← NewCacheEntry[];
fileTable[i] ← [
version: version, file: file, span: span, name: name, type: type]}
ELSE {
FS.Close[file]; file ← FS.nullOpenFile;
zone.FREE[@name]; zone.FREE[@type]}}};
ENDLOOP;
IF i = nullFileIndex THEN binder[nullActual]
ELSE binder[[fileTable[i].version, [fileTable[i].name, 0, fileTable[i].name.length]]]}};
Acquire:
PROC [id: Name, actual: ActualId]
RETURNS [FileParms.SymbolSpace] = {
i: FileIndex ← SearchCache[actual.version];
IF i = nullFileIndex
THEN {
i ← NewCacheEntry[];
fileTable[i] ← [
version: actual.version, name: CopyName[@actual.locator], type: CopyName[@id]]};
OpenFile[i];
RETURN [
IF fileTable[i].file =
FS.nullOpenFile
OR fileTable[i].span = nullSpan
THEN FileParms.nullSymbolSpace
ELSE [file: fileTable[i].file, span: fileTable[i].span]]};
Release: PROC [s: FileParms.SymbolSpace] = {NULL}; -- add ref counts?
Forget:
PROC [actual: ActualId] = {
i: NAT ← 0;
WHILE i < nextFile
DO {
IF fileTable[i].version = actual.version THEN GO TO delete;
IF fileTable[i].name #
NIL
THEN {
d: ConvertUnsafe.SubString ← [fileTable[i].name, 0, fileTable[i].name.length];
IF ConvertUnsafe.EqualSubStrings[d, actual.locator, FALSE] THEN GO TO delete};
i ← i + 1;
EXITS
delete => {
ClearCacheEntry[i];
nextFile ← nextFile - 1;
IF i # nextFile
THEN {
fileTable[i] ← fileTable[nextFile]; fileTable[nextFile] ← [nullActual.version]}}};
ENDLOOP};
operations for update access
outputFile: FS.OpenFile;
AcquireOutput:
PUBLIC
PROC [name:
LONG
STRING]
RETURNS [
FS.OpenFile] = {
fileName: Rope.ROPE = ConvertUnsafe.ToRope[name];
outputFile ←
FS.Open[fileName,
FS.write
! FS.Error => IF error.code = notFound THEN {outputFile ← FS.Create[fileName]; CONTINUE}];
RETURN [outputFile]};
ReleaseOutput:
PUBLIC
PROC [file:
FS.OpenFile] = {
IF outputFile = FS.nullOpenFile OR ~FS.SameFile[file, outputFile] THEN ERROR;
FS.Close[outputFile]; outputFile ← FS.nullOpenFile};
command line arguments
aList: CommandUtil.PairList;
SetAList: PUBLIC PROC [map: CommandUtil.PairList] = {aList ← map};
ClearAList: PUBLIC PROC = {aList ← CommandUtil.FreePairList[aList]};
initialization/finalization
Initialize:
PUBLIC
PROC [scratchZone:
UNCOUNTED
ZONE]
RETURNS [FileParms.Ops] = {
zone ← scratchZone;
fileTable ← NIL; AdjustFileTable[16];
nextFile ← 0;
outputFile ← FS.nullOpenFile;
RETURN [[Binding, Acquire, Release, Forget]]};
Finalize:
PUBLIC
PROC = {
FOR i: NAT IN [0..nextFile) DO ClearCacheEntry[i] ENDLOOP;
IF outputFile # FS.nullOpenFile THEN {FS.Close[outputFile]; outputFile ← FS.nullOpenFile};
--zone.--FREE[@fileTable]; zone ← NIL};
interpretation of file names (Pilot PreCascade conventions)
FileName:
PROC [key: ConvertUnsafe.SubString, default:
LONG
STRING]
RETURNS [
LONG
STRING] = {
t: LONG STRING = CommandUtil.KeyValue[key, aList];
d: ConvertUnsafe.SubString ←
SELECT
TRUE
FROM
(t # NIL) => [base: t, offset: 0, length: t.length],
(default # NIL) => [base: default, offset: 0, length: default.length],
ENDCASE => key;
RETURN [NormalizeFileName[d]]};
CopyName:
PROC [master: ConvertUnsafe.SubString]
RETURNS [s:
LONG
STRING] = {
s ← zone.NEW[StringBody[master.length]];
ConvertUnsafe.AppendRope[s, ConvertUnsafe.SubStringToRope[master]];
RETURN};
NormalizeFileName:
PROC [formal: ConvertUnsafe.SubString]
RETURNS [s:
LONG
STRING] = {
IF formal.length = 1 AND formal.base[formal.offset] = '$ THEN s ← NIL
ELSE {
dot: BOOL ← FALSE;
s ← zone.NEW[StringBody[formal.length+(".bcd"L).length]];
FOR i:
CARDINAL
IN [formal.offset .. formal.offset+formal.length)
DO
IF formal.base[i] = '. THEN dot ← TRUE;
-- ConvertUnsafe.AppendChar[s, formal.base[i]];
ENDLOOP;
ConvertUnsafe.AppendRope[s, ConvertUnsafe.SubStringToRope[formal]];
IF ~dot THEN ConvertUnsafe.AppendRope[s, ".bcd"]};
RETURN};
EquivalentStrings:
PROC [s1, s2:
LONG
STRING]
RETURNS [
BOOL] = {
IF s1 #
NIL
AND s2 #
NIL
THEN {
d1: ConvertUnsafe.SubString ← [base: s1, offset: 0, length: s1.length];
d2: ConvertUnsafe.SubString ← [base: s2, offset: 0, length: s2.length];
RETURN [ConvertUnsafe.EqualSubStrings[d1, d2, FALSE]]}
ELSE RETURN [FALSE]};
file setup
OpenFile:
PROC [i: FileIndex] = {
IF fileTable[i].file =
FS.nullOpenFile
AND fileTable[i].name #
NIL
THEN
fileTable[i].file ← CreateFile[fileTable[i].name];
IF fileTable[i].file #
FS.nullOpenFile
AND fileTable[i].span = nullSpan
THEN {
version: TimeStamp.Stamp;
d: ConvertUnsafe.SubString ← [fileTable[i].type, 0, fileTable[i].type.length];
[version, fileTable[i].span] ← ReadHeader[fileTable[i].file, @d];
IF version # fileTable[i].version
THEN {
ClearCacheEntry[i];
fileTable[i].file ← FS.nullOpenFile; fileTable[i].span ← nullSpan}}};
low-level file manipulation and cache management
zone: UNCOUNTED ZONE ← NIL;
nullSpan: FileSegment.Span = FileSegment.nullSpan;
FileRecord:
TYPE =
RECORD[
version: TimeStamp.Stamp ← ,
file: FS.OpenFile ← FS.nullOpenFile,
span: FileSegment.Span ← nullSpan,
name: LONG STRING ← NIL,
type: LONG STRING ← NIL];
FileTable: TYPE = RECORD [SEQUENCE length: FileIndex OF FileRecord];
fileTable: REF FileTable;
nextFile: NAT;
file table management
SearchCache:
PROC [version: TimeStamp.Stamp]
RETURNS [i: FileIndex] = {
FOR i
IN [0 .. nextFile)
DO
IF fileTable[i].version = version THEN EXIT;
REPEAT
FINISHED => i ← nullFileIndex;
ENDLOOP;
RETURN};
NewCacheEntry:
PROC
RETURNS [i: FileIndex] = {
WHILE nextFile >= fileTable.length DO AdjustFileTable[fileTable.length + 16] ENDLOOP;
i ← nextFile; nextFile ← nextFile + 1};
AdjustFileTable:
PROC [newSize:
NAT] = {
newTable: REF FileTable;
oldSize: NAT = IF fileTable = NIL THEN 0 ELSE fileTable.length;
IF newSize = 0 THEN newTable ← NIL
ELSE {
i: FileIndex;
newTable ← --zone.--NEW[FileTable[newSize]];
FOR i IN [0..MIN[oldSize, newSize]) DO newTable[i] ← fileTable[i] ENDLOOP;
FOR i IN [oldSize..newSize) DO newTable[i] ← [version: nullActual.version] ENDLOOP};
IF fileTable # NIL THEN --zone.--FREE[@fileTable];
fileTable ← newTable};
ClearCacheEntry:
PROC [i: FileIndex] = {
IF fileTable[i].file #
FS.nullOpenFile
THEN {
FS.Close[fileTable[i].file]; fileTable[i].file ← FS.nullOpenFile};
IF fileTable[i].name # NIL THEN zone.FREE[@fileTable[i].name];
IF fileTable[i].type # NIL THEN zone.FREE[@fileTable[i].type]};
file setup
NameToRope:
PROC [s:
LONG
STRING]
RETURNS [r: Rope.
ROPE] = {
oldLength: CARDINAL = s.length;
IF oldLength > 1
AND s[s.length-1] = '.
THEN
s.length ← s.length - 1; -- undo Alto convention for Pilot
r ← ConvertUnsafe.ToRope[s];
s.length ← oldLength;
RETURN};
CreateFile:
PROC [s:
LONG
STRING]
RETURNS [file:
FS.OpenFile ←
FS.nullOpenFile] = {
IF s #
NIL
THEN
file ← FS.Open[NameToRope[s], FS.read ! FS.Error => TRUSTED {CONTINUE}];
RETURN};
ReadHeader:
PROC [file:
FS.OpenFile, typeId: ConvertUnsafe.SubString]
RETURNS [
version: TimeStamp.Stamp ← nullActual.version,
span: FileSegment.Span ← nullSpan] = {
headerInterval: VM.Interval ← VM.nullInterval;
DeleteHeader:
PROC = {
IF headerInterval #
VM.nullInterval
THEN {
VM.Free[headerInterval];
headerInterval ← VM.nullInterval}};
IF file #
FS.nullOpenFile
THEN {
ENABLE {
UNWIND => {NULL};
ANY => {GO TO badFile}};
BcdBase:
PROC [p:
LONG
POINTER]
RETURNS [BcdDefs.Base] =
INLINE {
RETURN [LOOPHOLE[p, BcdDefs.Base]]};
bcd: BcdOps.BcdBase;
bcdPages: CARDINAL ← 8;
mtb, ftb, sgb: BcdDefs.Base;
mti: BcdDefs.MTIndex;
sSeg: BcdDefs.SGIndex;
nString: BcdOps.NameString;
d: ConvertUnsafe.SubString;
DO
headerInterval ← VM.Allocate[count: bcdPages];
bcd ← VM.PageNumberToAddress[headerInterval.page];
FS.Read[file: file, fromPage: 1, pageCount: bcdPages, to: bcd];
IF bcd.versionIdent # BcdDefs.VersionID THEN GO TO badFile;
IF bcdPages >= bcd.nPages THEN EXIT;
bcdPages ← bcd.nPages;
VM.Free[headerInterval]; headerInterval ← VM.nullInterval
ENDLOOP;
IF bcd.nConfigs # 0 THEN GO TO badFile; -- no packaged bcd's (for now)
nString ← LOOPHOLE[bcd + bcd.ssOffset];
d.base ← @nString.string;
ftb ← BcdBase[bcd + bcd.ftOffset];
mtb ← BcdBase[bcd + bcd.mtOffset]; mti ← BcdDefs.MTIndex.FIRST;
UNTIL mti = bcd.mtLimit
DO
d.offset ← mtb[mti].name; d.length ← nString.size[mtb[mti].name];
IF ConvertUnsafe.EqualSubStrings[typeId, d] THEN EXIT;
mti ← mti + (
WITH m: mtb[mti]
SELECT
FROM
direct => BcdDefs.MTRecord.direct.SIZE + m.length*BcdDefs.Link.SIZE,
indirect => BcdDefs.MTRecord.indirect.SIZE,
multiple => BcdDefs.MTRecord.multiple.SIZE,
ENDCASE => ERROR);
REPEAT
FINISHED =>
IF bcd.nModules = 1 THEN mti ← BcdDefs.MTIndex.FIRST ELSE GOTO badFile;
ENDLOOP;
ftb ← BcdBase[bcd + bcd.ftOffset];
version ←
IF mtb[mti].file = BcdDefs.FTSelf
THEN bcd.version
ELSE ftb[mtb[mti].file].version;
sgb ← BcdBase[bcd + bcd.sgOffset]; sSeg ← mtb[mti].sseg;
IF sSeg = BcdDefs.SGNull
OR sgb[sSeg].pages = 0 OR sgb[sSeg].file # BcdDefs.FTSelf THEN GO TO badFile;
span ← [base: sgb[sSeg].base, pages: sgb[sSeg].pages];
DeleteHeader[];
EXITS
badFile => {DeleteHeader[]; span ← nullSpan}};
RETURN};
}.