Package de.zib.scalaris.executor

Class ScalarisOpExecutor

java.lang.Object

de.zib.scalaris.executor.ScalarisOpExecutor

Direct Known Subclasses:

ScalarisSingleOpExecutor, ScalarisTxOpExecutor

public abstract class ScalarisOpExecutor
extends java.lang.Object

Executes multiple ScalarisOp operations in multiple phases only sending requests to Scalaris once per work phase.

Since:

3.13

Version:

3.13

Author:

Nico Kruber, kruber@zib.de

Constructor Summary

Constructors

Constructor	Description
ScalarisOpExecutor()

Method Summary

Modifier and Type	Method	Description
void	addOp(ScalarisOp op)	Adds the given operation to be executed.
java.util.ArrayList<ScalarisOp>	getOps()	Gets the current list of operations.
int	getWorkPhases()
void	reset()	Re-sets the executor as if created from scratch.
void	run()	Executes all operations previously added with addOp(ScalarisOp).

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScalarisOpExecutor

public ScalarisOpExecutor()

Method Detail

addOp

public void addOp(ScalarisOp op)

Adds the given operation to be executed.

Parameters:

op - the operation to add

reset

public void reset()

Re-sets the executor as if created from scratch.

run

public void run()
         throws com.ericsson.otp.erlang.OtpErlangException,
                UnknownException

Executes all operations previously added with addOp(ScalarisOp).

Throws:

com.ericsson.otp.erlang.OtpErlangException - if an error occurred verifying a result from previous operations

UnknownException - if an error occurred verifying a result from previous operations

getWorkPhases

public int getWorkPhases()

Returns:

the workPhases

getOps

public java.util.ArrayList<ScalarisOp> getOps()

Gets the current list of operations. This is backed by the operations in this executor - if it is reset, the list will be empty. Create a copy of this list if it should be retained.

Returns:

the ops the current list of operations