Package | Description |
---|---|
com.sun.jini.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
Modifier and Type | Field and Description |
---|---|
private OutriggerServerImpl |
OutriggerServerWrapper.delegate
The object being delegated to
|
private OutriggerServerImpl |
TransitionWatchers.server
The server we are working for
|
private OutriggerServerImpl |
TakeMultipleWatcher.server
The OutriggerServerImpl we are part of.
|
private OutriggerServerImpl |
ExpirationOpQueue.server
The server we are working for
|
private OutriggerServerImpl |
AvailabilityRegistrationWatcher.server
The OutriggerServerImpl we are part of.
|
private OutriggerServerImpl |
TxnMonitor.space
The space we belong to.
|
private OutriggerServerImpl |
EntryHolderSet.space |
private OutriggerServerImpl |
EntryHolder.space
The server we are working for
|
Modifier and Type | Method and Description |
---|---|
(package private) OutriggerServerImpl |
WatchersForTemplateClass.getServer()
Return the
OutriggerServerImpl this
handle is part of. |
(package private) OutriggerServerImpl |
TransitionWatchers.getServer()
Return the
OutriggerServerImpl this
TransitionWatchers object is part of. |
(package private) OutriggerServerImpl |
TemplateHandle.getServer()
Return the
OutriggerServerImpl this
handle is part of. |
(package private) OutriggerServerImpl |
SingletonQueryWatcher.getServer()
Method to give sub-classes access to OutriggerServerImpl
Assumes caller owns lock on
this and that
this watcher has not been removed. |
(package private) OutriggerServerImpl |
TxnMonitor.space()
Return the space we're part of.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
Txn.abort(OutriggerServerImpl space)
Abort the transaction.
|
void |
TransactableReadIfExistsWatcher.abort(TransactableMgr mgr,
OutriggerServerImpl space)
If a transaction ends in the middle of a query we want
to throw an exception to the client making the query
(not the
Txn calling us here.) |
void |
TransactableEventWatcher.abort(TransactableMgr mgr,
OutriggerServerImpl space)
Just need to terminate this registration.
|
void |
TransactableAvailabilityWatcher.abort(TransactableMgr mgr,
OutriggerServerImpl space)
Just need to terminate this registration.
|
void |
Transactable.abort(TransactableMgr mgr,
OutriggerServerImpl space)
Abort this object's part of the transaction.
|
void |
TakeMultipleWatcher.abort(TransactableMgr mgr,
OutriggerServerImpl space)
If a transaction ends in the middle of a query we want
to throw an exception to the client making the query
(not the
Txn calling us here.) |
void |
TakeIfExistsWatcher.abort(TransactableMgr mgr,
OutriggerServerImpl space)
If a transaction ends in the middle of a query we want
to throw an exception to the client making the query
(not the
Txn calling us here.) |
void |
EntryHandle.abort(TransactableMgr mgr,
OutriggerServerImpl space) |
void |
ConsumingWatcher.abort(TransactableMgr mgr,
OutriggerServerImpl space)
If a transaction ends in the middle of a query we want
to throw an exception to the client making the query
(not the
Txn calling us here.) |
(package private) boolean |
TxnState.abort(TransactableMgr mgr,
OutriggerServerImpl space,
EntryHandle owner)
Abort this object's part of the transaction.
|
(package private) void |
StorableAvailabilityWatcher.cleanup(OutriggerServerImpl server,
boolean expired)
Overridden by subclasses if there is any cleanup work they need
to do as part of
cancel or
removeIfExpired . |
(package private) void |
AvailabilityRegistrationWatcher.cleanup(OutriggerServerImpl server,
boolean expired)
Overridden by subclasses if there is any cleanup work they need
to do as part of
cancel or
removeIfExpired . |
(package private) void |
Txn.commit(OutriggerServerImpl space)
Having prepared, roll the changes
forward.
|
void |
TransactableReadIfExistsWatcher.commit(TransactableMgr mgr,
OutriggerServerImpl space)
This should never happen since we always return
NOTCHANGED from prepare . |
void |
TransactableEventWatcher.commit(TransactableMgr mgr,
OutriggerServerImpl space)
This should never happen since we always return
NOTCHANGED from prepare . |
void |
TransactableAvailabilityWatcher.commit(TransactableMgr mgr,
OutriggerServerImpl space)
This should never happen since we always return
NOTCHANGED from prepare . |
void |
Transactable.commit(TransactableMgr mgr,
OutriggerServerImpl space)
Commit this object's part of the transaction.
|
void |
TakeMultipleWatcher.commit(TransactableMgr mgr,
OutriggerServerImpl space)
This should never happen since we always return
NOTCHANGED from prepare . |
void |
TakeIfExistsWatcher.commit(TransactableMgr mgr,
OutriggerServerImpl space)
This should never happen since we always return
NOTCHANGED from prepare . |
void |
EntryHandle.commit(TransactableMgr mgr,
OutriggerServerImpl space) |
void |
ConsumingWatcher.commit(TransactableMgr mgr,
OutriggerServerImpl space)
This should never happen since we always return
NOTCHANGED from prepare . |
(package private) boolean |
TxnState.commit(TransactableMgr mgr,
OutriggerServerImpl space,
EntryHandle owner)
Commit this object's part of the transaction.
|
(package private) int |
Txn.prepare(OutriggerServerImpl space)
Prepare for transaction commit.
|
int |
TransactableReadIfExistsWatcher.prepare(TransactableMgr mgr,
OutriggerServerImpl space)
If a transaction ends in the middle of a query we want
to throw an exception to the client making the query
not the
Txn calling us here.) |
int |
TransactableEventWatcher.prepare(TransactableMgr mgr,
OutriggerServerImpl space)
Just need to terminate this registration and return
NOTCHANGED . |
int |
TransactableAvailabilityWatcher.prepare(TransactableMgr mgr,
OutriggerServerImpl space)
Just need to terminate this registration and return
NOTCHANGED . |
int |
Transactable.prepare(TransactableMgr mgr,
OutriggerServerImpl space)
Prepare to commit this object's part of the transaction.
|
int |
TakeMultipleWatcher.prepare(TransactableMgr mgr,
OutriggerServerImpl space)
If a transaction ends in the middle of a query we want
to throw an exception to the client making the query
(not to the
Txn calling us here.) |
int |
TakeIfExistsWatcher.prepare(TransactableMgr mgr,
OutriggerServerImpl space)
If a transaction ends in the middle of a query we want
to throw an exception to the client making the query
not the
Txn calling us here.) |
int |
EntryHandle.prepare(TransactableMgr mgr,
OutriggerServerImpl space)
Methods required by the Transactable interface
|
int |
ConsumingWatcher.prepare(TransactableMgr mgr,
OutriggerServerImpl space)
If a transaction ends in the middle of a query we want
to throw an exception to the client making the query
not the
Txn calling us here.) |
(package private) int |
TxnState.prepare(TransactableMgr mgr,
OutriggerServerImpl space,
EntryHandle owner)
Prepare to commit this object's part of the transaction.
|
Constructor and Description |
---|
EntryHolder(OutriggerServerImpl space,
Hashtable idMap)
Create a new
EntryHolder with the shared
idMap , and which will hold classes of the given
className . |
EntryHolderSet(OutriggerServerImpl space) |
ExpirationOpQueue(OutriggerServerImpl server)
Create a new
ExpirationOpQueue that
will handle lease expiration logging for the
specified server. |
TransitionWatchers(OutriggerServerImpl server)
Create a new
TransitionWatchers object
for the specified server. |
TxnMonitor(OutriggerServerImpl space,
Configuration config)
Create a new TxnMonitor.
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.