All Packages Class Hierarchy This Package Previous Next Index
Interface javaNOW.EntrySpaceI
- public interface EntrySpaceI
Interface to store and retrieve Entrys
-
DEFAULT_HASH_SIZE
-
-
MAX_WAIT
- Constants
-
barrier(int)
- implements barrier
-
clear()
- remove all messages in the entry space
-
get(Entry)
- Removes message from message space in nonblocking fashion.
-
getEntryCount()
- It returns number of messages in the messagespace
-
getEntryCount(Entry)
- It returns number of messages in the messagespace that matches the
message value as that of theEntry
-
getHashSize()
- Accesss
-
getIfExists(Entry)
- Removes message from message space in nonblocking fashion.
-
getIfExistsType(Entry)
- It returns vector of messages that match the message value of the
theEntry
-
getIfExistsType(Entry, int)
- It returns nth message in the message space that matches the message value
as that of theEntry
-
present(Entry)
- Returns true if message exist in message spaces (nonblocking)
-
put(Entry)
- Inserts a message into message space
-
read(Entry)
- Returns a copy of message from message space in blocking fashion.
-
readIfExists(Entry)
- Returns a copy of message from message space in nonblocking fashion.
-
readIfExistsType(Entry)
- It is same as getIfExistsType() couterpart except it returns copy of messages
-
readIfExistsType(Entry, int)
- It is same as getIfExistsType() couterpart except it returns copy of messages
-
setHashSize(int)
- Modifiers
-
subscribe(String, JavaNOWEntryNotifier, JavaNOWEntryFilter)
- subscribe to receive events of given type
-
sync(int)
- implements sync -- for barrier
-
sync(int)
- It blocks until message space contains numEntrys number of messages
-
unsubscribe(String)
- unsubscribe to receive events of given type
-
waitUntilFound(Entry)
- Waits until message exist in message spaces (blocking)
MAX_WAIT
public static final int MAX_WAIT
- Constants
DEFAULT_HASH_SIZE
public static final int DEFAULT_HASH_SIZE
getHashSize
public abstract int getHashSize()
- Accesss
- See Also:
- class, method
getIfExists
public abstract Entry getIfExists(Entry t) throws UninitializedEntrySpace
- Removes message from message space in nonblocking fashion.
If message does not exist, it returns null
- See Also:
- class, method
get
public abstract Entry get(Entry t) throws UninitializedEntrySpace, SingleThreadBlockException
- Removes message from message space in nonblocking fashion.
If message does not exist, it blocks until it is inserted
- See Also:
- class, method
getIfExistsType
public abstract Entry[] getIfExistsType(Entry t) throws UninitializedEntrySpace
- It returns vector of messages that match the message value of the
theEntry
- See Also:
- class, method
getIfExistsType
public abstract Entry getIfExistsType(Entry t,
int n) throws UninitializedEntrySpace
- It returns nth message in the message space that matches the message value
as that of theEntry
- See Also:
- class, method
present
public abstract boolean present(Entry t) throws UninitializedEntrySpace
- Returns true if message exist in message spaces (nonblocking)
- See Also:
- class, method
waitUntilFound
public abstract void waitUntilFound(Entry t) throws UninitializedEntrySpace, SingleThreadBlockException
- Waits until message exist in message spaces (blocking)
- See Also:
- class, method
readIfExists
public abstract Entry readIfExists(Entry t) throws UninitializedEntrySpace
- Returns a copy of message from message space in nonblocking fashion.
If message does not exist, it returns null
- See Also:
- class, method
read
public abstract Entry read(Entry t) throws UninitializedEntrySpace, SingleThreadBlockException
- Returns a copy of message from message space in blocking fashion.
If message does not exist, it blocks until it is inserted
- See Also:
- class, method
readIfExistsType
public abstract Entry[] readIfExistsType(Entry t) throws UninitializedEntrySpace
- It is same as getIfExistsType() couterpart except it returns copy of messages
- See Also:
- class, method
readIfExistsType
public abstract Entry readIfExistsType(Entry t,
int n) throws UninitializedEntrySpace
- It is same as getIfExistsType() couterpart except it returns copy of messages
- See Also:
- class, method
getEntryCount
public abstract int getEntryCount(Entry msg)
- It returns number of messages in the messagespace that matches the
message value as that of theEntry
- See Also:
- class, method
getEntryCount
public abstract int getEntryCount()
- It returns number of messages in the messagespace
- See Also:
- class, method
sync
public abstract void sync(int numEntrys) throws SingleThreadBlockException
- It blocks until message space contains numEntrys number of messages
- See Also:
- class, method
setHashSize
public abstract void setHashSize(int hsize)
- Modifiers
- See Also:
- class, method
put
public abstract void put(Entry t) throws UninitializedEntrySpace, SingleThreadBlockException
- Inserts a message into message space
- See Also:
- class, method
clear
public abstract void clear() throws SingleThreadBlockException
- remove all messages in the entry space
- See Also:
- class, method
barrier
public abstract void barrier(int num) throws InvalidArgumentException
- implements barrier
- See Also:
- class, method
sync
public abstract void sync(int num) throws InvalidArgumentException
- implements sync -- for barrier
- See Also:
- class, method
subscribe
public abstract void subscribe(String subscriberId,
JavaNOWEntryNotifier notifier,
JavaNOWEntryFilter filter) throws DuplicateSubscriberException
- subscribe to receive events of given type
- See Also:
- class, method
unsubscribe
public abstract void unsubscribe(String subscriberId) throws NoSuchSubscriberException
- unsubscribe to receive events of given type
- See Also:
- class, method
All Packages Class Hierarchy This Package Previous Next Index