TJaMStreamDefsImpl.mesa
Copyright © 1985 by Xerox Corporation. All rights reserved.
Updated for Pilot Martin Newell 23-Jul-81 14:02:05
Doug Wyatt, 13-Oct-81 17:46:21
Bill Paxton, 22-Jan-82 8:35:38
Russ Atkinson, September 23, 1983 7:18 pm
Birrell, August 23, 1983 10:10 am
Michael Plass, February 14, 1985 1:08:27 pm PST
DIRECTORY
ConvertUnsafe USING [ToRope],
FS USING [AccessOptions, Error, StreamOpen],
IO USING [Close, EndOf, GetChar, PutChar, SetIndex, STREAM],
Rope USING [ROPE],
TJaMStorage USING [Zone],
TJaMStreamDefs USING [AccessOptions, Append, DefaultAccess, Read, StreamErrorCode, StreamHandle, StreamObject];
TJaMStreamDefsImpl:
MONITOR
IMPORTS ConvertUnsafe, FS, TJaMStorage, IO
EXPORTS TJaMStreamDefs = {OPEN TJaMStreamDefs;
ROPE: TYPE = Rope.ROPE;
zone: UNCOUNTED ZONE = TJaMStorage.Zone[];
openList: LIST OF IO.STREAM ← NIL; -- here to keep the streams from being collected
StreamError: PUBLIC SIGNAL[stream: StreamHandle, error: StreamErrorCode] = CODE;
FileNameError: PUBLIC SIGNAL[name: LONG STRING] = CODE;
NewByteStream: PUBLIC PROC
[name:
LONG
STRING, access: AccessOptions]
RETURNS [StreamHandle] = {
data: Data ← NIL;
s: StreamHandle ← NIL;
data ← NewStream[name,access];
s ← zone.
NEW[StreamObject ← [reset: FileReset, get: FileGetChar,
putback: FilePutback, put: FilePutChar, endof: FileEndof, destroy: FileDestroy,
data: data]];
RETURN[s];
};
NewWordStream: PUBLIC PROC
[name:
LONG
STRING, access: AccessOptions]
RETURNS [StreamHandle] = {
s: StreamHandle ← NewByteStream[name,access];
s.get ← FileGetWord; s.put ← FilePutWord;
RETURN[s];
};
Data: TYPE = LONG POINTER TO IO.STREAM;
AddStream:
ENTRY
PROC [stream:
IO.
STREAM]
RETURNS [Data] = {
openList ← CONS[stream, openList];
RETURN [@openList.first];
};
RemStream:
ENTRY
PROC [data: Data]
RETURNS [
IO.
STREAM] = {
lag: LIST OF IO.STREAM ← NIL;
FOR list:
LIST
OF
IO.
STREAM ← openList, list.rest
UNTIL list =
NIL
DO
IF @list.first = data
THEN {
IF lag = NIL
THEN openList ← list.rest
ELSE lag.rest ← list.rest;
RETURN [list.first];
};
lag ← list;
ENDLOOP;
RETURN [NIL];
};
NewStream:
PROC [name:
LONG
STRING, access: AccessOptions]
RETURNS [Data] = {
new: BOOL ← FALSE;
stream: IO.STREAM ← NIL;
rope: ROPE ← ConvertUnsafe.ToRope[name];
accessOptions:
FS.AccessOptions ←
SELECT access
FROM
DefaultAccess, Read => read,
Append => append,
ENDCASE => create;
stream ←
FS.StreamOpen[
fileName: rope,
accessOptions: accessOptions
! FS.Error => GO TO NotFound;
];
RETURN [AddStream[stream]];
EXITS NotFound => ERROR FileNameError[name];
};
File Stream Procedures
FileReset:
PROC[s: StreamHandle] = {
data: Data ← s.data;
IO.SetIndex[data^,0];
};
FileGetChar:
PROC[s: StreamHandle]
RETURNS [
CHAR] = {
data: Data ← s.data;
RETURN[IO.GetChar[data^]];
};
FileGetWord:
PROC[s: StreamHandle]
RETURNS [
WORD] = {
data: Data ← s.data;
card: CARDINAL ← (IO.GetChar[data^]-0C) * 256;
card ← card + (IO.GetChar[data^]-0C);
RETURN[LOOPHOLE[card, WORD]];
};
FilePutback:
PROC[s: StreamHandle, c:
CHAR] = {
ERROR StreamError[s,StreamOperation];
};
FilePutChar:
PROC[s: StreamHandle, c:
CHAR] = {
data: Data ← s.data;
IO.PutChar[data^, c];
};
FilePutWord:
PROC[s: StreamHandle, w:
WORD] = {
data: Data ← s.data;
card: CARDINAL ← LOOPHOLE[w, CARDINAL];
IO.PutChar[data^, (card / 256) + 0C];
IO.PutChar[data^, (card MOD 256) + 0C];
};
FileEndof:
PROC[s: StreamHandle]
RETURNS [
BOOL] = {
data: Data ← s.data;
RETURN[IO.EndOf[data^]];
};
FileDestroy:
PROC[s: StreamHandle] = {
data: Data ← s.data;
stream: IO.STREAM ← RemStream[data];
IF stream #
NIL
THEN {
IO.Close[stream];
zone.FREE[@s];
};
};
}.