CEnvironment.java

Go to the documentation of this file.

package org.lightvoting.simulation.environment;

import org.lightjason.agentspeak.language.CLiteral;
import org.lightjason.agentspeak.language.CRawTerm;
import org.lightjason.agentspeak.language.ILiteral;
import org.lightvoting.simulation.agent.CChairAgent;
import org.lightvoting.simulation.agent.CVotingAgent;

import java.util.Collections;
import java.util.LinkedList;
import java.util.List;


public final class CEnvironment
{
    private final List<CGroup> m_groups;

    private final List<CVotingAgent> m_agentList;

    // Index of the last activated agent
    private int m_currentIndex;

    private boolean m_firstActivated;
    private final String m_fileName;

    public CEnvironment( final int p_size, final String p_fileName )
    {
        m_fileName = p_fileName;
        m_groups = Collections.synchronizedList( new LinkedList<>() );
        m_agentList = new LinkedList<>();
    }

    public final void initialset( final CVotingAgent p_votingAgent )
    {
        m_agentList.add( p_votingAgent );

        if  ( !m_firstActivated )
        {

            final CVotingAgent l_firstAgent = m_agentList.get( 0 );

            l_firstAgent.sleep( 0 );
            l_firstAgent.getChair().sleep( 0 );
            m_firstActivated = true;
        }
    }

    public ILiteral literal( final CVotingAgent p_votingAgent )
    {
        return CLiteral.from( "groups", CRawTerm.from( m_groups ) );
    }

    public CGroup openNewGroupRandom( final CVotingAgent p_votingAgent )
    {
        final CGroup l_group = new CGroup( p_votingAgent, "RANDOM" );
        m_groups.add( l_group );
        System.out.println( "Created Group " + l_group );
        this.wakeUpAgent();

        return l_group;
    }

    public CGroup openNewGroupCoordinated( final CVotingAgent p_votingAgent )
    {
        final CGroup l_group = new CGroup( p_votingAgent, "COORDINATED" );
        m_groups.add( l_group );
        System.out.println( "Created Group " + l_group );

        return l_group;
    }

    public void addAgentRandom( final CGroup p_randomGroup, final CVotingAgent p_votingAgent )
    {
        p_randomGroup.addRandom( p_votingAgent );
        this.wakeUpAgent();
    }


    public void addAgentCoordinated( final CGroup p_group, final CVotingAgent p_votingAgent )
    {
        p_group.addCoordinated( p_votingAgent );
        this.wakeUpAgent();
    }

    public ILiteral detectGroup( final CChairAgent p_chairAgent )
    {
        for ( final CGroup l_group : m_groups )
        {
            if ( !( ( l_group.literal( p_chairAgent ) ) == null ) )
                return l_group.literal( p_chairAgent );
        }
        return null;
    }

    // open group for further elections, unless the capacity is reached
    // also, wake up the next agent

    public void reopen( final CGroup p_group )
    {
        p_group.reopen();
        this.wakeUpAgent();
    }

    private void wakeUpAgent()
    {
        m_currentIndex++;
        final CVotingAgent l_wakingAgent =  m_agentList.get( m_currentIndex );
        l_wakingAgent.sleep( 0 );
        l_wakingAgent.getChair().sleep( 0 );
        System.out.println( "Waking up agent " + l_wakingAgent.name() );
    }
}