
DIRECTORY
Rope,
CrRPC USING [Handle, Object, ProcsObject, CallProc, DestroyProc, SetParametersProc, GetBulkDataXferProcProc, PutBulkDataXferProcProc, ReadBulkDataStreamProc, WriteBulkDataSegmentProc, CallContinuationProc, SetContinuationProc],
CrRPCBackdoor USING [CreateClientHandleProc, RegisterCreateClientHandleProc],
IO;

CrRPCLoopbackImpl: CEDAR PROGRAM
IMPORTS CrRPCBackdoor, IO
~ BEGIN

class: ATOM = $Loopback;
count: INT ¬ 0;

Loopback: CrRPC.CallProc = {
push, pull: IO.STREAM;
interim: Rope.ROPE;
push ¬ IO.ROS[];
putArgs[h, push];
interim ¬ IO.RopeFromROS[push];
pull ¬ IO.RIS[interim];
getResults[h, pull];
IO.Close[pull];
};

Destroy: CrRPC.DestroyProc = {
NULL;
};

SetParameters: CrRPC.SetParametersProc = {
RETURN[h, NIL];
};

GetBulkDataXferProc: CrRPC.GetBulkDataXferProcProc = {
RETURN[NIL];
};

PutBulkDataXferProc: CrRPC.PutBulkDataXferProcProc = {
NULL;
};

ReadBulkDataStream: CrRPC.ReadBulkDataStreamProc = {
RETURN[FALSE];
};

WriteBulkDataSegment: CrRPC.WriteBulkDataSegmentProc = {
RETURN[FALSE, FALSE];
};

CallContinuation: CrRPC.CallContinuationProc = {
NULL;
};

SetContinuation: CrRPC.SetContinuationProc = {
NULL;
};

Finalize: PROC [CrRPC.Handle] RETURNS[renewHandle: BOOL] = {
RETURN[FALSE];
};

CreateLoopbackHandle: CrRPCBackdoor.CreateClientHandleProc = {
handle: CrRPC.Handle ¬ NEW[CrRPC.Object];
handle.class ¬ class;
handle.kind ¬ client;
handle.data ¬ NIL;
handle.clientData ¬ NIL;
handle.procs ¬ NEW[CrRPC.ProcsObject];
handle.procs.call ¬ Loopback;
handle.procs­ ¬ [
destroy: Destroy,
setParameters: SetParameters,
call: Loopback,
getBulkDataSource: GetBulkDataXferProc,
getBulkDataSink: GetBulkDataXferProc,
putBulkDataSource: PutBulkDataXferProc,
putBulkDataSink: PutBulkDataXferProc,
readBulkDataStream: ReadBulkDataStream,
writeBulkDataSegment: WriteBulkDataSegment,
callContinuation: CallContinuation,
setContinuation: SetContinuation,
finalize: Finalize
];
RETURN[handle];
};

CrRPCBackdoor.RegisterCreateClientHandleProc[class: $Loopback, proc: CreateLoopbackHandle];

END.
  z  CrRPCLoopbackImpl.mesa
Copyright س 1988, 1991 by Xerox Corporation.  All rights reserved.
Doug Terry, November 16, 1988 2:57:12 pm PST
Wes Irish, May 1, 1989 4:34:05 pm PDT
Willie-Sue, November 17, 1989 12:06:10 pm PST
Demers, April 26, 1990 3:35 pm PDT

A Courier RPC transport that simply pipes its arguments into its results, i.e. acts as an RPC echo server.  This allows one to use Sirocco-generated stubs to convert between opaque types (word sequences) and actual Cedar types.

