JUnit test for ADOPTagent. More...

Inheritance diagram for frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >:

[legend]

Public Member Functions
	ADOPTagentTest (boolean useCentralMailer, boolean useDelay, MessageType startMsgType, Class< V > domClass, Class< U > utilClass, boolean useXCSP, boolean useTCP, boolean countNCCCs, boolean maximize, int sign)
	Creates a JUnit test case.
void	setUp () throws Exception
void	testRandom ()
	Tests the DPOPagent on a random problem.
Collection< MessageType >	getMsgTypes ()
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.

Static Public Member Functions
static TestSuite	suite ()

Protected Member Functions
void	tearDown () throws Exception

Private Member Functions
void	setStartMsgType (MessageType startMsgType) throws JDOMException
	Sets the type of the start message for all modules.
void	setStartMsgType (Element messages, MessageType startMsgType)
	Overwrites the type of the start messages.

Private Attributes
final int	maxNbrVars = 5
	Maximum number of variables in the problem.
final int	maxNbrEdges = 15
	Maximum number of binary constraints in the problem.
final int	maxNbrAgents = 5
	Maximum number of agents.
Queue	queue
	The queue used to listen to the agents.
Map< Object, QueueOutputPipeInterface >	pipes
	For each agent, the output pipe to it.
QueueIOPipe	pipe
	The testers pipe.
Map< String, AgentInterface< V > >	agents
	All agents, indexed by their IDs.
int	nbrAgents
	Total number of agents.
int	nbrMsgsReceived
	Used to track the number of various types of messages received from the agents.
int	nbrAgentsFinished
	Number of agents finished.
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.
boolean	countNCCCs = false
	Whether we should count Non-Concurrent Constraint Checks.
SolutionCollector< V, U >	solCollector
	The solution collector listening for the solution.
Preprocessing< V, U >	preProcessingTester
	Used to check the output of the preprocessing listener.
MessageType	startMsgType
	The type of the start message.
Document	agentDesc
	The description of the agent.
boolean	useCentralMailer
	`true` if the algorithm must be tested with the central mailer
DCOPProblemInterface< V, U >	problem
	The random problem.
boolean	useDelay
	`true` when the central mailer must be tested with delays
CentralMailer	mailman
	The CentralMailer.
Class< V >	domClass
	The class of variable values.
Class< U >	utilClass
	The class of utility values.
boolean	useXCSP
	Whether to use XCSP.
boolean	useTCP
	Whether to use TCP pipes.
final boolean	maximize
	Whether to test on maximization problem.
final int	sign
	The required sign for the costs/utilities.

Detailed Description

JUnit test for ADOPTagent.

Author: Thomas Leaute, Brammert Ottens

Parameters

<V>	the type used for variable values
<U>	the type used for utility values

Constructor & Destructor Documentation

◆ ADOPTagentTest()

frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable< U > >.ADOPTagentTest	(	boolean	useCentralMailer,
		boolean	useDelay,
		MessageType	startMsgType,
		Class< V >	domClass,
		Class< U >	utilClass,
		boolean	useXCSP,
		boolean	useTCP,
		boolean	countNCCCs,
		boolean	maximize,
		int	sign )

Creates a JUnit test case.

Parameters

useCentralMailer	`true` when the central mailer should be tested
useDelay	`true` when the central mailer must be tested with delays
startMsgType	the type of the start message
domClass	the class of variable values
utilClass	the class of utility values
useXCSP	whether to use XCSP
useTCP	whether TCP pipes should be used for communication between agents
countNCCCs	whether we should tell the agent to count NCCCs
maximize	Whether to test on maximization problem
sign	The required sign for the costs/utilities

References countNCCCs, domClass, maximize, sign, startMsgType, useCentralMailer, useDelay, useTCP, useXCSP, and utilClass.

Referenced by suite().

Member Function Documentation

◆ getMsgTypes()

Collection< MessageType > frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.getMsgTypes ( )

See also: IncomingMsgPolicyInterface.getMsgTypes()

Implements frodo2.communication.MessageListener< T >.

References frodo2.algorithms.AgentInterface< V extends Addable< V > >.AGENT_CONNECTED, frodo2.algorithms.AgentInterface< V extends Addable< V > >.AGENT_FINISHED, frodo2.algorithms.AgentInterface< V extends Addable< V > >.LOCAL_AGENT_ADDRESS_REQUEST, and frodo2.algorithms.AgentInterface< V extends Addable< V > >.LOCAL_AGENT_REPORTING.

◆ notifyIn()

void frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.notifyIn ( Message msg )

