-- Stub file AlpineTransactionRpcBinderImpl.mesa was translated on -- 3-May-83 12:39:40 PDT by Lupine of 18-Feb-83 11:25:52 PST. -- Source interface AlpineTransaction came from file AlpineTransaction.bcd, -- which was created on 3-May-83 12:37:59 PDT with version stamp 124#372#30473427702 -- from source of 8-Mar-83 14:35:29 PST. -- The RPC stub modules for AlpineTransaction are: -- AlpineTransactionRpcControl.mesa; -- AlpineTransactionRpcClientImpl.mesa; -- AlpineTransactionRpcBinderImpl.mesa; -- AlpineTransactionRpcServerImpl.mesa. -- The parameters for this translation are: -- Target language = Cedar; -- Default parameter passing = VALUE; -- Deallocate server heap arguments = TRUE; -- Inline RpcServerImpl dispatcher stubs = TRUE; -- Maximum number of dynamic heap NEWs = 50, MDS NEWs = 50; -- Acceptable parameter protocols = VersionRange[1,1]. -- NOTE: Discard this module unless you use dynamic client binding. DIRECTORY AlpineTransaction, AlpineTransactionRpcControl USING [InterfaceRecord, InterfaceRecordObject], AlpineTransactionRpcClientImpl, RPC USING [InterfaceName, Zones], RTTypesBasic USING [EstablishFinalization, FinalizationQueue, FQEmpty, FQNext, NewFQ]; AlpineTransactionRpcBinderImpl: MONITOR IMPORTS AlpineTransaction, ClientPrototype: AlpineTransactionRpcClientImpl, RTT: RTTypesBasic EXPORTS AlpineTransactionRpcControl SHARES AlpineTransactionRpcControl = BEGIN OPEN RpcControl: AlpineTransactionRpcControl, RpcPublic: RPC; -- Dynamic instantiation and binding routines. ImportNewInterface: PUBLIC SAFE PROCEDURE [ interfaceName: RpcPublic.InterfaceName, parameterStorage: RpcPublic.Zones ] RETURNS [interfaceRecord: RpcControl.InterfaceRecord] = TRUSTED BEGIN interfaceRecord ← NewInterface[]; LupineDetails[interfaceRecord].module.ImportInterface [ interfaceName: interfaceName, parameterStorage: parameterStorage ! UNWIND => FreeInterface[interfaceRecord] ]; END; UnimportNewInterface: SAFE PROCEDURE [ interfaceRecord: RpcControl.InterfaceRecord ] = TRUSTED BEGIN LupineDetails[interfaceRecord].module.UnimportInterface[]; FreeInterface[interfaceRecord]; END; -- Utility routines for interface instantiation and caching. ConcreteLupineDetails: TYPE = REF LupineDetailsObject; LupineDetailsObject: PUBLIC TYPE = RECORD [ module: ClientModule←NIL, list: RpcControl.InterfaceRecord←NIL, --package reference next: RpcControl.InterfaceRecord←NIL --free list -- ]; LupineDetails: PROCEDURE [abstractInterface: RpcControl.InterfaceRecord] RETURNS [ConcreteLupineDetails] = INLINE {RETURN[abstractInterface.lupineDetails]}; ClientModule: TYPE = POINTER TO FRAME[AlpineTransactionRpcClientImpl]; clientInterfaceCache: RpcControl.InterfaceRecord ← NIL; -- free interface -- records clientInterfaceList: RpcControl.InterfaceRecord ← NIL; -- all interface -- records NewInterfaceRecord: PUBLIC SAFE PROCEDURE RETURNS [interfaceRecord: RpcControl.InterfaceRecord] = TRUSTED BEGIN interfaceRecord ← NEW[RpcControl.InterfaceRecordObject]; END; NewInterface: PROCEDURE RETURNS [interface: RpcControl.InterfaceRecord]= BEGIN GetCachedInterface: ENTRY PROCEDURE RETURNS [cachedIR: RpcControl.InterfaceRecord] = INLINE BEGIN ENABLE UNWIND => NULL; IF (cachedIR←clientInterfaceCache) # NIL THEN clientInterfaceCache ← LupineDetails[clientInterfaceCache].next; END; ReclaimInterfaces[]; IF (interface ← GetCachedInterface[]) = NIL THEN BEGIN ChainNewInterface: ENTRY PROCEDURE = INLINE BEGIN ENABLE UNWIND => NULL; interface.lupineDetails ← NEW[ LupineDetailsObject ← [module: module, list: clientInterfaceList]]; clientInterfaceList ← interface; END; -- ChainNewInterface. module: ClientModule = NEW ClientPrototype; interface ← NewInterfaceRecord[]; interface↑ ← [ Create: module.Create, CreateWorker: module.CreateWorker, AssertAlpineWheel: module.AssertAlpineWheel, Finish: module.Finish, Unknown: AlpineTransaction.Unknown, OperationFailed: AlpineTransaction.OperationFailed]; ChainNewInterface[]; END; END; FreeInterface: ENTRY PROCEDURE [interface: RpcControl.InterfaceRecord]= INLINE BEGIN ENABLE UNWIND => NULL; LupineDetails[interface].next ← clientInterfaceCache; clientInterfaceCache ← interface; END; -- Finalization for dynamic interfaces. Just cache and reuse for now. freedInterfaces: RTT.FinalizationQueue = RTT.NewFQ[20]; ReclaimInterfaces: PROCEDURE = INLINE BEGIN WHILE ~RTT.FQEmpty[freedInterfaces] DO interface: RpcControl.InterfaceRecord = NARROW[RTT.FQNext[freedInterfaces]]; IF interface.lupineDetails # NIL THEN UnimportNewInterface[interface]; ENDLOOP; END; -- Module initialization. RTT.EstablishFinalization[ type: CODE[RpcControl.InterfaceRecordObject], npr: 1, fq: freedInterfaces ]; END. -- AlpineTransactionRpcBinderImpl.