
DIRECTORY
Atom USING [ GetPropFromList, PutPropOnList ],
FinchSynthesizer,
FinchSmarts USING [ ConvDesc, ObtainServiceInterface, RegisterForReports, ReportConversationStateProc, ReportRequestStateProc, ReportSystemStateProc, ServiceConnect ],
Random USING [ Create, NextInt, RandomStream ],
RefID USING [ ID ],
Rope USING [ ROPE ],
Thrush USING [ ConversationID, InterfaceSpec, NB, nullConvID, nullID, SHHH ],
Synthesizer USING [ ActionID, nullActionID, SynthSpec, SynthSpecBody, SynthSpecs ],
SynthesizerServerRpcControl USING [InterfaceRecord ],
SynthesizerServerSunImport USING [ ImportInterface ]
;

FinchSynthesizerImpl: CEDAR MONITOR
IMPORTS Random, SynthesizerServerSunImport, Atom, FinchSmarts
EXPORTS FinchSynthesizer = {


ConvDesc: TYPE = FinchSmarts.ConvDesc;
ConversationID: TYPE = Thrush.ConversationID;
NB: TYPE = Thrush.NB;
nullID: RefID.ID = Thrush.nullID;
SHHH: TYPE = Thrush.SHHH;
SynthSpecs: TYPE = Synthesizer.SynthSpecs; -- LIST OF Synthesizer.SynthSpec

NconcSpecs: PROC[l1, l2: SynthSpecs] RETURNS [SynthSpecs] = INLINE {
IF l1=NIL THEN RETURN[l2];
FOR specs: SynthSpecs ¬ l1, specs.rest WHILE specs#NIL DO
IF specs.rest=NIL THEN { specs.rest¬l2; RETURN[l1]; };
ENDLOOP;
ERROR;
};

defaultTranslateProc: FinchSynthesizer.SynthesizerTranslateProc ¬ NIL;

synthesizerServer: SynthesizerServerRpcControl.InterfaceRecord ¬ NIL;
shhh: SHHH;
serviceID: RefID.ID ¬ nullID;

SysStateReport: ENTRY FinchSmarts.ReportSystemStateProc = {
};

ConvStateReport: ENTRY FinchSmarts.ReportConversationStateProc = {
ENABLE UNWIND => NULL;
sCDesc: FinchSynthesizer.SConvDesc = GetSCDesc[cDesc];
IF sCDesc=NIL THEN RETURN; -- No biggee
SELECT cDesc.situation.self.state FROM
$failed, $idle => -- If pending specs still exist, report aborted upstream (somehow)???
sCDesc.pendingSpecs ¬ NIL; -- For now, just zap them; problem is monitor locks.
ENDCASE;
};

ReportReport: ENTRY FinchSmarts.ReportRequestStateProc = {
ENABLE UNWIND => NULL;
SELECT actionReport.actionClass FROM
$synthesizer => {
sCDesc: FinchSynthesizer.SConvDesc = GetSCDesc[cDesc];
IF sCDesc=NIL THEN RETURN; -- presumably nothing was pending!
FOR rqs: Synthesizer.SynthSpecs ¬ sCDesc.pendingSpecs, rqs.rest WHILE rqs#NIL DO
IF actionReport.actionID#rqs.first.actionID THEN LOOP;
betterActionRequest ¬ rqs.first;
SELECT actionReport.actionType FROM
$finished, $flushed => sCDesc.pendingSpecs ¬ rqs.rest; ENDCASE;
EXIT;
ENDLOOP;
IF betterActionRequest=NIL THEN ERROR; -- Complain?["missing reports"]
};
ENDCASE=> cDesc ¬ cDesc; -- a place to stand during debugging
};

TextToSpeech: PUBLIC PROC
-- TAKES -- [
convID: Thrush.ConversationID¬Thrush.nullConvID,
synthSpec: Synthesizer.SynthSpec,
queueIt: BOOL¬TRUE,
synthesizerTranslateProc: FinchSynthesizer.SynthesizerTranslateProc¬NIL,
synthesizerModel: ATOM¬NIL, -- Not presently interpreted
synthesizerVersion: ATOM¬NIL
]
RETURNS [
nb: Thrush.NB¬$success,
newConvID: Thrush.ConversationID,
newActionID: Synthesizer.ActionID
] = {
cDesc: ConvDesc;
sCDesc: FinchSynthesizer.SConvDesc;
ScheduleSpeech: ENTRY PROC RETURNS[nb: NB¬$success] = {
ENABLE UNWIND=>NULL;
nb ¬ sCDesc.synthInterface.clientStubTextToSpeech[
sCDesc.synthInterface, sCDesc.synthShhh, cDesc.situation.self, sCDesc.synthesizerServiceID, synthSpec.textToSpeak, synthSpec.actionID, TRUE, queueIt];
IF nb=$success THEN
sCDesc.pendingSpecs ¬ NconcSpecs[sCDesc.pendingSpecs, LIST[synthSpec]];
};
[nb,cDesc,sCDesc]¬SynthesizerConnect[convID];
IF nb=$success THEN {
newConvID ¬ cDesc.situation.self.convID;
synthSpec ¬ NEW[Synthesizer.SynthSpecBody ¬ synthSpec­];
newActionID ¬
IF synthSpec.actionID=Synthesizer.nullActionID THEN (synthSpec.actionID ¬ NewID[])
ELSE synthSpec.actionID;
IF synthesizerTranslateProc#NIL THEN
synthSpec.textToSpeak ¬ synthesizerTranslateProc[synthSpec.textToSpeak]
ELSE IF defaultTranslateProc#NIL THEN
synthSpec.textToSpeak ¬ synthesizerTranslateProc[synthSpec.textToSpeak];
nb ¬ ScheduleSpeech[];
};
};

SpeakText: PUBLIC PROC[textToSpeak: Rope.ROPE] RETURNS [nb: NB] = {
RETURN[TextToSpeech[
synthSpec: NEW[Synthesizer.SynthSpecBody ¬ [textToSpeak: textToSpeak]]].nb];
};

StopSpeech: PUBLIC PROC
-- TAKES -- [
convID: Thrush.ConversationID¬Thrush.nullConvID,
actionID: Synthesizer.ActionID ¬ Synthesizer.nullActionID
]
RETURNS [
nb: Thrush.NB¬$success,
newConvID: Thrush.ConversationID,
newActionID: Synthesizer.ActionID
] = {
[nb, newConvID, newActionID] ¬ TextToSpeech[
convID, NEW[Synthesizer.SynthSpecBody ¬ [textToSpeak: NIL, actionID: actionID]], FALSE];
};

ResetSynthesizer: PUBLIC PROC[convID: Thrush.ConversationID] RETURNS [nb: Thrush.NB] ={
RETURN[DoStopSpeech[convID: convID, reset: TRUE]];
};

DoStopSpeech: PROC[
convID: Thrush.ConversationID, reset: BOOL] RETURNS [nb: Thrush.NB] ={
cDesc: ConvDesc;
sCDesc: FinchSynthesizer.SConvDesc;
IF ([nb,cDesc, sCDesc]¬SynthesizerConnect[convID]).nb#$success OR cDesc.situation.self.state#$active THEN RETURN;
nb ¬ sCDesc.synthInterface.clientStubStopSpeech[
sCDesc.synthInterface, sCDesc.synthShhh, cDesc.situation.self, sCDesc.synthesizerServiceID, reset];
};

GetSynthesizerSpecifications: PUBLIC PROC[conversationID: Thrush.ConversationID]
RETURNS [nb: Thrush.NB¬$success, synthesizerModel: ATOM, synthesizerVersion: ATOM] = {
cDesc: ConvDesc;
sCDesc: FinchSynthesizer.SConvDesc;
IF ([nb,cDesc, sCDesc]¬SynthesizerConnect[conversationID]).nb#$success OR cDesc.situation.self.state#$active THEN RETURN;
[nb, synthesizerModel, synthesizerVersion] ¬ 
sCDesc.synthInterface.clientStubGetSynthesizerSpecifications[sCDesc.synthInterface, sCDesc.synthShhh, sCDesc.synthesizerServiceID];
};
RegisterTranslateProc: PUBLIC PROC [
conversationID: Thrush.ConversationID, translate: FinchSynthesizer.SynthesizerTranslateProc¬NIL] = {
defaultTranslateProc ¬ translate;
};


SynthesizerConnect: PROC[convID: Thrush.ConversationID]
RETURNS [nb: NB, cDesc: ConvDesc, sCDesc: FinchSynthesizer.SConvDesc] = {
[nb, cDesc] ¬ FinchSmarts.ServiceConnect["text-to-speech", convID];
IF nb#$success THEN RETURN;
sCDesc ¬ GetSCDescE[cDesc];
nb ¬ SynthesizerInterface[cDesc, sCDesc];
};

GetSCDescE: ENTRY PROC[
cDesc: ConvDesc ] RETURNS [sCDesc: FinchSynthesizer.SConvDesc] = {
ENABLE UNWIND => NULL;
IF cDesc=NIL THEN ERROR;
RETURN[GetSCDesc[cDesc, TRUE]];
};

GetSCDesc: INTERNAL PROC[
cDesc: ConvDesc, createOK: BOOL¬FALSE ] RETURNS [sCDesc: FinchSynthesizer.SConvDesc] = {
IF cDesc=NIL THEN RETURN[NIL];
sCDesc ¬ NARROW[Atom.GetPropFromList[cDesc.props, $SConvDesc]];
IF ~createOK OR sCDesc#NIL THEN RETURN;
sCDesc ¬ NEW[FinchSynthesizer.SConvDescBody ¬ []];
cDesc.props ¬ Atom.PutPropOnList[cDesc.props, $SConvDesc, sCDesc];
};

SynthesizerInterface: PROC[cDesc: ConvDesc, sCDesc: FinchSynthesizer.SConvDesc]
RETURNS [nb: NB¬$success] = {
interfaceSpec: Thrush.InterfaceSpec;
IF cDesc=NIL OR sCDesc = NIL THEN ERROR; -- we don't support this mode
IF synthesizerServer#NIL AND sCDesc.synthesizerServiceID#nullID THEN RETURN;
[nb, interfaceSpec] ¬ FinchSmarts.ObtainServiceInterface[NIL, "SynthesizerServer", cDesc];
IF nb#$success THEN RETURN;
IF synthesizerServer=NIL OR interfaceSpec.serviceID#serviceID THEN {
[synthesizerServer, shhh] ¬ SynthesizerServerSunImport.ImportInterface[
instance: interfaceSpec.interfaceName.instance];
serviceID ¬ interfaceSpec.serviceID;
};
sCDesc.synthesizerServiceID ¬ serviceID;
sCDesc.synthShhh ¬ shhh;
sCDesc.synthInterface ¬ synthesizerServer;
};

