|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
Transaction.addDelOnList(OtpErlangString key,
OtpErlangList toAdd,
OtpErlangList toRemove)
|
|
void |
AbstractTransaction.addDelOnList(OtpErlangString key,
OtpErlangList toAdd,
OtpErlangList toRemove)
Changes the list stored at the given key, i.e. |
|
|
Transaction.addDelOnList(String key,
List<T> toAdd,
List<T> toRemove)
|
|
|
AbstractTransaction.addDelOnList(String key,
List<T> toAdd,
List<T> toRemove)
Changes the list stored at the given key, i.e. |
|
ScalarisVM.AddNodesResult |
ScalarisVM.addNodes(int number)
Adds the given number of nodes to the Scalaris VM of the current connection. |
|
void |
Transaction.addOnNr(OtpErlangString key,
OtpErlangDouble toAdd)
|
|
void |
AbstractTransaction.addOnNr(OtpErlangString key,
OtpErlangDouble toAdd)
Changes the number stored at the given key, i.e. |
|
void |
Transaction.addOnNr(OtpErlangString key,
OtpErlangLong toAdd)
|
|
void |
AbstractTransaction.addOnNr(OtpErlangString key,
OtpErlangLong toAdd)
Changes the number stored at the given key, i.e. |
|
|
Transaction.addOnNr(String key,
T toAdd)
|
|
|
AbstractTransaction.addOnNr(String key,
T toAdd)
Changes the number stored at the given key, i.e. |
|
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. |
|
abstract void |
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. |
|
void |
TransactionSingleOp.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.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. |
|
abstract void |
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. |
|
void |
TransactionSingleOp.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. |
|
void |
Transaction.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 |
Transaction.testAndSet(OtpErlangString key,
OtpErlangObject oldValue,
OtpErlangObject newValue)
|
|
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). |
|
|
Transaction.testAndSet(String key,
OldT oldValue,
NewT newValue)
|
|
|
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). |
|
void |
Transaction.write(OtpErlangString key,
OtpErlangObject value)
|
|
void |
AbstractTransaction.write(OtpErlangString key,
OtpErlangObject value)
Stores the given key /value pair. |
|
|
Transaction.write(String key,
T value)
|
|
|
AbstractTransaction.write(String key,
T value)
Stores the given key /value pair. |
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 |
ScalarisChangeListOp1.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests)
|
int |
ScalarisIncrementOp1.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests)
|
int |
ScalarisChangeListOp2.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests)
|
int |
ScalarisWriteOp.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests)
|
int |
ScalarisOp.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests)
Executes the given phase. |
int |
ScalarisReadOp.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests)
|
int |
ScalarisIncrementOp2.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests)
|
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 |
---|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |