Package | Description |
---|---|
com.sun.jini.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.
|
private static Txn[] |
TxnTable.txnArray
An array of type
Txn to pass to toArray |
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. |
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.
|
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,
WeakHashMap 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 formally 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.
|
Constructor and Description |
---|
ConsumingWatcher(long expiration,
long timestamp,
long startOrdinal,
WeakHashMap provisionallyRemovedEntrySet,
Txn txn,
boolean takeIt)
Create a new
ConsumingWatcher . |
OutriggerServerImpl.AllReps(String classFor,
Txn txn)
Create a new
AllReps object for the given class. |
OutriggerServerImpl.ContentsQuery(Uuid uuid,
EntryRep[] tmpls,
Txn txn,
long limit) |
OutriggerServerImpl.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 lockedEntries,
WeakHashMap provisionallyRemovedEntrySet,
Txn txn)
Create a new
TakeIfExistsWatcher . |
TakeMultipleWatcher(int limit,
long expiration,
long timestamp,
long startOrdinal,
WeakHashMap 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 lockedEntries,
WeakHashMap provisionallyRemovedEntrySet,
Txn txn)
Create a new
TransactableReadIfExistsWatcher . |
TxnMonitorTask(Txn txn,
TxnMonitor monitor,
TaskManager manager,
WakeupManager wakeupMgr)
Create a new TxnMonitorTask.
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.