
DIRECTORY
BasicTime USING [GMT, nullGMT],
IO USING [Close, Error, GetLength, SetIndex, STREAM, UnsafeGetBlock],
ListerSysOps USING [Interceptor, MappedFile, MappedFileInner,
MappedFileInnerRecord, MappedFileRecord, OpenKind],
MobDefs USING [],
PFS USING [Delete, Error, GetInfo, OpenFile, OpenFileFromStream, PATH, PathFromRope, StreamOpen, UniqueID],
Rope USING [Concat, Equal, ROPE],
VM USING [AddressForPageNumber, BytesForPages, Free, Interval, nullInterval, PagesForBytes, SimpleAllocate];
ListerSysOpsImpl: CEDAR MONITOR
IMPORTS IO, PFS, Rope, VM
EXPORTS ListerSysOps
= BEGIN 

GMT: TYPE = BasicTime.GMT;
nullGMT: GMT = BasicTime.nullGMT;
ROPE: TYPE = Rope.ROPE;
STREAM: TYPE = IO.STREAM;

currentInterceptor: ListerSysOps.Interceptor м NIL;
openList: OpenStreamList м NIL;

OpenStreamList: TYPE = LIST OF OpenStreamEntry;
OpenStreamEntry: TYPE = RECORD [stream: STREAM, kind: ListerSysOps.OpenKind];

Intercept: PUBLIC ENTRY PROC [interceptor: ListerSysOps.Interceptor] RETURNS [old: ListerSysOps.Interceptor] = {
old м currentInterceptor;
currentInterceptor м interceptor;
};
Open: PUBLIC PROC [name: ROPE, kind: ListerSysOps.OpenKind]
RETURNS [stream: STREAM м NIL, err: ROPE м NIL, time: GMT м nullGMT] = {
interceptor: ListerSysOps.Interceptor м currentInterceptor;
IF interceptor # NIL AND interceptor.open # NIL
THEN
[stream, err, time] м interceptor.open[interceptor, name, kind]
ELSE {
ENABLE PFS.Error => { err м error.explanation; GO TO oops };
st: STREAM м PFS.StreamOpen[
fileName: PFS.PathFromRope[name],
accessOptions: IF kind = read THEN $read ELSE $create];
time м PFS.GetInfo[PFS.OpenFileFromStream[st]].uniqueID.egmt.gmt;
stream м st;
};
IF err = NIL THEN AddToList[stream, kind];
EXITS oops => {};
};
Close: PUBLIC PROC [stream: STREAM, abortAndDelete: BOOL] RETURNS [err: ROPE] = {
interceptor: ListerSysOps.Interceptor м currentInterceptor;
kind: ListerSysOps.OpenKind;
[stream, kind] м RemFromList[stream];
IF stream = NIL THEN RETURN;
IF interceptor # NIL AND interceptor.close # NIL
THEN
err м interceptor.close[interceptor, stream, abortAndDelete]
ELSE {
ENABLE {
PFS.Error => { err м error.explanation; GO TO exit };
IO.Error => GO TO exit;
};
file: PFS.OpenFile м PFS.OpenFileFromStream[stream];
uid: PFS.UniqueID;
namePath: PFS.PATH;
[fullFName: namePath, uniqueID: uid] м PFS.GetInfo[file];
SELECT kind FROM
read, writeLog => IO.Close[stream];
ENDCASE => {
IO.Close[stream, abortAndDelete];
IF abortAndDelete THEN PFS.Delete[namePath, uid];
};
};
EXITS exit => {};
};

Delete: PUBLIC PROC [name: ROPE] RETURNS [err: ROPE] = {
interceptor: ListerSysOps.Interceptor м currentInterceptor;
IF interceptor # NIL AND interceptor.delete # NIL
THEN err м interceptor.delete[interceptor, name]
ELSE PFS.Delete[PFS.PathFromRope[name]
! PFS.Error => { err м error.explanation; CONTINUE }];
};

Cleanup: PUBLIC PROC [abortAndDelete: BOOL] = {
DO
sample: LIST OF MappedFileInner м mappedFiles;
IF sample = NIL THEN EXIT;
[] м RemMappedFileInner[sample.first, FALSE];
ENDLOOP;
DO
sample: OpenStreamList м openList;
IF sample = NIL THEN EXIT;
[] м Close[sample.first.stream, abortAndDelete];
ENDLOOP;
};

