The listener that checks the messages sent by the UTILpropagation listeners. More...

Inheritance diagram for frodo2.algorithms.dpop.test.UTILpropagationTest >.Listener:

[legend]

Public Member Functions
	Listener (boolean useTCP, boolean useXML, Element parameters, Class< ? extends StatsReporter > listenerClass, boolean withAnonymVars) throws IOException, NoSuchMethodException, IllegalArgumentException, InstantiationException, IllegalAccessException, InvocationTargetException, ClassNotFoundException
	Constructor that tests the UTIL propagation protocol on a random DFS.
void	waitForOutputs ()
	Waits for the outputs of the module and checks their validity.
Collection< MessageType >	getMsgTypes ()
	Listens to the outputs of the UTIL propagation protocol.
void	notifyIn (Message msg)
void	setQueue (Queue queue)
	Does nothing.
Public Member Functions inherited from frodo2.communication.IncomingMsgPolicyInterface< T >
default void	notifyIn (Message msg, Object toAgent)
	Notifies the listener of an incoming message.

Protected Member Functions
void	setUpPrelimModules (Queue queue, DCOPProblemInterface< AddableInteger, U > subProblem)
	Sets up modules that are necessary for the module under test to work.
void	checkOutput ()
	Checks that the output of the module is correct.
Hypercube< AddableInteger, U >	simulateUTIL (String var)
	Simulates UTIL propagation on the subtree rooted at the input variable, while checking separators.

Protected Attributes
Integer	nbrMsgsRemaining
	The number of output messages remaining to be received from the UTIL propagation protocol.
final ReentrantLock	finished_lock = new ReentrantLock ()
	Used to make the test thread wait.
final Condition	finished = finished_lock.newCondition()
	Used to wake up the test thread when all agents have finished.
Map< String, UtilitySolutionSpace< AddableInteger, U > >	hypercubes
	For each variable, the constraint it is responsible for enforcing.
UTILpropagation< AddableInteger, U >	statsGatherer
	The stats gatherer.
XCSPparser< AddableInteger, U >	parser
	The parser for the problem.

Private Attributes
U	optTotalUtil
	Optimal, total utility across all connected components.
Object	optTotalUtil_lock = new Object ()
	Used to synchronize access to optTotalUtil, which can be `null`.
Map< String, QueueOutputPipeInterface >	pipes
	The pipes of the queue network, indexed by agent name.
Queue	myQueue
	The Listener's own queue.
List< ? extends UtilitySolutionSpace< AddableInteger, U > >	spaces
	The constraints in the problem.

Detailed Description

The listener that checks the messages sent by the UTILpropagation listeners.

Constructor & Destructor Documentation

frodo2.algorithms.dpop.test.UTILpropagationTest< U extends Addable< U > >.Listener.Listener	(	boolean	useTCP,
		boolean	useXML,
		Element	parameters,
		Class< ? extends StatsReporter >	listenerClass,
		boolean	withAnonymVars ) throws IOException, NoSuchMethodException, IllegalArgumentException, InstantiationException, IllegalAccessException, InvocationTargetException, ClassNotFoundException

Constructor that tests the UTIL propagation protocol on a random DFS.

Parameters

useTCP	`true` whether TCP pipes should be used instead of QueueIOPipes
useXML	whether we should use the constructor that takes in XML elements or the manual constructor
parameters	the parameters for the module under test
listenerClass	the class of the listener under test
withAnonymVars	`true` if anonymous variables should be taken into account when parsing the problem

Exceptions

IOException	if the method fails to create pipes
NoSuchMethodException	if the UTILpropagation class does not have a public constructor that takes in a ProblemInterface and a JDOM Element
InvocationTargetException	if the UTILpropagation constructor throws an exception
IllegalAccessException	if the UTILpropagation class does not have a public constructor that takes in a ProblemInterface and a JDOM Element
InstantiationException	if the instantiation of UTILpropagation failed
IllegalArgumentException	if an error occurs in passing arguments to the constructor of UTILpropagation
ClassNotFoundException	if the utility class is unknown

Here is the call graph for this function:

void frodo2.algorithms.dpop.test.UTILpropagationTest >.Listener.checkOutput ( )

protected

Checks that the output of the module is correct.

Here is the call graph for this function:

Collection< MessageType > frodo2.algorithms.dpop.test.UTILpropagationTest >.Listener.getMsgTypes ( )

Listens to the outputs of the UTIL propagation protocol.

void frodo2.algorithms.dpop.test.UTILpropagationTest >.Listener.notifyIn ( Message msg )

Referenced by notifyIn().

Here is the call graph for this function:

void frodo2.algorithms.dpop.test.UTILpropagationTest >.Listener.setQueue ( Queue queue )

Does nothing.

See also: frodo2.communication.IncomingMsgPolicyInterface.setQueue(frodo2.communication.Queue)

void frodo2.algorithms.dpop.test.UTILpropagationTest< U extends Addable< U > >.Listener.setUpPrelimModules	(	Queue	queue,
		DCOPProblemInterface< AddableInteger, U >	subProblem )