Packages

c

be.opimedia.scala_par_am

ParAAMCSState

class ParAAMCSState[Exp, Abs, Addr, Time] extends ParAAMLSAState[Exp, Abs, Addr, Time]

ParAAMCSState: ParAAM-C-S-state for Parallel AAM - Concurrent - Sender - state

The worklist is implemented by an immutable list of sets of states.

The main method eval() just starts the unique actor ActorSender. This actor sends the initial state to the first actor ActorEval.

Each actor ActorEval evaluates a state, updates data, and sends that it is now available to the actor ActorSender.

Each time that the ActorSender receives a message from an actor ActorEval, it sends one state of the worklist to each actor ActorEval available, until to the worklist becomes empty.

Extend ParAAMLSAState class to reuse common code.

Source https://bitbucket.org/OPiMedia/scala-par-am/src/master/scala-par-am/src/main/scala/machine/ParAAMCSState.scala

Linear Supertypes
ParAAMLSAState[Exp, Abs, Addr, Time], SeqAAM[Exp, Abs, Addr, Time], EvalKontMachine[Exp, Abs, Addr, Time], AbstractMachine[Exp, Abs, Addr, Time], AnyRef, Any
Known Subclasses
ParAAMCHybrid, ParAAMCHybridH, ParAAMCPart, ParAAMCPartH, ParAAMCSPart, ParAAMCSSet, ParAAMCSet, ParAAMCSetH, ParAAMCState
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ParAAMCSState
  2. ParAAMLSAState
  3. SeqAAM
  4. EvalKontMachine
  5. AbstractMachine
  6. AnyRef
  7. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ParAAMCSState()(implicit arg0: Expression[Exp], arg1: JoinLattice[Abs], arg2: Address[Addr], arg3: Timestamp[Time])

Type Members

  1. trait Output extends AnyRef

    The output of the abstract machine.

    The output of the abstract machine.

    Definition Classes
    AbstractMachine
  2. trait Control extends MemoHashCode

    The control component of the machine

    The control component of the machine

    Definition Classes
    EvalKontMachine
  3. case class ControlError(err: SemanticError) extends Control with Product with Serializable

    Or an error component, in case an error is reached (e.g., incorrect number of arguments in a function call)

    Or an error component, in case an error is reached (e.g., incorrect number of arguments in a function call)

    Definition Classes
    EvalKontMachine
  4. case class ControlEval(exp: Exp, env: Environment[Addr]) extends Control with Product with Serializable

    It can either be an eval component, where an expression needs to be evaluated in an environment

    It can either be an eval component, where an expression needs to be evaluated in an environment

    Definition Classes
    EvalKontMachine
  5. case class ControlKont(v: Abs) extends Control with Product with Serializable

    Or it can be a continuation component, where a value has been reached and a continuation should be popped from the stack to continue the evaluation

    Or it can be a continuation component, where a value has been reached and a continuation should be popped from the stack to continue the evaluation

    Definition Classes
    EvalKontMachine
  6. type CollectedLocalResults = (List[State], Option[Graph[State]])
    Definition Classes
    ParAAMLSAState
  7. type LocalResults = (List[State], List[(State, Set[State])])
    Definition Classes
    ParAAMLSAState
  8. trait KontAddr extends MemoHashCode

    The store used for continuations is a KontStore (defined in Kontinuation.scala).

    The store used for continuations is a KontStore (defined in Kontinuation.scala). It is parameterized by continuation addresses, that are element of the KontAddress typeclass.

    Definition Classes
    SeqAAM

Value Members

  1. def collectLocalResults(actors: Array[ActorRef], message: Int, timeout: FiniteDuration, computeGraph: Boolean, selfActor: ActorRef = null, selfLocal: LocalResults = (Nil, Nil)): CollectedLocalResults

    Sends message to each actor to ask halted and edges collected locally.

    Sends message to each actor to ask halted and edges collected locally. Builds and returns complete halted and graph results.

    Definition Classes
    ParAAMLSAState
  2. def eval(exp: Exp, sem: Semantics[Exp, Abs, Addr, Time], config: MachineConfig): Output

    Performs the evaluation of an expression as SeqAAM.eval.

    Performs the evaluation of an expression as SeqAAM.eval. It is the main work that is parallelized.

    exp

    The program to be evaluate

    config

    Specify some parameters of the machine

    returns

    An object implementing the Output trait, containing information about the evaluation.

    Definition Classes
    ParAAMCSState → ParAAMLSAState → SeqAAM → AbstractMachine
  3. def isParallel: Boolean

    Returns true iff the machine is a parallel machine

    Returns true iff the machine is a parallel machine

    Definition Classes
    ParAAMLSAState → AbstractMachine
  4. def minProcess: Int

    Returns the minimum processes possible for this machine.

    Returns the minimum processes possible for this machine. Must be >= 1 and must be 1 if !isParallel.

    Definition Classes
    ParAAMCSState → ParAAMLSAState → AbstractMachine
  5. def name: String

    The name of the abstract machine.

    The name of the abstract machine.

    Definition Classes
    ParAAMCSState → ParAAMLSAState → SeqAAM → AbstractMachine
  6. def nbNotEvalProcess: Int

    Returns the number of processes that whose task is not to perform step evaluation.

    Returns the number of processes that whose task is not to perform step evaluation. Must be >= 0.

    Definition Classes
    ParAAMCSState → ParAAMLSAState → AbstractMachine