
DIRECTORY
CedarProcess USING [Process],
Commander USING [CommandObject, Handle],
FS USING [ComponentPositions, Error, ExpandName, StreamOpen],
IO USING [Close, noInputStream, noWhereStream, PutF, PutFL, PutFR, PutRope, STREAM, Value],
IOClasses USING [CreateDribbleOutputStream],
List USING [AList, Assoc, DotCons, PutAssoc],
MakeDo USING [ActionRep, EnumerateResults, NodeClassRep, NodeRep, PublicPartsOfNode, UncurrentProducer],
MakeDoBasics USING [CheckIn, EndFork, Execution, InnerSuspectNodeChange, NeedToFinish, RegisterReporter, Reporter, ReporterRep, SetES],
MakeDoPrivate USING [ActionRep, AddFailedCmd, NodeClassRep, NodeRep],
MoreIOClasses USING [CreateBuffer, SendBuffer],
Process USING [Abort, InvalidProcess],
RefTab USING [Delete],
Rope,
SimpleFeedback USING [Append];


MakeDoReportOnFiles: CEDAR MONITOR
IMPORTS FS, IO, IOClasses, List, MakeDo, MakeDoBasics, MakeDoPrivate, MoreIOClasses, Process, RefTab, Rope, SimpleFeedback
EXPORTS MakeDo

=
BEGIN OPEN MakeDo, MakeDoPrivate, MakeDoBasics;

ROPE: TYPE = Rope.ROPE;
NodeRep: PUBLIC TYPE = MakeDoPrivate.NodeRep;
ActionRep: PUBLIC TYPE = MakeDoPrivate.ActionRep;
NodeClassRep: PUBLIC TYPE = MakeDoPrivate.NodeClassRep;
reporterOnFiles: MakeDoBasics.Reporter ~ NEW [MakeDoBasics.ReporterRep м [
destroyAuxBox: DestroyAuxBox,
auxBoxDestroyed: AuxBoxDestroyed,
buffer: Buffer,
msg: Msg,
flush: Flush
]];

AuxBox: TYPE ~ LIST OF FileExecutionViewer;
auxBox: AuxBox м NIL;

FileExecutionViewer: TYPE ~ REF FileExecutionViewerRep;
FileExecutionViewerRep: TYPE ~ RECORD [
logFileName: ROPE,
logStream: IO.STREAM
];

bufKey: ATOM = $MakeDoBuffer;

logFilePrefix: ROPE м ".makeLog.";

auxBoxOccupancy: INT м 0;
monitor: BOOL м FALSE;

DestroyAuxBox: -- PUBLIC -- PROC ~ {
FOR auxRest: AuxBox м auxBox, auxRest.rest WHILE auxRest # NIL DO
exView: FileExecutionViewer ~ auxRest.first;
exView.logStream.Close[];
ENDLOOP;
auxBox м NIL;
};

AuxBoxDestroyed: -- PUBLIC -- PROC RETURNS [BOOL м TRUE] ~ {
RETURN [auxBox = NIL];
};

Buffer: -- PUBLIC -- ENTRY PROC [e: Execution] = {
ENABLE UNWIND => NULL;
InnerBuffer[e];
RETURN};

