
DIRECTORY
RefText USING [New, ObtainScratch, ReleaseScratch, TrustTextRopeAsText],
Rope USING [FromRefText, Flatten, ROPE],

SunRPC,
SunRPCAuth USING [Conversation, Flavor, GetCredentialsAndNextVerifier, maxValueBytes, nullFlavor],
SunRPCNumbers USING [],
SunRPCType USING [AcceptStat, MsgType, ReplyStat, rpcVersion]
;

SunRPCImpl: CEDAR PROGRAM
IMPORTS RefText, Rope, SunRPC, SunRPCAuth
EXPORTS SunRPC, SunRPCNumbers
~ {
OPEN RPCT: SunRPCType;
ROPE: TYPE ~ Rope.ROPE;

Handle: TYPE ~ SunRPC.Handle;

Conversation: TYPE ~ SunRPCAuth.Conversation;
AuthFlavor: TYPE ~ SunRPCAuth.Flavor;
nullFlavor: AuthFlavor ~ SunRPCAuth.nullFlavor;
AuthValue: TYPE ~ REF TEXT;

Error: PUBLIC ERROR [code: ATOM] ~ CODE;
maxRefTextLength: CARDINAL м 8*1024;
maxAuthBytes: CARDINAL ~ SunRPCAuth.maxValueBytes;

GetFlavor: PUBLIC PROC [h: Handle]
RETURNS [flavor: ATOM] ~ {
RETURN [ h.flavor ];
};
StartCall: PUBLIC PROC [h: Handle, c: Conversation, pgm, version, proc: CARD] ~ {
cFlavor, vFlavor: AuthFlavor;
credentials, verifier: AuthValue;

h.procs.prepareForMessage[h];
h.xid м h.xid + 1;
h.authData м c;

SunRPC.PutCard32[h, h.xid]; -- xid
SunRPC.PutCard32[h, ORD[RPCT.MsgType.call]]; -- msgType
SunRPC.PutCard32[h, RPCT.rpcVersion]; -- rpcvers
SunRPC.PutCard32[h, pgm]; -- prog
SunRPC.PutCard32[h, version]; -- vers
SunRPC.PutCard32[h, proc]; -- proc

[cFlavor, credentials, vFlavor, verifier] м SunRPCAuth.GetCredentialsAndNextVerifier[c];
SunRPC.PutCard32[h, cFlavor];
SunRPC.PutCard32[h, credentials.length];
IF credentials.length > 0 THEN SunRPC.PutBlock[h, credentials, 0, credentials.length];
SunRPC.PutCard32[h, vFlavor];
SunRPC.PutCard32[h, verifier.length];
IF verifier.length > 0 THEN SunRPC.PutBlock[h, verifier, 0, verifier.length];
};


StartAcceptReply: PUBLIC PROC [h: Handle, acceptStat: CARD32]
~ {

h.procs.prepareForMessage[h];
SunRPC.PutCard32[h, h.xid]; -- xid
SunRPC.PutCard32[h, ORD[RPCT.MsgType.reply]]; -- msgType
SunRPC.PutCard32[h, ORD[RPCT.ReplyStat.msgAccepted]]; -- replyStat

SunRPC.PutAuth[h, h.authFlavor, NARROW[h.authData]]; -- replyVerifier

SunRPC.PutCard32[h, acceptStat]; -- acceptStat
};

StartRejectReply: PUBLIC PROC [h: Handle, rejectStat: CARD32] ~ {

h.procs.prepareForMessage[h];
SunRPC.PutCard32[h, h.xid]; -- xid
SunRPC.PutCard32[h, ORD[RPCT.MsgType.reply]]; -- msgType
SunRPC.PutCard32[h, ORD[RPCT.ReplyStat.msgDenied]]; -- replyStat
SunRPC.PutCard32[h, rejectStat]; -- rejectStat
};

StartReply: PUBLIC PROC [h: Handle] ~ {
StartAcceptReply[h, ORD[RPCT.AcceptStat.success]];
};

SkipBytes: PUBLIC PROC [h: Handle, bytes: CARDINAL] ~ {
h.procs.skipBytes[h, bytes];
};

GetRefText: PUBLIC PROC [h: Handle] RETURNS [refText: REF TEXT] ~ {
length: CARD м SunRPC.GetCard32[h];
IF length > maxRefTextLength THEN ERROR Error[$outOfBufferSpace];
refText м RefText.New[length];
SunRPC.GetBlock[h, refText, 0, length];
SunRPC.GetAlign[h];
};

GetEphemeralRefText: PUBLIC PROC [h: Handle, oldBuffer: REF TEXT]
RETURNS [newBuffer: REF TEXT] ~ {
length: CARD м SunRPC.GetCard32[h];
IF length > maxRefTextLength THEN ERROR Error[$outOfBufferSpace];
SELECT TRUE FROM
(oldBuffer = NIL) => {
newBuffer м RefText.ObtainScratch[length];
};
(oldBuffer.maxLength < length) => {
RefText.ReleaseScratch[oldBuffer];
newBuffer м RefText.ObtainScratch[length];
};
ENDCASE => {
newBuffer м oldBuffer;
};
IF (newBuffer.length м length) > 0 THEN {
SunRPC.GetBlock[h, newBuffer, 0, length];
SunRPC.GetAlign[h];
};
};

GetRope: PUBLIC PROC [h: Handle] RETURNS [ROPE] ~ {
temp: REF TEXT м GetEphemeralRefText[h, NIL];
result: ROPE м Rope.FromRefText[temp];
RefText.ReleaseScratch[temp];
RETURN [result];
};

GetAuth: PUBLIC PROC [h: Handle] RETURNS [flavor: AuthFlavor, value: AuthValue] ~ {
flavor м [SunRPC.GetCard32[h]];
value м GetEphemeralRefText[h, NIL];
};

GetBool: PUBLIC PROC [h: Handle] RETURNS [BOOL] ~ {
rep: CARD32 ~ SunRPC.GetCard32[h];
RETURN [rep#0]
};

GetInt64: PUBLIC PROC [h: Handle] RETURNS [INT64] ~ {
a: PACKED ARRAY [0..1] OF CARD32;
a[0] м SunRPC.GetCard32[h];
a[1] м SunRPC.GetCard32[h];
RETURN [LOOPHOLE[a]];
};

GetCard64: PUBLIC PROC [h: Handle] RETURNS [CARD64] ~ {
a: PACKED ARRAY [0..1] OF CARD32;
a[0] м SunRPC.GetCard32[h];
a[1] м SunRPC.GetCard32[h];
RETURN [LOOPHOLE[a]];
};

GetReal: PUBLIC PROC [h: Handle] RETURNS [REAL] ~ {
rep: CARD32 ~ SunRPC.GetCard32[h];
RETURN [LOOPHOLE[rep]]
};

oneDRealRep: PACKED ARRAY [0..1] OF CARD32 ~ LOOPHOLE[DREAL[1.0]];
drealHi: [0..1] ~ IF oneDRealRep[1] = 0 THEN 0 ELSE 1;
drealLo: [0..1] ~ 1 - drealHi;
GetDReal: PUBLIC PROC [h: Handle] RETURNS [DREAL] ~ {
a: PACKED ARRAY [0..1] OF CARD32;
a[drealHi] м SunRPC.GetCard32[h];
a[drealLo] м SunRPC.GetCard32[h];
RETURN [LOOPHOLE[a]]
};

PutRefText: PUBLIC PROC [h: Handle, refText: REF READONLY TEXT] ~ {
SunRPC.PutCard32[h, refText.length];
SunRPC.PutBlock[h, refText, 0, refText.length];
SunRPC.PutAlign[h, 0];
};

PutRope: PUBLIC PROC [h: Handle, rope: ROPE] ~ {
IF rope = NIL
THEN {
SunRPC.PutCard32[h, 0];
}
ELSE TRUSTED {
PutRefText[h, RefText.TrustTextRopeAsText[Rope.Flatten[rope]]];
};
};

PutAuth: PUBLIC PROC [h: Handle, flavor: AuthFlavor, value: AuthValue] ~ {
SunRPC.PutCard32[h, flavor];
IF value.length > maxAuthBytes THEN ERROR;
SunRPC.PutCard32[h, value.length];
IF value.length > 0 THEN SunRPC.PutBlock[h, value, 0, value.length];
SunRPC.PutAlign[h, 0];
};

PutBool: PUBLIC PROC [h: Handle, bool: BOOL] ~ {
SunRPC.PutCard32[h, ORD[bool]];
};

PutInt64: PUBLIC PROC [h: Handle, int64: INT64] ~ {
a: PACKED ARRAY [0..1] OF CARD32 м LOOPHOLE[int64];
SunRPC.PutCard32[h, a[0]];
SunRPC.PutCard32[h, a[1]];
};

PutCard64: PUBLIC PROC [h: Handle, card64: CARD64] ~ {
a: PACKED ARRAY [0..1] OF CARD32 м LOOPHOLE[card64];
SunRPC.PutCard32[h, a[0]];
SunRPC.PutCard32[h, a[1]];
};

PutReal: PUBLIC PROC [h: Handle, real: REAL] ~ {
SunRPC.PutCard32[h, LOOPHOLE[real]];
};

PutDReal: PUBLIC PROC [h: Handle, dreal: DREAL] ~ {
a: PACKED ARRAY [0..1] OF CARD32 м LOOPHOLE[dreal];
SunRPC.PutCard32[h, a[drealHi]];
SunRPC.PutCard32[h, a[drealLo]];
};

}...

  (  
SunRPCImpl.mesa
Copyright ╙ 1989, 1991, 1992 by Xerox Corporation.  All rights reserved.
Demers, November 23, 1988 2:45:39 pm PST
Carl Hauser, November 22, 1988 4:01:56 pm PST
Willie-Sue, March 16, 1989 7:03:43 pm PST
Michael Plass, September 23, 1991 11:51 am PDT
David Nichols, January 15, 1991 5:44 pm PST
Willie-s, August 21, 1991 12:27 pm PDT
Chauser, January 3, 1992 1:48 pm PST
Types
Parameters
Clients

Fill in the call message header ...
Servers
Fill in the reply message header ... through acceptStat
Fill in the reply message header ... through rejectStat
Serializing / Deserializing
BEWARE: the returned value is ephemeral (allocated with ObtainScratch rather than New).
Assumes INT64 is big-endian.
Assumes CARD64 is big-endian.
Assumes INT64 is big-endian.
Assumes CARD64 is big-endian.
Э╩╘  ХNewlineDelimiter
Ц(cedarcode) styleЩ codeЩKЪЬ
╧eЬ=ЩHKЩ(KЩ-KЩ)KЩ.KЩ+KЩ&KЩ$KШ ЧЪ╧k	Ш	KЪЬЮЬ;ШHKЪЬЮЬЮЬШ(KШ KЪЬШKЪЬЮЬRШbKЪЬЮЬШKЪЬЮЬ-Ш=KШKШ ЧЪ╧n
ЬЮЬЮШKЪЮЬ"Ш)KЪЮЬШKШKЪЮЬЮЬШheadЩKЪЮЬЮЬЮЬШKШ KЪЬЮЬШKШ KЪЬЮЬШ-ЪЬЮЬШ%KЪЬ/Ш/ЧKЪЬЮЬЮЬЮЬШKШ KЪ
ЯЬЮЬЮЬЮЬЮЬШ(ЧЩ
KЪЬЮЬ
Ш$KЪЬЮЬШ2KШ ЧЩЪ
Я	ЬЮЬЮЬЮЬ
ЮЬШ=KЪЮЬШKЪЬШKЩ ЧЪЯ	ЬЮЬЮЬ2ЮЬШQKШKШ!KШ KШKШKШKШ Щ#KЪЬ╧cШ"KЪЬЮЬЮЬа
Ш7KЪЬЮЬа
Ш0KЪЬаШ!KЪЬаШ%KЪЬаШ"KШ KЪЬXШXKЪЬШKЪЬ(Ш(KЪЮЬЮЬ8ШVKЪЬШKЪЬ%Ш%KЪЮЬЮЬ2ШMЧKШKШ KШ ЧЧЩKШ ЪЯЬЮЬЮЬЮЬШ=KЪЬШKЩ7KШ KШKЪЬаШ"KЪЬЮЬЮЬа
Ш8KЪЬЮЬЮЬаШBKШ KЪЬ ЮЬаШEKШ KЪЬ!аШ.KШKШ ЧЪЯЬЮЬЮЬЮЬШAKЩ7KШ KШKЪЬаШ"KЪЬЮЬЮЬа
Ш8KЪЬЮЬЮЬаШ@KЪЬ!аШ.KШKШ ЧЪЯ
ЬЮЬЮЬШ'KЪЬЮЬЮЬШ2KШKШ ЧЧЩЪЯ	ЬЮЬЮЬЮЬШ7KШKЪЬШЧKШ ЪЯ
ЬЮЬЮЬЮЬЮЬЮЬШCKЪЬЮЬШ#KЪЮЬЮЬЮЬШAKШKШ'KШKШKШ ЧЪЯЬЮЬЮЬ"ЮЬЮЬЮЬШcKЪЬЮЬШ#KЪЮЬЮЬЮЬШAЪЮЬЮЬЮШЪЬЮЬШKЪЬ*Ш*KШЧШ#KЪЬ"Ш"KЪЬ*Ш*KШЧЪЮЬШKШKШЧЧЪЮЬ ЮЬШ)KЪЬ)Ш)KШKШЧKШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШ3KЪЬЮЬЮЬЮЬШ-KЪЬЮЬШ&KШKЪЮЬ
ШKШKШ ЧЪЯЬЮЬЮЬЮЬ+ШSKЩWKЪЬШKЪЬЮЬШ$KШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШ3KЪЬЮЬШ"KЪЮЬШKЪЬШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШ5KЪЬЮЬЩKЪ	ЬЮЬЮЬЮЬЮЬШ!KЪЬШKЪЬШKЪЮЬЮЬШKЪЬШKШ ЧЪ
Я	ЬЮЬЮЬЮЬЮЬШ7KЪЬЮЬЩKЪ	ЬЮЬЮЬЮЬЮЬШ!KЪЬШKЪЬШKЪЮЬЮЬШKЪЬШKШ ЧЪ
ЯЬЮЬЮЬЮЬЮЬШ3KЪЬЮЬШ"KЪЮЬЮЬШKЪЬШKШ ЧKЪЬЮЬЮЬЮЬЮЬЮЬЮЬШBKЪЬЮЬЮЬЮЬШ6KЪЬШЪ
ЯЬЮЬЮЬЮЬЮЬШ5KЪ	ЬЮЬЮЬЮЬЮЬШ!KЪЬ!Ш!KЪЬ!Ш!KЪЮЬЮЬШKЪЬШKШ ЧЪЯ
ЬЮЬЮЬЮЬЮЬЮЬШCKШ$KШ/KШKШKШ ЧЪЯЬЮЬЮЬЮЬШ0ЪЮЬЮШЪЮЬШKЪЬШKШЧЪЮЬЮЬШKЪЬ?Ш?KШЧЧKШKШ ЧЪЯЬЮЬЮЬ6ШJKШKЪЮЬЮЬЮЬШ*KШ"KЪЮЬЮЬ,ШDKШШKШ ЧЧЪЯЬЮЬЮЬЮЬШ0KЪЬЮЬШKЪЬШKШ ЧЪЯЬЮЬЮЬЮЬШ3KЪЬЮЬЩKЪЬЮЬЮЬЮЬЮЬЮЬШ3KЪЬШKЪЬШKЪЬШKШ ЧЪЯ	ЬЮЬЮЬЮЬШ6KЪЬЮЬЩKЪЬЮЬЮЬЮЬЮЬЮЬ	Ш4KЪЬШKЪЬШKЪЬШKШ ЧЪЯЬЮЬЮЬЮЬШ0KЪЬЮЬШ$KЪЬШKШ ЧЪЯЬЮЬЮЬЮЬШ3KЪЬЮЬЮЬЮЬЮЬЮЬШ3KЪЬ Ш KЪЬ Ш KЪЬШKШ ЧKШЧЧKШ Ч ЕЧ    h  #d  