DIRECTORYBasics,BasicTime,Commander,ComputeServerClient,ComputeServer,ComputeServerControl,ComputeServerDebugger,ComputeServerInternal,InterpreterToolPrivate,IO,PrincOps,PupDefs,PupErrors,PupTypes;ComputeServerActiveServicesImpl: CEDAR MONITORIMPORTS BasicTime, ComputeServerInternal, PupErrorsEXPORTS ComputeServerInternal= BEGINSTREAM: TYPE = IO.STREAM;ActiveServicesItem: TYPE = ComputeServerInternal.ActiveServicesItem;ActiveServicesListBase: PUBLIC ComputeServerInternal.ActiveServicesItem _ NIL;ActiveServicesItemObject: TYPE = ComputeServerInternal.ActiveServicesItemObject;PupListener: TYPE = REF ComputeServerInternal.PupListenerObject;AddPupAddress: PUBLIC ENTRY PROC [serverPupAddress: PupDefs.PupAddress, procHandle: ComputeServerInternal.RegisteredProcHandle, listener: PupListener] RETURNS [newItem: ActiveServicesItem] = {newItem _ NEW[ActiveServicesItemObject _ [next: ActiveServicesListBase, listenerPupAddress: serverPupAddress, listener: listener, startListenGMT: BasicTime.Now[], procHandle: procHandle, success: true]];ActiveServicesListBase _ newItem;};MatchPupAddress: PUBLIC ENTRY PROC [serverPupAddress: PupDefs.PupAddress, flagStarted: BOOL] RETURNS [found: BOOL, item: ActiveServicesItem] = {nowItem: ActiveServicesItem _ ActiveServicesListBase ;WHILE nowItem # NIL DOIF serverPupAddress = nowItem.listenerPupAddress THEN {IF flagStarted THEN nowItem.heardDoService _ TRUE;RETURN [TRUE, nowItem];};nowItem _ nowItem.next;ENDLOOP;RETURN[FALSE, NIL];};findDebuggerItemFromInterpreterHandle: PUBLIC ENTRY PROC [h: InterpreterToolPrivate.Handle] RETURNS [found: BOOL, item: ActiveServicesItem _ NIL] = {nowItem: ActiveServicesItem _ ActiveServicesListBase ;WHILE nowItem # NIL DOIF h = nowItem.h THEN RETURN [TRUE, nowItem];nowItem _ nowItem.next;ENDLOOP;RETURN[FALSE, NIL];};KillOldUnstartedServices: PUBLIC PROC = {nowItem: ActiveServicesItem _ ActiveServicesListBase ;lastItem: ActiveServicesItem _ NIL;now: BasicTime.GMT _ BasicTime.Now[];WHILE nowItem # NIL DOIF ~nowItem.heardDoService AND BasicTime.Period[nowItem.startListenGMT, now] > 77 THEN {IF nowItem.listener # NIL THEN ComputeServerInternal.DestroyPupListener[nowItem.listener];nowItem.listener _ NIL;IF lastItem = NIL THEN ActiveServicesListBase _ nowItem.nextELSE lastItem.next _ nowItem.next;};lastItem _ nowItem;nowItem _ nowItem.next;ENDLOOP;};DeletePupAddress: PUBLIC ENTRY PROC [serverPupAddress: PupDefs.PupAddress] RETURNS [found: BOOL] = {nowItem: ActiveServicesItem _ ActiveServicesListBase ;lastItem: ActiveServicesItem _ NIL;WHILE nowItem # NIL DOIF serverPupAddress = nowItem.listenerPupAddress THEN {IF nowItem.listener # NIL THEN ComputeServerInternal.DestroyPupListener[nowItem.listener];nowItem.listener _ NIL;IF lastItem = NIL THEN ActiveServicesListBase _ nowItem.nextELSE lastItem.next _ nowItem.next;RETURN[TRUE];};lastItem _ nowItem;nowItem _ nowItem.next;ENDLOOP;RETURN[FALSE];};END.  „  ComputeServerActiveServicesImpl.mesaThe Compute Server side of the Summoner.  MONITOR to maintain the state of the active services.Last Edited by: Bob Hagmann, May 13, 1985 3:43:48 pm PDTCopyright c 1984 by Xerox Corporation.  All rights reserved.Variable DeclarationsActive Services List MaintenceInitializationBob Hagmann May 13, 1985 3:43:48 pm PDTchanges to: DIRECTORY‌ت"  –"Cedar" styleک headڑœ$™$Ibodyڑœ*دkœ.™_L™8Jڑœ
دmœ1™<code2ڑ‌	ک	Mک MڑœکMک
Mک
MڑœکMڑœکMکMڑœکMڑœکMڑœکMڑ‌œکMک	MڑœکMک
Mڑœ	ک	——ڑœ!‌œ‌ک.Mڑ‌œ,ک3Mڑ‌œکMڑœ‌ک—™Mڑ‌œ‌œ‌œ‌œکIcodeک Nک Icode1ک Oڑœ‌œ,کDNڑœ‌œ,‌œکNNڑœ‌œ2کPOڑœ‌œ‌œ)ک@Jک Jک —ڑœ™ڑ
ذbnœ‌œ‌œ‌œw‌œ"کہMڑœ
‌œ¾کثMڑœ!ک!Mڑœک—ڑںœ‌œ‌œ‌œ5‌œ‌œ	‌œکگMڑœ6ک6ڑ‌œ‌œ‌کڑ‌œ/‌œ‌ک7Mڑ‌œ‌œ‌œک2Mڑ‌œ‌œکMک—MڑœکMڑ‌œک—Mڑ‌œ‌œ‌œکMڑœک—ڑدb%œ‌œ‌œ‌œ$‌œ	‌œ‌œک•Mڑœ6ک6ڑ‌œ‌œ‌کMڑ‌œ‌œ‌œ‌œک-MڑœکMڑ‌œک—Mڑ‌œ‌œ‌œکMڑœک—ڑں ‌œ‌ œک)Mڑœ6ک6Mڑœ‌œک#Mڑœ‌œک%ڑ‌œ‌œ‌کڑ‌œ‌œ4‌œکXMڑ‌œ‌œ‌œ<کZMڑœ‌œکMڑ‌œ‌œ‌œ'‌œک_Mک—MڑœکMڑœکMڑ‌œک—Mڑœک—Mک Mک ڑںœ‌œ‌œ‌œ(‌œ	‌œکdMڑœ6ک6Mڑœ‌œک#ڑ‌œ‌œ‌کڑ‌œ/‌œک7Mڑ‌œ‌œ‌œ<کZMڑœ‌œکMڑ‌œ‌œ‌œ'‌œک_Mڑ‌œ‌œکMڑœک—MڑœکMڑœکMڑ‌œک—Mڑ‌œ‌œکMڑœک—Jک —™Nک Nک Mڑ‌œک—™'Nڑœدr	™—N™ — …—    ھ  P  