DIRECTORY
BasicTime,
Commander,
CommanderOps,
Convert, 
ForkOps,
ForkOpsMonitor,
IO,
Process,
Rope,
TerminalIO;

ForkOpsTest: CEDAR MONITOR
IMPORTS BasicTime, Commander, CommanderOps, Convert, ForkOps, ForkOpsMonitor, IO, Process, TerminalIO ~
BEGIN

last: REF Desc ¬ NIL;

lastNumber: INT ¬ 0;
GetNumber: ENTRY PROC [] RETURNS [n: INT] = {
n ¬ lastNumber;
lastNumber ¬ lastNumber+1;
};

Now: PROC [] RETURNS [ms: CARD] = {
p: BasicTime.Pulses ¬ BasicTime.GetClockPulses[];
ms ¬ (BasicTime.PulsesToMicroseconds[p]+500)/1000
};

Desc: TYPE = RECORD [
index: INT,
start: CARD,
ms: INT,
times: INT ¬ -1,
pause: INT ¬ 0
];

ForksPending: Commander.CommandProc ~ {
TerminalIO.PutF1["%g forks pending\n", IO.card[ForkOpsMonitor.Pending[]]];
};

RealReturns: Commander.CommandProc ~ {
TerminalIO.PutF1["%g real returns\n", IO.card[ForkOpsMonitor.RealReturns[]]];
};

RealForks: Commander.CommandProc ~ {
TerminalIO.PutF1["%g real forks\n", IO.card[ForkOpsMonitor.RealForks[]]];
};

YieldCount: Commander.CommandProc ~ {
TerminalIO.PutF1["%g yields to reduce peek congestions\n", IO.card[ForkOpsMonitor.YieldCount[]]];
};

AbortFork: Commander.CommandProc ~ {
ForkOps.Stop[Forkee, last, TRUE];
};

ForkSlow: Commander.CommandProc ~ {
ENABLE Convert.Error => CommanderOps.Failed["needs integer milliseconds"];
d: REF Desc ¬ NEW[Desc];
d.start ¬ Now[];
d.index ¬ GetNumber[];
d.pause ¬ Convert.IntFromRope[CommanderOps.NextArgument[cmd]];
TerminalIO.PutF["Forking no %g for: %g milliseconds\n", IO.int[d.index], IO.int[d.pause]];
last ¬ d;
ForkOps.Fork[Forkee, d];
};

ForkDelayed: Commander.CommandProc ~ {
ENABLE Convert.Error => CommanderOps.Failed["needs integer milliseconds"];
d: REF Desc ¬ NEW[Desc];
d.start ¬ Now[];
d.index ¬ GetNumber[];
d.ms ¬ Convert.IntFromRope[CommanderOps.NextArgument[cmd]];
TerminalIO.PutF["Forking no %g in: %g milliseconds\n", IO.int[d.index], IO.int[d.ms]];
last ¬ d;
ForkOps.ForkDelayed[d.ms, Forkee, d];
};

ForkPeriodically: Commander.CommandProc ~ {
ENABLE Convert.Error => CommanderOps.Failed["needs integer milliseconds and integer times"];
d: REF Desc ¬ NEW[Desc];
d.start ¬ Now[];
d.index ¬ GetNumber[];
d.ms ¬ Convert.IntFromRope[CommanderOps.NextArgument[cmd]];
d.times ¬ Convert.IntFromRope[CommanderOps.NextArgument[cmd]];
TerminalIO.PutF["Periodically forking no %g %g times using: %g milliseconds\n", IO.int[d.index], IO.int[d.times], IO.int[d.ms]];
last ¬ d;
ForkOps.ForkPeriodically[d.ms, Forkee, d];
};

Forkee: PROC [x: REF] ~ {
ENABLE ABORTED => TerminalIO.PutRope["ABORTED\n"];
d: REF Desc ¬ NARROW[x];
now: CARD ¬ Now[];
time: CARD ¬ now-d.start;
d.start ¬ now;
IF d.pause>0 THEN {
Process.PauseMsec[d.pause];
};
TerminalIO.PutF["Perform: %g required %g used %g\n", IO.int[d.index], IO.int[d.ms], IO.card[time]];
IF d.times>=0 THEN {
IF d.times=0 
THEN {
TerminalIO.PutRope["calling Stop\n"];
ForkOps.Stop[Forkee, d];
}
ELSE d.times ¬ d.times -1
};
};

Commander.Register["ForkOps-ForkSlow", ForkSlow, "Test of ForkOps"];
Commander.Register["ForkOps-ForkDelayed", ForkDelayed, "Test of ForkOps"];
Commander.Register["ForkOps-ForkPeriodically", ForkPeriodically, "Test of ForkOps"];
Commander.Register["ForkOps-Pending", ForksPending, "Test of ForkOps"];
Commander.Register["ForkOps-RealForks", RealForks, "Test of ForkOps"];
Commander.Register["ForkOps-RealReturns", RealReturns, "Test of ForkOps"];
Commander.Register["ForkOps-YieldCount", YieldCount, "Test of ForkOps"];
Commander.Register["ForkOps-AbortFork", AbortFork, "Test of ForkOps"];
END.
    Ü  
ForkOpsTest.mesa
Copyright Ó 1993 by Xerox Corporation.  All rights reserved.
Created by Christian Jacobi, April 13, 1993 
Christian Jacobi, May 17, 1993 12:14 pm PDT

This is used to debug the ForkOps package.

 Êª  •NewlineDelimiter
–(cedarcode) style™ code•MarkoutsideHeader™Kšœ
Ïeœ1™<K™,K™+K™ K™*K™ —šÏk	˜	K˜
K˜
K˜K˜	K˜K˜K˜K˜K˜K˜K˜ —šÏnœžœž˜KšžœEžœ˜g—Kšž˜K˜ Kšœžœžœ˜K˜ Kšœžœ˜š
Ÿ	œžœžœžœžœ˜-K˜K˜K˜K˜ —šŸœžœžœžœ˜#K˜1K˜1K˜K˜ —šœžœžœ˜Kšœžœ˜Kšœžœ˜Kšœžœ˜Kšœžœ˜Kšœžœ˜K˜K˜ —šŸœ˜'Kšœ'žœ!˜JK˜K˜ —šŸœ˜&Kšœ&žœ%˜MK˜K˜ —šŸ	œ˜$Kšœ$žœ#˜IK˜K˜ —šŸ
œ˜%Kšœ;žœ$˜aK˜K˜ —šŸ	œ˜$Jšœžœ˜!K˜K˜ —šŸœ˜#KšžœD˜JKšœžœžœ˜K˜K˜K˜>Kšœ8žœžœ˜ZK˜	K˜K˜K˜ —šŸœ˜&KšžœD˜JKšœžœžœ˜K˜K˜K˜;Kšœ7žœžœ˜VK˜	K˜%K˜K˜ —šŸœ˜+KšžœV˜\Kšœžœžœ˜K˜K˜K˜;K˜>KšœPžœžœžœ˜€K˜	K˜*K˜K˜ —šŸœžœžœ˜Kšžœžœ$˜2Kšœžœžœ˜Kšœžœ	˜Kšœžœ˜K˜šžœžœ˜K˜K˜—Kšœ5žœžœžœ˜cšžœžœ˜šžœ˜šžœ˜K˜%K˜K˜—Kšžœ˜—K˜—K˜K˜ —K˜DK˜JK˜TK˜GK˜FK˜JK˜HK˜FKšžœ˜— …—    ª  0  