
DIRECTORY
IO,
RefID USING [ ID ],
Rope USING [ROPE],
RuntimeError USING [ UNCAUGHT ],
SRPCCalls USING [
Conversation, Error, GetSHandle, Handle, NewRPCConversation, ReleaseConversation, ReportProc, SHandle, TimeoutEnable],
Thrush,
ThrushSunRPC,
ThrushSunRPCConvert,
LarkFeep,
LarkFeepRpcControl,
LarkFeepSunRPC,
LarkFeepSunRPCClient,
LarkFeepSunImport,
VoiceUtils
;

LarkFeepToLarkFeepSunRPC: CEDAR PROGRAM
IMPORTS IO, LarkFeepSunRPCClient, RuntimeError, SRPCCalls, ThrushSunRPCConvert, VoiceUtils
EXPORTS LarkFeepSunImport = {

OPEN IO, ThrushSunRPCConvert;

sunSHHH: CARD32 = 0;
SHandle: TYPE ~ SRPCCalls.SHandle;
InterfaceRecord: TYPE = LarkFeepRpcControl.InterfaceRecord;
Feep: PROC [interface: InterfaceRecord, shhh: Thrush.SHHH, serviceID: RefID.ID, convID: Thrush.ConversationID, requestingParty: Thrush.PartyID, number: Rope.ROPE, noisy: BOOLEAN ¬ FALSE, on, off: CARDINAL¬ 177777B] RETURNS [nb: Thrush.NB] = {
ENABLE {
SRPCCalls.Error => { nb ¬ ReportError[shhh, errCode, explanation]; CONTINUE; };
RuntimeError.UNCAUGHT => { nb ¬ ReportError[shhh, $unknownError]; CONTINUE; };
};
srNB: ThrushSunRPC.NB;
srNB ¬ LarkFeepSunRPCClient.Feep[h: GetHandle[shhh], shhh: sunSHHH, serviceID: serviceID, convID: ConvIDToSr[convID], requestingParty: requestingParty, number: ROPEToSr[number], noisy: noisy, on: on, off: off];
nb ¬ SrToATOM[srNB];
};

Flash: PROC [interface: InterfaceRecord, shhh: Thrush.SHHH, serviceID: RefID.ID, convID: Thrush.ConversationID, requestingParty: Thrush.PartyID, actionID: Thrush.ActionID, extraTime: CARDINAL¬ 177777B] RETURNS [nb: Thrush.NB] = {
ENABLE {
SRPCCalls.Error => { nb ¬ ReportError[shhh, errCode, explanation]; CONTINUE; };
RuntimeError.UNCAUGHT => { nb ¬ ReportError[shhh, $unknownError]; CONTINUE; };
};
srNB: ThrushSunRPC.NB;
srNB ¬ LarkFeepSunRPCClient.Flash[h: GetHandle[shhh], shhh: sunSHHH, serviceID: serviceID, convID: ConvIDToSr[convID], requestingParty: requestingParty, actionID: actionID, extraTime: extraTime];
nb ¬ SrToATOM[srNB];
};
GetHandle: PROC[shhh: Thrush.SHHH] RETURNS [h: SRPCCalls.Handle] ~ {
sHandle: SHandle;
IF shhh = NIL THEN SRPCCalls.Error[$noConversationSupplied];
sHandle ¬ SRPCCalls.GetSHandle[shhh];
IF sHandle=NIL THEN SRPCCalls.Error[$invalidConversationSupplied];
h ¬ sHandle.handle;
};
sunPgm: CARD ¬ 390914;  -- decimal program number for VoiceRopeServer
sunPgmVersion: CARD ¬ 1;
sunCallTimeout: INT ¬ 3000;
sunCallRetries: INT ¬ 3;
sunCallTimeoutEnable: SRPCCalls.TimeoutEnable ¬ always;

ImportInterface: PUBLIC PROC [instance: Rope.ROPE]
RETURNS [interface: InterfaceRecord, shhh: Thrush.SHHH] ~ {
shhh ¬ SRPCCalls.NewRPCConversation[serverName: instance, rpcProgram: sunPgm, rpcVersion: sunPgmVersion, timeoutEnable: sunCallTimeoutEnable, timeoutInMs: sunCallTimeout, retries: sunCallRetries, reportProc: ForwardReports];
SRPCCalls.GetSHandle[shhh].enabled ¬ TRUE;
interface ¬ NEW[LarkFeepRpcControl.InterfaceRecordObject];
interface­ ¬ [clientStubFeep: Feep, clientStubFlash: Flash ];
};

UnImportInterface: PUBLIC PROC [shhh: Thrush.SHHH] ~ {
SRPCCalls.ReleaseConversation[shhh];
};

ReportError: PROC[shhh: Thrush.SHHH, errCode: ATOM, explanation: Rope.ROPE¬NIL]
RETURNS[nb: Thrush.NB] ~ {
sHandle: SHandle ¬ SRPCCalls.GetSHandle[shhh];
IF sHandle=NIL THEN RETURN;
ForwardReports[sHandle, errCode, explanation];
nb ¬ $callFailed;
};

ForwardReports: SRPCCalls.ReportProc ~ {
VoiceUtils.ProblemFR[remark: "Lark Feep Failure, code: %g, expl: %g", where: $System, a1: atom[ec], a2: rope[expl]];
};
}.
  
  
LarkFeepToLarkFeepSunRPC.mesa
Copyright س 1990, 1992 by Xerox Corporation.  All rights reserved.
Pier, May 24, 1990 12:47:50 pm PDT
Swinehart, September 19, 1990 7:17:38 am PDT
Polle Zellweger (PTZ) October 29, 1990 3:31:44 pm PST
Procedures
Handles
Connecting
instance should be a SunRPC address, in the form "sun#[1.2.3.4]#5", where [1.2.3.4] is the Arpa address, and 5 is the port.
Polle Zellweger (PTZ) October 29, 1990 12:05:26 pm PST
Allow detection of NIL ropes across a SunRPC connection.
changes to: Feep
 ‌ت€  •NewlineDelimiter
