grinda.client
Class BlockingOperationManager

java.lang.Object
  java.lang.Thread
      grinda.client.BlockingOperationManager

All Implemented Interfaces:

java.lang.Runnable

public class BlockingOperationManager
extends java.lang.Thread

Manages the locks due a blocking operation (i.e. take...). This class is the implementation of a stub allowing an external entity to execute its methods.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

BlockingOperationManager()
Creates a new operation manager

Method Summary

void	addListener(TupleSpaceOperation op, Semaphore s)
void	deliver(java.util.List topicPath, EndpointReferenceType producer, java.lang.Object message) This method is called by the service to notify the insertion of a tuple
java.lang.String	getAddress()
void	run()
void	setAddress(java.lang.String addr)
void	stopListening() Blocks this process before exiting

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BlockingOperationManager

public BlockingOperationManager()

Creates a new operation manager

Method Detail

deliver

public void deliver(java.util.List topicPath,
                    EndpointReferenceType producer,
                    java.lang.Object message)

This method is called by the service to notify the insertion of a tuple

Parameters:

n - informations about the insertion

getAddress

public java.lang.String getAddress()

setAddress

public void setAddress(java.lang.String addr)

addListener

public void addListener(TupleSpaceOperation op,
                        Semaphore s)

stopListening

public void stopListening()

Blocks this process before exiting

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread