Package | Description |
---|---|
net.jini.core.discovery |
A standard utility class for finding particular lookup services.
|
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.lookup |
Standard utility classes for managing the join state of a service
and the service discovery duties of a client or service.
|
org.apache.river.discovery |
Provides a set of constraints, low-level utility classes, and provider
interfaces for participating in versions 1 and 2 of the multicast request,
multicast announcement, and unicast discovery protocols.
|
org.apache.river.example.browser |
A visualization tool for exploring Jini Network Technology
communities (djinns) with support for ServiceUI.
|
org.apache.river.fiddler |
Provides the server side of an implementation of the lookup discovery service
(see
). |
org.apache.river.reggie |
Provides implementations of
ServiceRegistrar . |
Modifier and Type | Method and Description |
---|---|
ServiceRegistrar |
LookupLocator.getRegistrar()
Perform unicast discovery and return the ServiceRegistrar
object for the given lookup service.
|
ServiceRegistrar |
LookupLocator.getRegistrar(int timeout)
Perform unicast discovery and return the ServiceRegistrar
object for the given lookup service, with the given discovery timeout.
|
protected ServiceRegistrar |
LookupLocator.getRegistrar(InvocationConstraints constraints)
Perform unicast discovery and return the ServiceRegistrar
object for the given lookup service, with the given constraints.
|
Modifier and Type | Field and Description |
---|---|
private ServiceRegistrar |
AbstractLookupLocatorDiscovery.LocatorReg.proxy |
ServiceRegistrar |
AbstractLookupDiscoveryManager.ProxyReg.proxy
The discovered registrar to be managed
|
protected ServiceRegistrar |
IncomingUnicastResponse.registrar
The registrar we have discovered.
|
private ServiceRegistrar[] |
LookupUnmarshalException.registrars
Array containing the set of instances of
ServiceRegistrar
that were successfully unmarshalled during the process in which at
least one failure occurred. |
protected ServiceRegistrar[] |
RemoteDiscoveryEvent.regs
Array containing a subset of the set of proxies to the lookup
service(s) with which this event is associated.
|
private ServiceRegistrar[] |
DiscoveryEvent.regs
The registrars with which this event is associated.
|
Modifier and Type | Field and Description |
---|---|
private Map<ServiceRegistrar,String[]> |
DiscoveryEvent.groups
Map from the registrars of this event to the groups in which each
is a member.
|
Map<ServiceRegistrar,String[]> |
AbstractLookupLocatorDiscovery.NotifyTask.groupsMap
Map of discovered registrars to groups in which each is a member
|
Map<ServiceRegistrar,String[]> |
AbstractLookupDiscovery.NotifyTask.groupsMap
Map of discovered registrars-to-groups in which each is a member
|
Modifier and Type | Method and Description |
---|---|
private ServiceRegistrar[] |
AbstractLookupLocatorDiscovery.buildServiceRegistrar()
From each element of the set of LocatorReg objects that correspond
to lookup services that have been discovered, this method extracts
the ServiceRegistrar reference and returns all of the references
in an array of ServiceRegistrar.
|
private static ServiceRegistrar[] |
RemoteDiscoveryEvent.clipNullsFromEnd(ServiceRegistrar[] regsArray)
Convenience method that copies elements from the given array into
a new array, and returns the new array.
|
private ServiceRegistrar |
AbstractLookupLocatorDiscovery.LocatorReg.getProxy() |
ServiceRegistrar |
IncomingUnicastResponse.getRegistrar()
Return the lookup service registrar we have discovered.
|
ServiceRegistrar |
ConstrainableLookupLocator.getRegistrar()
Performs unicast discovery as specified by
LookupLocator.getRegistrar() with the following differences. |
ServiceRegistrar |
ConstrainableLookupLocator.getRegistrar(int timeout)
Performs unicast discovery as specified by
LookupLocator.getRegistrar(int) , additionally applying the
supplied discovery constraints. |
ServiceRegistrar[] |
RemoteDiscoveryEvent.getRegistrars()
Returns an array consisting of instances of the ServiceRegistrar
interface.
|
ServiceRegistrar[] |
LookupUnmarshalException.getRegistrars()
Accessor method that returns an array consisting of instances of
ServiceRegistrar , where each element of the array
corresponds to a successfully unmarshalled object. |
ServiceRegistrar[] |
LookupDiscoveryRegistration.getRegistrars()
Returns an array consisting of instances of the ServiceRegistrar
interface.
|
ServiceRegistrar[] |
DiscoveryManagement.getRegistrars()
Returns an array of instances of
ServiceRegistrar , each
corresponding to a proxy to one of the currently discovered lookup
services. |
ServiceRegistrar[] |
DiscoveryEvent.getRegistrars()
Return the set of registrars to which this event applies.
|
ServiceRegistrar[] |
AbstractLookupLocatorDiscovery.getRegistrars()
Returns an array of instances of
ServiceRegistrar , each
corresponding to a proxy to one of the currently discovered lookup
services. |
ServiceRegistrar[] |
AbstractLookupDiscoveryManager.getRegistrars()
Returns an array of instances of
ServiceRegistrar , each
corresponding to a proxy to one of the currently discovered lookup
services. |
ServiceRegistrar[] |
AbstractLookupDiscovery.getRegistrars()
Returns an array of instances of
ServiceRegistrar , each
corresponding to a proxy to one of the currently discovered lookup
services. |
Modifier and Type | Method and Description |
---|---|
private Map<ServiceRegistrar,String[]> |
AbstractLookupLocatorDiscovery.deepCopy(Map<ServiceRegistrar,String[]> groupsMap)
Creates and returns a deep copy of the input parameter.
|
private Map<ServiceRegistrar,String[]> |
AbstractLookupDiscoveryManager.deepCopy(Map<ServiceRegistrar,String[]> groupsMap)
Creates and returns a deep copy of the input parameter.
|
private Map<ServiceRegistrar,String[]> |
AbstractLookupDiscovery.deepCopy(Map<ServiceRegistrar,String[]> groupsMap)
Creates and returns a deep copy of the input parameter.
|
Map<ServiceRegistrar,String[]> |
DiscoveryEvent.getGroups()
Returns a set that maps to each registrar referenced by this event,
the current set of groups in which each registrar is a member.
|
private Map<ServiceRegistrar,String[]> |
AbstractLookupDiscovery.mapRegToGroups(ServiceRegistrar reg,
String[] curGroups)
Convenience method that creates and returns a mapping of a single
ServiceRegistrar instance to a set of groups. |
Modifier and Type | Method and Description |
---|---|
private static ServiceRegistrar[] |
RemoteDiscoveryEvent.clipNullsFromEnd(ServiceRegistrar[] regsArray)
Convenience method that copies elements from the given array into
a new array, and returns the new array.
|
void |
LookupDiscoveryRegistration.discard(ServiceRegistrar registrar)
Informs the lookup discovery service of the existence of an
unavailable lookup service and requests that the lookup discovery
service discard the unavailable lookup service.
|
void |
DiscoveryManagement.discard(ServiceRegistrar proxy)
Removes an instance of
ServiceRegistrar from the
managed set of lookup services, making the corresponding lookup
service eligible for re-discovery. |
void |
AbstractLookupLocatorDiscovery.discard(ServiceRegistrar proxy)
Removes an instance of
ServiceRegistrar from the
managed set of lookup services, making the corresponding lookup
service eligible for re-discovery. |
void |
AbstractLookupDiscoveryManager.discard(ServiceRegistrar proxy)
Removes an instance of
ServiceRegistrar from the
managed set of lookup services, making the corresponding lookup
service eligible for re-discovery. |
void |
AbstractLookupDiscovery.discard(ServiceRegistrar reg)
Discard a registrar from the set of registrars already
discovered.
|
private AbstractLookupDiscoveryManager.ProxyReg |
AbstractLookupDiscoveryManager.findReg(ServiceRegistrar proxy) |
private LookupLocator |
AbstractLookupLocatorDiscovery.findRegFromProxy(ServiceRegistrar proxy)
This method searches the set of discovered LocatorReg objects
for the element that contains the given ServiceRegistrar object.
|
private String[] |
AbstractLookupDiscovery.getActualGroups(ServiceRegistrar reg)
This method retrieves from the given
ServiceRegistrar ,
the current groups in which that registrar is a member. |
int |
AbstractLookupDiscoveryManager.getFrom(ServiceRegistrar proxy)
Return where the proxy came from.
|
private void |
LookupUnmarshalException.init(ServiceRegistrar[] registrars,
MarshalledObject[] marshalledRegistrars,
Throwable[] exceptions)
Initializes the abstract state of this class.
|
private static void |
RemoteDiscoveryEvent.insertRegistrars(ServiceRegistrar[] regsArray,
List regsList)
Places the lookup service reference(s), contained in the input
ArrayList, into the 'empty' slots occurring at the end (indicated
by the first null element) of the input array.
|
private Map |
AbstractLookupLocatorDiscovery.mapRegToGroups(ServiceRegistrar reg,
String[] curGroups)
Convenience method that creates and returns a mapping of a single
ServiceRegistrar instance to a set of groups. |
private Map<ServiceRegistrar,String[]> |
AbstractLookupDiscovery.mapRegToGroups(ServiceRegistrar reg,
String[] curGroups)
Convenience method that creates and returns a mapping of a single
ServiceRegistrar instance to a set of groups. |
static void |
OutgoingUnicastResponse.marshal(OutputStream str,
ServiceRegistrar reg,
String[] groups)
Marshal a unicast response to the given output stream.
|
private void |
AbstractLookupDiscovery.notifyOnGroupChange(ServiceRegistrar reg,
String[] oldGroups,
String[] newGroups)
After a possible change in the member groups of the given
ServiceRegistrar parameter, this method compares
the registrar's original set of member groups to its new set
of member groups. |
private void |
AbstractLookupDiscovery.sendChanged(ServiceRegistrar reg,
String[] curGroups)
Convenience method that sends a changed event containing only
one registrar to all registered listeners that are interested in
such events.
|
private void |
AbstractLookupDiscovery.sendDiscarded(ServiceRegistrar reg,
String[] curGroups)
Convenience method that sends a discarded event containing only
one registrar to all registered listeners.
|
Modifier and Type | Method and Description |
---|---|
private void |
AbstractLookupLocatorDiscovery.addNotify(List<DiscoveryListener> notifies,
Map<ServiceRegistrar,String[]> groupsMap,
boolean discard)
Add a notification task to the pending queue, and start an instance of
the Notifier thread if one isn't already running.
|
private void |
AbstractLookupDiscovery.addNotify(List<DiscoveryListener> notifies,
Map<ServiceRegistrar,String[]> groupsMap,
int eventType)
Add a notification task to the pending queue, and wake up the Notifier.
|
private Map<ServiceRegistrar,String[]> |
AbstractLookupLocatorDiscovery.deepCopy(Map<ServiceRegistrar,String[]> groupsMap)
Creates and returns a deep copy of the input parameter.
|
private Map<ServiceRegistrar,String[]> |
AbstractLookupDiscoveryManager.deepCopy(Map<ServiceRegistrar,String[]> groupsMap)
Creates and returns a deep copy of the input parameter.
|
private Map<ServiceRegistrar,String[]> |
AbstractLookupDiscovery.deepCopy(Map<ServiceRegistrar,String[]> groupsMap)
Creates and returns a deep copy of the input parameter.
|
private void |
AbstractLookupDiscoveryManager.notifyListener(DiscoveryListener l,
Map<ServiceRegistrar,String[]> groupsMap,
int eventType)
Notify a specific listener for a discovery event.
|
private void |
AbstractLookupDiscoveryManager.notifyListener(Map<ServiceRegistrar,String[]> groupsMap,
int eventType)
Notify all listeners for a discovery event.
|
Constructor and Description |
---|
DiscoveryEvent(Object source,
ServiceRegistrar[] regs)
Construct a new
DiscoveryEvent object, with the given
source and set of registrars. |
LookupUnmarshalException(ServiceRegistrar[] registrars,
MarshalledObject[] marshalledRegistrars,
Throwable[] exceptions)
Constructs a new instance of
LookupUnmarshalException . |
LookupUnmarshalException(ServiceRegistrar[] registrars,
MarshalledObject[] marshalledRegistrars,
Throwable[] exceptions,
String message)
Constructs a new instance of
LookupUnmarshalException . |
ProxyReg(ServiceRegistrar proxy,
String[] memberGroups,
int from)
Constructs an instance of this wrapper class.
|
Constructor and Description |
---|
DiscoveryEvent(Object source,
Map<ServiceRegistrar,String[]> groups)
Construct a new
DiscoveryEvent object, with the given
source and registrars-to-groups mapping. |
NotifyTask(List<DiscoveryListener> listeners,
Map<ServiceRegistrar,String[]> groupsMap,
boolean discard) |
NotifyTask(List<DiscoveryListener> listeners,
Map<ServiceRegistrar,String[]> groupsMap,
int eventType) |
RemoteDiscoveryEvent(Object source,
long eventID,
long seqNum,
MarshalledObject handback,
boolean discarded,
Map<ServiceRegistrar,String> groups)
Constructs a new instance of
RemoteDiscoveryEvent . |
Modifier and Type | Field and Description |
---|---|
private ServiceRegistrar |
ServiceDiscoveryManager.ServiceItemReg.proxy |
private ServiceRegistrar |
ServiceDiscoveryManager.ProxyReg.proxy |
private ServiceRegistrar |
ServiceDiscoveryManager.LeaseListenerImpl.proxy |
(package private) ServiceRegistrar |
JoinManager.ProxyReg.proxy
The prepared proxy to the lookup service referenced by
this class, and with which this join manager's service will be
registered.
|
Modifier and Type | Field and Description |
---|---|
private Map<ServiceRegistrar,ServiceItem> |
ServiceDiscoveryManager.ServiceItemReg.items |
Modifier and Type | Method and Description |
---|---|
private ServiceRegistrar[] |
ServiceDiscoveryManager.buildServiceRegistrar()
Returns array of ServiceRegistrar created from the proxyRegSet
|
ServiceRegistrar[] |
JoinManager.getJoinSet()
Returns an array of
ServiceRegistrar objects, each
corresponding to a lookup service with which the service is currently
registered (joined). |
ServiceRegistrar |
ServiceDiscoveryManager.ServiceItemReg.getProxy() |
ServiceRegistrar |
ServiceDiscoveryManager.ProxyReg.getProxy() |
Modifier and Type | Method and Description |
---|---|
private void |
ServiceDiscoveryManager.discard(ServiceRegistrar proxy)
Discards a ServiceRegistrar through the discovery manager.
|
private void |
ServiceDiscoveryManager.DiscMgrListener.discard(ServiceRegistrar proxy)
Discards a ServiceRegistrar through the discovery manager.
|
private void |
ServiceDiscoveryManager.fail(Throwable e,
ServiceRegistrar proxy,
String sourceClass,
String sourceMethod,
String msg,
boolean cacheTerminated)
Convenience method invoked when failure occurs in the cache tasks
executed in this utility.
|
private JoinManager.ProxyReg |
JoinManager.findReg(ServiceRegistrar proxy)
For the given lookup service proxy, searches the
joinSet
for the corresponding ProxyReg element, and upon finding
such an element, returns that element; otherwise returns
null . |
private void |
ServiceDiscoveryManager.LookupCacheImpl.handleMatchNoMatch(ServiceRegistrar proxy,
ServiceID srvcID)
Convenience method called (only
when a TRANSITION_MATCH_NOMATCH event is received) that removes the
given
item from the serviceIdMap and wakes
up the ServiceDiscardTimerTask if the given
item is discarded; otherwise, sends a removed event. |
private void |
ServiceDiscoveryManager.LookupCacheImpl.itemMatchMatchChange(ServiceID srvcID,
ServiceDiscoveryManager.ServiceItemReg itemReg,
ServiceRegistrar proxy,
ServiceItem newItem,
boolean matchMatchEvent)
With respect to a given service (referenced by the parameter
newItem), if either an event has been received from the given lookup
service (referenced by the proxy parameter), or a snapshot of the
given lookup service's state has been retrieved, this method
determines whether the service's attributes have changed, or whether
a new version of the service has been registered.
|
boolean |
ServiceDiscoveryManager.ServiceItemReg.proxyNotUsedToTrackChange(ServiceRegistrar proxy,
ServiceItem item) |
private ServiceDiscoveryManager.EventReg |
ServiceDiscoveryManager.registerListener(ServiceRegistrar proxy,
ServiceTemplate tmpl,
RemoteEventListener listenerProxy,
long duration)
Registers for events from the lookup service associated with the given
proxy, and returns both the lease and the event sequence number from the
event registration wrapped in the locally-defined class,
EventReg . |
ServiceItem |
ServiceDiscoveryManager.ServiceItemReg.removeProxy(ServiceRegistrar proxy) |
private ServiceDiscoveryManager.ProxyReg |
ServiceDiscoveryManager.removeReg(ServiceRegistrar proxy)
Removes and returns element from proxyRegSet that corresponds to the
given proxy.
|
void |
ServiceDiscoveryManager.ServiceItemReg.replaceProxyUsedToTrackChange(ServiceRegistrar proxy,
ServiceItem item)
Replaces the proxy used to track change if the proxy passed in is non null,
also replaces the ServiceItem.
|
Constructor and Description |
---|
LeaseListenerImpl(ServiceRegistrar proxy) |
ProxyReg(ServiceRegistrar proxy) |
ProxyReg(ServiceRegistrar proxy)
Constructor that associates this class with the lookup service
referenced in the given
ProxyReg parameter. |
ServiceItemReg(ServiceRegistrar proxy,
ServiceItem item) |
Modifier and Type | Field and Description |
---|---|
private ServiceRegistrar |
UnicastResponse.registrar
The lookup service proxy.
|
Modifier and Type | Method and Description |
---|---|
ServiceRegistrar |
UnicastResponse.getRegistrar()
Returns the lookup service proxy.
|
Constructor and Description |
---|
UnicastResponse(String host,
int port,
String[] groups,
ServiceRegistrar registrar)
Creates new
UnicastResponse instance containing the given
values. |
Modifier and Type | Field and Description |
---|---|
private ServiceRegistrar |
Browser.lookup |
private ServiceRegistrar |
ServiceEditor.registrar |
private ServiceRegistrar |
ServiceBrowser.AttributePanel.registrar |
private ServiceRegistrar |
Browser.Lookup.registrar |
Modifier and Type | Method and Description |
---|---|
private void |
Browser.addOne(ServiceRegistrar registrar) |
Constructor and Description |
---|
AttributePanel(ServiceItem item,
ServiceRegistrar registrar) |
Lookup(ServiceRegistrar registrar) |
ServiceBrowser(ServiceItem item,
ServiceRegistrar registrar,
Browser browser) |
ServiceEditor(ServiceItem item,
Object admin,
ServiceRegistrar registrar,
Browser browser) |
Modifier and Type | Field and Description |
---|---|
ServiceRegistrar |
FiddlerImpl.DiscardRegistrarTask.registrar
The registrar to discard
|
Modifier and Type | Method and Description |
---|---|
ServiceRegistrar[] |
FiddlerRegistration.getRegistrars()
Returns an array consisting of instances of the ServiceRegistrar
interface.
|
private ServiceRegistrar[] |
FiddlerImpl.intersectRegSets(ServiceRegistrar[] regs0,
ServiceRegistrar[] regs1)
Returns the set of registrars common to both input parameters
|
Modifier and Type | Method and Description |
---|---|
void |
FiddlerRegistration.discard(ServiceRegistrar registrar)
Informs the lookup discovery service of the existence of an
unavailable lookup service and requests that the lookup discovery
service discard the unavailable lookup service.
|
void |
FiddlerImpl.discard(Uuid registrationID,
ServiceRegistrar registrar)
This method is the "backend" server counterpart to the method of
the same name provided by the
LookupDiscoveryRegistration
proxy (an instance of FiddlerRegistration ) that is
returned by this service when a client requests a registration. |
void |
Fiddler.discard(Uuid registrationID,
ServiceRegistrar registrar)
Informs the lookup discovery service of the existence of an
unavailable lookup service and requests that the lookup discovery
service discard the unavailable lookup service.
|
private static void |
FiddlerRegistration.insertRegistrars(ServiceRegistrar[] regsArray,
ArrayList regsList)
Places the the lookup service reference(s), contained in the input
ArrayList, into the 'empty' slots occurring at the end (indicated
by the first null element) of the input array.
|
private ServiceRegistrar[] |
FiddlerImpl.intersectRegSets(ServiceRegistrar[] regs0,
ServiceRegistrar[] regs1)
Returns the set of registrars common to both input parameters
|
private ServiceRegistrar[] |
FiddlerImpl.intersectRegSets(ServiceRegistrar[] regs0,
ServiceRegistrar[] regs1)
Returns the set of registrars common to both input parameters
|
private HashMap |
FiddlerImpl.mapRegToGroups(ServiceRegistrar reg,
String[] groups)
Convenience method that creates and returns a mapping of a single
ServiceRegistrar instance to a set of groups. |
private boolean |
FiddlerImpl.regIsElementOfRegSet(ServiceRegistrar reg,
ServiceRegistrar[] regSet)
Returns true if the input registrar is an element of the given array
|
private boolean |
FiddlerImpl.regIsElementOfRegSet(ServiceRegistrar reg,
ServiceRegistrar[] regSet)
Returns true if the input registrar is an element of the given array
|
private static void |
FiddlerImpl.writeRegistrarsArray(ServiceRegistrar[] regs,
Logger logger,
Level level) |
Constructor and Description |
---|
DiscardRegistrarTask(FiddlerImpl.RegistrationInfo regInfo,
ServiceRegistrar registrar)
Constructs an instance of this class and stores the registration
information.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
ConstrainableRegistrarProxy
RegistrarProxy subclass that supports constraints.
|
(package private) class |
RegistrarProxy
A RegistrarProxy is a proxy for a registrar.
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.