RemFromList: ENTRY PROC [stream: STREAM]
RETURNS [st: STREAM м NIL, kind: ListerSysOps.OpenKind м read] = {
lag: OpenStreamList м openList;
IF lag # NIL THEN {
IF lag.first.stream = stream THEN {
st м stream;
kind м lag.first.kind;
openList м lag.rest;
RETURN;
};
DO
next: OpenStreamList м lag.rest;
IF next = NIL THEN EXIT;
IF next.first.stream = stream THEN {
st м stream;
kind м next.first.kind;
lag.rest м next.rest;
RETURN;
}; 
lag м next;
ENDLOOP;
};
};
AddToList: ENTRY PROC [stream: STREAM, kind: ListerSysOps.OpenKind] = {
openList м CONS[ [stream, kind], openList];
};
mappedFiles: LIST OF MappedFileInner м NIL;

MappedFile: TYPE = ListerSysOps.MappedFile;
MappedFileRecord: TYPE = ListerSysOps.MappedFileRecord;
MappedFileInner: TYPE = ListerSysOps.MappedFileInner;

FindMappedFile: ENTRY PROC [name: ROPE] RETURNS [mf: MappedFile] = {
ENABLE UNWIND => NULL;
FOR each: LIST OF MappedFileInner м mappedFiles, each.rest WHILE each # NIL DO
mfi: MappedFileInner м each.first;
IF Rope.Equal[name, mfi.name] THEN {
mfi.count м mfi.count + 1;
RETURN [NEW[MappedFileRecord м [mfi]]];
};
ENDLOOP;
RETURN [NIL];
};

AddMappedFileInner: ENTRY PROC [mfi: MappedFileInner] = {
mappedFiles м CONS[mfi, mappedFiles];
};

DestroyHandle: ENTRY PROC [mf: MappedFile] RETURNS [mfi: MappedFileInner] = {
IF mf # NIL THEN {
mfi м mf.mfi;
mf.mfi м NIL;
};
};

RemMappedFileInner: ENTRY PROC [mfi: MappedFileInner, decr: BOOL]
RETURNS [st: STREAM] = {
ENABLE UNWIND => NULL;
lag: LIST OF MappedFileInner м mappedFiles;
IF decr THEN {
IF mfi.count > 0 THEN mfi.count м mfi.count - 1;
IF mfi.count > 0 THEN RETURN; -- new
};
IF lag # NIL THEN {
interval: VM.Interval м mfi.interval;
st м mfi.stream;
mfi.stream м NIL;
mfi.interval м VM.nullInterval;
mfi.base м NIL;
IF interval # VM.nullInterval THEN TRUSTED {VM.Free[interval]};
IF lag.first = mfi THEN {mappedFiles м lag.rest; RETURN};
FOR each: LIST OF MappedFileInner м lag.rest, each.rest WHILE each # NIL DO
IF each.first = mfi THEN {lag.rest м each.rest; RETURN};
lag м each;
ENDLOOP;
};
};

Map: PUBLIC PROC [name: ROPE] RETURNS [mf: MappedFile, err: ROPE] = {
mf м FindMappedFile[name];
IF mf = NIL THEN {
stream: STREAM;
time: BasicTime.GMT;
[stream, err, time] м Open[name, read];
IF stream # NIL THEN {
bytes: INT м IO.GetLength[stream];
interval: VM.Interval;
mfi: MappedFileInner;

IF bytes = 0 THEN
RETURN[mf: NIL, err: Rope.Concat["0 length stream for file: ", name]];
interval м VM.SimpleAllocate[VM.PagesForBytes[bytes]];
mfi м NEW[ListerSysOps.MappedFileInnerRecord м [
name: name,
interval: interval,
count: 1,
stream: stream,
base: VM.AddressForPageNumber[interval.page],
bytes: bytes]];
TRUSTED {
wp: LONG POINTER TO CARD м LOOPHOLE[mfi.base];
wn: CARD м VM.BytesForPages[interval.count] / BYTES[CARD];
WHILE wn # 0 DO
wpн м CARD.LAST;
wn м wn - 1;
ENDLOOP;
IO.SetIndex[stream, 0];
[] м IO.UnsafeGetBlock[
self: stream,
block: [base: mfi.base, startIndex: 0, count: bytes]];
};
AddMappedFileInner[mfi];
mf м NEW[MappedFileRecord м [mfi]];
};
};
};

