DIRECTORY
CountedVM USING [Handle, Object],
CountedVMSidedoor USING [],
FinalizeOps USING [CallQueue, CreateCallQueue, EnableFinalization, FinalizeProc],
RegisterRefLiteral USING [Create],
VM USING [AddressForPageNumber, Allocate, FalseBool, Free, Interval, LogPageCount, nullInterval, NullInterval, PageCount, PagesForWords, VMPartition, ZeroPageNumber];

CountedVMImpl: CEDAR MONITOR
IMPORTS FinalizeOps, RegisterRefLiteral, VM
EXPORTS CountedVM, CountedVMSidedoor
~ BEGIN

Handle: TYPE ~ CountedVM.Handle;
Object: TYPE ~ CountedVM.Object;
allocatedPages: REF INT м NEW[INT м 0];
allocatedObjects: REF INT м NEW[INT м 0];
freedPages: REF INT м NEW[INT м 0];
freedObjects: REF INT м NEW[INT м 0];
statistics: PUBLIC --CountedVMSidedoor-- LIST OF REF ANY м LIST[MakeAtom["allocatedPages"], allocatedPages, MakeAtom["allocatedObjects"], allocatedObjects, MakeAtom["freedPages"], freedPages, MakeAtom["freedObjects"], freedObjects];

tries: NAT м 3;

AllocateStat: ENTRY PROC [pages: INT] = {
allocatedObjectsн м allocatedObjectsн + 1;
allocatedPagesн м allocatedPagesн + pages;
};

Allocate: PUBLIC PROC [words: INT, 
partition: VM.VMPartition м normalVM, subRange: VM.NullInterval м [0, 0], 
start: VM.ZeroPageNumber м 0, alignment: VM.LogPageCount м 0, in64K: VM.FalseBool м FALSE] RETURNS [h: Handle м NIL] = {
IF words > 0 THEN TRUSTED {
count: VM.PageCount ~ VM.PagesForWords[words];
FOR i: NAT IN [0..tries] DO
interval: VM.Interval ~ VM.Allocate[count: count, partition: partition, subRange: subRange, start: start, alignment: alignment, in64K: in64K
<< This doesn't make much sense in a pcr world....
! VM.CantAllocate => {
IF i = tries THEN REJECT;
SafeStorage.ReclaimCollectibleObjects[suspendMe: TRUE, traceAndSweep: FALSE];
Process.Pause[Process.MsecToTicks[200]];
LOOP;
}
>>
];
h м NEW[Object м [interval: interval, pointer: VM.AddressForPageNumber[interval.page], words: words]];
[] м FinalizeOps.EnableFinalization[h, fq];
AllocateStat[interval.count];
EXIT;
ENDLOOP;
};
};

SimpleAllocate: PUBLIC PROC [words: INT] RETURNS [Handle] = {
RETURN[Allocate[words: words]];
};

Free: PUBLIC ENTRY UNSAFE PROC [handle: Handle] = {
IF handle # NIL AND handle.pointer # NIL AND handle.words # 0 THEN {
interval: VM.Interval м handle.interval;
handle.pointer м NIL;
handle.words м 0;
handle.interval м VM.nullInterval;
TRUSTED {VM.Free[interval]};
freedObjectsн м freedObjectsн + 1;
freedPagesн м freedPagesн + interval.count;
};
handle м NIL;
};

Finalize: FinalizeOps.FinalizeProc ~ {
h: Handle м NARROW[object];
TRUSTED { Free[h] };
};

MakeAtom: PROC [ s: STRING ] RETURNS [ATOM] ~ {
RETURN[NARROW[RegisterRefLiteral.Create[CODE[ATOM], s]]];
};


fq: FinalizeOps.CallQueue ~ FinalizeOps.CreateCallQueue[Finalize];

END.
   ╞  
