<> <> <> <> DIRECTORY Atom USING [ DottedPair, DottedPairNode ], IO, Commander USING [ CommandProc, Register ], Convert USING [ RopeFromInt ], Lark USING [ bStar, bThorp, ConnectionSpec, ConnectionSpecRec, CommandEvent, CommandEvents, CommandEventSequence, Device, disabled, EchoParameters, EchoParameterRecord, enabled, endNum, Event, KeyTable, Milliseconds, o3i1, o2i2, o1i1, Passel, reset, SHHH, StatusEvent, Tone, ToneSpec, ToneSpecRec, VoiceBuffer ], LarkPlay USING [ ToneList, ToneSpec, ToneSpecRec ], LarkOpsRpcControl, LarkSmarts, List USING [ Nconc1 ], Multicast USING [ HandleMulticast, StopHandlingMulticast ], Nice, Process USING [ Detach, EnableAborts, MsecToTicks, SetTimeout ], Pup USING [ nullSocket ], Rope USING [ Cat, Concat, Fetch, FromChar, Length, ROPE, Substr, Translate, TranslatorType ], RPC USING [ CallFailed ], ThNet USING [ pd ], ThParty USING [ PartyInfo ], ThPartyPrivate USING [ SmartsData ], Thrush USING[ NetAddress, ProseSpec, ProseSpecs, ROPE, SHHH, SmartsID ], ThSmartsPrivate USING [ ConvDesc, flushMarker, proseFailure, indexMarkerEnd, LarkInfo, LarkProseQueue, LarkState, LSwitches, LState, maxClientMarker, maxControlMarker, ProgressTones, ProseCmd, SmartsInfo, SwitchState ], TU USING [ RefAddr ], VoiceUtils USING [ ProblemFR, Report ] ; LarkOutImpl: CEDAR MONITOR LOCKS info USING info: LarkInfo IMPORTS Commander, Convert, IO, LarkOpsRpcControl, List, Multicast, Nice, Process, Rope, RPC, ThNet, TU, VoiceUtils EXPORTS ThSmartsPrivate= { OPEN IO; <> ConvDesc: TYPE = ThSmartsPrivate.ConvDesc; LarkInfo: TYPE = ThSmartsPrivate.LarkInfo; LarkState: TYPE = ThSmartsPrivate.LarkState; SmartsData: TYPE = ThPartyPrivate.SmartsData; SmartsInfo: TYPE = ThSmartsPrivate.SmartsInfo; SmartsID: TYPE = Thrush.SmartsID; ProseCmd: TYPE = ThSmartsPrivate.ProseCmd; ROPE: TYPE = Thrush.ROPE; firstTone: LarkState = FIRST[ThSmartsPrivate.ProgressTones]; bStar: Lark.Event = Lark.bStar; bThorp: Lark.Event = Lark.bThorp; enabled: Lark.Event = Lark.enabled; endNum: Lark.Event = Lark.endNum; disabled: Lark.Event = Lark.disabled; reset: Lark.Event = Lark.reset; larkRegistry: ROPE _ ".Lark"; PD: TYPE = RECORD [ waitForTelco: CARDINAL _ 500, -- default values for initial pause, on time, and off time telcoMinOn: CARDINAL _ 60, -- when generating touch-tones. telcoMinOff: CARDINAL _ 60, flashWaitTime: CARDINAL _ 800, idleWaitTime: CARDINAL _ 20000, -- time for supervisor to wait for more events. blinkWaitTime: CARDINAL _ 500, -- if LED is blinking, don't wait so long. backDoorOH: BOOL_FALSE, callTimeoutOK: BOOL_FALSE, -- set to keep Thrush alive when debugging a Lark. tonesInvalid: BOOL_TRUE, tonesLast: BOOL_TRUE, -- sets up alternate lark setup situation in supervisor loop <<<>>> noisyFeeps: BOOL_FALSE -- TRUE if caller is to hear automatically-generated touchtones. ]; pd: REF PD _ NEW[PD_[]]; dialTone: LarkPlay.ToneSpec _ NIL; busyTone: LarkPlay.ToneSpec _ NIL; errorTone: LarkPlay.ToneSpec _ NIL; ringbackTone: LarkPlay.ToneSpec _ NIL; quenchSpec: Lark.ToneSpec _ NEW[Lark.ToneSpecRec _[volume: 0, totalTime: 0, tones: LIST[[0,0,0,0]]]]; <> pReset: PUBLIC ProseCmd _ "\022"; stopAndFlush: PUBLIC ProseCmd _ "\033[S"; commenceSpeech: ProseCmd = "\033[C"; -- \033 is ESC cmdLeader: ProseCmd = "\033["; -- for constructing arbitrary commands indexMarkerLen: INT = 6; <> minControlMarker: INT = 200; -- reserved for packet control <> speechDoneMarker: INT = 255; speechDone: ProseCmd = "\033[C\033[255i"; -- commence speech & report back when done <> EnterLarkState: PUBLIC ENTRY PROC[ info: LarkInfo, newState: LarkState, data: LIST OF REF ANY_NIL ] = { ENABLE UNWIND=>NULL; EnterLarkSt[info, newState, data]; }; EnterLarkSt: PUBLIC INTERNAL PROC[ info: LarkInfo, newState: LarkState, data: LIST OF REF ANY ] = { ENABLE UNWIND=>NULL; trans: LSTrans _ lsTrans[info.larkState][newState]; oldState: LarkState = info.larkState; sw: BOOL_FALSE; otherAction: REF_NIL; connectionSpec: ThParty.PartyInfo; toneSpec: LarkPlay.ToneSpec; newProses: Thrush.ProseSpecs; ropeSpec: Rope.ROPE; keyTable: Lark.KeyTable; feepSpecs: REF AFeepType_NIL; IF pd.tonesInvalid THEN SetTones[]; FOR dL: LIST OF REF ANY_data, dL.rest WHILE dL#NIL DO WITH dL.first SELECT FROM cS: ThParty.PartyInfo => connectionSpec _ cS; tS: LarkPlay.ToneSpec => toneSpec _ tS; nP: Thrush.ProseSpecs => newProses _ nP; kT: Lark.KeyTable => keyTable _ info.keyTable _ kT; dP: Atom.DottedPair => SELECT dP.key FROM $audioSource => {info.audioSource _ NARROW[dP.val]; sw_TRUE; }; $transmitOnly => {info.transmitOnly _ dP.val=$true;sw_TRUE; }; $textToSpeech => info.textToSpeech _ dP.val=$true; $phoneNumber => ropeSpec _ NARROW[dP.val]; ENDCASE; -- unknown ENDCASE; -- unknown ENDLOOP; IF connectionSpec # NIL AND connectionSpec.numParties=2 THEN TRUSTED { info.forwardedCall _ connectionSpec[0].socket.host # connectionSpec[1].socket.host; IF info.blinkProcess=NIL THEN Process.Detach[info.larkProcess _ FORK BlinkLED[info]]; }; <> <> SELECT trans FROM nop => NULL; -- Certifiably nothing at all to do, unless there's data or some submode has changed.
watch out set => { info.larkState_newState; RETURN; }; X => {info.audioSource _ NIL; info.transmitOnly _ FALSE;LarkProblem["%g: Invalid LarkState Transition", info]; RETURN;}; rec => { info.larkState_recovering; LarkFailed[info.larkSmartsInfo]; --RETURN--}; fai => { info.larkState _ failed; LarkProblem["%g: Lark failure requested by server", info]; info.larkProcess _ NIL; info.audioSource _ NIL; info.transmitOnly _ FALSE; NOTIFY info.stateChange; -- Be sure process notices failure and disappears. RETURN; }; zap => { info.audioSource _ NIL; info.transmitOnly _ FALSE; }; ENDCASE; IF tSetFwd[trans] = setFwd THEN { <> newState _ IF info.forwardedCall THEN trunkForwarding ELSE trunkTalking; trans _ lsTrans[info.larkState][newState]; }; info.larkState_newState; <> <> IF (tDisconn[trans] = $disconnect OR connectionSpec#NIL) AND info.spec#NIL THEN { <> IF ThNet.pd.debug THEN Deb[ info, 'd ]; QueueLarkAction[info, aDisconnect]; }; <> toneSpec _ SELECT trans FROM dia, diu => dialTone, -- to handset receiver rbk, rbu => IF toneSpec#NIL THEN toneSpec ELSE ringbackTone, bzy, bzu => busyTone, err, eru => errorTone, rng, rgu => toneSpec, ENDCASE => NIL ; SELECT tDoTones[trans] FROM doTones => { IF ThNet.pd.debug THEN Deb[ info, 'T ]; IF toneSpec#NIL THEN QueueLarkAction[info, toneSpec]; }; stopTones => { IF ThNet.pd.debug THEN Deb[ info, 't ]; QueueLarkAction[info, aNoTones]; }; ENDCASE; IF newProses#NIL THEN SELECT trans FROM sup, spn, tlk => { reqProseSpecs, lastReqProseSpecs: Thrush.ProseSpecs _ NIL; FOR pL: Thrush.ProseSpecs _ newProses, pL.rest WHILE pL#NIL DO pS: Thrush.ProseSpec = pL.first; IF pS.type = request THEN { elt: Thrush.ProseSpecs _ LIST[pS]; IF reqProseSpecs=NIL THEN reqProseSpecs _ elt ELSE IF lastReqProseSpecs=NIL THEN ERROR ELSE lastReqProseSpecs.rest _ elt; lastReqProseSpecs _ elt; }; ENDLOOP; IF reqProseSpecs#NIL THEN { IF ThNet.pd.debug THEN Deb[info, 'P, rope[newProses.first.prose], IF newProses.rest#NIL THEN rope[" ... MORE"] ELSE [null[]]]; QueueLarkAction[info, reqProseSpecs]; }; }; ENDCASE; <> <> SELECT tHookState[trans] FROM reset => { SELECT info.switchState FROM $monitor, $speaker => info.switchState_$onhook; -- going totally idle ENDCASE; }; spkrTrans => IF info.switchState=$onhook THEN -- dialtone, direct connect or ringback info.switchState _ $speaker; ENDCASE; -- no state change cases. IF info.switchState#info.lastSwitchState THEN sw_TRUE; SELECT tSwitch[trans] FROM switch => sw_TRUE; switchIfDiff => IF oldState { IF ThNet.pd.debug THEN Deb[info, 'F]; feepSpecs _ RopeToDTMF[ropeSpec]; pd.noisyFeeps _ feepSpecs.audible; }; ENDCASE; IF sw THEN TRUSTED { command: ROPE _ larkCommands[info.switchState][newState]; IF ThNet.pd.debug THEN Deb[info, 'M, rope[command]]; otherAction _ QueueCommandSequence[info, command, @info.lState, info.scratchEv]; IF trans=fls THEN { Process.Detach[FORK FlashWait[info]]; info.larkState _ oldState; -- never really enter fls state, stay in forwarding or trunkTalking. }; info.lastSwitchState _ info.switchState; }; IF feepSpecs#NIL THEN QueueLarkAction[info, feepSpecs]; <> IF keyTable#NIL THEN { IF ThNet.pd.debug THEN Deb[info, 'K]; QueueLarkAction[info, keyTable]; }; IF connectionSpec#NIL THEN { IF ThNet.pd.debug THEN Deb[info, 'C]; SELECT trans FROM sup, spn, tlk, frd, frn => QueueLarkAction[info, connectionSpec]; sgl, sgn => IF info.forwardedCall THEN QueueLarkAction[info, connectionSpec]; <> ENDCASE; }; IF otherAction#NIL THEN { IF ThNet.pd.debug THEN Deb[info, 'O]; QueueLarkAction[info, otherAction]; }; }; LarkFailed: PUBLIC ERROR [smartsInfo: SmartsInfo] = CODE; TonesDone: PUBLIC ENTRY PROC[info: LarkInfo, commandEvent: Lark.StatusEvent ] = { Deb[info, 'z]; SELECT commandEvent.event FROM 'F=> -- Feeping complete { IF info.larkState#trunkSignalling THEN RETURN; EnterLarkSt[info, trunkTalking, NIL]; }; ENDCASE => -- other tones finished. QueueLarkAction[info, NEW[ATonesDoneType _ [commandEvent.event]]]; }; FlashWait: PUBLIC ENTRY PROC[info: LarkInfo ] = TRUSTED { ENABLE UNWIND => NULL; flashWait: CONDITION; IF info=NIL THEN RETURN; Process.SetTimeout[@flashWait, Process.MsecToTicks[pd.flashWaitTime]]; -- 600 ms or so. Deb[info, 'w]; WAIT flashWait; Deb[info, 'W]; IF info.larkState=trunkTalking THEN -- nothing has gone wrong <<<>>> []_QueueCommandSequence[info, larkCommands[info.switchState][info.larkState], @info.lState, info.scratchEv]; }; BlinkLED: PUBLIC ENTRY PROC[info: LarkInfo] = TRUSTED { ENABLE UNWIND => NULL; blinkWait: CONDITION; IF info=NIL THEN RETURN; WHILE info.forwardedCall AND info.larkState >= trunkSignalling AND info.larkState <= trunkFlashing AND info.larkProcess#NIL DO Deb[info, 'B]; []_QueueLarkAction[info, aToggleLED]; Process.SetTimeout[@blinkWait, Process.MsecToTicks[pd.blinkWaitTime]]; -- 500 ms or so. WAIT blinkWait; ENDLOOP; info.blinkProcess _ NIL; }; QueueFeeps: PUBLIC PROC[sInfo: SmartsInfo, feeps: Rope.ROPE ] = { EnterLarkState[sInfo.larkInfo, trunkSignalling, LIST[NEW[Atom.DottedPairNode_[$phoneNumber, feeps]]]]; }; ProseControlDone: PUBLIC INTERNAL PROC[info: LarkInfo, marker: INT] = { IF marker=ThSmartsPrivate.proseFailure THEN { LarkProblem["Text-to-speech service failed", info]; Fail[info]; } ELSE QueueLarkAction[info, NEW[ASpeechDoneType _ [marker]]]; }; <<>> <> FailE: ENTRY PROC[info: LarkInfo] = {Fail[info];}; Fail: INTERNAL PROC[info: LarkInfo] = { IF info.larkState#recovering THEN info.larkState_failed; }; LarkSupervisor: PROCEDURE[ info: LarkInfo ] = { <> <> <> ENABLE UNWIND => NULL; req: REF; WaitForAction: ENTRY PROC[info: LarkInfo] RETURNS [ref: REF_NIL] = TRUSTED { ENABLE UNWIND=>NULL; DO elt: LIST OF REF _ info.newActions; IF info.larkState=failed OR info.larkState=recovering THEN RETURN[NIL]; IF elt # NIL THEN { ref_elt.first; info.newActions _ elt.rest; RETURN[ref]; }; Process.SetTimeout[@info.stateChange, Process.MsecToTicks[pd.idleWaitTime]]; WAIT info.stateChange; IF info.newActions = NIL THEN { IF info.nextToneList#NIL THEN Fail[info]; -- Notification is late. RETURN[NIL]; }; ENDLOOP; }; IF info.larkToneSpec=NIL THEN info.larkToneSpec _ NEW[Lark.ToneSpecRec _ [volume: 0, totalTime: 0, tones: NIL]]; IF info.cSpec=NIL THEN info.cSpec _ NEW[Lark.ConnectionSpecRec _ [ protocol: interactive, encoding: muLaw, sampleRate: 8000, packetSize: 160, buffer: in1, keyIndex: IF ThNet.pd.encryptVoice THEN 1 ELSE 0, localSocket: [[0],[0], Pup.nullSocket], remoteSocket: [[0],[0], Pup.nullSocket] ]]; TRUSTED { Process.EnableAborts[@info.stateChange]; }; <> StopMulticast[info]; Multicast.StopHandlingMulticast[shh: info.shh, realHost: info.netAddress.host]; WHILE (req_WaitForAction[info])#NIL DO -- Deal with communications failure. ENABLE { RPC.CallFailed => IF pd.callTimeoutOK THEN RESUME ELSE { LarkProblem["%g: Call Failed", info]; GOTO Failed; }; ABORTED => { LarkProblem["%g: LarkSupervisor aborted", info]; GOTO Failed; }; }; DoTones: PROC[newTones: BOOL] = { -- Does one tone from current list of tones IF info.nextToneList=NIL THEN RETURN; info.larkToneSpec.volume _ info.toneSpec.volume; info.expectedNotification _ IF info.expectedNotification='z THEN 'a ELSE info.expectedNotification+1; info.larkToneSpec.notification _ [tones, info.expectedNotification]; info.larkToneSpec.tones _ info.nextToneList.first; []_info.interface.SpecifyTones[shh: info.shh, queueIt: ~newTones, tones: info.larkToneSpec]; }; SpeakText: PROC = { textPkt: Rope.ROPE; IF ~info.textToSpeech OR info.flushInProgress THEN RETURN; WHILE info.pktsOutstanding < numPkts AND info.textToSpeak.Length[] > 0 DO proseText: Rope.ROPE _ info.textToSpeak; IF proseText.Length[] <= maxTextPktLen THEN { textPkt _ Rope.Concat[proseText, speechDone]; <> info.textToSpeak _ ""; info.ctrlMarkerQueue _ List.Nconc1[info.ctrlMarkerQueue, NEW[INT _ speechDoneMarker]]; } ELSE { <> index: INT _ maxTextPktLen; WHILE IO.TokenProc[Rope.Fetch[proseText, index-1]] = other DO index _ index-1; IF index=0 THEN {index _ maxTextPktLen; EXIT}; <> ENDLOOP; IF Rope.Fetch[proseText, index-1] = IO.ESC THEN index _ index-1 ELSE IF Rope.Fetch[proseText, index-2] = IO.ESC THEN index _ index-2; <> info.controlMarker _ IF info.controlMarker>=ThSmartsPrivate.maxControlMarker THEN minControlMarker ELSE info.controlMarker+1; textPkt _ Rope.Cat[cmdLeader, Convert.RopeFromInt[info.controlMarker], Rope.FromChar[ThSmartsPrivate.indexMarkerEnd], proseText.Substr[len: index]]; info.textToSpeak _ proseText.Substr[start: index]; info.ctrlMarkerQueue _ List.Nconc1[info.ctrlMarkerQueue, NEW[INT _ info.controlMarker]]; }; info.interface.CommandString[shh: info.shh, device: keyboard, commands: textPkt]; info.pktsOutstanding _ info.pktsOutstanding+1; ENDLOOP; }; WITH req SELECT FROM d: REF ADisconnectType => IF info.spec#NIL THEN { buf: Lark.VoiceBuffer _ out1; info.interface.Disconnect[ shh: info.shh, buffer: in1 ]; -- always stop in1 (tx1) FOR i: NAT IN [1..info.spec.numParties) DO info.interface.Disconnect[ shh: info.shh, buffer: buf ]; -- out1 (tx1) through outn (txn) buf _ SUCC[buf]; ENDLOOP; IF info.spec.numParties>2 THEN StopMulticast[info]; info.spec _ NIL; }; spec: ThParty.PartyInfo => { cSpec: Lark.ConnectionSpec = info.cSpec; conference: BOOL _ spec.numParties>=3; IF spec.numParties>=2 THEN { <> IF conference THEN conference _ StartMulticast[info, spec.conferenceHost]; <> cSpec.buffer _ in1; cSpec.remoteSocket _ spec[0].socket; cSpec.remoteSocket.host _ IF conference THEN spec.conferenceHost.host ELSE spec[1].socket.host; cSpec.localSocket _ cSpec.remoteSocket; -- superstition info.interface.Connect[shh: info.shh, specs: cSpec ]; <> cSpec.buffer _ out1; FOR i: NAT IN [1..spec.numParties) DO cSpec.localSocket _ spec[i].socket; IF conference THEN cSpec.localSocket.host _ spec.conferenceHost.host; cSpec.remoteSocket _ cSpec.localSocket; -- superstition info.interface.Connect[shh: info.shh, specs: cSpec ]; cSpec.buffer _ SUCC[cSpec.buffer]; ENDLOOP; }; }; keyTable: Lark.KeyTable => info.interface.SetKeyTable[shh: info.shh, table: keyTable]; ts: LarkPlay.ToneSpec => { info.toneSpec_ts; info.nextToneList _ info.toneSpec.tones; DoTones[TRUE]; }; ps: Thrush.ProseSpecs => { IF ~info.textToSpeech THEN LOOP; FOR proseS: Thrush.ProseSpecs _ ps, proseS.rest WHILE proseS#NIL DO pSpec: Thrush.ProseSpec = proseS.first; newText: Rope.ROPE; IF ~pSpec.queueIt THEN ProseFlush[info, stopAndFlush]; newText _ IF pSpec.direction=record -- really want BOOLEAN pSpec.filter THEN pSpec.prose -- allows client to send Prose reset ELSE Rope.Translate[base: pSpec.prose, translator: FilterText]; info.textToSpeak _ Rope.Concat[info.textToSpeak, newText]; info.clientMarker _ IF info.clientMarker = ThSmartsPrivate.maxClientMarker THEN minClientMarker ELSE info.clientMarker + 1; EnterProseQueue[info, pSpec, info.clientMarker]; info.textToSpeak _ Rope.Cat[info.textToSpeak, cmdLeader, Convert.RopeFromInt[info.clientMarker], Rope.FromChar[ThSmartsPrivate.indexMarkerEnd]]; ENDLOOP; <> SpeakText[]; }; pd: REF ASpeechDoneType => { marker: REF INT _ NIL; IF pd.indexMarker = ThSmartsPrivate.flushMarker THEN { info.flushInProgress _ FALSE; info.ctrlMarkerQueue _ NIL; info.pktsOutstanding _ 0; SpeakText[]; } ELSE { IF info.ctrlMarkerQueue = NIL THEN { LarkProblem["Text-to-speech service: empty control marker list", info]; GOTO Failed; }; marker _ NARROW[info.ctrlMarkerQueue.first]; IF pd.indexMarker = marker^ THEN { info.ctrlMarkerQueue _ info.ctrlMarkerQueue.rest; info.pktsOutstanding _ info.pktsOutstanding-1; SpeakText[]; } ELSE { LarkProblem["Text-to-speech service: wrong marker received", info]; GOTO Failed; }; }; }; td: REF ATonesDoneType => IF info.toneSpec#NIL THEN { IF td.event#info.expectedNotification THEN GOTO Failed; IF info.nextToneList#NIL AND info.nextToneList.rest#NIL THEN info.nextToneList _ info.nextToneList.rest ELSE IF NOT info.toneSpec.repeatIndefinitely THEN { info.toneSpec_NIL; info.nextToneList_NIL } ELSE info.nextToneList _ info.toneSpec.tones; IF info.nextToneList#NIL THEN DoTones[FALSE]; }; a: REF ANoTonesType => { info.toneSpec_NIL; info.nextToneList_NIL; quenchSpec.tones.first.on _ 0; []_info.interface.SpecifyTones[shh: info.shh, tones: quenchSpec, queueIt: FALSE]; }; led: REF AToggleLEDType => { info.lState.lSw[led] _ IF info.lState.lSw[led] = disabled THEN enabled ELSE disabled; ledToggler[0] _ [led, info.lState.lSw[led]]; []_info.interface.Commands[info.shh, ledToggler]; }; resetAction: REF ResetActionType => { []_info.interface.Reset[shh: info.shh, rName: "Don't revert"]; <<< revert. Remember to change 2d parameter next time Lark.mesa changes.>>>> StopMulticast[info]; ProseFlush[info, pReset]; }; echoParameters: Lark.EchoParameters => []_info.interface.EchoSupression[shh: info.shh, echo: echoParameters]; commands: Lark.CommandEvents => IF commands#NIL THEN info.interface.Commands[ info.shh, commands ]; feepSpecs: REF AFeepType => { IF feepSpecs=NIL THEN LOOP; IF (quenchSpec.tones.first.on _ feepSpecs.initialDelay)#0 THEN []_info.interface.SpecifyTones[shh: info.shh, tones: quenchSpec, queueIt: FALSE]; []_info.interface.Feep[ shh: info.shh, on: feepSpecs.on, off: feepSpecs.off, notify: [tones, 'F], waveTable: ThNet.pd.feepVolume, queueIt: TRUE, events: feepSpecs.digits]; } ENDCASE; REPEAT Failed => { FailE[info]; }; ENDLOOP; info.larkProcess _ NIL; }; StartMulticast: PROC[info: LarkInfo, hostAddress: Thrush.NetAddress] RETURNS[ok: BOOL_TRUE] = { IF info.spec=NIL OR info.spec.numParties <=2 THEN RETURN[FALSE]; ok _ Multicast.HandleMulticast[shh: info.shh, net: info.netAddress.net, realHost: info.netAddress.host, listeningTo: hostAddress.host]; IF ~ok THEN { VoiceUtils.ProblemFR["Couldn't set multicasting [%g => %g]", $Lark, info, int[info.netAddress.host], int[hostAddress.host]]; RETURN; }; info.interface.SetHostNumber[shh: info.shh, host: [hostAddress.net, hostAddress.host]]; }; StopMulticast: PROC[info: LarkInfo, force: BOOL_FALSE] = { IF info.spec=NIL OR info.spec.numParties <=2 THEN RETURN; info.interface.SetHostNumber[shh: info.shh, host: [info.netAddress.net, info.netAddress.host]]; Multicast.StopHandlingMulticast[shh: info.shh, realHost: info.netAddress.host]; }; FilterText: Rope.TranslatorType = { -- PROC [old: CHAR] RETURNS [new: CHAR] <> SELECT old FROM IO.TAB, IO.LF, IO.CR, IO.ESC => new _ old; -- Don't allow user to send reset (ControlR) < IO.SP => new _ IO.SP; ENDCASE => new _ old; }; ProseFlush: PROC[info: LarkInfo, proseCmd: ProseCmd] = { <> info.textToSpeak _ ""; IF ~info.flushInProgress THEN { info.interface.CommandString[shh: info.shh, device: keyboard, commands: proseCmd]; info.flushInProgress _ TRUE; }; }; <<>> EnterProseQueue: ENTRY PROC[info: LarkInfo, pS: Thrush.ProseSpec, internalClientMarker: INT] = { <> elt: ThSmartsPrivate.LarkProseQueue _ LIST[[pS, internalClientMarker]]; IF info.proseQueue=NIL THEN info.proseQueue _ elt ELSE IF info.pTail=NIL THEN ERROR ELSE info.pTail.rest _ elt; info.pTail _ elt; }; <> QueueLarkAction: INTERNAL PROC[info: LarkInfo, ref: REF] = { elt: LIST OF REF = LIST[ref]; lst: LIST OF REF = info.lastAction; IF info.newActions=NIL THEN info.newActions _ elt ELSE IF lst=NIL THEN ERROR ELSE lst.rest _ elt; info.lastAction _ elt; IF info.larkProcess=NIL THEN TRUSTED { Process.Detach[info.larkProcess _ FORK LarkSupervisor[ info ]]; }; NOTIFY info.stateChange; }; LarkProblem: PROC[remark: ROPE, info: LarkInfo] = { VoiceUtils.ProblemFR[remark, $Lark, info, TU.RefAddr[info.larkSmartsInfo]]; }; QueueCommandSequence: INTERNAL PROC[ info: LarkInfo, commands: ROPE, lState: LONG POINTER TO LState, scratchEv: Lark.CommandEvents] RETURNS[otherAction: REF_NIL]= TRUSTED { eventIndex: INTEGER_-1; c: CHAR; i: NAT; index: INTEGER; event: Lark.Event; events: Lark.CommandEvents _ scratchEv; nextState: LState _ []; len: NAT; IF commands=NIL THEN RETURN; -- status quo len _ commands.Length[]; <> FOR i IN [0..len) DO SELECT (c_commands.Fetch[i]) FROM 'J, 'j => IF ~pd.backDoorOH THEN LOOP; ENDCASE; SELECT c FROM 'Z => { lState^_ []; otherAction _ resetAction; }; -- Zap; reset hardware to full idle 'X, 'x => { -- Crossbar switch specification, possibly parameterized by next character param: CHAR _ commands.Fetch[i+1]; outputs: PACKED ARRAY [0..8) OF BOOLEAN; row: NAT; wasParam, doIt: BOOL_TRUE; SELECT param FROM IN ['0..'9] => wasParam _ FALSE; -- no parameter, just do it. <> 'A => IF info.audioSource#$linea THEN doIt_FALSE; 'B => IF info.audioSource#$lineb THEN doIt_FALSE; 'r => IF info.audioSource=$linea OR info.audioSource=$lineb THEN doIt_FALSE; 't => IF info.transmitOnly THEN doIt_FALSE; -- inhibit all receive switching. 'F => IF ~pd.noisyFeeps THEN doIt_FALSE; -- caller hears auto-feeping ENDCASE => doIt_FALSE; -- unrecognized parameter, don't do it; IF wasParam THEN { i_i+1; param _ commands.Fetch[i+1]; }; row _ Digit[param]; outputs _ LOOPHOLE[nextState.xbar[row]]; IF doIt THEN outputs[Digit[commands.Fetch[i+2]]] _ (c='X); nextState.xbar[row] _ LOOPHOLE[outputs]; i_i+2; LOOP; }; 'E, 'e => { nextState.echoStyle _ commands.Fetch[i_i+1]-'0; otherAction _ echosOn[nextState.echoStyle]; }; 'M, 'm => { nextState.voiceMode _ SELECT commands.Fetch[i_i+1] FROM '0 => Lark.o3i1, '1 => Lark.o2i2, '2 => Lark.o1i1, ENDCASE => ERROR; }; ENDCASE=> { IF c IN ['a..'z] THEN { event _ Lark.disabled; c_c-('a-'A); } ELSE event _ Lark.enabled; IF lStateForLetter[c]#none THEN nextState.lSw[lStateForLetter[c]] _ event; }; ENDLOOP; IF nextState=lState^ THEN RETURN; IF nextState.echoStyle#lState.echoStyle AND otherAction=NIL THEN otherAction _ echosOff[lState.echoStyle]; FOR iteration: NAT IN [0..1] DO -- 0: compute size; 1: fill in result sequence. index_-1; IF nextState.voiceMode#lState.voiceMode THEN events[index_index+1] _ [voiceMode, nextState.voiceMode]; FOR i: LSwitches DECREASING IN LSwitches DO IF nextState.lSw[i]#lState.lSw[i] THEN events[index_index+1] _ [lDevs[i], nextState.lSw[i]]; ENDLOOP; FOR i: NAT IN [0..8) DO IF nextState.xbar[i]#lState.xbar[i] THEN { outputs: PACKED ARRAY[0..8) OF BOOLEAN = LOOPHOLE[lState.xbar[i]]; nxtOutputs: PACKED ARRAY[0..8) OF BOOLEAN = LOOPHOLE[nextState.xbar[i]]; FOR j: NAT IN [0..8) DO IF outputs[j]#nxtOutputs[j] THEN events[index_index+1] _ [ Lark.Device[LOOPHOLE[IF nxtOutputs[j] THEN 23 ELSE 22]], LOOPHOLE[i*16+j] ]; ENDLOOP; }; ENDLOOP; IF index=-1 THEN { events_NIL; EXIT; }; IF iteration=0 THEN events _ NEW[Lark.CommandEventSequence[index+1]]; ENDLOOP; QueueLarkAction[info, events]; lState^ _ nextState; lState.lSw[xBarAll] _ Lark.disabled; }; Digit: PROC[c: CHAR] RETURNS [digit: NAT] = INLINE { RETURN[c-'0]; }; RopeToDTMF: PROC [r: Thrush.ROPE] RETURNS [fs: REF AFeepType] = { len: INT _ MIN[Lark.Passel.LAST, r.Length[]]; ce: Lark.CommandEvents; ceIndex: INT_0; number: INTEGER; fs _ NEW[AFeepType_[]]; FOR rIndex: INT IN [0..len) DO c: CHAR = r.Fetch[rIndex]; SELECT c FROM IN ['0..'9], IN ['a..'d], '#, '* => ceIndex _ ceIndex+1; 'P => IF ceIndex#0 THEN ceIndex _ ceIndex+1 ELSE fs.initialDelay _ number*100; 'A => fs.audible _ TRUE; 'O => fs.on _ number*10; 'F => fs.off _ number*10; IN ['\001..'\037] => number _ c-'\000; ENDCASE; -- unrecognized, so ignore it. ENDLOOP; ce _ NEW[Lark.CommandEventSequence[ceIndex]]; fs.digits _ ce; ceIndex _ 0; FOR rIndex: INT IN [0..len) DO c: CHAR = r.Fetch[rIndex]; val: CHAR _ '\000; SELECT c FROM IN ['0..'9] => val _ LOOPHOLE[128 + c - '0]; IN ['a..'d] => val _ LOOPHOLE[138 + c - 'a]; '* => val _ Lark.bStar; '# => val _ Lark.bThorp; IN ['\001..'\037] => number _ c-'\000; 'P => IF ceIndex#0 THEN val _ LOOPHOLE[number*10]; ENDCASE; IF val = '\000 THEN LOOP; ce[ceIndex] _ [touchPad, val]; ceIndex _ ceIndex+1; ENDLOOP; }; SetTones: INTERNAL PROC[] = { IF ~pd.tonesInvalid THEN RETURN; pd.tonesInvalid _ FALSE; dialTone _ NEW[LarkPlay.ToneSpecRec _ [repeatIndefinitely: TRUE, volume: ThNet.pd.tonesVolume, tones: LIST[LIST[ [f1: 350, f2: 440, on: 5000, off: 0], [f1: 350, f2: 440, on: 5000, off: 0]]]]]; busyTone _ NEW[LarkPlay.ToneSpecRec _ [repeatIndefinitely: TRUE, volume: ThNet.pd.tonesVolume, tones: LIST[LIST[ [f1: 480, f2: 620, on: 500, off: 500, repetitions: 5], [f1: 480, f2: 620, on: 500, off: 500, repetitions: 5]]]]]; errorTone _ NEW[LarkPlay.ToneSpecRec _ [repeatIndefinitely: TRUE, volume: ThNet.pd.tonesVolume, tones: LIST[LIST[ [f1: 480, f2: 620, on: 250, off: 250, repetitions: 10], [f1: 480, f2: 620, on: 250, off: 250, repetitions: 10]]]]]; ringbackTone _ NEW[LarkPlay.ToneSpecRec _ [repeatIndefinitely: TRUE, volume: ThNet.pd.tonesVolume, tones: LIST[LIST[ [f1: 440, f2: 480, on: 2000, off: 4000], [f1: 440, f2: 480, on: 2000, off: 4000]]]]]; }; Deb: PROC[info: LarkInfo, c: CHAR, p1, p2, p3, p4: IO.Value_[null[]]] = { s: IO.STREAM; IF ~ThNet.pd.debug THEN RETURN; s_IO.ROS[]; s.PutF["<%g", char[c]]; SELECT c FROM 'M => s.PutF["-- %g", p1]; ENDCASE; s.PutRope[">\r"]; VoiceUtils.Report[s.RopeFromROS[], $LarkDetailed, info]; }; QuickState: ARRAY LarkState OF IO.Value = [ rope["none"], rope["idle"], rope["talking"], rope["trunkSignalling"], rope["trunkTalking"], rope["trunkForwarding"], rope["trunkFlashing"], rope["failed"], rope["recovering"], rope["ringing"], rope["silence"], rope["dialTone"], rope["ringBack"], rope["busyTone"], rope["errorTone"]]; <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <<>> <> <> <<0 dec1 co1>> <<1 Xmtr Rcvr>> <<2 from Telewall to Telewall>> <<3 mike speaker>> <<4 silence DTMF receiver>> <<5 dec2 co2>> <<6 line 1 in line 1 out>> <<7 line 2 in line 2 out>> CommandsForState: TYPE = REF CommandsForStateArray; CommandsForStateArray: TYPE = ARRAY LarkState OF ROPE; <> <> <> <> <> <> <> <<];>> <<>> telsetCommands: CommandsForState _ NEW[CommandsForStateArray _ <> [ NIL, -- none "Z", -- idle "SXt01Xt06Xr10XA60XB70X14", -- talking "HIX02X06X14XF01", -- trunkSignalling "HISTX02Xr10XA60XB70Xt21Xt26X14", -- trunkTalking, codec-assisted electronic mode "E3HIX02X20X24", -- trunkForwarding, trunk to remote Lark connection. "STX02Xr10XA60XB70Xt21Xt26X14", -- trunkFlashing, on-hook but otherwise trunkTalking. <<"Z", -- trunkFlashing, on-hook for a second.>> "Z", -- failed "Z", -- recovering "RX03X06X14", -- ringing "SX14", -- silence toneStdCommand, toneStdCommand, toneStdCommand, toneStdCommand -- tones ]]; toneStdCommand: ROPE = "SX01X14X06"; monitorCommands: CommandsForState _ NEW[CommandsForStateArray _ <> [ NIL, -- none "Z", -- idle "LSXt01Xt06Xt03Xr10XA60XB70X14", -- talking "LHIX02X06X03X14XF01", -- trunkSignalling "LHISTX02Xr10XA60XB70Xt21Xt26Xt23X14", -- trunkTalking, codec-assisted electronic mode "LE3HIX02X20X24", -- trunkForwarding, trunk to remote Lark connection. "LSTX02Xr10XA60XB70Xt21Xt26Xt23X14", -- trunkFlashing, on-hook but otherwise trunkTalking. <<"Z", -- trunkFlashing, on-hook for a second.>> "Z", -- failed "Z", -- recovering "RX03X06X14", -- ringing "LSX14", -- silence toneMonCommand, toneMonCommand, toneMonCommand, toneMonCommand -- tones ]]; toneMonCommand: ROPE = "LSX01X03X14X06"; speakerCommands: CommandsForState _ NEW[CommandsForStateArray _ <> [ NIL, -- none "Z", -- idle "E1LXt03Xt06Xr30XA60XB70X14", -- talking "LHIX02X06XF03", -- trunkSignalling "E2M1THILXr30X02Xt25Xt26X24Xt53XA60XB70", -- trunkTalking, gain-controlled digital mode "LE3HIX02X20X24", -- trunkForwarding, trunk to remote Lark connection. (need gain setting for echo?) "Z", -- trunkFlashing, on-hook for a second. <<"STX02X10X21X26X14", -- trunkFlashing, on-hook but otherwise unchanged.>> "Z", -- failed "Z", -- recovering "RX03X06", -- ringing "LX14", -- silence toneSpkrCommand, toneSpkrCommand, toneSpkrCommand, toneSpkrCommand -- tones ]]; toneSpkrCommand: ROPE = "LX03X14X06"; larkCommands: ARRAY ThSmartsPrivate.SwitchState OF CommandsForState _ [ telsetCommands, -- good as any for "onhook" condition telsetCommands, -- telset speakerCommands, -- speaker speakerCommands, -- sPEAKER monitorCommands, -- monitor monitorCommands -- mONITOR ]; <<>> echoStyleFD: REF _ NEW[Lark.EchoParameterRecord _[ <> buffer: out1, buffer2Controlled: FALSE, buffer1Controlled: TRUE, decayTime: 5, gain: [ 1024, 2048, 2048, 2048, 32767 ] ]]; echoStyleFwd: REF _ echoStyleFD; echoStyleBD: REF _ NEW[Lark.EchoParameterRecord _[ <> buffer: in2, buffer2Controlled: FALSE, buffer1Controlled: TRUE, decayTime: 10, gain: [ 2048, 4096, 8192, 16384, 32767 ] ]]; echoStyleNoFD: REF _ NEW[Lark.EchoParameterRecord _[ <> buffer: out1, -- not interesting buffer2Controlled: FALSE, buffer1Controlled: TRUE, --
FALSE, compensates for a Lark bug; restore when fixed decayTime: 5, gain: [ 32767, 32767, 32767, 32767, 32767 ] ]]; echoStyleNoFwd: REF _ echoStyleNoFD; echoStyleNoBD: REF _ NEW[Lark.EchoParameterRecord _[ <> buffer: in2, -- not interesting buffer2Controlled: FALSE, buffer1Controlled: TRUE, --
FALSE, compensates for a Lark bug; restore when fixed decayTime: 5, gain: [ 32767, 32767, 32767, 32767, 32767 ] ]]; echosOn: ARRAY [0..3] OF REF_[ NIL, echoStyleFD, echoStyleBD, echoStyleFwd ]; echosOff: ARRAY [0..3] OF REF_[ NIL, echoStyleNoFD, echoStyleNoBD, echoStyleNoFwd ]; <> LSwitches: TYPE = ThSmartsPrivate.LSwitches; LState: TYPE = ThSmartsPrivate.LState; lDevs: ARRAY LSwitches OF Lark.Device = [ crossBar, offHookRelay, aRelay, sideTone, ringEnable, revertRelay, revertHookswitch, led, spMode, crossBar--random...not used-- ]; lStateForLetter: ARRAY CHAR['A..'Z] OF LSwitches = [ none, none, none, none, none, -- A to E revert, revertHook, hook, aSwitch, hook, none, led, -- F to L none, none, none, none, none, -- M to Q ringO, sideTone, spMode, none, none, none, none, none, -- R to Y none -- Z -- ]; LSTrans: TYPE = { nop, -- nothing to do set, -- enter specified state (usu. step to recovery) without taking any other actions. zap, zpu, zpn, -- reset Lark hardware (u means unconnect first, n means silence tones first) trk, tkn, -- Set for electronic phone connection (n means silence tones first) frd, frn, -- Trunk-to-network forwarding versions of trk, tkn (frn probably doesn't exist; wrong end <>) tlk, -- like supervision, but must also adjust switching. sup, spn, -- supervision, OK to change connection, key table. (n means silence tones first) ksp, -- key supervision, OK to change key table. sgl, sgn, -- Do trunk signalling (n means silence tones first) fls, -- Flash the phone line rng, rgu, -- Set for ringing (u means unconnect first, r means repeating tone) dia, diu, -- Set for dial tone (tones should be more generic and user-programmable than this!) rbk, rbu, -- Set for ring back bzy, bzu, -- Set for busy tone err, eru, -- Set for error tone sil, -- silence tones, ksp obtains fai, -- enter failed state, by Smarts-level request. Don't complain, just do it. Make sure process goes away. rec, -- move from failed state to recovering state, but complain to caller that Lark has failed, via signal. X -- invalid transition; complain, then remain in present state (go idle?) }; lsTrans: ARRAY LarkState OF ARRAY LarkState OF LSTrans = [[ <> nop, zap, X, X, X, X, X, X, X, X, X, X, X, X, err ],[-- non (none) X, nop, spn, sgl, trk, frd, X, fai, X, rng, nop, dia, rbk, bzy, err ],[-- idl (idle) X, zpu, sup, X, X, X, X, fai, X, rgu, nop, diu, rbu, bzu, eru ],[-- tlk (talking) X, zpn, X, ksp, trk, frd, X, fai, X, X, nop, X, X, X, X ],[-- sig (trkSignalling) X, zap, X, sgl, ksp, X, fls, fai, X, X, nop, X, X, X, X ],[-- trk (trkTalking) X, zpu, X, sgl, X, sup, X, fai, X, X, nop, diu, rbu, bzu, eru ],[-- fwd (trkForwarding) X, zap, X, X, trk, X, sup, fai, X, X, nop, X, X, X, X ],[-- fls (trkFlash) set, rec, rec, rec, rec, rec, rec, set, set, rec, rec, rec, rec, rec, rec ],[-- fai (failed) set, nop, nop, nop, nop, nop, nop, nop, nop, nop, nop, nop, nop, nop, nop ],[-- rec (recovering) X, zpn, spn, sgn, tkn, frn, X, fai, X, ksp, sil, dia, rbk, bzy, err ],[-- rng (ringing) X, zap, tlk, sgl, trk, frd, X, fai, X, rng, ksp, dia, rbk, bzy, err ],[-- shh (silence) X, zpn, spn, sgn, tkn, frn, X, fai, X, rng, sil, ksp, rbk, bzy, err ],[-- dia (dialTone) X, zpn, spn, sgn, tkn, frn, X, fai, X, rng, sil, dia, ksp, bzy, err ],[-- rbk (ringBack) X, zpn, spn, sgn, tkn, frn, X, fai, X, rng, sil, dia, rbk, ksp, err ],[-- bzy (busyTone) X, zpn, spn, sgn, tkn, frn, X, fai, X, rng, sil, dia, rbk, bzy, ksp ] -- err (errorTone) ]; <> TDisconn: TYPE = { X, disconnect }; tDisconn: ARRAY LSTrans OF TDisconn = [ -- zpu, rgu, diu, rbu, bzu, eru X, X, X, disconnect, X, X, X, X, X, X, X, X, X, X, X, X, X, disconnect, X, disconnect, X, disconnect, X, disconnect, X, disconnect, X, X, X, X ]; TDoTones: TYPE = { X, doTones, stopTones }; tDoTones: ARRAY LSTrans OF TDoTones = [ -- rng, rgu, dia, diu, rbk, rbu, bzy, bzu, err, eru; zpn, tkn, spn, sgn, sil X, X, X, X, stopTones, X, stopTones, X, X, X, X, stopTones, X, X, stopTones, X, doTones, doTones, doTones, doTones, doTones, doTones, doTones, doTones, doTones, doTones, stopTones, X, X, X ]; THookState: TYPE = { X, reset, spkrTrans }; tHookState: ARRAY LSTrans OF THookState = [ -- zap, zpu, zpn; trk, tkn, tlk, spn, fls, dia, diu, rbk, rbu, bzy, bzu, err, eru, sil X, X, reset, reset, reset, spkrTrans, spkrTrans, X, X, spkrTrans, X, spkrTrans, X, X, X, spkrTrans, X, X, spkrTrans, spkrTrans, spkrTrans, spkrTrans, spkrTrans, spkrTrans, spkrTrans, spkrTrans, spkrTrans, X, X, X ]; TSwitch: TYPE = { X, switch, switchIfDiff }; tSwitch: ARRAY LSTrans OF TSwitch = [ -- zap, zpu, zpn, trk, tkn, frd, frn, tlk, spn, sgl, sgn, fls; rng, rgu, dia, diu, rbk, rbu, bzy, bzu, err, eru X, X, switch, switch, switch, switch, switch, switch, switch, switch, X, switch, X, switch, switch, switch, switchIfDiff, switchIfDiff, switchIfDiff, switchIfDiff, switchIfDiff, switchIfDiff, switchIfDiff, switchIfDiff, switchIfDiff, switchIfDiff, switch, X, X, X ]; TSetFwd: TYPE = { X, setFwd }; tSetFwd: ARRAY LSTrans OF TSetFwd = [ -- trk, tkn X, X, X, X, X, setFwd, setFwd, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X, X ]; <> ADisconnectType: TYPE = { aDisconnect }; aDisconnect: REF ADisconnectType _ NEW[ADisconnectType_aDisconnect]; ResetActionType: TYPE = { resetAction }; resetAction: REF ResetActionType _ NEW[ResetActionType_resetAction]; AFeepType: TYPE = RECORD [ initialDelay: CARDINAL _ pd.waitForTelco, on: CARDINAL _ pd.telcoMinOn, off: CARDINAL _ pd.telcoMinOff, audible: BOOL_FALSE, digits: Lark.CommandEvents_NIL ]; ANoTonesType: TYPE = { aNoTones }; aNoTones: REF ANoTonesType _ NEW[ANoTonesType_aNoTones]; ATonesDoneType: TYPE = RECORD [ event: Lark.Event ]; ASpeechDoneType: TYPE = RECORD [ indexMarker: INT ]; AToggleLEDType: TYPE = { aToggleLED }; aToggleLED: REF AToggleLEDType _ NEW[AToggleLEDType_aToggleLED]; ledToggler: Lark.CommandEvents _ NEW[Lark.CommandEventSequence[1]]; ViewCmd: Commander.CommandProc = TRUSTED { Nice.View[pd, "Lark Out PD"]; }; Commander.Register["VuLarkOut", ViewCmd, "Program Management variables for Lark Output"]; }. <> <> <> <<>> <> <> <> <> <> <> <> <> <> <> <> <> <> < SpeakText (local of LarkSupervisor), ps (local of LarkSupervisor), pd (local of LarkSupervisor)>> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> < VoiceUtils, Handle => ID>> <> <> <> <> <> <> <> <> <> <> <> < LarkOps>> <> <<>>