
DIRECTORY
Basics USING [Card16FromH],
Commander USING [CommandProc, Register],
SunPMap USING [ipProtocolUDP],
SunPMapLocal USING [SetLocal, UnsetLocal],
SunRPC,
SunRPCOnUDP,
LoganBerrySunRPC,
LoganBerrySunRPCServer;

LoganBerrySunRPCServerStub: CEDAR PROGRAM
IMPORTS Basics, Commander, SunPMapLocal, SunRPC, SunRPCOnUDP, LoganBerrySunRPCServer ~ {
OPEN LoganBerrySunRPC, LoganBerrySunRPCServer;

Handle: TYPE ~ SunRPC.Handle;

CloseCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
db: CARD32;

{
conv ¬ SunRPC.GetCard32[h];
};
{
db ¬ SunRPC.GetCard32[h];
};

[] ¬ Close[h, conv, db];

beginReturn[h];

};

DescribeCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
db: CARD32;
info: SchemaInfo;

{
conv ¬ SunRPC.GetCard32[h];
};
{
db ¬ SunRPC.GetCard32[h];
};

[info] ¬ Describe[h, conv, db];

beginReturn[h];

{
SunRPC.PutRope[h, info.dbName];
MProc12[h, info.logs];
MProc13[h, info.indices];
};
};

EndGenerateCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
cursor: CARD32;

{
conv ¬ SunRPC.GetCard32[h];
};
{
cursor ¬ SunRPC.GetCard32[h];
};

[] ¬ EndGenerate[h, conv, cursor];

beginReturn[h];

};

NextEntryCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
cursor: CARD32;
dir: CursorDirection;
entry: Entry;

{
conv ¬ SunRPC.GetCard32[h];
};
{
cursor ¬ SunRPC.GetCard32[h];
};
{
ord: CARDINAL ¬ SunRPC.GetCard32[h];
dir ¬ VAL[ord];
};

[entry] ¬ NextEntry[h, conv, cursor, dir];

beginReturn[h];

{
MProc14[h, entry];
};
};

DeleteEntryCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
db: CARD32;
key: ROPE;
value: ROPE;

{
conv ¬ SunRPC.GetCard32[h];
};
{
db ¬ SunRPC.GetCard32[h];
};
{
key ¬ SunRPC.GetRope[h];
};
{
value ¬ SunRPC.GetRope[h];
};

[] ¬ DeleteEntry[h, conv, db, key, value];

beginReturn[h];

};

ReadEntryCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
db: CARD32;
key: ROPE;
value: ROPE;
entry: Entry;
others: BOOLEAN;

{
conv ¬ SunRPC.GetCard32[h];
};
{
db ¬ SunRPC.GetCard32[h];
};
{
key ¬ SunRPC.GetRope[h];
};
{
value ¬ SunRPC.GetRope[h];
};

[entry, others] ¬ ReadEntry[h, conv, db, key, value];

beginReturn[h];

{
MProc14[h, entry];
};
{
PutBool[h, others];
};
};

OpenCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
dbName: ROPE;
db: CARD32;

{
conv ¬ SunRPC.GetCard32[h];
};
{
dbName ¬ SunRPC.GetRope[h];
};

[db] ¬ Open[h, conv, dbName];

beginReturn[h];

{
SunRPC.PutCard32[h, db];
};
};

WriteEntryCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
db: CARD32;
entry: Entry;
log: CARD32;
replace: BOOLEAN;

{
conv ¬ SunRPC.GetCard32[h];
};
{
db ¬ SunRPC.GetCard32[h];
};
{
entry ¬ UProc15[h];
};
{
log ¬ SunRPC.GetCard32[h];
};
{
replace ¬ GetBool[h];
};

[] ¬ WriteEntry[h, conv, db, entry, log, replace];

beginReturn[h];

};

GenerateEntriesCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
db: CARD32;
key: ROPE;
start: ROPE;
end: ROPE;
cursor: CARD32;

{
conv ¬ SunRPC.GetCard32[h];
};
{
db ¬ SunRPC.GetCard32[h];
};
{
key ¬ SunRPC.GetRope[h];
};
{
start ¬ SunRPC.GetRope[h];
};
{
end ¬ SunRPC.GetRope[h];
};

[cursor] ¬ GenerateEntries[h, conv, db, key, start, end];

beginReturn[h];

{
SunRPC.PutCard32[h, cursor];
};
};

BuildIndicesCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
db: CARD32;

{
conv ¬ SunRPC.GetCard32[h];
};
{
db ¬ SunRPC.GetCard32[h];
};

[] ¬ BuildIndices[h, conv, db];

beginReturn[h];

};

CompactLogsCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {
conv: CARD32;
db: CARD32;

{
conv ¬ SunRPC.GetCard32[h];
};
{
db ¬ SunRPC.GetCard32[h];
};

[] ¬ CompactLogs[h, conv, db];

beginReturn[h];

};

NullCaller: PROC [h: Handle, beginReturn: SunRPCBeginReturnProc] ~ {

beginReturn[h];

};

SunRPCBeginReturnProc: TYPE ~ PROC [h: Handle];

