<> <> <> <> <> <> <> <<>> <> <<>> DIRECTORY Basics USING [charsPerWord], PrincOpsUtils USING [LongCopy], RPC USING [Zones], Rope USING [ ROPE ], RPCLupine USING [DataLength, maxDataLength, --PktLength,-- RPCPkt, StubPkt]; LupineRuntime: DEFINITIONS IMPORTS PrincOpsUtils = { OPEN RpcPrivate: RPCLupine; <> TranslationError: ERROR; BindingError: ERROR; RuntimeError: ERROR; <> MarshalingError: PROC; MarshalingExprError: PROC RETURNS [never: UNSPECIFIED]; <> UnmarshalingError: PROC; UnmarshalingExprError: PROC RETURNS [never: UNSPECIFIED]; DispatchingError: PROC RETURNS [never: UNSPECIFIED]; <> defaultZones: RPC.Zones; <> NilHeader: TYPE = BOOL _ NULL; RopeHeader: TYPE = CARDINAL _ NULL; ListHeader, SequenceHeader: TYPE = LONG CARDINAL _ NULL; StringHeader: TYPE = MACHINE DEPENDENT RECORD [ header (0): SELECT OVERLAID * FROM Lengths => [maxLength (0), length (1): CARDINAL_NULL], All => [all (0): LONG CARDINAL], ENDCASE] _ [Lengths[]]; <> DoubleWord: TYPE = LONG CARDINAL; -- LONG UNSPECIFIED doesn't work well StubPktDoubleWord: PROC [pkt: RpcPrivate.StubPkt, index: RpcPrivate.DataLength] RETURNS [--ptrToDoubleWord:-- POINTER TO DoubleWord] = INLINE { RETURN[LOOPHOLE[@pkt.data[index]]]}; RpcPktDoubleWord: PROC [pkt: RpcPrivate.RPCPkt, index: RpcPrivate.DataLength] RETURNS [--ptrToDoubleWord:-- LONG POINTER TO DoubleWord] = INLINE { RETURN[LOOPHOLE[@pkt.data[index]]]}; SHORT: PROC [long: LONG CARDINAL] RETURNS [CARDINAL] = INLINE { IF long <= LAST[CARDINAL] THEN RETURN[long] ELSE RETURN[UnmarshalingExprError[]]; }; Words: TYPE = --LONG-- CARDINAL _ NULL; WordsForChars: PROC [chars: CARDINAL] RETURNS [--words:-- Words] = INLINE { RETURN[(chars+Basics.charsPerWord-1)/Basics.charsPerWord]; }; CheckPktLength: PROC [ pkt: RpcPrivate.RPCPkt, lastPkt: BOOL _ TRUE, pktLength: RpcPrivate.DataLength ] = INLINE { <> <> }; FinishThisPkt, StartNextPkt: PROC [ pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength ] RETURNS [zeroPktLength: RpcPrivate.DataLength]; CopyToPkt: PROC [ pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength, dataAdr: LONG POINTER, dataLength: Words, alwaysOnePkt: BOOL _ FALSE ] RETURNS [--newPktLength:-- RpcPrivate.DataLength] = INLINE { IF alwaysOnePkt OR pktLength+dataLength <= RpcPrivate.maxDataLength THEN { PrincOpsUtils.LongCopy[to: @pkt.data[pktLength], from: dataAdr, nwords: dataLength]; RETURN[pktLength+dataLength]; } ELSE RETURN[ CopyToMultiplePkts[pkt, pktLength, dataAdr, dataLength] ]; }; CopyFromPkt: PROC [ pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength, dataAdr: LONG POINTER, dataLength: Words, alwaysOnePkt: BOOL _ FALSE ] RETURNS [--newPktLength:-- RpcPrivate.DataLength] = INLINE { IF alwaysOnePkt OR pktLength+dataLength <= RpcPrivate.maxDataLength THEN { PrincOpsUtils.LongCopy[to: dataAdr, from: @pkt.data[pktLength], nwords: dataLength]; RETURN[pktLength+dataLength]; } ELSE RETURN[ CopyFromMultiplePkts[pkt, pktLength, dataAdr, dataLength] ]; }; CopyToMultiplePkts, CopyFromMultiplePkts: PRIVATE PROC [ pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength, dataAdr: LONG POINTER, dataLength: Words ] RETURNS [--newPktLength:-- RpcPrivate.DataLength]; MarshalRope: PROC [ rope: Rope.ROPE, pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength, assertShortRope: BOOL] RETURNS [newLength: RpcPrivate.DataLength]; UnmarshalRope: PROC [pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength, assertShortRope: BOOL] RETURNS [rope: Rope.ROPE, newLength: RpcPrivate.DataLength]; MarshalAtom: PROC [ atom: ATOM, pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength] RETURNS [newLength: RpcPrivate.DataLength]; UnmarshalAtom: PROC [pkt: RpcPrivate.RPCPkt, pktLength: RpcPrivate.DataLength] RETURNS [atom: ATOM, newLength: RpcPrivate.DataLength]; <<>> }. -- LupineRuntime. <> <> <<>> <<>>