DIRECTORY 
CardTable USING [ Create, EachPairAction, Fetch, Pairs, Ref, Store ],
Commander USING [ CommandProc, Register ],
CommandTool USING [ NextArgument ],
Convert USING [ IntFromRope ],
IO,
Lark USING [ CommandEventSequence, LarkModel, Machine, SHHH ],
LarkControl USING [ GetLark, SetApplicationMode ],
LarkOpsRpcControl USING [ ImportNewInterface, InterfaceRecord ],
LarkSmarts,
LarkSmartsMonitorImpl,
LarkSmartsRpcControl USING [ExportInterface, InterfaceName, UnexportInterface],
LupineRuntime,
MBQueue USING [ Create, Flush, Queue, QueueClientAction ],
NamesGV USING [ GVGetAttribute ],
NamesRPC USING [ StartConversation ],
Nice USING [ LarkConLogStream ],
Process USING [ Detach, Pause, SecondsToTicks ],
Pup USING [ nullSocket ],
RefID USING [ ID, Reseal, Unseal ],
Rope USING [Concat, Equal],
RPC USING [ AuthenticateFailed, EncryptionKey, ExportFailed, GetCaller, ImportFailed ],
ThNet USING [ pd ],
ThPartyPrivate USING [ AssignSmartsID, RegisterLocal, UnsealSmarts ],
ThParty USING [ Deregister, Enable, SmartsInterfaceRecord ],
Thrush USING [
Credentials, epoch, Epoch, NB, NetAddress, noAddress, nullID, PartyID, PartyType, ROPE, SmartsID, unencrypted ], 
ThSmartsPrivate USING [
CheckHookState, EnterLarkState, Fail, LarkInfo, LarkInfoBody, LarkParseEvent, LarkProgress, LarkReportAction, LarkSubstitution, NoteNewState, QueueLarkAction, RegisterTrunk, SetupTimeouts, SmartsInfo, SmartsInfoBody ],
ThSmartsRpcControl,
ThVersions,
Triples USING [ Make ],
TU,
VoiceUtils USING [ CmdOrToken, CurrentPasskey, DNFProc, InstanceFromNetAddress, MakeRName, Problem, ProblemFR, RegisterWhereToReport, ReportFR, RnameToRspec, Rspec, WhereProc ]
;