Server: SunRPC.ServerProc ~ {

ENABLE {
LoganBerrySunRPCServer.Error => { -- (1 )
SunRPC.StartReply[h];
SunRPC.PutRope[h, ec];
SunRPC.PutRope[h, explanation];
GOTO Finished;
};
};

beginReturn: SunRPCBeginReturnProc ~ {
SunRPC.StartReply[h];
SunRPC.PutRope[h, NIL];  -- no error
};

doReply ¬ TRUE;
replyTimeToLive ¬ 2;

SELECT proc FROM
8  => CloseCaller[h, beginReturn];
1  => DescribeCaller[h, beginReturn];
5  => EndGenerateCaller[h, beginReturn];
4  => NextEntryCaller[h, beginReturn];
7  => DeleteEntryCaller[h, beginReturn];
2  => ReadEntryCaller[h, beginReturn];
11 => OpenCaller[h, beginReturn];
6  => WriteEntryCaller[h, beginReturn];
3  => GenerateEntriesCaller[h, beginReturn];
9  => BuildIndicesCaller[h, beginReturn];
10  => CompactLogsCaller[h, beginReturn];
0  => NullCaller[h, beginReturn];
ENDCASE => ERROR SunRPC.Error[$wrongProc];

EXITS
Finished => { NULL }
};


