DIRECTORY
Atom,
Basics,
CrRPC,
CStrings USING [CString],
IO,
Process,
RefText,
Rope,
RuntimeError,
UXStrings,
XNS,
XNSWKS;

CrRPCSample: CEDAR PROGRAM
IMPORTS Atom, CrRPC, IO, Rope, UXStrings
~ {

debugMsgs: BOOL м FALSE;

CRRPCSampleSetDebugMsgs: PROC [val: INT] RETURNS [oldVal: INT] ~ {
oldVal м (IF debugMsgs THEN 1 ELSE 0);
debugMsgs м (val # 0);
};

XRConsoleMsgInner: PROC [m: CStrings.CString] ~ TRUSTED MACHINE CODE { "XR_ConsoleMsg" };

DebugMsg: PROC [r: Rope.ROPE] ~ TRUSTED {
text: REF TEXT;
text м Rope.ToRefText[r];
XRConsoleMsgInner[UXStrings.ViewRefText[text]];
};
BytePtr: TYPE ~ LONG POINTER TO BYTE;

FWORD: TYPE ~ Basics.FWORD;
HWORD: TYPE ~ Basics.HWORD;
ROPE: TYPE ~ Rope.ROPE;
STREAM: TYPE ~ IO.STREAM;
Ticks: TYPE ~ Process.Ticks;

Handle: TYPE ~ CrRPC.Handle;
CreateRefXNSAddress: UNSAFE PROC [from: LONG POINTER TO XNS.Address] RETURNS [copy: REF XNS.Address] ~ TRUSTED {
copy м NEW[XNS.Address м (fromн)];
};

GetCMUXHandleClass: PROC RETURNS [class: ATOM] ~ { class м $CMUX };

PutMySimpleCredentialsAndVerifier: PROC [h: Handle, s: STREAM] ~ {
CrRPC.PutCard16[s, 0];
CrRPC.PutCard16[s, 11];
CrRPC.PutRope[s, "Xerox"];
CrRPC.PutRope[s, "PARC"];
CrRPC.PutRope[s, "Demers"];
CrRPC.PutCard16[s, 1];
CrRPC.PutCard16[s, 0d0e9H];
};

GetAndDumpContentsOfStream: PROC [h: Handle, s: STREAM] ~ {
WHILE NOT IO.EndOf[s] DO
x: CARD16 м CrRPC.GetCard16[s];
DebugMsg[IO.PutFR1["%x\n", IO.card[x]]];
ENDLOOP;
};

PutListAddressesArgs: CrRPC.PutArgsProc ~ {
msg: ROPE м "PutListAddressesArgs was called\n";
DebugMsg[msg];
};

GetListAddressesResults: CrRPC.GetResultsProc -- [h, s] -- ~ {
msg: ROPE м "GetListAddressesResults was called\n";
DebugMsg[msg];
GetAndDumpContentsOfStream[h, s];
DebugMsg["done with GetListAddressesResults\n"];
};

GetListAddressesError: CrRPC.GetErrorProc -- [h, s, errNum] -- ~ {
msg: ROPE м IO.PutFR1["GetListAddressesError errnum %g\n", IO.card[errNum]];
DebugMsg[msg];
GetAndDumpContentsOfStream[h, s];
DebugMsg["done with GetListAddressesError\n"];
};

CallListAddresses: PROC [h: Handle] ~ {
CrRPC.Call[h, 2, 3, 0, PutListAddressesArgs, GetListAddressesResults, GetListAddressesError];
};

PutListDomainsServedArgs: CrRPC.PutArgsProc ~ {
msg: ROPE м "PutListDomainsServerArgs was called\n";
DebugMsg[msg];
CrRPC.PutBulkDataSink[h, s, XferListDomainsServedBulkData];
PutMySimpleCredentialsAndVerifier[h, s];
msg м "PutListDomainsServerArgs done\n";
DebugMsg[msg];
};

XferOneDomain: PROC[s: STREAM] ~ {
DebugMsg["Domain : "];
DebugMsg[CrRPC.GetRope[s]];
DebugMsg[":"];
DebugMsg[CrRPC.GetRope[s]];
DebugMsg["\n"];
};

XferDomainSeq: PROC[s: STREAM] ~ {
seqLen: CARD16;
DebugMsg["XferDomainSeq called\n"];
seqLen м CrRPC.GetCard16[s];
WHILE seqLen > 0 DO
XferOneDomain[s];
seqLen м seqLen - 1;
ENDLOOP;
};

XferListDomainsServedBulkData: CrRPC.BulkDataXferProc -- [h, s, checkAbort] -- ~ {
DebugMsg["XferListDomainsServedBulkData called\n"];
IF checkAbort[h] THEN RETURN [FALSE];
DO
tag: CARD16 м CrRPC.GetCard16[s];
SELECT tag FROM
0 => {
XferDomainSeq[s];
IF checkAbort[h] THEN RETURN [FALSE];
};
1 => {
XferDomainSeq[s];
IF checkAbort[h] THEN RETURN [FALSE];
IF NOT IO.EndOf[s] THEN DebugMsg[IO.PutFR1["bulk data ends before endOfStream, charsAvail %g\n", IO.int[IO.CharsAvail[s, FALSE]]]]; -- DEBUG
RETURN [FALSE];
};
ENDCASE => {
DebugMsg[IO.PutFR1["error: bulk data tag %g\n", IO.card[tag]]];
RETURN [TRUE];
};
ENDLOOP;
};

GetListDomainsServedResults: CrRPC.GetResultsProc -- [h, s] -- ~ {
msg: ROPE м "GetListDomainsServedResults was called\n";
DebugMsg[msg];
GetAndDumpContentsOfStream[h, s];
DebugMsg["done with GetListDomainsServedResults\n"];
};

GetListDomainsServedError: CrRPC.GetErrorProc -- [h, s, errNum] -- ~ {
msg: ROPE м IO.PutFR1["GetListDomainsServedError errnum %g\n", IO.card[errNum]];
DebugMsg[msg];
GetAndDumpContentsOfStream[h, s];
DebugMsg["done with GetListDomainsServedError\n"];
};

CallListDomainsServed: PROC [h: Handle] ~ {
CrRPC.Call[h, 2, 3, 1, PutListDomainsServedArgs, GetListDomainsServedResults, GetListDomainsServedError];
};

PutCheckSimpleCredentialsArgs: CrRPC.PutArgsProc ~ {
msg: ROPE м "PutCheckSimpleCredentialsArgs was called\n";
DebugMsg[msg];
PutMySimpleCredentialsAndVerifier[h, s];
};

GetCheckSimpleCredentialsResults: CrRPC.GetResultsProc -- [h, s] -- ~ {
msg: ROPE м "GetCheckSimpleCredentialsResults was called\n";
DebugMsg[msg];
GetAndDumpContentsOfStream[h, s];
DebugMsg["done with GetCheckSimpleCredentialsResults\n"];
};

GetCheckSimpleCredentialsError: CrRPC.GetErrorProc -- [h, s, errNum] -- ~ {
msg: ROPE м IO.PutFR1["GetCheckSimpleCredentialsError errnum %g\n", IO.card[errNum]];
DebugMsg[msg];
GetAndDumpContentsOfStream[h, s];
DebugMsg["done with GetCheckSimpleCredentialsError\n"];
};

CallCheckSimpleCredentials: PROC [h: Handle] ~ {
CrRPC.Call[h, 14, 2, 2, PutCheckSimpleCredentialsArgs, GetCheckSimpleCredentialsResults, GetCheckSimpleCredentialsError];
};


samplePgm: CARD32 м 1776;
samplePgmVersion: CARD16 м 0;

sampleNegateProcNum: CARD16 м 0;
sampleSendToServerProcNum: CARD16 м 1;
sampleGetFromServerProcNum: CARD16 м 2;

sampleOutOfRangeErrNum: CARD16 м 0;

CallNegate: PROC [h: Handle, x: INT] ~ {
PutNegateArgs: CrRPC.PutArgsProc -- [h, s] -- ~ {
msg: ROPE м IO.PutFR1["PutNegateArgs %g was called\n", IO.int[x] ];
DebugMsg[msg];
CrRPC.PutInt32[s, x];
};
GetNegateResults: CrRPC.GetResultsProc -- [h, s] -- ~ {
ans: INT32;
msg: ROPE;
DebugMsg["GetNegateResults called ... "];
ans м CrRPC.GetInt32[s];
msg м IO.PutFR1["recvd %g\n", IO.int[ans] ];
DebugMsg[msg];
};
GetNegateError: CrRPC.GetErrorProc -- [h, s, errNum] -- ~ {
msg: ROPE м IO.PutFR1["GetNegateError errnum %g\n", IO.card[errNum]];
DebugMsg[msg];
GetAndDumpContentsOfStream[h, s];
DebugMsg["done with GetNegateError\n"];
};
CrRPC.Call[h, samplePgm, samplePgmVersion, sampleNegateProcNum, PutNegateArgs, GetNegateResults, GetNegateError];
};

ServeNegate: PROC [h: Handle, s: STREAM, beginReturn: CrRPC.BeginReturnProc, beginError: CrRPC.BeginErrorProc] ~ {
x: INT;
msg: ROPE;
DebugMsg["ServeNegate ["];
x м CrRPC.GetInt32[s];
msg м IO.PutFR1["%g] ", IO.int[x] ];
DebugMsg[msg];
IF x = INT.FIRST THEN {
DebugMsg["raises OutOfRange\n"];
beginError[h, sampleOutOfRangeErrNum];
RETURN;
};
msg м IO.PutFR1["returns %g\n", IO.int[-x] ];
beginReturn[h];
DebugMsg[msg];
CrRPC.PutInt32[s, -x];
};

ServeSample: CrRPC.ServerProc -- [h, s, pgm, pgmVersion, proc, beginReturn, beginError, beginReject] -- ~ {
msg: ROPE;
SELECT proc FROM
sampleNegateProcNum => {
ServeNegate[h, s, beginReturn, beginError];
};
ENDCASE => {
msg м IO.PutFR1["ServeSample proc %g rejected\n", IO.card[proc]];
DebugMsg[msg];
beginReject[h, CrRPC.noSuchProcedure];
};
};

pleaseStopSample: BOOL м FALSE;

SetPleaseStopSample: PROC [new: INT] RETURNS [old: INT] ~ {
old м IF pleaseStopSample THEN 1 ELSE 0;
pleaseStopSample м (new # 0);
};

StopSampleQueryProc: CrRPC.StopServerQueryProc -- [h] RETURNS [BOOL] -- ~ {
RETURN [pleaseStopSample];
};

AtomFromUnixString: PROC [s: CStrings.CString] RETURNS [ATOM] ~ {
RETURN[ Atom.MakeAtom[UXStrings.ToRope[s, 40]] ];
};

}.


  ~  
CrRPCSample.mesa
Copyright ╙ 1986, 1988, 1989, 1991 by Xerox Corporation.  All rights reserved.
Demers, April 26, 1990 9:36 am PDT
Willie-s, December 9, 1991 5:04 pm PST


Convert, -- ??? 
CrRPCBackdoor,
ProcStream,
UnixTypes, -- ???
Debugging
Copied Types and Constants
Clearinghouse Client Calls
Here's the stuff to do GetAddresses for a clearinghouse ...

Credentials
Simple type
Length, in words
Three-part name ...
Verifier
Length, in words
Hashed password
Immediate Bulk Data
Sample Courier Client/Server Pair
This is a client-server pair for a simple protocol:
OutOfRange: ERROR [] = 0;
Negate: PROC [x: INT] RETURNS [minusX: INT] RAISES OutOfRange = 0;
SendToServer: PROC [source: BulkDataSource, abortAfter: INT] RETURNS [nBytesRecvd: CARD32, hash: CARD32] = 1;
GetFromServer: PROC [nBytesWanted: CARD32, sink: BulkDataSink, abortAfter: INT] RETURNS [hash: CARD32] = 2;
Startup
Э╩	О  ХNewlineDelimiter
Ц(cedarcode) styleЩ ЪЬЩIcodeЪЬ
╧eЬCЩNKЩ"KЩ&KЩ KЩ ЧЪ╧k	Ш	KШKШKЩKШKЪЬЩKЪЬ	ЮЬШKЪЮЬШKЪЬШKЩKЪЬШKЪЬШKЪЬШKЩKШ
KЪЮЬШKЪЮЬШKШ ЧЪ╤blnЬЮЬЮШKЪЮЬЮЬШ(KЪЬШKШ headЩ	KЪЬЮЬЮЬШKШ Ъ
╧nЬЮЬЮЬЮЬ
ЮЬШBKЪЬ
ЮЬЮЬЮЬШ&KШKШKШ ЧЪ
аЬЮЬЮЬЮЬЮЬШYKШ ЧЪаЬЮЬ
ЮЬЮЬШ)KЪЬЮЬЮЬШKШKЪЬ/Ш/KШЧЧЩKЪЬ	ЮЬЮЬЮЬЮЬЮЬШ%KШ KЪЮЬЮЬ
ЮЬШKЪЮЬЮЬ
ЮЬШKЪЮЬЮЬЮЬШKЪЮЬЮЬЮЬЮЬШKЪЬЮЬШKШ KЪЬЮЬШЧЩЩ;KЩ ЧЪаЬЮЬЮЬЮЬЮЬЮЬЮЬ
ЮЬЮЬЮЬЮЬШpKЪЬЮЬЮЬШ"KШKШ ЧЪаЬЮЬЮЬ	ЮЬШCKШ ЧЪа!ЬЮЬЮЬШBЩЩKЪЬШЧЩKЪЬШЧЩKЪЬШKЪЬШKЪЬШЧЧЩЩKЪЬШЧЩKЪЬШЧЧKШKШ ЧЪаЬЮЬЮЬШ;ЪЮЬЮЬЮЬ
ЮШKЪЬЮЬШKЪЬ	ЮЬЮЬШ(KЪЮЬШЧKШKШ ЧЪаЬШ+KЪЬЮЬ'Ш0KЪЬШKШKШ ЧЪаЬ╧cЬШ>KЪЬЮЬ*Ш3KЪЬШKШ!KЪЬ0Ш0KШKШ ЧЪаЬбЬШBKЪЬЮЬЮЬ-ЮЬШLKЪЬШKШ!KЪЬ.Ш.KШKШ ЧЪаЬЮЬШ'KЪЬ]Ш]KШKШ ЧЪаЬШ/KЪЬЮЬ+Ш4KЪЬШЩKЪЬ;Ш;ЧKШ(KШ(KЪЬШKШKШ ЧЪаЬЮЬЮЬШ"KЪЬШKЪЬШKЪЬШKЪЬШKЪЬШKШKШ ЧЪаЬЮЬЮЬШ"KЪЬЮЬШKЪЬ#Ш#KШЪЮЬЮШKШKШKЪЮЬШЧKШKШ ЧЪаЬбЬШRKЪЬ3Ш3KЪЮЬЮЬЮЬЮЬШ%ЪЮШKЪЬЮЬШ!ЪЮЬЮШШKШKЪЮЬЮЬЮЬЮЬШ%KШЧШKШKЪЮЬЮЬЮЬЮЬШ%KЪЮЬЮЬЮЬ
ЮЬ
ЮЬ>ЮЬЮЬЮЬбШМKЪЮЬЮЬШKШЧЪЮЬШKЪЬ	ЮЬ%ЮЬШ?KЪЮЬЮЬШKШЧЧKЪЮЬШЧKШKШ ЧЪаЬбЬШBKЪЬЮЬ.Ш7KЪЬШKШ!KЪЬ4Ш4KШKШ ЧЪаЬбЬШFKЪЬЮЬЮЬ1ЮЬШPKЪЬШKШ!KЪЬ2Ш2KШKШ ЧЪаЬЮЬШ+KЪЬiШiKШKШ ЧЪаЬШ4KЪЬЮЬ0Ш9KЪЬШKЪЬ(Ш(KШKШ ЧЪа ЬбЬШGKЪЬЮЬ3Ш<KЪЬШKШ!KЪЬ9Ш9KШKШ ЧЪаЬбЬШKKЪЬЮЬЮЬ6ЮЬШUKЪЬШKШ!KЪЬ7Ш7KШKШ ЧЪаЬЮЬШ0KЪЬyШyKШKШ ЧЧЩ!Щ3KЩKЩBKЩmKЩkKШ ЧKЪЬЮЬШKЪЬЮЬШKШ KЪЬЮЬШ KЪЬЮЬШ&KЪЬЮЬШ'KШ KЪЬЮЬШ#KШ Ъа
ЬЮЬЮЬШ(ЪаЬбЬШ1KЪЬЮЬЮЬ)ЮЬ
ШCKЪЬШKШKШЧЪаЬбЬШ7KЪЬЮЬШKЪЬЮЬШ
KЪЬ)Ш)KШKЪЬЮЬЮЬШ,KЪЬШKШЧЪаЬбЬШ;KЪЬЮЬЮЬ&ЮЬШEKЪЬШKШ!KЪЬ'Ш'KШЧKЪЬqШqKШKШ ЧЪаЬЮЬЮЬKШrKЪЬЮЬШKЪЬЮЬШ
KЪЬШKШKЪЬЮЬЮЬ
Ш$KЪЬШЪЮЬЮЬЮЬЮЬШKЪЬ Ш KЪЬ&Ш&KЪЮЬШKШЧKЪЬЮЬЮЬШ-KШKЪЬШKШKШKШ ЧЪаЬбIЬШkKЪЬЮЬШ
ЪЮЬЮШЪЬШKЪЬ+Ш+KШЧЪЮЬШKЪЬЮЬ*ЮЬШAKЪЬШKЪЬ&Ш&KШЧЧKШKШ ЧKЪЬЮЬЮЬШKШ Ъ
аЬЮЬЮЬЮЬЮЬШ;KЪЬЮЬЮЬЮЬШ(KШKШЧKШ ЪаЬбЬШKKЪЮЬШKШKШ ЧЪаЬЮЬЮЬЮЬШAKЪЮЬ+Ш1KШKШ ЧЧLЩKШЧKШ KШ KШ KШ KШ Ч ЕЧ    v  (В  