
DIRECTORY
BasicTime USING [GMT, nullGMT],
CinderSysOps USING [Interceptor,  OpenKind], 
FS USING [Delete, Error, GetInfo, GetName, OpenFile, OpenFileFromStream, StreamOpen],
IO USING [Close, Error, STREAM],
Rope USING [ROPE];
CinderSysOpsImpl: CEDAR MONITOR
IMPORTS FS, IO
EXPORTS CinderSysOps
= BEGIN 

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

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

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

Intercept: PUBLIC ENTRY PROC [interceptor: CinderSysOps.Interceptor] RETURNS [old: CinderSysOps.Interceptor] = {
old м currentInterceptor;
currentInterceptor м interceptor;
};
Open: PUBLIC PROC [name: ROPE, kind: CinderSysOps.OpenKind]
RETURNS [stream: STREAM м NIL, err: ROPE м NIL, time: GMT м nullGMT] = {
interceptor: CinderSysOps.Interceptor м currentInterceptor;
IF interceptor # NIL AND interceptor.open # NIL
THEN
[stream, err, time] м interceptor.open[interceptor, name, kind]
ELSE {
ENABLE FS.Error => {err м error.explanation; GO TO oops};
st: STREAM м FS.StreamOpen[
fileName: name,
accessOptions: IF kind = read THEN $read ELSE $create];
time м FS.GetInfo[FS.OpenFileFromStream[st]].created;
stream м st;
};
IF err = NIL THEN AddToList[stream, kind];
EXITS oops => {};
};
Close: PUBLIC PROC [stream: STREAM, abortAndDelete: BOOL] RETURNS [err: ROPE] = {
interceptor: CinderSysOps.Interceptor м currentInterceptor;
kind: CinderSysOps.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 {
FS.Error => {err м error.explanation; GO TO exit};
IO.Error => GO TO exit;
};
file: FS.OpenFile м FS.OpenFileFromStream[stream];
name: ROPE м FS.GetName[file].fullFName;
time: BasicTime.GMT м FS.GetInfo[file].created;
SELECT kind FROM
read, writeLog => IO.Close[stream];
ENDCASE => {
IO.Close[stream, abortAndDelete];
IF abortAndDelete THEN FS.Delete[name, time];
};
};
EXITS exit => {};
};

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

Cleanup: PUBLIC PROC [abortAndDelete: BOOL] = {
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: CinderSysOps.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: CinderSysOps.OpenKind] = {
openList м CONS[ [stream, kind], openList];
};
END.

   2  
CinderSysOpsImpl.mesa
Copyright ╙ 1987, 1989, 1991 by Xerox Corporation.  All rights reserved.
Russ Atkinson (RRA) November 20, 1987 4:45:58 pm PST
Andy Litman February 16, 1988 11:39:36 pm PST
JKF July 22, 1989 3:58:35 pm PDT

FS supplies the default operation

FS supplies the default operation


Э╩~  Ц(cedarcode) styleХNewlineDelimiter
Щ codeЩKЪЬ
╧eЬ=ЩHKЪЬ╧kЬЮЩ4KЪ╧y*╨kyЩ-KЪЮЬЩ ЧKШ ЪЮ	Ш	KЪЬ
ЮЬЮЬШKЪЬЮЬШ-KЪЮЬЮЬMШUKЪЮЬЮЬЮЬШ KЪЬЮЬЮЬШЧheadЪ╧nЬЮЬЮШKЪЮЬЮЬЮШKЪЮЬШKЪЬЮЬШKШ ЪЮЬЮЬЮЬШKЪЬ	ЮЬШ!ЧKЪЮЬЮЬЮЬШKЪЮЬЮЬЮЬЮЬШKШ KЪЬ/ЮЬШ3KЪЬЮЬШKШ KЪЬЮЬЮЬЮЬШ/KЪЬЮЬЮЬ
ЮЬШMKШ Ъ
б	ЬЮЬЮЬЮЬ)ЮЬ$ШpKЪЬШKЪЬ!Ш!KШKЩ ЧЪбЬЮЬЮЬЮЬЮЬ
ЮЬЮЬЮЬЮЬЮЬШДKЪЬ;Ш;ЪЮЬЮЬЮЬЮШ/ЪЮШKЪЬ?Ш?ЧЪЮЬШKЪЮЬЩ!KЪЮЬЮЬ$ЮЬЮЬШ9KЪЬЮЬЮЬ,ЮЬЮЬЮЬ
ШcKЪЬЮЬ	ЮЬ!Ш5KЪЬШKШЧЧKЪЮЬЮЬЮЬШ*KЪЮЬШKШKЩ ЧЪбЬЮЬЮЬ
ЮЬЮЬЮЬЮЬШQKЪЬ;Ш;KЪЬШKЪЬ%Ш%KЪЮЬ
ЮЬЮЬЮЬШЪЮЬЮЬЮЬЮШ0ЪЮШKЪЬ<Ш<ЧЪЮЬШKЪЮЬЩ!ЪЮЬШKЪЮЬ$ЮЬЮЬШ2KЪЮЬ
ЮЬЮЬШKШЧKЪЬЮЬЮЬШ2KЪЬЮЬЮЬШ(KЪЬЮЬЮЬШ/ЪЮЬЮШKЪЬЮЬШ#ЪЮЬШKЪЮЬШ!KЪЮЬЮЬЮЬШ-KЪЬШЧЧKШЧЧKЪЮЬШKШKШ ЧЪбЬЮЬЮЬЮЬЮЬЮЬШ8KЪЬ;Ш;ЪЮЬЮЬЮЬЮШ1KЪЮЬ,Ш0KЪЮЬЮЬЮЬ$ЮЬШGЧ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Ш Ч ЕЧ    Ь  L  