InnerBuffer: INTERNAL PROC [e: Execution] = {--structure contorted to avoid Cirio blind spots
ch: Commander.Handle ~ e.ch;
bufout: IO.STREAM = MoreIOClasses.CreateBuffer[];
gname, verless, logFileName, fmterr: ROPE;
logStream: IO.STREAM;
IF AuxBoxDestroyed[] THEN {
auxBoxOccupancy м 0;
};
auxBoxOccupancy м auxBoxOccupancy + 1;
e.bch м NEW [Commander.CommandObject м [
commandLine: "Shouldn't care",
propertyList: List.PutAssoc[bufKey, bufout, CopyAList[ch.propertyList]]
]];
gname м MakeDo.PublicPartsOfNode[e.goal].name;
{lgname: ROPE ~ gname;
fullName: ROPE;
cp: FS.ComponentPositions;
[fullName, cp, ] м FS.ExpandName[lgname !FS.Error => GOTO Genit];
verless м Rope.Substr[base: fullName, start: 0, len: cp.ext.start+cp.ext.length];
logFileName м Rope.Replace[verless, cp.base.start, 0, logFilePrefix];
EXITS Genit => {
logFileName м IO.PutFR["%gAction%g", [rope[logFilePrefix]], [integer[actionCount м actionCount.SUCC]]];
ch.err.PutF["Log for making %g going to %g\n", [rope[gname]], [rope[logFileName]] ]};
};
e.bch.in м IO.noInputStream;
{llogFileName: ROPE ~ logFileName;
llogStream: IO.STREAM;
llogStream м FS.StreamOpen[fileName: llogFileName, accessOptions: create !FS.Error => {
fmterr м IO.PutFR["FS.Error[%g, %g]", [atom[error.code]], [rope[error.explanation]] ];
GOTO Complain}];
logStream м llogStream;
EXITS Complain => {
ch.err.PutF["%g when trying to create command log %g; output will not be logged.\n", [rope[fmterr]], [rope[logFileName]] ];
logStream м IO.noWhereStream}
};
{exView: FileExecutionViewer ~ NEW [FileExecutionViewerRep м [logFileName: logFileName, logStream: logStream]];
this: LIST OF FileExecutionViewer ~ LIST[exView];
e.view м exView;
IF auxBox = NIL
THEN auxBox м this
ELSE { this.rest м auxBox; auxBox м this };
};
e.bch.err м e.bch.out м IOClasses.CreateDribbleOutputStream[bufout, logStream];
e.es м buffered;
};

CopyAList: PUBLIC PROC [old: List.AList] RETURNS [new: List.AList] ~ {
tail: List.AList м NIL;
new м NIL;
UNTIL old = NIL DO
newItem: List.AList м LIST[List.DotCons[key: old.first.key, val: old.first.val]];
IF tail = NIL THEN new м newItem ELSE tail.rest м newItem;
old м old.rest;
tail м newItem;
ENDLOOP;
};


actionCount: INT м 0;

Abandonit: PROC [e: Execution] ~ {
{OPEN e;
IF NeedToFinish[e] THEN {
ENABLE UNWIND => {
EndFork[e.resources];
Flush[e, TRUE, TRUE, a.cmd];
[] м job.processes.Delete[process];
};
IF forked THEN Flush[e, TRUE, TRUE, a.cmd];
a.fails м true;
AddFailedCmd[job, a];
EnumerateResults[a, InnerSuspectNodeChange];
CheckIn[job, goal, a, e.process];
SetES[e, final];
UncurrentProducer[goal];
SimpleFeedback.Append[$MakeDo, oneLiner, $info, "command execution abandoned"];
}
ELSE SimpleFeedback.Append[$MakeDo, oneLiner, $info, "command execution already finishing"];
}};

Stopit: PROC [e: Execution]  = {
message: ROPE м "command execution ABORTed";
IF e.process # NIL AND e.process.status = busy
THEN TRUSTED {Process.Abort[e.process.process !Process.InvalidProcess => {
message м 
IF process#e.process.process THEN "Zowie!  Bug 6 encountered!"
ELSE IF e.process.status=busy THEN "Wow!  CedarProcess bug observed!"
ELSE "Already gone!";
CONTINUE;
}]}
ELSE message м IF e.process = NIL
THEN "Can't ABORT because it's not gotten started yet"
ELSE SELECT e.process.status FROM
done => "Can't ABORT because it's already done",
aborted => "Can't ABORT because it's already ABORTED",
debugging => "Won't ABORT because it's being debugged",
busy => "Wouldn't ABORT because it was not busy a few microseconds ago",
invalid => "Won't ABORT because it's invalid",
ENDCASE => "Won't ABORT because status unrecognized (I'm suffering software rot!)";
SimpleFeedback.Append[$MakeDo, oneLiner, $info,  message];
RETURN};

Gushit: PROC [e: Execution] = {
e.gushMe м TRUE;
};


Msg: -- PUBLIC -- ENTRY PROC [ch: Commander.Handle, format: ROPE, v1, v2, v3, v4, v5: IO.Value м [null[]]] = {
ENABLE UNWIND => NULL;
ch.out.PutFL[format, LIST[v1, v2, v3, v4, v5]];
};

