---

agent.h

Go to the documentation of this file.

/***************************************************************************
                          agent.h  -  description
                             -------------------
    begin                : Mon Dec 3 2001
    copyright            : (C) 2001 by Vlad Mereuta
    email                : dizzy@deity.fsnet.co.uk
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 ***************************************************************************/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#ifndef AGENT_H
#define AGENT_H

#include <vector>

#include <dalt_client/entity.h>
#include <dalt_client/action.h>
#include <dalt_client/sense.h>
#include <dalt_client/dalt_client.h>
#include <dalt_client/run_time_info.h>

#include <zthread/Thread.h>
#include <zthread/Semaphore.h>
#include <zthread/Mutex.h>
#include <zthread/LockedQueue.h>
#include <zthread/Guard.h>

namespace DALT_Client {

using namespace ZThread;
using namespace std;

class Agent : public Entity, public Thread
{
protected:
    static Mutex        agent_sync;
    Mutex           stay_alive_mutex;
    Mutex           method_mutex;
    vector<Sense*>  senses;
    float               fitness;
    bool            is_clonable;
    DALTClient*     dalt_client;
    Semaphore*      locker;
    SOAPMethod* state_change_method;
    
    bool            stay_alive;
    LockedQueue<Action*>            action_queue;
public: 
//  SOAPProxy*  endpoint;

    RunTimeInfo rti;

    Agent(string type, int id, DALTClient* client);
    ~Agent();
    
    virtual void addSense(Sense* sense);
    
    virtual void senseAndAct()=0;
    
    virtual void    newCycle();
    
    virtual void    finishedCycle();
    
    virtual int executeAction(Action& action)=0;
    virtual void    queueAction(Action* act);
    
    virtual void    clone();
    
    virtual void kill() throw (Synchronization_Exception);
    
    virtual void    run() throw();
};

}

#endif

---