
DIRECTORY
IO,
RefID USING [ ID ],
Rope USING [ROPE],
RuntimeError USING [ UNCAUGHT ],
SRPCCalls USING [
Conversation, Error, GetSHandle, NewRPCConversation, ReleaseConversation, ReportProc, SHandle, TimeoutEnable],
SunRPC,
Thrush,
ThrushSunRPC,
ThrushSunRPCConvert,
SynthesizerServer,
SynthesizerServerRpcControl,
SynthesizerServerSunImport,
SynthesizerServerSunRPC,
SynthesizerServerSunRPCClient,
VoiceUtils
;

SynthesizerServerToSynthesizerServerSunRPC: CEDAR PROGRAM
IMPORTS IO, RuntimeError, SRPCCalls, SynthesizerServerSunRPCClient, ThrushSunRPCConvert, VoiceUtils
EXPORTS SynthesizerServerSunImport
 = {

OPEN IO, ThrushSunRPCConvert;

sunSHHH: CARD32 = 0;
SHandle: TYPE ~ SRPCCalls.SHandle;
InterfaceRecord: TYPE ~ SynthesizerServerRpcControl.InterfaceRecord;
TextToSpeech: PROC [
interface: InterfaceRecord,
shhh: Thrush.SHHH¬Thrush.none,
credentials: Thrush.Credentials, -- authenticates caller
serviceID: RefID.ID, -- identifies particular service
textToSpeak: Rope.ROPE,
actionID: Thrush.ActionID,
filter: BOOL¬TRUE,
queueIt: BOOL¬TRUE
] RETURNS [nb: Thrush.NB] = {
ENABLE {
SRPCCalls.Error => { nb ¬ ReportError[shhh, errCode, explanation]; CONTINUE; };
RuntimeError.UNCAUGHT => { nb ¬ ReportError[shhh, $unknownError]; CONTINUE; };
};
srNB: ThrushSunRPC.NB;
srNB ¬ SynthesizerServerSunRPCClient.TextToSpeech[h: GetHandle[shhh], shhh: sunSHHH, credentials: CredentialsToSr[credentials], serviceID: serviceID, textToSpeak: ROPEToSr[textToSpeak], actionID: actionID, filter: filter, queueIt: queueIt];
nb ¬ SrToATOM[srNB];
};

StopSpeech: PROC [
interface: InterfaceRecord,
shhh: Thrush.SHHH¬Thrush.none,
credentials: Thrush.Credentials,
serviceID: RefID.ID,
reset: BOOL ¬ FALSE
] RETURNS [nb: Thrush.NB] = {
ENABLE {
SRPCCalls.Error => { nb ¬ ReportError[shhh, errCode, explanation]; CONTINUE; };
RuntimeError.UNCAUGHT => { nb ¬ ReportError[shhh, $unknownError]; CONTINUE; };
};
srNB: ThrushSunRPC.NB;
srNB ¬ SynthesizerServerSunRPCClient.StopSpeech[h: GetHandle[shhh], shhh: sunSHHH, credentials: CredentialsToSr[credentials], serviceID: serviceID, reset: reset];
nb ¬ SrToATOM[srNB];
};

GetSynthesizerSpecifications: PROC [
interface: InterfaceRecord,
shhh: Thrush.SHHH¬Thrush.none,
serviceID: RefID.ID
] RETURNS [ nb: Thrush.NB, synthesizerModel: ATOM, synthesizerVersion: ATOM ] = {
ENABLE {
SRPCCalls.Error => { nb ¬ ReportError[shhh, errCode, explanation]; CONTINUE; };
RuntimeError.UNCAUGHT => { nb ¬ ReportError[shhh, $unknownError]; CONTINUE; };
};
srNB: ThrushSunRPC.NB;
srSm, srSv: Rope.ROPE;
[srNB, srSm, srSv] ¬ SynthesizerServerSunRPCClient.GetSynthesizerSpecifications[h: GetHandle[shhh], shhh: sunSHHH, serviceID: serviceID];
nb ¬ SrToATOM[srNB];
synthesizerModel ¬ SrToATOM[srSm];
synthesizerVersion ¬ SrToATOM[srSv];
};
GetHandle: PROC[shhh: Thrush.SHHH] RETURNS [h: SunRPC.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 ¬ 390911;  -- 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[SynthesizerServerRpcControl.InterfaceRecordObject];
interface­ ¬ [
clientStubTextToSpeech: TextToSpeech, clientStubStopSpeech: StopSpeech,
clientStubGetSynthesizerSpecifications: GetSynthesizerSpecifications ];
};

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: "Synthesizer Server Failure, code: %g, expl: %g", where: $System, a1: atom[ec], a2: rope[expl]];
};
}.
   &  