Flush: --PUBLIC-- ENTRY PROC [e: Execution, long, abandon: BOOL, asRope: ROPE] = {
ENABLE UNWIND => NULL;
exView: FileExecutionViewer ~ NARROW[e.view];
bch: Commander.Handle ~ e.bch;
ch: Commander.Handle ~ e.ch;
buffer: IO.STREAM = NARROW[List.Assoc[bufKey, bch.propertyList]];
last: LIST OF FileExecutionViewer м NIL;
IF abandon THEN {
ch.out.PutF["%lAbandoning %g%l\n", [rope["be"]], [rope[asRope]], [rope["BE"]]];
MoreIOClasses.SendBuffer[buffer, ch.out, FALSE];
ch.out.PutRope["\n"];
}
ELSE IF long THEN MoreIOClasses.SendBuffer[buffer, ch.out, TRUE]
ELSE ch.out.PutF["%lDone with %g%l\n", [rope["e"]], [rope[asRope]], [rope["E"]]];
IF AuxBoxDestroyed[] THEN {
auxBoxOccupancy м 0;
}
ELSE FOR cur: LIST OF FileExecutionViewer м auxBox, cur.rest WHILE cur # NIL DO
IF cur.first = exView THEN {
IF last # NIL THEN last.rest м cur.rest ELSE auxBox м cur.rest;
cur.first.logStream.Close[];
auxBoxOccupancy м auxBoxOccupancy - 1;
EXIT;
};
last м cur;
ENDLOOP;
};

MakeDoBasics.RegisterReporter[$FILES, reporterOnFiles];
END.
   К  
MakeDoReportOnFiles.Mesa
Copyright ╙ 1991 by Xerox Corporation.  All rights reserved.
Last tweaked by Mike Spreitzer on April 26, 1990 9:57:00 am PDT
Carl Hauser, April 11, 1985 3:43:34 pm PST
Eduardo Pelegri-Llopart March 20, 1989 9:51:55 am PST
JKF January 11, 1989 10:32:27 am PST
Willie-s, September 27, 1991 4:44 pm PDT
Michael Plass, September 30, 1991 12:51 pm PDT
EXPORTS MakeDo, MakeDoBasics
INVARIANT
The integrity of the aux box data structure.
Viewer Manipulation
CopyAList copies the CONS cells of the list itself and also copies the DotCons cells which are the elements of the list.  Because the DotCons cells are copied, one can change the key-value mappings in the new list without affecting the mappings in the old list. Because the CONS cells are copied, one can alter the list without affecting the old list.
ERROR CommanderOps.Failed["CommandTool.CopyAList is deimplemented"];

 Э╩
  ХNewlineDelimiter