LarkSmartsInitImpl: CEDAR MONITOR LOCKS root
IMPORTS IO, 
CardTable,
Commander,
CommandTool,
Convert,
LarkOpsRpcControl,
LarkControl,
LarkSmartsRpcControl,
NamesGV,
NamesRPC,
root: LarkSmartsMonitorImpl,
LupineRuntime,
MBQueue,
Nice,
Process,
RefID,
Rope,
RPC,
ThNet,
ThPartyPrivate,
ThParty,
Thrush,
ThSmartsPrivate,
ThSmartsRpcControl,
ThVersions,
Triples,
TU,
VoiceUtils
EXPORTS LarkSmarts, ThSmartsPrivate
SHARES LarkSmartsMonitorImpl = {
OPEN IO;

larkInfos: CardTable.Ref _ NIL; -- Locate current or previous LarkInfos directly.



Reseal: PROC[r: REF] RETURNS[RefID.ID] = INLINE {RETURN[RefID.Reseal[r]]; };
nullID: RefID.ID = Thrush.nullID;
PartyID: TYPE = Thrush.PartyID;
ROPE: TYPE = Thrush.ROPE;
SHHH: TYPE = Lark.SHHH;  -- Encrypts conv. if first arg to RPC PROC
LarkInfo: TYPE = ThSmartsPrivate.LarkInfo;
SmartsID: TYPE = Thrush.SmartsID;
SmartsInfo: TYPE = ThSmartsPrivate.SmartsInfo;
SmartsInfoBody: TYPE = ThSmartsPrivate.SmartsInfoBody;

larkRegistry: ROPE_".lark";

potentialServiceProvider: PROC[credentials: Thrush.Credentials, smartsInfo: SmartsInfo];


Register: PUBLIC PROC[
shh: SHHH,	-- encrypts connection
oldSmartsID: Thrush.SmartsID,
oldEpoch: Thrush.Epoch,
machine: Lark.Machine, -- machine name for registering Lark --
model: Lark.LarkModel,
authenticated: BOOL_FALSE,
clientInstance: ROPE
] RETURNS [ smartsID: Thrush.SmartsID_nullID, epoch: Thrush.Epoch_Thrush.epoch ] = {
larkSh: Lark.SHHH;
smartsInfo: SmartsInfo;
larkInfo: LarkInfo;
inputQueue: MBQueue.Queue;
larkInterface: LarkOpsRpcControl.InterfaceRecord_NIL;
fullRname: ROPE = RPC.GetCaller[shh];
partyRname: ROPE _ fullRname;
dbRname: ROPE;
serviceName: ROPE;
partyType: Thrush.PartyType _ $telephone;
s: VoiceUtils.Rspec _ NIL;
netAddress: Thrush.NetAddress = [machine.net, machine.host, Pup.nullSocket];

larkInfo _ LarkInfoForNetAddress[netAddress].info;
IF larkInfo#NIL AND ~larkInfo.failed THEN {
inputQueue _ larkInfo.inputQueue;
ThSmartsPrivate.Fail[larkInfo, "Lark is reregistering", FALSE]; -- already rebooted
}
ELSE inputQueue _ MBQueue.Create[];

IF (s_VoiceUtils.RnameToRspec[partyRname])#NIL
AND VoiceUtils.RnameToRspec[s.simpleName] # NIL THEN partyRname_s.simpleName;
dbRname _ partyRname.Concat[larkRegistry];
serviceName _ NamesGV.GVGetAttribute[dbRname, $service, NIL];
IF serviceName#NIL THEN partyType _ $service;
larkSh _ IF NOT ThNet.pd.encryptionRequested THEN Thrush.unencrypted
ELSE NamesRPC.StartConversation [
caller: myName.instance,
callee: fullRname,
key:	serverPassword,
level:	--<<ECB>>--CBCCheck ! RPC.AuthenticateFailed=> {
VoiceUtils.ProblemFR["Can't authenticate %g to %g", $System, NIL,
rope[myName.instance], rope[fullRname]]; GOTO NotSmart; }];

larkInterface _ LarkOpsRpcControl.ImportNewInterface[
interfaceName: [type: "Lark.Lark", instance: clientInstance] ! RPC.ImportFailed=> {
VoiceUtils.ProblemFR["Can't import Lark interface from %g", $System, NIL, rope[clientInstance]]; GOTO NotSmart; }];

larkInfo _ NEW[ThSmartsPrivate.LarkInfoBody _ [
interface: larkInterface,
shh: larkSh,
netAddress: netAddress,
model: model,
inputQueue: inputQueue,
textToSpeech: Rope.Equal[serviceName, "Text-to-Speech", FALSE],
scratchEv: NEW[Lark.CommandEventSequence[15]]
]];
smartsID _ ThPartyPrivate.AssignSmartsID[];
smartsInfo _ NEW[SmartsInfoBody_ [
smartsID: smartsID,
partyType: partyType,
ParseEvent: ThSmartsPrivate.LarkParseEvent,
NoteNewStateP: ThSmartsPrivate.NoteNewState,
requests: MBQueue.Create[],
larkInfo: larkInfo
]];
inputQueue.QueueClientAction[
QdLarkRegistration, NEW[RegistrationInfoSpec _
[smartsInfo, partyRname, serviceName, fullRname, clientInstance]]];
EXITS
NotSmart => RETURN; 
};

RegistrationInfo: TYPE = REF RegistrationInfoSpec;
RegistrationInfoSpec: TYPE = RECORD [
smartsInfo: SmartsInfo,
partyRname: ROPE,
serviceName: ROPE, 
fullRname: ROPE,
clientInstance: ROPE
];

