
DIRECTORY Commander, CommanderOps, Convert, IO, Labels, Process, Real, RefText, Rope, ViewerClasses;

ThreadsCountLabel: CEDAR PROGRAM
IMPORTS Commander, CommanderOps, Convert, IO, Labels, Process, Real, RefText, Rope
=

BEGIN

ROPE: TYPE ~ Rope.ROPE;
Viewer: TYPE ~ ViewerClasses.Viewer;

CirioNubThreadDataRep: TYPE ~ MACHINE DEPENDENT RECORD [ --translated from CirioNubTypes.h
index, gen: CARD,
sStat: CARD,
pri: CARD,
dbMsg: INT,
dbFrozen: INT,
pc, sp, fp: POINTER];

Counts: TYPE ~ RECORD [f, ry, rn, m, c, o: NAT м 0];
Style: TYPE ~ {twiddle, count};

pause: INT м 15000;
style: Style м twiddle;
divisor: NAT м 1;
nThreads: INT м 121;
buf: REF TEXT м RefText.New[100];
twiddle: ARRAY [0..3] OF CHAR м ['\\, '|, '/, '-];
hexChars: ARRAY [0..15] OF CHAR ~ ['0, '1, '2, '3, '4, '5, '6, '7, '8, '9, 'A, 'B, 'C, 'D, 'E, 'F];

LocalGetThread: UNSAFE PROC [idx: INT, buf: POINTER TO CirioNubThreadDataRep] RETURNS [INT]
~ UNCHECKED MACHINE CODE {"CirioNubLocalGetThread"};

GetMaxThreads: PROC RETURNS [INT]
~ TRUSTED MACHINE CODE {"CirioNubLocalGetMaxThreads"};

Watch: PROC [but: Viewer] ~ {
twid: [0..255] м 0;
rem: NAT м divisor;
Process.SetPriority[Process.priorityForeground];
DO
counts: Counts м [];
buf: CirioNubThreadDataRep;
desc: ROPE;
nThreads м GetMaxThreads[];
FOR idx: NAT IN [0..nThreads) DO
cc: INT;
TRUSTED {cc м LocalGetThread[idx, @buf]};
IF cc#0 THEN counts.f м counts.f.SUCC
ELSE SELECT buf.sStat FROM
1 => counts.f м counts.f.SUCC;
2 => counts.ry м counts.ry.SUCC;
3 => counts.rn м counts.rn.SUCC;
4 => counts.m м counts.m.SUCC;
5 => counts.c м counts.c.SUCC;
ENDCASE => counts.o м counts.o.SUCC;
ENDLOOP;
IF (rem м rem.PRED) = 0 THEN {
desc м FmtCounts[counts, style, twid];
Labels.Set[but, desc];
rem м divisor};
Process.PauseMsec[pause];
twid м (twid.SUCC) MOD 256;
ENDLOOP;
};

Control: PROC [cmd: Commander.Handle] RETURNS [result: REF ANY м NIL, msg: ROPE м NIL] ~ {
argv: CommanderOps.ArgumentVector ~ CommanderOps.Parse[cmd];
i: NAT м 1;
WHILE i < argv.argc DO
len: INT ~ argv[i].Length;
SELECT TRUE FROM
len = 0 => RETURN [$Failure, usage];
argv[i].Fetch[len-1]='s => {
rl: ROPE ~ argv[i].Substr[len: len-1];
period: REAL м 0.0;
period м Convert.RealFromRope[rl !Convert.Error => {
cmd.err.PutF["Convert.Error near %g trying to parse \"%q\" as a REAL.\n", [integer[index]], [rope[rl]] ];
GOTO Dont}];
IF period < 0.1 OR period > 1.0E3 THEN RETURN [$Failure, IO.PutFR1["Sample period should be in the range [0.1 .. 1000] seconds, not %g", [real[period]] ]];
pause м Real.Round[period*1000];
cmd.out.PutF1["Sampling period set to %g seconds.\n", [real[period]] ];
EXITS Dont => iмi};
argv[i].Fetch[0] = '/ => {
ri: ROPE ~ argv[i].Substr[start: 1];
d: INT ~ Convert.IntFromRope[ri !Convert.Error => {
cmd.err.PutF["Convert.Error near %g trying to parse \"%q\" as an INT.\n", [integer[index]], [rope[ri]] ];
GOTO Dont}];
IF d<1 OR d>65536 THEN RETURN [$Failure, IO.PutFR1["Painting divisor should be in the range [1 .. 65536], not %g", [integer[d]] ]];
divisor м d;
cmd.out.PutF1["Painting divisor set to %g.\n", [integer[d]] ];
EXITS Dont => iмi};
argv[i].Equal["twiddle", FALSE] => style м twiddle;
argv[i].Equal["count", FALSE] => style м count;
ENDCASE => RETURN [$Failure, usage];
i м i.SUCC;
ENDLOOP;
RETURN};

