The AFB algorithm by Gershman, Meisels, and Zivan (JAIR'09). More...

Inheritance diagram for frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >:

[legend]

Classes
class	ConvergenceMessage
	A message reporting the convergence for a given component. More...
class	ClusterInfo
	Information about a cluster of variables owned by this agent. More...
class	ComponentInfo
	The information about a particular component of the constraint graph. More...

Public Member Functions
	AFB ()
	Empty constructor.
	AFB (Element parameters, DCOPProblemInterface< V, U > problem)
	The constructor called in "statistics gatherer" mode.
	AFB (DCOPProblemInterface< V, U > problem, Element parameters)
	Constructor.
void	reset ()
Collection< MessageType >	getMsgTypes ()
void	getStatsFromQueue (Queue queue)
void	setSilent (boolean silent)
void	setQueue (Queue queue)
void	notifyIn (Message msg)
HashMap< String, ArrayList< CurrentAssignment< V > > >	getAssignmentHistories ()
Map< String, V >	getCurrentSolution ()
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 Attributes
static MessageType	START_MSG_TYPE = AgentInterface.START_AGENT
	The type of the message telling AFB to start.
static MessageType	ORDER_MSG_TYPE = OrderMsg.ORDER_MSG_TYPE
	The types of the messages containing the chosen linear order of clusters of variables.
static MessageType	ORDER_STATS_MSG_TYPE = OrderMsg.STATS_MSG_TYPE
	The types of the messages containing the chosen linear order of clusters of variables sent to the stats gatherer.
static final MessageType	FB_CPA_TYPE = new MessageType ("AFB", "FB_CPA")
	The type of the FB_CPA messages, sent to request estimations from unassigned agents.
static final MessageType	CPA_MSG_TYPE = new MessageType ("AFB", "CPA")
	The type of the CPA messages, sent to the next variable in the ordering.
static final MessageType	FB_ESTIMATE_TYPE = new MessageType ("AFB", "FB_ESTIMATE")
	The type of the FB_ESTIMATE messages, sent as response to a FB_CPA message.
static final MessageType	OUTPUT_MSG_TYPE = new MessageType ("AFB", "Solution")
	The type of the message containing the optimal solution found.
static final MessageType	UB_MSG_TYPE = new MessageType ("AFB", "UB")
	The type of the messages broadcast by the last variable containing the current upper bound.
static final MessageType	STATS_MSG_TYPE = new MessageType ("AFB", "SolutionStats")
	The type of the message containing the optimal solution found sent to the stats gatherer.

Private Member Functions
void	start ()
	Parses the problem.
boolean	checkAllCostsNonNeg ()
void	processCpaMsg (CPAmsg< V, U > msgCast, Comparable<?> componentID, ComponentInfo compInfo, int clusterIndex, ClusterInfo info)
void	processFbEstimate (FbEstimateMsg< V, U > msgCast, Comparable<?> componentID, ComponentInfo compInfo, int clusterIndex, ClusterInfo info)
void	processFbCpa (FbCpaMsg< V, U > msgCast, ComponentInfo compInfo, int clusterIndex, ClusterInfo info)
void	processLinearOrdering (OrderMsg< V, U > msg, List< String > agents, Comparable<?> componentID, List< List< String > > order, ComponentInfo compInfo)
void	initiate (Comparable<?> compID, ComponentInfo compInfo)
	Chooses a first value for the first variable and starts the algorithm.
UtilitySolutionSpace< V, U >	h (final int i, ComponentInfo compInfo)
UtilitySolutionSpace< V, U >	f (int clusterIndex, ComponentInfo compInfo, PA< V, U > pa)
	Method to compute the value f for a given cluster and some assigned value.
UtilitySolutionSpace< V, U >	getLocalSpace (ComponentInfo compInfo, int clusterIndex, PA< V, U > pa, final boolean groundClusterVars)
	Method to compute the local space for a given cluster of variables and an assigned values, as a function of the variables in the current cluster.
void	assign_CPA (Comparable<?> compID, ComponentInfo compInfo, final int clusterIndex)
	Method to assign a value to a variable.
void	backtrack (Comparable<?> componentID, ComponentInfo compInfo, ClusterInfo info, int clusterIndex)
void	terminate (Comparable<?> compID, ComponentInfo compInfo)
	Sends output and termination messages.

Private Attributes
final boolean	verbose = false
	If set to true, information about each sent and received message will be printed to the console.
final boolean	convergence
	`true` when the convergence history is to be stored
HashMap< String, ArrayList< CurrentAssignment< V > > >	assignmentHistoriesMap
	For each variable, its assignment history.
HashMap< Comparable<?>, ComponentInfo >	compInfos
	The information about each component in the constraint graph.
HashMap< String, Comparable<?> >	compOfCluster
	For each cluster of variables, its component ID.
Queue	queue
	This module's queue.
DCOPProblemInterface< V, U >	problem
	The problem.
boolean	started = false
	Whether the module has already started the algorithm.
boolean	finished = false
	Whether the module has already finished the algorithm.
U	zero
	The 0 cost.
HashMap< String, V >	solution
	The solution.
Class< V >	valClass
	The class of V.
Class< V[]>	valArrayClass
	The class of V[].
LinkedList< SolutionMsg< V, U > >	pendingSolMsgs
	Used to store solution messages received before their corresponding linear order.
LinkedList< ConvergenceMessage< V > >	pendingConvMsgs
	Used to store convergence messages received by the stats gatherer before their corresponding linear order.
LinkedList< FbCpaMsg< V, U > >	pendingFbCpaMsgs
	For some clusters, a FbCpaMsg that was received before the var order message.
HashMap< String, CPAmsg< V, U > >	pendingCPAmsgs
	For some clusters, a CPAmsg that was received before the var order message.

Static Private Attributes
static final MessageType	CONV_STATS_MSG_TYPE = new MessageType ("AFB", "Convergence")
	The type of the message reporting the convergence for a given component.

Detailed Description

The AFB algorithm by Gershman, Meisels, and Zivan (JAIR'09).

Author: Alexandra Olteanu, Thomas Leaute

Parameters

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

Constructor & Destructor Documentation

◆ AFB() [1/3]

frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.AFB ( )

Empty constructor.

◆ AFB() [2/3]

frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.AFB	(	Element	parameters,
		DCOPProblemInterface< V, U >	problem )

The constructor called in "statistics gatherer" mode.

Parameters

parameters	the description of what statistics should be reported (currently unused)
problem	the overall problem

References problem.

◆ AFB() [3/3]

frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.AFB	(	DCOPProblemInterface< V, U >	problem,
		Element	parameters )

Constructor.

Parameters

problem	this agent's problem
parameters	the parameters for AFB

References problem.

Member Function Documentation

◆ assign_CPA()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.assign_CPA	(	Comparable<?>	compID,
		ComponentInfo	compInfo,
		final int	clusterIndex )

private

Method to assign a value to a variable.

Parameters

compID	the ID of the component in the constraint graph
compInfo	the information about the component in the constraint graph
clusterIndex	the index of the cluster for which we are assigning values

Referenced by assign_CPA(), initiate(), processCpaMsg(), and processFbEstimate().

Here is the call graph for this function:

◆ backtrack()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.backtrack	(	Comparable<?>	componentID,
		ComponentInfo	compInfo,
		ClusterInfo	info,
		int	clusterIndex )

private

Parameters

componentID	the ID of the component in the constraint graph
compInfo	the information about the component in the constraint graph
info	the CLusterInfo of the cluster for which we are assigning a value
clusterIndex	the index of the cluster for which we are assigning values

Todo: Backtrack messages don't need to contain the CPA.

Referenced by assign_CPA(), and processCpaMsg().

Here is the call graph for this function:

◆ checkAllCostsNonNeg()

boolean frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.checkAllCostsNonNeg ( )

private

Returns: true if all utilities in all spaces are non-negative, false otherwise

References frodo2.solutionSpaces.DCOPProblemInterface< V extends Addable< V >, U extends Addable >.getSolutionSpaces(), frodo2.solutionSpaces.SolutionSpace< V extends Addable< V > >.Iterator< V >.hasNext(), and zero.

Referenced by start().

Here is the call graph for this function:

◆ f()

UtilitySolutionSpace< V, U > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.f	(	int	clusterIndex,
		ComponentInfo	compInfo,
		PA< V, U >	pa )

private

Method to compute the value f for a given cluster and some assigned value.

Parameters

clusterIndex	Index of the cluster for which we want to compute f
compInfo	The ComponentInfo of the component the variable belongs to
pa	Current partial assignment.

Returns: f = The sum of the cost that i has with variables already in the CPA + h(v) at the same value.

References getLocalSpace(), and frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.h.

Referenced by assign_CPA(), and processFbCpa().

Here is the call graph for this function:

◆ getAssignmentHistories()

HashMap< String, ArrayList< CurrentAssignment< V > > > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.getAssignmentHistories ( )

See also: StatsReporterWithConvergence.getAssignmentHistories()

Implements frodo2.algorithms.StatsReporterWithConvergence< Val extends Addable< Val > >.

Referenced by frodo2.algorithms.afb.test.AFBagentTest< V extends Addable< V >, U extends Addable >.checkOutput().

◆ getCurrentSolution()

Map< String, V > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.getCurrentSolution ( )

See also: StatsReporterWithConvergence.getCurrentSolution()

Todo: Auto-generated method stub

Implements frodo2.algorithms.StatsReporterWithConvergence< Val extends Addable< Val > >.

◆ getLocalSpace()

UtilitySolutionSpace< V, U > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.getLocalSpace	(	ComponentInfo	compInfo,
		int	clusterIndex,
		PA< V, U >	pa,
		final boolean	groundClusterVars )

private

Method to compute the local space for a given cluster of variables and an assigned values, as a function of the variables in the current cluster.

Parameters

compInfo	The ComponentInfo of the current component.
clusterIndex	Index of the cluster for which we want to get the local space
pa	The PA
groundClusterVars	Whether the variables in the current cluster should also be grounded

Returns: The local space associated with this cluster and PA index

References getLocalSpace(), frodo2.solutionSpaces.UtilitySolutionSpace< V extends Addable< V >, U extends Addable >.join(), frodo2.solutionSpaces.UtilitySolutionSpace< V extends Addable< V >, U extends Addable >.slice(), frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ClusterInfo.spaces, and frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ClusterInfo.vars.

Referenced by f(), and getLocalSpace().

Here is the call graph for this function:

◆ getMsgTypes()

Collection< MessageType > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.getMsgTypes ( )

See also: StatsReporterWithConvergence.getMsgTypes()

Implements frodo2.communication.MessageListener< T >.

References frodo2.algorithms.AgentInterface< V extends Addable< V > >.AGENT_FINISHED, CPA_MSG_TYPE, FB_CPA_TYPE, FB_ESTIMATE_TYPE, ORDER_MSG_TYPE, OUTPUT_MSG_TYPE, START_MSG_TYPE, and UB_MSG_TYPE.

◆ getStatsFromQueue()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.getStatsFromQueue ( Queue queue )

See also: StatsReporterWithConvergence.getStatsFromQueue(Queue)

Implements frodo2.algorithms.StatsReporter.

References CONV_STATS_MSG_TYPE, ORDER_STATS_MSG_TYPE, and queue.

Referenced by frodo2.algorithms.afb.test.AFBagentTest< V extends Addable< V >, U extends Addable >.setUp().

◆ h()

UtilitySolutionSpace< V, U > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.h	(	final int	i,
		ComponentInfo	compInfo )

private

Parameters

i	The index of the cluster to compute h for
compInfo	the ComponentInfo of the component this variable belongs to

Returns: h for each possible value from the variable domain. The indexing of this array is the same as the indexing of the variable domain.

References frodo2.solutionSpaces.DCOPProblemInterface< V extends Addable< V >, U extends Addable >.getSolutionSpaces(), h(), frodo2.solutionSpaces.UtilitySolutionSpace< V extends Addable< V >, U extends Addable >.join(), problem, valArrayClass, and valClass.

Referenced by h().

Here is the call graph for this function:

◆ initiate()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.initiate	(	Comparable<?>	compID,
		ComponentInfo	compInfo )

private

Chooses a first value for the first variable and starts the algorithm.

Parameters

compID	the ID of the component in the constraint graph
compInfo	the information about the component in the constraint graph

References assign_CPA(), frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.clusterInfos, frodo2.solutionSpaces.ProblemInterface< V extends Addable< V >, U extends Addable >.getPlusInfUtility(), and frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.order.

Referenced by processLinearOrdering().

Here is the call graph for this function:

◆ notifyIn()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.notifyIn ( Message msg )

See also: StatsReporterWithConvergence.notifyIn(Message)

Implements frodo2.communication.IncomingMsgPolicyInterface< T >.

References frodo2.communication.MessageType.equals(), notifyIn(), and ORDER_STATS_MSG_TYPE.

Referenced by notifyIn(), and processLinearOrdering().

Here is the call graph for this function:

◆ processCpaMsg()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.processCpaMsg	(	CPAmsg< V, U >	msgCast,
		Comparable<?>	componentID,
		ComponentInfo	compInfo,
		int	clusterIndex,
		ClusterInfo	info )

private

Parameters

msgCast	A message of type CPA_MSG_TYPE containing the current PA
componentID	The current componentID
compInfo	The ComponentInfo corresponding to componentID
clusterIndex	The index of the current cluster
info	The ClusterInfo corresponding to clusterIndex

Here is the call graph for this function:

◆ processFbCpa()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.processFbCpa	(	FbCpaMsg< V, U >	msgCast,
		ComponentInfo	compInfo,
		int	clusterIndex,
		ClusterInfo	info )

private

Parameters

msgCast	A message of type FB_CPA.
compInfo	The ComponentInfo corresponding to componentID
clusterIndex	The index of the current cluster
info	The VarInfo corresponding to varIndex

Here is the call graph for this function:

◆ processFbEstimate()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.processFbEstimate	(	FbEstimateMsg< V, U >	msgCast,
		Comparable<?>	componentID,
		ComponentInfo	compInfo,
		int	clusterIndex,
		ClusterInfo	info )

private

Parameters

msgCast	A message of type FB_ESTIMATE
componentID	The current componentID
compInfo	The ComponentInfo corresponding to componentID
clusterIndex	The index of the current cluster
info	The ClusterInfo corresponding to clusterIndex

Here is the call graph for this function:

◆ processLinearOrdering()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.processLinearOrdering	(	OrderMsg< V, U >	msg,
		List< String >	agents,
		Comparable<?>	componentID,
		List< List< String > >	order,
		ComponentInfo	compInfo )

private

Parameters

msg	A message of type ORDER_MSG_TYPE
agents	The agent list received.
componentID	The componentID of the component for which we received the linear ordering.
order	The variable ordering received.
compInfo	The ComponentInfo corresponding to componentID

Here is the call graph for this function:

◆ reset()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.reset ( )

See also: StatsReporterWithConvergence.reset()

Implements frodo2.algorithms.StatsReporter.

◆ setQueue()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.setQueue ( Queue queue )

See also: StatsReporterWithConvergence.setQueue(Queue)

Implements frodo2.communication.MessageListener< T >.

References queue.

◆ setSilent()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.setSilent ( boolean silent )

See also: StatsReporterWithConvergence.setSilent(boolean)

Implements frodo2.algorithms.StatsReporter.

Referenced by frodo2.algorithms.afb.test.AFBagentTest< V extends Addable< V >, U extends Addable >.setUp().

◆ start()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.start ( )

private

Parses the problem.

References checkAllCostsNonNeg(), frodo2.solutionSpaces.ProblemInterface< V extends Addable< V >, U extends Addable >.getZeroUtility(), and frodo2.solutionSpaces.DCOPProblemInterface< V extends Addable< V >, U extends Addable >.maximize().

Here is the call graph for this function:

◆ terminate()

void frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable< U > >.terminate	(	Comparable<?>	compID,
		ComponentInfo	compInfo )

private

Sends output and termination messages.

Parameters

compID	the ID of the component in the constraint graph
compInfo	the information about the component in the constraint graph

References frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.agents, frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.B, frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.bestSol, frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.history, OUTPUT_MSG_TYPE, frodo2.communication.Queue.sendMessage(), frodo2.communication.Queue.sendMessageToMulti(), frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.solutionSent, frodo2.algorithms.AgentInterface< V extends Addable< V > >.STATS_MONITOR, and verbose.

Referenced by assign_CPA(), and backtrack().

Here is the call graph for this function:

Member Data Documentation

◆ assignmentHistoriesMap

HashMap< String, ArrayList< CurrentAssignment<V> > > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.assignmentHistoriesMap

private

For each variable, its assignment history.

◆ compInfos

HashMap<Comparable<?>, ComponentInfo> frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.compInfos

private

The information about each component in the constraint graph.

◆ compOfCluster

HashMap<String, Comparable<?> > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.compOfCluster

private

For each cluster of variables, its component ID.

◆ CONV_STATS_MSG_TYPE

final MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.CONV_STATS_MSG_TYPE = new MessageType ("AFB", "Convergence")

staticprivate

The type of the message reporting the convergence for a given component.

Referenced by frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ConvergenceMessage< V extends Addable< V > >.ConvergenceMessage(), frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ConvergenceMessage< V extends Addable< V > >.ConvergenceMessage(), and getStatsFromQueue().

◆ convergence

final boolean frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.convergence

private

true when the convergence history is to be stored

Referenced by assign_CPA(), frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.ComponentInfo(), and frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ComponentInfo.ComponentInfo().

◆ CPA_MSG_TYPE

final MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.CPA_MSG_TYPE = new MessageType ("AFB", "CPA")

static

The type of the CPA messages, sent to the next variable in the ordering.

Referenced by frodo2.algorithms.afb.CPAmsg< V extends Addable< V >, U extends Addable >.CPAmsg(), frodo2.algorithms.afb.CPAmsg< V extends Addable< V >, U extends Addable >.CPAmsg(), and getMsgTypes().

◆ FB_CPA_TYPE

final MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.FB_CPA_TYPE = new MessageType ("AFB", "FB_CPA")

static

The type of the FB_CPA messages, sent to request estimations from unassigned agents.

Referenced by frodo2.algorithms.afb.FbCpaMsg< V extends Addable< V >, U extends Addable >.FbCpaMsg(), frodo2.algorithms.afb.FbCpaMsg< V extends Addable< V >, U extends Addable >.FbCpaMsg(), and getMsgTypes().

◆ FB_ESTIMATE_TYPE

final MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.FB_ESTIMATE_TYPE = new MessageType ("AFB", "FB_ESTIMATE")

static

The type of the FB_ESTIMATE messages, sent as response to a FB_CPA message.

Referenced by frodo2.algorithms.afb.FbEstimateMsg< V extends Addable< V >, U extends Addable >.FbEstimateMsg(), frodo2.algorithms.afb.FbEstimateMsg< V extends Addable< V >, U extends Addable >.FbEstimateMsg(), and getMsgTypes().

◆ finished

boolean frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.finished = false

private

Whether the module has already finished the algorithm.

◆ ORDER_MSG_TYPE

MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ORDER_MSG_TYPE = OrderMsg.ORDER_MSG_TYPE

static

The types of the messages containing the chosen linear order of clusters of variables.

Referenced by getMsgTypes().

◆ ORDER_STATS_MSG_TYPE

MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ORDER_STATS_MSG_TYPE = OrderMsg.STATS_MSG_TYPE

static

The types of the messages containing the chosen linear order of clusters of variables sent to the stats gatherer.

Referenced by getStatsFromQueue(), and notifyIn().

◆ OUTPUT_MSG_TYPE

final MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.OUTPUT_MSG_TYPE = new MessageType ("AFB", "Solution")

static

The type of the message containing the optimal solution found.

Referenced by getMsgTypes(), and terminate().

◆ pendingConvMsgs

LinkedList< ConvergenceMessage<V> > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.pendingConvMsgs

private

Used to store convergence messages received by the stats gatherer before their corresponding linear order.

◆ pendingCPAmsgs

HashMap< String, CPAmsg<V, U> > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.pendingCPAmsgs

private

For some clusters, a CPAmsg that was received before the var order message.

◆ pendingFbCpaMsgs

LinkedList< FbCpaMsg<V, U> > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.pendingFbCpaMsgs

private

For some clusters, a FbCpaMsg that was received before the var order message.

◆ pendingSolMsgs

LinkedList< SolutionMsg<V, U> > frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.pendingSolMsgs

private

Used to store solution messages received before their corresponding linear order.

◆ problem

DCOPProblemInterface<V, U> frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.problem

private

The problem.

Referenced by AFB(), AFB(), frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.ClusterInfo.ClusterInfo(), h(), and processLinearOrdering().

◆ queue

Queue frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.queue

private

This module's queue.

Referenced by getStatsFromQueue(), and setQueue().

◆ solution

HashMap<String, V> frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.solution

private

The solution.

◆ START_MSG_TYPE

MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.START_MSG_TYPE = AgentInterface.START_AGENT

static

The type of the message telling AFB to start.

Referenced by getMsgTypes().

◆ started

boolean frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.started = false

private

Whether the module has already started the algorithm.

◆ STATS_MSG_TYPE

final MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.STATS_MSG_TYPE = new MessageType ("AFB", "SolutionStats")

static

The type of the message containing the optimal solution found sent to the stats gatherer.

◆ UB_MSG_TYPE

final MessageType frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.UB_MSG_TYPE = new MessageType ("AFB", "UB")

static

The type of the messages broadcast by the last variable containing the current upper bound.

Referenced by assign_CPA(), and getMsgTypes().

◆ valArrayClass

Class<V[]> frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.valArrayClass

private

The class of V[].

Referenced by h(), and processLinearOrdering().

◆ valClass

Class<V> frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.valClass

private

The class of V.

Referenced by h(), and processLinearOrdering().

◆ verbose

final boolean frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.verbose = false

private

If set to true, information about each sent and received message will be printed to the console.

Referenced by assign_CPA(), backtrack(), processCpaMsg(), processFbCpa(), processFbEstimate(), and terminate().

◆ zero

U frodo2.algorithms.afb.AFB< V extends Addable< V >, U extends Addable >.zero

private

The 0 cost.

Referenced by checkAllCostsNonNeg().

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

src/frodo2/algorithms/afb/AFB.java

Classes

Public Member Functions

Static Public Attributes

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ AFB() [1/3]

◆ AFB() [2/3]

◆ AFB() [3/3]

Member Function Documentation

◆ assign_CPA()

◆ backtrack()

◆ checkAllCostsNonNeg()

◆ f()

◆ getAssignmentHistories()

◆ getCurrentSolution()

◆ getLocalSpace()

◆ getMsgTypes()

◆ getStatsFromQueue()

◆ h()

◆ initiate()

◆ notifyIn()

◆ processCpaMsg()

◆ processFbCpa()

◆ processFbEstimate()

◆ processLinearOrdering()

◆ reset()

◆ setQueue()

◆ setSilent()

◆ start()

◆ terminate()

Member Data Documentation

◆ assignmentHistoriesMap

◆ compInfos

◆ compOfCluster

◆ CONV_STATS_MSG_TYPE

◆ convergence

◆ CPA_MSG_TYPE

◆ FB_CPA_TYPE

◆ FB_ESTIMATE_TYPE

◆ finished

◆ ORDER_MSG_TYPE

◆ ORDER_STATS_MSG_TYPE

◆ OUTPUT_MSG_TYPE

◆ pendingConvMsgs

◆ pendingCPAmsgs

◆ pendingFbCpaMsgs

◆ pendingSolMsgs

◆ problem

◆ queue

◆ solution

◆ START_MSG_TYPE

◆ started

◆ STATS_MSG_TYPE

◆ UB_MSG_TYPE

◆ valArrayClass

◆ valClass

◆ verbose

◆ zero