See also: IncomingMsgPolicyInterface.notifyIn(Message)

Implements frodo2.communication.IncomingMsgPolicyInterface< T >.

References frodo2.algorithms.AgentInterface< V extends Addable< V > >.LOCAL_AGENT_REPORTING, nbrAgents, notifyIn(), pipe, and pipes.

Referenced by notifyIn().

Here is the call graph for this function:

◆ setQueue()

void frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.setQueue ( Queue queue )

Does nothing.

See also: IncomingMsgPolicyInterface.setQueue(Queue)

Implements frodo2.communication.MessageListener< T >.

References queue.

◆ setStartMsgType() [1/2]

void frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable< U > >.setStartMsgType	(	Element	messages,
		MessageType	startMsgType )

private

Overwrites the type of the start messages.

Parameters

messages	messages element
startMsgType	the new type of the start messages

References startMsgType.

◆ setStartMsgType() [2/2]

void frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.setStartMsgType ( MessageType startMsgType ) throws JDOMException

private

Sets the type of the start message for all modules.

Parameters

startMsgType the new type for the start message

Exceptions

JDOMException if parsing the agent configuration file failed

References agentDesc, setStartMsgType(), frodo2.algorithms.AgentInterface< V extends Addable< V > >.START_AGENT, and startMsgType.

Referenced by setStartMsgType(), and setUp().

Here is the call graph for this function:

◆ setUp()

void frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.setUp ( ) throws Exception

See also: junit.framework.TestCase#setUp()

References agentDesc, countNCCCs, frodo2.algorithms.test.AllTests.createRandProblem(), domClass, mailman, maxNbrAgents, maxNbrEdges, maxNbrVars, nbrAgentsFinished, nbrMsgsReceived, frodo2.algorithms.XCSPparser< V extends Addable< V >, U extends Addable >.parse(), pipes, preProcessingTester, problem, queue, frodo2.algorithms.Problem< V extends Addable< V >, U extends Addable >.reset(), frodo2.algorithms.Problem< V extends Addable< V >, U extends Addable >.setDomClass(), frodo2.algorithms.XCSPparser< V extends Addable< V >, U extends Addable >.setDomClass(), setStartMsgType(), frodo2.algorithms.AbstractProblem< V extends Addable< V >, U extends Addable >.setUtilClass(), frodo2.algorithms.XCSPparser< V extends Addable< V >, U extends Addable >.setUtilClass(), solCollector, frodo2.algorithms.AgentInterface< V extends Addable< V > >.STATS_MONITOR, and utilClass.

Here is the call graph for this function:

◆ suite()

TestSuite frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.suite ( )

static

Returns: the test suite

Bug: ADOPT does not seem to handle message delays.

Bug: The first test fails

References ADOPTagentTest(), and suite().

Referenced by suite(), and frodo2.algorithms.adopt.test.AllTestsADOPT.suite().

Here is the call graph for this function:

◆ tearDown()

void frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.tearDown ( ) throws Exception

protected

See also: junit.framework.TestCase#tearDown()

References agents, mailman, pipe, pipes, preProcessingTester, problem, queue, and solCollector.

◆ testRandom()

void frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.testRandom ( )

Tests the DPOPagent on a random problem.

References agentDesc, agents, frodo2.algorithms.AgentFactory< V extends Addable< V >, U extends Addable >.createAgent(), frodo2.communication.mailer.CentralMailer.execute(), frodo2.solutionSpaces.ProblemInterface< V extends Addable< V >, U extends Addable >.getAgent(), frodo2.algorithms.adopt.Preprocessing< Val extends Addable< Val >, U extends Addable >.getReportedHeuristics(), mailman, nbrAgents, nbrAgentsFinished, pipe, problem, queue, solCollector, frodo2.algorithms.AbstractDCOPsolver< V extends Addable< V >, U extends Addable, S extends Solution< V, U >.solve(), frodo2.timeout, useCentralMailer, and useTCP.

Here is the call graph for this function:

Member Data Documentation

◆ agentDesc

Document frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.agentDesc

private

The description of the agent.

Referenced by setStartMsgType(), setUp(), and testRandom().

◆ agents

Map< String, AgentInterface<V> > frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.agents

private

All agents, indexed by their IDs.

Referenced by tearDown(), and testRandom().

◆ countNCCCs

boolean frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.countNCCCs = false

private

Whether we should count Non-Concurrent Constraint Checks.

Referenced by ADOPTagentTest(), and setUp().

◆ domClass

Class<V> frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.domClass

private

The class of variable values.

