-- Copyright (C) 1986 by Xerox Corporation. All rights reserved. -- Stub file was translated on May 19, 1986 10:00:55 am PDT by Lupine of February 22, 1986 5:15:54 pm PST -- Source interface ThParty came from file ThParty.bcd, which was created on May 19, 1986 10:00:45 am PDT with version stamp 125#171#14570621437 from source of May 22, 1985 12:18:35 pm PDT. -- The RPC stub modules for ThParty are: -- ThPartyRpcControl.mesa; -- ThPartyRpcClientImpl.mesa; -- ThPartyRpcBinderImpl.mesa; -- ThPartyRpcServerImpl.mesa. -- The parameters for this translation are: -- Target language = Cedar -- Default parameter passing = VALUE -- Deallocate server heap arguments = TRUE -- Inline RpcServerImpl dispatcher stubs = TRUE -- Declare signals = TRUE -- Warn about short POINTER ("MDS") allocations = TRUE -- Maximum number of dynamic heap NEWs = 50, MDS NEWs = 50 -- Acceptable parameter protocols = VersionRange[1..1]. DIRECTORY Basics, Lark, Thrush, ThSmarts, ThParty, ThPartyRpcControl USING [InterfaceRecord, InterMdsCallsOnly, LupineProtocolVersion, ProcedureIndex, SignalIndex], RPC --USING SOME OF [InterfaceName, standardZones, Zones]--, RPCLupine --USING SOME OF [Alloc, Call, DataLength, DeAlloc, Dispatcher, -- GetPkt, GetStubPkt, ImportHandle, ImportInterface, maxDataLength, -- maxPrincipalLength, maxShortStringLength, pktOverhead, ReceiveExtraPkt, -- SendPrelimPkt, StartCall, StartSignal, StubPkt, UnimportInterface]--, RPCLupineExtras --USING SOME OF [ImportInterfaceWithHost, noHost, -- RPCHost]--, LupineRuntime --USING SOME OF [BindingError, CheckPktLength, CopyFromPkt, -- CopyFromMultiplePkts, CopyToPkt, CopyToMultiplePkts, defaultZones, -- DispatchingError, FinishThisPkt, ListHeader, MarshalingError, -- MarshalingExprError, MarshalAtom, MarshalRope, NilHeader, ProtocolError, -- RopeHeader, RpcPktDoubleWord, RuntimeError, SequenceHeader, SHORT, -- StartNextPkt, StringHeader, StubPktDoubleWord, TranslationError, -- UnmarshalingError, UnmarshalingExprError, UnmarshalAtom, UnmarshalRope, -- WordsForChars]--, Atom --USING SOME OF [GetPName, MakeAtom]--, PrincOpsUtils --USING SOME OF [Enter, Exit]--, Rope --USING SOME OF [InlineFlatten, Length, NewText, Text]--, VM --USING SOME OF [AddressForPageNumber, PageCount, PageNumber, -- PageNumberForAddress, PagesForWords]--; ThPartyRpcClientImpl: MONITOR IMPORTS RpcPrivate: RPCLupine, RpcPrivateExtras: RPCLupineExtras, Lupine: LupineRuntime, Atom, PrincOpsUtils, Rope EXPORTS ThParty, ThPartyRpcControl SHARES ThParty, ThPartyRpcControl, Rope = BEGIN OPEN ThParty, RpcControl: ThPartyRpcControl, RpcPublic: RPC; -- Standard remote binding routines. bound: BOOLEAN _ FALSE; myInterface: RpcPrivate.ImportHandle; paramZones: RpcPublic.Zones _ RpcPublic.standardZones; ImportInterface: PUBLIC ENTRY SAFE PROCEDURE [ interfaceName: RpcPublic.InterfaceName, parameterStorage: RpcPublic.Zones, hostHint: RpcPrivateExtras.RPCHost_RpcPrivateExtras.noHost ] = TRUSTED BEGIN ENABLE UNWIND => NULL; IsNull: PROCEDURE [string: Rope.ROPE] RETURNS [BOOLEAN] = INLINE {RETURN[string.Length[] = 0]}; myInterface _ RpcPrivateExtras.ImportInterfaceWithHost [ interface: [ type: IF ~IsNull[interfaceName.type] THEN interfaceName.type ELSE "ThParty~125#171#14570621437", instance: interfaceName.instance, version: interfaceName.version ], localOnly: RpcControl.InterMdsCallsOnly, stubProtocol: RpcControl.LupineProtocolVersion, hostHint: hostHint ]; paramZones _ [ gc: IF parameterStorage.gc # NIL THEN parameterStorage.gc ELSE Lupine.defaultZones.gc, heap: IF parameterStorage.heap # NIL THEN parameterStorage.heap ELSE Lupine.defaultZones.heap, mds: IF parameterStorage.mds # NIL THEN parameterStorage.mds ELSE Lupine.defaultZones.mds ]; bound _ TRUE; END; UnimportInterface: PUBLIC ENTRY SAFE PROCEDURE = TRUSTED BEGIN ENABLE UNWIND => NULL; IF ~bound THEN Lupine.BindingError; myInterface _ RpcPrivate.UnimportInterface[myInterface]; paramZones _ RpcPublic.standardZones; bound _ FALSE; END; -- Remote public procedure stubs. Alert: PUBLIC SAFE PROCEDURE [shhh: SHHH, credentials: Credentials, state: StateInConv, reason: Reason, calledPartyID: PartyHandle, urgency: CallUrgency, alertKind: AlertKind, newConv: BOOL, comment: ROPE] RETURNS [nb: NB, convID: ConversationHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ Alert, credentials (1): Credentials, state (8): StateInConv, reason (9): Reason, calledPartyID (10): PartyHandle, urgency (12): CallUrgency, alertKind (13): AlertKind, newConv (14): BOOL]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB, convID (1): ConversationHandle]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+49]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 15; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+49]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shhh]; argPkt^ _ [credentials: credentials, state: state, reason: reason, calledPartyID: calledPartyID, urgency: urgency, alertKind: alertKind, newConv: newConv]; BEGIN -- Marshal comment: ROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[comment, pkt, pktLength, TRUE]; END; -- Marshal comment. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 3, signalHandler: ClientDispatcher]; [nb: nb, convID: convID] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 3]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+49]; RETURN[nb, convID]; END; -- UNWIND. END; -- Alert. Advance: PUBLIC SAFE PROCEDURE [shhh: SHHH, credentials: Credentials, state: StateInConv, reason: Reason, comment: ROPE] RETURNS [nb: NB] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ Advance, credentials (1): Credentials, state (8): StateInConv, reason (9): Reason]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+44]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 10; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+44]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shhh]; argPkt^ _ [credentials: credentials, state: state, reason: reason]; BEGIN -- Marshal comment: ROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[comment, pkt, pktLength, TRUE]; END; -- Marshal comment. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 1, signalHandler: ClientDispatcher]; [nb: nb] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 1]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+44]; RETURN[nb]; END; -- UNWIND. END; -- Advance. CreateConversation: PUBLIC SAFE PROCEDURE [shhh: SHHH, credentials: Credentials, urgency: CallUrgency, alertKind: AlertKind] RETURNS [nb: NB, convID: ConversationHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ CreateConversation, credentials (1): Credentials, urgency (8): CallUrgency, alertKind (9): AlertKind]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB, convID (1): ConversationHandle]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+10] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 10; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shhh]; argPkt^ _ [credentials: credentials, urgency: urgency, alertKind: alertKind]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 3, signalHandler: ClientDispatcher]; [nb: nb, convID: convID] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 3]; RETURN[nb, convID]; END; -- CreateConversation. MergeConversations: PUBLIC SAFE PROCEDURE [shhh: SHHH, credentials: Credentials, otherStateID: StateID, otherConvID: ConversationHandle] RETURNS [nb: NB] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ MergeConversations, credentials (1): Credentials, otherStateID (8): StateID, otherConvID (9): ConversationHandle]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+11] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 11; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shhh]; argPkt^ _ [credentials: credentials, otherStateID: otherStateID, otherConvID: otherConvID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 1, signalHandler: ClientDispatcher]; [nb: nb] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 1]; RETURN[nb]; END; -- MergeConversations. OtherParty: PUBLIC SAFE PROCEDURE [shhh: SHHH, credentials: Credentials] RETURNS [nb: NB, partyID: PartyHandle, description: Thrush.ROPE, conference: BOOL] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ OtherParty, credentials (1): Credentials]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB, partyID (1): PartyHandle, conference (3): BOOL]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+38]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 8; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+38]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shhh]; argPkt^ _ [credentials: credentials]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 38, signalHandler: ClientDispatcher]; pktLength _ 4; [nb: nb, partyID: partyID, conference: conference] _ resPkt^; BEGIN -- Unmarshal description: Thrush.ROPE from pkt.data[pktLength]. [description, pktLength] _ Lupine.UnmarshalRope[pkt, pktLength, TRUE]; END; -- Unmarshal description. Lupine.CheckPktLength[pkt: pkt, pktLength: pktLength]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+38]; RETURN[nb, partyID, description, conference]; END; -- UNWIND. END; -- OtherParty. DescribeParty: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle] RETURNS [description: Thrush.ROPE] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ DescribeParty, partyID (1): PartyHandle]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+34]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 3; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+34]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 34, signalHandler: ClientDispatcher]; pktLength _ 0; BEGIN -- Unmarshal description: Thrush.ROPE from pkt.data[pktLength]. [description, pktLength] _ Lupine.UnmarshalRope[pkt, pktLength, TRUE]; END; -- Unmarshal description. Lupine.CheckPktLength[pkt: pkt, pktLength: pktLength]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+34]; RETURN[description]; END; -- UNWIND. END; -- DescribeParty. ConversationsForParty: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ ConversationsForParty, partyID (1): PartyHandle]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+3] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 3; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 0, signalHandler: ClientDispatcher]; Lupine.CheckPktLength[pkt: pkt, pktLength: 0]; RETURN[]; END; -- ConversationsForParty. SetIntervals: PUBLIC SAFE PROCEDURE [shhh: SHHH, credentials: Credentials, intervalSpecs: Thrush.IntervalSpecs] RETURNS [nb: NB] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ SetIntervals, credentials (1): Credentials]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+254]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 8; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+254]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shhh]; argPkt^ _ [credentials: credentials]; BEGIN -- Marshal intervalSpecs: Thrush.IntervalSpecs to pkt.data[pktLength]. thisNode1: Thrush.IntervalSpecs; listLength: Lupine.ListHeader _ 0; FOR thisNode1 _ intervalSpecs, thisNode1.rest UNTIL thisNode1 = NIL DO listLength _ listLength + 1; ENDLOOP; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; Lupine.RpcPktDoubleWord[pkt, pktLength]^ _ listLength; pktLength _ pktLength + 2; FOR thisNode1 _ intervalSpecs, thisNode1.rest UNTIL thisNode1 = NIL DO BEGIN -- Marshal thisNode1.first: Thrush.IntervalSpec to -- pkt.data[pktLength]. pktLength _ MarshalThrushDotIntervalSpec[thisNode1.first, pkt, pktLength]; END; -- Marshal thisNode1.first. ENDLOOP; -- FOR thisNode1. END; -- Marshal intervalSpecs. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 1, signalHandler: ClientDispatcher]; [nb: nb] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 1]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+254]; RETURN[nb]; END; -- UNWIND. END; -- SetIntervals. DescribeInterval: PUBLIC SAFE PROCEDURE [shhh: SHHH, credentials: Credentials, targetInterval: Thrush.IntervalSpec, minSilence: Thrush.VoiceTime] RETURNS [nb: NB, exists: BOOL, intervals: Thrush.IntervalSpecs] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ DescribeInterval, credentials (1): Credentials, minSilence (8): Thrush.VoiceTime]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB, exists (1): BOOL]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+254]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 10; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+254]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shhh]; argPkt^ _ [credentials: credentials, minSilence: minSilence]; BEGIN -- Marshal targetInterval: Thrush.IntervalSpec to pkt.data[pktLength]. pktLength _ MarshalThrushDotIntervalSpec[targetInterval, pkt, pktLength]; END; -- Marshal targetInterval. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 254, signalHandler: ClientDispatcher]; pktLength _ 2; BEGIN -- OnePkt. -- Move statics from pkt now. [nb: nb, exists: exists] _ resPkt^; BEGIN -- Unmarshal intervals: Thrush.IntervalSpecs from pkt.data[pktLength]. lastNode: Thrush.IntervalSpecs _ (intervals _ NIL); listLength: Lupine.ListHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; listLength _ Lupine.RpcPktDoubleWord[pkt, pktLength]^; pktLength _ pktLength + 2; WHILE listLength > 0 DO thisNode1: Thrush.IntervalSpecs = paramZones.gc.CONS[--DefaultValue--,NIL]; BEGIN -- Unmarshal thisNode1.first: Thrush.IntervalSpec -- from pkt.data[pktLength]. [thisNode1.first, pktLength] _ UnmarshalThrushDotIntervalSpec[pkt, pktLength]; END; -- Unmarshal thisNode1.first. IF lastNode # NIL THEN lastNode _ (lastNode.rest _ thisNode1) ELSE lastNode _ (intervals _ thisNode1); listLength _ listLength - 1; ENDLOOP; -- WHILE listLength > 0. END; -- Unmarshal intervals. Lupine.CheckPktLength[pkt: pkt, pktLength: pktLength]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+254]; RETURN[nb, exists, intervals]; END; -- OnePkt. END; -- UNWIND. END; -- DescribeInterval. RegisterKey: PUBLIC SAFE PROCEDURE [shh: SHHH, credentials: Credentials, key: Thrush.EncryptionKey] RETURNS [nb: NB, keyIndex: [0..15]] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ RegisterKey, credentials (1): Credentials, key (8): Thrush.EncryptionKey]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB, keyIndex (1): [0..15]]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+12] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 12; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [credentials: credentials, key: key]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 2, signalHandler: ClientDispatcher]; [nb: nb, keyIndex: keyIndex] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; RETURN[nb, keyIndex]; END; -- RegisterKey. SetProse: PUBLIC SAFE PROCEDURE [shhh: SHHH, credentials: Credentials, proseSpecs: Thrush.ProseSpecs] RETURNS [nb: NB] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ SetProse, credentials (1): Credentials]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): NB]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+254]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 8; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+254]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shhh]; argPkt^ _ [credentials: credentials]; BEGIN -- Marshal proseSpecs: Thrush.ProseSpecs to pkt.data[pktLength]. thisNode1: Thrush.ProseSpecs; listLength: Lupine.ListHeader _ 0; FOR thisNode1 _ proseSpecs, thisNode1.rest UNTIL thisNode1 = NIL DO listLength _ listLength + 1; ENDLOOP; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; Lupine.RpcPktDoubleWord[pkt, pktLength]^ _ listLength; pktLength _ pktLength + 2; FOR thisNode1 _ proseSpecs, thisNode1.rest UNTIL thisNode1 = NIL DO BEGIN -- Marshal thisNode1.first: Thrush.ProseSpec to pkt.data[pktLength]. pktLength _ MarshalThrushDotProseSpec[thisNode1.first, pkt, pktLength]; END; -- Marshal thisNode1.first. ENDLOOP; -- FOR thisNode1. END; -- Marshal proseSpecs. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 1, signalHandler: ClientDispatcher]; [nb: nb] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 1]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+254]; RETURN[nb]; END; -- UNWIND. END; -- SetProse. CreateParty: PUBLIC SAFE PROCEDURE [shh: SHHH, rName: Rname, type: Thrush.PartyType] RETURNS [partyID: PartyHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ CreateParty, type (1): Thrush.PartyType]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ partyID (0): PartyHandle]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+36]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 2; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+36]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [type: type]; BEGIN -- Marshal rName: Rname to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[rName, pkt, pktLength, TRUE]; END; -- Marshal rName. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 2, signalHandler: ClientDispatcher]; [partyID: partyID] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+36]; RETURN[partyID]; END; -- UNWIND. END; -- CreateParty. GetParty: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle, rName: Rname, type: Thrush.PartyType] RETURNS [newPartyID: PartyHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ GetParty, partyID (1): PartyHandle, type (3): Thrush.PartyType]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ newPartyID (0): PartyHandle]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+38]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 4; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+38]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID, type: type]; BEGIN -- Marshal rName: Rname to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[rName, pkt, pktLength, TRUE]; END; -- Marshal rName. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 2, signalHandler: ClientDispatcher]; [newPartyID: newPartyID] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+38]; RETURN[newPartyID]; END; -- UNWIND. END; -- GetParty. GetPartyFromNumber: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle, phoneNumber: Thrush.ROPE, description: ROPE, trunkOK: BOOL] RETURNS [newPartyID: PartyHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ GetPartyFromNumber, partyID (1): PartyHandle, trunkOK (3): BOOL]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ newPartyID (0): PartyHandle]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+72]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 4; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+72]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID, trunkOK: trunkOK]; BEGIN -- Marshal phoneNumber: Thrush.ROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[phoneNumber, pkt, pktLength, TRUE]; END; -- Marshal phoneNumber. BEGIN -- Marshal description: ROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[description, pkt, pktLength, TRUE]; END; -- Marshal description. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 2, signalHandler: ClientDispatcher]; [newPartyID: newPartyID] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+72]; RETURN[newPartyID]; END; -- UNWIND. END; -- GetPartyFromNumber. GetPartyFromFeepNum: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle, feepNum: Thrush.ROPE] RETURNS [newPartyID: PartyHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ GetPartyFromFeepNum, partyID (1): PartyHandle]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ newPartyID (0): PartyHandle]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+37]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 3; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+37]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID]; BEGIN -- Marshal feepNum: Thrush.ROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[feepNum, pkt, pktLength, TRUE]; END; -- Marshal feepNum. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 2, signalHandler: ClientDispatcher]; [newPartyID: newPartyID] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+37]; RETURN[newPartyID]; END; -- UNWIND. END; -- GetPartyFromFeepNum. GetRname: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle] RETURNS [Rname: Thrush.Rname] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ GetRname, partyID (1): PartyHandle]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+34]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 3; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+34]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 34, signalHandler: ClientDispatcher]; pktLength _ 0; BEGIN -- Unmarshal Rname: Thrush.Rname from pkt.data[pktLength]. [Rname, pktLength] _ Lupine.UnmarshalRope[pkt, pktLength, TRUE]; END; -- Unmarshal Rname. Lupine.CheckPktLength[pkt: pkt, pktLength: pktLength]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+34]; RETURN[Rname]; END; -- UNWIND. END; -- GetRname. Register: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle, interface: SmartsInterface, properties: ThSmarts.SmartsProperties, oldSmartsID: SmartsHandle] RETURNS [smartsID: SmartsHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ Register, partyID (1): PartyHandle, properties (3): ThSmarts.SmartsProperties, oldSmartsID (5): SmartsHandle]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ smartsID (0): SmartsHandle]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+82]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 7; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+82]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID, properties: properties, oldSmartsID: oldSmartsID]; BEGIN -- Marshal interface: SmartsInterface to pkt.data[pktLength]. pktLength _ MarshalSmartsInterface[interface, pkt, pktLength]; END; -- Marshal interface. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 2, signalHandler: ClientDispatcher]; [smartsID: smartsID] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+82]; RETURN[smartsID]; END; -- UNWIND. END; -- Register. RegisterClone: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle, clonePartyID: PartyHandle, oldSmartsID: SmartsHandle] RETURNS [smartsID: SmartsHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ RegisterClone, partyID (1): PartyHandle, clonePartyID (3): PartyHandle, oldSmartsID (5): SmartsHandle]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ smartsID (0): SmartsHandle]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+7] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 7; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID, clonePartyID: clonePartyID, oldSmartsID: oldSmartsID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 2, signalHandler: ClientDispatcher]; [smartsID: smartsID] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; RETURN[smartsID]; END; -- RegisterClone. Deregister: PUBLIC SAFE PROCEDURE [shh: SHHH, smartsID: SmartsHandle] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ Deregister, smartsID (1): SmartsHandle]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+3] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 3; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [smartsID: smartsID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 0, signalHandler: ClientDispatcher]; Lupine.CheckPktLength[pkt: pkt, pktLength: 0]; RETURN[]; END; -- Deregister. Enable: PUBLIC SAFE PROCEDURE [shh: SHHH, smartsID: SmartsHandle] RETURNS [nb: Thrush.NB] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ Enable, smartsID (1): SmartsHandle]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): Thrush.NB]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+3] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 3; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [smartsID: smartsID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 1, signalHandler: ClientDispatcher]; [nb: nb] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 1]; RETURN[nb]; END; -- Enable. Disable: PUBLIC SAFE PROCEDURE [shh: SHHH, smartsID: SmartsHandle] RETURNS [nb: Thrush.NB] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ Disable, smartsID (1): SmartsHandle]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nb (0): Thrush.NB]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+3] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: LONG POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 3; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [smartsID: smartsID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 1, signalHandler: ClientDispatcher]; [nb: nb] _ resPkt^; Lupine.CheckPktLength[pkt: pkt, pktLength: 1]; RETURN[nb]; END; -- Disable. GetNumbersForRName: PUBLIC SAFE PROCEDURE [shh: SHHH, rName: ROPE] RETURNS [fullRName: ROPE, number: ROPE, homeNumber: ROPE] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ GetNumbersForRName]; pkt: RpcPrivate.RPCPkt = RpcPrivate.GetPkt[space: RpcPrivate.Alloc[RpcPrivate.pktOverhead+102]]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 1; lastPkt: BOOLEAN; BEGIN ENABLE UNWIND => RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+102]; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt.transferIndex _ GetNumbersForRName; BEGIN -- Marshal rName: ROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[rName, pkt, pktLength, TRUE]; END; -- Marshal rName. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 102, signalHandler: ClientDispatcher]; pktLength _ 0; BEGIN -- Unmarshal fullRName: ROPE from pkt.data[pktLength]. [fullRName, pktLength] _ Lupine.UnmarshalRope[pkt, pktLength, TRUE]; END; -- Unmarshal fullRName. BEGIN -- Unmarshal number: ROPE from pkt.data[pktLength]. [number, pktLength] _ Lupine.UnmarshalRope[pkt, pktLength, TRUE]; END; -- Unmarshal number. BEGIN -- Unmarshal homeNumber: ROPE from pkt.data[pktLength]. [homeNumber, pktLength] _ Lupine.UnmarshalRope[pkt, pktLength, TRUE]; END; -- Unmarshal homeNumber. Lupine.CheckPktLength[pkt: pkt, pktLength: pktLength]; RpcPrivate.DeAlloc[LOOPHOLE[pkt], RpcPrivate.pktOverhead+102]; RETURN[fullRName, number, homeNumber]; END; -- UNWIND. END; -- GetNumbersForRName. SetRingEnable: PUBLIC SAFE PROCEDURE [shh: SHHH, partyID: PartyHandle, ringEnable: Thrush.RingEnable, ringInterval: INT, update: BOOL] = TRUSTED BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ SetRingEnable, partyID (1): PartyHandle, ringEnable (3): Thrush.RingEnable, ringInterval (4): INT, update (6): BOOL]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+7] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 7; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: shh]; argPkt^ _ [partyID: partyID, ringEnable: ringEnable, ringInterval: ringInterval, update: update]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 0, signalHandler: ClientDispatcher]; Lupine.CheckPktLength[pkt: pkt, pktLength: 0]; RETURN[]; END; -- SetRingEnable. -- Remote public signals and errors. -- Public signal and error dispatcher. ClientDispatcher: --PROCEDURE [pkt: RPCPkt, callLength: DataLength, -- lastPkt: BOOLEAN, localConversation: Conversation] RETURNS [returnLength: -- DataLength]-- RpcPrivate.Dispatcher = BEGIN SELECT LOOPHOLE[pkt.data[0], RpcControl.SignalIndex] FROM ENDCASE => RETURN[Lupine.DispatchingError[]]; END; -- ClientDispatcher -- Public signal and error dispatcher stubs. -- Marshall/Unmarshal procedures. UnmarshalThrushDotIntervalSpec: PROC[pkt: RpcPrivate.RPCPkt, pktLength0: RpcPrivate.DataLength] RETURNS[value: Thrush.IntervalSpec, pktLength: RpcPrivate.DataLength] = BEGIN pktLength _ pktLength0; { isNIL: Lupine.NilHeader; IF pktLength+1 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; isNIL _ pkt.data[pktLength]; pktLength _ pktLength+1; IF isNIL THEN value _ NIL ELSE BEGIN value _ (paramZones.gc.NEW[Thrush.IntervalSpecBody]); BEGIN -- Unmarshal value^: Thrush.IntervalSpecBody from pkt.data[pktLength]. pktLength _ Lupine.CopyFromPkt[pkt: pkt, pktLength: pktLength, dataAdr: LOOPHOLE[value], dataLength: SIZE[Thrush.IntervalSpecBody], alwaysOnePkt: FALSE]; END; -- Unmarshal value^. END; -- IF isNIL. };END; MarshalSmartsInterface: PROC[value: ThParty.SmartsInterface, pkt: RpcPrivate.RPCPkt, pktLength0: RpcPrivate.DataLength] RETURNS[pktLength: RpcPrivate.DataLength] = BEGIN pktLength _ pktLength0; { pkt.data[pktLength] _ value=NIL; pktLength _ pktLength+1; IF value # NIL THEN BEGIN -- Marshal value^: ThSmarts.SmartsInterfaceRecord to pkt.data[pktLength]. pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: LOOPHOLE[value], dataLength: SIZE[ThSmarts.SmartsInterfaceRecord], alwaysOnePkt: TRUE]; BEGIN OPEN record: value^; BEGIN -- Marshal record.type: RPC.ShortROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[record.type, pkt, pktLength, TRUE]; END; -- Marshal record.type. BEGIN -- Marshal record.instance: RPC.ShortROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[record.instance, pkt, pktLength, TRUE]; END; -- Marshal record.instance. END; -- OPEN record: value^. END; -- Marshal value^. };END; MarshalThrushDotProseSpec: PROC[value: Thrush.ProseSpec, pkt: RpcPrivate.RPCPkt, pktLength0: RpcPrivate.DataLength] RETURNS[pktLength: RpcPrivate.DataLength] = BEGIN pktLength _ pktLength0; { IF pktLength+1 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; pkt.data[pktLength] _ value=NIL; pktLength _ pktLength+1; IF value # NIL THEN BEGIN -- Marshal value^: Thrush.ProseSpecBody to pkt.data[pktLength]. pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: LOOPHOLE[value], dataLength: SIZE[Thrush.ProseSpecBody], alwaysOnePkt: FALSE]; BEGIN OPEN record: value^; BEGIN -- Marshal record.prose: Rope.ROPE to pkt.data[pktLength]. pktLength _ Lupine.MarshalRope[record.prose, pkt, pktLength, FALSE]; END; -- Marshal record.prose. END; -- OPEN record: value^. END; -- Marshal value^. };END; MarshalThrushDotIntervalSpec: PROC[value: Thrush.IntervalSpec, pkt: RpcPrivate.RPCPkt, pktLength0: RpcPrivate.DataLength] RETURNS[pktLength: RpcPrivate.DataLength] = BEGIN pktLength _ pktLength0; { IF pktLength+1 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; pkt.data[pktLength] _ value=NIL; pktLength _ pktLength+1; IF value # NIL THEN BEGIN -- Marshal value^: Thrush.IntervalSpecBody to pkt.data[pktLength]. pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: LOOPHOLE[value], dataLength: SIZE[Thrush.IntervalSpecBody], alwaysOnePkt: FALSE]; END; -- Marshal value^. };END; -- No module initialization. END. -- ThPartyRpcClientImpl.