Packages

class ParRP extends LevelBasedPropagation[ParRP] with ParRPInterTurn with LevelStruct

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ParRP
  2. LevelStruct
  3. TwoVersionStruct
  4. Struct
  5. ParRPInterTurn
  6. LevelBasedPropagation
  7. Evaluator
  8. TwoVersionPropagationImpl
  9. Initializer
  10. TwoVersionPropagation
  11. AnyRef
  12. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ParRP(backoff: Backoff, priorTurn: Option[ParRP])

Type Members

  1. type State[P, S <: Struct] = ParRPState[P, S]
    Definition Classes
    ParRPLevelStructTwoVersionStructStruct

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def acquireShared(reactive: ReSource[TState]): Key[ParRPInterTurn]
  5. def admit(reactive: Reactive[TState]): Unit
    Definition Classes
    ParRPParRPInterTurn
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clear(): Unit
  8. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate() @throws( ... )
  9. final def commitDependencyDiff(node: Reactive[ParRP], current: Set[ReSource[ParRP]])(updated: Set[ReSource[ParRP]]): Unit
    Definition Classes
    TwoVersionPropagationImpl
  10. def commitPhase(): Unit

    Commits all uncommitted changes to the reactive element.

    Commits all uncommitted changes to the reactive element.

    Definition Classes
    TwoVersionPropagationImplTwoVersionPropagation
  11. def discover(source: ReSource[TState], sink: Reactive[TState]): Unit

    registering a dependency on a node we do not personally own does require some additional care.

    registering a dependency on a node we do not personally own does require some additional care. we let the other turn update the dependency and admit the dependent into the propagation queue so that it gets updated when that turn continues the responsibility for correctly passing the locks is moved to the commit phase

    Definition Classes
    ParRPParRPInterTurnTwoVersionPropagationImpl
  12. def drop(source: ReSource[TState], sink: Reactive[TState]): Unit

    this is for cases where we register and then unregister the same dependency in a single turn

    this is for cases where we register and then unregister the same dependency in a single turn

    Definition Classes
    ParRPParRPInterTurnTwoVersionPropagationImpl
  13. def dynamicDependencyInteraction(dependency: ReSource[TState]): Unit

    allow turn to handle dynamic access to reactives

    allow turn to handle dynamic access to reactives

    Definition Classes
    ParRPTwoVersionPropagationImpl
  14. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  16. def evaluate(r: Reactive[ParRP]): Unit
    Definition Classes
    LevelBasedPropagation → Evaluator
  17. def evaluateIn(head: Reactive[ParRP])(dt: ReevTicket[core.Reactive.Value, ParRP]): Unit
    Definition Classes
    LevelBasedPropagation
  18. def forget(reactive: Reactive[TState]): Unit
    Definition Classes
    ParRPParRPInterTurn
  19. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  21. def ignite(reactive: Reactive[ParRP], incoming: Set[ReSource[ParRP]], ignitionRequiresReevaluation: Boolean): Unit

    to be implemented by the propagation algorithm, called when a new reactive has been instantiated and needs to be connected to the graph and potentially reevaluated.

    to be implemented by the propagation algorithm, called when a new reactive has been instantiated and needs to be connected to the graph and potentially reevaluated.

    reactive

    the newly instantiated reactive

    incoming

    a set of incoming dependencies

    ignitionRequiresReevaluation

    true if the reactive must be reevaluated at creation even if none of its dependencies change in the creating turn.

    Attributes
    protected
    Definition Classes
    LevelBasedPropagationInitializer
  22. final def initializationPhase(initialChanges: Map[ReSource[ParRP], InitialChange[ParRP]]): Unit

    Starts the propagation by applying the initial changes

    Starts the propagation by applying the initial changes

    Definition Classes
    TwoVersionPropagationImplTwoVersionPropagation
  23. final def initialize(ic: InitialChange[ParRP]): Unit
  24. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  25. final val key: Key[ParRPInterTurn]
  26. val levelQueue: LevelQueue[ParRP]
    Definition Classes
    LevelBasedPropagation
  27. def makeDerivedStructState[V](ip: InitValues[V], creationTicket: CreationTicket[ParRP]): ParRPState[V, ParRP]

    Creates the internal state of Reactives

    Creates the internal state of Reactives

    Attributes
    protected[this]
    Definition Classes
    ParRPInitializer
  28. def makeSourceStructState[V](valuePersistency: InitValues[V], creationTicket: CreationTicket[ParRP]): State[V, ParRP]

    Creates the internal state of ReSources

    Creates the internal state of ReSources

    Attributes
    protected[this]
    Definition Classes
    Initializer
  29. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  31. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  32. def observe(f: () ⇒ Unit): Unit
    Definition Classes
    TwoVersionPropagationImpl
  33. def observerPhase(): Unit

    Call all registered after-commit obverser functions.

    Call all registered after-commit obverser functions.

    Definition Classes
    TwoVersionPropagationImplTwoVersionPropagation
  34. def preparationPhase(initialWrites: Set[ReSource[TState]]): Unit

    lock all reactives reachable from the initial sources retry when acquire returns false

    lock all reactives reachable from the initial sources retry when acquire returns false

    initialWrites

    List of affected reactive values

    Definition Classes
    ParRPTwoVersionPropagation
  35. def propagationPhase(): Unit

    Performs the actual propagation, setting the new (not yet committed) values for each reactive element.

    Performs the actual propagation, setting the new (not yet committed) values for each reactive element.

    Definition Classes
    LevelBasedPropagationTwoVersionPropagation
  36. val reevaluationTicket: ReevTicket[_, ParRP]
    Definition Classes
    LevelBasedPropagation
  37. def releasePhase(): Unit

    this is called after the turn has finished propagating, but before handlers are executed

    this is called after the turn has finished propagating, but before handlers are executed

    Definition Classes
    ParRPTwoVersionPropagation
  38. def rollbackPhase(): Unit

    Reverts all uncommitted changes to the reactive element.

    Reverts all uncommitted changes to the reactive element.

    Definition Classes
    TwoVersionPropagationImplTwoVersionPropagation
  39. def schedule(commitable: Committable[ParRP]): Unit

    Schedules a temporarily written change to be committed by the turn.

    Schedules a temporarily written change to be committed by the turn.

    Definition Classes
    TwoVersionPropagationImplTwoVersionPropagation
  40. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  41. def toString(): String
    Definition Classes
    ParRP → AnyRef → Any
  42. def token: Token
    Definition Classes
    TwoVersionPropagationImpl
  43. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  44. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  45. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  46. def writeState(pulsing: ReSource[TState])(value: Value): Unit
    Definition Classes
    ParRPTwoVersionPropagationImpl

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from LevelStruct

Inherited from TwoVersionStruct

Inherited from Struct

Inherited from ParRPInterTurn

Inherited from LevelBasedPropagation[ParRP]

Inherited from Evaluator[ParRP]

Inherited from Initializer[ParRP]

Inherited from TwoVersionPropagation[ParRP]

Inherited from AnyRef

Inherited from Any

Ungrouped