idStream: Random.RandomStream ¬ Random.Create[seed: -1];
NewID: PROC RETURNS[CARD]~{RETURN[LOOPHOLE[Random.NextInt[idStream]]]};


InitializeFinchSynthesizer: PUBLIC PROC = {
FinchSmarts.RegisterForReports[key: $FinchSynthesizer, s: NIL, c: ConvStateReport, r: ReportReport];
};
}.
  œ  
FinchSynthesizerImpl.mesa
Copyright Ó 1986, 1988, 1992 by Xerox Corporation.  All rights reserved.
Last Edited by: Swinehart, September 22, 1990 3:18 pm PDT
Confusion about locks here and in FinchSmartsImpl; careful!
Declarations
Hints, valid if serviceID is current.
Supervision

At present, all that's necessary is to be sure no SCDescs remain in next iteration.  Any actions will have been abandoned.  We count on FinchSmarts to do that for us.
[nb: NB, cDesc: ConvDesc, remark: ROPE]
BROADCAST sCDesc.stateChange; -- This will be enough to alert interested parties
[cDesc: ConvDesc, actionReport: Thrush.ActionReport, actionRequest: REF]
RETURNS[betterActionRequest: REF]
This one should get the reports first.  Then the client that requested action reports can get them too.
BROADCAST sCDesc.stateChange;
Throw away pending intervals that are complete.  This includes intervals preceding the one being reported on.
Endcase events are now expected, since there is no event-filtering in FinchSmarts; these will be events for other applications.
Client Functions

