de.zib.scalaris.executor
Class ScalarisOpExecutor

java.lang.Object
  extended by de.zib.scalaris.executor.ScalarisOpExecutor
Direct Known Subclasses:
ScalarisSingleOpExecutor, ScalarisTxOpExecutor

public abstract class ScalarisOpExecutor
extends 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
ScalarisOpExecutor()
           
 
Method Summary
 void addOp(ScalarisOp op)
          Adds the given operation to be executed.
 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 OtpErlangException,
                UnknownException
Executes all operations previously added with addOp(ScalarisOp).

Throws:
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 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