Package | Description |
---|---|
com.sun.jini.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
Modifier and Type | Field and Description |
---|---|
private EntryHandle |
SingletonQueryWatcher.handle
If resolved and an entry was found the entry to return
|
private EntryHandle |
EntryTransition.handle
The
EntryHandle of the entry that changed |
Modifier and Type | Field and Description |
---|---|
private FastList<EntryHandle> |
EntryHolder.contents
The list that holds the handles
|
private Iterator<EntryHandle> |
EntryHolder.SimpleRepEnum.contentsIterator |
private Iterator<EntryHandle> |
EntryHolder.ContinuingQuery.contentsIterator
Current position in parent
EntryHolder 's
contents |
Modifier and Type | Method and Description |
---|---|
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 EntryHandle |
EntryHolder.getContentsHead()
Get the head of the contents list
|
(package private) EntryHandle |
EntryTransition.getHandle()
Return the
EntryHandle for entry undergoing the
visibility transition. |
private EntryHandle |
EntryHolder.handleFor(EntryRep rep)
Return the handle for the given
EntryRep object. |
(package private) EntryHandle |
EntryHolderSet.handleFor(Object cookie)
Given an entry ID, return the handle associated
with it.
|
(package private) EntryHandle |
EntryHolder.hasMatch(EntryRep tmpl,
TransactableMgr txn,
boolean takeIt,
Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet)
Return an
EntryHandle object that matches the given
template, or null if none does. |
(package private) EntryHandle |
EntryHolder.ContinuingQuery.next(Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet)
Return the next matching entry.
|
(package private) EntryHandle[] |
TakeMultipleWatcher.resolvedWithEntries()
If the query has been resolved by finding an matching entry,
returns the
EntryHandle for that entry. |
(package private) EntryHandle |
SingletonQueryWatcher.resolvedWithEntry()
If the query has been resolved by finding an matching entry,
returns the
EntryHandle for that entry. |
Modifier and Type | Method and Description |
---|---|
(package private) boolean |
TxnState.abort(TransactableMgr mgr,
OutriggerServerImpl space,
EntryHandle owner)
Abort this object's part of the transaction.
|
(package private) void |
EntryHolder.add(EntryHandle handle,
TransactableMgr txn)
Add new new entry to the holder.
|
private void |
OutriggerServerImpl.addWrittenRep(EntryHandle handle,
EntryHolder holder,
Txn txn)
Add the written rep to the relevant data structures.
|
(package private) boolean |
EntryHolder.attemptCapture(EntryHandle handle,
TransactableMgr txn,
boolean takeIt,
Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet,
long now)
Atomically check to see if the passed entry can be read/taken by
the specified operation using the specified transaction and if
it can read/take it and return
true , otherwise
return false . |
(package private) boolean |
OutriggerServerImpl.attemptCapture(EntryHandle handle,
TransactableMgr txn,
boolean takeIt,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet,
long now,
QueryWatcher watcher)
Atomically check to see if the passed entry can be read/taken by
the specified operation using the specified transaction and if
it can read/take it and return
true , otherwise
return false . |
private void |
TakeMultipleWatcher.captured(EntryHandle handle)
Mark this query as resolved.
|
(package private) boolean |
TxnState.commit(TransactableMgr mgr,
OutriggerServerImpl space,
EntryHandle owner)
Commit this object's part of the transaction.
|
private EntryRep[] |
OutriggerServerImpl.completeTake(EntryHandle[] handles,
int found,
Txn txn) |
private EntryRep |
OutriggerServerImpl.completeTake(EntryHandle handle,
Txn txn) |
private boolean |
EntryHolder.confirmAvailability(EntryRep rep,
EntryHandle handle,
TransactableMgr txn,
boolean takeIt,
long time,
Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet)
With the EntryRep
rep passed in, verify that the
entry hasn't been taken by someone else, hasn't expired, etc. |
private boolean |
EntryHolder.confirmAvailabilityWithTxn(EntryRep rep,
EntryHandle handle,
TransactableMgr txnMgr,
boolean takeIt,
long time,
Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet) |
private boolean |
EntryHolder.grab(EntryHandle handle,
TransactableMgr txn,
int op,
boolean takeIt,
boolean recovery)
Given an entry that we want to return as the result of a query
and we have confirmed we can return it, make the results of the
query visible to the rest of the service.
|
private boolean |
EntryHolder.ContinuingQuery.handleMatch(EntryHandle handle)
Returns
true if handle has not been removed
and matches one or more of the templates |
private boolean |
EntryHolder.isExpired(long now,
EntryHandle handle)
Return
true if the entry held by the given
handle has expired by the time in now . |
(package private) int |
TxnState.prepare(TransactableMgr mgr,
OutriggerServerImpl space,
EntryHandle owner)
Prepare to commit this object's part of the transaction.
|
(package private) void |
EntryHolder.recoverTake(EntryHandle handle,
Txn txn)
Recover a logged take.
|
(package private) void |
EntryHolderSet.remove(EntryHandle handle)
Remove the passed handle and associated entry.
|
(package private) boolean |
EntryHolder.remove(EntryHandle h,
boolean recovery)
Remove the given handle from this holder and the
idMap . |
(package private) void |
SingletonQueryWatcher.resolve(EntryHandle handle,
Throwable throwable)
Mark this query as resolved.
|
Constructor and Description |
---|
EntryTransition(EntryHandle handle,
TransactableMgr txn,
boolean available,
boolean visible,
boolean newEntry)
Create a new
EntryTransition object
with the specified content. |
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.