DIRECTORYAllocatorOps USING[permanentPageZone],Collector USING[InternalReclaim],PrincOps USING[PsbIndex],Process USING[GetCurrent],StorageAccounting USING[defaultCollectionInterval, PSBIMap],SafeStorage USING[];StorageAccountingImpl: MONITOR -- Protects the storage account booksIMPORTS AllocatorOps, Collector, ProcessEXPORTS StorageAccounting, SafeStorage= BEGIN OPEN StorageAccounting;nWordsRequested: PUBLIC INT _ 0;nWordsAllocated: PUBLIC INT _ 0; --  >=  CollectionInterval implies  collectSUMnWordsAllocated: PUBLIC INT _ 0;nWordsReclaimed: PUBLIC INT _ 0;nObjectsCreated: PUBLIC INT _ 0;nObjectsReclaimed: PUBLIC INT _ 0;MapPsbiToWordsAllocated: PUBLIC LONG POINTER TO StorageAccounting.PSBIMap;CollectionInterval: PUBLIC INT _ StorageAccounting.defaultCollectionInterval;SuspensionThreshold: PUBLIC INT _ ComputeSuspensionThreshold[];ComputeSuspensionThreshold: PROC RETURNS[LONG INTEGER] ={RETURN[CollectionInterval+CollectionInterval]};NWordsAllocated: PUBLIC --to SS-- ENTRY SAFE PROCRETURNS[INT] = TRUSTED {ENABLE UNWIND => NULL;RETURN[SUMnWordsAllocated + nWordsAllocated];};NWordsReclaimed: PUBLIC --to SS-- SAFE PROCRETURNS[INT] = TRUSTED {RETURN[nWordsReclaimed];};ConsiderCollection: PUBLIC PROC[requestedWords, suppliedWords: LONG CARDINAL] = {psbi: PrincOps.PsbIndex = LOOPHOLE[Process.GetCurrent[]];nw: LONG INTEGER _ MapPsbiToWordsAllocated.elements[psbi].current + suppliedWords;MapPsbiToWordsAllocated.elements[psbi].current _ nw;nWordsAllocated _ nWordsAllocated + suppliedWords;nWordsRequested _ nWordsRequested + requestedWords;  -- total count for all processesIF LOOPHOLE[nWordsAllocated, INT] >= CollectionInterval OR nw > SuspensionThresholdTHEN Collector.InternalReclaim[allocationInterval, nw > SuspensionThreshold];};SetCollectionInterval: PUBLIC --to SS-- ENTRY SAFE PROC[newInterval: LONG CARDINAL]RETURNS[oldInterval: LONG CARDINAL] = TRUSTED {ENABLE UNWIND => NULL;oldInterval _ CollectionInterval;CollectionInterval _ newInterval;SuspensionThreshold _ ComputeSuspensionThreshold[];};ResetNWordsAllocated: PUBLIC ENTRY PROC = {ENABLE UNWIND => NULL;SUMnWordsAllocated _ SUMnWordsAllocated + nWordsAllocated;nWordsAllocated _ 0;FOR i: PrincOps.PsbIndex IN PrincOps.PsbIndexDOMapPsbiToWordsAllocated.elements[i].total_ MapPsbiToWordsAllocated.elements[i].total+ MapPsbiToWordsAllocated.elements[i].current;MapPsbiToWordsAllocated.elements[i].current _ 0;ENDLOOP;};ResetTotalNWordsAllocatedOnly: PUBLIC ENTRY PROC = {SUMnWordsAllocated _ SUMnWordsAllocated + nWordsAllocated;nWordsAllocated _ 0;};MapPsbiToWordsAllocated _AllocatorOps.permanentPageZone.NEW[StorageAccounting.PSBIMap[LAST[PrincOps.PsbIndex]+1]];FOR i: PrincOps.PsbIndex IN PrincOps.PsbIndexDO MapPsbiToWordsAllocated.elements[i] _ [total: 0, current: 0] ENDLOOP;END.    ╢  StorageAccountingImpl.Mesalast edited January 17, 1984 12:02:04 pm PST by Paul RovnerVARIABLESPROCStotal count for all processes since the last colectionSTART HERE Э╩р  Ш JЪЬЩJЪЬ;Щ;JШ Ъ╧k	Ш	JЪЬЭЬШ&IprocЪЬ
ЭЬШ!JЪЬ	ЭЬШKЪЬЭЬШJЪЬЭЬ%Ш<JЪЬЭЬШЧJШ JЪЬЭЬ╧c%ШDJЪЭЬ!Ш(JЪЭЬШ&JЪЬЭЬЭЬШJЩ JЩ ЪЬ	Щ	JЪЬЭЬЭЬШ JШ JЪЬЭЬЭЬЮ+ШLJЪЬЭЬЭЬШ#JЪЬЭЬЭЬШ JЪЬЭЬЭЬШ JЪЬЭЬЭЬШ"JЪ	ЬЭЬЭЬЭЬЭЬШJJЪЬЭЬЭЬ/ШMJЪЬЭЬЭЬ Ш?ЧJЩ JЩ JЪЬЩJШ Ъ
╧nЬЭЬЭЬЭЬЭЬШ8JЪЬЭЬ)Ш0ЧJШ ЪЯЬЭЬЮ	ЬЭЬЭЬЭШ1JЪЭЬЭЬЭЬЭЬЭЬЭЬШ.JЪЭЬ'Ш-JЪЬШЧJШ Ъ	ЯЬЭЬЮ	ЬЭЬЭШ+JЪЭЬЭЬЭЬШJЪЭЬШJЪЬШЧJШ ЪЯЬЭЬ ЭЬЭЬШQKЪЬЭЬШ9KЪЬЭЬЭЬBШRKЪЬ4Ш4KЪЬ2Ш2KЪЬ6Щ6KЪЬ5Ю ШUЪЭЬЭЬЭЬЭЬШSKЪЭЬIШMЧKЪЬШKШ ЧЪЯЬЭЬЮ	ЬЭЬЭЬЭЬЭЬЭЬШSJЪЭЬЭЬЭЬЭЬЭЬЭЬЭЬШEJЪЬ!Ш!JЪЬ!Ш!JЪЬ3Ш3JЪЬШЧJШ ЪЯЬЭЬЭЬЭЬЭЬЭЬЭЬШAJЪЬ:Ш:JЪЬШЪЭЬЭЬШ-ЪЭШЪЬ)Ш)ЪЬ+Ш+JЪЬ.Ш.ЧЧЧJЪЬ0Ш0JЪЭШЧJЪЬШЧJШ ЪЯЬЭЬЭЬЭЬШ4JЪЬ:Ш:JЪЬШJЪЬШЧJЩ JЩ JЪЬ
Щ
JШ ЪЬШJЪЬЭЬЭЬШYЧJШ ЪЭЬЭЬШ-JЪЭЬ>ЭЬШHЧJШ JЪЭЬШJШ Ч ЕЧ       ╢  