Referenced by ADOPTagentTest(), and setUp().

◆ finished

final Condition frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.finished = finished_lock.newCondition()

private

Used to wake up the test thread when all agents have finished.

◆ finished_lock

final ReentrantLock frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.finished_lock = new ReentrantLock ()

private

Used to make the test thread wait.

◆ mailman

CentralMailer frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.mailman

private

The CentralMailer.

Referenced by setUp(), tearDown(), and testRandom().

◆ maximize

final boolean frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.maximize

private

Whether to test on maximization problem.

Referenced by ADOPTagentTest().

◆ maxNbrAgents

final int frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.maxNbrAgents = 5

private

Maximum number of agents.

Referenced by setUp().

◆ maxNbrEdges

final int frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.maxNbrEdges = 15

private

Maximum number of binary constraints in the problem.

Referenced by setUp().

◆ maxNbrVars

final int frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.maxNbrVars = 5

private

Maximum number of variables in the problem.

Note: Must be at least 2.

Referenced by setUp().

◆ nbrAgents

int frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.nbrAgents

private

Total number of agents.

Referenced by notifyIn(), and testRandom().

◆ nbrAgentsFinished

int frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.nbrAgentsFinished

private

Number of agents finished.

Referenced by setUp(), and testRandom().

◆ nbrMsgsReceived

int frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.nbrMsgsReceived

private

Used to track the number of various types of messages received from the agents.

Referenced by setUp().

◆ pipe

QueueIOPipe frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.pipe

private

The testers pipe.

Referenced by notifyIn(), tearDown(), and testRandom().

◆ pipes

Map<Object, QueueOutputPipeInterface> frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.pipes

private

For each agent, the output pipe to it.

Referenced by notifyIn(), setUp(), and tearDown().

◆ preProcessingTester

Preprocessing<V, U> frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.preProcessingTester

private

Used to check the output of the preprocessing listener.

Referenced by setUp(), and tearDown().

◆ problem

DCOPProblemInterface<V, U> frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.problem

private

The random problem.

Referenced by setUp(), tearDown(), and testRandom().

◆ queue

Queue frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.queue

private

The queue used to listen to the agents.

Referenced by setQueue(), setUp(), tearDown(), and testRandom().

◆ sign

final int frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.sign

private

The required sign for the costs/utilities.

Referenced by ADOPTagentTest().

◆ solCollector

SolutionCollector<V, U> frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.solCollector

private

The solution collector listening for the solution.

Referenced by setUp(), tearDown(), and testRandom().

◆ startMsgType

MessageType frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.startMsgType

private

The type of the start message.

Referenced by ADOPTagentTest(), setStartMsgType(), and setStartMsgType().

◆ useCentralMailer

boolean frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.useCentralMailer

private

true if the algorithm must be tested with the central mailer

Referenced by ADOPTagentTest(), and testRandom().

◆ useDelay

boolean frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.useDelay

private

true when the central mailer must be tested with delays

Referenced by ADOPTagentTest().

◆ useTCP

boolean frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.useTCP

private

Whether to use TCP pipes.

Referenced by ADOPTagentTest(), and testRandom().

◆ useXCSP

boolean frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.useXCSP

private

Whether to use XCSP.

Referenced by ADOPTagentTest().

◆ utilClass

Class frodo2.algorithms.adopt.test.ADOPTagentTest< V extends Addable< V >, U extends Addable >.utilClass

private

The class of utility values.

Referenced by ADOPTagentTest(), and setUp().

The documentation for this class was generated from the following file:

src/frodo2/algorithms/adopt/test/ADOPTagentTest.java

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ ADOPTagentTest()

Member Function Documentation

◆ getMsgTypes()

◆ notifyIn()

◆ setQueue()

◆ setStartMsgType() [1/2]

◆ setStartMsgType() [2/2]

◆ setUp()

◆ suite()

◆ tearDown()

◆ testRandom()

Member Data Documentation

◆ agentDesc

◆ agents

◆ countNCCCs

◆ domClass

◆ finished

◆ finished_lock

◆ mailman

◆ maximize

◆ maxNbrAgents

◆ maxNbrEdges

◆ maxNbrVars

◆ nbrAgents

◆ nbrAgentsFinished

◆ nbrMsgsReceived

◆ pipe

◆ pipes

◆ preProcessingTester

◆ problem

◆ queue

◆ sign

◆ solCollector

◆ startMsgType

◆ useCentralMailer

◆ useDelay

◆ useTCP

◆ useXCSP

◆ utilClass