DIRECTORY BasicTime USING [GetClockPulses, MicrosecondsToPulses, Pulses], Process USING [Pause, Yield], Xl USING [TQ], XlTQPrivate USING [TQRec, Job], XTkFastAccessPrivate; XTkFastAccessPrivateImpl: CEDAR MONITOR IMPORTS BasicTime, Process EXPORTS Xl<>, XTkFastAccessPrivate ~ BEGIN OPEN XTkFastAccessPrivate; TQRep: PUBLIC TYPE = XlTQPrivate.TQRec; TQ: TYPE = REF TQRep; pieceSize: INT = 8; TQSet: TYPE = REF TQSetRep; TQSetRep: PUBLIC TYPE = RECORD [ pieces: ARRAY [0..pieceSize) OF Xl.TQ м ALL[NIL], --members of set state: ARRAY [0..pieceSize) OF XlTQPrivate.Job м ALL[NIL], --previous state clientAccessible: BOOL м FALSE, nextSet: TQSet м NIL --rarely used as sets are typically quite small ]; freeList: TQSet м NIL; --MONITORED New: ENTRY PROC [link: TQSet м NIL] RETURNS [s: TQSet] = { s м freeList; IF s#NIL THEN freeList м s.nextSet ELSE s м NEW[TQSetRep]; s.clientAccessible м TRUE; s.nextSet м link }; Free: ENTRY PROC [s: TQSet] = { s.pieces м ALL[NIL]; s.state м ALL[NIL]; s.nextSet м freeList; freeList м s }; Include: PUBLIC PROC [set: TQSet, tq: Xl.TQ] RETURNS [s: TQSet] = { IF set=NIL THEN set м New[]; s м set; IF ~s.clientAccessible THEN ERROR; --protects further refs to freed sets DO FOR idx: [0..pieceSize) IN [0..pieceSize) DO IF s.pieces[idx]=tq THEN RETURN; IF s.pieces[idx]=NIL THEN {s.pieces[idx] м tq; RETURN}; ENDLOOP; s м New[s]; ENDLOOP }; limit: BasicTime.Pulses м BasicTime.MicrosecondsToPulses[5000000]; Synchronize: PUBLIC PROC [set: TQSet] = { Init: PROC [set: TQSet] = { WHILE set#NIL DO set.clientAccessible м FALSE; FOR i: [0..pieceSize) IN [0..pieceSize) DO t: TQ м set.pieces[i]; IF t#NIL THEN { IF t.this=NIL AND t.lockCount=0 <> THEN set.pieces[i] м NIL ELSE set.state[i] м t.this; }; ENDLOOP; set м set.nextSet; ENDLOOP; }; Check: PROC [set: TQSet] RETURNS [mustWait: BOOL м FALSE] = { WHILE set#NIL DO FOR i: [0..pieceSize) IN [0..pieceSize) DO t: TQ м set.pieces[i]; IF t#NIL THEN { IF t.this=NIL AND t.lockCount=0 <> THEN set.pieces[i] м NIL ELSE { IF set.state[i] # t.this THEN set.pieces[i] м NIL ELSE {mustWait м TRUE; RETURN} }; }; ENDLOOP; set м set.nextSet; ENDLOOP; }; IF set#NIL THEN { pulses: BasicTime.Pulses; Init[set]; Process.Yield[]; IF Check[set].mustWait THEN { start: BasicTime.Pulses м BasicTime.GetClockPulses[]; DO Process.Pause[5]; Process.Pause[5]; IF ~Check[set].mustWait THEN RETURN; pulses м BasicTime.GetClockPulses[]; IF (pulses-start <>) > limit THEN EXIT; <> ENDLOOP }; Free[set]; --return only the first piece; thats ok since sets are normally small }; }; END. ·XTkFastAccessPrivateImpl.mesa Copyright ╙ 1991 by Xerox Corporation. All rights reserved. Created by Christian Jacobi, July 8, 1991 5:15:35 pm PDT Christian Jacobi, June 15, 1992 10:04 pm PDT Crazy internal module which is used to enable synchronization of stopping the paint processes. Sort of linear search for duplicates, that is ok as sets are small Initializes the state information and nil's out tq's not necesarry to wait for. Returns whether we must wait for a tq; might nil out more... Э╩Ц(cedarcode) styleХNewlineDelimiter ШcodeЪЬЩKЪЬ ╧eЬ1Щ