GetBool: PROC [h: SunRPC.Handle] RETURNS [BOOL] ~ INLINE {
RETURN [SunRPC.GetCard32[h] # 0] };
PutBool: PROC [h: SunRPC.Handle, bool: BOOL] ~ INLINE {
SunRPC.PutCard32[h, IF bool THEN 1 ELSE 0] };


MProc14: PROC [h: SunRPC.Handle, val: Entry] ~ {
SunRPC.PutCard32[h, val.length];
FOR i16: CARDINAL IN [0..val.length) DO
SunRPC.PutRope[h, val.body[i16].type];
SunRPC.PutRope[h, val.body[i16].value];
ENDLOOP;
};

MProc13: PROC [h: SunRPC.Handle, val: IndexList] ~ {
SunRPC.PutCard32[h, val.length];
FOR i17: CARDINAL IN [0..val.length) DO
SunRPC.PutRope[h, val.body[i17].key];
SunRPC.PutRope[h, val.body[i17].file];
SunRPC.PutRope[h, val.body[i17].order];
ENDLOOP;
};

MProc12: PROC [h: SunRPC.Handle, val: LogList] ~ {
SunRPC.PutCard32[h, val.length];
FOR i18: CARDINAL IN [0..val.length) DO
SunRPC.PutCard32[h, val.body[i18].id];
SunRPC.PutRope[h, val.body[i18].file];
ENDLOOP;
};

UProc15: PROC [h: SunRPC.Handle] RETURNS [res: Entry] ~ {
{
length20: CARDINAL ~ SunRPC.GetCard32[h];
res ¬  NEW[EntryObject[length20]];
FOR i19: CARDINAL IN [0..length20) DO
res.body[i19].type ¬ SunRPC.GetRope[h];
res.body[i19].value ¬ SunRPC.GetRope[h];
ENDLOOP;
};
};

LoganBerrySunServer: Commander.CommandProc ~ {

sunPgm: CARD ¬ 390905;  -- decimal program number
sunPgmVersion: CARD ¬ 1;

theServer: SunRPC.Server;
[] ¬ SunPMapLocal.UnsetLocal[program~sunPgm, version~sunPgmVersion];  -- in case server already running
theServer ¬ SunRPCOnUDP.CreateServer[pgm~sunPgm, serverProc~Server, version~sunPgmVersion];
[] ¬ SunPMapLocal.SetLocal[program~sunPgm, version~sunPgmVersion, protocol~SunPMap.ipProtocolUDP, port~Basics.Card16FromH[SunRPCOnUDP.GetServerPort[theServer]]];
};

Commander.Register[key: "LoganBerrySunServer", proc: LoganBerrySunServer,  doc: "Install LoganBerry Sun server"];

}...
  ê  
LoganBerrySunRPCServerStub.Mesa
Copyright Ó 1986, 1992 by Xerox Corporation.  All rights reserved.
Adapted from LoganBerryP2205V1ServerImpl.mesa
Doug Terry, September 14, 1989 3:27:15 pm PDT
Brian Oki, May 29, 1990 4:31 pm PDT
Willie-s, April 23, 1992 3:14 pm PDT

Types
[h: Handle, c: Conversation, proc: CARD, clientData: REF] RETURNS [doReply: BOOL, replyTimeToLive: CARDINAL]
Unmarshal / Marshal Procs --
[cmd: Commander.Handle] RETURNS [result: REF ANY _ NIL, msg: ROPE _ NIL]
 Ê	  –(cedarcode) style•NewlineDelimiter
™ šœ™Jšœ	Ïeœ6™BJšœ-™-Icode™-K™#K™$K˜ —šÏk	˜	Kšœžœ˜Kšœ
žœ˜(Kšœžœ˜Kšœžœ˜*Kšœ˜K˜K˜Kšœ˜—K˜ šÏnœžœž˜)Kšžœ*œ'˜XKšžœ*˜.J™ —™K˜ Kšœžœ˜—K˜ šŸœžœ4˜EKšœžœ˜Kšœžœ˜K˜ ˜K˜K˜—˜K˜K˜—K˜ K˜K˜ Kšœ˜K˜ K˜K˜ —šŸœžœ4˜HKšœžœ˜Kšœžœ˜K˜K˜ ˜K˜K˜—˜K˜K˜—K˜ K˜K˜ Kšœ˜K˜ ˜Kšœ˜K˜K˜K˜—K˜K˜ —šŸœžœ4˜KKšœžœ˜Kšœžœ˜K˜ ˜K˜K˜—˜K˜K˜—K˜ K˜"K˜ Kšœ˜K˜ K˜K˜ —šŸœžœ4˜IKšœžœ˜Kšœžœ˜K˜K˜K˜ ˜K˜K˜—˜K˜K˜—˜Kšœžœ˜$Kšœžœ˜K˜—K˜ K˜*K˜ Kšœ˜K˜ ˜K˜K˜—K˜K˜ —šŸœžœ4˜KKšœžœ˜Kšœžœ˜Kšœžœ˜
Kšœžœ˜K˜ ˜K˜K˜—˜K˜K˜—˜K˜K˜—˜K˜K˜—K˜ K˜*K˜ Kšœ˜K˜ K˜K˜ —šŸœžœ4˜IKšœžœ˜Kšœžœ˜Kšœžœ˜
Kšœžœ˜K˜Kšœžœ˜K˜ ˜K˜K˜—˜K˜K˜—˜K˜K˜—˜K˜K˜—K˜ K˜5K˜ Kšœ˜K˜ ˜K˜K˜—˜K˜K˜—K˜K˜ —šŸ
œžœ4˜DKšœžœ˜Kšœžœ˜Kšœžœ˜K˜ ˜K˜K˜—˜K˜K˜—K˜ K˜K˜ Kšœ˜K˜ ˜Kšœ˜K˜—K˜K˜ —šŸœžœ4˜JKšœžœ˜Kšœžœ˜K˜Kšœžœ˜Kšœ	žœ˜K˜ ˜K˜K˜—˜K˜K˜—˜K˜K˜—˜K˜K˜—˜K˜K˜—K˜ K˜2K˜ Kšœ˜K˜ K˜K˜ —šŸœžœ4˜OKšœžœ˜Kšœžœ˜Kšœžœ˜
Kšœžœ˜Kšœžœ˜
Kšœžœ˜K˜ ˜K˜K˜—˜K˜K˜—˜K˜K˜—˜K˜K˜—˜K˜K˜—K˜ K˜9K˜ Kšœ˜K˜ ˜Kšœ˜K˜—K˜K˜ —šŸœžœ4˜LKšœžœ˜Kšœžœ˜K˜ ˜K˜K˜—˜K˜K˜—K˜ K˜K˜ Kšœ˜K˜ K˜K˜ —šŸœžœ4˜KKšœžœ˜Kšœžœ˜K˜ ˜K˜K˜—˜K˜K˜—K˜ K˜K˜ Kšœ˜K˜ K˜K˜ —šŸ
œžœ4˜DK˜ Kšœ˜K˜ K˜K˜ —Kšœžœžœ˜/K˜ šŸœ˜JšÏcœ Q™lK˜ šžœ˜šœ" ˜)Kšœ˜Kšœ˜Kšœ˜Kšžœ
˜Kšœ˜—Kšœ˜—K˜ šœ&˜&Kšœ˜Kšœžœ ˜$K˜—K˜ Kšœ
žœ˜K˜K˜ šžœž˜Kšœ"˜"K˜%K˜(K˜&K˜(K˜&K˜!K˜'K˜,K˜)K˜)Kšœ!˜!Kšžœžœ˜*—K˜ šž˜Kšœžœ˜—K˜—K˜ šœ™K˜ š
Ÿœžœžœžœžœ˜:Kšžœ˜#—šŸœžœžœžœ˜7Kšœžœžœžœ˜-K˜ —K˜ šŸœžœ#˜0Kšœ ˜ šžœžœžœž˜'Kšœ&˜&Kšœ'˜'Kšžœ˜—K˜—K˜ šŸœžœ'˜4Kšœ ˜ šžœžœžœž˜'Kšœ%˜%Kšœ&˜&Kšœ'˜'Kšžœ˜—K˜—K˜ šŸœžœ%˜2Kšœ ˜ šžœžœžœž˜'Kšœ&˜&Kšœ&˜&Kšžœ˜—K˜—K˜ šŸœžœžœ˜9˜Kšœ
žœ˜)Kšœžœ˜"šžœžœžœž˜%K˜'K˜(Kšžœ˜—K˜—K˜—K˜ šŸœ˜.Kšœžœ
žœžœžœžœžœ™HK˜ Kšœžœ ˜1Kšœžœ˜K˜ K˜KšœF !˜gK˜[K˜¡K˜K˜ —K˜qK˜ —K˜— …—    ¾  $¶  