---

LoomKernel.h

Go to the documentation of this file.

/***************************************************************** lm-cpr beg
 *
 * AI Loom - A cross platform artificial intelligence framework
 * AI Loom is (c) Copyright 2003 Josh Brown
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Library General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Library General Public License for more details.
 *
 * You should have received a copy of the GNU Library General Public
 * License along with this library; if not, write to the
 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
 * Boston, MA 02111-1307, USA.
 *
 * -----------------------------------------------------------------
 * File:          $RCSfile: LoomKernel.h,v $
 * Date modified: $Date: 2003/10/21 18:55:19 $
 * Version:       $Revision: 1.3 $
 * -----------------------------------------------------------------
 *
 ************************************************************** lm-cpr-end */
#ifndef LM_LOOM_KERNEL_H
#define LM_LOOM_KERNEL_H


#include <boost/bind.hpp>
#include <boost/function.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/thread/thread.hpp>

#include <list>
#include <map>
#include <queue>
#include <string>

#ifdef PLEXUS
#include <plx/Router/NodePtr.h>
#endif

namespace lm
{
   // forward declarations
   class Agent;
   class Effector;
   class Sensor;
   class NetworkConnection;
   

   class LoomKernel
   {
   public:
      LoomKernel();

      bool hasAgent(const std::string& name);

      void init(int port = -1);

      void connectTo(std::string hostname, int port);

      void sendMessageWith(Agent* agent, Effector* e);
      
      void update();
      
      ~LoomKernel();

      void add(const Sensor& newSensor);

      void add(const Effector& newEffect);

      void registerAgent(Agent* a);

      void unregisterAgent(Agent* a);
      
      std::string popPostQueue(Agent* a);
 
      std::list<Agent*> getAgents();
      
   public:
      // public functor that bind returns on run
      boost::function<void ()> bindedRun;
      
   private:

      void run(Agent* a);
      
      //  a list of the agents in this agentCollector
      std::list<Agent*> mAgents;

      // the effector pool that all agents in this agentCollector can use
      std::list<Effector*> effectorPool;

      // the sensor pool that all agents in this agentCollector can use
      std::list<Sensor*> sensorPool;

#ifdef PLEXUS
      // the plexus node for this agent collector
      plx::NodePtr mLocalNode;
#endif

      boost::thread_group thrds;

      boost::thread* mThreadPtr;

   public:
      typedef std::map<Agent*, std::queue<std::string>* > QueueMap;
      QueueMap mPostQueueMap;
      QueueMap mPreQueueMap;

#ifdef PLEXUS
      NetworkConnection* mNetworkConnection;
#endif
   };

   
} // end namespace

#endif // LM_AGENT_COLLECTOR_H

---