DIRECTORYAMBridge USING [ TVToProc ],AMEvents USING [ CallDebugger ],AMTypes USING [ Error, TV ],Atom USING [ PutProp, GetPName, GetProp, PropList ],BasicTime USING [ GMT, Now, Unpack, Unpacked ],Commander USING [ CommandProc, GetProperty, Handle, Register ], FS USING [ StreamOpen, Error ],Interpreter USING [ Evaluate ],IO,Log,PrincOps USING [ BytePC, FrameHandle, GFTIndex ],PrincOpsUtils USING [ LongCOPY, GetReturnFrame ],ProcessProps USING [ GetPropList ],RefTab USING [ Create, Fetch, Ref, Store ],Rope USING [ Flatten, InlineLength, ROPE, Text ],SpyTypes USING [ DoWriteDataProc, IsActiveProc, WriteTraceProc ];LogImpl: CEDAR MONITOR -- for CLogIMPORTSAMBridge,AMEvents,AMTypes,Atom,BasicTime,Commander,FS,Interpreter,IO,PrincOpsUtils,ProcessProps,RefTab,RopeEXPORTS Log = {OPEN IO, SpyTypes;pd: PUBLIC REF Log.PD _ NEW[Log.PD_[]];ROPE: TYPE = Rope.ROPE;STREAM: TYPE = IO.STREAM;ThHandle: TYPE = LONG CARDINAL;WhereToReport: TYPE = Log.WhereToReport;WhereProc: TYPE = Log.WhereProc;WP: TYPE = REF WPRec;WPRec: TYPE = RECORD [proc: WhereProc,fixedWhereData: REF,defaultIfNotFound: Log.DNFProc_NIL];RegisterWhereToReport: PUBLIC PROC[proc: WhereProc, where: WhereToReport, fixedWhereData: REF,defaultIfNotFound: Log.DNFProc] = {Atom.PutProp[$ReportStreams, where, NEW[WPRec_[proc: proc, fixedWhereData: fixedWhereData, defaultIfNotFound: defaultIfNotFound]]];};FindWhere: PUBLIC PROC[where: WhereToReport, whereData: REF] RETURNS [s: IO.STREAM] = {wp: WP;IF where=NIL THEN RETURN[pd.sysOut];wp _ NARROW[Atom.GetProp[$ReportStreams, where]];IF wp=NIL THEN RETURN[pd.sysOut];s_wp.proc[wp.fixedWhereData, whereData];IF s#NIL THEN RETURN[s];RETURN[IF s#NIL THEN s ELSE IF wp.defaultIfNotFound=NIL OR wp.defaultIfNotFound[where, whereData] THEN pd.sysOut ELSE NIL];};Report: PUBLIC PROC[remark: ROPE, where: WhereToReport, whereData: REF _NIL] = {reportS: STREAM _ FindWhere[where, whereData];seconds: INT;IF remark=NIL OR reportS = NIL THEN RETURN;seconds _ LogTime[reportS, where];reportS.PutF["   %02d: %s\n", int[seconds], rope[remark]]; -- wish I could affort looking up caller.};ReportFR: PUBLIC PROC[remark: ROPE, where: WhereToReport, whereData: REF,a1, a2: IO.Value] = {Report[IO.PutFR[remark, a1, a2], where, whereData];};Problem: PUBLIC PROC[remark: ROPE, where: WhereToReport, whereData: REF] = TRUSTED {IF remark=NIL THEN remark_"Unspecified problem";Report[remark, where, whereData];IF pd.attended THEN AMEvents.CallDebugger[remark];};ProblemFR: PUBLIC PROC[remark: ROPE, where: WhereToReport, whereData: REF, a1, a2: IO.Value] = TRUSTED {Problem[IO.PutFR[remark, a1, a2], where, whereData];};ProblemBool: PUBLIC PROC[remark: ROPE, where: WhereToReport, bool: BOOL, whereData: REF]RETURNS[sameBool: BOOL] = {sameBool_bool;Problem[remark, where, whereData];};ProblemHandle: PUBLIC PROC[ remark: ROPE, where: WhereToReport, handle: ThHandle, whereData: REF]RETURNS[sameHandle: ThHandle] = {sameHandle_handle;Problem[remark, where, whereData];};CmdWhere: WhereProc = {pl: Atom.PropList _ ProcessProps.GetPropList[];ch: Commander.Handle;IF pl=NIL THEN RETURN[NIL];ch _ NARROW[Commander.GetProperty[$CommanderHandle, pl]];IF ch=NIL THEN RETURN[NIL];RETURN[ch.err];};SetAttended: Commander.CommandProc = {pd.attended _ TRUE;Report["Attended[TRUE]", $Cmd, NIL];};ClearAttended: Commander.CommandProc = {pd.attended _ FALSE;Report["Attended[FALSE]", $Cmd, NIL];};LogTime: PROC[s: IO.STREAM, where: ATOM] RETURNS [seconds: INT] = {oldT: REF BasicTime.Unpacked _ NARROW[RefTab.Fetch[logTimes, where].val];now: BasicTime.GMT _ BasicTime.Now[];nowU: BasicTime.Unpacked _ BasicTime.Unpack[now];seconds _ nowU.second;nowU.second _ 0;nowU.secondsThisYear _ 0;IF oldT=NIL THEN {oldT_NEW[BasicTime.Unpacked];[]_RefTab.Store[logTimes, where, oldT];};IF nowU=oldT^ THEN RETURN;oldT^ _ nowU;s.PutF["%g\n", time[now]];};logTimes: RefTab.Ref _ RefTab.Create[];loggingGroups: PUBLIC CARDINAL_0;Noop: PUBLIC PROC = {NULL};RealLogInfo: TYPE = RECORD [logD1: LONG CARDINAL,logD2: LONG CARDINAL,length: CARDINAL,logCode: PACKED SEQUENCE maxLength: CARDINAL OF CHAR];rli: REF RealLogInfo _ NEW[RealLogInfo];WriteTrace: WriteTraceProc _ NIL;DoWriteData: DoWriteDataProc _ NIL;IsActive: IsActiveProc _ NIL;WriteData: PUBLIC PROC[info: Log.LogInfo] = TRUSTED {logCode: Rope.Text;nbytes: NAT;IF loggingGroups=0 OR info.logCode =NIL THEN RETURN;logCode_Rope.Flatten[Atom.GetPName[info.logCode]];rli.logD1_info.logD1;rli.logD2_info.logD2;nbytes _ MIN[logCode.InlineLength[], 20];rli.length_nbytes;PrincOpsUtils.LongCOPY[from: LOOPHOLE[logCode, LONG POINTER]+2,to: LOOPHOLE[rli,         LONG POINTER]+6, nwords: (nbytes+1)/2];DoWriteData[type: CODE[RealLogInfo], size: SIZE[RealLogInfo[nbytes]], data: LOOPHOLE[rli]];};Here: PUBLIC PROC = TRUSTED {frame: PrincOps.FrameHandle;IF loggingGroups=0 OR ~IsActive[] THEN RETURN;frame _ PrincOpsUtils.GetReturnFrame[];IF frame=NIL THEN RETURN;WriteTrace[frame.accesslink.gfi, frame.pc];};DoLog: PUBLIC PROC[groups: CARDINAL_177777B] = {IF WriteTrace=NIL THEN {WriteTrace _ NARROW[FetchBinding[$WriteTrace], REF WriteTraceProc]^;DoWriteData _ NARROW[FetchBinding[$WriteData], REF DoWriteDataProc]^;IsActive _ NARROW[FetchBinding[$IsActive], REF IsActiveProc]^;};loggingGroups_ IF WriteTrace#NIL THEN groups ELSE 0;};FetchBinding: PROC[field: ATOM] RETURNS [REF] = {RETURN[Atom.GetProp[$Interfaces, field]];};CLog: TYPE = Log.CLog;MakeCLog: PUBLIC PROC[fileName: ROPE, CommandProc: PROC[CLog]_NIL, new: BOOL_FALSE, keep: CARDINAL_2]RETURNS[cLog: CLog_NIL] = {logStream: IO.STREAM;logStream _ FS.StreamOpen[fileName: fileName, keep: keep,accessOptions: IF new THEN $create ELSE $append!FS.Error => logStream_NIL];IF logStream=NIL THEN RETURN[NIL];cLog_NEW[Log.CLogBody_[logStream: logStream, CommandProc: CommandProc]];logStream.SetIndex[0];};WriteCLog: PUBLIC ENTRY PROC[cLog: CLog, entry: ROPE] = {WriteLog[cLog, entry];};CloseCLog: PUBLIC ENTRY PROC[cLog: CLog] RETURNS[nullCLog: CLog_NIL] = {IF cLog=NIL THEN RETURN;IF cLog.logStream#NIL THEN cLog.logStream.Close[];cLog.logStream_NIL;};WriteLog: INTERNAL PROC[cLog: CLog, entry: ROPE] = {cLog.logStream.SetIndex[cLog.logStream.GetLength[]];cLog.logStream.PutRope[entry];cLog.logStream.Flush[];};DoCLog: PUBLIC ENTRY PROC[cLog: CLog, entry: ROPE] = {IF entry#NIL THEN WriteLog[cLog, entry];DOpos: INT _ cLog.logReadPos;IF pos >= cLog.logStream.GetLength[] THEN EXIT;cLog.logStream.SetIndex[cLog.logReadPos];cLog.CommandProc[cLog]; cLog.logReadPos _ cLog.logStream.GetIndex[];IF pos=cLog.logReadPos THEN ERROR; -- Not making progress!ENDLOOP;};RedoCLog: PUBLIC PROC[cLog: CLog] = {cLog.logReadPos_0;DoCLog[cLog, NIL];};GetBinding: PUBLIC PROC[qualifiedName: ROPE] RETURNS [tv: AMTypes.TV] = {tv _ Interpreter.Evaluate[qualifiedName].result;};GetBindingToProc: PUBLIC PROC[qualifiedProcName: ROPE]RETURNS [proc: PROC ANY RETURNS ANY] = TRUSTED {tv: AMTypes.TV = Interpreter.Evaluate[qualifiedProcName].result;IF tv=NIL THEN RETURN[NIL];proc _ LOOPHOLE[AMBridge.TVToProc[tv!AMTypes.Error=>CONTINUE]];};pd.ch _ NARROW[Commander.GetProperty[$CommanderHandle, ProcessProps.GetPropList[]]];IF pd.ch#NIL THEN { pd.sysIn _ pd.ch.in; pd.sysOut _ pd.ch.out; };RegisterWhereToReport[CmdWhere, $Cmd, NIL, NIL];Commander.Register["Attended", SetAttended, "Break on errors"];Commander.Register["Unattended", ClearAttended, "Log on errors, then muddle on."];}.   Ь  LogImpl.mesaSimple Logging output, other general utilities; support for spy log stuff.Last modified by D. Swinehart, June 16, 1984 4:53:57 pm PDTVariablesCopiesReporting and SuspendingAssociates Where atoms with print times.Procedures for performance monitoring and debuggingCommand Logging, indirect execution.Originally developed as part of ThMessageDBImplRuntime BindingInitialization Э╩  Ш JЪЬЩJЪЬJЩJJЪЬ;Щ;JШ Ъ╧k	Ш	JЪЬ	ЭЬШJЪЬ	ЭЬШ JЪЬЭЬШJЪЬЭЬ*Ш4JЪЬ
ЭЬЭЬШ/JЪЬ
ЭЬ1Ш@JЪЭЬЭЬШJЪЬЭЬШJЪЭЬШJШJЪЬ	ЭЬ#Ш1JЪЬЭЬШ1JЪЬЭЬШ#JЪЬЭЬШ+JЪЬЭЬЭЬ	Ш1JЪЬ	ЭЬ2Ш@JШJШ ЧЪЬ	ЭЬЭЬ╧cШ"ЪЭШJШ	JШ	JШJЪЬШJШ
JШ
JЪЭЬШJШJЪЭЬШJЪЬШJЪЬШJШJЪЬШЧЪЭЬШJЪЭЬЭЬШЧJШ ЧJЩ	JШ ЪЬЭЬЭЬЭЬЭЬЭЬШ'JШ ЧЪЬЩJШ JЪЭЬЭЬЭЬШJЪЭЬЭЬЭЬЭЬШJЪЬ
ЭЬЭЬЭЬШJЪЬЭЬШ(JЪЬЭЬШ ЧJШ ЩJЩ JЪЭЬЭЬЭЬШЪЬЭЬЭЬШJШJЪЬЭШJЪЬЭШ"JШJШ ЧЪ╧nЬЭЬЭЬШ#JЪЬ7ЭШ;JЪЬ#Ш#JЪЬ$ЭЬ\ШГJЪЬШЧJШ ЪЯ	ЬЭЬЭЬ"ЭЬЭЬЭЬЭЬШWJЪЬЭЬШJЪЭЬЭЬЭЬЭЬШ$JЪЬЭЬ&Ш1JЪЭЬЭЬЭЬЭЬШ!JШ(JЪЭЬЭЬЭЬЭЬШJЪЭЬЭЬЭЬЭЬЭЬЭЬЭЬЭЬ(ЭЬЭЬЭЬШ{JЪЬШЧJШ ЪЯЬЭЬЭЬ	ЭЬ#ЭЬЭЬШPJЪЬ	ЭЬШ.JЪЬ	ЭЬШJЪЭЬЭЬЭЬЭЬЭЬЭЬШ+JШ"JЪЬ;Ю)ШdJШЧJШ Ъ
ЯЬЭЬЭЬ	ЭЬ#ЭЬШIJЪЬЭЬШJЪЬЭЬ*Ш3JШJШ ЧЪЯЬЭЬШJЪЬЭЬ#ЭЬЭЬШ?JЪЭЬЭЬЭЬШ0JШ!JЪЭЬЭЬШ2JШЧJШ ЪЯ	ЬЭЬШJЪ	ЬЭЬ#ЭЬЭЬ
ЭЬШQJЪЬЭЬ*Ш4JШJШ ЧЪЯЬЭЬШJЪЬЭЬЭЬЭЬШ?JЪЭЬЭЬШJШJЪЬ"Ш"JШЧJЩ ЪЯЬЭЬ
ЭЬШ@JЪЬЭЬШ!JЪЭЬШ!JЪЬШJЪЬ"Ш"JШЧJШ ЪЯЬШJЪЬ/Ш/JЪЬШJЪ
ЭЬЭЬЭЬЭЬЭЬШJЪЬЭЬ.Ш9JЪ
ЭЬЭЬЭЬЭЬЭЬШJЪЭЬ	ШJШЧJШ ЪЯЬШ&JЪЬЭЬШJЪЬЭЬШ$JЪЬШЧJШ ЪЯЬШ(JЪЬЭЬШJЪЬ ЭЬШ%JЪЬШЧJШ ЪЯЬЭЬЭЬЭЬ	ЭЬЭЬЭЬШCJЪЬЭЬЭЬ$ШIJЪЬЭЬШ%JШ1JШJШJШЪЭЬЭЬЭЬШJЪЬЭЬШJШ'JШЧJЪЭЬЭЬЭЬШJШJШJШJШ ЧШ'JЩ(ЧJЩ ЧЪЬ3Щ3JШ JЪЬЭЬЭЬШ!JШ JЪЯЬЭЬЭЬЭЬШJШ ЪЬЭЬЭЬШJЪЬЭЬЭЬШJЪЬЭЬЭЬШJЪЬЭЬШJЪ
Ь	ЭЬЭЬЭЬЭЬЭШ4JШЧJЪЬЭЬЭЬШ(JШ JЪЬЭЬШ!JЪЬЭЬШ#JЪЬЭЬШJШ ЪЯ	ЬЭЬЭЬЭЬШ5JЪЬШJЪЬЭЬШJЪ
ЭЬЭЬЭЬЭЬЭЬШ4JШ2JШJШJЪЬ	ЭЬШ)JЪЬШЪЬШЪЬЭЬ
ЭЬЭЬШ(JЪЬЭЬЭЬЭЬШAЧЧJЪЬЭЬЭЬЭЬШ[JШЧJШ ЪЯЬЭЬЭЬЭЬШJШJЪЭЬЭЬЭЬЭЬШ.JШ'JЪЭЬЭЬЭЬЭЬШJШ+JШЧJШ ЪЯЬЭЬЭЬ	ЭЬШ0ЪЭЬЭЬЭЬШJЪЬЭЬЭЬШDJЪЬЭЬЭЬШEJЪЬЭЬЭЬШ>JШЧJЪ	ЬЭЬЭЬЭЬЭЬШ4JЪЬШЧJШ Ъ
ЯЬЭЬЭЬЭЬЭЬШ1JЪЭЬ#Ш)JШЧJШ ЧJЩ$Щ/JЩ JЪЬЭЬШJШ ЪЯЬЭЬЭЬЭЬЯЬЭЬЭЬЭЬЭЬЭЬШeЪЭЬЭЬШJЪЬЭЬЭЬШЪЬ9Ш9JЪЬЭЬЭЬ	ЭЬ	Ш0JЪЬЭЬШЧJЪ
ЭЬЭЬЭЬЭЬЭЬШ"JЪЬЭЬ@ШHJШJШЧЧJШ ЪЯ	ЬЭЬЭЬШ9JШJШЧJШ ЪЯ	ЬЭЬЭЬЭЬЭЬЭЬШHJЪЭЬЭЬЭЬЭЬШJЪЭЬЭЬЭЬШ2JЪЬЭЬШJШJШ ЧЪЯЬЭЬЭЬЭЬШ4JШ4JШJШJШЧJШ Ъ
ЯЬЭЬЭЬЭЬЭЬШ6JЪЭЬЭЬЭЬШ(ЪЭШJЪЬЭЬШJЪЭЬ#ЭЬЭЬШ/JШ)JШJЪЬ,Ш,JЪЭЬЭЬЭЬЮШ:JЪЭЬШЧJЪЬШЧЧШ ЪЯЬЭЬЭЬШ%JШJЪЬЭЬШJШJШ ЧЧЩJЩ ЪЯ
ЬЭЬЭЬЭЬЭЬЭЬШIJЪЬ0Ш0JШЧJШ ЪЯЬЭЬЭЬЭЬШ6JЪЭЬЭЬЭЬЭЬЭЬЭЬШ0JЪЬ@Ш@JЪ
ЭЬЭЬЭЬЭЬЭЬШJЪЬЭЬ%ЭЬШ?JШЧJШ ЧЩJЩ JЪЬЭЬFШTJЪЭЬЭЬЭЬ1ШBJЪЬ&ЭЬЭЬШ0JШ?JШRЧJШJШ JШ JШ Ч ЕЧ    а  *W  