CountedVMImpl.mesa
Copyright ╙ 1985, 1986, 1989, 1991, 1992 by Xerox Corporation.  All rights reserved.
Taft, December 10, 1983 3:03 pm
Plass, December 21, 1983 1:33 pm
Russ Atkinson (RRA) August 22, 1985 5:31:08 pm PDT
Doug Wyatt, February 26, 1985 10:20:58 am PST
Carl Hauser, March 24, 1988 3:09:29 pm PST
Michael Plass, August 31, 1992 12:00 pm PDT
Chauser, July 30, 1992 11:17 am PDT
Willie-s, August 6, 1991 1:21 pm PDT

statistics: PUBLIC --CountedVMSidedoor-- LIST OF REF ANY = LIST[$allocatedPages, allocatedPages, $allocatedObjects, allocatedObjects, $freedPages, freedPages, $freedObjects, freedObjects];
No ref literals in Cedar Core!
# of times to try to collect extra garbage before giving up
There is a possibility that if we could collect some outstanding goodies that we could get enough VM to make all of this work out OK.  If we have performed enough GCs, though, we allow the signal to percolate upwards.
We can try to free this interval
 Э╩E  ХNewlineDelimiter
Ц(cedarcode) styleЩ codeЪЬЩKЪЬ
╧eЬIЩTKЩKЩ JЩ2KЩ-KЩ*KЩ+KЩ#KЩ$KЩ ЧЪ╧k	Ш	KЪЬ
ЮЬШ!KЪЬЮЬШKШQKЪЬЮЬ
Ш"KЪЮЬЮЬЮШжKШ ЧЪ╧nЬЮЬЮШKЪЮЬ"ЮШ+KЪЮЬШ$KЪЬЮШЧKШ KЪЬЮЬШ KЪЬЮЬШ KЪ	ЬЮЬЮЬЮЬЮЬШ'KЪ	ЬЮЬЮЬЮЬЮЬШ)KЪ	ЬЮЬЮЬЮЬЮЬШ#KЪ	ЬЮЬЮЬЮЬЮЬШ%ЪЬЮЬ╧cЬЮЬЮЬЮЬЮЬЮЬ}Щ╝KЩЧKЪЬЮЬаЬЮЬЮЬЮЬЮЬЮЬйШшKШ ЪЬЮЬШKЪЬ;Щ;KШ ЧЪЯЬЮЬЮЬ	ЮЬШ)KЪЬ*Ш*KЪЬ*Ш*KЪЬШKШ ЧЪЯЬЮЬЮЬ	ЮЬЮЬ#ЮЬ ЮЬ ЮЬЮЬЮЬЮЬЮЬШчЪЮЬЮЬЮЬШKЪЬЮЬЮЬШ.ЪЮЬЮЬЮЬЮШЪЬ
ЮЬЮЬrШМЪ╧y╨by/Ш2Ъб╨kyбШKЪбbгбгбUЩ┘KЪгбгбгбШKЪб1гбгбШMKЪб(Ш(KЪгбШKЪбШЧKЪбШЧKШЧKЪЬЮЬ(ЮЬ5ШfKШ+KЪЬШKЪЮЬШKЪЮЬШЧKШЧKЪЬШKШ ЧЪ
ЯЬЮЬЮЬ	ЮЬЮЬШ=KЪЮЬШKЪЬШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШ3ЪЮЬ
ЮЬЮЬЮЬЮЬЮЬШDKЪЬ Щ KЪЬ
ЮЬШ(KЪЬЮЬШKЪЬШKЪЬ"Ш"KЪЮЬЮЬШKЪЬ"Ш"KЪЬ+Ш+KШЧKЪЬ	ЮЬШKШKШ ЧЪЯЬЮЬШ&KЪЬЮЬ	ШKЪЮЬШKЪЬШЧKШ Ъ
ЯЬЮЬЮЬЮЬЮЬШ/KЪЮЬЮЬЮЬЮЬШ9KЪЬШЧШ KШ ЧШBKШ ЧKЪЮЬШЧ ЕЧ    
к  ╡  