QdLarkRegistration: ENTRY PROC[r:REF] = {
ENABLE UNWIND => NULL;
nb: Thrush.NB;
registrationInfo: RegistrationInfo _ NARROW[r];
smartsInfo: SmartsInfo _ registrationInfo.smartsInfo;
larkInfo: LarkInfo _ smartsInfo.larkInfo;
credentials: Thrush.Credentials;
smartsID: Thrush.SmartsID;
smarts: REF;
localSmarts: ThParty.SmartsInterfaceRecord;
localSmarts _ ThSmartsRpcControl.NewInterfaceRecord[];
localSmarts.clientStubProgress _ ThSmartsPrivate.LarkProgress;
localSmarts.clientStubSubstitution _ ThSmartsPrivate.LarkSubstitution;
localSmarts.clientStubReportAction _ ThSmartsPrivate.LarkReportAction;
[nb, credentials] _ ThPartyPrivate.RegisterLocal[
rName: (SELECT smartsInfo.partyType FROM
$telephone => registrationInfo.partyRname,
ENDCASE=> registrationInfo.serviceName),
type: smartsInfo.partyType,
interfaceRecord: localSmarts,
smartsID: smartsInfo.smartsID, -- pre-allocated so Lark could know.
properties: [role: $voiceTerminal, netAddress: larkInfo.netAddress]
];
IF nb # $success OR (smartsID_credentials.smartsID) = nullID THEN {
VoiceUtils.ProblemFR["Can't register Lark: %g, %g",$System,NIL,
rope[registrationInfo.fullRname], rope[registrationInfo.clientInstance]]; GOTO NotSmart; };
larkInfo.larkSmartsInfo _ smartsInfo;
smarts _ RefID.Unseal[smartsID];
IF smarts=NIL THEN ERROR;
Triples.Make[$SmartsData, smarts, smartsInfo];
IF smartsInfo.partyType # $service THEN
[--nb--, smartsInfo.otherSmartsID]_
ThSmartsPrivate.RegisterTrunk[ smartsID, smartsInfo, registrationInfo.partyRname ];
VoiceUtils.ReportFR[" (%g = %g)", $Smarts, smartsInfo, rope[registrationInfo.clientInstance], TU.RefAddr[smarts]];
IF potentialServiceProvider#NIL THEN potentialServiceProvider[credentials, smartsInfo];
RegisterLarkInfo[larkInfo];
NoteApplicationState[larkInfo, 'r];
[]_ThSmartsPrivate.CheckHookState[larkInfo];
EXITS
NotSmart => RETURN; 
};