[h: CrRPC.Handle, remotePgm: CrRPC.CARD32, remotePgmVersion: CrRPC.CARD16, remoteProc: CrRPC.CARD16, putArgs: CrRPC.PutArgsProc, getResults: CrRPC.GetResultsProc, getError: CrRPC.GetErrorProc]
[h: CrRPC.Handle]
[h: CrRPC.Handle, op: ATOM, argument: REF ANY] RETURNS [hNew: CrRPC.Handle, result: REF ANY]
[h: CrRPC.Handle, s: STREAM] RETURNS [CrRPC.BulkDataXferProc]
[h: CrRPC.Handle, s: STREAM, proc: CrRPC.BulkDataXferProc]
[h: CrRPC.Handle, s: STREAM, checkAbort: CrRPC.BulkDataCheckAbortProc, readValue: CrRPC.BulkDataValueProc] RETURNS [abort: BOOL]
[h: CrRPC.Handle, s: STREAM, checkAbort: CrRPC.BulkDataCheckAbortProc, writeValue: CrRPC.BulkDataValueProc, n: CARDINAL _ 1B (1)] RETURNS [abort: BOOL, heAborted: BOOL]
[h: CrRPC.Handle, proc: CrRPC.ContinuationProc, clientData: REF ANY]
[h: CrRPC.Handle, proc: CrRPC.ContinuationProc, clientData: REF ANY]
[remote: CrRPC.RefAddress] RETURNS [CrRPC.Handle]
 ‌تج  –(cedarcode) style•NewlineDelimiter
ک code•MarkoutsideHeaderڑœ™Kڑœ
دeœ7™BKڑœ,™,K™%K™-K™"K™ Kڑœم™مK™ —ڑدk	ک	KکKڑœ‍œطکمKڑœ‍œ:کMKڑ‍œک—Kک Kڑذblœ‍œ‍ک Kڑ‍œ‍کڑœ‍کKک Kڑœ‍œکKڑœ‍œکKک ڑدnœکKڑœ#‍œ‍œ‍œ]™ہKڑœ‍œ‍œکKڑœ‍œکKڑœ‍œ‍œکKڑœکKڑœ
‍œکKڑœ‍œ‍œ
کKڑœکKڑ‍œکKکKک —•StartOfExpansion -- [h: CrRPC.Handle]ڑ œکKڑœ™Kڑ‍œکKکKک —–` -- [h: CrRPC.Handle, op: ATOM, argument: REF ANY] RETURNS [hNew: CrRPC.Handle, result: REF ANY]ڑ œک*Kڑœ‍œ‍œ‍œ‍œ‍œ‍œ™\Kڑ‍œ‍œکKکKک —–A -- [h: CrRPC.Handle, s: STREAM] RETURNS [CrRPC.BulkDataXferProc]ڑ œ#ک6Kڑœ‍œ‍œ™=Kڑ‍œ‍œکKکKک —–> -- [h: CrRPC.Handle, s: STREAM, proc: CrRPC.BulkDataXferProc]ڑ œ#ک6Kڑœ‍œ™:Kڑ‍œکKک—Kک –„ -- [h: CrRPC.Handle, s: STREAM, checkAbort: CrRPC.BulkDataCheckAbortProc, readValue: CrRPC.BulkDataValueProc] RETURNS [abort: BOOL]ڑ œ"ک4Kڑœ‍œP‍œ	‍œ™€Kڑ‍œ‍œکKکKک —–¬ -- [h: CrRPC.Handle, s: STREAM, checkAbort: CrRPC.BulkDataCheckAbortProc, writeValue: CrRPC.BulkDataValueProc, n: CARDINAL _ 1B (1)] RETURNS [abort: BOOL, heAborted: BOOL]ڑ œ$ک8Kڑœ‍œT‍œ‍œ	‍œ‍œ™¨Kڑ‍œ‍œ‍œکKکKک —–H -- [h: CrRPC.Handle, proc: CrRPC.ContinuationProc, clientData: REF ANY]ڑ œ ک0Kڑœ<‍œ‍œ™DKڑ‍œکKکKک —–H -- [h: CrRPC.Handle, proc: CrRPC.ContinuationProc, clientData: REF ANY]ڑ œک.Kڑœ<‍œ‍œ™DKڑ‍œکKکKک —ڑ œ‍œ‍œ‍œک<Kڑ‍œ‍œکKکKک —ڑ œ*ک>Kڑذck1™1Kڑœ‍œک)KکKکKڑœ‍œکKڑœ‍œکKڑœ‍œک&KککKکKکKکKک'Kک%Kک'Kک%Kک'Kک+Kڑœ#ک#Kک!KڑœکKک—Kڑ‍œ	کKکKک —K–=[class: ATOM, proc: CrRPCBackdoor.CreateClientHandleProc]ڑœ[ک[Kک —Kڑ‍œک— …—    ى  2  