Describe the assigned synthesizer.


Utilities
Count on validity of conversation to validate serviceID;
Initialization
Ask Finch to inform us of changes in conversation state, and action reports.

Swinehart, October 3, 1986 4:40:54 pm PDT
Based on a prototype FinchRecordingImpl, and on code extracted from old FinchSmartsImpls., DIRECTORY, }, PlaybackTune


 Ê	  •NewlineDelimiter
–(cedarcode) style™ šœ™Jšœ
Ïeœ=™HJšœ9™9—Icode˜ šÏk	˜	Kšœžœ$˜.K˜K˜§Kšœžœ#˜/K˜Kšœžœžœ˜K˜MKšœS˜SKšœžœ˜5Kšœžœ˜4K˜K˜ —šÏnœžœž˜#JšÏt=™=Kšžœ6˜=Kšžœ˜K˜ —™K˜ Kšœ
žœ˜&Kšœžœ˜-Kšžœžœ
žœ˜K˜!Kšžœžœ
žœ˜KšœžœÏcÐck¡˜KK˜ šŸ
œžœžœžœ˜DKšžœžœžœžœ˜šžœ$žœžœž˜9Kšžœžœžœžœ˜6Kšžœ˜—Kšžœ˜Kšœ˜K˜ —KšœBžœ˜FK˜ ™%KšœAžœ˜EKšœžœ˜Kšœžœ
˜K˜ ——šœ™J™ šŸœžœ&˜;J™¦K˜K˜ —šÐbnœžœ,˜BJšœžœžœ™'Kšžœžœžœ˜K˜6Kš	žœžœžœžœ¡˜'šžœž˜&šœ¡Ðct¡B¤˜YKšœžœ¡¤¡1¤˜Q—Kšžœ˜—Jšž	œ¡2™PK˜K˜ —šŸœžœ'˜:JšœDžœ™HJšžœžœ™!Jšœg™gKšžœžœžœ˜šžœž˜$šœ˜Kšœ6˜6Kš	žœžœžœžœ¡"˜=Jšž	œ™šžœ=žœžœž˜PKšžœ*žœžœ˜6K˜ šžœž˜#K™mKšœ7žœ˜?—Kšžœ˜Kšžœ˜—Kšžœžœžœžœ¡¤¡¤˜HK˜—šžœ¡$˜=K™——Kšœ˜—K˜ —™J™ šŸœž˜š¡Ñcjk¡œ˜K˜0Kšœ!˜!Kšœ	žœžœ˜KšœDž˜HKšœžœžœ¡˜8Kšœžœž˜Kšœ˜—šžœ˜	Kšœžœ
˜Kšœ!˜!Kšœ!˜!Kšœ˜—K˜K˜#š
Ÿœžœžœžœžœ˜7KšÐksÏs¦§¦§˜šœ1 ˜2Kšœ‡žœ˜–—šžœž˜Kšœ6žœ˜G—Kšœ˜—K˜-šžœžœ˜K˜(Kšœžœ)˜8˜Kšžœ-žœ˜RKšžœ˜—šžœžœž˜$Kšœ
 œ œ œ
 ˜G—šžœžœžœž˜%Kš	œ
 œ œ œ
 œ˜H—K˜K˜—K˜K˜ —šŸ	œžœžœžœžœžœ˜Cšžœ˜Kšœžœ>˜L—K˜K˜ —šŸ
