grinda.impl
Class BlockingOperationManager

java.lang.Object
  java.lang.Thread
      grinda.impl.AbstractSubscribeManager
          grinda.impl.BlockingOperationManager

All Implemented Interfaces:

java.lang.Runnable

public class BlockingOperationManager
extends AbstractSubscribeManager

Handles tuples just inserted notifying eventually the clients that are blocked upon operations like take

Nested Class Summary

Nested classes/interfaces inherited from class grinda.impl.AbstractSubscribeManager

AbstractSubscribeManager.HandlingInfo

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()

Method Summary

void	addListener(TupleSpaceOperation op, java.lang.String dst) Adds a listener for a blocking operation
boolean	handle(TupleSpaceResult r) Handles result coming from other peers
void	removeListener(TupleSpaceOperation op, java.lang.String dst) Removes a listener
void	setTupleSpaceSet(TupleSpaceSet s)

Methods inherited from class grinda.impl.AbstractSubscribeManager

enqueue, run, terminate

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()

Method Detail

setTupleSpaceSet

public void setTupleSpaceSet(TupleSpaceSet s)

handle

public boolean handle(TupleSpaceResult r)

Handles result coming from other peers

Parameters:

r - TupleSpaceResult

Returns:

true

addListener

public void addListener(TupleSpaceOperation op,
                        java.lang.String dst)

Adds a listener for a blocking operation

Specified by:

addListener in class AbstractSubscribeManager

Parameters:

op - the operation

dst - url of the listener

removeListener

public void removeListener(TupleSpaceOperation op,
                           java.lang.String dst)

Description copied from class: AbstractSubscribeManager

Removes a listener

Specified by:

removeListener in class AbstractSubscribeManager

Parameters:

op - the operation template to listen to

dst - listener address