EnableSmarts: PUBLIC ENTRY PROC[r: REF] = {
ENABLE UNWIND => NULL;
larkInfo: LarkInfo _ NARROW[r];
debugging: BOOL;
smartsInfo: SmartsInfo _ larkInfo.larkSmartsInfo;
IF larkInfo.failed THEN RETURN; -- Lost a race
IF ThParty.Enable[ smartsID: smartsInfo.smartsID] # $success 
OR (smartsInfo.otherSmartsID # nullID AND
ThParty.Enable[smartsID: smartsInfo.otherSmartsID] # $success) THEN {
VoiceUtils.Problem["Could not enable", $Smarts, smartsInfo];
ThSmartsPrivate.Fail[larkInfo, "Lark failure due to failure to enable party", FALSE];
};
ThSmartsPrivate.EnterLarkState[ larkInfo, idle ]; -- Reset the Lark
debugging _ Rope.Equal[case: FALSE, s2: "D",
s1: NamesGV.GVGetAttribute[
VoiceUtils.InstanceFromNetAddress[larkInfo.netAddress, larkRegistry], $mode, "O"]];
larkInfo.debugging _ debugging;
ThSmartsPrivate.SetupTimeouts[ larkInfo, debugging ]; -- Reset the Lark
NoteApplicationState[larkInfo, 'R];
};

Deregister: PUBLIC ENTRY PROC[r: REF] = {
larkInfo: LarkInfo _ NARROW[r];
smartsID: SmartsID _ nullID;
otherSmartsID: SmartsID _ nullID;
smartsInfo: SmartsInfo _ IF larkInfo#NIL THEN larkInfo.larkSmartsInfo ELSE NIL;
smarts: REF;
IF smartsInfo = NIL THEN {
VoiceUtils.Problem["No Smarts to Deregister", $System];
RETURN;
};
NoteApplicationState[larkInfo, 'U];
smartsID _ smartsInfo.smartsID;
smarts _ ThPartyPrivate.UnsealSmarts[smartsID];
VoiceUtils.ReportFR["Smarts %d (%g) is dead", $Smarts, smartsInfo,
card[Reseal[smarts]], TU.RefAddr[smarts]];
smartsInfo.failed _ TRUE;
smartsInfo.larkInfo.larkSmartsInfo _ NIL;
IF smartsInfo.larkInfo.larkTrunkSmartsInfo#NIL THEN {
smartsInfo.larkInfo.larkTrunkSmartsInfo.failed _ TRUE;
smartsInfo.larkInfo.larkTrunkSmartsInfo.larkInfo _ NIL;
};
smartsInfo.larkInfo.larkTrunkSmartsInfo _ NIL;
smartsInfo.larkInfo _ NIL;
otherSmartsID _ smartsInfo.otherSmartsID;
IF otherSmartsID # nullID THEN [--nb--]_ThParty.Deregister[smartsID: otherSmartsID];
[--nb--]_ThParty.Deregister[smartsID: smartsID];
smartsInfo.requests.Flush[]; -- Abandon progress-notification queue
};

NoteApplicationState: INTERNAL PROC[info: LarkInfo, state: CHAR] = {
LarkControl.SetApplicationMode[LarkControl.GetLark[info.netAddress], state];
};

Login: PUBLIC PROC[shh: SHHH_, smartsID: SmartsID_, authenticated: BOOL_TRUE] = { NULL;};


WhereIsSmartsLog: VoiceUtils.WhereProc -- [fixedWhereData: REF ANY, whereData: REF ANY] RETURNS [s: STREAM _ NIL] --  = CHECKED {
info: SmartsInfo=NARROW[whereData];
larkInfo: LarkInfo = IF info#NIL THEN info.larkInfo ELSE NIL;
IF larkInfo#NIL THEN s_Nice.LarkConLogStream[larkInfo.netAddress];
IF s#NIL AND s=Nice.LarkConLogStream[Thrush.noAddress] THEN s_NIL; -- use default stream unless debug viewer stream open.
};

WhereIsLarkLog: VoiceUtils.WhereProc -- [fixedWhereData: REF ANY, whereData: REF ANY] RETURNS [s: STREAM _ NIL] --  = CHECKED {
info: ThSmartsPrivate.LarkInfo=NARROW[whereData];
IF info#NIL THEN s_Nice.LarkConLogStream[info.netAddress];
IF s#NIL AND s=Nice.LarkConLogStream[Thrush.noAddress] THEN s_NIL; -- only want the debug viewer stream
};

WhereIsLarkLogFerSherr: VoiceUtils.WhereProc _ WhereIsLarkLog;
FerSherrDefault: VoiceUtils.DNFProc=TRUSTED{ RETURN[ThNet.pd.defaultLarkReports]; };


KillLark: Commander.CommandProc = {
netAddress: Thrush.NetAddress =
[[173B],[Convert.IntFromRope[CommandTool.NextArgument[cmd], 8]], Pup.nullSocket];
larkInfo: LarkInfo _ LarkInfoForNetAddress[netAddress].info;
IF larkInfo=NIL THEN RETURN;
ThSmartsPrivate.Fail[larkInfo, "Lark failed through operator request", TRUE];
};

myName: LarkSmartsRpcControl.InterfaceName;
serverPassword: RPC.EncryptionKey;

LarkSmartsInit: Commander.CommandProc = {
ENABLE {
RPC.ExportFailed => { VoiceUtils.Problem["LarkSmarts export failed", $System]; GOTO Failed; };
};
instance: ROPE = VoiceUtils.MakeRName[style: rName, name:
VoiceUtils.CmdOrToken[cmd: cmd, key: "ThrushServerInstance", default: "Strowger.Lark"]];
serverPassword _ VoiceUtils.CurrentPasskey[VoiceUtils.CmdOrToken[
cmd: cmd, key: "ThrushServerPassword", default: "MFLFLX"]];
myName _ [
type: "LarkSmarts.Lark",
instance: instance,
version: ThVersions.ThrushVR
];
VoiceUtils.RegisterWhereToReport[proc: WhereIsLarkLog, where: $Lark];
VoiceUtils.RegisterWhereToReport[proc: WhereIsLarkLogFerSherr, where: $LarkDetailed, defaultIfNotFound: FerSherrDefault];
VoiceUtils.RegisterWhereToReport[proc: WhereIsSmartsLog, where: $Smarts];
LarkSmartsRpcControl.UnexportInterface[!LupineRuntime.BindingError=>CONTINUE];
LarkSmartsRpcControl.ExportInterface[
interfaceName: myName,
user: instance,
password: serverPassword
];
VoiceUtils.ReportFR["Export[LarkSmarts.Lark, %s]", $System, NIL, rope[myName.instance]];
EXITS
Failed =>
LarkSmartsRpcControl.UnexportInterface[!LupineRuntime.BindingError=>CONTINUE];
};

RegisterServiceProvider: PUBLIC PROC[
serviceProvider: PROC[credentials: Thrush.Credentials, smartsInfo: SmartsInfo]]  = {
potentialServiceProvider _ serviceProvider;
};

RegisterLarkInfo: PROC[info: LarkInfo] = {
index: CARD _ LarkInfoForNetAddress[info.netAddress].index;
[] _ larkInfos.Store[index, info];
};

LarkInfoForNetAddress: PROC[netAddress: Thrush.NetAddress]
RETURNS[info: LarkInfo, index: CARD] = TRUSTED {
netAddress.socket _ Pup.nullSocket; -- only interested in host values
index _ LOOPHOLE[LONG[@netAddress], LONG POINTER TO CARD]^;
IF larkInfos=NIL THEN {
larkInfos _ CardTable.Create[mod: 59];
TRUSTED { Process.Detach[FORK LarkWatchDogTimerProcess[]]; };
};
info _ NARROW[larkInfos.Fetch[index].val];
};

LarkWatchDogTimerProcess: PROC = {
LarkWatchDogTimer: CardTable.EachPairAction = {
info: LarkInfo = NARROW[val];
IF info=NIL OR info.failed THEN RETURN[FALSE];
ThSmartsPrivate.QueueLarkAction[info, NEW[BOOL_TRUE]];
Process.Pause[Process.SecondsToTicks[ThNet.pd.larkWatchDogTimerInterval]];
RETURN[FALSE];
};
DO
IF ThNet.pd.runLarkWatchDogTimer THEN [] _ larkInfos.Pairs[LarkWatchDogTimer];
Process.Pause[Process.SecondsToTicks[1]];
ENDLOOP;
};


 
Commander.Register["LarkSmarts", LarkSmartsInit, "LarkSmarts <ExportInstance[Strowger]> <ServerPassword[...]>\nInitialize and Export LarkSmarts"];


Commander.Register["KillLark", KillLark, "KillLark 110 -- deregisters lark 110"];


}.
ΊLarkSmartsInitImpl.mesa
Copyright c 1985, 1986 by Xerox Corporation.  All rights reserved.
Last modified by D. Swinehart, December 17, 1986 10:39:25 pm PST
Last Edited by: Pier, May 3, 1984 2:52:59 pm PDT
Copies
Limited registration for supporting service registration.  This handles only one service that would like to register with LarkSmarts parties (intended for synthesizer).  If multiple registrations became necessary, would have to extend this.
See LarkSmartsInitImpl for the point of invocation, LarkSmartsSynthImpl for an example of use.
Registration/Deregistration/Initialization
This procedure is synchronous with the Lark.  We do enough to get started, then serialize the actual registration action with input and fail events.
The LarkSmarts interface definition suggests that a Lark could present enough information during registration to be simply re-validated (kind of like a hand stamp at a dance) without any great effort.  That turns out not to be worth it.  If a Lark registers when already registered, we get rid of any old information about it first.   Don't assume that its type has not changed from $telephone to $service or vice/versa
Develop partyRname: the actual RName to be used to represent this party; and dbRname: the name under which database items are stored in Grapevine.  The rName obtained from the conversation handle may have either form initially, since Finches will supply the former and Larks will supply the latter.  Also, obtain the name of the service represented by this Rname, if any, from the database.
Above converts from, say, Swinehart.pa.lark to Swinehart.pa.
Also, from Swinehart.pa to Swinehart.pa.  Strips one registry if there are two or more.

