
DIRECTORY
Basics USING [FFromInt32, HFromInt16],
BasicTime USING [GMT, Now, nullGMT],
Commander USING [CommandProc, Register],
CrRPC USING [BulkDataCheckAbortProc],
IO,
PFS,
PFSNames,
Rope,
TrickleChargeP9813V411 USING [AnyBodyHomeType, EnumerateForInfoType, ErrorType, FileInfoType, FileNotFoundType, RetrieveType];


TrickleChargeP9813V411Impl: CEDAR PROGRAM
IMPORTS Basics, BasicTime, Commander, IO, PFS, Rope
EXPORTS TrickleChargeP9813V411
~ BEGIN
GMT: TYPE = BasicTime.GMT;
ROPE: TYPE = Rope.ROPE;
STREAM: TYPE = IO.STREAM;
tempName: PFSNames.PATH ~ PFS.PathFromRope["/tmp/Enumerate.txt"];
startTime: BasicTime.GMT м BasicTime.Now[];
anybodyHomeCount: CARD м 0;
enumForInfoCount: CARD м 0;
fileInfoCount: CARD м 0;
retrieveCount: CARD м 0;
anybodyHomeTime: GMT м BasicTime.nullGMT;
enumForInfoStart: GMT м BasicTime.nullGMT;
enumForInfoEnd: GMT м BasicTime.nullGMT;
fileInfoStart: GMT м BasicTime.nullGMT;
fileInfoEnd: GMT м BasicTime.nullGMT;
fileInfoName: ROPE;
retrieveStart: GMT м BasicTime.nullGMT;
retrieveEnd: GMT м BasicTime.nullGMT;
retrieveInProgress: BOOL м FALSE;
retrieveName: ROPE;
AnyBodyHome: PUBLIC TrickleChargeP9813V411.AnyBodyHomeType = {
anybodyHomeCount м anybodyHomeCount.SUCC;
anybodyHomeTime м BasicTime.Now[];
RETURN[301];	-- 311 from dmachine
};

EnumerateForInfo: PUBLIC TrickleChargeP9813V411.EnumerateForInfoType = {
ENABLE PFS.Error => {
IF error.code = $unknownFile
THEN ERROR FileNotFound[pattern]
ELSE ERROR Error[error.explanation];
};
Enumerate: PFS.InfoProc = {
fullNameRope: ROPE ~ PFS.RopeFromPath[fullFName];
length: INT16 ~ Rope.Length[fullNameRope];
createdInt: INT ~ LOOPHOLE[uniqueID.egmt.gmt];
IO.PutHWord[self: s, hword: Basics.HFromInt16[length]];
IO.PutFWord[self: s, fword: Basics.FFromInt32[createdInt]];
IO.PutFWord[self: s, fword: Basics.FFromInt32[bytes]];
IO.PutRope[self: s, r: fullNameRope];
RETURN[TRUE];
};
Abort: CrRPC.BulkDataCheckAbortProc = {
IF abortProcess THEN RETURN [TRUE] ELSE RETURN[FALSE];
};
abortProcess: BOOL м FALSE;
s: STREAM м PFS.StreamOpen[fileName: tempName, accessOptions: create];
enumForInfoCount м enumForInfoCount.SUCC;
enumForInfoStart м BasicTime.Now[];
PFS.EnumerateForInfo[pattern: PFS.PathFromRope[pattern], proc: Enumerate];
IO.Close[self: s, abort: FALSE];
s м PFS.StreamOpen[fileName: tempName, accessOptions: read];
abortProcess м info[h: h, s: s, checkAbort: Abort];
IO.Close[self: s, abort: FALSE];
PFS.Delete[name: tempName];
enumForInfoEnd м BasicTime.Now[];
};

FileInfo: PUBLIC TrickleChargeP9813V411.FileInfoType = {
ENABLE PFS.Error => {
IF error.code = $unknownFile
THEN ERROR FileNotFound[name]
ELSE ERROR Error[error.explanation];
};
createdUID: PFS.UniqueID;
wantedUID: PFS.UniqueID;
wantedGMT: GMT ~ LOOPHOLE[wantedCreatedTime];
fullFNamePath: PFSNames.PATH;
wantedUID.egmt.gmt м wantedGMT;
fileInfoCount м fileInfoCount.SUCC;
fileInfoStart м BasicTime.Now[];
fileInfoName м name;
[fullFName: fullFNamePath, bytes: bytes, uniqueID: createdUID] м PFS.FileInfo[name: PFS.PathFromRope[name], wantedUniqueID: wantedUID];
created м LOOPHOLE[createdUID.egmt.gmt];
fullFName м PFS.RopeFromPath[fullFNamePath];
fileInfoEnd м BasicTime.Now[];
};

