Uses of Class
de.zib.scalaris.UnknownException

Packages that use UnknownException
de.zib.scalaris This package contains means to communicate with the erlang scalaris ring from Java. 
de.zib.scalaris.executor   
de.zib.scalaris.jmx   
de.zib.scalaris.operations   
 

Uses of UnknownException in de.zib.scalaris
 

Methods in de.zib.scalaris that throw UnknownException
 void AbstractTransaction.addDelOnList(OtpErlangString key, OtpErlangList toAdd, OtpErlangList toRemove)
          Changes the list stored at the given key, i.e.
 void Transaction.addDelOnList(OtpErlangString key, OtpErlangList toAdd, OtpErlangList toRemove)
           
<T> void
AbstractTransaction.addDelOnList(String key, List<T> toAdd, List<T> toRemove)
          Changes the list stored at the given key, i.e.
<T> void
Transaction.addDelOnList(String key, List<T> toAdd, List<T> toRemove)
           
 ScalarisVM.AddNodesResult ScalarisVM.addNodes(int number)
          Adds the given number of nodes to the Scalaris VM of the current connection.
 void AbstractTransaction.addOnNr(OtpErlangString key, OtpErlangDouble toAdd)
          Changes the number stored at the given key, i.e.
 void Transaction.addOnNr(OtpErlangString key, OtpErlangDouble toAdd)
           
 void AbstractTransaction.addOnNr(OtpErlangString key, OtpErlangLong toAdd)
          Changes the number stored at the given key, i.e.
 void Transaction.addOnNr(OtpErlangString key, OtpErlangLong toAdd)
           
<T> void
AbstractTransaction.addOnNr(String key, T toAdd)
          Changes the number stored at the given key, i.e.
<T> void
Transaction.addOnNr(String key, T toAdd)
           
static void CommonErlangObjects.checkResult_failAbort(OtpErlangObject received_raw, boolean compressed)
          Processes the received_raw term from erlang and if it is a {fail, abort, KeyList}, issues an AbortException.
static void CommonErlangObjects.checkResult_failAbort(OtpErlangTuple received, boolean compressed)
          Processes the received_raw term from erlang and if it is a {fail, abort, KeyList}, issues an AbortException.
 void Transaction.commit()
          Commits the current transaction.
 DeleteResult ReplicatedDHT.delete(OtpErlangString key)
          Tries to delete all replicas of the given key in 2000ms.
 DeleteResult ReplicatedDHT.delete(OtpErlangString key, int timeout)
          Tries to delete all replicas of the given key.
 DeleteResult ReplicatedDHT.delete(String key)
          Tries to delete all replicas of the given key in 2000ms.
 DeleteResult ReplicatedDHT.delete(String key, int timeout)
          Tries to delete all replicas of the given key.
 ScalarisVM.GetInfoResult ScalarisVM.getInfo()
          Gets some information about the VM and Scalaris.
 Monitor.GetNodeInfoResult Monitor.getNodeInfo()
          Gets some information about the VM and Scalaris.
 Monitor.GetNodePerformanceResult Monitor.getNodePerformance()
          Gets some information about the VM and Scalaris.
 List<ErlangValue> ScalarisVM.getNodes()
          Gets the names of the nodes in the Scalaris VM of the current connection.
 int ScalarisVM.getNumberOfNodes()
          Gets the number of nodes in the Scalaris VM of the current connection.
 List<String> ScalarisVM.getOtherVMs(int max)
          Retrieves additional nodes from the Scalaris VM of the current connection for use by ConnectionFactory.addNode(String).
 List<String> Scalaris.getRandomNodes(int max)
          Retrieves random nodes from Scalaris for use by ConnectionFactory.addNode(String) or ScalarisVM.
 int RoutingTable.getReplicationFactor()
          Returns the replication factor used by the current routing table implementation.
 Monitor.GetServiceInfoResult Monitor.getServiceInfo()
          Gets some information about the Scalaris ring.
 Monitor.GetServicePerformanceResult Monitor.getServicePerformance()
          Gets some information about the Scalaris ring.
 String ScalarisVM.getVersion()
          Gets the version of the Scalaris VM of the current connection.
 boolean ScalarisVM.killNode(ErlangValue name)
          Kills the given node inside the Scalaris VM of the current connection.
 List<ErlangValue> ScalarisVM.killNodes(int number)
          Kills the given number of nodes inside the Scalaris VM of the current connection.
 ScalarisVM.DeleteNodesByNameResult ScalarisVM.killNodes(List<ErlangValue> names)
          Kills the given nodes inside the Scalaris VM of the current connection.
 void TransactionSingleOp.ResultList.processAddDelOnListAt(int pos)
          Processes the result at the given position which originated from a add_del_on_list request.
 void Transaction.ResultList.processAddDelOnListAt(int pos)
          Processes the result at the given position which originated from a add_del_on_list request.
