<> <> <> <> <> <> <> <> <> DIRECTORY AlpineEnvironment USING [Outcome, TransactionPriority, TransID, nullTransID], AlpineImport USING [Handle, nullHandle], AlpineInternal USING [Difficulty, FileInstanceHandle, LockTransHeaderHandle, LogRecordID, nullLogRecordID, WorkerOutcome, WorkLevel], BasicTime USING [GMT], Process USING [Milliseconds], RPC USING [ConversationID, maxShortStringLength]; Worker: DEFINITIONS = BEGIN State: TYPE = { unknown, active, preparing, ready, completing, fpmComplete, fpmCompleteBeingForcedOut, complete }; StateDuringRecovery: TYPE = { active, ready, committed, aborted }; Outcome: TYPE = AlpineEnvironment.Outcome --{abort, commit, unknown}--; Object: TYPE = MONITORED RECORD [ transID: AlpineEnvironment.TransID _ AlpineEnvironment.nullTransID, --immutable-- beginRecord: AlpineInternal.LogRecordID _ AlpineInternal.nullLogRecordID, --immutable-- coordinator: AlpineImport.Handle _ AlpineImport.nullHandle, --immutable-- locks: AlpineInternal.LockTransHeaderHandle _ NIL, --immutable-- coordinatorIsRemote: BOOL _ TRUE, state: State _ unknown, --increases monotonically to complete-- outcome: Outcome _ unknown, --changes during state transition ready -> completing-- backupComplete: BOOLEAN _ FALSE, -- increases monotonically to TRUE ; not used yet -- allowableDifficulty: Difficulty _ hard, < normal -> zero during preparing or completing state.>> <> <> priority: AlpineEnvironment.TransactionPriority _ normal, nStarts: [0..maxStarts] _ 0, <> <> stateDuringRecovery: StateDuringRecovery _ active, <> timeOfLastStartWork: BasicTime.GMT, <> estimatedUpdateCost: INT _ 0, <<0 means that the transaction is readonly. The estimatedUpdateCost increases during>> <> fileInstanceList: AlpineInternal.FileInstanceHandle _ NIL, <> enabledWheelList: LIST OF RPC.ConversationID _ NIL, <> <> continueWorker: Handle _ nullHandle, --holds continuation transaction, if any-- next: Handle _ nullHandle --WorkerMap data structure-- ]; Handle: TYPE = REF Object; nullHandle: Handle = NIL; shortWaitTime: Process.Milliseconds = 100; <> <> Difficulty: TYPE = AlpineInternal.Difficulty; --{zero, normal, hard} WorkLevel: TYPE = AlpineInternal.WorkLevel; --Difficulty [normal .. hard] <> <> <> maxStarts: CARDINAL = 7; <> <> <> <> BeginLogRep: TYPE = MACHINE DEPENDENT RECORD [ coordinator: StrBody]; CompletingLogRep: TYPE = MACHINE DEPENDENT RECORD [ outcome: AlpineInternal.WorkerOutcome]; StrBody: TYPE = MACHINE DEPENDENT RECORD [ length: CARDINAL _ 0, maxLength: CARDINAL _ RPC.maxShortStringLength, text: PACKED ARRAY[0..RPC.maxShortStringLength) OF CHAR]; END. <> <> <<>>