DIRECTORYIO, AlpineLog, LogBasic, LogRep, Commander, Rope, Process, RestartFile, FileLog, RuntimeError, RedBlackTree;AnalyzeAlpineLog: CEDAR PROGRAMIMPORTS IO, AlpineLog, LogBasic, Commander, Process, RestartFile, RuntimeError, RedBlackTreeEXPORTS SHARES FileLog = BEGINWordNumber: TYPE = LogBasic.WordNumber;logSize: INT; FileLogRecord: TYPE = FileLog.FileLogRecord; pageNode: TYPE = RECORD [file: INT,firstPage, count: INT,occurrenceCount: INT];GetKey: RedBlackTree.GetKey ~ {RETURN[data]};Compare: RedBlackTree.Compare ~ {key: REF pageNode _ NARROW[k];d: REF pageNode _ NARROW[data];IF key.file < d.file THEN RETURN[less];IF key.file > d.file THEN RETURN[greater];IF key.firstPage < d.firstPage THEN RETURN[less];IF key.firstPage > d.firstPage THEN RETURN[greater];IF key.count < d.count THEN RETURN[less];IF key.count > d.count THEN RETURN[greater];RETURN[equal];};Analyze: PROC [out: IO.STREAM] ~ TRUSTED {wordNumberForCheckpointCompleteRecord:  WordNumber _ RestartFile.ReadRestartRecord[].wordNumberForCheckpointCompleteRecord;currentRecord, checkpointRecord, startAnalysisRecord: AlpineLog.RecordID;currentRecordType: LocalRecordType;pageTable: RedBlackTree.Table _ RedBlackTree.Create[ GetKey, Compare ];PrintPageNode: RedBlackTree.EachNode ~ CHECKED {node: REF pageNode _ NARROW[data];out.PutF[ "File %g Page %g Length %g Occurrences %g \n", IO.int[node.file], IO.int[node.firstPage], IO.int[node.count], IO.int[node.occurrenceCount] ];};newNode, oldNode: REF pageNode;TRUSTED { logSize _ LogBasic.LogFileSize[]*256 };[checkpointRecord: checkpointRecord, startAnalysisRecord: startAnalysisRecord] _ CheckpointCompleteRecordFromWord[wordNumberForCheckpointCompleteRecord];TRUSTED {currentRecord _ LogBasic.OpenRecordStreamFromWord[LogBasic.LocateFirstRecord[]].currentRecord;};DO currentRecordType _ PeekType[currentRecord];RecordTypeCount[currentRecordType] _ RecordTypeCount[currentRecordType]+1;IF (currentRecordType = writePages) OR (currentRecordType = writeLeaderPage) THENout.PutF[ "At position %g the record type is %g \n", IO.int[currentRecord.lowBits MOD logSize], IO.rope[RecordTypeName[currentRecordType]]];SELECT currentRecordType FROMwritePages => {header: FileLogRecord[writePages];[] _ AlpineLog.ReadForRecovery[thisRecord: currentRecord, to: [base: @header, length: SIZE[FileLogRecord[writePages]]] ! RuntimeError.UNCAUGHT => CONTINUE];out.PutF[ "\tFileID: %g Pages: %g %g\n", IO.card[LOOPHOLE[header.fileID.id]], IO.card[header.pageRun.firstPage], IO.card[header.pageRun.count]];oldNode _ NARROW[RedBlackTree.Lookup[ pageTable, newNode _ NEW[pageNode _ [LOOPHOLE[header.fileID.id], header.pageRun.firstPage, header.pageRun.count, 1] ]]]; IF oldNode # NIL THEN {oldNode.occurrenceCount _ oldNode.occurrenceCount + 1;}ELSE RedBlackTree.Insert[pageTable, newNode, newNode];};writeLeaderPage => {header: FileLogRecord[writeLeaderPage];[] _ AlpineLog.ReadForRecovery[thisRecord: currentRecord, to: [base: @header, length: SIZE[FileLogRecord[writeLeaderPage]]] ! RuntimeError.UNCAUGHT => CONTINUE];out.PutF[ "\tFileID: %g Count: %g\n", IO.card[LOOPHOLE[header.fileID.id]], IO.card[header.pageCount]];oldNode _ NARROW[RedBlackTree.Lookup[ pageTable, newNode _ NEW[pageNode _ [LOOPHOLE[header.fileID.id], -1, 1, 1] ]]]; IF oldNode # NIL THEN {oldNode.occurrenceCount _ oldNode.occurrenceCount + 1;}ELSE RedBlackTree.Insert[pageTable, newNode, newNode];};ENDCASE => NULL;{endOfLog, truncatedRecord: BOOL;[endOfLog: endOfLog, truncatedRecord: truncatedRecord, currentRecord: currentRecord] _ LogBasic.AdvanceRecordStream[];IF LOOPHOLE[currentRecord.lowBits, INT] MOD logSize = LOOPHOLE[startAnalysisRecord.lowBits, INT] MOD logSize THEN EXIT;};Process.CheckForAbort[];ENDLOOP;LogBasic.CloseRecordStream[];RedBlackTree.EnumerateIncreasing[ pageTable, PrintPageNode ];};PeekType: PROC [thisRecord: AlpineLog.RecordID] RETURNS [localRecordType: LocalRecordType] = TRUSTED {recordTypeHeader: LogRep.RecordTypeHeader;status: AlpineLog.ReadProcStatus;[status: status] _ LogBasic.GetCurrentRecord[currentRecord: thisRecord,to: [base: @recordTypeHeader, length: LogRep.RecordTypeHeader.SIZE]];IF status = sourceExhausted THEN ERROR ;RETURN [GetLocalType[recordTypeHeader.type]];};LocalRecordType: TYPE = { noop, checkpointBegin, checkpointComplete, coordinatorBegin, coordinatorRegisterWorker, coordinatorCollecting, coordinatorCompleting, coordinatorComplete, workerBegin, workerReady, workerCompleting, workerComplete, writePages, writeLeaderPage, setSize, create, delete, lock, reserved, none };RecordTypeName: ARRAY LocalRecordType OF Rope.ROPE =  [ "noop", "checkpointBegin", "checkpointComplete", "coordinatorBegin", "coordinatorRegisterWorker", "coordinatorCollecting", "coordinatorCompleting", "coordinatorComplete", "workerBegin", "workerReady", "workerCompleting", "workerComplete", "writePages", "writeLeaderPage", "setSize", "create", "delete", "lock", "reserved", "none" ];RecordTypeCount: ARRAY LocalRecordType OF INT;GetLocalType: PROC [recordType: AlpineLog.RecordType] RETURNS [localRecordType: LocalRecordType] ~ {SELECT recordType FROMnoop => localRecordType _ noop;checkpointBegin => localRecordType _ checkpointBegin;checkpointComplete => localRecordType _ checkpointComplete;coordinatorBegin => localRecordType _ coordinatorBegin;coordinatorRegisterWorker => localRecordType _ coordinatorRegisterWorker;coordinatorCollecting => localRecordType _ coordinatorCollecting;coordinatorCompleting => localRecordType _ coordinatorCompleting;coordinatorComplete => localRecordType _ coordinatorComplete;workerBegin => localRecordType _ workerBegin;workerReady => localRecordType _ workerReady;workerCompleting => localRecordType _ workerCompleting;workerComplete => localRecordType _ workerComplete;writePages => localRecordType _ writePages;writeLeaderPage => localRecordType _ writeLeaderPage;setSize => localRecordType _ setSize;create => localRecordType _ create;delete => localRecordType _ delete;lock => localRecordType _ localRecordType _ lock;reserved => localRecordType _ reserved;ENDCASE => localRecordType _ none;};CheckpointCompleteRecordFromWord: PROC [checkpointWord: WordNumber] RETURNS [ok: BOOL, checkpointRecord, startAnalysisRecord: AlpineLog.RecordID] = TRUSTED {{checkpointCompleteRecordBody: LogRep.CheckpointCompleteRecord;notStartOfRecord: BOOL;currentRecord: AlpineLog.RecordID;[notStartOfRecord: notStartOfRecord, currentRecord: currentRecord] _LogBasic.OpenRecordStreamFromWord[checkpointWord ! LogBasic.InvalidPage =>GOTO failReturn ];IF notStartOfRecord THEN GOTO failReturn;IF LogBasic.CheckCurrentRecord[].truncated THEN GOTO failReturn;IF LogBasic.GetCurrentRecord[currentRecord, [base: @checkpointCompleteRecordBody,length: SIZE[LogRep.CheckpointCompleteRecord]]].status = destinationFull ORcheckpointCompleteRecordBody.type # checkpointComplete THEN GOTO failReturn;checkpointRecord _ checkpointCompleteRecordBody.thisRecordID;startAnalysisRecord _ checkpointCompleteRecordBody.startAnalysisRecordID;ok _ TRUE;EXITSfailReturn => { ok _ FALSE };};LogBasic.CloseRecordStream[];RETURN [ok, checkpointRecord, startAnalysisRecord];};--CheckpointCompleteRecordFromWordAnalyzeCommand: Commander.CommandProc -- [cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL] --  = {RecordTypeCount _ ALL[0];Analyze[cmd.out];FOR rt: LocalRecordType IN [noop .. none] DOIF RecordTypeCount[rt]#0 THEN cmd.out.PutF[ " %g: %g ",  IO.rope[RecordTypeName[rt]], IO.int[RecordTypeCount[rt]] ];ENDLOOP;};Commander.Register[key: "AnalyzeAlpineLog", proc: AnalyzeCommand, doc: "Scan an alpine log listing the types and sizes of the records found in it."]END.    ¼  AnalyzeAlpineLog.mesaScan an alpine log listing the types and sizes of the records found in it.Last Edited by: Hauser, May 6, 1985 2:55:17 pm PDTCarl Hauser, November 22, 1985 10:20:41 am PSTcurrentRecord _ LogBasic.OpenRecordStreamFromCheckpoint[wordNumberForCheckpointCompleteRecord, checkpointRecord, startAnalysisRecord].currentRecord;-- ! IO.Error => EXITUpdates: Recover.myFileStore.Returns ok = FALSE if any error detected.‌ت2  ک J™J™J™2Icode™.—ڑدk	ک	JڑœkکkJک—ڑœ‌کJڑ‌œUک\Jڑ‌œکJڑ‌œ	کJڑœ‌کJک —Jڑœ'ک'JکJک Jڑœ-ک-Jک ڑœ
‌œ‌œکJڑœ‌œک
Jڑœ‌œکJڑœ‌کJک—Jک ڑœکJکJکJک —ڑœ!ک!Jڑœ‌œکJڑœ‌œکJڑ‌œ‌œ‌œک'Jڑ‌œ‌œ‌œ
ک*Jڑ‌œ‌œ‌œک1Jڑ‌œ‌œ‌œ
ک4Jڑ‌œ‌œ‌œک)Jڑ‌œ‌œ‌œ
ک,Jڑ‌œکJکJک —ڑ
دnœ‌œ‌œ‌œ‌œک*Jڑœ{ک{JڑœIکIJڑœ#ک#JڑœGکGڑœ'‌œک0Jک"Jڑœ—ک—JکJک —JکJک1Jڑœ™ک™Jڑœ”™”Jڑœiکiڑ‌کJڑœ,ک,JڑœJکJJڑœQکQڑœٹکٹJڑœ‌œ
‌™Jڑœک—ڑ‌œ‌کڑœکJڑœ"ک"JڑœV‌œBکœJڑœگکگJڑœ
‌œڈکںڑ‌œ‌œکJک6Jک—Jڑ‌œ2ک6Jڑœک—ڑœکJڑœ'ک'JڑœV‌œGک،JڑœfکfJڑœ
‌œfکvڑ‌œ‌œکJک6Jک—Jڑ‌œ2ک6Jک Jڑœک—Jڑ‌œ‌œک—کJڑœ ک JڑœvکvJڑœwکwJک—JکJڑ‌ک—JڑœکJڑœ=ک=JکJک —ڑدbœ‌œ"‌œ&‌œکfJک*Jک!کGJڑœ>‌œکE—Jڑ‌œ‌œ‌œک(Jڑ‌œ'ک-JکJک —Jڑœ‌œ©ک¾Jک Jڑœ‌œ‌œ‌œزک„Jک Jڑœ‌œ‌œک.Jک ڑںœ‌œ$‌œ'کdڑ‌œ‌کJڑœکJڑœ5ک5Jڑœ;ک;Jڑœ7ک7JڑœIکIJڑœAکAJڑœAکAJڑœ=ک=Jڑœ-ک-Jڑœ-ک-Jڑœ7ک7Jڑœ3ک3Jڑœ+ک+Jڑœ5ک5Jڑœ%ک%Jڑœ#ک#Jڑœ#ک#Jڑœ1ک1Jڑœ'ک'Jڑ‌œک"—JکJک —ڑ‍ œ‌œ‌œکMJڑœ‌œHکPJڑœ™ڑœ)™)JکJک>Jڑœ‌œکJک"کDکJJڑ‌œک——Jڑ‌œ‌œ‌œک)Jڑ‌œ)‌œ‌œک@ڑ‌œOکQJڑœ‌œ=‌کKJڑœ7‌œ‌œکL—Jک=JکIJڑœ‌œک
ڑ‌کJڑœ‌œک—Jک—JکJڑ‌œ-ک3Jڑœدc"ک$Jک —Jک •StartOfExpansionP -- [cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL] -- ڑںœذckOœکyJڑœکJکڑœ*‌ک,Jڑ‌œ‌œWکtJڑ‌œک—JکJک J–\[key: ROPE, proc: Commander.CommandProc, doc: ROPE _ NIL, clientData: REF ANY _ NIL]ڑœ”ک”Jڑ‌œک—— …—    Z  &H  