–(cedarcode) style™ ڑœ™Icodeڑœ
دeœ7™BK™"K™,K™5—Kک ڑدk	ک	KکKڑœ‍œ‍œکKڑœ‍œ‍œکKڑœ‍œ‍œک ڑœ
‍œکKکv—KڑœکKڑœکKڑœکKڑœ	ک	KکKڑœکKڑœکKڑœکKک
KکKک —Kڑدnœ‍œ‍ک'Kڑ‍œSکZKڑ‍œکKک Kڑ‍œکKک Icode0ڑœ	‍œکKڑœ	‍œک"Kڑœ‍œ&ک;head™
ڑںœ‍œ+‍œd‍œ	‍œ‍œ‍œ
‍œ‍œکٍڑذosکKڑ œ 6کOKڑ œ /کNKڑ کKڑœ‍œکKکزKکKک—Kک —ڑںœ‍œ+‍œ‍œh‍œ
‍œ‍œکهڑ کKڑ œ 6کOKڑ œ /کNKڑ کKڑœ‍œکKڑœںœ¢کأKکKک———™ڑں	œ‍œ‍œ‍œکDKڑœکKڑ‍œ‍œ‍œ*ک<Kک%Kڑ‍œ	‍œ‍œ/کBKکKک——™
Kڑœ‍œدc-کEKڑœ‍œکKڑœ‍œکKڑœ‍œکKک7Kک ڑںœ‍œ‍œ‍œک2Kڑ‍œ+‍œک;K™{KکàKڑœ%‍œک*Kڑœ‍œ+ک:Kک=KکKک —ڑںœ‍œ‍œ‍œک6Kک$KکKک —ڑںœ‍œ‍œ‍œ‍œ‍œکOKڑ‍œ‍	œکKک.Kڑ‍œ	‍œ‍œ‍œکKک.KکKکKک —ڑںœک(KکtKک——Kڑœک™6K™8Kڑœدr™—— …—    ¢  ,  