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