Package | Description |
---|---|
com.sun.jini.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
Modifier and Type | Field and Description |
---|---|
private EntryRep[] |
OutriggerServerImpl.ContentsQuery.lastBatch
Last batch of entries returned
|
private EntryRep[] |
OutriggerServerImpl.IteratorImpl.lastBatch
Last batch of
EntryRep objects sent to the
client. |
private EntryRep |
MatchSetProxy.lastRepReturned
Last rep returned
|
private static EntryRep |
EntryRep.matchAnyRep
This object represents the passing of a
null
parameter as a template, which is designed to match any entry. |
private EntryRep |
WrittenEntry.rep
The EntryRep this node refers to.
|
private EntryRep |
SnapshotRep.rep |
private EntryRep |
OutriggerAvailabilityEvent.rep
The entry that triggered the event
|
private EntryRep |
BaseHandle.rep |
private EntryRep |
AvailabilityRegistrationWatcher.VisibilityEventSender.rep
the
EntryRep for the entry that became visible |
private EntryRep[] |
MatchSetProxy.reps
Last batch fetched from server
|
(package private) EntryRep[] |
MatchSetData.reps
Intial set of entries
|
private EntryRep[] |
IteratorProxy.reps
Last set of reps we got from the server
|
private EntryRep |
OutriggerServerImpl.IteratorImpl.tmpl
The template the match
|
private EntryRep[] |
OutriggerServerImpl.ContentsQuery.tmpls
The complete set of templates
|
private EntryRep[] |
EntryHolder.ContinuingQuery.tmpls
Templates being used for the query
|
Modifier and Type | Method and Description |
---|---|
private EntryRep[] |
OutriggerServerImpl.completeTake(EntryHandle[] handles,
int found,
Txn txn) |
private EntryRep |
OutriggerServerImpl.completeTake(EntryHandle handle,
Txn txn) |
(package private) static EntryRep |
EntryRep.matchAnyEntryRep()
The
EntryRep that marks a ``match any'' request. |
private EntryRep[] |
OutriggerServerImpl.ContentsQuery.nextBatch(Uuid lastReceived,
long now) |
EntryRep[] |
OutriggerServerWrapper.nextBatch(Uuid contentsQueryUuid,
Uuid entryUuid) |
EntryRep[] |
OutriggerServerImpl.nextBatch(Uuid contentsQueryUuid,
Uuid entryUuid) |
EntryRep[] |
OutriggerServer.nextBatch(Uuid contentsQueryUuid,
Uuid entryUuid)
Return the next batch of entries associated with the specified
contents query.
|
EntryRep |
RepEnum.nextRep()
Return the next
EntryRep object, or null
if there is none. |
EntryRep |
OutriggerServerImpl.AllReps.nextRep() |
EntryRep |
EntryHolder.SimpleRepEnum.nextRep() |
EntryRep[] |
OutriggerServerImpl.IteratorImpl.nextReps(int max,
Uuid id) |
EntryRep[] |
OutriggerServerWrapper.nextReps(Uuid iterationUuid,
int max,
Uuid entryUuid) |
EntryRep[] |
OutriggerServerImpl.nextReps(Uuid iterationUuid,
int max,
Uuid entryUuid) |
EntryRep[] |
OutriggerAdmin.nextReps(Uuid iterationUuid,
int max,
Uuid entryUuid)
Fetch up to
max EntryRep objects from
the specified iteration. |
(package private) EntryRep |
WrittenEntry.rep()
Return the EntryRep of this entry.
|
(package private) EntryRep |
SnapshotRep.rep()
Return the pre-computed
EntryRep . |
(package private) EntryRep |
BaseHandle.rep()
Return the handle's
EntryRep object. |
(package private) static EntryRep[] |
SpaceProxy2.repFor(Collection entries,
String argName) |
(package private) static EntryRep |
SpaceProxy2.repFor(Entry entry)
Return an
EntryRep object for the given
Entry . |
private EntryRep |
OutriggerServerImpl.setupTmpl(EntryRep tmpl) |
Modifier and Type | Method and Description |
---|---|
(package private) WrittenEntry |
WrittenEntry.add(EntryRep rep)
Add a new entry after this one.
|
(package private) void |
WatchersForTemplateClass.add(TransitionWatcher watcher,
EntryRep template)
Add a
TransitionWatcher to the list
of watchers looking for visibility transitions in
entries that match the specified template. |
(package private) void |
TransitionWatchers.add(TransitionWatcher watcher,
EntryRep template)
Add a
TransitionWatcher to the list
of watchers looking for visibility transitions in
entries that match the specified template. |
(package private) void |
TypeTree.addTypes(EntryRep bits)
Update the type tree with the given bits.
|
private void |
OutriggerServerImpl.checkForEmpty(EntryRep[] entries,
String msg)
Utility method to check for zero length arrays of entries
and throw an exception if necessary
|
private boolean |
EntryHolder.confirmAvailability(EntryRep rep,
EntryHandle handle,
TransactableMgr txn,
boolean takeIt,
long time,
Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet)
With the EntryRep
rep passed in, verify that the
entry hasn't been taken by someone else, hasn't expired, etc. |
private boolean |
EntryHolder.confirmAvailabilityWithTxn(EntryRep rep,
EntryHandle handle,
TransactableMgr txnMgr,
boolean takeIt,
long time,
Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet) |
MatchSetData |
OutriggerServerWrapper.contents(EntryRep[] tmpls,
Transaction tr,
long leaseTime,
long limit) |
MatchSetData |
OutriggerServerImpl.contents(EntryRep[] tmpls,
Transaction tr,
long leaseTime,
long limit) |
MatchSetData |
OutriggerServer.contents(EntryRep[] tmpls,
Transaction tr,
long leaseTime,
long limit)
Start a new contents query.
|
Uuid |
OutriggerServerWrapper.contents(EntryRep tmpl,
Transaction txn) |
Uuid |
OutriggerServerImpl.contents(EntryRep tmpl,
Transaction tr) |
Uuid |
OutriggerAdmin.contents(EntryRep tmpl,
Transaction txn)
Return the remote iterator object needed by
JavaSpaceAdmin.contents . |
(package private) EntryHolder.ContinuingQuery |
EntryHolder.continuingQuery(EntryRep[] tmpls,
TransactableMgr txn,
boolean takeThem,
long now)
Return an object that can be used to perform a query that can
return multiple matches and be restarted in another thread.
|
private EntryHolder.ContinuingQuery |
OutriggerServerImpl.createQuery(EntryRep[] tmpls,
String clazz,
Txn txn,
boolean takeIt,
long now)
Crerate a ContinuingQuery for the holder of the specified class.
|
(package private) static EntryHandleTmplDesc |
EntryHandle.descFor(EntryRep tmpl,
int numFields)
Return the template description -- mask and hash.
|
(package private) static void |
OutriggerServerImpl.dump(EntryHolder holder,
String name,
EntryRep rep)
Debug method: Dump out the bucket for the given holder, for an
operation using the given rep.
|
(package private) void |
OutriggerServerImpl.dump(String name,
EntryRep rep)
Debug method: Dump out the bucket for the holder for the given
rep.
|
(package private) static Entry |
SpaceProxy2.entryFrom(EntryRep rep)
Return an entry generated from the given rep.
|
private EntryHandle |
OutriggerServerImpl.find(EntryRep tmplRep,
Txn txn,
boolean takeIt,
Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet)
Find an entry that is at least
whichClass that
matches the template tmplRep (at least the
template's type, and matches in values provided). |
private Object |
OutriggerServerImpl.getMatch(EntryRep tmpl,
Transaction tr,
long timeout,
boolean takeIt,
boolean ifExists,
OutriggerServer.QueryCookie queryCookieFromClient)
Do the heavy lifting for queries.
|
private EntryHandle |
EntryHolder.handleFor(EntryRep rep)
Return the handle for the given
EntryRep object. |
(package private) static long |
EntryHandle.hashFor(EntryRep rep,
int numFields)
Calculate the hash for a particular entry, assuming the given number
of fields.
|
private static long |
EntryHandle.hashFor(EntryRep rep,
int numFields,
EntryHandleHashDesc hashDesc)
Calculate the hash for a particular entry, assuming the given
number of fields, filling in the fields of
desc
with the relevant values. |
(package private) static long |
EntryHandle.hashForField(EntryRep rep,
int field)
Return the hash value for a given field, which is then merged in
as part of the overall hash for the entry.
|
(package private) EntryHandle |
EntryHolder.hasMatch(EntryRep tmpl,
TransactableMgr txn,
boolean takeIt,
Set conflictSet,
Set lockedEntrySet,
WeakHashMap provisionallyRemovedEntrySet)
Return an
EntryHandle object that matches the given
template, or null if none does. |
(package private) EntryHolder |
EntryHolderSet.holderFor(EntryRep rep)
Return the
EntryHolder object for the exact class
of the Entry object held in bits . |
private static boolean |
EntryRep.isMatchAny(EntryRep rep)
Return
true if the given rep is that ``match any''
EntryRep . |
(package private) boolean |
TemplateHandle.matches(EntryRep entry)
Return
true if this template matches the given entry. |
(package private) boolean |
EntryRep.matches(EntryRep other)
See if the other object matches the template object this
represents.
|
EventRegistration |
OutriggerServerWrapper.notify(EntryRep tmpl,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback) |
EventRegistration |
OutriggerServerImpl.notify(EntryRep tmpl,
Transaction tr,
RemoteEventListener listener,
long leaseTime,
MarshalledObject handback) |
EventRegistration |
OutriggerServer.notify(EntryRep tmpl,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback)
When entries are written that match this template notify the
given
listener . |
Object |
OutriggerServerWrapper.read(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.read(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServer.read(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie)
Find an entry in the space that matches the passed template and
is visible to the passed transaction.
|
Object |
OutriggerServerWrapper.readIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.readIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServer.readIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie)
Find an entry in the space that matches the passed template and
is visible to the passed transaction.
|
EventRegistration |
OutriggerServerWrapper.registerForAvailabilityEvent(EntryRep[] tmpls,
Transaction txn,
boolean visibilityOnly,
RemoteEventListener listener,
long leaseTime,
MarshalledObject handback) |
EventRegistration |
OutriggerServerImpl.registerForAvailabilityEvent(EntryRep[] tmpls,
Transaction tr,
boolean visibilityOnly,
RemoteEventListener listener,
long leaseTime,
MarshalledObject handback) |
EventRegistration |
OutriggerServer.registerForAvailabilityEvent(EntryRep[] tmpls,
Transaction txn,
boolean visibilityOnly,
RemoteEventListener listener,
long leaseTime,
MarshalledObject handback)
When entries that match one or more of the passed templates
transition from invisible to visible notify the give
listener . |
private void |
OutriggerServerImpl.IteratorImpl.rememberLast(EntryRep[] newLast)
Utility to set
lastBatch and lastId . |
private EntryRep |
OutriggerServerImpl.setupTmpl(EntryRep tmpl) |
(package private) void |
EntryRep.shareWith(EntryRep other)
Set this entry's generic data to be shared with the
other
object. |
Object |
OutriggerServerWrapper.take(EntryRep[] tmpls,
Transaction tr,
long timeout,
int limit,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.take(EntryRep[] tmpls,
Transaction tr,
long timeout,
int limit,
OutriggerServer.QueryCookie queryCookieFromClient) |
Object |
OutriggerServer.take(EntryRep[] tmpls,
Transaction tr,
long timeout,
int limit,
OutriggerServer.QueryCookie cookie)
Find and remove up to
limit entries in the space
that match one or more of the passed templates and are visible
to the passed transaction. |
Object |
OutriggerServerWrapper.take(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.take(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServer.take(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie)
Find and remove an entry in the space that matches the passed
template and is visible to the passed transaction.
|
Object |
OutriggerServerWrapper.takeIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.takeIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServer.takeIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie)
Find and remove an entry in the space that matches the passed
template and is visible to the passed transaction.
|
private void |
OutriggerServerImpl.typeCheck(EntryRep rep)
Check if an entry (or template) class definition
has changed.
|
long[] |
OutriggerServerWrapper.write(EntryRep[] entries,
Transaction txn,
long[] leaseTimes) |
long[] |
OutriggerServerImpl.write(EntryRep[] entries,
Transaction tr,
long[] leaseTimes) |
long[] |
OutriggerServer.write(EntryRep[] entries,
Transaction txn,
long[] leaseTimes)
Write a set of entires into the space.
|
long[] |
OutriggerServerWrapper.write(EntryRep entry,
Transaction txn,
long lease) |
long[] |
OutriggerServerImpl.write(EntryRep rep,
Transaction tr,
long lease) |
long[] |
OutriggerServer.write(EntryRep entry,
Transaction txn,
long lease)
Write a new entry into the space.
|
Constructor and Description |
---|
AvailabilityRegistrationWatcher.VisibilityEventSender(EntryRep rep,
boolean isVisible,
long ourSeqNumber)
Create a new
VisibilityEventSender that will send
a new OutriggerAvailabilityEvent . |
BaseHandle(EntryRep rep)
Create a new handle
|
EntryHandle(EntryRep rep,
TransactableMgr mgr,
EntryHolder holder)
Create a new handle, calculating the hash for the object.
|
EntryHolder.ContinuingQuery(EntryRep[] tmpls,
TransactableMgr txn,
boolean takeThem,
long now)
Create a new
ContinuingQuery object. |
MatchSetData(Uuid uuid,
EntryRep[] reps,
long intialLeaseDuration)
Creates a new MatchSetData instance.
|
OutriggerAvailabilityEvent(JavaSpace source,
long eventID,
long seqNum,
MarshalledObject handback,
boolean visibilityTransition,
EntryRep rep)
Constructs an OutriggerAvailabilityEvent object.
|
OutriggerServerImpl.ContentsQuery(Uuid uuid,
EntryRep[] tmpls,
Txn txn,
long limit) |
OutriggerServerImpl.IteratorImpl(EntryRep tmpl,
Txn txn)
Create a
RemoteIterImpl object to return all
objects that match the given template. |
SnapshotRep(EntryRep e)
Construct an SnapshotRep from an existing EntryRep
|
TemplateHandle(EntryRep tmpl,
WatchersForTemplateClass owner)
Create a handle for the template
tmpl . |
WrittenEntry(EntryRep rep)
Create a new time-stamped entry for the given EntryRep.
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.