c

rescala.parrp.ParRP

ParRPTransaction

class ParRPTransaction extends LevelBasedTransaction with ParRPInterTurn

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ParRPTransaction
  2. ParRPInterTurn
  3. LevelBasedTransaction
  4. Initializer
  5. Evaluator
  6. TwoVersionTransactionImpl
  7. TwoVersionTransaction
  8. Transaction
  9. AnyRef
  10. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

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

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 access(reactive: ParRP.ReSource): Value
  5. def acquireShared(reactive: ParRP.ReSource): Key[ParRPInterTurn]
  6. def admit(reactive: ParRP.Derived): Unit
    Definition Classes
    ParRPTransactionParRPInterTurn
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def beforeDynamicDependencyInteraction(dependency: ParRP.ReSource): Unit

    allow turn to handle dynamic access to reactives

    allow turn to handle dynamic access to reactives

    Definition Classes
    ParRPTransactionTwoVersionTransactionImpl
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  10. final def commitDependencyDiff(node: ParRP.Derived, current: Set[ParRP.ReSource])(updated: Set[ParRP.ReSource]): Unit
    Definition Classes
    TwoVersionTransactionImpl
  11. def commitPhase(): Unit

    Commits all uncommitted changes to the reactive element.

    Commits all uncommitted changes to the reactive element.

    Definition Classes
    TwoVersionTransactionImplTwoVersionTransaction
  12. def discover(source: ParRP.ReSource, sink: ParRP.Derived): 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
    ParRPTransactionParRPInterTurnTwoVersionTransactionImpl
  13. def drop(source: ParRP.ReSource, sink: ParRP.Derived): 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
    ParRPTransactionParRPInterTurnTwoVersionTransactionImpl
  14. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  16. def evaluate(r: ParRP.Derived): Unit

    Overrides the evaluator, this is essentially an inlined callback

    Overrides the evaluator, this is essentially an inlined callback

    Definition Classes
    LevelBasedTransaction → Evaluator
  17. def evaluateIn(head: ParRP.Derived)(dt: ParRP.ReevTicket[core.Core.Derived.Value]): Unit
    Definition Classes
    LevelBasedTransaction
  18. def forget(reactive: ParRP.Derived): Unit
    Definition Classes
    ParRPTransactionParRPInterTurn
  19. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  20. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  21. final def initializationPhase(initialChanges: Map[ParRP.ReSource, ParRP.InitialChange]): Unit

    Starts the propagation by applying the initial changes

    Starts the propagation by applying the initial changes

    Definition Classes
    LevelBasedTransactionTwoVersionTransaction
  22. def initialize(reactive: ParRP.Derived, incoming: Set[ParRP.ReSource], needsReevaluation: 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

    needsReevaluation

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

    Attributes
    protected
    Definition Classes
    LevelBasedTransactionInitializer
  23. def initializer: ParRP.Initializer
    Definition Classes
    LevelBasedTransactionTransaction
  24. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  25. final val key: Key[ParRPInterTurn]
  26. lazy val levelQueue: ParRP.LevelQueue
    Definition Classes
    LevelBasedTransaction
  27. def makeDerivedStructState[V](initialValue: V): ParRPState[V]

    Creates the internal state of Deriveds

    Creates the internal state of Deriveds

    Attributes
    protected[this]
    Definition Classes
    ParRPTransactionInitializer
  28. def makeSourceStructState[V](initialValue: V): State[V]

    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() @IntrinsicCandidate()
  31. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  32. final def now[A](reactive: ParRP.ReadAs[A]): A
    Definition Classes
    Transaction
  33. def observe(f: ParRP.Observation): Unit
  34. def observerPhase(): Unit

    Call all registered after-commit obverser functions.

    Call all registered after-commit obverser functions.

    Definition Classes
    TwoVersionTransactionImplTwoVersionTransaction
  35. val observers: ListBuffer[ParRP.Observation]
    Definition Classes
    TwoVersionTransactionImpl
  36. def preparationPhase(initialWrites: Set[ParRP.ReSource]): 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
    ParRPTransactionTwoVersionTransaction
  37. final def prepareInitialChange(ic: ParRP.InitialChange): Unit
    Definition Classes
    LevelBasedTransaction
  38. 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
    LevelBasedTransactionTwoVersionTransaction
  39. def register(reactive: ParRP.ReSource): Unit

    hook for schedulers to globally collect all created resources, usually does nothing

    hook for schedulers to globally collect all created resources, usually does nothing

    Attributes
    protected[this]
    Definition Classes
    Initializer
  40. 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
    ParRPTransactionTwoVersionTransaction
  41. def rollbackPhase(): Unit

    Reverts all uncommitted changes to the reactive element.

    Reverts all uncommitted changes to the reactive element.

    Definition Classes
    TwoVersionTransactionImplTwoVersionTransaction
  42. def schedule(commitable: ParRP.ReSource): 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
    TwoVersionTransactionImplTwoVersionTransaction
  43. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  44. val toCommit: ListBuffer[ParRP.ReSource]
    Definition Classes
    TwoVersionTransactionImpl
  45. def toString(): String
    Definition Classes
    ParRPTransaction → AnyRef → Any
  46. val token: Token
    Definition Classes
    TwoVersionTransactionImpl
  47. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  48. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  49. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  50. def writeState(pulsing: ParRP.ReSource)(value: Value): Unit
  51. object accessHandler extends Twoversion.AccessHandler
    Definition Classes
    TwoVersionTransactionImpl

Deprecated Value Members

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

Inherited from ParRPInterTurn

Inherited from ParRP.Initializer

Inherited from Evaluator

Inherited from ParRP.Transaction

Inherited from AnyRef

Inherited from Any

Ungrouped