abstract  void ResultList.processAddDelOnListAt(int pos)
          Processes the result at the given position which originated from a add_del_on_list request.
 void TransactionSingleOp.ResultList.processAddOnNrAt(int pos)
          Processes the result at the given position which originated from an add_on_nr request.
 void Transaction.ResultList.processAddOnNrAt(int pos)
          Processes the result at the given position which originated from an add_on_nr request.
abstract  void ResultList.processAddOnNrAt(int pos)
          Processes the result at the given position which originated from an add_on_nr request.
 void Transaction.ResultList.processCommitAt(int pos)
          Processes the result at the given position which originated from a commit request.
 ErlangValue ResultList.processReadAt(int pos)
          Processes the result at the given position which originated from a read request and returns the value that has been read.
 void TransactionSingleOp.ResultList.processTestAndSetAt(int pos)
          Processes the result at the given position which originated from a test_and_set request.
 void Transaction.ResultList.processTestAndSetAt(int pos)
          Processes the result at the given position which originated from an add_on_nr request.
abstract  void ResultList.processTestAndSetAt(int pos)
          Processes the result at the given position which originated from a test_and_set request.
 void TransactionSingleOp.ResultList.processWriteAt(int pos)
          Processes the result at the given position which originated from a write request.
 void Transaction.ResultList.processWriteAt(int pos)
          Processes the result at the given position which originated from a write request.
abstract  void ResultList.processWriteAt(int pos)
          Processes the result at the given position which originated from a write request.
 ErlangValue AbstractTransaction.read(OtpErlangString key)
          Gets the value stored under the given key.
 ErlangValue AbstractTransaction.read(String key)
          Gets the value stored under the given key.
abstract  ResL AbstractTransaction.req_list(ReqL req)
          Executes all requests in req.
 Transaction.ResultList Transaction.req_list(Transaction.RequestList req)
          Executes all requests in req.
 Transaction.ResultList Transaction.req_list(TransactionOperation op)
          Executes the given operation.
 TransactionSingleOp.ResultList TransactionSingleOp.req_list(TransactionSingleOp.RequestList req)
          Executes all requests in req and commits each one of them in a single transaction.
 TransactionSingleOp.ResultList TransactionSingleOp.req_list(TransactionSingleOpOperation op)
          Executes the given operation.
 boolean ScalarisVM.shutdownNode(ErlangValue name)
          Shuts down the given node (graceful leave) inside the Scalaris VM of the current connection.
 List<ErlangValue> ScalarisVM.shutdownNodes(int number)
          Shuts down the given number of nodes (graceful leave) inside the Scalaris VM of the current connection.
 ScalarisVM.DeleteNodesByNameResult ScalarisVM.shutdownNodesByName(List<ErlangValue> names)
          Shuts down the given nodes (graceful leave) inside the Scalaris VM of the current connection.
 void AbstractTransaction.testAndSet(OtpErlangString key, OtpErlangObject oldValue, OtpErlangObject newValue)
          Stores the given key/new_value pair if the old value at key is old_value (atomic test_and_set).
 void Transaction.testAndSet(OtpErlangString key, OtpErlangObject oldValue, OtpErlangObject newValue)
           
<OldT,NewT>
void
AbstractTransaction.testAndSet(String key, OldT oldValue, NewT newValue)
          Stores the given key/new_value pair if the old value at key is old_value (atomic test_and_set).
<OldT,NewT>
void
Transaction.testAndSet(String key, OldT oldValue, NewT newValue)
           
 void AbstractTransaction.write(OtpErlangString key, OtpErlangObject value)
          Stores the given key/value pair.
 void Transaction.write(OtpErlangString key, OtpErlangObject value)
           
<T> void
AbstractTransaction.write(String key, T value)
          Stores the given key/value pair.
<T> void
Transaction.write(String key, T value)
           
 

Constructors in de.zib.scalaris that throw UnknownException
DeleteResult(OtpErlangList list)
          Creates a delete state object by converting the result list returned from erlang.
 

Uses of UnknownException in de.zib.scalaris.executor
 

