-- Stub file was translated on February 1, 1984 5:22:19 pm PST by Lupine of December 20, 1983 1:22:57 pm PST -- Source interface AlpineOwner came from file AlpineOwner.bcd, which was created on February 1, 1984 5:21:55 pm PST with version stamp 151#23#12372767523 from source of April 2, 1983 1:52:55 pm PST. -- The RPC stub modules for AlpineOwner are: -- AlpineOwnerRpcControl.mesa; -- AlpineOwnerRpcClientImpl.mesa; -- AlpineOwnerRpcBinderImpl.mesa; -- AlpineOwnerRpcServerImpl.mesa. -- The parameters for this translation are: -- Target language = Cedar -- Default parameter passing = VALUE -- Deallocate server heap arguments = TRUE -- Inline RpcServerImpl dispatcher stubs = FALSE -- Declare signals = FALSE -- Warn about short POINTER ("MDS") allocations = TRUE -- Maximum number of dynamic heap NEWs = 50, MDS NEWs = 50 -- Acceptable parameter protocols = VersionRange[1..1]. DIRECTORY AlpineEnvironment, AlpineOwner, AlpineOwnerRpcControl USING [InterMdsCallsOnly, LupineProtocolVersion, ProcedureIndex, SignalIndex], RPC USING [InterfaceName, standardZones, Zones], RPCLupine --USING SOME OF [Call, DataLength, Dispatcher, GetStubPkt, -- ImportHandle, ImportInterface, maxDataLength, maxPrincipalLength, -- maxShortStringLength, pktOverhead, ReceiveExtraPkt, SendPrelimPkt, -- StartCall, StartSignal, StubPkt, UnimportInterface]--, LupineRuntime --USING SOME OF [BindingError, CheckPktLength, CopyFromPkt, -- CopyFromMultiplePkts, CopyToPkt, CopyToMultiplePkts, defaultZones, -- DispatchingError, FinishThisPkt, ListHeader, MarshalingError, -- MarshalingExprError, NilHeader, ProtocolError, RopeHeader, RpcPktDoubleWord, -- RuntimeError, SequenceHeader, SHORT, StartNextPkt, StringHeader, -- StubPktDoubleWord, TranslationError, UnmarshalingError, UnmarshalingExprError, -- WordsForChars]--, Atom --USING SOME OF [GetPName, MakeAtom]--, Rope --USING SOME OF [InlineFlatten, Length, NewText, Text]--; AlpineOwnerRpcClientImpl: MONITOR IMPORTS AlpineOwner, RpcPrivate: RPCLupine, Lupine: LupineRuntime, Atom, Rope EXPORTS AlpineOwner, AlpineOwnerRpcControl SHARES AlpineOwner, AlpineOwnerRpcControl, Rope = BEGIN OPEN AlpineOwner, RpcControl: AlpineOwnerRpcControl, 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 ] = TRUSTED BEGIN ENABLE UNWIND => NULL; IsNull: PROCEDURE [string: Rope.ROPE] RETURNS [BOOLEAN] = INLINE {RETURN[string.Length[] = 0]}; IF bound THEN Lupine.BindingError; myInterface _ RpcPrivate.ImportInterface [ interface: [ type: IF ~IsNull[interfaceName.type] THEN interfaceName.type ELSE "AlpineOwner~151#23#12372767523", instance: interfaceName.instance, version: interfaceName.version ], localOnly: RpcControl.InterMdsCallsOnly, stubProtocol: RpcControl.LupineProtocolVersion ]; 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. ReadProperties: PUBLIC PROCEDURE [conversation: Conversation, transID: TransID, volumeGroupID: VolumeGroupID, owner: OwnerName, desiredProperties: OwnerPropertySet] RETURNS [properties: LIST OF OwnerPropertyValuePair] = BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ ReadProperties, transID (1): TransID, volumeGroupID (10): VolumeGroupID, desiredProperties (15): OwnerPropertySet]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+254] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 16; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: conversation]; argPkt^ _ [transID: transID, volumeGroupID: volumeGroupID, desiredProperties: desiredProperties]; BEGIN -- Marshal owner: OwnerName to pkt.data[pktLength]. pkt.data[pktLength] _ owner=NIL; pktLength _ pktLength+1; IF owner # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: owner]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: TRUE]; END; -- IF owner # NIL. END; -- Marshal owner. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 254, signalHandler: ClientDispatcher]; pktLength _ 0; BEGIN -- Unmarshal properties: LIST OF OwnerPropertyValuePair -- from pkt.data[pktLength]. lastNode: LIST OF OwnerPropertyValuePair _ (properties _ NIL); listLength: Lupine.ListHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; listLength _ Lupine.StubPktDoubleWord[pkt, pktLength]^; pktLength _ pktLength + 2; WHILE listLength > 0 DO thisNode1: LIST OF OwnerPropertyValuePair = paramZones.gc.CONS[--DefaultValue--,NIL]; BEGIN -- Unmarshal thisNode1.first: OwnerPropertyValuePair -- from pkt.data[pktLength]. pktLength _ Lupine.CopyFromPkt[pkt: pkt, pktLength: pktLength, dataAdr: @thisNode1.first, dataLength: SIZE[OwnerPropertyValuePair], alwaysOnePkt: FALSE]; -- Restore garbled REFs to NIL following copy. BEGIN OPEN record: thisNode1.first; WITH variant: record SELECT FROM createAccessList => BEGIN OPEN record: variant; LOOPHOLE[record.createAccessList, LONG POINTER] _ NIL; END; -- OPEN record: variant. modifyAccessList => BEGIN OPEN record: variant; LOOPHOLE[record.modifyAccessList, LONG POINTER] _ NIL; END; -- OPEN record: variant. ENDCASE => NULL; -- WITH variant: record. END; -- OPEN record: thisNode1.first. BEGIN OPEN record: thisNode1.first; WITH variant: record SELECT FROM createAccessList => BEGIN -- Unmarshal variant: RECORD [createAccessList: -- AccessList] from pkt.data[pktLength]. BEGIN OPEN record: variant; BEGIN -- Unmarshal record.createAccessList: AccessList -- from pkt.data[pktLength]. lastNode: AccessList _ (record.createAccessList _ NIL); listLength: Lupine.ListHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; listLength _ Lupine.StubPktDoubleWord[pkt, pktLength]^; pktLength _ pktLength + 2; WHILE listLength > 0 DO thisNode5: AccessList = paramZones.gc.CONS[--DefaultValue--,NIL]; BEGIN -- Unmarshal thisNode5.first: RName from -- pkt.data[pktLength]. ropeIsNIL: Lupine.NilHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; ropeIsNIL _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeIsNIL THEN thisNode5.first _ NIL ELSE BEGIN ropeLength: Lupine.RopeHeader; textRope: Rope.Text; ropeLength _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeLength > RpcPrivate.maxShortStringLength THEN Lupine.UnmarshalingError; thisNode5.first _ textRope _ Rope.NewText[size: ropeLength]; pktLength _ Lupine.CopyFromPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[ropeLength], alwaysOnePkt: FALSE]; END; -- IF ropeIsNIL. END; -- Unmarshal thisNode5.first. IF lastNode # NIL THEN lastNode _ (lastNode.rest _ thisNode5) ELSE lastNode _ (record.createAccessList _ thisNode5); listLength _ listLength - 1; ENDLOOP; -- WHILE listLength > 0. END; -- Unmarshal record.createAccessList. END; -- OPEN record: variant. END; -- Unmarshal variant. modifyAccessList => BEGIN -- Unmarshal variant: RECORD [modifyAccessList: -- AccessList] from pkt.data[pktLength]. BEGIN OPEN record: variant; BEGIN -- Unmarshal record.modifyAccessList: AccessList -- from pkt.data[pktLength]. lastNode: AccessList _ (record.modifyAccessList _ NIL); listLength: Lupine.ListHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; listLength _ Lupine.StubPktDoubleWord[pkt, pktLength]^; pktLength _ pktLength + 2; WHILE listLength > 0 DO thisNode5: AccessList = paramZones.gc.CONS[--DefaultValue--,NIL]; BEGIN -- Unmarshal thisNode5.first: RName from -- pkt.data[pktLength]. ropeIsNIL: Lupine.NilHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; ropeIsNIL _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeIsNIL THEN thisNode5.first _ NIL ELSE BEGIN ropeLength: Lupine.RopeHeader; textRope: Rope.Text; ropeLength _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeLength > RpcPrivate.maxShortStringLength THEN Lupine.UnmarshalingError; thisNode5.first _ textRope _ Rope.NewText[size: ropeLength]; pktLength _ Lupine.CopyFromPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[ropeLength], alwaysOnePkt: FALSE]; END; -- IF ropeIsNIL. END; -- Unmarshal thisNode5.first. IF lastNode # NIL THEN lastNode _ (lastNode.rest _ thisNode5) ELSE lastNode _ (record.modifyAccessList _ thisNode5); listLength _ listLength - 1; ENDLOOP; -- WHILE listLength > 0. END; -- Unmarshal record.modifyAccessList. END; -- OPEN record: variant. END; -- Unmarshal variant. ENDCASE => NULL; -- WITH variant: record. END; -- OPEN record: thisNode1.first. END; -- Unmarshal thisNode1.first. IF lastNode # NIL THEN lastNode _ (lastNode.rest _ thisNode1) ELSE lastNode _ (properties _ thisNode1); listLength _ listLength - 1; ENDLOOP; -- WHILE listLength > 0. END; -- Unmarshal properties. Lupine.CheckPktLength[pkt: pkt, pktLength: pktLength]; RETURN[properties]; END; -- ReadProperties. WriteProperties: PUBLIC PROCEDURE [conversation: Conversation, transID: TransID, volumeGroupID: VolumeGroupID, owner: OwnerName, properties: LIST OF OwnerPropertyValuePair, enforceTotalQuota: BOOL] = BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ WriteProperties, transID (1): TransID, volumeGroupID (10): VolumeGroupID, enforceTotalQuota (15): BOOL]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+254] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 16; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: conversation]; argPkt^ _ [transID: transID, volumeGroupID: volumeGroupID, enforceTotalQuota: enforceTotalQuota]; BEGIN -- Marshal owner: OwnerName to pkt.data[pktLength]. IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; pkt.data[pktLength] _ owner=NIL; pktLength _ pktLength+1; IF owner # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: owner]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: FALSE]; END; -- IF owner # NIL. END; -- Marshal owner. BEGIN -- Marshal properties: LIST OF OwnerPropertyValuePair to -- pkt.data[pktLength]. thisNode1: LIST OF OwnerPropertyValuePair; listLength: Lupine.ListHeader _ 0; FOR thisNode1 _ properties, thisNode1.rest UNTIL thisNode1 = NIL DO listLength _ listLength + 1; ENDLOOP; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; Lupine.StubPktDoubleWord[pkt, pktLength]^ _ listLength; pktLength _ pktLength + 2; FOR thisNode1 _ properties, thisNode1.rest UNTIL thisNode1 = NIL DO BEGIN -- Marshal thisNode1.first: OwnerPropertyValuePair to -- pkt.data[pktLength]. pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: @thisNode1.first, dataLength: SIZE[OwnerPropertyValuePair], alwaysOnePkt: FALSE]; BEGIN OPEN record: thisNode1.first; WITH variant: record SELECT FROM createAccessList => BEGIN -- Marshal variant: RECORD [createAccessList: -- AccessList] to pkt.data[pktLength]. BEGIN OPEN record: variant; BEGIN -- Marshal record.createAccessList: AccessList -- to pkt.data[pktLength]. thisNode5: AccessList; listLength: Lupine.ListHeader _ 0; FOR thisNode5 _ record.createAccessList, thisNode5.rest UNTIL thisNode5 = NIL DO listLength _ listLength + 1; ENDLOOP; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; Lupine.StubPktDoubleWord[pkt, pktLength]^ _ listLength; pktLength _ pktLength + 2; FOR thisNode5 _ record.createAccessList, thisNode5.rest UNTIL thisNode5 = NIL DO BEGIN -- Marshal thisNode5.first: RName to pkt.data[pktLength]. IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; pkt.data[pktLength] _ thisNode5.first=NIL; pktLength _ pktLength+1; IF thisNode5.first # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: thisNode5.first]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: FALSE]; END; -- IF thisNode5.first # NIL. END; -- Marshal thisNode5.first. ENDLOOP; -- FOR thisNode5. END; -- Marshal record.createAccessList. END; -- OPEN record: variant. END; -- Marshal variant. modifyAccessList => BEGIN -- Marshal variant: RECORD [modifyAccessList: -- AccessList] to pkt.data[pktLength]. BEGIN OPEN record: variant; BEGIN -- Marshal record.modifyAccessList: AccessList -- to pkt.data[pktLength]. thisNode5: AccessList; listLength: Lupine.ListHeader _ 0; FOR thisNode5 _ record.modifyAccessList, thisNode5.rest UNTIL thisNode5 = NIL DO listLength _ listLength + 1; ENDLOOP; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; Lupine.StubPktDoubleWord[pkt, pktLength]^ _ listLength; pktLength _ pktLength + 2; FOR thisNode5 _ record.modifyAccessList, thisNode5.rest UNTIL thisNode5 = NIL DO BEGIN -- Marshal thisNode5.first: RName to pkt.data[pktLength]. IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; pkt.data[pktLength] _ thisNode5.first=NIL; pktLength _ pktLength+1; IF thisNode5.first # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: thisNode5.first]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: FALSE]; END; -- IF thisNode5.first # NIL. END; -- Marshal thisNode5.first. ENDLOOP; -- FOR thisNode5. END; -- Marshal record.modifyAccessList. END; -- OPEN record: variant. END; -- Marshal variant. ENDCASE => NULL; -- WITH variant: record. END; -- OPEN record: thisNode1.first. END; -- Marshal thisNode1.first. ENDLOOP; -- FOR thisNode1. END; -- Marshal properties. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 0, signalHandler: ClientDispatcher]; Lupine.CheckPktLength[pkt: pkt, pktLength: 0]; RETURN[]; END; -- WriteProperties. Create: PUBLIC PROCEDURE [conversation: Conversation, transID: TransID, volumeGroupID: VolumeGroupID, owner: OwnerName, properties: LIST OF OwnerPropertyValuePair, enforceTotalQuota: BOOL] RETURNS [--spaceLeftOnVolumeGroup:-- PageCount] = BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ Create, transID (1): TransID, volumeGroupID (10): VolumeGroupID, enforceTotalQuota (15): BOOL]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ spaceLeftOnVolumeGroup (0): PageCount]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+254] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 16; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: conversation]; argPkt^ _ [transID: transID, volumeGroupID: volumeGroupID, enforceTotalQuota: enforceTotalQuota]; BEGIN -- Marshal owner: OwnerName to pkt.data[pktLength]. IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; pkt.data[pktLength] _ owner=NIL; pktLength _ pktLength+1; IF owner # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: owner]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: FALSE]; END; -- IF owner # NIL. END; -- Marshal owner. BEGIN -- Marshal properties: LIST OF OwnerPropertyValuePair to -- pkt.data[pktLength]. thisNode1: LIST OF OwnerPropertyValuePair; listLength: Lupine.ListHeader _ 0; FOR thisNode1 _ properties, thisNode1.rest UNTIL thisNode1 = NIL DO listLength _ listLength + 1; ENDLOOP; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; Lupine.StubPktDoubleWord[pkt, pktLength]^ _ listLength; pktLength _ pktLength + 2; FOR thisNode1 _ properties, thisNode1.rest UNTIL thisNode1 = NIL DO BEGIN -- Marshal thisNode1.first: OwnerPropertyValuePair to -- pkt.data[pktLength]. pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: @thisNode1.first, dataLength: SIZE[OwnerPropertyValuePair], alwaysOnePkt: FALSE]; BEGIN OPEN record: thisNode1.first; WITH variant: record SELECT FROM createAccessList => BEGIN -- Marshal variant: RECORD [createAccessList: -- AccessList] to pkt.data[pktLength]. BEGIN OPEN record: variant; BEGIN -- Marshal record.createAccessList: AccessList -- to pkt.data[pktLength]. thisNode5: AccessList; listLength: Lupine.ListHeader _ 0; FOR thisNode5 _ record.createAccessList, thisNode5.rest UNTIL thisNode5 = NIL DO listLength _ listLength + 1; ENDLOOP; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; Lupine.StubPktDoubleWord[pkt, pktLength]^ _ listLength; pktLength _ pktLength + 2; FOR thisNode5 _ record.createAccessList, thisNode5.rest UNTIL thisNode5 = NIL DO BEGIN -- Marshal thisNode5.first: RName to pkt.data[pktLength]. IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; pkt.data[pktLength] _ thisNode5.first=NIL; pktLength _ pktLength+1; IF thisNode5.first # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: thisNode5.first]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: FALSE]; END; -- IF thisNode5.first # NIL. END; -- Marshal thisNode5.first. ENDLOOP; -- FOR thisNode5. END; -- Marshal record.createAccessList. END; -- OPEN record: variant. END; -- Marshal variant. modifyAccessList => BEGIN -- Marshal variant: RECORD [modifyAccessList: -- AccessList] to pkt.data[pktLength]. BEGIN OPEN record: variant; BEGIN -- Marshal record.modifyAccessList: AccessList -- to pkt.data[pktLength]. thisNode5: AccessList; listLength: Lupine.ListHeader _ 0; FOR thisNode5 _ record.modifyAccessList, thisNode5.rest UNTIL thisNode5 = NIL DO listLength _ listLength + 1; ENDLOOP; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; Lupine.StubPktDoubleWord[pkt, pktLength]^ _ listLength; pktLength _ pktLength + 2; FOR thisNode5 _ record.modifyAccessList, thisNode5.rest UNTIL thisNode5 = NIL DO BEGIN -- Marshal thisNode5.first: RName to pkt.data[pktLength]. IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.StartNextPkt[pkt: pkt, pktLength: pktLength]; pkt.data[pktLength] _ thisNode5.first=NIL; pktLength _ pktLength+1; IF thisNode5.first # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: thisNode5.first]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: FALSE]; END; -- IF thisNode5.first # NIL. END; -- Marshal thisNode5.first. ENDLOOP; -- FOR thisNode5. END; -- Marshal record.modifyAccessList. END; -- OPEN record: variant. END; -- Marshal variant. ENDCASE => NULL; -- WITH variant: record. END; -- OPEN record: thisNode1.first. END; -- Marshal thisNode1.first. ENDLOOP; -- FOR thisNode1. END; -- Marshal properties. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 2, signalHandler: ClientDispatcher]; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; RETURN[resPkt.spaceLeftOnVolumeGroup]; END; -- Create. Destroy: PUBLIC PROCEDURE [conversation: Conversation, transID: TransID, volumeGroupID: VolumeGroupID, owner: OwnerName] = BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ Destroy, transID (1): TransID, volumeGroupID (10): VolumeGroupID]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+49] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 15; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: conversation]; argPkt^ _ [transID: transID, volumeGroupID: volumeGroupID]; BEGIN -- Marshal owner: OwnerName to pkt.data[pktLength]. pkt.data[pktLength] _ owner=NIL; pktLength _ pktLength+1; IF owner # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: owner]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: TRUE]; END; -- IF owner # NIL. END; -- Marshal owner. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 0, signalHandler: ClientDispatcher]; Lupine.CheckPktLength[pkt: pkt, pktLength: 0]; RETURN[]; END; -- Destroy. ReadNext: PUBLIC PROCEDURE [conversation: Conversation, transID: TransID, volumeGroupID: VolumeGroupID, previousOwner: OwnerName, desiredProperties: OwnerPropertySet] RETURNS [owner: OwnerName, properties: LIST OF OwnerPropertyValuePair] = BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ ReadNext, transID (1): TransID, volumeGroupID (10): VolumeGroupID, desiredProperties (15): OwnerPropertySet]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+254] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 16; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: conversation]; argPkt^ _ [transID: transID, volumeGroupID: volumeGroupID, desiredProperties: desiredProperties]; BEGIN -- Marshal previousOwner: OwnerName to pkt.data[pktLength]. pkt.data[pktLength] _ previousOwner=NIL; pktLength _ pktLength+1; IF previousOwner # NIL THEN BEGIN textRope: Rope.Text = Rope.InlineFlatten[r: previousOwner]; IF textRope.length > RpcPrivate.maxShortStringLength THEN Lupine.MarshalingError; pkt.data[pktLength] _ textRope.length; pktLength _ pktLength+1; pktLength _ Lupine.CopyToPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[textRope.length], alwaysOnePkt: TRUE]; END; -- IF previousOwner # NIL. END; -- Marshal previousOwner. [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 254, signalHandler: ClientDispatcher]; pktLength _ 0; BEGIN -- Unmarshal owner: OwnerName from pkt.data[pktLength]. ropeIsNIL: Lupine.NilHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; ropeIsNIL _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeIsNIL THEN owner _ NIL ELSE BEGIN ropeLength: Lupine.RopeHeader; textRope: Rope.Text; ropeLength _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeLength > RpcPrivate.maxShortStringLength THEN Lupine.UnmarshalingError; owner _ textRope _ Rope.NewText[size: ropeLength]; pktLength _ Lupine.CopyFromPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[ropeLength], alwaysOnePkt: FALSE]; END; -- IF ropeIsNIL. END; -- Unmarshal owner. BEGIN -- Unmarshal properties: LIST OF OwnerPropertyValuePair -- from pkt.data[pktLength]. lastNode: LIST OF OwnerPropertyValuePair _ (properties _ NIL); listLength: Lupine.ListHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; listLength _ Lupine.StubPktDoubleWord[pkt, pktLength]^; pktLength _ pktLength + 2; WHILE listLength > 0 DO thisNode1: LIST OF OwnerPropertyValuePair = paramZones.gc.CONS[--DefaultValue--,NIL]; BEGIN -- Unmarshal thisNode1.first: OwnerPropertyValuePair -- from pkt.data[pktLength]. pktLength _ Lupine.CopyFromPkt[pkt: pkt, pktLength: pktLength, dataAdr: @thisNode1.first, dataLength: SIZE[OwnerPropertyValuePair], alwaysOnePkt: FALSE]; -- Restore garbled REFs to NIL following copy. BEGIN OPEN record: thisNode1.first; WITH variant: record SELECT FROM createAccessList => BEGIN OPEN record: variant; LOOPHOLE[record.createAccessList, LONG POINTER] _ NIL; END; -- OPEN record: variant. modifyAccessList => BEGIN OPEN record: variant; LOOPHOLE[record.modifyAccessList, LONG POINTER] _ NIL; END; -- OPEN record: variant. ENDCASE => NULL; -- WITH variant: record. END; -- OPEN record: thisNode1.first. BEGIN OPEN record: thisNode1.first; WITH variant: record SELECT FROM createAccessList => BEGIN -- Unmarshal variant: RECORD [createAccessList: -- AccessList] from pkt.data[pktLength]. BEGIN OPEN record: variant; BEGIN -- Unmarshal record.createAccessList: AccessList -- from pkt.data[pktLength]. lastNode: AccessList _ (record.createAccessList _ NIL); listLength: Lupine.ListHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; listLength _ Lupine.StubPktDoubleWord[pkt, pktLength]^; pktLength _ pktLength + 2; WHILE listLength > 0 DO thisNode5: AccessList = paramZones.gc.CONS[--DefaultValue--,NIL]; BEGIN -- Unmarshal thisNode5.first: RName from -- pkt.data[pktLength]. ropeIsNIL: Lupine.NilHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; ropeIsNIL _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeIsNIL THEN thisNode5.first _ NIL ELSE BEGIN ropeLength: Lupine.RopeHeader; textRope: Rope.Text; ropeLength _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeLength > RpcPrivate.maxShortStringLength THEN Lupine.UnmarshalingError; thisNode5.first _ textRope _ Rope.NewText[size: ropeLength]; pktLength _ Lupine.CopyFromPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[ropeLength], alwaysOnePkt: FALSE]; END; -- IF ropeIsNIL. END; -- Unmarshal thisNode5.first. IF lastNode # NIL THEN lastNode _ (lastNode.rest _ thisNode5) ELSE lastNode _ (record.createAccessList _ thisNode5); listLength _ listLength - 1; ENDLOOP; -- WHILE listLength > 0. END; -- Unmarshal record.createAccessList. END; -- OPEN record: variant. END; -- Unmarshal variant. modifyAccessList => BEGIN -- Unmarshal variant: RECORD [modifyAccessList: -- AccessList] from pkt.data[pktLength]. BEGIN OPEN record: variant; BEGIN -- Unmarshal record.modifyAccessList: AccessList -- from pkt.data[pktLength]. lastNode: AccessList _ (record.modifyAccessList _ NIL); listLength: Lupine.ListHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; listLength _ Lupine.StubPktDoubleWord[pkt, pktLength]^; pktLength _ pktLength + 2; WHILE listLength > 0 DO thisNode5: AccessList = paramZones.gc.CONS[--DefaultValue--,NIL]; BEGIN -- Unmarshal thisNode5.first: RName from -- pkt.data[pktLength]. ropeIsNIL: Lupine.NilHeader; IF pktLength+2 > RpcPrivate.maxDataLength THEN pktLength _ Lupine.FinishThisPkt[pkt: pkt, pktLength: pktLength]; ropeIsNIL _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeIsNIL THEN thisNode5.first _ NIL ELSE BEGIN ropeLength: Lupine.RopeHeader; textRope: Rope.Text; ropeLength _ pkt.data[pktLength]; pktLength _ pktLength+1; IF ropeLength > RpcPrivate.maxShortStringLength THEN Lupine.UnmarshalingError; thisNode5.first _ textRope _ Rope.NewText[size: ropeLength]; pktLength _ Lupine.CopyFromPkt[pkt: pkt, pktLength: pktLength, dataAdr: BASE[DESCRIPTOR[textRope.text]], dataLength: Lupine.WordsForChars[ropeLength], alwaysOnePkt: FALSE]; END; -- IF ropeIsNIL. END; -- Unmarshal thisNode5.first. IF lastNode # NIL THEN lastNode _ (lastNode.rest _ thisNode5) ELSE lastNode _ (record.modifyAccessList _ thisNode5); listLength _ listLength - 1; ENDLOOP; -- WHILE listLength > 0. END; -- Unmarshal record.modifyAccessList. END; -- OPEN record: variant. END; -- Unmarshal variant. ENDCASE => NULL; -- WITH variant: record. END; -- OPEN record: thisNode1.first. END; -- Unmarshal thisNode1.first. IF lastNode # NIL THEN lastNode _ (lastNode.rest _ thisNode1) ELSE lastNode _ (properties _ thisNode1); listLength _ listLength - 1; ENDLOOP; -- WHILE listLength > 0. END; -- Unmarshal properties. Lupine.CheckPktLength[pkt: pkt, pktLength: pktLength]; RETURN[owner, properties]; END; -- ReadNext. ReadDBProperties: PUBLIC PROCEDURE [conversation: Conversation, transID: TransID, volumeGroupID: VolumeGroupID] RETURNS [--nOwners:-- NAT, --nEntriesUsed:-- NAT, --nEntries:-- NAT, --totalQuota:-- PageCount, --totalSpaceInUse:-- PageCount, --volumeGroupSize:-- PageCount] = BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ ReadDBProperties, transID (1): TransID, volumeGroupID (10): VolumeGroupID]; ResultOverlay: TYPE = MACHINE DEPENDENT RECORD [ nOwners (0): NAT, nEntriesUsed (1): NAT, nEntries (2): NAT, totalQuota (3): PageCount, totalSpaceInUse (5): PageCount, volumeGroupSize (7): PageCount]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+15] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: POINTER TO ArgumentOverlay = @pkt.data[0]; resPkt: POINTER TO ResultOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 15; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: conversation]; argPkt^ _ [transID: transID, volumeGroupID: volumeGroupID]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 9, signalHandler: ClientDispatcher]; Lupine.CheckPktLength[pkt: pkt, pktLength: 9]; RETURN[resPkt.nOwners, resPkt.nEntriesUsed, resPkt.nEntries, resPkt.totalQuota, resPkt.totalSpaceInUse, resPkt.volumeGroupSize]; END; -- ReadDBProperties. ReorganizeDB: PUBLIC PROCEDURE [conversation: Conversation, transID: TransID, volumeGroupID: VolumeGroupID, nEntries: NAT] = BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.ProcedureIndex _ ReorganizeDB, transID (1): TransID, volumeGroupID (10): VolumeGroupID, nEntries (15): NAT]; pktBuffer: ARRAY [1..RpcPrivate.pktOverhead+16] OF WORD; pkt: RpcPrivate.StubPkt = RpcPrivate.GetStubPkt[space: @pktBuffer]; argPkt: POINTER TO ArgumentOverlay = @pkt.data[0]; pktLength: RpcPrivate.DataLength _ 16; lastPkt: BOOLEAN; RpcPrivate.StartCall[callPkt: pkt, interface: myInterface, localConversation: conversation]; argPkt^ _ [transID: transID, volumeGroupID: volumeGroupID, nEntries: nEntries]; [returnLength: , lastPkt: lastPkt] _ RpcPrivate.Call[ pkt: pkt, callLength: pktLength, maxReturnLength: 0, signalHandler: ClientDispatcher]; Lupine.CheckPktLength[pkt: pkt, pktLength: 0]; RETURN[]; END; -- ReorganizeDB. --Remote public signals and errors are imported from the interface. -- 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 AccessFailed => RETURN[ AccessFailedStub[pkt: pkt, callLength: callLength, lastPkt: lastPkt, localConversation: localConversation]]; LockFailed => RETURN[ LockFailedStub[pkt: pkt, callLength: callLength, lastPkt: lastPkt, localConversation: localConversation]]; OperationFailed => RETURN[ OperationFailedStub[pkt: pkt, callLength: callLength, lastPkt: lastPkt, localConversation: localConversation]]; StaticallyInvalid => RETURN[ StaticallyInvalidStub[pkt: pkt, callLength: callLength, lastPkt: lastPkt, localConversation: localConversation]]; Unknown => RETURN[ UnknownStub[pkt: pkt, callLength: callLength, lastPkt: lastPkt, localConversation: localConversation]]; ENDCASE => RETURN[Lupine.DispatchingError[]]; END; -- ClientDispatcher -- Public signal and error dispatcher stubs. AccessFailedStub: --ERROR [missingAccess: AlpineEnvironment.NeededAccess]-- RpcPrivate.Dispatcher = INLINE BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.SignalIndex, missingAccess (1): AlpineEnvironment.NeededAccess]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; ERROR AccessFailed[argPkt.missingAccess]; END; -- AccessFailedStub. LockFailedStub: --ERROR [why: AlpineEnvironment.LockFailure]-- RpcPrivate.Dispatcher = INLINE BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.SignalIndex, why (1): AlpineEnvironment.LockFailure]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; ERROR LockFailed[argPkt.why]; END; -- LockFailedStub. OperationFailedStub: --ERROR [why: AlpineEnvironment.OperationFailure]-- RpcPrivate.Dispatcher = INLINE BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.SignalIndex, why (1): AlpineEnvironment.OperationFailure]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; ERROR OperationFailed[argPkt.why]; END; -- OperationFailedStub. StaticallyInvalidStub: --ERROR-- RpcPrivate.Dispatcher = INLINE BEGIN Lupine.CheckPktLength[pkt: pkt, pktLength: 1]; ERROR StaticallyInvalid[]; END; -- StaticallyInvalidStub. UnknownStub: --ERROR [what: AlpineEnvironment.UnknownType]-- RpcPrivate.Dispatcher = INLINE BEGIN ArgumentOverlay: TYPE = MACHINE DEPENDENT RECORD [ transferIndex (0): RpcControl.SignalIndex, what (1): AlpineEnvironment.UnknownType]; argPkt: LONG POINTER TO ArgumentOverlay = @pkt.data[0]; Lupine.CheckPktLength[pkt: pkt, pktLength: 2]; ERROR Unknown[argPkt.what]; END; -- UnknownStub. -- No module initialization. END. -- AlpineOwnerRpcClientImpl.