œž˜š¡¥¡œ˜K˜0K˜9Kšœ˜—šžœ˜	Kšœžœ
˜Kšœ!˜!Kšœ!˜!Kšœ˜—˜,Kšœžœ+žœžœ˜X—Kšœ˜K˜ —šŸœžœžœžœ˜WKšžœ%žœ˜2Kšœ˜K˜ —šŸœžœ˜Kšœ&žœžœžœ˜FK˜K˜#Kšžœ=žœ$žœžœ˜q˜0Kšœc˜c—Kšœ˜K˜ —šŸœžœžœ'˜PKšžœžœžœžœ˜VK™"K˜K˜#KšžœEžœ$žœžœ˜y˜-Kšœƒ˜ƒ—K˜K™ —šŸœžœ˜$Kšœ\žœ˜dK˜!K˜J™ ——™	K˜ K˜ šŸœžœ˜7Kšžœžœ:˜IK˜CKšžœžœžœ˜K˜K˜)K˜K˜ —šŸ
œžœžœ˜Kšœžœ)˜BKšžœžœžœ˜Kšžœžœžœžœ˜Kšžœžœ˜K˜K˜ —šŸ	œžœžœ˜Kšœžœžœžœ)˜XKš
žœžœžœžœžœ˜Kšœ	žœ0˜?Kš
žœžœžœžœžœ˜'Kšœ	žœ&˜2K˜BK˜K˜ —šŸœžœ5˜OKšžœžœ˜K˜$Kšžœžœžœ
žœžœžœ¡˜Fš
žœžœžœ$žœžœ˜LJ™8—Kšœ9žœ˜ZKšžœžœžœ˜šžœžœžœ)˜D˜GK˜0—K˜$K˜—K˜(K˜K˜*K˜K˜ —K˜8KšŸœžœžœžœžœžœ˜GK˜ —J™˜ šŸœžœžœ˜+Kšœ:žœ'˜dJ™LK˜——K˜K™ ™)KšœYÏr™u—K™ K™ K™ — …—    Ê  ,h  