Get encryption taken care of 
Make sure we can talk to the Lark
No further bad things are expected to happen.
If anyone has registered, call them.  They may want to register a service with our party.  See LarkSmartsSynthImpl for an (the) example.
Subsequent input events must relate to new world.
If the phone is on-hook, mark us ready to go, and set up any once-only Lark params.
Notification would loop
We're debugging if the lark's mode field in the database has the value "D" or "d"
Serialized with input events.  Called (queued) only from LarkOutImpl.Fail.
Not implemented
Other Utilities
Initialization, export "LarkSmarts"
Same as $Lark, except doesn't print at all if debugging viewer not found.
See LarkSmartsSynthImpl for an (the) example.  See Register (above) for invocation of potentialServiceProvider.
Polls active Larks at intervals, so that non-working ones can be discovered and removed from registered service quickly.  This happens whether the Larks are involved in conversations or not.
[key: CardTable.Key, val: CardTable.Val] RETURNS [quit: BOOLEAN]
Special case requesting simplest status check.  If Lark doesn't return, will trigger
failure of LarkSmarts.
Swinehart, May 22, 1985 5:03:50 pm PDT
Cedar 6.0
New ways of defining service parties.  autoAnswer (formerly hotLine), radio, and textToSpeech attributes obtained from data base.  Text-To-Speech service contemplated.
Deregistration works in the face of duplicate service names, etc.
changes to: DIRECTORY, Register, DO
changes to: DIRECTORY, Register, DO, DeregisterIfRegistered, ConsiderOne (local of DeregisterIfRegistered), Deregister
Swinehart, October 28, 1985 9:55:38 am PST
Names, Log => VoiceUtils, Handle => ID
changes to: DIRECTORY, LarkSmartsInitImpl, ConversationID, Reseal, nullID, PartyID, SmartsID, Register, EnableSmarts, ConsiderOne (local of DeregisterIfRegistered), Deregister, SimpleDeregister, Login
Swinehart, November 8, 1985 3:32:57 pm PST
Accommodate new ThParty implementation
changes to: DIRECTORY, Reseal, SHHH, Register, interfaceName, EnableSmarts, DeregisterIfRegistered, Deregister
Swinehart, May 17, 1986 5:57:14 pm PDT
Cedar 6.1
changes to: DIRECTORY, WhereIsSmartsLog, WhereIsLarkLog, KillLark
Swinehart, May 25, 1986 10:09:37 pm PDT
Lark => LarkOps
changes to: DIRECTORY, LarkSmartsInitImpl, Register

