edu.iu.harp.io

Class DataMap

java.lang.Object

edu.iu.harp.io.DataMap

public class DataMap
extends java.lang.Object

A wrapper for operations on queues associated with communication contextName and operationName. The main data structure is a map from contextName to a sub-map; The sub-map is a map from operationName to a BlockingQueue. The BlockingQueue is a queue for the Data. All operations are conducted on this map.

Constructor Summary

Constructors

Constructor and Description
DataMap()

Method Summary

Modifier and Type	Method and Description
void	clean() Clean the DataMap
void	cleanData(java.lang.String contextName) Clean the Data related to the context Invoke this when the context is done.
void	cleanOperationData(java.lang.String contextName, java.lang.String operationName) Clean the data of the operation under the context
void	putData(Data data) Put the Data to the DataMap
Data	waitAndGetData(java.lang.String contextName, java.lang.String operationName, long maxWaitTime) Wait and get the data from the queue of the operation under the context

Methods inherited from class java.lang.Object

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

Constructor Detail

DataMap

public DataMap()

Method Detail

waitAndGetData

public Data waitAndGetData(java.lang.String contextName,
                           java.lang.String operationName,
                           long maxWaitTime)
                    throws java.lang.InterruptedException

Wait and get the data from the queue of the operation under the context

Parameters:

contextName - the name of the context

operationName - the name of the operation

maxWaitTime - maximum waiting time

Returns:

the data

Throws:

java.lang.InterruptedException

putData

public void putData(Data data)

Put the Data to the DataMap

Parameters:

data - the Data to be put

cleanOperationData

public void cleanOperationData(java.lang.String contextName,
                               java.lang.String operationName)

Clean the data of the operation under the context

Parameters:

contextName - the name of the context

operationName - the name of the operation

cleanData

public void cleanData(java.lang.String contextName)

Clean the Data related to the context Invoke this when the context is done.

Parameters:

contextName - the name of the context

clean

public void clean()

Clean the DataMap