DIRECTORY
Convert,
Rope,
SunRPCAuth,
SunRPC,
SunRPCOnUDP,
SunRPCOnNetworkStream,
UXStrings;

SunRPCTest: CEDAR PROGRAM
IMPORTS Convert, Rope, SunRPCAuth, SunRPC, SunRPCOnUDP, SunRPCOnNetworkStream, UXStrings
~ BEGIN

client: SunRPC.Handle;
conversation: SunRPCAuth.Conversation;

server: SunRPCOnNetworkStream.Server;
serverAddress: Rope.ROPE;

pgm: CARD ~ 123456;
version: CARD ~ 10245;

nullProc: CARD ~ 0;
echoProc: CARD ~ 1;

StartTCPServer: PROC [] RETURNS [UXStrings.CString] ~ {
server ¬ SunRPCOnNetworkStream.CreateServer[pgm, version, IServe, $ARPA, NIL, NIL];
serverAddress ¬ SunRPCOnNetworkStream.GetServerAddress[server].local;
RETURN [UXStrings.Create[serverAddress]];
};

StopServer: PROC [] RETURNS [] ~ {
SunRPC.DestroyServer[server];
};

udpserverport: SunRPCOnUDP.Port;
StartUDPServer: PROC [] RETURNS [UXStrings.CString] ~ {
server ¬ SunRPCOnUDP.CreateServer[pgm, version, IServe];
udpserverport ¬ SunRPCOnUDP.GetServerPort[server];
RETURN [UXStrings.Create[Convert.RopeFromCard[LOOPHOLE[udpserverport]]]];
};


IServe: SunRPC.ServerProc ~ {
SELECT proc FROM
0 => {
h.StartReply[];
RETURN[TRUE, 10];
};
1 => {
text: Rope.ROPE ¬ h.GetRope[];
h.StartReply[];
h.PutRope[text];
RETURN[TRUE, 10];
};
ENDCASE => RETURN[FALSE, 10];
};

LocalTCP: PROC [] RETURNS [] ~ {
client ¬ SunRPCOnNetworkStream.Create[$ARPA, serverAddress];
conversation ¬ SunRPCAuth.Initiate[myName: "Chauser"];
};

LocalUDP: PROC [] RETURNS [] ~ {
client ¬ SunRPCOnUDP.Create[remotePort~udpserverport];
conversation ¬ SunRPCAuth.Initiate[myName: "Chauser"];
};

RemoteTCP: PROC [address: UXStrings.CString] RETURNS [] ~ {
client ¬ SunRPCOnNetworkStream.Create[$ARPA, UXStrings.ToRope[address, 100]];
conversation ¬ SunRPCAuth.Initiate[myName: "Chauser"];
};

RemoteUDP: PROC [address: UXStrings.CString, port: SunRPCOnUDP.Port] RETURNS [] ~ {
client ¬ SunRPCOnUDP.Create[Convert.ArpaAddressFromRope[UXStrings.ToRope[address, 100]], port];
conversation ¬ SunRPCAuth.Initiate[myName: "Chauser"];
};

ReleaseClient: PROC [] RETURNS [] ~ {
SunRPC.Destroy[client];
};

CallNullProc: PROC [] RETURNS [] ~ {
client.StartCall[conversation, pgm, version, nullProc];
client.SendCallAndReceiveReply[];
};

CallNull100: PROC [] RETURNS [] ~ {
FOR i: INT IN [0..100) DO
client.StartCall[conversation, pgm, version, nullProc];
client.SendCallAndReceiveReply[];
ENDLOOP;
};

CallNullN: PROC [n: INT] RETURNS [] ~ {
FOR i: INT IN [0..n) DO
client.StartCall[conversation, pgm, version, nullProc];
client.SendCallAndReceiveReply[500, 5];
ENDLOOP;
};

CallEchoProc: PROC[] RETURNS [Rope.ROPE] ~ {
client.StartCall[conversation, pgm, version, echoProc];
client.PutRope["Test Message"];
client.SendCallAndReceiveReply[];
RETURN[client.GetRope[]];
};