Retrieve: PUBLIC TrickleChargeP9813V411.RetrieveType = {
ENABLE PFS.Error => {
IF error.code = $unknownFile
THEN ERROR FileNotFound[name]
ELSE ERROR Error[error.explanation];
};
Abort: CrRPC.BulkDataCheckAbortProc = {
IF abortThis THEN RETURN [TRUE] ELSE RETURN[FALSE];
};
abortThis: BOOL м FALSE;
s: STREAM;
wantedGMT: GMT ~ LOOPHOLE[wantedCreatedTime];
wantedUID: PFS.UniqueID;
retrieveStreamOptions: PFS.StreamOptions;
retrieveStreamOptions[includeFormatting] м TRUE;
wantedUID.egmt.gmt м wantedGMT;
retrieveCount м retrieveCount.SUCC;
retrieveStart м BasicTime.Now[];
retrieveInProgress м TRUE;
retrieveName м name;
s м PFS.StreamOpen[fileName: PFS.PathFromRope[name], accessOptions: read,
streamOptions: retrieveStreamOptions, wantedUniqueID: wantedUID];
abortThis м data[h: h, s: s, checkAbort: Abort];
IO.Close[self: s, abort: FALSE];
retrieveInProgress м FALSE;
retrieveEnd м BasicTime.Now[];
};

FileNotFound: PUBLIC TrickleChargeP9813V411.FileNotFoundType = CODE;
Error: PUBLIC TrickleChargeP9813V411.ErrorType = CODE;
nullGMTRope: ROPE ~ "nullGMT";
TCStats: Commander.CommandProc = {
cmd.out.PutF1["***** Server started at %g\n", [time[startTime]] ];
cmd.out.PutF["anybodyHomeCount: %g (%g)\n",
[cardinal[anybodyHomeCount]],
IF anybodyHomeTime = BasicTime.nullGMT THEN [rope[nullGMTRope]] ELSE [time[anybodyHomeTime]] ];

cmd.out.PutF["enumForInfoCount: %g (%g, %g)\n",
[cardinal[enumForInfoCount]],
IF enumForInfoStart = BasicTime.nullGMT THEN [rope[nullGMTRope]] ELSE [time[enumForInfoStart]],
IF enumForInfoEnd = BasicTime.nullGMT THEN [rope[nullGMTRope]] ELSE [time[enumForInfoEnd]] ];

cmd.out.PutFL["fileInfoCount: %g (%g, %g) (%g)\n",
LIST[ [cardinal[fileInfoCount]],
IF fileInfoStart = BasicTime.nullGMT THEN [rope[nullGMTRope]] ELSE [time[fileInfoStart]],
IF fileInfoEnd = BasicTime.nullGMT THEN [rope[nullGMTRope]] ELSE [time[fileInfoEnd]],
[rope[fileInfoName]]] ];

cmd.out.PutFL["retrieveCount: %g (%g, %g) (%g%g)\n",
LIST[ [cardinal[retrieveCount]],
IF retrieveStart = BasicTime.nullGMT THEN [rope[nullGMTRope]] ELSE [time[retrieveStart]],
IF retrieveEnd = BasicTime.nullGMT THEN [rope[nullGMTRope]] ELSE [time[retrieveEnd]],
[rope[retrieveName]], [rope[IF retrieveInProgress THEN " - in progress" ELSE NIL]]] ];

};

Commander.Register["TCStats", TCStats, "Statistics for TrickleChargeServer"];

END.
  j  