Κ˜š
œ™Icodešœ
Οm
œ7™BJš
œ@™@J™0J˜—šΟk	œ
˜
Jšœ
žœ6˜EJšœ
žœ˜*Jšœžœ˜#Jšœžœ˜Jšžœ
˜Jšœžœ-žœ˜>Jšœžœ!˜2Jšœžœ)˜@J˜J˜Jšœžœ5˜OJ˜Jšœžœ-˜:Jšœžœ˜!Jšœ	žœ˜%Jšœžœ˜ Jšœžœ#˜0Jšœžœ˜Jšœžœžœ˜#J˜Jšžœ
žœN˜WJšœžœ˜Jšœžœ1˜EJš
œ<˜<Jšœžœžœ5žœ˜€
šœžœ˜Jš
œΪ
˜Ϊ
—J˜J˜Jšœžœ
˜Jš
ž˜Jš
ϡ
˜°
J˜
J˜—šœž
œ
žœ˜,šžœ
žœ˜J˜
Jš
œ
˜
Jš
œ˜Jš
œ˜Jš
œ˜J˜J˜J˜J˜	J˜J˜J˜J˜J˜J˜J˜Jšžœ
˜J˜J˜J˜J˜J˜J˜J˜J˜Jšžœ
˜Jš
œ
˜
—Jšžœ˜#Jšžœ˜ Jšžœ
žœ
˜J˜JšœžœΟc1˜QJ˜J˜—š
œ™J˜JšΟnœžœžœžœžœžœžœ˜LJ˜!Jšœ	žœ˜Jšžœžœ
žœ
˜JšžœžœžœŸ*˜CJšœ
žœ˜*Jšœ
žœ˜!Jšœžœ˜.Jšœžœ"˜6—˜Jšœžœ	˜J˜J™π
J™^Jšœžœ
Οt7œ˜XJ˜—™*J˜š œžœ
žœ
˜JšœžœŸ˜!Jš
Οs˜Jš
’˜JšœŸ'˜>J˜Jš’œ
žœ
ž’
˜Jšœž˜Jšœ
žœK˜TJ™”
Jšœ
žœ
˜J˜J˜J˜Jšœ1žœ
˜5Jšœžœžœ˜%Jšœžœ
˜Jšœ	žœ
˜Jšœ
žœ
˜J˜)Jšœžœ
˜J˜LJ˜J™£J˜2šžœ
žœ
žœžœ˜+J˜!Jšœ8žœŸ˜SJ˜
—Jšžœ˜#J˜J™†šžœ)ž˜.Jšžœ)žœ˜MJ™<J™W—J˜*Jšœ8žœ˜=Jšžœ
žœ
žœ˜-J™Jš
œ™Jšœ	žœ
žœžœ˜Dšžœ˜!J˜J˜J˜šœŸœžœ˜7šœ=žœ
˜AJšœ)žœ˜;—J˜——Jš
œ!™!š
œ5˜5šœ?žœ˜SJšœEžœžœ˜s—J˜—šœžœ!˜/J˜J˜J˜J˜
J˜Jšœ8žœ˜?Jšœžœ˜-J˜—Jšœ
‘!˜+šœ
žœ˜"Jš
œ˜J˜J˜+J˜,J˜Jš
œ˜Jš
œ˜—˜šœžœ˜.Jš
œC˜C——š
ž˜Jšœžœ˜—J˜J˜—J˜2˜%J˜Jšœžœ
˜Jšœ
ž˜Jšœžœ
˜Jšœž˜J˜J˜—š œžœ
žœžœ˜)Jšžœ
žœžœ
˜Jšœžœ
˜Jšœ%žœ˜/J˜5J˜)J˜ J˜Jšœžœ
˜J˜+Jš
œ6˜6J˜>J˜FJ˜Fš
œ1˜1šœžœž˜(Jš
œ*˜*Jšžœ!˜(—J˜J˜JšœŸ$˜CJš
œC˜CJš
œ˜—šžœžœ*žœ˜CJšœ;žœ
˜?JšœJžœ
˜[—Jš
œ-™-Jš
œ%˜%Jš
œ ˜ Jšžœžœ
žœ
žœ
˜Jš
œ.˜.šžœ!ž˜'šœ
Ÿœ˜#Jš
œS˜S——Jš
œr˜ršžœžœ
žœ‘
œ˜WJ™ˆ
—š
œ˜Jš
œ1™1—J˜#š
œ,˜,J™S—š
ž˜Jšœžœ˜—Jš
œ˜—J˜š
 œžœ
žœ
žœžœ˜+Jšžœ
žœžœ
˜Jšœžœ˜Jšœžœ
˜Jš
œ1˜1Jšžœžœ
žœŸ˜.Jšžœ;˜=šžœ
ž
œ"ž˜)Jšœ=žœ˜EJš
œ<˜<šœNžœ˜UJš
œ™—Jš
œ˜—Jšœ2Ÿ˜CJ™Qšœžœ
˜,š
œ˜Jš
œS˜S——J˜Jšœ6Ÿ˜GJ˜#J˜J˜—š
 
œžœ
žœ
žœžœ˜)J™JJšœžœ˜J˜J˜!Jšœžœ
žœ
žœžœ
žœ
˜OJšœžœ
˜šžœžœ
žœ˜J˜7Jšžœ
˜J˜—J˜#J˜J˜/š
œB˜BJšœžœ˜*—Jšœžœ
˜Jšœ%žœ
˜)šžœ)žœ
žœ˜5Jšœ1žœ
˜6Jšœ3žœ
˜7J˜—Jšœ*žœ
˜.Jšœžœ
˜Jš
œ)˜)JšžœžŸ
œ
Ÿœ.˜TJšœ
Ÿœ)˜0JšœŸ&˜CJ˜—J˜š œžœ
žœžœ˜DJ˜LJ˜J˜—š œžœ
žœžœ&žœ
žœžœ˜YJ™J˜——™J˜•StartOfExpansionO -- [fixedWhereData: REF ANY, whereData: REF ANY] RETURNS [s: STREAM _ NIL] -- šœ&ΠckNœžœ˜
Jšœžœ˜#Jšœžœžœ
žœžœ
žœ
˜=Jšžœ
žœ.˜BJšžœžœ
žœ+žœžœŸ6˜yJ˜—J˜–O -- [fixedWhereData: REF ANY, whereData: REF ANY] RETURNS [s: STREAM _ NIL] -- šœ$£Nœžœ˜Jšœžœ˜1Jšžœžœ
žœ*˜:Jšžœžœ
žœ+žœžœŸ$˜gJ˜J˜—J–O -- [fixedWhereData: REF ANY, whereData: REF ANY] RETURNS [s: STREAM _ NIL] -- š
œ>˜>šœ$žœžœ!˜TJ˜——š
œ#™#J˜š œ˜#˜J˜Q—J˜<Jšžœ
žœ
žœ
žœ
˜JšœGžœ˜MJ˜J˜—J˜+J˜"J˜š œ˜)šžœ˜JšžœLžœ˜^J˜—šœ
žœ+˜9Jš
œX˜X—š
œA˜AJ˜;—˜
J˜Jš
œ˜J˜J˜—Jš
œE˜Eš
œy˜yJ™I—Jš
œI˜IJšœDžœ˜N˜%J˜J˜J˜J˜—Jšœ<žœ˜Xš
ž˜˜	JšœDžœ˜N——Jš
œ˜J˜—š œžœ
žœ
˜%Jšœžœ
‘8œ˜TJš
œo™oJš
œ+˜+J˜J˜—š œžœ˜*Jšœžœ0˜;J˜"J˜J˜—š œžœ˜:Jšžœžœžœ˜0Jšœ$Ÿ!˜EJš
œžœ
žœžœ
žœ
žœ
žœ˜;˜J˜&Jšžœžœ ˜=J˜—Jšœžœ˜*J˜J˜—š œžœ˜"J™Ύ
–D -- [key: CardTable.Key, val: CardTable.Val] RETURNS [quit: BOOLEAN]š œ˜/Jšœ)žœžœ
™@Jšœžœ˜Jšžœžœ
žœ
žœ
žœ
žœ˜.šœ&žœ
žœ
žœ˜6J™TJ™—J˜JJšžœ
žœ˜J˜—š
ž˜Jšžœžœ)˜NJ˜)Jšžœ
˜—J˜—J˜J˜—J˜
š
œ’
˜’
J˜J˜—š
œQ˜QJ˜J˜—J˜™&K™	K™§
K™AKšœΟr™#Kšœ€<œ"€™v—™*Kšœ$ž™&Kšœ€uœ"€%™Θ
—™*K™&Kšœ€b™n—™&K™	Kšœ€5™A—™'K™Kšœ€'™3—K™—…—4–Rί