Package | Description |
---|---|
com.sun.jini.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 | Method and Description |
---|---|
(package private) void |
TxnMonitorTask.add(QueryWatcher query)
Add in a resource.
|
(package private) void |
TxnMonitor.add(QueryWatcher query,
Collection 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,
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 |
OutriggerServerImpl.monitor(QueryWatcher watcher,
Collection toMonitor)
Make sure the transactions listed here are monitored for as
long as the given query exists.
|
Constructor and Description |
---|
TxnMonitor.ToMonitor(QueryWatcher query,
Collection txns) |
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.