DIRECTORYArpa USING [Address],ArpaExtras USING [MyAddress],Basics USING [HFromCard16],RefText USING [New],SunPMap USING [CallitProc, DumpProc, GetPortProc, ipProtocolUDP, MapEntry, NullProc, SetProc, UnsetProc],SunPMapLocal USING [],SunPMapServer USING [],SunRPC USING [BytesRemaining, Create, Destroy, Error, GetBlock, Handle, PutBlock, SendCallAndReceiveReply, StartCall],SunRPCAuth USING [Conversation, Initiate, Terminate];SunPMapServerImpl: CEDAR MONITORIMPORTS ArpaExtras, Basics, RefText, SunRPC, SunRPCAuthEXPORTS SunPMapLocal, SunPMapServer~ {tableSize: CARDINAL ~ 31;longTimeout: CARD _ 5000;Address: TYPE ~ Arpa.Address;Handle: TYPE ~ SunRPC.Handle;Conversation: TYPE ~ SunRPCAuth.Conversation;MapEntry: TYPE ~ SunPMap.MapEntry;Item: TYPE ~ REF ItemObject;ItemObject: TYPE ~ RECORD [next: Item,entry: MapEntry];Headers: TYPE ~ REF HeadersObject;HeadersObject: TYPE ~ ARRAY [0 .. tableSize) OF Item;headers: Headers _ NEW[HeadersObject];Hash: PROC [program, version: CARD] RETURNS [CARD] ~ {RETURN [(3*program + version) MOD tableSize];};Null: PUBLIC SunPMap.NullProc -- [h: Handle, c: Conversation] -- ~ {NULL;};Set: PUBLIC SunPMap.SetProc -- [h: Handle, c: Conversation, program, version, protocol, port: CARD32] RETURNS [success: BOOL] -- ~ {RETURN [SetLocal[program, version, protocol, port]];};SetLocal: PUBLIC ENTRY PROC [program, version, protocol, port: CARD32]RETURNS [success: BOOL] ~ {index: CARD _ Hash[program, version];FOR item: Item _ headers[index], item.next WHILE item # NIL DOIF (item.entry.program = program) AND (item.entry.version = version) AND (item.entry.protocol = protocol) AND (item.entry.port = port)THEN RETURN [FALSE];ENDLOOP;headers[index] _ NEW[ItemObject _ [headers[index], [program, version, protocol, port]]];RETURN [TRUE];};Unset: PUBLIC SunPMap.UnsetProc -- [h: Handle, c: Conversation, program, version: CARD32] RETURNS [success: BOOL] -- ~ {RETURN [UnsetLocal[program, version]];};UnsetLocal: PUBLIC ENTRY PROC [program, version: CARD32] RETURNS [success: BOOL] ~ {prev, p: Item;index: CARD _ Hash[program, version];success _ FALSE;prev _ NIL; p _ headers[index];DOIF p = NIL THEN RETURN;IF (p.entry.program = program) AND (p.entry.version = version)THEN {success _ TRUE;IF prev = NIL THEN headers[index] _ p.next ELSE prev.next _ p.next;}ELSE {prev _ p;};p _ p.next;ENDLOOP;};GetPort: PUBLIC SunPMap.GetPortProc -- [h: Handle, c: Conversation, program, version, protocol: CARD32] RETURNS [port: CARD32] -- ~ {RETURN [GetPortLocal[program, version, protocol]];};GetPortLocal: PUBLIC ENTRY PROC [program, version, protocol: CARD32]RETURNS [port: CARD32] ~ {index: CARD _ Hash[program, version];FOR item: Item _ headers[index], item.next WHILE item # NIL DOIF (item.entry.program = program) AND (item.entry.version = version) AND (item.entry.protocol = protocol)THEN RETURN [item.entry.port];ENDLOOP;RETURN [0];};Dump: PUBLIC SunPMap.DumpProc -- [h: Handle, c: Conversation, eachMapEntry: PROC[MapEntry]] -- ~ {DumpLocal[eachMapEntry];};DumpLocal: PUBLIC PROC [eachMapEntry: PROC[MapEntry]] ~ {FOR i: CARDINAL IN [0 .. tableSize) DOFOR p: Item _ headers[i], p.next WHILE p # NIL DOeachMapEntry[p.entry];ENDLOOP;ENDLOOP;};Callit: PUBLIC SunPMap.CallitProc -- [h: Handle, c: Conversation, program, version, proc: CARD32, args: REF TEXT] RETURNS [port: CARD32, result: REF TEXT] -- ~ {gotError: BOOL _ FALSE;[port, result] _ CallitLocal[program, version, proc, args, longTimeout, 0! SunRPC.Error => { gotError _ TRUE; CONTINUE }];IF gotError THEN ERROR SunRPC.Error[$abortWithoutReturn];};CallitLocal: PUBLIC PROC [program, version, proc: CARD32, args: REF TEXT, timeout: CARD, retries: CARD] RETURNS [port: CARD32, result: REF TEXT] ~ {hLocal: Handle _ NIL;conversation: Conversation _ NIL;CleanUp: PROC ~ {IF hLocal # NILTHEN { SunRPC.Destroy[hLocal]; hLocal _ NIL };IF conversation # NILTHEN { SunRPCAuth.Terminate[conversation]; conversation _ NIL };};{ ENABLE UNWIND => CleanUp[];bytes: CARDINAL;port _ GetPortLocal[program, version, SunPMap.ipProtocolUDP];IF port = 0 THEN ERROR SunRPC.Error[$serviceNotRegistered];hLocal _ SunRPC.Create[remoteAddress~ArpaExtras.MyAddress[], remotePort~Basics.HFromCard16[port]];conversation _ SunRPCAuth.Initiate[];SunRPC.StartCall[hLocal, conversation, program, version, proc];SunRPC.PutBlock[hLocal, args, 0, args.length];[] _ SunRPC.SendCallAndReceiveReply[hLocal, timeout, retries];bytes _ SunRPC.BytesRemaining[hLocal];result _ RefText.New[bytes];SunRPC.GetBlock[hLocal, result, 0, bytes];};CleanUp[];};}...      SunPMapServerImpl.mesaCopyright ╙ 1987 by Xerox Corporation.  All rights reserved.Demers, November 4, 1987 11:47:53 am PSTParametersTypesMapProceduresIt's okay to do this without holding the monitor lock because REF operations are atomic ... Э╩┬  Ш codeЩKЩ<KЩ(KШ ЧЪ╧k	Ш	KЪЬЭЬШKЪЬЭЬШKЪЬЭЬШKЪЬЭЬШKЪЬЭЬ\ШiKЪЬЭЬШKЪЬЭЬШKЪЬЭЬjШvKЪЬЭЬ$Ш4KШKШ ЧЪ╧nЬЭЬЭШ KЪЭЬ0Ш7KЪЭЬШ#KШheadЩ
KЪЬЭЬШKЪЬЭЬШЧЩKЪЬ	ЭЬШKШ KЪЬЭЬШKЪЬЭЬШ-KШ KЪЬ
ЭЬШ"ЧЩKЪЬЭЬЭЬШЪЬЭЬЭЬШKШKШKШKШ ЧKЪЬ	ЭЬЭЬШ"KЪЬЭЬЭЬЭЬШ5KШ KЪЬЭЬШ&KШ Ъ
ЮЬЭЬЭЬЭЬЭЬШ6KЪЭЬЭЬШ-KШЧЧЩ
ЪЮЬЭЬ╧c"ЬШDJЪЭЬШKШKШ ЧЪЮЬЭЬЯdЬШДKЪЭЬ.Ш4KШKШ ЧЪЮЬЭЬЭЬЭЬ$ЭЬЭЬЭЬШbKЪЬЭЬШ%ЪЭЬ(ЭЬЭЬЭШ>ЪЭЬ ЭЬ ЭЬ"ЭЬШЖKЪЭЬЭЬЭЬШЧKЪЭЬШЧKЪЬЭЬDШXKЪЭЬЭЬШKШKШ ЧЪЮЬЭЬЯTЬШxKЪЭЬ Ш&KШKШ ЧЪЮ
ЬЭЬЭЬЭЬЭЬЭЬЭЬШTKШKЪЬЭЬШ%KЪЬ
ЭЬШKЪЬЭЬШЪЭШKЪЭЬЭЬЭЬЭЬШЪЭЬЭЬШ>ЪЭЬШKЪЬ
ЭЬШKЪЭЬЭЬЭЬЭЬШCKШЧЪЭЬШKШ	KШЧЧKШKЪЭЬШЧKШKШ ЧЪЮЬЭЬЯ]ЬШЕJЪЭЬ,Ш2KШKШ ЧЪЮЬЭЬЭЬЭЬЭЬЭЬЭЬШ_KЪЬЭЬШ%ЪЭЬ(ЭЬЭЬЭШ>ЪЭЬ ЭЬ ЭЬ!ШiKЪЭЬЭЬШЧKЪЭЬШЧKЪЭЬШKШKШ ЧЪЮЬЭЬЯ@ЬШbJЪЬШKШKШ ЧЪЮ	ЬЭЬЭЬЭЬШ9KЩ[ЪЭЬЭЬЭЬЭШ&ЪЭЬЭЬЭЬЭШ1KЪЬШKЪЭЬШЧKЪЭЬШЧKШKШ ЧЪЮЬЭЬЯ{ЬШбJЪЬ
ЭЬЭЬШKЪЬiЭЬЭЬШ{KЪЭЬ
ЭЬЭЬ#Ш9KШKШ ЧЪЮЬЭЬЭЬЭЬЭЬЭЬЭЬЭЬЭЬЭЬ
ЭЬЭЬШФKЪЬЭЬШKЪЬЭЬШ!ЪЮЬЭЬШKЪЭЬ
ЭЬЭЬ$ЭЬШ>KЪЭЬЭЬЭЬ6ЭЬШVKШЧKШ ЪЬЭЬЭЬШKЪЬЭЬШKЪЬ=Ш=KЪЭЬ
ЭЬЭЬ%Ш;KЪЬbШbKШ%KЪЬ?Ш?KЪЬ.Ш.KЪЬ>Ш>KЪЬ&Ш&KЪЬШKЪЬ*Ш*KШЧJШ
KШKШ ЧЧKШЧJШ Ч ЕЧ    "  ф  