
DIRECTORY
Rope,
SunRPC,
SunRPCAuth,
LoganBerrySunRPC,
LoganBerrySunRPCClient;

LoganBerrySunRPCClientStub: CEDAR PROGRAM
IMPORTS Rope, SunRPC, SunRPCAuth
EXPORTS LoganBerrySunRPCClient ~ {
OPEN LoganBerrySunRPC;

Handle: TYPE ~ SunRPC.Handle;
Conversation: TYPE ~ SunRPCAuth.Conversation;


Error: PUBLIC ErrorType ~ CODE;

GetError: SunRPCGetErrorProc ~ {
ec: ROPE;
explanation: ROPE;
ec м SunRPC.GetRope[h];
IF NOT Rope.IsEmpty[ec] THEN {
explanation м SunRPC.GetRope[h];
ERROR Error[ec, explanation];
};
};


Close: PUBLIC CloseType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, db];
};
GetResults: PROC [h: Handle] ~ {
NULL
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~8 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

Describe: PUBLIC DescribeType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, db];
};
GetResults: PROC [h: Handle] ~ {
info.dbName м SunRPC.GetRope[h];
info.logs м UProc1[h];
info.indices м UProc2[h];
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~1 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

EndGenerate: PUBLIC EndGenerateType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, cursor];
};
GetResults: PROC [h: Handle] ~ {
NULL
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~5 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

NextEntry: PUBLIC NextEntryType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, cursor];
SunRPC.PutCard32[h, ORD[dir]];
};
GetResults: PROC [h: Handle] ~ {
entry м UProc3[h];
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~4 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

DeleteEntry: PUBLIC DeleteEntryType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, db];
SunRPC.PutRope[h, key];
SunRPC.PutRope[h, value];
};
GetResults: PROC [h: Handle] ~ {
NULL
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~7 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

ReadEntry: PUBLIC ReadEntryType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, db];
SunRPC.PutRope[h, key];
SunRPC.PutRope[h, value];
};
GetResults: PROC [h: Handle] ~ {
entry м UProc3[h];
others м SunRPCGetBool[h];
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~2 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

Open: PUBLIC OpenType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutRope[h, dbName];
};
GetResults: PROC [h: Handle] ~ {
db м SunRPC.GetCard32[h];
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~11 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

WriteEntry: PUBLIC WriteEntryType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, db];
MProc4[h, entry];
SunRPC.PutCard32[h, log];
SunRPCPutBool[h, replace];
};
GetResults: PROC [h: Handle] ~ {
NULL
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~6 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

GenerateEntries: PUBLIC GenerateEntriesType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, db];
SunRPC.PutRope[h, key];
SunRPC.PutRope[h, start];
SunRPC.PutRope[h, end];
};
GetResults: PROC [h: Handle] ~ {
cursor м SunRPC.GetCard32[h];
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~3 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

BuildIndices: PUBLIC BuildIndicesType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, db];
};
GetResults: PROC [h: Handle] ~ {
NULL
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~9 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

CompactLogs: PUBLIC CompactLogsType ~ {
PutArgs: PROC [h: Handle] ~ {
SunRPC.PutCard32[h, conv];
SunRPC.PutCard32[h, db];
};
GetResults: PROC [h: Handle] ~ {
NULL
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~10 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};

Null: PUBLIC NullType ~ {
PutArgs: PROC [h: Handle] ~ {
NULL
};
GetResults: PROC [h: Handle] ~ {
NULL
};

SunRPCCall[h~h, remotePgm~2205, remotePgmVersion~1, remoteProc~0 , putArgs~PutArgs, getResults~GetResults, getError~GetError];
};


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

UProc2: PROC [h: SunRPC.Handle] RETURNS [res: IndexList] ~ {
{
length7: CARDINAL ~ SunRPC.GetCard32[h];
res м  NEW[IndexListObject[length7]];
FOR i6: CARDINAL IN [0..length7) DO
res.body[i6].key м SunRPC.GetRope[h];
res.body[i6].file м SunRPC.GetRope[h];
res.body[i6].order м SunRPC.GetRope[h];
ENDLOOP;
};
};

UProc3: PROC [h: SunRPC.Handle] RETURNS [res: Entry] ~ {
{
length11: CARDINAL ~ SunRPC.GetCard32[h];
res м  NEW[EntryObject[length11]];
FOR i10: CARDINAL IN [0..length11) DO
res.body[i10].type м SunRPC.GetRope[h];
res.body[i10].value м SunRPC.GetRope[h];
ENDLOOP;
};
};

UProc1: PROC [h: SunRPC.Handle] RETURNS [res: LogList] ~ {
{
length9: CARDINAL ~ SunRPC.GetCard32[h];
res м  NEW[LogListObject[length9]];
FOR i8: CARDINAL IN [0..length9) DO
res.body[i8].id м SunRPC.GetCard32[h];
res.body[i8].file м SunRPC.GetRope[h];
ENDLOOP;
};
};

MProc4: PROC [h: SunRPC.Handle, val: Entry] ~ {
SunRPC.PutCard32[h, val.length];
FOR i5: CARDINAL IN [0..val.length) DO
SunRPC.PutRope[h, val.body[i5].type];
SunRPC.PutRope[h, val.body[i5].value];
ENDLOOP;
};
sunPgm: CARD м 390905;  -- decimal program number
sunPgmVersion: CARD м 1;

fastTimeout: CARD м 500;
mediumTimeout: CARD м 2000;
defaultRetries: CARD м 5;
noRetries: CARD м 0;

SunRPCPutArgsProc: TYPE ~ PROC [h: Handle];
SunRPCGetResultsProc: TYPE ~ PROC [h: Handle];
SunRPCGetErrorProc: TYPE ~ PROC [h: Handle];

SunRPCCall: PROC [h: SunRPC.Handle, remotePgm, remotePgmVersion, remoteProc: CARD, putArgs: SunRPCPutArgsProc, getResults: SunRPCGetResultsProc, getError: SunRPCGetErrorProc] ~ {
SunRPC.StartCall[h~h, c~SunRPCAuth.Initiate[], pgm~sunPgm, version~sunPgmVersion, proc~remoteProc];
putArgs[h];
[] м SunRPC.SendCallAndReceiveReply[h~h, timeoutMsec~mediumTimeout, retries~defaultRetries];
getError[h];
getResults[h];
SunRPC.ReleaseReply[h];
};

}...
  ш  
LoganBerrySunRPCClientStub.Mesa
Copyright ╙ 1986, 1992 by Xerox Corporation.  All rights reserved.
Doug Terry, September 14, 1989 3:30:52 pm PDT
Adapted from LoganBerryP2205V1ClientImpl.mesa
Willie-s, April 23, 1992 3:07 pm PDT
Errors
GetErrorProc

Remote Procedures --
Unmarshal / Marshal Procs --

Placing calls --

This is where this module differs most from the Courier stub from which it is derived.  We define a SunRPCCall that looks similar to the CrRPC.Call and hides the differences in calling sequences between the two protocols.  

Since SUN RPC doesn't have any error handling mechanism, remote errors are returned as explict error codes.  An error code is at the head of all returned results.  If the returned error code is NIL, then the regular procedure results follow; otherwise, the error code is followed by the error explanation.

Note: we ignore the passed remotePgm number and version (its the Courier one).
The following will not be called if getError raises an Error.

 Э╩╩  Ц(cedarcode) styleХNewlineDelimiter
Щ ЪЬЩJЪЬ	╧eЬ6ЩBIcodeЩ-JЪЬ-Щ-JЩ$KШ ЧЪ╧k	Ш	KШKЪЬШKЪЬШKЪЬШKЪЬШЧKШ Ъ╧nЬЮЬЮШ)KЪЮЬШ KЪЮЬШ"KЪЮЬШKШ KЪЬЮЬШKЪЬ-Ш-ЧKШ ЪЬЩKШ KЪЯЬЮЬЮЬШKШ ЧЪЬЩJЩ ЪЯЬШ 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Ш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Ш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Ш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ЪЮЬШ#ЧЪЯЬЮЬЮЬЮЬШ=KЪЬЮЬЮЬЮЬШ-KШ ЧЪЯЬЮЬЮЬШ<ШKЪЬ	ЮЬШ(KЪЬЮЬШ%ЪЮЬЮЬЮЬЮШ#KШ%KШ&KШ'KЪЮЬШЧKШЧKШЧKШ ЪЯЬЮЬЮЬШ8ШKЪЬ
ЮЬШ)KЪЬЮЬШ"ЪЮЬЮЬЮЬЮШ%KШ'KШ(KЪЮЬШЧKШЧKШKШ ЧЪЯЬЮЬЮЬШ:ШKЪЬ	ЮЬШ(KЪЬЮЬШ#ЪЮЬЮЬЮЬЮШ#KШ&KШ&KЪЮЬШЧKШЧKШKШ ЧЪЯЬЮЬ#Ш/KЪЬ Ш ЪЮЬЮЬЮЬЮШ&KЪЬ%Ш%KЪЬ&Ш&KЪЮЬШЧKШЧЧJЩ ЪЬЩJЩ JЩТJЩ KЪЬЮЬ╧cШ1KЪЬЮЬШKШ KЪЬЮЬШKЪЬЮЬШKЪЬЮЬШKЪЬЮЬШKШ KЪЬЮЬЮЬШ+KЪЬЮЬЮЬШ.KЪЬЮЬЮЬШ,KШ ЪЯ
ЬЮЬ=ЮЬaШ▓JЪЬNЩNKЪЬcШcKЪЬШKШ\KЪЬШJЪЬ=Щ=KЪЬШKШKШЧJЩ KШ ЧKШЧ ЕЧ    \  %  