Package | Description |
---|---|
com.sun.jini.fiddler |
Provides the server side of an implementation of the lookup discovery service
(see
). |
com.sun.jini.mahalo |
Provides implementations of the
TransactionManager service.
|
com.sun.jini.mercury |
Provides implementations of the
EventMailbox service.
|
com.sun.jini.norm.event | |
com.sun.jini.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
com.sun.jini.reggie |
Provides implementations of
ServiceRegistrar . |
com.sun.jini.thread |
These are utility classes and interfaces for helping with tasks done in multiple threads.
|
net.jini.discovery |
These are utility classes and interfaces that conform to the discovery and join
protocol defined in the Jini Discovery and Join Specification.
|
net.jini.lease |
Standard service and utility classes for managing leases.
|
net.jini.lookup |
Standard utility classes for managing the join state of a service
and the service discovery duties of a client or service.
|
Modifier and Type | Class and Description |
---|---|
private class |
FiddlerImpl.AddGroupsTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.AddLocatorsTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.ChangedEventTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.DiscardedEventTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.DiscardRegistrarTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.DiscoveredEventTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.NewRegistrationTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.RemoveGroupsTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.RemoveLocatorsTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.SendEventTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.SetGroupsTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
private class |
FiddlerImpl.SetLocatorsTask
This class represents a
Task object that is placed
in the TaskManager queue for processing in the thread
pool. |
Modifier and Type | Class and Description |
---|---|
class |
ParticipantTask
A
ParticipantTask is a general task which
interacts with a participant. |
class |
SettlerTask
A
SettlerTask is scheduled task, which
causes an unsettled transaction to settle. |
Modifier and Type | Method and Description |
---|---|
(package private) TaskManager.Task[] |
PrepareJob.createTasks()
Creates the
TaskManager.Task s necessary to
inform participants to vote. |
(package private) TaskManager.Task[] |
PrepareAndCommitJob.createTasks()
Creates the
TaskManager.Task s necessary to
inform participants to vote and roll-forward/back. |
(package private) abstract TaskManager.Task[] |
Job.createTasks()
Create the tasks required to compute all of the
PartialResult objects necessary for the
solution to the original problem. |
(package private) TaskManager.Task[] |
CommitJob.createTasks()
Creates the
TaskManager.Task s necessary to
inform participants to roll-back. |
(package private) TaskManager.Task[] |
AbortJob.createTasks()
Creates the
TaskManager.Task s necessary to
inform participants to roll-back. |
Modifier and Type | Method and Description |
---|---|
(package private) int |
Job.attempt(TaskManager.Task who)
Given a
TaskManager.Task , this method
returns the current number of attempts it has made. |
(package private) Object |
PrepareJob.doWork(TaskManager.Task who,
Object param)
The work to be performed by each
TaskManager.Task
is provided by the Job that creates it. |
(package private) Object |
PrepareAndCommitJob.doWork(TaskManager.Task who,
Object param)
The work to be performed by each
TaskManager.Task
is provided by the Job that creates it. |
(package private) abstract Object |
Job.doWork(TaskManager.Task who,
Object param)
The work performed is implemented here.
|
(package private) Object |
CommitJob.doWork(TaskManager.Task who,
Object param)
The work to be performed by each
TaskManager.Task
is provided by the Job that creates it. |
(package private) Object |
AbortJob.doWork(TaskManager.Task who,
Object param)
The work to be performed by each
TaskManager.Task
is provided by the Job that creates it. |
(package private) boolean |
Job.performWork(TaskManager.Task who,
Object param)
Used by a task to do a piece of work and record the
number of attempts.
|
private void |
Job.reportDone(TaskManager.Task who,
Object param) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
MailboxImpl.NotifyTask
A task that represents an event notification task for a particular
registration.
|
Modifier and Type | Class and Description |
---|---|
private class |
EventType.SendTask
Subclass of
RetryTask used by EventType
to send events. |
Modifier and Type | Class and Description |
---|---|
private class |
Notifier.NotifyTask
A task that represent a notification of matching a particular
template under a given transaction.
|
(package private) class |
TxnMonitorTask
A task that will try to validate the state of a transaction.
|
Modifier and Type | Class and Description |
---|---|
private class |
RegistrarImpl.AddressTask
Address for unicast discovery response.
|
private class |
RegistrarImpl.DecodeRequestTask
Task for decoding multicast request packets.
|
private class |
RegistrarImpl.EventTask
An event to be sent, and the listener to send it to.
|
private class |
RegistrarImpl.SocketTask
Socket for unicast discovery response.
|
Modifier and Type | Class and Description |
---|---|
class |
RetryTask |
Modifier and Type | Field and Description |
---|---|
TaskManager.Task |
TaskManager.TaskThread.task
The task being run, if any
|
Modifier and Type | Method and Description |
---|---|
void |
TaskManager.add(TaskManager.Task t)
Add a new task.
|
void |
TaskManager.addIfNew(TaskManager.Task t)
Add a new task if it is not equal to (using the equals method)
to any existing active or pending task.
|
boolean |
TaskManager.remove(TaskManager.Task t) |
boolean |
TaskManager.removeIfPending(TaskManager.Task t)
Remove a task if it is pending (not active).
|
private boolean |
TaskManager.removeTask(TaskManager.Task t,
int min)
Remove a task if it has index >= min.
|
private boolean |
TaskManager.runAfter(TaskManager.Task t,
int i)
Returns t.runAfter(i), or false if an exception is thrown.
|
Modifier and Type | Class and Description |
---|---|
private class |
LookupDiscovery.DecodeAnnouncementTask
Task which decodes received multicast announcement packets.
|
private class |
LookupDiscovery.UnicastDiscoveryTask
Task which retrieves elements from the set of pendingDiscoveries and
performs the appropriate processing based on the object type of
the element.
|
private class |
LookupLocatorDiscovery.DiscoveryTask
Task which retrieves elements from the set of undiscoveredLocators
and attempts, through the unicast discovery protocol, to discover
the lookup service having the LookupLocator referenced by the element.
|
Modifier and Type | Method and Description |
---|---|
private void |
LookupDiscovery.restoreContextAddTask(TaskManager.Task t) |
Modifier and Type | Class and Description |
---|---|
private class |
LeaseRenewalManager.QueuerTask |
private class |
LeaseRenewalManager.RenewTask |
Modifier and Type | Class and Description |
---|---|
private class |
JoinManager.ProxyRegTask
Abstract base class from which all of the task classes are derived.
|
private static class |
ServiceDiscoveryManager.CacheTask
Class for implementing register/lookup/notify/dropProxy/discard tasks
|
private class |
ServiceDiscoveryManager.LookupCacheImpl.DiscardServiceTask
Task class used to asynchronously notify service discard.
|
private class |
ServiceDiscoveryManager.LookupCacheImpl.LookupTask
This class requests a "snapshot" of the given registrar's state.
|
private class |
ServiceDiscoveryManager.LookupCacheImpl.NewOldServiceTask
Task class used to asynchronously process the service state
("snapshot"), matching this cache's template, that was retrieved
from the given lookup service.
|
private class |
ServiceDiscoveryManager.LookupCacheImpl.NotifyEventTask
Task class used to asynchronously notify all registered service
discovery listeners of serviceAdded/serviceRemoved/serviceChanged
events.
|
private class |
ServiceDiscoveryManager.LookupCacheImpl.ProxyRegDropTask
When the given registrar is discarded, this Task class is used to
remove the registrar from the various maps maintained by this
cache.
|
private class |
ServiceDiscoveryManager.LookupCacheImpl.RegisterListenerTask
This task class, when executed, first registers to receive
ServiceEvents from the given ServiceRegistrar.
|
private class |
ServiceDiscoveryManager.LookupCacheImpl.ServiceDiscardTimerTask
Task class used to determine whether or not to "commit" a service
discard request, increasing the chances that the service will
eventually be re-discovered.
|
private class |
ServiceDiscoveryManager.LookupCacheImpl.UnmapProxyTask
Task class used to asynchronously disassociate the given lookup
service proxy from the given ServiceItemReg.
|
private static class |
ServiceDiscoveryManager.ServiceIdTask
Abstract base class for controlling the order-of-execution of tasks
corresponding to a particular serviceID associated with a particular
lookup service.
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.