| Package | Description |
|---|---|
| de.zib.scalaris |
This package contains means to communicate with the erlang scalaris ring from Java.
|
| de.zib.scalaris.operations |
| Modifier and Type | Method | Description |
|---|---|---|
void |
AbstractTransaction.addDelOnList(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangList toAdd,
com.ericsson.otp.erlang.OtpErlangList toRemove) |
Changes the list stored at the given key, i.e.
|
<T> void |
AbstractTransaction.addDelOnList(java.lang.String key,
java.util.List<T> toAdd,
java.util.List<T> toRemove) |
Changes the list stored at the given key, i.e.
|
void |
AbstractTransaction.addOnNr(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangDouble toAdd) |
Changes the number stored at the given key, i.e.
|
void |
AbstractTransaction.addOnNr(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangLong toAdd) |
Changes the number stored at the given key, i.e.
|
<T> void |
AbstractTransaction.addOnNr(java.lang.String key,
T toAdd) |
Changes the number stored at the given key, i.e.
|
static void |
CommonErlangObjects.checkResult_failAbort(com.ericsson.otp.erlang.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(com.ericsson.otp.erlang.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.
|
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.processAddDelOnListAt(int pos) |
Processes the result at the given position which originated from
a add_del_on_list request.
|
abstract void |
ResultList.processAddOnNrAt(int pos) |
Processes the result at the given position which originated from
an add_on_nr 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.processCommitAt(int pos) |
Processes the result at the given position which originated from
a commit 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.processTestAndSetAt(int pos) |
Processes the result at the given position which originated from
a test_and_set request.
|
abstract void |
ResultList.processWriteAt(int pos) |
Processes the result at the given position which originated from
a write request.
|
void |
TransactionSingleOp.ResultList.processWriteAt(int pos) |
Processes the result at the given position which originated from
a write request.
|
abstract ResL |
AbstractTransaction.req_list(ReqL req) |
Executes all requests in
req. |
Transaction.ResultList |
Transaction.req_list(TransactionOperation op) |
Executes the given operation.
|
Transaction.ResultList |
Transaction.req_list(Transaction.RequestList req) |
Executes all requests in
req. |
void |
AbstractTransaction.testAndSet(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangObject oldValue,
com.ericsson.otp.erlang.OtpErlangObject newValue) |
Stores the given key/new_value pair if the old value at
key is old_value (atomic test_and_set).
|
<OldT,NewT> |
AbstractTransaction.testAndSet(java.lang.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 |
AbstractTransaction.write(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangObject value) |
Stores the given
key/value pair. |
<T> void |
AbstractTransaction.write(java.lang.String key,
T value) |
Stores the given
key/value pair. |
| Modifier and Type | Method | Description |
|---|---|---|
java.lang.Object |
CommitOp.processResult() |
|
java.lang.Object |
Operation.processResult() |
Processes the result set by
Operation.setResult(OtpErlangObject, boolean). |
static void |
CommitOp.processResult_commit(com.ericsson.otp.erlang.OtpErlangObject received_raw,
boolean compressed) |
Processes the received_raw term from erlang interpreting it as a
result from a commit operation.
|
java.lang.Object |
AddDelOnListOp.processResultSingle() |
|
java.lang.Object |
AddOnNrOp.processResultSingle() |
|
ErlangValue |
ReadOp.processResultSingle() |
|
java.lang.Object |
TestAndSetOp.processResultSingle() |
|
java.lang.Object |
TransactionSingleOpOperation.processResultSingle() |
Processes the result set by
Operation.setResult(OtpErlangObject, boolean)
assuming that operation was committed. |
java.lang.Object |
WriteOp.processResultSingle() |