Ц(cedarcode) styleЩ codeЪЬЩKЪЬ
╧eЬ1Щ<KЪЬ?Щ?KЪЬ'╧kЩ*KЪЬ5Щ5KЩ$KЩ(KЩ.ЧKШ ЪЮ	Ш	KЪЬЮЬШKЪЬ
ЮЬШ(KЪЮЬЮЬ5Ш=KЪЮЬЮЬDЮЬ	Ш[KЪЬ
ЮЬШ,KЪЬЮЬ#Ш-KЪЬЮЬ\ШhKЪЬЮЬuШЗKЪЬЮЬ2ШEKЪЬЮЬШ/KЪЬЮЬШ&KЪЬЮЬ
ШKЪЬШKЪЬЮЬ
ШЧKШ KШ Ъ╤bnxЬЮЬЮШ"KЪЮЬЮЬЮЬlШzKЪЮЬЩKЪЮЬШЪЮ	Щ	KЩ,ЧЧKШ KЪЬШKЪЮЬЮЬ%Ш/KШ KЪЮЬЮЬЮЬШKЪЬ	ЮЬЮЬШ-KЪЬЮЬЮЬШ1KЪЬЮЬЮЬШ7headЩЪЬ)ЮЬШJKШKЪЬ!Ш!KЪЬШKЪЬ	Ш	KЪЬШKЪЬШKШ ЧKЪЬЮЬЮЬЮЬШ+KЪЬЮЬШKШ KЪЬЮЬЮЬШ7ЪЬЮЬЮЬШ'KЪЬЮЬШKЪЬЮЬЮШKШЧKШ KЪЬЮЬШKШ ЪЬЮЬШ"KШ ЧKЪЬЮЬШKЪЬ	ЮЬЮЬШKШ Ъ╧nЬ╧cЬЮЬШ$ЪЮЬ(ЮЬЮЬЮШAKШ,KШKЪЮЬШЧKЪЬ	ЮЬШKЪЬШЧKШ ЪаЬбЬЮЬЮЬЮЬЮЬШ<KЪЮЬЮЬШKЪЬШKШ ЧЪаЬбЬЮЬЮЬШ2KЪЮЬЮЬЮЬШKЪЬШKЪЮЬШЧKШ ЪаЬЮЬЮЬб0Ш]KШKЪЬЮЬЮЬ Ш1KЪЬ%ЮЬШ*KЪЬЮЬЮЬШЪЮЬЮЬШKЪЬШKШЧKЪЬ&Ш&ЪЬЮЬШ(KШKЪЬGШGKШЧKЪЬ.Ш.KЪЬ	ЮЬ	ШKЪЬ
ЮЬШKЪЬЮЬШKЪЬЮЬЮЬ
ЮЬШAKЪЬQШQKЪЬEШEЪЮЬШKЪЬЮЬOЮЬШgKЪЬUШUЧKШKЪЬЮЬШKЪЬЮЬШ"KЪЬЮЬЮЬШЪЬЮЬ;ЮЬШWKЪЬ	ЮЬKШVKЪЮЬШЧKЪЬШЪЮЬШKЪЬ{Ш{KЪЬЮЬШЧKЪЬШKЪЬЮЬMШoKЪЬЮЬЮЬЮЬ	Ш1KЪЬЮШЪЮЬ
ЮШKЪЮЬШKЪЮЬ'Ш+ЧKШKЪЬOШOKШKШKШ ЧЪа	ЬЮЬЮЬЮЬШFKЪЬЮЬ∙ЮЬIЩ▀KЪЬЮЬШKЪЬЮЬШ
ЪЮЬЮЬЮШKЪЬЮЬ7ШQKЪЮЬЮЬЮЬЮЬШ:KЪЬШKЪЬШKЪЮЬШЧKЪЮЬ?ЩDKЪЬШKЩ ЧKШ KШ KЪЬЮЬШKШ Ъа	ЬЮЬШ"KЪЬЮЬШЪЮЬЮЬШЪЮЬЮЬШKЪЬШKЪЬ	ЮЬЮЬ	ШKЪЬ#Ш#KЪЬШЧKЪЮЬЮЬ
ЮЬЮЬ	Ш+KШKЪЬШKЪЬ,Ш,KШ!KШKЪЬШKЪЬOШOKШЧKЪЮЬXШ\KШЧKШ ХStartOfExpansionВ -- [parent: REF ANY, clientData: REF ANY _ NIL, mouseButton: Menus.MouseButton _ red, shift: BOOL _ FALSE, control: BOOL _ FALSE]ЪаЬЮЬШ KЪЬ	ЮЬШ,Ц-[message: ROPE, clearFirst: BOOL _ FALSE]ЪЮЬЮЬЮЬШ.ЪЮЬЮЬ>ШJЪЬ
Ш
KЪЮЬЮЬШ>KЪЮЬЮЬЮЬ#ШEKЪЮЬШЧKЪЮЬШ	KЪЬШЧЪЮЬЮЬЮШ!KЪЮЬ2Ш6ЪЮЬЮЬЮШ!KЪЬ0Ш0KЪЬ6Ш6KЪЬ7Ш7KЪЬHШHKЪЬ.Ш.KЪЮЬLШSЧЧЧKЪЬ:Ш:KЪЮЬШЧKШ ЦВ -- [parent: REF ANY, clientData: REF ANY _ NIL, mouseButton: Menus.MouseButton _ red, shift: BOOL _ FALSE, control: BOOL _ FALSE]ЪаЬЮЬШKЪЬЮЬШKШЧKШ KШ ЪаЬбЬЮЬЮЬ ЮЬЮЬШnKЪЮЬЮЬЮЬШKЪЬЮЬШ/KШЧKШ ЪаЬб
ЬЮЬЮЬЮЬ
ЮЬШRKЪЮЬЮЬЮЬШKЪЬЮЬ	Ш-KЪЬШKШKЪЬЮЬЮЬЮЬ'ШAKЪЬЮЬЮЬЮЬШ(ЪЮЬ	ЮЬШKЪЬOШOKЪЬ)ЮЬШ0KШKШЧKЪЮЬЮЬЮЬ*ЮЬШ@KЪЮЬMШQЪЮЬЮЬШKШKШЧЪЮЬЮЬЮЬЮЬ(ЮЬЮЬЮШOЪЮЬЮЬШKЪЮЬЮЬЮЬЮЬШ?KШKШ&KЪЮЬШKШЧKШKЪЮЬШЧKШKШ KШ7ЧЧKЪЮЬШЧ ЕЧ    В  )#  