Methods in de.zib.scalaris.executor that throw UnknownException
 int ScalarisChangeListOp2.doPhase(int phase, int firstOp, ResultList results, RequestList requests)
           
 int ScalarisIncrementOp1.doPhase(int phase, int firstOp, ResultList results, RequestList requests)
           
 int ScalarisIncrementOp2.doPhase(int phase, int firstOp, ResultList results, RequestList requests)
           
 int ScalarisReadOp.doPhase(int phase, int firstOp, ResultList results, RequestList requests)
           
 int ScalarisWriteOp.doPhase(int phase, int firstOp, ResultList results, RequestList requests)
           
 int ScalarisChangeListOp1.doPhase(int phase, int firstOp, ResultList results, RequestList requests)
           
 int ScalarisOp.doPhase(int phase, int firstOp, ResultList results, RequestList requests)
          Executes the given phase.
 void ScalarisOpExecutor.run()
          Executes all operations previously added with ScalarisOpExecutor.addOp(ScalarisOp).
 

Uses of UnknownException in de.zib.scalaris.jmx
 

Methods in de.zib.scalaris.jmx that throw UnknownException
 Double MonitorService.getCurLatencyAvg()
           
 Double MonitorServiceMBean.getCurLatencyAvg()
          Gets the current, i.e.
 Double MonitorNode.getCurLatencyAvg()
           
 Double MonitorNodeMBean.getCurLatencyAvg()
          Gets the current, i.e.
 Double MonitorService.getCurLatencyStddev()
           
 Double MonitorServiceMBean.getCurLatencyStddev()
          Gets the current, i.e.
 Double MonitorNode.getCurLatencyStddev()
           
 Double MonitorNodeMBean.getCurLatencyStddev()
          Gets the current, i.e.
 int MonitorNode.getDhtNodes()
           
 int MonitorNodeMBean.getDhtNodes()
          Gets the number of Scalaris nodes running in the VM the monitor is connected to.
 String MonitorNode.getErlangVersion()
           
 String MonitorNodeMBean.getErlangVersion()
          Gets the version of Erlang running in the VM the monitor is connected to.
 Map<Long,Double> MonitorService.getLatencyAvg()
           
 Map<Long,Double> MonitorServiceMBean.getLatencyAvg()
          Gets average latency values of the whole Scalaris ring from the VM the monitor is connected to.
 Map<Long,Double> MonitorNode.getLatencyAvg()
           
 Map<Long,Double> MonitorNodeMBean.getLatencyAvg()
          Gets average latency values collected in the VM the monitor is connected to.
 Map<Long,Double> MonitorService.getLatencyStddev()
           
 Map<Long,Double> MonitorServiceMBean.getLatencyStddev()
          Gets the standard deviation of the latency values of the whole Scalaris ring from the VM the monitor is connected to.
 Map<Long,Double> MonitorNode.getLatencyStddev()
           
 Map<Long,Double> MonitorNodeMBean.getLatencyStddev()
          Gets the standard deviation of the latency values collected in the VM the monitor is connected to.
 Long MonitorService.getNodes()
           
 Long MonitorServiceMBean.getNodes()
          Gets the number of Scalaris nodes of the whole Scalaris ring from the VM the monitor is connected to.
 String MonitorNode.getScalarisVersion()
           
 String MonitorNodeMBean.getScalarisVersion()
          Gets the version of Scalaris running in the VM the monitor is connected to.
 Long MonitorService.getTotalLoad()
           
 Long MonitorServiceMBean.getTotalLoad()
          Gets the total load of the whole Scalaris ring from the VM the monitor is connected to.
 

Uses of UnknownException in de.zib.scalaris.operations
 

Methods in de.zib.scalaris.operations that throw UnknownException
static void CommitOp.processResult_commit(OtpErlangObject received_raw, boolean compressed)
          Processes the received_raw term from erlang interpreting it as a result from a commit operation.
 ReadRandomFromListOp.Result ReadRandomFromListOp.processResult()
           
 Object Operation.processResult()
          Processes the result set by Operation.setResult(OtpErlangObject, boolean).
 Object CommitOp.processResult()
           
 Object TestAndSetOp.processResult()
           
 ReadSublistOp.Result ReadSublistOp.processResult()
           
 Object AddDelOnListOp.processResult()
           
 Object WriteOp.processResult()
           
 ErlangValue ReadOp.processResult()
           
 Object AddOnNrOp.processResult()
           
 ReadRandomFromListOp.Result ReadRandomFromListOp.processResultSingle()
           
 Object TestAndSetOp.processResultSingle()
           
 ReadSublistOp.Result ReadSublistOp.processResultSingle()
           
 Object AddDelOnListOp.processResultSingle()
           
 Object TransactionSingleOpOperation.processResultSingle()
          Processes the result set by Operation.setResult(OtpErlangObject, boolean) assuming that operation was committed.
 Object WriteOp.processResultSingle()
           
 ErlangValue ReadOp.processResultSingle()
           
 Object AddOnNrOp.processResultSingle()