TrickleChargeP9813V411Impl.mesa
Copyright ╙ 1989, 1991, 1992 by Xerox Corporation.  All rights reserved.
Tim Diebert: September 19, 1989 8:58:44 am PDT
Willie-s, January 31, 1992 6:37 pm PST
Copied Types
Constants 
Stats 
Exported Procs 
[h: CrRPC.Handle] RETURNS [mayBe: TrickleChargeP9813V411.INT16]
[h: CrRPC.Handle, pattern: ROPE, info: CrRPC.BulkDataSink]
CrRPC.BulkDataSink =[h: CrRPC.Handle, s: STREAM, checkAbort: CrRPC.BulkDataCheckAbortProc] RETURNS [abort: BOOL]
[fullFName: PATH, attachedTo: PATH, uniqueID: UniqueID, bytes: INT, mutability: Mutability, fileType: PFS.FileType] RETURNS [continue: BOOL]
TrickleChargeP9813V411.EnumerationRep: TYPE ~ RECORD [
nameLength: Basics.HWORD, -- if the name of the file is bigger than this we have a real problem.
created: Basics.FWORD, -- really BasicTime.GMT LOOPHOLEd
size: Basics.FWORD, -- number of bytes in the file
nameBytes: PACKED ARRAY [0..0) OF BYTE -- the contents of the name.
];
[h: CrRPC.Handle] RETURNS [abort: BOOL]
[h: CrRPC.Handle, name: ROPE, wantedCreatedTime: TrickleChargeP9813V411.INT32] RETURNS [fullFName: ROPE, bytes: TrickleChargeP9813V411.INT32, created: TrickleChargeP9813V411.INT32]
[h: CrRPC.Handle, name: ROPE, wantedCreatedTime: TrickleChargeP9813V411.INT32, data: CrRPC.BulkDataSink]
[h: CrRPC.Handle] RETURNS [abort: BOOL]
Exported Errors 
[file: ROPE]
[description: ROPE]
Commander stuff 
Э╩:  ХNewlineDelimiter
Ц(cedarcode) styleЩ ЪЬЩIcodeЪЬ
╧eЬ=ЩHKЩ.KЩ&ЧKШ Ъ╧k	Ш	KЪЬЮЬШ&KЪЬ
ЮЬЮЬШ$KЪЬ
ЮЬШ(KЪЬЮЬШ%KЪЮЬШKЪЮЬШKШ	KЪЬШKЪЬЮЬbШ~ЧKШ KШ Ъ╨lnЬЮШ)KЪЮЬЮЬЮЬШ3KЪЮЬШKЪЬЮШheadЩIcode1ЪЮЬЮЬЮЬШMЪЮЬЮЬЮЬШMЪЮЬЮЬЮЬЮЬШЧhead2Щ
MЪЬЮЬЮЬ$ШAЧЩMЪЬЮЬШ+MЪЬЮЬШMЪЬЮЬШMЪЬЮЬШMЪЬЮЬШMЪЬЮЬШ)MЪЬЮЬШ*MЪЬЮЬШ(MЪЬЮЬШ'MЪЬЮЬШ%MЪЬЮЬШMЪЬЮЬШ'MЪЬЮЬШ%MЪЬЮЬЮЬШ!MЪЬЮЬШЧЩХStartOfExpansionC -- [h: CrRPC.Handle] RETURNS [mayBe: TrickleChargeP9813V411.INT16]Ъ╧nЬЮЬ+Ш>KЪ╨ck?Щ?KЪЬ$ЮЬШ)KШ"KЪЮЬ╧cШ!KШЧKЦ> -- [h: CrRPC.Handle, pattern: ROPE, info: CrRPC.BulkDataSink]Ш ЪаЬЮЬ0ШHKЪб:Щ:KЦ` -- [h: CrRPC.Handle, s: STREAM, checkAbort: CrRPC.BulkDataCheckAbortProc] RETURNS [abort: BOOL]ЪбЬб\ЩpЪЮЬЮЬШЪЮЬШKЪЮЬЮЬШ KЪЮЬЮЬШ$ЧKЪЬШЧЪа	ЬЮЬШKЪб$ЬбЬб2ЩМЪЬ'ЮЬЮЬЩ6KЪЬЮЬвFЩ`KЪЬЮЬвбвбвЩ8KЪЬЮЬвЩ2KЪ
ЬЮЬЮЬЮЬЮЬвЩCKЪЬЩЧKЦ[base: ROPE]ЪЬЮЬЮЬШ1KЪЬЮЬЮЬШ*KЪЬЮЬЮЬШ.KЦ [self: STREAM, hword: HWORD]ЪЮЬ5Ш7KЦ [self: STREAM, fword: FWORD]ЪЮЬ9Ш;KЦ [self: STREAM, fword: FWORD]ЪЮЬ4Ш6KЦF[self: STREAM, r: ROPE, start: INT _ 0, len: INT _ 2147483647]ЪЮЬ#Ш%KЪЮЬЮЬШKШЧЦ+ -- [h: CrRPC.Handle] RETURNS [abort: BOOL]ЪаЬ"Ш'KЪб'Щ'KЪЮЬЮЬЮЬЮЬЮЬЮЬЮЬШ6KШЧKЪЬЮЬЮЬШKЪЬЮЬЮЬ7ШFKЦ:[pattern: ROPE, proc: FS.InfoProc, wDir: ROPE _ NIL]ЪЬ$ЮЬШ)KШ#KЦ:[pattern: ROPE, proc: FS.InfoProc, wDir: ROPE _ NIL]ЪЮЬЮЬ)ШJKЦ'[self: STREAM, abort: BOOL _ FALSE]ЪЮЬЮЬШ KЦ╓[fileName: ROPE, accessOptions: FS.AccessOptions _ read, streamOptions: FS.StreamOptions _ (3)[TRUE, TRUE, TRUE], keep: CARDINAL _ 1B (1), createByteCount: FS.ByteCount _ 2560, streamBufferParms: FS.StreamBufferParms _ [vmPagesPerBuffer: 8, nBuffers: 2], extendFileProc: FS.ExtendFileProc, wantedCreatedTime: GMT _ OPAQUE#17777777777B, remoteCheck: BOOL _ TRUE, wDir: ROPE _ NIL, checkFileType: BOOL _ FALSE, fileType: FS.FileType _ [0B (0)]]ЪЬЮЬ5Ш<KШ3KЦ'[self: STREAM, abort: BOOL _ FALSE]ЪЮЬЮЬШ KЦR[name: ROPE, wantedCreatedTime: GMT _ OPAQUE#17777777777B, wDir: ROPE _ NIL]ЪЮЬШKШ!KШЧKЦ╕ -- [h: CrRPC.Handle, name: ROPE, wantedCreatedTime: TrickleChargeP9813V411.INT32] RETURNS [fullFName: ROPE, bytes: TrickleChargeP9813V411.INT32, created: TrickleChargeP9813V411.INT32]Ш ЪаЬЮЬ(Ш8KЪб┤Щ┤ЪЮЬЮЬШЪЮЬШKЪЮЬЮЬШKЪЮЬЮЬШ$ЧKЪЬШЧKЪЬЮЬ
ШKЪЬЮЬ
ШKЪЬЮЬЮЬШ-KЪЬЮЬШKШKЪЬЮЬШ#KШ KШKЦn[name: ROPE, wantedCreatedTime: GMT _ OPAQUE#17777777777B, remoteCheck: BOOL _ TRUE, wDir: ROPE _ NIL]ЪЬAЮЬЮЬ0ШЗKЪЬ
ЮЬШ(KЪЬЮЬШ,KШKШЧKЦl -- [h: CrRPC.Handle, name: ROPE, wantedCreatedTime: TrickleChargeP9813V411.INT32, data: CrRPC.BulkDataSink]Ш ЪаЬЮЬ(Ш8KЪбhЩhЪЮЬЮЬШЪЮЬШKЪЮЬЮЬШKЪЮЬЮЬШ$ЧKЪЬШЧЦ+ -- [h: CrRPC.Handle] RETURNS [abort: BOOL]ЪаЬ"Ш'KЪб'Щ'KЪЮЬЮЬЮЬЮЬЮЬЮЬЮЬШ3KШЧKЪЬЮЬЮЬШKЪЬЮЬШ
KЪЬЮЬЮЬШ-KЪЬЮЬ
ШKЪЬЮЬШ)KЪЬ+ЮЬШ0KШKЦ╓[fileName: ROPE, accessOptions: FS.AccessOptions _ read, streamOptions: FS.StreamOptions _ (3)[TRUE, TRUE, TRUE], keep: CARDINAL _ 1B (1), createByteCount: FS.ByteCount _ 2560, streamBufferParms: FS.StreamBufferParms _ [vmPagesPerBuffer: 8, nBuffers: 2], extendFileProc: FS.ExtendFileProc, wantedCreatedTime: GMT _ OPAQUE#17777777777B, remoteCheck: BOOL _ TRUE, wDir: ROPE _ NIL, checkFileType: BOOL _ FALSE, fileType: FS.FileType _ [0B (0)]]ЪЬЮЬШ#KШ KЪЬЮЬШKШKЪЬЮЬЮЬkШЛKШ0KЦ'[self: STREAM, abort: BOOL _ FALSE]ЪЮЬЮЬШ KЪЬЮЬШKШKШKШ ЧЧЩЦ -- [file: ROPE]ЪаЬЮЬ+ЮЬШDKЪбЩЧЦ -- [description: ROPE]ЪаЬЮЬ$ЮЬШ6KЪбЩЧЧЩKЦ -- [file: ROPE]ЪЬЮЬШЪаЬШ"KШBЪЬ+Ш+KЪЬШKЪЮЬ%ЮЬЮЬШ_KШ ЧЪЬ/Ш/KЪЬШKЪЮЬ&ЮЬЮЬШ_KЪЮЬ$ЮЬЮЬШ]ЧKШ Ш2KЪЮЬШ KЪЮЬ#ЮЬЮЬШYKЪЮЬ!ЮЬЮЬШUKШKШ ЧШ4KЪЮЬШ KЪЮЬ#ЮЬЮЬШYKЪЮЬ!ЮЬЮЬШUKЪ	ЬЮЬЮЬЮЬЮЬШVKШ ЧKШKШ ЧKЪЬMШMЧЧKШ KЪЮЬШЧ ЕЧ    d  +  