SynthesizerServerToSynthesizerServerSunRPC.mesa
Copyright س 1990, 1992 by Xerox Corporation.  All rights reserved.
Pier, May 24, 1990 12:56:29 pm PDT
Swinehart, September 19, 1990 7:17:53 am PDT
Polle Zellweger (PTZ) October 29, 1990 3:30:54 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 3:30:54 pm PST
Allow detection of NIL ropes across a SunRPC connection.
changes to: TextToSpeech


 ‌تھ  •NewlineDelimiter
–(cedarcode) style™ ڑœ/™/Icodeڑœ
دeœ7™BK™"K™,K™5—Kک ڑدk	ک	KکKڑœ‍œ‍œکKڑœ‍œ‍œکKڑœ‍œ‍œک ڑœ
‍œکKکn—KکKڑœکKڑœکKڑœکKڑœکKڑœکKڑœکKڑœکKڑœکKک
KکKک —Kڑدn*œ‍œ‍ک9Kڑ‍œ\کcKڑ‍œک"KڑœکKک Kڑ‍œکKک Icode0ڑœ	‍œکڑœ	‍œک"J™ —Kڑœ‍œ/کDhead™
ڑںœ‍œکKکKڑœ‍œکKڑœ!دcک8Kڑœ‍œ  ک5Kڑœ‍œکKڑœکKڑœ‍œ‍œکKڑœ	‍œ‍کڑœ‍œ‍œکڑذosکKڑ،œ،6کOKڑ،œ،/کNKڑ،ک—Kڑœ‍œکKڑœ%ںœ؟کًKکKک—Kک —ڑں
œ‍œکKکKڑœ‍œکKڑœ ک Kڑœ‍œکKڑœ‍œ‍کڑœ‍œ‍œکڑ،کKڑ،œ،6کOKڑ،œ،/کNKڑ،ک—Kڑœ‍œکKڑœ%ں
œsک¢KکKک—Kک —ڑںœ‍œک$KکKڑœ‍œکKڑœ‍کڑ	œ‍œ‍œ‍œ‍œکQڑ،کKڑ،œ،6کOKڑ،œ،/کNKڑ،ک—Kڑœ‍œکKڑœ‍œکKڑœ3ںœ:ک‰KکKک"Kک$Kک———™ڑں	œ‍œ‍œ‍œکAKڑœکKڑ‍œ‍œ‍œ*ک<Kک%Kڑ‍œ	‍œ‍œ/کBKکKک——™
Kڑœ‍œ -کEKڑœ‍œکKڑœ‍œکKڑœ‍œکKک7Kک ڑںœ‍œ‍œ‍œ‍œ+‍œکnK™{KکàKڑœ%‍œک*Kڑœ‍œ4کCکKڑœGکGKڑœGکG—KکKک —ڑںœ‍œ‍œ‍œک6Kک$KکKک —ڑںœ‍œ‍œ‍œ‍œ‍œکOKڑ‍œ‍	œکKک.Kڑ‍œ	‍œ‍œ‍œکKک.KکKکKک —ڑںœک(Kک}Kک——Kڑœک™5K™8Kڑœدr™—K™ K™ — …—      ط  