FmtCounts: PROC [counts: Counts, style: Style, it: [0..255]] RETURNS [ROPE] ~ {
buf.length м 0;
buf м RefText.AppendChar[buf, 'f];
buf м Convert.AppendCard[buf, counts.f];
buf м RefText.AppendRope[buf, " ry"];
buf м Convert.AppendCard[buf, counts.ry];
buf м RefText.AppendRope[buf, " rn"];
buf м Convert.AppendCard[buf, counts.rn];
buf м RefText.AppendRope[buf, " m"];
buf м Convert.AppendCard[buf, counts.m];
buf м RefText.AppendRope[buf, " c"];
buf м Convert.AppendCard[buf, counts.c];
buf м RefText.AppendRope[buf, " o"];
buf м Convert.AppendCard[buf, counts.o];
buf м RefText.AppendChar[buf, ' ];
SELECT style FROM
twiddle => buf м RefText.AppendChar[buf, twiddle[it MOD 4]];
count => {
buf м RefText.AppendChar[buf, hexChars[it/16]];
buf м RefText.AppendChar[buf, hexChars[it MOD 16]]};
ENDCASE => ERROR;
RETURN Rope.FromRefText[buf]};

usage: ROPE ~ "Usage: ThreadsCountLabel ( twiddle | count | <seconds>s | /<int>)*";

Start: PROC ~ {
n0: ROPE ~ FmtCounts[[f: 22, rn: 12, m: 13], count, 255];
lab: Viewer ~ Labels.Create[[name: n0]];
TRUSTED {Process.Detach[FORK Watch[lab]]};
Commander.Register["ThreadsCountLabel", Control, usage];
RETURN};

Start[];

END.
    м  
ThreadsCountLabel.mesa
Copyright ╙ 1990, 1992 by Xerox Corporation.  All rights reserved.
Spreitze, November 5, 1990 10:14 am PST
Weiser, May 26, 1992 10:08 pm PDT
 Э╩8  ХNewlineDelimiter
Ц(cedarcode) styleЩ codeЪЬЩKЪЬ
╧eЬ7ЩBKЩ'KЩ!ЧKШ KЪ╧k	Ь#ЮЬ6ШdKШ Ъ╧nЬЮЬЮШ KЪЮЬ#ЮЬ&ШRKШЧKШ KЪЮШKШ KЪЮЬЮЬЮЬШKЪЬЮЬШ$KШ Ъ
ЬЮЬЮЬЮ	ЬЮЬ╧c!ШZKЪЬЮЬШKЪЬЮЬШKЪЬЮЬШ
KЪЬЮЬШKЪЬ
ЮЬШKЪЬЮЬШЧKШ KЪЬЮЬЮЬЮЬШ4KЪЬЮЬШKШ KЪЬЮЬ	ШKШKЪЬ	ЮЬШKЪЬ
ЮЬШKЪЬЮЬЮЬШ!KЪЬ	ЮЬЮЬЮЬШ2KЪЬ
ЮЬ	ЮЬЮЬDШcKШ ЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬШ[KЪЬЮ	ЬЮЬЮЬШ4ЧKШ ЪЯЬЮЬЮЬЮЬШ!KЪЬЮЬЮЬЮЬ Ш6ЧKШ ЪЯЬЮЬШKШKЪЬЮЬШKЪЬ0Ш0ЪЮШKШKШKЪЬЮЬШKШЪЮЬЮЬЮЬЮШ KЪЬЮЬШKЪЮЬ"Ш)KЪЮЬЮЬЮШ%ЪЮЬЮЬЮШKЪЬЮЬШKЪЬЮЬШ KЪЬЮЬШ KЪЬЮЬШKЪЬЮЬШKЪЮЬЮЬШ$ЧKЪЮЬШЧЪЮЬЮЬЮЬШKШ&KШKШЧKШKЪЬЮЬЮЬШKЪЮЬШЧKШЧKШ ЪЯЬЮЬЮЬ
ЮЬЮЬЮЬЮЬЮЬШZKШ<KЪЬЮЬШЪЮЬЮШKЪЬЮЬШЪЮЬЮЬЮШKЪЬЮЬШ$ШKЪЬЮЬШ&KЪЬЮЬШШ4KШiKЪЮЬШЧKЪ
ЮЬЮЬЮЬЮЬЮЬ`ШЫKШ KШGKЪЮЬШЧШKЪЬЮЬШ$ЪЬЮЬ-Ш3KШiKЪЮЬШЧKЪ
ЮЬЮЬ	ЮЬЮЬЮЬXШГKШKШ>KЪЮЬШЧKЪЬЮЬШ3KЪЬЮЬШ/KЪЮЬЮЬШ$ЧKЪЬЮЬШKЪЮЬШЧKЪЮЬШЧKШ ЪЯ	ЬЮЬ.ЮЬЮЬШOKШKШ"KШ(KШ%KШ)KШ%KШ)KШ$KШ(KШ$KШ(KШ$KШ(KШ"ЪЮЬЮШKЪЬ4ЮЬШ<Ш
KШ/KЪЬ*ЮЬШ4ЧKЪЮЬЮЬШЧKЪЮЬШЧKШ KЪЬЮЬHШSKШ ЪЯЬЮЬШKЪЬЮЬ1Ш9KШ(KЪЮЬЮЬШ*KШ8KЪЮЬШЧKШ KШKШ KЪЮЬШЧ ЕЧ    >  "  