
DIRECTORY
Arpa USING [Address, MyAddress],
Basics USING [HFromCard16],
RefText USING [New],
SunPMap USING [CallitProc, DumpProc, GetPortProc, ipProtocolUDP, MapEntry, NullProc, SetProc, UnsetProc],
SunPMapLocal USING [],
SunPMapServer USING [],
SunRPC USING [BytesRemaining, Destroy, Error, GetBlock, Handle, PutBlock, SendCallAndReceiveReply, StartCall],
SunRPCOnUDP USING [Create],
SunRPCAuth USING [Conversation, Initiate, Terminate]
;

SunPMapServerImpl: CEDAR MONITOR
IMPORTS Arpa, Basics, RefText, SunRPC, SunRPCOnUDP, 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 м SunRPCOnUDP.Create[remoteAddress~Arpa.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[];
};

}...

   Z  
SunPMapServerImpl.mesa
Copyright ╙ 1987, 1991, 1992 by Xerox Corporation.  All rights reserved.
Demers, November 4, 1987 11:47:53 am PST
Willie-s, August 21, 1991 12:40 pm PDT
Chauser, January 3, 1992 10:57 am PST
Parameters
Types
Map
Procedures
It's okay to do this without holding the monitor lock because REF operations are atomic ...
 Э╩ё  Ц(cedarcode) styleХNewlineDelimiter
Щ codeЩKЪЬ
╧eЬ=ЩHKЩ(KЩ&KЩ%KШ ЧЪ╧k	Ш	KЪЬЮЬШ KЪЬЮЬШKЪЬЮЬШKЪЬЮЬ\ШiKЪЬЮЬШKЪЬЮЬШKЪЬЮЬbШnKЪЬЮЬ
ШKЪЬЮЬ$Ш4KШKШ ЧЪ╧nЬЮЬЮШ KЪЮЬ7Ш>KЪЮЬШ#KШheadЩ
KЪЬЮЬШKЪЬЮЬШЧЩKЪЬ	ЮЬШKШ KЪЬЮЬШKЪЬЮЬШ-KШ KЪЬ
ЮЬШ"ЧЩKЪЬЮЬЮЬШЪЬЮЬЮЬШKШKШKШKШ ЧKЪЬ	ЮЬЮЬШ"KЪЬЮЬЮЬЮЬШ5KШ KЪЬЮЬШ&KШ Ъ
ЯЬЮЬЮЬЮЬЮЬШ6KЪЮЬЮЬШ-KШЧЧЩ
ЪЯЬЮЬ╧c"ЬШDKЪЮЬШ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Ш ЧЪЯЬЮЬа]ЬШЕKЪЮЬ,Ш2KШKШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬШ_KЪЬЮЬШ%ЪЮЬ(ЮЬЮЬЮШ>ЪЮЬ ЮЬ ЮЬ!ШiKЪЮЬЮЬШЧKЪЮЬШЧKЪЮЬШKШKШ ЧЪЯЬЮЬа@ЬШbKЪЬШKШKШ ЧЪЯ	ЬЮЬЮЬЮЬШ9KЩ[ЪЮЬЮЬЮЬЮШ&ЪЮЬЮЬЮЬЮШ1KЪЬШKЪЮЬШЧKЪЮЬШЧKШKШ ЧЪЯЬЮЬа{ЬШбKЪЬ
ЮЬЮЬШKЪЬiЮЬЮЬШ{KЪЮЬ
ЮЬЮЬ#Ш9KШKШ ЧЪЯЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬ
ЮЬЮЬШФKЪЬЮЬШKЪЬЮЬШ!ЪЯЬЮЬШKЪЮЬ
ЮЬ$ЮЬШ>KЪЮЬЮЬ6ЮЬШVKШЧKШ ЪЬЮЬЮЬШKЪЬЮЬШKЪЬ=Ш=KЪЮЬ
ЮЬЮЬ%Ш;KЪЬaШaKШ%KЪЬ?Ш?KЪЬ.Ш.KЪЬ>Ш>KЪЬ&Ш&KЪЬШKЪЬ*Ш*KШЧKШ
KШKШ ЧЧKШЧKШ Ч ЕЧ    (  s  