<Lupine>LupineRuntimeImpl.mesa.>> <> <> <> DIRECTORY Basics USING [DIVMOD], LupineRuntime USING [CheckPktLength, Words], PrincOpsUtils USING [LongCOPY], RPCLupine USING [DataLength, maxDataLength, ReceiveExtraPkt, RejectUnbound, RPCPkt, SendPrelimPkt ], RPC USING [CallFailed, Zones], SafeStorage USING [GetSystemZone], UnsafeStorage USING [GetSystemUZone]; LupineRuntimeImpl: PROGRAM IMPORTS Basics, Lupine: LupineRuntime, PrincOpsUtils, RpcPrivate: RPCLupine, RpcPublic: RPC, SafeStorage, UnsafeStorage EXPORTS LupineRuntime = BEGIN Words: TYPE = LupineRuntime.Words; <> TranslationError: PUBLIC ERROR = CODE; BindingError: PUBLIC ERROR = CODE; RuntimeError: PUBLIC ERROR = CODE; <> MarshalingError: PUBLIC PROCEDURE = {ERROR}; MarshalingExprError: PUBLIC PROCEDURE RETURNS [never: UNSPECIFIED] = {RETURN[ERROR]}; <> UnmarshalingError: PUBLIC PROCEDURE = {ERROR RpcPublic.CallFailed[why: stubProtocol]}; UnmarshalingExprError: PUBLIC PROCEDURE RETURNS [never: UNSPECIFIED] = {ERROR RpcPublic.CallFailed[why: stubProtocol]}; DispatchingError: PUBLIC PROCEDURE RETURNS [never: UNSPECIFIED] = {ERROR RpcPrivate.RejectUnbound}; <> defaultZones: PUBLIC RPC.Zones _ [ gc: SafeStorage.GetSystemZone[], heap: UnsafeStorage.GetSystemUZone[], mds: NIL--??-- ]; <> Checking: BOOLEAN _ TRUE; <> FinishThisPkt: PUBLIC PROCEDURE [ pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength ] RETURNS [--zeroPktLength:-- RpcPrivate.DataLength] = BEGIN Lupine.CheckPktLength[pkt: pkt, lastPkt: FALSE, pktLength: pktLength]; [] _ RpcPrivate.ReceiveExtraPkt[prevPkt: pkt]; RETURN[0]; END; StartNextPkt: PUBLIC PROCEDURE [ pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength ] RETURNS [--zeroPktLength:-- RpcPrivate.DataLength] = BEGIN RpcPrivate.SendPrelimPkt[pkt: pkt, length: pktLength]; RETURN[0]; END; CopyToMultiplePkts: PUBLIC PROCEDURE [ pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength, dataAdr: LONG POINTER, dataLength: Words ] RETURNS [--newPktLength:-- RpcPrivate.DataLength] = BEGIN initialWords: Words = RpcPrivate.maxDataLength - pktLength; wholePkts: CARDINAL _ NULL; finalWords: Words _ NULL; IF Checking AND NOT ( <> pktLength IN [0..RpcPrivate.maxDataLength] AND dataLength > 0 AND pktLength+dataLength > RpcPrivate.maxDataLength ) THEN ERROR; [quotient: wholePkts, remainder: finalWords] _ Basics.DIVMOD[ num: dataLength-initialWords, ------------------------ den: RpcPrivate.maxDataLength ]; <> PrincOpsUtils.LongCOPY[ from: dataAdr, to: @pkt.data[pktLength], nwords: initialWords]; dataAdr _ dataAdr + initialWords; <> THROUGH [0..wholePkts) DO RpcPrivate.SendPrelimPkt[pkt: pkt, length: RpcPrivate.maxDataLength]; PrincOpsUtils.LongCOPY[ from: dataAdr, to: @pkt.data[0], nwords: RpcPrivate.maxDataLength]; dataAdr _ dataAdr + RpcPrivate.maxDataLength; ENDLOOP; <> IF finalWords > 0 THEN BEGIN RpcPrivate.SendPrelimPkt[pkt: pkt, length: RpcPrivate.maxDataLength]; PrincOpsUtils.LongCOPY[from: dataAdr, to: @pkt.data[0], nwords: finalWords]; RETURN[finalWords]; END ELSE RETURN[RpcPrivate.maxDataLength]; END; CopyFromMultiplePkts: PUBLIC PROCEDURE [ pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength, dataAdr: LONG POINTER, dataLength: Words ] RETURNS [--newPktLength:-- RpcPrivate.DataLength] = BEGIN firstDataAdr: LONG POINTER = dataAdr; BEGIN ENABLE UNWIND => <> <> IF dataLength > 0 THEN BEGIN firstDataAdr^ _ 0; PrincOpsUtils.LongCOPY[ from: firstDataAdr, to: firstDataAdr+1, nwords: dataLength-1 ]; END; initialWords: Words = RpcPrivate.maxDataLength - pktLength; wholePkts: CARDINAL _ NULL; finalWords: Words _ NULL; IF Checking AND NOT ( <> pktLength IN [0..RpcPrivate.maxDataLength] AND dataLength > 0 AND pktLength+dataLength > RpcPrivate.maxDataLength ) THEN ERROR; [quotient: wholePkts, remainder: finalWords] _ Basics.DIVMOD[ num: dataLength-initialWords, ------------------------ den: RpcPrivate.maxDataLength ]; <> PrincOpsUtils.LongCOPY[ to: dataAdr, from: @pkt.data[pktLength], nwords: initialWords]; dataAdr _ dataAdr + initialWords; <> THROUGH [0..wholePkts) DO Lupine.CheckPktLength[ pkt: pkt, lastPkt: FALSE, pktLength: RpcPrivate.maxDataLength ]; [] _ RpcPrivate.ReceiveExtraPkt[prevPkt: pkt]; PrincOpsUtils.LongCOPY[ to: dataAdr, from: @pkt.data[0], nwords: RpcPrivate.maxDataLength]; dataAdr _ dataAdr + RpcPrivate.maxDataLength; ENDLOOP; <> IF finalWords > 0 THEN BEGIN Lupine.CheckPktLength[ pkt: pkt, lastPkt: FALSE, pktLength: RpcPrivate.maxDataLength ]; [] _ RpcPrivate.ReceiveExtraPkt[prevPkt: pkt]; PrincOpsUtils.LongCOPY[to: dataAdr, from: @pkt.data[0], nwords: finalWords]; RETURN[finalWords]; END ELSE RETURN[RpcPrivate.maxDataLength]; END; -- ENABLE UNWIND. END; <> <> IF NIL # LOOPHOLE[0, POINTER] THEN ERROR; END. -- LupineRuntimeImpl.