Package | Description |
---|---|
org.apache.river.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
Modifier and Type | Field and Description |
---|---|
private Txn |
TxnMonitorTask.txn
transaction being monitored
|
private Txn |
TransactableReadIfExistsWatcher.txn
The transaction this query is
being performed under.
|
private Txn |
TransactableEventWatcher.txn
The transaction (represented as a
Txn ) this
event registration is associated with. |
private Txn |
TransactableAvailabilityWatcher.txn
The transaction (represented as a
Txn ) this
event registration is associated with. |
private Txn |
TakeMultipleWatcher.txn
If non-null the transaction this query is
being performed under.
|
private Txn |
TakeIfExistsWatcher.txn
If non-null the transaction this query is
being performed under.
|
private Txn |
OutriggerServerImpl.ContentsQuery.txn
The transaction the query is being performed under
|
(package private) Txn |
OutriggerServerImpl.AllReps.txn |
private Txn |
ConsumingWatcher.txn
If non-null the transaction this query is
being performed under.
|
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentMap<Long,Set<Txn>> |
TxnTable.brokenTxns
Map of transaction ids to the
List of broken
Txn objects that have the id. |
private Map<QueryWatcher,Collection<Txn>> |
TxnMonitorTask.queries
All the queries on the space (not queries to the transaction
manager) waiting for
txn to be resolved. |
private Map<Long,Txn> |
OutriggerServerImpl.recoveredTxns
The transactions recovered after restart.
|
private java.util.concurrent.ConcurrentMap<TxnTable.Key,Txn> |
TxnTable.txns
Map of manager,id pairs (represented as
Keys s) to non-broken
Txn s. |
(package private) Collection<Txn> |
TxnMonitor.ToMonitor.txns |
Modifier and Type | Method and Description |
---|---|
private Txn |
OutriggerServerImpl.enterTxn(Transaction baseTr)
This method takes a transactional semantic object
baseTr (the transaction object passed to us by the
client) and retrieves the associated Txn object
(the internal representation for that transaction) from the
space's records. |
(package private) Txn |
TxnTable.get(TransactionManager manager,
long id)
Given a
TransactionManager , manager , and a
transaction id, return the associated Txn , or
null if there is no Txn for this manager/id
pair. |
private Txn |
OutriggerServerImpl.getRecoveredTxn(Long txnId) |
private Txn |
OutriggerServerImpl.getTxn(TransactionManager mgr,
long id)
Look in the table for the
Txn object for the given
manager/id pair. |
(package private) Txn |
TxnTable.put(ServerTransaction tr)
Atomically test if there is a
Txn for the specified
ServerTransaction in the table, creating a new
Txn , and place in table if there is not. |
Txn |
Txn.restore(ObjectInputStream in) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
TxnMonitorTask.addSibling(Txn txn)
Add a ``sibling'' transaction, one that is now blocking progress
on one of the same entries.
|
private void |
OutriggerServerImpl.addWrittenRep(EntryHandle handle,
EntryHolder holder,
Txn txn)
Add the written rep to the relevant data structures.
|
int |
Txn.compareTo(Txn o) |
private EntryRep[] |
OutriggerServerImpl.completeTake(EntryHandle[] handles,
int found,
Txn txn) |
private EntryRep |
OutriggerServerImpl.completeTake(EntryHandle handle,
Txn txn) |
private EntryHolder.ContinuingQuery |
OutriggerServerImpl.createQuery(EntryRep[] tmpls,
String clazz,
Txn txn,
boolean takeIt,
long now)
Crerate a ContinuingQuery for the holder of the specified class.
|
private EntryHandle |
OutriggerServerImpl.find(EntryRep tmplRep,
Txn txn,
boolean takeIt,
Set conflictSet,
Set lockedEntrySet,
Set<EntryHandle> provisionallyRemovedEntrySet)
Find an entry that is at least
whichClass that
matches the template tmplRep (at least the
template's type, and matches in values provided). |
private void |
TxnTable.put(Txn txn)
Used to put a formerly broken
Txn in the main table. |
(package private) void |
TxnTable.recover(Txn txn)
Restore a
Txn in the table as part of log recovery. |
(package private) void |
EntryHolder.recoverTake(EntryHandle handle,
Txn txn)
Recover a logged take.
|
private TxnMonitorTask |
TxnMonitor.taskFor(Txn txn)
Return the monitor task for this transaction, creating it if
necessary.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
TxnMonitor.add(Collection<Txn> transactions)
Add a set of
transactions to be monitored under no
lease. |
(package private) void |
TxnMonitor.add(QueryWatcher query,
Collection<Txn> transactions)
Add a set of
transactions to be monitored under the
given query. |
(package private) void |
OutriggerServerImpl.monitor(Collection<Txn> toMonitor)
Make sure the transactions listed here are monitored for
a reasonable amount of time since they recently caused a conflict,
although for a non-leased event.
|
private void |
OutriggerServerImpl.monitor(QueryWatcher watcher,
Collection<Txn> toMonitor)
Make sure the transactions listed here are monitored for as
long as the given query exists.
|
Constructor and Description |
---|
AllReps(String classFor,
Txn txn)
Create a new
AllReps object for the given class. |
ConsumingWatcher(long expiration,
long timestamp,
long startOrdinal,
Set<EntryHandle> provisionallyRemovedEntrySet,
Txn txn,
boolean takeIt)
Create a new
ConsumingWatcher . |
ContentsQuery(Uuid uuid,
EntryRep[] tmpls,
Txn txn,
long limit) |
IteratorImpl(EntryRep tmpl,
Txn txn)
Create a
RemoteIterImpl object to return all
objects that match the given template. |
TakeIfExistsWatcher(long expiration,
long timestamp,
long startOrdinal,
Set<Uuid> lockedEntries,
Set<EntryHandle> provisionallyRemovedEntrySet,
Txn txn)
Create a new
TakeIfExistsWatcher . |
TakeMultipleWatcher(int limit,
long expiration,
long timestamp,
long startOrdinal,
Set<EntryHandle> provisionallyRemovedEntrySet,
Txn txn)
Create a new
TakeMultipleWatcher . |
TransactableAvailabilityWatcher(long timestamp,
long startOrdinal,
Uuid cookie,
boolean visibilityOnly,
MarshalledObject handback,
long eventID,
RemoteEventListener listener,
Txn txn)
Create a new
TransactableAvailabilityWatcher . |
TransactableEventWatcher(long timestamp,
long startOrdinal,
Uuid cookie,
MarshalledObject handback,
long eventID,
RemoteEventListener listener,
Txn txn)
Create a new
TransactableEventWatcher . |
TransactableReadIfExistsWatcher(long expiration,
long timestamp,
long startOrdinal,
Set<Uuid> lockedEntries,
Set<EntryHandle> provisionallyRemovedEntrySet,
Txn txn)
Create a new
TransactableReadIfExistsWatcher . |
TxnMonitorTask(Txn txn,
TxnMonitor monitor,
java.util.concurrent.ExecutorService manager,
WakeupManager wakeupMgr)
Create a new TxnMonitorTask.
|
Constructor and Description |
---|
ToMonitor(QueryWatcher query,
Collection<Txn> txns) |
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.