CallPMap0: PROC[]  ~ {
client.StartCall[conversation, 100000, 2, 0];
client.SendCallAndReceiveReply[];
RETURN[];
};

CallPMap0N: PROC[n: INT]  ~ {
FOR i: INT IN [0..n) DO
client.StartCall[conversation, 100000, 2, 0];
client.SendCallAndReceiveReply[];
ENDLOOP;
RETURN[];
};

DumpPMap: PROC[] RETURNS [UXStrings.CString] ~ {
result: Rope.ROPE;
client.StartCall[conversation, 100000, 2, 4];
client.SendCallAndReceiveReply[];
DO
more: CARD;
IF (more ¬ client.GetCard32[]) = 0 THEN EXIT;
result ¬ result.Cat[Convert.RopeFromCard[client.GetCard32[]], " " ];  -- program
result ¬ result.Cat[Convert.RopeFromCard[client.GetCard32[]], " " ];  -- version
result ¬ result.Cat[Convert.RopeFromCard[client.GetCard32[]], " " ];  -- protocol
result ¬ result.Cat[Convert.RopeFromCard[client.GetCard32[]], "\n " ];  -- port

ENDLOOP;
RETURN[ UXStrings.Create[result] ];

};
END.
   |  
SunRPCTest.mesa
Copyright Ó 1992 by Xerox Corporation.  All rights reserved.
Chauser, January 7, 1992 10:44 am PST

 ÊŒ  •NewlineDelimiter
–(cedarcode) style™ šœ™Jšœ
Ïeœ1™<J™%J™ —codešÏk	˜	K˜Kšœ˜K˜K˜K˜K˜K˜
—K˜ KšÏn
œžœž˜KšžœQ˜Xšœž˜K˜ Kšœ˜K˜&K˜ Kšœ%˜%Kšœžœ˜K˜ Kšœžœ
˜Kšœ	žœ	˜K˜ K˜K˜K˜ šŸœžœžœ˜7KšœIžœžœ˜SK˜EKšžœ#˜)K˜—K˜ šŸ
œžœžœ˜"Kšœ˜K˜K˜ —Kšœ ˜ šŸœžœžœ˜7Kšœ8˜8Kšœ2˜2Kšžœ(žœ˜IK˜—K˜ —˜ šŸœ˜šžœž˜šœ˜Kšœ˜Kšžœžœ˜Kšœ˜—šœ˜Kšœžœ˜Kšœ˜K˜Kšžœžœ˜Kšœ˜—Kšžœžœž	œ˜—K˜—K˜ šŸœžœžœ˜ K˜<K˜6K˜—K˜ šŸœžœžœ˜ K˜6K˜6K˜K˜ —šŸ	œžœžœ˜;K˜MK˜6K˜—K˜ šŸ	œžœ6žœ˜SK˜_K˜6K˜K˜ —šŸœžœžœ˜%Kšœ˜K˜K˜ —šŸœžœžœ˜$K˜7Kšœ!˜!K˜—K˜ šŸœžœžœ˜#šžœžœžœ
ž˜K˜7Kšœ!˜!Kšžœ˜—K˜K˜ —šŸ	œžœžœžœ˜'šžœžœžœž˜K˜7Kšœ'˜'Kšžœ˜—K˜K˜ —šŸœžœžœžœ˜,K˜7K˜Kšœ!˜!Kšžœ˜Kšœ˜K˜ —šŸ	œžœ˜Kšœ-˜-Kšœ!˜!Kšžœ˜	Kšœ˜—K˜ šŸ
œžœžœ˜šžœžœžœž˜Kšœ-˜-Kšœ!˜!Kšžœ˜—Kšžœ˜	Kšœ˜K˜ —šŸœžœžœ˜0Kšœžœ˜Kšœ-˜-Kšœ!˜!šž˜Kšœžœ˜Kšžœ!žœžœ˜-KšœFÏc
˜PKšœF 
˜PKšœF ˜QKšœH ˜OK˜ Kšžœ˜—Kšžœ˜#K˜ Kšœ˜——Kšžœ˜— …—    ú    