All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class javaNOW.RemoteEntrySpace

java.lang.Object
   |
   +----javaNOW.RemoteEntrySpace

public class RemoteEntrySpace

extends Object

implements EntrySpaceI

RemoteEntrySpace(String, JavaNOWAPI)

Constructors

addWaitingEntrySpaceKeys(EntrySpaceKey)

keeps count of sync for EntrySpaces

barrier(int)

barrier: waits numEntrys number of processes have executed this operation.

clear()

Removes all message from a entrySpace

eval(ActiveEntry, Object)

It is used to evaluate a message method (execute()) and inserts the output of that method in message space.

finalize()

get(String, Entry)

Removes message from message space in blocking fashion.

getEntryCount()

It returns number of messages in the EntrySpace

getEntryCount(Entry)

It returns number of messages in the EntrySpace that matches the message value as that of entry

getIfExists(Entry)

Removes message from message space in nonblocking fashion.

getIfExistsType(Entry)

It returns vector of messages that match the message value of the entry

getIfExistsType(Entry, int)

It returns nth message in the message space that matches the message value as that of entry

notifyIfWaiting()

Wake any processes who are waiting in sync

present(String, 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 nonblocking 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() counterpart except it returns copy of messages

removeWaitingEntrySpaceKeys(EntrySpaceKey)

remove EntrySpace from list of waiting EntrySpaces

sync(int)

waits until the message space contains numEntrys number of messages

validateArgument(Object)

waitAllHosts()

waitAllHosts(long)

waitUntilFound(Entry)

Waits until message exist in message spaces (blocking)

 public RemoteEntrySpace(String name,
                         JavaNOWAPI api)

Constructors

See Also:

class, method

 protected void finalize() throws Throwable

Overrides:

finalize in class Object

 public void put(Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

Inserts a message into message space

See Also:

class, method

 public Entry getIfExists(Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

Removes message from message space in nonblocking fashion. If message does not exist, it returns null

See Also:

class, method

 public Entry get(String entrySpace,
                  Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

Removes message from message space in blocking fashion. If message does not exist, it blocks until it is inserted

See Also:

class, method

 public boolean present(String entrySpace,
                        Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

Returns true if message exist in message spaces (nonblocking)

See Also:

class, method

 public void waitUntilFound(Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

Waits until message exist in message spaces (blocking)

See Also:

class, method

 public Entry readIfExists(Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

Returns a copy of message from message space in nonblocking fashion. If message does not exist, it returns null

See Also:

class, method

 public Entry read(Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

Returns a copy of message from message space in nonblocking fashion. If message does not exist, it blocks until it is inserted

See Also:

class, method

 public void eval(ActiveEntry entry,
                  Object arg) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

It is used to evaluate a message method (execute()) and inserts the output of that method in message space.

See Also:

class, method

 public Entry[] getIfExistsType(Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

It returns vector of messages that match the message value of the entry

See Also:

class, method

 public Entry getIfExistsType(Entry entry,
                              int n) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

It returns nth message in the message space that matches the message value as that of entry

See Also:

class, method

 public Entry[] readIfExistsType(Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

It is same as getIfExistsType() couterpart except it returns copy of messages

See Also:

class, method

 public Entry readIfExistsType(Entry entry,
                               int n) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

It is same as getIfExistsType() counterpart except it returns copy of messages

See Also:

class, method

 public int getEntryCount(Entry entry) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

It returns number of messages in the EntrySpace that matches the message value as that of entry

See Also:

class, method

 public int getEntryCount() throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

It returns number of messages in the EntrySpace

See Also:

class, method

 public void barrier(int numEntrys) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

barrier: waits numEntrys number of processes have executed this operation.

See Also:

class, method

 public void sync(int numEntrys) throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

waits until the message space contains numEntrys number of messages

See Also:

class, method

 public void clear() throws InvalidArgumentException, NotSerializableException, JavaNOWShutException

Removes all message from a entrySpace

See Also:

class, method

 protected synchronized void addWaitingEntrySpaceKeys(EntrySpaceKey ts)

keeps count of sync for EntrySpaces

See Also:

class, method

 protected synchronized void removeWaitingEntrySpaceKeys(EntrySpaceKey ts)

remove EntrySpace from list of waiting EntrySpaces

See Also:

class, method

 protected void waitAllHosts(long milliseconds)

 protected void waitAllHosts()

 protected void notifyIfWaiting() throws SingleThreadBlockException

Wake any processes who are waiting in sync

See Also:

class, method

 protected void validateArgument(Object arg) throws InvalidArgumentException, NotSerializableException

All Packages  Class Hierarchy  This Package  Previous  Next  Index