Package | Description |
---|---|
org.apache.river.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
ConsumingWatcher
Subclass of QueryWatcher for takes and transactional reads.
|
(package private) class |
ReadIfExistsWatcher
Subclass of
QueryWatcher for non-transactional if
exists reads. |
(package private) class |
ReadWatcher
Subclass of
QueryWatcher for non-transactional reads. |
(package private) class |
SingletonQueryWatcher
Subclass of
QueryWatcher for singleton queries. |
(package private) class |
TakeIfExistsWatcher
Subclass of
QueryWatcher for takeIfExists
queries. |
(package private) class |
TakeMultipleWatcher
Subclass of
QueryWatcher for blocking take multiple
queries. |
(package private) class |
TransactableReadIfExistsWatcher
Subclass of
QueryWatcher for and transactional
readIfExists queries. |
Modifier and Type | Field and Description |
---|---|
(package private) QueryWatcher |
TxnMonitor.ToMonitor.query |
Modifier and Type | Field and Description |
---|---|
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. |
Modifier and Type | Method and Description |
---|---|
(package private) void |
TxnMonitorTask.add(QueryWatcher query)
Add in a resource.
|
(package private) void |
TxnMonitor.add(QueryWatcher query,
Collection<Txn> transactions)
Add a set of
transactions to be monitored under the
given query. |
(package private) boolean |
OutriggerServerImpl.attemptCapture(EntryHandle handle,
TransactableMgr txn,
boolean takeIt,
Set lockedEntrySet,
Set<EntryHandle> 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 |
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 |
---|
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.