Package | Description |
---|---|
net.jini.admin |
These interfaces provide common ways to export
particular administrative functionality.
|
net.jini.core.entry |
The
Entry interface and its associated
UnusableEntryException are used by the lookup service
to represent service-specific attributes and by the JavaSpace
interface to mark entries. |
net.jini.core.lookup |
These are the lookup service interfaces and classes.
|
net.jini.entry |
Provides classes that are useful when handling or implementing
entries.
|
net.jini.lookup |
Standard utility classes for managing the join state of a service
and the service discovery duties of a client or service.
|
net.jini.lookup.entry |
These are common entry classes for use as attributes in lookup services and
their associated JavaBeans(TM) component wrapping classes.
|
net.jini.lookup.entry.jmx | |
net.jini.space |
JavaSpaces servers provide a place on the network, a space,
for clients to store and exchange objects.
|
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.lookup.entry |
Helper utility classes for managing entries used as lookup service attributes.
|
org.apache.river.mahalo |
Provides implementations of the
TransactionManager service.
|
org.apache.river.mercury |
Provides implementations of the
EventMailbox service.
|
org.apache.river.norm |
Provides implementations of
LeaseRenewalService . |
org.apache.river.norm.lookup | |
org.apache.river.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
org.apache.river.reggie |
Provides implementations of
ServiceRegistrar . |
Modifier and Type | Method and Description |
---|---|
Entry[] |
JoinAdmin.getLookupAttributes()
Get the current attribute sets for the service.
|
Modifier and Type | Method and Description |
---|---|
void |
JoinAdmin.addLookupAttributes(Entry[] attrSets)
Add attribute sets for the service.
|
void |
JoinAdmin.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
void |
JoinAdmin.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CloneableEntry
Required by service utilities to avoid sharing internal state.
|
Modifier and Type | Field and Description |
---|---|
Entry |
UnusableEntryException.partialEntry
The partial entry.
|
Modifier and Type | Method and Description |
---|---|
Entry |
CloneableEntry.clone()
Clone has been implemented in AbstractEntry to allow utilities such as
ServiceDiscoveryManager to avoid sharing
internally stored mutable Entry instances with client code. |
Constructor and Description |
---|
UnusableEntryException(Entry partial,
String[] badFields,
Throwable[] exceptions)
Create an exception for the given partial entry and vectors of
bad field names/nested exception pairs.
|
Modifier and Type | Field and Description |
---|---|
Entry[] |
ServiceItem.attributeSets
Attribute sets.
|
Entry[] |
ServiceTemplate.attributeSetTemplates
Attribute set templates to match, or null.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceRegistration.addAttributes(Entry[] attrSets)
Adds the specified attribute sets (those that aren't duplicates of
existing attribute sets) to the registered service item.
|
void |
ServiceRegistration.modifyAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modifies existing attribute sets.
|
void |
ServiceRegistration.modifyAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modifies existing attribute sets.
|
void |
ServiceRegistration.setAttributes(Entry[] attrSets)
Deletes all of the service item's existing attributes, and replaces
them with the specified attribute sets.
|
Constructor and Description |
---|
ServiceItem(ServiceID serviceID,
Object service,
Entry[] attrSets)
Simple constructor.
|
ServiceTemplate(ServiceID serviceID,
Class[] serviceTypes,
Entry[] attrSetTemplates)
Simple constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractEntry
An abstract implementation of
Entry that provides useful
implementations of equals , hashCode , and
toString . |
Modifier and Type | Method and Description |
---|---|
Entry |
AbstractEntry.clone()
Clone has been implemented to allow utilities such as
ServiceDiscoveryManager to avoid sharing
internally stored instances with client code. |
Modifier and Type | Method and Description |
---|---|
static boolean |
AbstractEntry.equals(Entry e1,
Entry e2)
Returns
true if the two arguments are of the same
class and for each entry field F, the arguments'
values for F are either both null or the
invocation of equals on one argument's value for
F with the other argument's value for F as
its parameter returns true . |
private static Field[] |
AbstractEntry.fieldInfo(Entry entry)
Calculate the list of usable fields for this type
|
static int |
AbstractEntry.hashCode(Entry entry)
Returns zero XORed with the result of invoking
hashCode on each of the argument's
non-null entry fields. |
static String |
AbstractEntry.toString(Entry entry)
Returns a
String representation of its argument
that will contain the name of the argument's class and a
representation of each of the argument's entry fields. |
Modifier and Type | Field and Description |
---|---|
protected Entry[] |
JoinManager.AddAttributesTask.attrSets
The new attribute values with which the service's current
attributes will be augmented, replaced, or changed.
|
private Entry[] |
JoinManager.ModifyAttributesTask.attrSetTemplates |
private Entry[] |
JoinManager.lookupAttr
Contains the attributes with which to associate the service in each
of the lookup services with which this join manager registers the
service.
|
(package private) Entry[] |
JoinManager.RegisterTask.regAttrs
Attributes with which to register the service.
|
(package private) Entry[] |
JoinManager.LeaseExpireNotifyTask.regAttrs
Attributes with which to re-register the service.
|
Modifier and Type | Method and Description |
---|---|
Entry[] |
JoinManager.getAttributes()
Returns an array containing the set of attributes currently associated
with the service.
|
Modifier and Type | Method and Description |
---|---|
void |
JoinManager.addAttributes(Entry[] attrSets)
Associates a new set of attributes with the service, in addition to
the service's current set of attributes.
|
void |
JoinManager.ProxyReg.addAttributes(Entry[] attSet)
With respect to the lookup service referenced in this class
and with which this join manager's service is registered, this
method associates with that service a new set of attributes -- in
addition to that service's current set of attributes.
|
void |
JoinManager.addAttributes(Entry[] attrSets,
boolean checkSC)
Associates a new set of attributes with the service, in addition to
the service's current set of attributes.
|
void |
JoinManager.modifyAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Changes the service's current set of attributes using the same
semantics as the
modifyAttributes method of the
ServiceRegistration class. |
void |
JoinManager.modifyAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Changes the service's current set of attributes using the same
semantics as the
modifyAttributes method of the
ServiceRegistration class. |
void |
JoinManager.ProxyReg.modifyAttributes(Entry[] templ,
Entry[] attSet)
With respect to the lookup service referenced in this class
and with which this join manager's service is registered, this
method changes that service's current attributes by selecting
the attributes to change using the given first parameter;
and identifying the desired changes to make through the
contents of the second parameter.
|
void |
JoinManager.ProxyReg.modifyAttributes(Entry[] templ,
Entry[] attSet)
With respect to the lookup service referenced in this class
and with which this join manager's service is registered, this
method changes that service's current attributes by selecting
the attributes to change using the given first parameter;
and identifying the desired changes to make through the
contents of the second parameter.
|
void |
JoinManager.modifyAttributes(Entry[] attrSetTemplates,
Entry[] attrSets,
boolean checkSC)
Changes the service's current set of attributes using the same
semantics as the
modifyAttributes method of the
ServiceRegistration class. |
void |
JoinManager.modifyAttributes(Entry[] attrSetTemplates,
Entry[] attrSets,
boolean checkSC)
Changes the service's current set of attributes using the same
semantics as the
modifyAttributes method of the
ServiceRegistration class. |
void |
JoinManager.ProxyReg.register(Entry[] srvcAttrs)
Registers the service associated with this join manager with the
the lookup service corresponding to this class.
|
void |
JoinManager.replaceRegistration(Object serviceProxy,
Entry[] attrSets)
Registers a new reference to the service with all current and future
discovered lookup services, applying semantics identical to the
one-argument form of this method, except with respect to the
registration of the given attribute sets.
|
private void |
JoinManager.replaceRegistrationDo(Object serviceProxy,
Entry[] attrSets,
boolean doAttrs)
Convenience method invoked by either form of the method
replaceRegistration . |
void |
JoinManager.setAttributes(Entry[] attrSets)
Replaces the service's current set of attributes with a new set of
attributes.
|
void |
JoinManager.ProxyReg.setAttributes(Entry[] attSet)
With respect to the lookup service referenced in this class
and with which this join manager's service is registered, this
method replaces that service's current attributes with a new
set of attributes.
|
Constructor and Description |
---|
AddAttributesTask(JoinManager.ProxyReg proxyReg,
Entry[] newAttrs)
Constructor that associates this task with the lookup service
referenced in the given
ProxyReg parameter. |
JoinManager(Object serviceProxy,
Entry[] attrSets,
ServiceID serviceID,
DiscoveryManagement discoveryMgr,
LeaseRenewalManager leaseMgr)
Constructs an instance of this class that will register the
service with all discovered lookup services, using the supplied
ServiceID . |
JoinManager(Object serviceProxy,
Entry[] attrSets,
ServiceID serviceID,
DiscoveryManagement discoveryMgr,
LeaseRenewalManager leaseMgr,
Configuration config)
Constructs an instance of this class, configured using the items
retrieved through the given
Configuration , that will
register the service with all discovered lookup services, using the
supplied ServiceID . |
JoinManager(Object serviceProxy,
Entry[] attrSets,
ServiceIDListener callback,
DiscoveryManagement discoveryMgr,
LeaseRenewalManager leaseMgr)
Constructs an instance of this class that will register the given
service reference with all discovered lookup services and, through
an event sent to the given
ServiceIDListener object,
communicate the service ID assigned by the first lookup service
with which the service is registered. |
JoinManager(Object serviceProxy,
Entry[] attrSets,
ServiceIDListener callback,
DiscoveryManagement discoveryMgr,
LeaseRenewalManager leaseMgr,
Configuration config)
Constructs an instance of this class, configured using the items
retrieved through the given
Configuration object,
that will register the given service reference with all discovered
lookup services and, through an event sent to the given
ServiceIDListener object, communicate the service ID
assigned by the first lookup service with which the service is
registered. |
JoinManager(Object serviceProxy,
Entry[] attrSets,
ServiceID serviceID,
ServiceIDListener callback,
JoinManager.Conf conf)
Convenience method invoked by the constructors of this class that
uses the given
Configuration to initialize the current
instance of this utility, and initiates all join processing for
the given parameters. |
LeaseExpireNotifyTask(JoinManager.ProxyReg proxyReg,
Entry[] regAttrs)
Constructor that associates this task with the lookup service
referenced in the given
ProxyReg parameter. |
ModifyAttributesTask(JoinManager.ProxyReg proxyReg,
Entry[] attrSetTemplates,
Entry[] attrChanges)
Constructor that associates this task with the lookup service
referenced in the given
ProxyReg parameter. |
ModifyAttributesTask(JoinManager.ProxyReg proxyReg,
Entry[] attrSetTemplates,
Entry[] attrChanges)
Constructor that associates this task with the lookup service
referenced in the given
ProxyReg parameter. |
RegisterTask(JoinManager.ProxyReg proxyReg,
Entry[] regAttrs)
Constructor that associates this task with the lookup service
referenced in the given
ProxyReg parameter. |
SetAttributesTask(JoinManager.ProxyReg proxyReg,
Entry[] replacementAttrs)
Constructor that associates this task with the lookup service
referenced in the given
ProxyReg parameter. |
Modifier and Type | Class and Description |
---|---|
class |
Address
The address of the physical component of a service.
|
class |
Comment
A free-form comment about a service.
|
class |
Host |
class |
Location
The location of the physical component of a service.
|
class |
Name
The name of a service as used by users.
|
class |
ServiceInfo
Generic information about a service.
|
class |
ServiceType
Human-oriented information about the "type" of a service.
|
class |
Status
The base class from which other status-related entry classes may be
derived.
|
class |
UIDescriptor
Entry that enables a UI for a service to be associated
with the service in the attribute sets of the service item. |
Modifier and Type | Method and Description |
---|---|
Entry |
UIDescriptorBean.followLink()
Return the
UIDescriptor linked to by this JavaBeans component. |
Entry |
StatusBean.followLink()
Return the Entry linked to by this JavaBeans component.
|
Entry |
ServiceInfoBean.followLink()
Return the Entry linked to by this JavaBeans component.
|
Entry |
NameBean.followLink()
Return the Name linked to by this JavaBeans component.
|
Entry |
LocationBean.followLink()
Return the Entry linked to by this JavaBeans component.
|
Entry |
EntryBean.followLink()
Return the Entry linked to by this JavaBeans component.
|
Entry |
CommentBean.followLink()
Return the Entry linked to by this JavaBeans component.
|
Entry |
AddressBean.followLink()
Return the Entry linked to by this JavaBeans component.
|
Modifier and Type | Method and Description |
---|---|
static EntryBean |
EntryBeans.createBean(Entry ent)
Create a bean of the appropriate type for the given Entry
object, and link it to the object for immediate manipulation.
|
void |
UIDescriptorBean.makeLink(Entry e)
Make a link to a
UIDescriptor object. |
void |
StatusBean.makeLink(Entry e)
Make a link to an Entry object.
|
void |
ServiceInfoBean.makeLink(Entry e)
Make a link to an Entry object.
|
void |
NameBean.makeLink(Entry e)
Make a link to an Entry object.
|
void |
LocationBean.makeLink(Entry e)
Make a link to an Entry object.
|
void |
EntryBean.makeLink(Entry e)
Make a link to an Entry object.
|
void |
CommentBean.makeLink(Entry e)
Make a link to an Entry object.
|
void |
AddressBean.makeLink(Entry e)
Make a link to an Entry object.
|
Modifier and Type | Class and Description |
---|---|
class |
JMXProperty |
class |
JMXProtocolType |
Modifier and Type | Method and Description |
---|---|
abstract Entry |
AvailabilityEvent.getEntry()
Returns a copy of the
Entry whose transition
triggered this event. |
Entry |
MatchSet.getSnapshot()
|
abstract Entry |
AvailabilityEvent.getSnapshot()
Returns a snapshot of the
Entry whose
transition triggered this event. |
Entry |
MatchSet.next()
Removes one
Entry from the match set and
returns a copy to the caller. |
Entry |
JavaSpace.read(Entry tmpl,
Transaction txn,
long timeout)
Read any matching entry from the space, blocking until one exists.
|
Entry |
JavaSpace.readIfExists(Entry tmpl,
Transaction txn,
long timeout)
Read any matching entry from the space, returning
null if there is currently is none. |
Entry |
JavaSpace.snapshot(Entry e)
The process of serializing an entry for transmission to a JavaSpaces
service will be identical if the same entry is used twice.
|
Entry |
JavaSpace.take(Entry tmpl,
Transaction txn,
long timeout)
Take a matching entry from the space, waiting until one exists.
|
Entry |
JavaSpace.takeIfExists(Entry tmpl,
Transaction txn,
long timeout)
Take a matching entry from the space, returning
null if there is currently is none. |
Modifier and Type | Method and Description |
---|---|
EventRegistration |
JavaSpace.notify(Entry tmpl,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback)
When entries are written that match this template notify the
given
listener with a RemoteEvent that
includes the handback object. |
Entry |
JavaSpace.read(Entry tmpl,
Transaction txn,
long timeout)
Read any matching entry from the space, blocking until one exists.
|
Entry |
JavaSpace.readIfExists(Entry tmpl,
Transaction txn,
long timeout)
Read any matching entry from the space, returning
null if there is currently is none. |
Entry |
JavaSpace.snapshot(Entry e)
The process of serializing an entry for transmission to a JavaSpaces
service will be identical if the same entry is used twice.
|
Entry |
JavaSpace.take(Entry tmpl,
Transaction txn,
long timeout)
Take a matching entry from the space, waiting until one exists.
|
Entry |
JavaSpace.takeIfExists(Entry tmpl,
Transaction txn,
long timeout)
Take a matching entry from the space, returning
null if there is currently is none. |
Lease |
JavaSpace.write(Entry entry,
Transaction txn,
long lease)
Write a new entry into the space.
|
Modifier and Type | Method and Description |
---|---|
private Entry |
ServiceEditor.AttributeTreePanel.cloneEntry(Entry attr) |
private Entry |
ServiceEditor.AttributeTreePanel.generateTemplate(Entry attr) |
Entry[] |
Browser.ServiceListItem.getAttributes() |
protected Entry[] |
SpaceBrowser.SpaceEntryPanel.getEntryArray() |
protected Entry[] |
ServiceEditor.AttributeTreePanel.getEntryArray() |
protected Entry[] |
ServiceBrowser.AttributePanel.getEntryArray() |
protected abstract Entry[] |
EntryTreePanel.getEntryArray() |
Modifier and Type | Method and Description |
---|---|
private Entry |
ServiceEditor.AttributeTreePanel.cloneEntry(Entry attr) |
private void |
Browser.genEntries(StringBuffer buf,
Entry[] entries,
boolean showNulls) |
private Entry |
ServiceEditor.AttributeTreePanel.generateTemplate(Entry attr) |
Modifier and Type | Class and Description |
---|---|
private static class |
FiddlerImpl.FiddlerStatus
Class which is used to communicate the status of this service to
interested entities.
|
Modifier and Type | Field and Description |
---|---|
private Entry[] |
FiddlerImpl.thisServicesAttrs
The attributes to use when joining lookup service(s)
|
Modifier and Type | Method and Description |
---|---|
Entry[] |
FiddlerImpl.getLookupAttributes()
Returns the current attribute sets for the lookup discovery service.
|
Entry[] |
FiddlerAdminProxy.getLookupAttributes()
Get the current attribute sets for the lookup discovery service.
|
private static Entry[] |
FiddlerImpl.unmarshalAttributes(FiddlerImpl fiddlerImpl,
MarshalledObject[] marshalledAttrs)
Unmarshals each element of the
MarshalledObject[] array
parameter. |
Modifier and Type | Method and Description |
---|---|
void |
FiddlerImpl.addLookupAttributes(Entry[] attrSets)
Adds attribute sets to the current set of attributes associated
with the lookup discovery service.
|
void |
FiddlerAdminProxy.addLookupAttributes(Entry[] attrSets)
Add attribute sets to the current set of attributes associated
with the lookup discovery service.
|
private static MarshalledObject[] |
FiddlerImpl.marshalAttributes(FiddlerImpl fiddlerImpl,
Entry[] attrs)
Marshals each element of the
Entry[] array parameter. |
void |
FiddlerImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modifies the current set of attributes associated with the lookup
discovery service.
|
void |
FiddlerImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modifies the current set of attributes associated with the lookup
discovery service.
|
void |
FiddlerAdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current set of attributes associated with the lookup
discovery service.
|
void |
FiddlerAdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current set of attributes associated with the lookup
discovery service.
|
private static void |
FiddlerImpl.writeAttribute(Entry attr,
Logger logger,
Level level) |
private static void |
FiddlerImpl.writeAttributes(Entry[] attrs,
Logger logger,
Level level) |
Constructor and Description |
---|
LookupAttrsAddedLogObj(FiddlerImpl fiddlerImpl,
Entry[] attrs)
Constructs this class and stores the attributes that were added
|
LookupAttrsModifiedLogObj(FiddlerImpl fiddlerImpl,
Entry[] attrTmpls,
Entry[] modAttrs)
Constructs this class and stores the modified attributes
|
LookupAttrsModifiedLogObj(FiddlerImpl fiddlerImpl,
Entry[] attrTmpls,
Entry[] modAttrs)
Constructs this class and stores the modified attributes
|
Modifier and Type | Class and Description |
---|---|
class |
BasicServiceType
An implementation of ServiceType that uses ResourceBundles.
|
Modifier and Type | Method and Description |
---|---|
static Entry[] |
LookupAttributes.add(Entry[] attrSets,
Entry[] addAttrSets)
Returns a new array containing the elements of the
addAttrSets parameter (that are not duplicates of
any of the elements already in the attrSets parameter)
added to the elements of attrSets . |
static Entry[] |
LookupAttributes.add(Entry[] attrSets,
Entry[] addAttrSets,
boolean checkSC)
Returns a new array containing the elements of the
addAttrSets parameter (that are not duplicates of
any of the elements already in the attrSets parameter)
added to the elements of attrSets . |
private static Entry[] |
LookupAttributes.concat(Entry[] attrs1,
Entry[] attrs2)
Return a concatenation of the two arrays.
|
private static Entry[] |
LookupAttributes.delete(Entry[] attrs,
int i)
Return a new array containing all but the given element.
|
static Entry[] |
LookupAttributes.modify(Entry[] attrSets,
Entry[] attrSetTmpls,
Entry[] modAttrSets)
Returns a new array that contains copies of the attributes in the
attrSets parameter, modified according to the contents
of both the attrSetTmpls parameter and the
modAttrSets parameter. |
static Entry[] |
LookupAttributes.modify(Entry[] attrSets,
Entry[] attrSetTmpls,
Entry[] modAttrSets,
boolean checkSC)
Returns a new array that contains copies of the attributes in the
attrSets parameter, modified according to the contents
of both the attrSetTmpls parameter and the
modAttrSets parameter. |
private static Entry |
LookupAttributes.update(Entry e,
Entry mods)
Return a new entry that, for each non-
null field of
the parameter mods , has the same field value as
mods , else the same field value as the parameter
e . |
Modifier and Type | Method and Description |
---|---|
static Entry[] |
LookupAttributes.add(Entry[] attrSets,
Entry[] addAttrSets)
Returns a new array containing the elements of the
addAttrSets parameter (that are not duplicates of
any of the elements already in the attrSets parameter)
added to the elements of attrSets . |
static Entry[] |
LookupAttributes.add(Entry[] attrSets,
Entry[] addAttrSets)
Returns a new array containing the elements of the
addAttrSets parameter (that are not duplicates of
any of the elements already in the attrSets parameter)
added to the elements of attrSets . |
static Entry[] |
LookupAttributes.add(Entry[] attrSets,
Entry[] addAttrSets,
boolean checkSC)
Returns a new array containing the elements of the
addAttrSets parameter (that are not duplicates of
any of the elements already in the attrSets parameter)
added to the elements of attrSets . |
static Entry[] |
LookupAttributes.add(Entry[] attrSets,
Entry[] addAttrSets,
boolean checkSC)
Returns a new array containing the elements of the
addAttrSets parameter (that are not duplicates of
any of the elements already in the attrSets parameter)
added to the elements of attrSets . |
private static void |
LookupAttributes.check(Entry e)
Throws a
SecurityException if parameter e
is instanceof ServiceControlled . |
static void |
LookupAttributes.check(Entry[] attrs,
boolean nullOK)
Throws an
IllegalArgumentException if any element of
the array is not an instance of a valid Entry class
(the class is not public, or does not have a no-arg constructor, or
has primitive public non-static non-final fields). |
private static Entry[] |
LookupAttributes.concat(Entry[] attrs1,
Entry[] attrs2)
Return a concatenation of the two arrays.
|
private static Entry[] |
LookupAttributes.concat(Entry[] attrs1,
Entry[] attrs2)
Return a concatenation of the two arrays.
|
private static boolean |
LookupAttributes.contains(Entry[] eSet,
Entry e)
Returns
true if the Entry parameter
e is an element of the Entry[] array
parameter eSet ; returns false otherwise. |
private static boolean |
LookupAttributes.contains(Entry[] eSet,
Entry e)
Returns
true if the Entry parameter
e is an element of the Entry[] array
parameter eSet ; returns false otherwise. |
private static boolean |
LookupAttributes.contains(Entry[] eSet1,
Entry[] eSet2)
Returns
true if the Entry[] array parameter
eSet1 contains the Entry[] array parameter
eSet2 ; returns false otherwise. |
private static boolean |
LookupAttributes.contains(Entry[] eSet1,
Entry[] eSet2)
Returns
true if the Entry[] array parameter
eSet1 contains the Entry[] array parameter
eSet2 ; returns false otherwise. |
private static Entry[] |
LookupAttributes.delete(Entry[] attrs,
int i)
Return a new array containing all but the given element.
|
static boolean |
LookupAttributes.equal(Entry[] attrSet1,
Entry[] attrSet2)
Tests that two
Entry[] arrays are the same. |
static boolean |
LookupAttributes.equal(Entry[] attrSet1,
Entry[] attrSet2)
Tests that two
Entry[] arrays are the same. |
static boolean |
LookupAttributes.equal(Entry e1,
Entry e2)
Test that two entries are the same type, with the same
public fields.
|
private static Field[] |
LookupAttributes.getFields(Entry e)
Returns public fields, in super to subclass order, sorted
alphabetically within a given class.
|
private static Field[] |
LookupAttributes.getFields(Entry e,
Entry oe,
Field[] ofields)
Returns the public fields of the parameter
e . |
private static boolean |
LookupAttributes.isDup(Entry[] attrs,
int index)
Test if the set at the given
index is equal to any
other set earlier in the Entry[] array parameter. |
static boolean |
LookupAttributes.matches(Entry tmpl,
Entry e)
Test if the parameter
tmpl is the same class as, or a
superclass of, the parameter e , and that every
non-null public field of tmpl is the
same as the corresponding field of e . |
static Entry[] |
LookupAttributes.modify(Entry[] attrSets,
Entry[] attrSetTmpls,
Entry[] modAttrSets)
Returns a new array that contains copies of the attributes in the
attrSets parameter, modified according to the contents
of both the attrSetTmpls parameter and the
modAttrSets parameter. |
static Entry[] |
LookupAttributes.modify(Entry[] attrSets,
Entry[] attrSetTmpls,
Entry[] modAttrSets)
Returns a new array that contains copies of the attributes in the
attrSets parameter, modified according to the contents
of both the attrSetTmpls parameter and the
modAttrSets parameter. |
static Entry[] |
LookupAttributes.modify(Entry[] attrSets,
Entry[] attrSetTmpls,
Entry[] modAttrSets)
Returns a new array that contains copies of the attributes in the
attrSets parameter, modified according to the contents
of both the attrSetTmpls parameter and the
modAttrSets parameter. |
static Entry[] |
LookupAttributes.modify(Entry[] attrSets,
Entry[] attrSetTmpls,
Entry[] modAttrSets,
boolean checkSC)
Returns a new array that contains copies of the attributes in the
attrSets parameter, modified according to the contents
of both the attrSetTmpls parameter and the
modAttrSets parameter. |
static Entry[] |
LookupAttributes.modify(Entry[] attrSets,
Entry[] attrSetTmpls,
Entry[] modAttrSets,
boolean checkSC)
Returns a new array that contains copies of the attributes in the
attrSets parameter, modified according to the contents
of both the attrSetTmpls parameter and the
modAttrSets parameter. |
static Entry[] |
LookupAttributes.modify(Entry[] attrSets,
Entry[] attrSetTmpls,
Entry[] modAttrSets,
boolean checkSC)
Returns a new array that contains copies of the attributes in the
attrSets parameter, modified according to the contents
of both the attrSetTmpls parameter and the
modAttrSets parameter. |
private static Entry |
LookupAttributes.update(Entry e,
Entry mods)
Return a new entry that, for each non-
null field of
the parameter mods , has the same field value as
mods , else the same field value as the parameter
e . |
Modifier and Type | Field and Description |
---|---|
private Entry[] |
JoinStateManager.attributes
The join state, this data needs to be persisted between restarts
|
Modifier and Type | Method and Description |
---|---|
private static Entry[] |
TxnManagerImpl.attributesFor()
Create the service owned attributes for an Mahalo server
|
Entry[] |
TxnMgrAdminProxy.getLookupAttributes() |
Entry[] |
TxnManagerImpl.getLookupAttributes() |
Entry[] |
JoinStateManager.getLookupAttributes()
Get the current attribute sets for the service.
|
private static Entry[] |
JoinStateManager.readAttributes(ObjectInput in)
Utility method to read in an array of entities from a
ObjectInputStream . |
Modifier and Type | Method and Description |
---|---|
void |
TxnMgrAdminProxy.addLookupAttributes(Entry[] attrSets) |
void |
TxnManagerImpl.addLookupAttributes(Entry[] attrSets) |
void |
JoinStateManager.addLookupAttributes(Entry[] attrSets)
Add attribute sets for the service.
|
void |
TxnMgrAdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
TxnMgrAdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
TxnManagerImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
TxnManagerImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
JoinStateManager.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
void |
JoinStateManager.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
(package private) void |
JoinStateManager.startManager(Configuration config,
Object service,
ServiceID serviceID,
Entry[] baseAttributes)
Start the manager.
|
private static void |
JoinStateManager.writeAttributes(Entry[] attributes,
ObjectOutput out)
Utility method to write out an array of entities to an
ObjectOutputStream . |
Modifier and Type | Field and Description |
---|---|
private static Entry[] |
MailboxImpl.BASE_LOOKUP_ATTRS
The attributes to use when joining lookup services
|
(package private) Entry[] |
MailboxImplInit.lookupAttrs |
private Entry[] |
MailboxImpl.lookupAttrs |
Modifier and Type | Method and Description |
---|---|
Entry[] |
MailboxImpl.getLookupAttributes() |
Entry[] |
MailboxAdminProxy.getLookupAttributes() |
private static Entry[] |
MailboxImpl.unmarshalAttributes(MarshalledObject[] marshalledAttrs)
Unmarshals each element of the
MarshalledObject array
parameter. |
Modifier and Type | Method and Description |
---|---|
void |
MailboxImpl.addLookupAttributes(Entry[] attrSets) |
void |
MailboxAdminProxy.addLookupAttributes(Entry[] attrSets) |
(package private) static void |
MailboxImpl.dumpAttrs(Entry[] attrs,
Logger logger,
Level level)
Utility method for displaying lookup service attributes
|
private static MarshalledObject[] |
MailboxImpl.marshalAttributes(Entry[] attrs)
Marshals each element of the
Entry[] array parameter. |
void |
MailboxImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
MailboxImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
MailboxAdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
MailboxAdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
Constructor and Description |
---|
AttrsAddedLogObj(Entry[] attrs)
Constructs this class and stores the attributes that were added
|
AttrsModifiedLogObj(Entry[] attrTmpls,
Entry[] modAttrs)
Constructs this class and stores the modified attributes
along with the corresponding set of templates.
|
AttrsModifiedLogObj(Entry[] attrTmpls,
Entry[] modAttrs)
Constructs this class and stores the modified attributes
along with the corresponding set of templates.
|
MailboxImplInit(Configuration config,
boolean persistent,
ActivationID activationID,
Entry[] baseLookupAttrs) |
Modifier and Type | Method and Description |
---|---|
Entry[] |
NormServerBaseImpl.getLookupAttributes() |
Entry[] |
AdminProxy.getLookupAttributes() |
Modifier and Type | Method and Description |
---|---|
void |
NormServerBaseImpl.addLookupAttributes(Entry[] attrSets) |
void |
AdminProxy.addLookupAttributes(Entry[] attrSets) |
void |
NormServerBaseImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
NormServerBaseImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
AdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
AdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
Modifier and Type | Field and Description |
---|---|
private Entry[] |
JoinState.attributes
Pass through to get attribute array from the log recovery method
to the code that creates the
JoinManager |
private Entry[] |
JoinState.serviceAttributes
Attributes supplied by the service
|
Modifier and Type | Method and Description |
---|---|
Entry[] |
JoinState.getAttributes()
Get the current attribute sets for the service.
|
private static Entry[] |
JoinState.readAttributes(ObjectInputStream in)
Utility method to read in an array of entities from a
ObjectInputStream . |
Modifier and Type | Method and Description |
---|---|
void |
JoinState.addAttributes(Entry[] attrSets,
boolean checkSC)
Add attribute sets for the service.
|
void |
JoinState.modifyAttributes(Entry[] attrSetTemplates,
Entry[] attrSets,
boolean checkSC)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
void |
JoinState.modifyAttributes(Entry[] attrSetTemplates,
Entry[] attrSets,
boolean checkSC)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
private static void |
JoinState.writeAttributes(Entry[] attributes,
ObjectOutputStream out)
Utility method to write out an array of entities to an
ObjectOutputStream . |
Constructor and Description |
---|
JoinState(Object service,
LeaseRenewalManager lrm,
Configuration config,
Entry[] serviceAttributes,
ProxyPreparer recoveredLookupLocatorPreparer,
ServiceID serviceID)
Simple constructor.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
SnapshotRep
This class is used by the
snapshot implementation of the
proxy to create a snapshot . |
Modifier and Type | Field and Description |
---|---|
private Entry[] |
JoinStateManager.attributes
The list of attributes to start with.
|
Modifier and Type | Method and Description |
---|---|
private static Entry[] |
OutriggerServerImpl.attributesFor()
Create the service-owned attributes for an Outrigger server.
|
(package private) Entry |
EntryRep.entry()
Return an
Entry object built out of this
EntryRep This is used by the client-side proxy to
convert the EntryRep it gets from the space server
into the actual Entry object it represents. |
(package private) static Entry |
SpaceProxy2.entryFrom(EntryRep rep)
Return an entry generated from the given rep.
|
Entry |
OutriggerAvailabilityEvent.getEntry() |
Entry[] |
OutriggerServerWrapper.getLookupAttributes() |
Entry[] |
OutriggerServerImpl.getLookupAttributes() |
Entry[] |
JoinStateManager.getLookupAttributes()
Get the current attribute sets for the service.
|
Entry[] |
AdminProxy.getLookupAttributes() |
Entry |
OutriggerAvailabilityEvent.getSnapshot() |
Entry |
MatchSetProxy.getSnapshot() |
Entry |
MatchSetProxy.next() |
Entry |
IteratorProxy.next() |
Entry |
AdminIterator.next()
Deprecated.
Return the next entry in the sequence.
|
Entry |
SpaceProxy2.read(Entry tmpl,
Transaction txn,
long timeout) |
private static Entry[] |
JoinStateManager.readAttributes(ObjectInputStream in)
Utility method to read in an array of entities from a
ObjectInputStream . |
Entry |
SpaceProxy2.readIfExists(Entry tmpl,
Transaction txn,
long timeout) |
Entry |
SpaceProxy2.snapshot(Entry entry) |
Entry |
SpaceProxy2.take(Entry tmpl,
Transaction txn,
long timeout) |
Entry |
SpaceProxy2.takeIfExists(Entry tmpl,
Transaction txn,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
OutriggerServerWrapper.addLookupAttributes(Entry[] attrSets) |
void |
OutriggerServerImpl.addLookupAttributes(Entry[] attrSets) |
void |
JoinStateManager.addLookupAttributes(Entry[] attrSets)
Add attribute sets for the service.
|
void |
AdminProxy.addLookupAttributes(Entry[] attrSets) |
AdminIterator |
JavaSpaceAdmin.contents(Entry tmpl,
Transaction txn)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
ConstrainableJavaSpaceAdmin.contents(Entry tmpl,
Transaction txn)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
AdminProxy.contents(Entry tmpl,
Transaction tr) |
AdminIterator |
JavaSpaceAdmin.contents(Entry tmpl,
Transaction txn,
int fetchSize)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
ConstrainableJavaSpaceAdmin.contents(Entry tmpl,
Transaction txn,
int fetchSize)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
ConstrainableAdminProxy.contents(Entry tmpl,
Transaction tr,
int fetchSize)
Override super class to create secure
IteratorProxy s |
AdminIterator |
AdminProxy.contents(Entry tmpl,
Transaction tr,
int fetchSize) |
AdminIterator |
ConstrainableJavaSpaceAdmin.contents(Entry tmpl,
Transaction txn,
int fetchSize,
MethodConstraints constrains)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
ConstrainableAdminProxy.contents(Entry tmpl,
Transaction txn,
int fetchSize,
MethodConstraints constraints) |
void |
OutriggerServerWrapper.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
OutriggerServerWrapper.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
OutriggerServerImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
OutriggerServerImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
JoinStateManager.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
void |
JoinStateManager.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
void |
AdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
AdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
EventRegistration |
SpaceProxy2.notify(Entry tmpl,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback) |
Entry |
SpaceProxy2.read(Entry tmpl,
Transaction txn,
long timeout) |
Entry |
SpaceProxy2.readIfExists(Entry tmpl,
Transaction txn,
long timeout) |
(package private) static EntryRep |
SpaceProxy2.repFor(Entry entry)
Return an
EntryRep object for the given
Entry . |
Entry |
SpaceProxy2.snapshot(Entry entry) |
(package private) void |
JoinStateManager.startManager(Configuration config,
LogOps log,
Object service,
ServiceID serviceID,
Entry[] baseAttributes)
Start the manager.
|
Entry |
SpaceProxy2.take(Entry tmpl,
Transaction txn,
long timeout) |
Entry |
SpaceProxy2.takeIfExists(Entry tmpl,
Transaction txn,
long timeout) |
private UnusableEntryException |
EntryRep.throwNewUnusableEntryException(Entry partial,
String[] badFields,
Throwable[] exceptions)
Construct, log, and throw a new UnusableEntryException
|
Lease |
SpaceProxy2.write(Entry entry,
Transaction txn,
long lease) |
private static void |
JoinStateManager.writeAttributes(Entry[] attributes,
ObjectOutputStream out)
Utility method to write out an array of entities to an
ObjectOutputStream . |
Constructor and Description |
---|
EntryRep(Entry entry)
Create a serialized form of the entry with our object's
relevant fields set.
|
EntryRep(Entry entry,
boolean validate)
Create a serialized form of the entry.
|
SnapshotRep(Entry e)
Create a new
SnapshotRep that is a snapshot of
e . |
Modifier and Type | Field and Description |
---|---|
private Entry[] |
RegistrarImpl.LookupAttributesChangedLogObj.attrs
The new lookup service attributes.
|
private static Entry[] |
RegistrarImpl.baseAttrs
Base set of initial attributes for self
|
private Entry[] |
RegistrarImpl.lookupAttrs
The attributes to use when joining (including with myself)
|
(package private) Entry[] |
RegistrarImpl.Initializer.lookupAttrs |
Modifier and Type | Method and Description |
---|---|
Entry |
EntryRep.get()
Convert back to an Entry.
|
Entry[] |
RegistrarImpl.getLookupAttributes() |
Entry[] |
AdminProxy.getLookupAttributes() |
static Entry[] |
EntryRep.toEntry(EntryRep[] reps)
Converts an array of EntryRep to an array of Entry.
|
private static Entry[] |
RegistrarImpl.unmarshalAttributes(ObjectInputStream in)
Returns reggie's attributes unmarshalled from a null-terminated list of
MarshalledInstances read from the given stream, logging (but tolerating)
unmarshalling failures.
|
Modifier and Type | Method and Description |
---|---|
void |
Registration.addAttributes(Entry[] attrSets) |
void |
RegistrarImpl.addLookupAttributes(Entry[] attrSets) |
void |
AdminProxy.addLookupAttributes(Entry[] attrSets) |
private static void |
RegistrarImpl.marshalAttributes(Entry[] attrs,
ObjectOutputStream out)
Writes reggie's attributes to ObjectOutputStream as a
null-terminated list of MarshalledInstances.
|
void |
Registration.modifyAttributes(Entry[] attrSetTmpls,
Entry[] attrSets) |
void |
Registration.modifyAttributes(Entry[] attrSetTmpls,
Entry[] attrSets) |
void |
RegistrarImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
RegistrarImpl.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
AdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
AdminProxy.modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets) |
void |
Registration.setAttributes(Entry[] attrSets) |
static EntryRep[] |
EntryRep.toEntryRep(Entry[] entries,
boolean needCodebase)
Converts an array of Entry to an array of EntryRep.
|
Constructor and Description |
---|
EntryRep(Entry entry)
Converts an Entry to an EntryRep.
|
LookupAttributesChangedLogObj(Entry[] attrs)
Simple constructor
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.