UnMap: PUBLIC PROC [mf: MappedFile] = {
mfi: MappedFileInner м DestroyHandle[mf];
IF mfi # NIL THEN {
st: STREAM м RemMappedFileInner[mfi, TRUE];
IF st # NIL THEN {
[] м Close[st, TRUE];
};
};
};

MapBase: PUBLIC PROC [mf: MappedFile] RETURNS [LONG POINTER] = {
RETURN [mf.base];
};

MapLength: PUBLIC PROC [mf: MappedFile] RETURNS [CARD] = {
RETURN [mf.bytes];
};


END.

  Ж  
ListerSysOpsImpl.mesa
Copyright ╙ 1987, 1988, 1991 by Xerox Corporation.  All rights reserved.
Russ Atkinson (RRA) December 13, 1988 1:39:28 am PST
JKF February 2, 1989 5:07:58 pm PST
Eduardo Pelegri-Llopart February 2, 1989 9:04:17 pm PST
Willie-s, September 26, 1991 2:16 pm PDT

PFS supplies the default operation

PFS supplies the default operation

Mapped file support
RETURN;
 Э╩
Д  ХNewlineDelimiter
Ц(cedarcode) styleЩ codeЩKЪЬ
╧eЬ=ЩHKЪЬ╧kЬЮЩ4KЪЮЬ Щ#KЪ╧y7Щ7KЩ(ЧKШ ЪЮ	Ш	KЪЬ
ЮЬЮЬШKЪЮЬЮЬ%ЮЬШEKЪЬЮЬ_ШqKЪЬЮЬШKЪЮЬЮЬ8ЮЬ&ШkKЪЬЮЬЮЬШ!KЪЮЬЮЬdШlЧheadЪ╧nЬЮЬЮШKЪЮЬЮЬЮЬЮШKЪЮЬШKЪЬЮЬШKШ ЪЮЬЮЬЮЬШKЪЬ	ЮЬШ!ЧKЪЮЬЮЬЮЬШKЪЮЬЮЬЮЬЮЬШKШ KЪЬ/ЮЬШ3KЪЬЮЬШKШ KЪЬЮЬЮЬЮЬШ/KЪЬЮЬЮЬ
ЮЬШMKШ Ъ
а	ЬЮЬЮЬЮЬ)ЮЬ$ШpKЪЬШKЪЬ!Ш!KШKЩ ЧЪаЬЮЬЮЬЮЬЮЬ
ЮЬЮЬЮЬЮЬЮЬШДKЪЬ;Ш;ЪЮЬЮЬЮЬЮШ/ЪЮШKЪЬ?Ш?ЧЪЮЬШKЪЮЬЩ"KЪЮЬЮЬ%ЮЬЮЬШ<KЪЬЮЬЮЬЮЬ$ЮЬЮЬЮЬ
ШvKЪЬЮЬ	ЮЬ+ШAKЪЬШKШЧЧKЪЮЬЮЬЮЬШ*KЪЮЬШKШKЩ ЧЪаЬЮЬЮЬ
ЮЬЮЬЮЬЮЬШQKЪЬ;Ш;KЪЬШKЪЬ%Ш%KЪЮЬ
ЮЬЮЬЮЬШЪЮЬЮЬЮЬЮШ0ЪЮШKЪЬ<Ш<ЧЪЮЬШKЪЮЬЩ"ЪЮЬШKЪЮЬ%ЮЬЮЬШ5KЪЮЬ
ЮЬЮЬШKШЧKЪЬЮЬЮЬШ4KЪЬЮЬ
ШKЪЬ
ЮЬЮЬШKЪЬ'ЮЬШ9ЪЮЬЮШKЪЬЮЬШ#ЪЮЬШKЪЮЬШ!KЪЮЬЮЬЮЬШ1KЪЬШЧЧKШЧЧKЪЮЬШKШKШ ЧЪаЬЮЬЮЬЮЬЮЬЮЬШ8KЪЬ;Ш;ЪЮЬЮЬЮЬЮШ1KЪЮЬ,Ш0KЪ
ЮЬЮЬЮЬЮЬ%Ю	ЬШ]ЧKШKШ ЧЪаЬЮЬЮЬЮЬШ/ЪЮШKЪЬЮЬЮЬШ.KЪЮЬ
ЮЬЮЬЮЬШKЪЬ&ЮЬШ-KЪЮЬШЧЪЮШKЪЬ"Ш"KЪЮЬ
ЮЬЮЬЮЬШKЪЬ0Ш0KЪЮЬШЧKШKШ ЧЪаЬЮЬЮЬ
ЮЬЮЬЮЬЮЬ)ШkKЪЬШЪЮЬЮЬЮЬШЪЮЬЮЬШ#KЪЬШKЪЬШKЪЬШKЪЮЬШKШЧЪЮШKЪЬ Ш KЪЮЬЮЬЮЬЮЬШЪЮЬЮЬШ$KЪЬШKЪЬШKЪЬШKЪЮЬШKЪЬШЧKЪЬШKЪЮЬШЧKШЧKШKЩ ЧЪа	ЬЮЬЮЬ
ЮЬ"ШGKЪЬЮЬШ+KШЧЧЩKЪЬЮЬЮЬЮЬШ+KШ KЪЬЮЬШ+KЪЬЮЬ!Ш7KЪЬЮЬ Ш5KШ Ъ
аЬЮЬЮЬЮЬЮЬШDKЪЮЬЮЬЮЬШЪЮЬЮЬЮЬ*ЮЬЮЬЮШNKШ"ЪЮЬЮЬШ$KЪЬШKЪЮЬЮЬШ'KШЧKЪЮЬШЧKЪЮЬЮЬШKШKШ ЧЪаЬЮЬЮЬШ9KЪЬЮЬШ%KШKШ ЧЪаЬЮЬЮЬЮЬШMЪЮЬЮЬЮЬШKЪЬШKЪЬ	ЮЬШKШЧKШKШ ЧЪаЬЮЬЮЬЮЬЮЬЮЬШZKЪЮЬЮЬЮЬШKЪЬЮЬЮЬШ+ЪЮЬЮЬШKЪЮЬЮЬШ0KЪЮЬЮЬЮЬ╧cШ$KЪЬЩKШЧЪЮЬЮЬЮЬШKЪЬ
ЮЬШ%KЪЬШKЪЬЮЬШKЪЬЮЬШKЪЬЮЬШKЪ
ЮЬЮЬЮЬЮЬЮЬШ?KЪЮЬЮЬЮЬШ9ЪЮЬЮЬЮЬ'ЮЬЮЬЮШKKЪЮЬЮЬЮЬШ8KШKЪЮЬШЧKШЧKШKШ ЧЪаЬЮЬЮЬЮЬЮЬЮЬШEKЪЬШЪЮЬЮЬЮЬШKЪЬЮЬШKЪЬЮЬШKЪЬ'Ш'ЪЮЬ
ЮЬЮЬШKЪЬЮЬЮЬШ"KЪЬ
ЮЬ
ШKЪЬШKШ KЪЮЬЮЬЮЬЮЬ8ШXKЪЬЮЬЮЬШ6ЪЬЮЬ'Ш0KЪЬШKЪЬШKЪЬ	Ш	KЪЬШKЪЬЮЬ%Ш-KЪЬШЧЪЮЬШ	KЪЬЮЬЮЬЮЬЮЬЮЬШ.KЪ	ЬЮЬЮЬ!ЮЬЮЬШ:ЪЮЬЮШKЪЬЮЬЮЬШKШKЪЮЬШЧKЪЮЬШKЪЬЮЬUШ\KШЧKЪЬШKЪЬЮЬШ#KШЧKШЧKШKШ ЧЪаЬЮЬЮЬШ'KЪЬ)Ш)ЪЮЬЮЬЮЬШKЪЬЮЬЮЬШ+ЪЮЬЮЬЮЬШKЪЬЮЬШKЪЬШЧKШЧKШKШ ЧЪаЬЮЬЮЬЮЬЮЬЮЬШ@KЪЮЬШKШKШ ЧЪ
а	ЬЮЬЮЬЮЬЮЬШ:KЪЮЬШKШKШ ЧШ KШ ЧЧKЪЮЬШKШ Ч ЕЧ    n  %x  