nevrax.org : docs

00001 
00007 /* Copyright, 2000 Nevrax Ltd.
00008  *
00009  * This file is part of NEVRAX NEL.
00010  * NEVRAX NEL is free software; you can redistribute it and/or modify
00011  * it under the terms of the GNU General Public License as published by
00012  * the Free Software Foundation; either version 2, or (at your option)
00013  * any later version.
00014 
00015  * NEVRAX NEL is distributed in the hope that it will be useful, but
00016  * WITHOUT ANY WARRANTY; without even the implied warranty of
00017  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
00018  * General Public License for more details.
00019 
00020  * You should have received a copy of the GNU General Public License
00021  * along with NEVRAX NEL; see the file COPYING. If not, write to the
00022  * Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
00023  * MA 02111-1307, USA.
00024  */
00025 
00026 #ifndef NL_AGENTS_H
00027 #define NL_AGENTS_H
00028 
00029 #include "nel/ai/agent/agentexport.h"
00030 #include "nel/ai/agent/baseai.h"
00031 #include "nel/ai/agent/mailbox.h"
00032 
00033 namespace NLAIAGENT
00034 {       
00035         typedef CLocalMailBox tMailBoxLettre;
00036 
00045         class IBasicAgent : public IConnectIA
00046         {
00047         private:
00048                 struct CMethodCall
00049                 {
00050                         CMethodCall(const char *name, int i): MethodName (name)
00051                         {                               
00052                                 Index = i;
00053                         }
00054                         CStringVarName MethodName;
00055                         sint32 Index;
00056                 };
00057                 static CMethodCall _Method[];
00058 
00059         protected:
00061                 CProcessResult  _RunState;
00063                 IMailBox        *_Mail;
00064 
00065         protected:
00070                 IBasicAgent(const IBasicAgent &a);
00071 
00075                 virtual IObjectIA *run(const IMessageBase &m);          
00076 
00077 
00081                 virtual IMessageBase *runExec(const IMessageBase &m)
00082                 {
00083                         char debugString[1024*4];
00084                         char text[2048*8];
00085                         getDebugString(debugString);
00086                         sprintf(text,"IMessageBase *runExec(%s) note implementaited for the '%s' interface for the instence '%s'",(const char *)m.getType(),(const char *)getType(),debugString);
00087                         throw NLAIE::CExceptionNotImplemented(text);
00088                         return NULL;
00089                 }
00090 
00094                 virtual IMessageBase *runAchieve(const IMessageBase &m)
00095                 {
00096                         char debugString[1024*4];
00097                         char text[2048*8];
00098                         getDebugString(debugString);
00099                         sprintf(text,"runAchieve(%s) note implementaited for the '%s' interface for the instence '%s'",(const char *)m.getType(),(const char *)getType(),debugString);
00100                         throw NLAIE::CExceptionNotImplemented(text);
00101                         return NULL;
00102                 }
00103 
00107                 virtual IMessageBase *runAsk(const IMessageBase &m);            
00108 
00112                 virtual IMessageBase *runTell(const IMessageBase &m);           
00113 
00117                 virtual IMessageBase *runBreak(const IMessageBase &m)
00118                 {
00119                         char debugString[1024*4];
00120                         char text[2048*8];
00121                         getDebugString(debugString);
00122                         sprintf(text,"runBreak(%s) note implementaited for the '%s' interface for the instence '%s'",(const char *)m.getType(),(const char *)getType(),debugString);
00123                         throw NLAIE::CExceptionNotImplemented(text);
00124                         return NULL;
00125                 }
00126 
00130                 virtual IMessageBase *runKill(const IMessageBase &m)
00131                 {
00132                         char debugString[1024*4];
00133                         char text[2048*8];
00134                         getDebugString(debugString);
00135                         sprintf(text,"runKill(%s) note implementaited for the '%s' interface for the instence '%s'",(const char *)m.getType(),(const char *)getType(),debugString);
00136                         throw NLAIE::CExceptionNotImplemented(text);
00137                         return NULL;
00138                 }
00139 
00143                 virtual IMessageBase *runError(const IMessageBase &m)
00144                 {
00145                         char debugString[1024*4];
00146                         char text[2048*8];
00147                         getDebugString(debugString);
00148                         sprintf(text,"runError(%s) note implementaited for the '%s' interface for the instence '%s'",(const char *)m.getType(),(const char *)getType(),debugString);
00149                         throw NLAIE::CExceptionNotImplemented(text);
00150                         return NULL;
00151                 }
00152 
00153         public:
00155                 IBasicAgent(const IWordNumRef *parent);
00157                 IBasicAgent(const IWordNumRef *parent,IMailBox  *m);
00158                 virtual ~IBasicAgent();
00159 
00161                 virtual const CProcessResult &getState() const;
00163                 virtual void setState(TProcessStatement s, IObjectIA *result);
00164 
00166                 virtual IObjectIA::CProcessResult sendMessage(IMessageBase *msg);
00167 
00169                 virtual IObjectIA::CProcessResult sendMessage(IMessageBase *msg, IBasicAgent &receiver);
00170 
00172                 virtual IObjectIA::CProcessResult runActivity() = 0;            
00173 
00175                 virtual bool haveActivity() const = 0;
00176 
00178                 IMailBox *getMail() const;
00179 
00181 
00182                 virtual void save(NLMISC::IStream &os);
00183                 virtual void load(NLMISC::IStream &is);
00185 
00187 
00188                 virtual sint32 getMethodIndexSize() const;              
00189                 virtual tQueue isMember(const IVarName *,const IVarName *,const IObjectIA &) const;
00190                 virtual CProcessResult runMethodeMember(sint32, sint32, IObjectIA *);
00191                 virtual CProcessResult runMethodeMember(sint32 index,IObjectIA *);
00193 
00198                 virtual std::list<IBasicAgent *>::iterator addChild(IBasicAgent *p) = 0;
00202                 virtual void removeChild(const IBasicAgent *p) = 0;
00203 
00207                 virtual void removeChild(std::list<IBasicAgent *>::iterator &iter) = 0;
00208 
00212                 virtual void runChildren() = 0;
00213 
00217                 virtual void addMsgGroup(IBasicMessageGroup &grp);
00221                 virtual void removeMsgGroup(IBasicMessageGroup &grp);
00222 
00226                 virtual void processMessages() = 0;     
00227 
00228 
00229         public:
00233                 virtual const CProcessResult &run() = 0;
00234                 
00235         };      
00236 
00245         class IAgentComposite:public IBasicAgent
00246         {               
00247                 private:
00248                         typedef std::list<IBasicAgent *> tBasicList;
00249 
00250                         void deleteListe();
00251         
00252                 protected:              
00253                         tBasicList      _AgentList;
00254                         IAgentComposite(const IAgentComposite &a);
00255 
00256                 public:
00258                         IAgentComposite(IBasicAgent *parent);
00260                         IAgentComposite(IBasicAgent *parent,IMailBox *m);
00261 
00263 
00264                         virtual std::list<IBasicAgent *>::iterator addChild(IBasicAgent *p);    // Ajoute un fils � l'agent.
00265                         void cpyChild(const IBasicAgent &p);
00266                         void removeChild(const IBasicAgent &p);         
00267                         virtual void removeChild(const IBasicAgent *p);
00268                         virtual void removeChild(std::list<IBasicAgent *>::iterator &iter);
00270 
00272 
00273                         virtual void save(NLMISC::IStream &os);
00274                         virtual void load(NLMISC::IStream &is);         
00276 
00277                         virtual ~IAgentComposite();
00278         };
00279 
00280         class IAgent:public IAgentComposite
00281         {       
00282         public: 
00283                 static const NLAIC::CIdentType IdAgent;
00284                 
00285         protected:              
00286                 IAgent(const IAgent &a);
00287                 
00289 
00290                 virtual void runChildren();             // Activates the child agents           
00292         
00293         public:         
00295                 IAgent(IBasicAgent *parent);
00297                 IAgent(IBasicAgent *parent,IMailBox *m);
00298                 virtual ~IAgent();              
00299                                 
00301 
00302                 virtual const NLAIC::IBasicType *clone() const;
00303                 virtual const NLAIC::IBasicType *newInstance() const;
00304                 virtual void getDebugString(char *t) const;
00305                 virtual const NLAIC::CIdentType &getType() const;
00306                 virtual void save(NLMISC::IStream &os);
00307                 virtual void load(NLMISC::IStream &is);         
00309 
00311                 virtual bool isEqual(const IBasicObjectIA &a) const;
00313                 virtual void onKill(IConnectIA *A);
00314 
00315                 virtual bool haveActivity() const
00316                 {
00317                         return false;
00318                 }
00319 
00321                 virtual IObjectIA::CProcessResult runActivity()
00322                 {
00323                         return ProcessRun;
00324                 }               
00326 
00327                 virtual void processMessages();
00328                 virtual const CProcessResult &run();            
00330         };
00331 }
00332 #endif
agent.h
