NeL: NLAIAGENT::IAgentManager class Reference

00048                                                   :IAgent(parent)
00049                 {
00050                 }

00053                                                               :IAgent(parent,m)
00054                 {
00055                 }

00058                                                      :IAgent(a)
00059                 {
00060                 }

00068         {                       
00069                 p->incRef();
00070                 _AgentList.push_front((IBasicAgent *)p);
00071                 // Donne au fils accès à la boite aux lettres du père
00072                 p->getMail()->addMailBox( this->getMail() );
00073                 _SizeChild ++;
00074 
00075                 return _AgentList.begin();
00076         }

00596         {
00597                 _Connected.insert(a);
00598         }

00573         {
00574                 _Connection.insert(a);
00575         }

00351         {
00352                 return TQueue();
00353         }

00093         {               
00094                 NLAIC::IBasicInterface *m = new IAgent(*this);
00095                 return m;
00096         }

00556         {
00557                 b->addInConnectedList(this);
00558                 addInConnectionList(b);
00559         }

00522         {
00523                 IRefrence::refLoadStream(is);
00524                 NLAIC::CIdentTypeAlloc id;
00525                 sint32 i;
00526                 is.serial( i );
00527 
00528                 if(i)
00529                 {
00530                         while(i --)
00531                         {                                       
00532                                 is >> id;
00533                                 IWordNumRef *num = (IWordNumRef *)id.allocClass();
00534                                 num->load(is);
00535                                 addInConnectionList((IConnectIA *)((const IRefrence *)*num));
00536                                 delete num; 
00537                         }
00538                 }
00539 
00540                 
00541                 is.serial(i);
00542                 if(i)
00543                 {
00544                         while(i--)
00545                         {
00546                                 is >> id;                                       
00547                                 IWordNumRef *num = (IWordNumRef *)id.allocClass();
00548                                 num->load(is);
00549                                 addInConnectedList((IConnectIA *)((const IRefrence *)*num));
00550                                 delete num;
00551                         }
00552                 }
00553         }

00079         {
00080                 _AgentList.push_front((IBasicAgent *)p.clone());
00081                 _SizeChild ++;
00082         }

00094                 {
00095                         return --_Ref;
00096                 }

00070                 {
00071                         return IAgent::getMethodIndexSize();
00072                 }

00359                         {
00360                                 return _SizeChild;
00361                         }

00117                 {
00118                         return std::string("<unnamed>");
00119                 }

00107         {
00108                 t += NLAIC::stringGetBuild("class IAgent<%4x>",this);
00109         }

00481         {
00482                 return CIdent(0,_NumRef->getNumIdent().getId());
00483         }

00293                 {
00294                         std::string s;
00295                         getDebugString(s);
00296                         return s;
00297                 }

00333         {
00334                 return _Mail;
00335         }

00312         {
00313                 switch(id)
00314                 {
00315                 case 0:
00316                         {
00317                                 return std::string("IObjectIA::sendMessage(IMessage)");
00318                         }                       
00319                         break;
00320                 case 1:                 
00321                         break;
00322                 case 2:                 
00323                         return std::string("IObjectIA::run()");
00324                         break;
00325 
00326                 case 3:
00327                         {                               
00328                                 return std::string("IObjectIA::getStaticMember(Integer)");                              
00329                         }
00330                 }
00331                 return std::string("Mathod_?????(Param_?????)");
00332         }

00448         {
00449                 return IObjectIA::getMethodIndexSize() + _LastM;
00450         }

00403         {
00404                 const IRefrence *p = getParent();
00405 
00406                 if(p == NULL) return this;
00407 
00408                 while( true )
00409                 {
00410                         if(p->getParent() == NULL) return p;
00411                 }
00412         }

00512         {
00513                 return (IConnectIA *)IRefrence::getParent();
00514         }

00100                 {
00101                         return _Ref;
00102                 }

00310         {
00311                 return _RunState;
00312         }

00262                 {
00263                         return getStaticMember(getStaticMemberIndex(compName));
00264                 }

00194         {
00195                 return NULL;
00196         }

00189         {
00190                 return -1;
00191         }

00181         {
00182                 std::string text;
00183                 text = NLAIC::stringGetBuild("sint32 IObjectIA::getStaticMemberSize() note implementaited for the '%s' interface",(const char *)getType());
00184                 throw NLAIE::CExceptionNotImplemented(text.c_str());
00185                 return 0;       
00186         }

00278         {               
00279                 return *IdAgent;
00280         }

00424                 {
00425                         return false;
00426                 }

00081                 {
00082                         _Ref ++;
00083                 }

00117         {
00118                 
00119         }

00247         {
00248                 return -1;
00249         }

00112         {
00113                 return true;
00114         }

00357         {
00358                 return true;
00359         }

00453         {                       
00454                 if(className == NULL)
00455                 {
00456                         TQueue a;
00457                         for(int i = 0; i < _LastM; i++)
00458                         {
00459                                 if(*methodName == IBasicAgent::_Method[i].MethodName)
00460                                 {       
00461                                         CObjectType *c;
00462                                         if(i == _RunTel || i == _RunAsk)
00463                                         {
00464                                                 static NLAISCRIPT::CParam paramMsg(1,new NLAISCRIPT::COperandSimple (new NLAIC::CIdentType(NLAISCRIPT::CMsgNotifyParentClass::IdMsgNotifyParentClass)));
00465 
00466                                                 if(paramMsg.eval((NLAISCRIPT::CParam &)p) < 0.0) continue;
00467                                                 c = new CObjectType(new NLAIC::CIdentType(NLAISCRIPT::CMessageClass::IdMessageClass));
00468                                         }
00469                                         else
00470                                         if (i == _GetNumId)
00471                                         {
00472                                                 c = new CObjectType(new NLAIC::CIdentType(CStringType::IdStringType));
00473                                         }
00474                                         else
00475                                         {
00476                                                 c = new CObjectType(new NLAIC::CIdentType(CLocalAgentMail::LocalAgentMail));
00477                                         }
00478                                         a.push(CIdMethod(IBasicAgent::_Method[i].Index + IObjectIA::getMethodIndexSize(),0.0,NULL,c));                                  
00479                                         break;
00480                                 }
00481                         }
00482 
00483                         if(a.size()) return a;
00484                         else return IConnectIA::isMember(className,methodName,p);
00485                 }
00486                 return IConnectIA::isMember(className,methodName,p);
00487         }

00058         {
00059 //sint n = _SizeChild;
00060 
00061 #ifdef NL_DEBUG
00062                 if(_SizeChild != (sint)_AgentList.size())
00063                 {
00064                         sint i = (sint)_AgentList.size();
00065                         throw;
00066                 }       
00067 
00068 #endif
00069                 sint n = _SizeChild ;
00070                 while ( /*_AgentList.begin() !=  _AgentList.end()*/ n--)
00071                 {                                       
00072                         IConnectIA *c = _AgentList.front();
00073                         _AgentList.pop_front();
00074                         c->onKill(this);
00075                         c->release();                   
00076                 }
00077                 _SizeChild = 0;
00078                 IAgentComposite::Kill();
00079         }

00132         {       
00133                 IBasicAgent::load(is);
00134                 IAgentComposite::load(is);              
00135         }

00099         {       
00100                 NLAIC::IBasicInterface *m;
00101                 if(getParent() != NULL) m = new IAgent((IBasicAgent *)getParent());
00102                 else m = new IAgent(NULL);
00103                 return m;
00104         }

00082         {
00083                 if(eraseFromList<IBasicAgent *>(&_AgentList,(IBasicAgent *)a)) 
00084                 {
00085                         a->release();
00086                         _SizeChild --;
00087                 }
00088                 removeConnection(a);            
00089                 IAgentComposite::onKill(a);             
00090         }

00381         {
00382                 return *_NumRef;
00383         }

00386         {
00387                 return _NumRef;
00388         }

00135         {                                               
00136                 if(a.getType() == getType() ) return isEqual(a);                        
00137                 return false;
00138         }

00201         {
00202                 IMailBox *mail = getMail();
00203                 //const IMailBox::TListMessage &l = mail->getMesseageListe();
00204                 sint n = mail->getMessageCount();
00205 
00206                 while(/*l.begin() != l.end()*/ n --)
00207                 {
00208                         const IMessageBase &msg = getMail()->getMessage();
00209 #ifdef NL_DEBUG
00210         const char *msgBase = (const char *)msg.getType();
00211         const char *classBase = (const char *)getType();
00212 #endif
00213                         try
00214                         {
00215                                 (void)IBasicAgent::run( msg );
00216                                 mail->popMessage();
00217                         }
00218                         catch(NLAIE::IException &)
00219                         {
00220                                 // We send an Error message because the incoming message isn't processed.
00221                                 IMessageBase *o = (IMessageBase *)msg.clone();
00222                                 o->setMethodIndex(-1,-1);
00223                                 o->setSender(this);
00224                                 o->setPerformatif(IMessageBase::PError);
00225                                 o->setReceiver((IObjectIA *)msg.getSender());
00226                                 ((IObjectIA *)msg.getSender())->sendMessage(o);
00227 
00228                                 mail->popMessage();
00229                         }               
00230                 }
00231         }

00434         {
00435                 IObjectIA::load(is);
00436                 _NumRef->release();
00437                 NLAIC::CIdentTypeAlloc id;
00438                 is >> id;
00439                 _NumRef = (IWordNumRef *)id.allocClass();
00440                 _NumRef->load(is);
00441                 bool k;
00442                 is.serial( k );
00443                 if ( k ) 
00444                 {
00445                         if(_Parent) _Parent->release();
00446                         is >> id;
00447                         _Parent = (IWordNumRef *)id.allocClass();
00448                         _Parent->load(is);
00449                 }
00450                 else 
00451                 {
00452                         _Parent = NULL;
00453                 }
00454         }

00087                 {
00088                         if(decRef() == 0) 
00089                                         delete this;
00090                 }

00085         {                                       
00086                 _AgentList.erase(iter);
00087                 _SizeChild --;
00088         }

00109         {                       
00110                 std::list<IBasicAgent *>::iterator i = _AgentList.begin();
00111                 while(i != _AgentList.end())
00112                 {                                       
00113                         IBasicAgent *c = *i;
00114                         if(c == p)
00115                         {
00116                                 _AgentList.erase(i);                            
00117                                 p->getMail()->removeMailBox( this->getMail() );
00118                                 c->release();
00119                                 _SizeChild --;
00120                                 // Supprime chez l'ancien fils la boite au lettre du père                               
00121                                 break;
00122                         }
00123                         i++;
00124                 }
00125         }

00091         {                       
00092                 std::list<IBasicAgent *>::iterator i = _AgentList.begin();
00093                 while(i != _AgentList.end())
00094                 {                                       
00095                         if(*((*i)) == p)
00096                         {
00097                                 (*i)->release();
00098                                 _AgentList.erase(i);
00099                                 // Supprime chez l'ancien fils la boite au lettre du père
00100                                 p.getMail()->removeMailBox( this->getMail() );
00101                                 _SizeChild --;
00102                                 return;
00103                         }
00104                         i++;
00105                 }
00106         }

00562         {               
00563                 Agent->removeInConnectedList(this);
00564                 removeInConnectionList(Agent);                  
00565         }

00601         {
00602                 TListIBasicItr i = _Connected.find(a);
00603                 if(i != _Connected.end())
00604                                                 _Connected.erase(i);
00605                 /*TListIBasicItr i = _Connected.begin();
00606                 while(i != _Connected.end())
00607                 {                       
00608                         const IConnectIA *o = *i;
00609                         if(o == a)
00610                         {                                       
00611                                 _Connected.erase(i);
00612                                 return;
00613                         }
00614                         i++;
00615                 }*/
00616         }

00578         {
00579 
00580                 TListIBasicItr i = _Connection.find(a);
00581                 if(i != _Connection.end())
00582                                                         _Connection.erase(i);
00583                 /*TListIBasicItr i = _Connection.begin();
00584                 while(i != _Connection.end())
00585                 {                               
00586                         if(*i == a)
00587                         {
00588                                 _Connection.erase(i);
00589                                 return;
00590                         }
00591                         i++;
00592                 }*/
00593         }

00366         {
00367                 IMessageBase *returnMsg = NULL;
00368                 switch(msg.getPerformatif())
00369                 {
00370                 case IMessageBase::PUndefine:
00371                         {
00372                                 std::string text;
00373                                 text = NLAIC::stringGetBuild("Function IObjectIA *IBasicAgent::run('%s') proccess an IMessageBase::PUndefine performatif",(const char *)msg.getType());
00374                                 throw NLAIE::CExceptionNotImplemented(text.c_str());
00375                         }
00376                         break;          
00377                 case IMessageBase::PExec:
00378                 
00379                         returnMsg = runExec(msg);
00380                         if(msg.getContinuation() != NULL) 
00381                         {
00382                                 returnMsg->incRef();
00383                                 ((IObjectIA *)msg.getContinuation())->sendMessage(returnMsg);
00384                         }                               
00385                         break;
00386                 case IMessageBase::PAchieve:
00387                         returnMsg = runAchieve(msg);
00388                         if(msg.getContinuation() != NULL)
00389                         {
00390                                 returnMsg->incRef();
00391                                 ((IObjectIA *)msg.getContinuation())->sendMessage(returnMsg);
00392                         }
00393                         break;
00394                 case IMessageBase::PAsk:
00395                         returnMsg = runAsk(msg);
00396                         returnMsg->setPerformatif(IMessageBase::PTell);
00397                         returnMsg->incRef();                    
00398                         ((IObjectIA *)msg.getSender())->sendMessage(returnMsg);
00399                         if(msg.getContinuation() != NULL)
00400                         {                                       
00401                                 returnMsg->incRef();
00402                                 ((IObjectIA *)msg.getContinuation())->sendMessage(returnMsg);                           
00403                         }                       
00404                         break;
00405                 case IMessageBase::PTell:                       
00406                         returnMsg = runTell(msg);                       
00407                         
00408                         break;
00409                 case IMessageBase::PBreak:
00410                         returnMsg = runBreak(msg);
00411                         break;
00412                 case IMessageBase::PKill:
00413                         returnMsg = runKill(msg);
00414                         break;
00415                 case IMessageBase::PError:
00416                         returnMsg = runError(msg);
00417                         break;
00418 
00419                 case IMessageBase::PEven:
00420                         returnMsg = runEven(msg);                       
00421                         break;
00422                 default: break;
00423                 }
00424                 
00425                 if(returnMsg) returnMsg->release();
00426                 return NULL;
00427         }

00237         {       
00238                 /*nlinfo("%s<%4x> go to run %s with %d childs:",Shift.c_str(),this, (const char *)getType(),_AgentList.size());
00239                 Shift += "\t";
00240                 kShift++;*/
00241 
00242                 runChildren();          // Gestion des fils
00243                 getMail()->run();       // Execution de la boite aux lettres
00244 
00245                 processMessages();      // Traitement de ses propres messages
00246 
00247                 if(haveActivity() && getState().ResultState == processIdle) runActivity();
00248 
00249                 /*kShift --;
00250                 std::string chaine;
00251                 sint i;
00252                 for(i = 0; i < (sint)kShift; i ++)
00253                 {
00254                         chaine += Shift [i];                            
00255                 }
00256                 Shift = chaine;*/
00257 
00258 
00259                 return getState();  
00260         }

00128                 {
00129                         std::string debugString;
00130                         std::string text;
00131                         getDebugString(debugString);
00132                         text = "IMessageBase *runAchieve(";
00133                         text += (const char *)m.getType();
00134                         text += " note implementaited for the '";
00135                         text += (const char *)getType();
00136                         text += "' interface for the instence '";
00137                         text += (const char *)getType();
00138                         text += "' '";
00139                         text += debugString;
00140                         text += "'";
00141                         
00142                         throw NLAIE::CExceptionNotImplemented(text.c_str());
00143                         return NULL;
00144                 }

00430                 {
00431                         return ProcessRun;
00432                 }

00547         {
00548                 if(NLAISCRIPT::CMsgNotifyParentClass::IdMsgNotifyParentClass == m.getType())
00549                 {
00550                         if(getParent() != NULL)
00551                         {
00552                                 CNotifyParentScript *msg = new CNotifyParentScript();
00553                                 return msg;
00554                         }
00555                         else
00556                         {
00557                                 CNotifyParentScript *msg = new CNotifyParentScript((IBasicAgent *)getParent());
00558                                 return msg;
00559                         }
00560                 }
00561                 else
00562                 {
00563                         std::string debugString;
00564                         std::string text;
00565                         getDebugString(debugString);
00566                         text += NLAIC::stringGetBuild("runAsk(%s) note implementaited for the '%s' interface for the instence '%s'",(const char *)m.getType(),(const char *)getType(),debugString.c_str());
00567                         throw NLAIE::CExceptionNotImplemented(text.c_str());
00568                         return NULL;
00569                 }               
00570         }

00160                 {
00161                         std::string debugString;
00162                         std::string text;
00163                         getDebugString(debugString);
00164                         text = "IMessageBase *runBreak(";
00165                         text += (const char *)m.getType();
00166                         text += " note implementaited for the '";
00167                         text += (const char *)getType();
00168                         text += "' interface for the instence '";
00169                         text += (const char *)getType();
00170                         text += "' '";
00171                         text += debugString;
00172                         text += "'";
00173                         
00174                         throw NLAIE::CExceptionNotImplemented(text.c_str());
00175                         return NULL;
00176                 }

00161         {
00162                 std::list<IBasicAgent *>::iterator i_agl = _AgentList.begin();          
00163                 sint n = _SizeChild;
00164 
00165 #ifdef NL_DEBUG
00166                 if(n != (sint)_AgentList.size())
00167                                                                 throw;
00168 #endif
00169 
00170                 while ( /*i_agl != _AgentList.end()*/n -- )
00171                 {                                       
00172                         IBasicAgent *c = *i_agl;
00173 
00174                         
00175                         c->run();
00176                         switch(c->getState().ResultState)
00177                         {
00178                         case processToKill:
00179                                 {
00180                                         i_agl ++;
00181                                         removeChild(c);
00182                                 }
00183                                 break;
00184                         case processPresKill:
00185                                 {
00186                                         i_agl ++;
00187                                         c->incRef();
00188                                         removeChild(c);
00189                                         onKill(c);
00190                                 }
00191                                 break;
00192                         default:
00193                                 i_agl ++;
00194                                 break;
00195 
00196                         };                      
00197                 }
00198         }

00138         {
00139                 if(_Iter_Child != _AgentList.end())
00140                 {
00141                         IBasicAgent *c = *_Iter_Child;
00142 
00143                         if(c->runStep().ResultState == ProcessNotComplit.ResultState) return false;
00144 
00145                         if(c->getState().ResultState == processToKill)
00146                         {
00147                                 _Iter_Child ++;
00148                                 removeChild(c);
00149                         }
00150                         else _Iter_Child++;
00151 
00152                         return false;
00153 
00154                 }
00155 
00156                 _Iter_Child = _AgentList.begin();               
00157                 return true;
00158         }

00207                 {
00208                         std::string debugString;
00209                         std::string text;
00210                         getDebugString(debugString);
00211                         text = "IMessageBase *runError(";
00212                         text += (const char *)m.getType();
00213                         text += " note implementaited for the '";
00214                         text += (const char *)getType();
00215                         text += "' interface for the instence '";
00216                         text += (const char *)getType();
00217                         text += "' '";
00218                         text += debugString;
00219                         text += "'";
00220                         
00221                         throw NLAIE::CExceptionNotImplemented(text.c_str());
00222                         return NULL;
00223                 }

00106                 {
00107                         std::string debugString;
00108                         std::string text;
00109                         getDebugString(debugString);
00110                         text = "IMessageBase *runEven(";
00111                         text += (const char *)m.getType();
00112                         text += " note implementaited for the '";
00113                         text += (const char *)getType();
00114                         text += "' interface for the instence '";
00115                         text += (const char *)getType();
00116                         text += "' '";
00117                         text += debugString;
00118                         text += "'";
00119 
00120                         throw NLAIE::CExceptionNotImplemented(text.c_str());
00121                         return NULL;
00122                 }

00084                 {
00085                         std::string debugString;
00086                         std::string text;
00087                         getDebugString(debugString);
00088                         text = "IMessageBase *runExec(";
00089                         text += (const char *)m.getType();
00090                         text += " note implementaited for the '";
00091                         text += (const char *)getType();
00092                         text += "' interface for the instence '";
00093                         text += (const char *)getType();
00094                         text += "' '";
00095                         text += debugString;
00096                         text += "'";
00097                         
00098                         throw NLAIE::CExceptionNotImplemented(text.c_str());
00099                         return NULL;
00100                 }

00185                 {
00186                         std::string debugString;
00187                         std::string text;
00188                         getDebugString(debugString);
00189                         text = "IMessageBase *runKill(";
00190                         text += (const char *)m.getType();
00191                         text += " note implementaited for the '";
00192                         text += (const char *)getType();
00193                         text += "' interface for the instence '";
00194                         text += (const char *)getType();
00195                         text += "' '";
00196                         text += debugString;
00197                         text += "'";
00198                         
00199                         throw NLAIE::CExceptionNotImplemented(text.c_str());
00200                         return NULL;
00201                 }

00495         {
00496                 IBaseGroupType *param = (IBaseGroupType *)p;
00497 
00498                 switch(index - IObjectIA::getMethodIndexSize())
00499                 {
00500                 case _GetMailer:
00501                         {
00502                                 IObjectIA::CProcessResult a;                            
00503                                 a.Result = new CLocalAgentMail(this);                           
00504                                 return a;
00505                         }                       
00506                         break;
00507 
00508                 case _Father:
00509                         {
00510                                 IObjectIA::CProcessResult a;
00511                                 IRefrence *father = getParent();
00512                                 if ( father )
00513                                         a.Result = new CLocalAgentMail( (IBasicAgent *) father );                               
00514                                 else
00515                                 {
00516                                         a.Result = &DigitalType::NullOperator;
00517                                         a.Result->incRef();
00518                                 }
00519                                 return a;
00520                         }       
00521                         break;
00522 
00523                 case _RunAsk:
00524                 case _RunTel:
00525                         {
00526                                 IObjectIA::CProcessResult a;
00527                                 a.Result = run((const IMessageBase &)*param->get());
00528                                 return a;
00529                         }
00530                         break;
00531 
00532                 case _GetNumId:         
00533                         {                               
00534                                 IObjectIA::CProcessResult a;
00535                                 std::string t;
00536                                 ((const IWordNumRef &)*this).getNumIdent().getDebugString(t);
00537                                 a.Result = new CStringType(CStringVarName(t.c_str()));
00538                                 return a;
00539                         }
00540                         break;
00541 
00542                 }
00543                 return IConnectIA::runMethodeMember(index,p);
00544         }

00490         {
00491                 return IConnectIA::runMethodeMember(h,index,p);
00492         }

00229                 {
00230                         std::string debugString;
00231                         std::string text;
00232                         getDebugString(debugString);
00233                         text = "IMessageBase *runService(";
00234                         text += (const char *)m.getType();
00235                         text += " note implementaited for the '";
00236                         text += (const char *)getType();
00237                         text += "' interface for the instence '";
00238                         text += (const char *)getType();
00239                         text += "' '";
00240                         text += debugString;
00241                         text += "'";
00242                         
00243                         throw NLAIE::CExceptionNotImplemented(text.c_str());
00244                         return NULL;
00245                 }

00263         {
00264                 if(runChildrenStepByStep())
00265                 {
00266                         getMail()->run();       // Execution de la boite aux lettres
00267 
00268                         processMessages();      // Traitement de ses propres messages
00269 
00270                         if(haveActivity() && getState().ResultState == processIdle) runActivity();
00271                         return getState();
00272                 }
00273                 else 
00274                         return IObjectIA::ProcessNotComplit;
00275         }

00573         {
00574                 if(NLAISCRIPT::CMsgNotifyParentClass::IdMsgNotifyParentClass == m.getType())
00575                 {
00576                         /*const INombreDefine *n = (const INombreDefine *)m.getFront();
00577                         if(n->getNumber() != 0.0)
00578                         {
00579                                 const CLocalAgentMail *parent = (const CLocalAgentMail *)m.get();
00580                         }*/
00581                         return (IMessageBase *)m.clone();                       
00582                 }
00583                 else
00584                 {
00585 /*                      std::string debugString;
00586                         std::string text;
00587                         getDebugString(debugString);
00588                         text += NLAIC::stringGetBuild("runTell(%s) note implementaited for the '%s' interface for the instence '%s'",(const char *)m.getType(),(const char *)getType(),debugString.c_str());
00589                         throw NLAIE::CExceptionNotImplemented(text.c_str()); */
00590                         return NULL;
00591                 }
00592         }

00126         {                               
00127                 IBasicAgent::save(os);
00128                 IAgentComposite::save(os);
00129         }

00335         {
00336                 std::string text;
00337                 text = NLAIC::stringGetBuild("method 'sendMessage(%s,const IObjectIA &)' '%s' interface",name.getString(), (const char *)getType());
00338                 throw NLAIE::CExceptionNotImplemented(text.c_str());
00339                 return CProcessResult();
00340         }

00452                 {
00453                         return sendMessage((IMessageBase *)m);
00454                 }

00327         {
00328                 receiver.getMail()->addMessage( msg );
00329                 return IObjectIA::ProcessRun;
00330         }

00321         {
00322                 _Mail->addMessage(msg);
00323                 return IObjectIA::ProcessRun;
00324         }

00329                 {
00330                         if ( f.isReading() )
00331                                 load( f );
00332                         else
00333                                 save( f );
00334                 }

00462         {
00463                 if(_NumRef != NULL) _NumRef->release();
00464                 _NumRef = new CLocWordNumRef(ref.getNumIdent(),this);
00465         }

00662         {               
00663                 IRefrence::setParent(parent);
00664                 IConnectIA *p = (IConnectIA *)getParent();
00665 
00666                 if(p != NULL) connect(p);
00667         }

00315         {
00316                 _RunState.ResultState = state;
00317                 _RunState.Result = result;
00318         }

00199         {
00200                 std::string text;
00201                 text = NLAIC::stringGetBuild("Function void IObjectIA::setStaticMember(sint32,IObjectIA *) note implementaited for the '%s' interface",(const char *)getType());
00202                 throw NLAIE::CExceptionNotImplemented(text.c_str());
00203                 return false;
00204         }

00269                 {
00270                         return setStaticMember(getStaticMemberIndex(compName),change);
00271                 }

00486         {
00487                 ((CAgentNumber &)(_NumRef->getNumIdent().getId())).setTypeAt(t);
00488         }


Some IObjectIA method.
virtual sint32	getMethodIndexSize () const
virtual TQueue	isMember (const IVarName , const IVarName , const IObjectIA &) const
virtual CProcessResult	runMethodeMember (sint32 index, IObjectIA *)
virtual CProcessResult	runMethodeMember (sint32, sint32, IObjectIA *)
Some IBasicAgent method.
virtual void	processMessages ()
virtual const CProcessResult &	run ()
virtual const CProcessResult &	runStep ()
Some IBasicAgent method.
virtual void	runChildren ()
virtual bool	runChildrenStepByStep ()
	Activates the child agents.
Public Member Functions
virtual TQueue	canProcessMessage (const IVarName &)
void	connect (IConnectIA *b)
sint32	decRef ()
	Decrement the reference of an object.
virtual const IObjectIA *	getAgentContext () const=0
virtual int	getBaseMethodCount () const
	Return the nomber of internal C++ hard coded method that the class can process.
virtual sint	getChildCoun () const
virtual const CIdent	getIdentType () const
virtual const std::string	getInfo ()
IMailBox *	getMail () const
	Get the mail box letter.
virtual std::string	getMethodeMemberDebugString (sint32, sint32) const
virtual const IRefrence *	getOwner () const
	To get the top level parent of this agent.
IConnectIA *	getParent () const
	to get the agent parents
const sint32 &	getRef () const
	get the refence count.
virtual const CProcessResult &	getState () const
	Get the curent state of the agent.
const IObjectIA *	getStaticMember (const IVarName &compName) const
virtual const IObjectIA *	getStaticMember (sint32) const
virtual sint32	getStaticMemberIndex (const IVarName &) const
virtual sint32	getStaticMemberSize () const
virtual bool	haveActivity () const
	allow to know if the agent have an activity process to run.
	IAgentManager (const IAgentManager &a)
	Copy constructor.
	IAgentManager (IBasicAgent parent, IMailBox m)
	Construct manager with a parent and a mail box.
	IAgentManager (IBasicAgent *parent)
	Construct manager with a parent.
void	incRef ()
	Inc a reference. We use this when we have to conserve a pointer memeory for exemple in a list.
virtual void	init (IObjectIA *)
virtual sint32	isClassInheritedFrom (const IVarName &) const
virtual bool	isEqual (const IBasicObjectIA &a) const
	Implementation of the isEqual of the IBasicObjectIA.
virtual bool	isLocal ()
	If the result is true the object is loclal else its a representation of an object on the server. By the method return true.
virtual void	Kill ()
	Call this function to destroy an agent including its referneces in other agents and its childs.
virtual void	onKill (IConnectIA *A)
	Called by an agent who's destroyed te remove its references.
	operator const IWordNumRef & () const
	to get a word num ref of the agents.
	operator const IWordNumRef * () const
	to get a word num ref pointer of the agents.
bool	operator== (const IBasicObjectIA &classType) const
virtual void	release ()
	Release allow to release the pointer. The last release when the _Ref is nul delete the object.
void	removeConnection (IConnectIA *Agent)
	To release a connection.
virtual IObjectIA::CProcessResult	runActivity ()
	Mailer do'nt have own activity.
virtual CProcessResult	sendMessage (const IVarName &, IObjectIA *)
virtual IObjectIA::CProcessResult	sendMessage (IObjectIA *m)
virtual IObjectIA::CProcessResult	sendMessage (IMessageBase *msg, IBasicAgent &receiver)
	Send message to an receiver agent.
virtual IObjectIA::CProcessResult	sendMessage (IMessageBase *msg)
	Send a message to the agent.
virtual void	serial (NLMISC::IStream &f) throw (NLMISC::EStream)
virtual void	setParent (const IWordNumRef *parent)
	to set the parent of the agents.
virtual void	setState (TProcessStatement s, IObjectIA *result)
	Set the state of an agent.
virtual bool	setStaticMember (sint32, IObjectIA *)
bool	setStaticMember (const IVarName &compName, IObjectIA *change)
void	setTypeAt (uint64 t)
	That function allow user to change the 7 bit of the type field in the sid agent number;.
virtual	~IAgentManager ()
Some IBasicAgent method.
virtual const NLAIC::IBasicType *	clone () const
virtual void	getDebugString (std::string &t) const
virtual const NLAIC::CIdentType &	getType () const
virtual void	load (NLMISC::IStream &is)
virtual const NLAIC::IBasicType *	newInstance () const
virtual void	save (NLMISC::IStream &os)
Some IBasicAgent method.
virtual const NLAIC::IBasicType *	clone () const
virtual void	getDebugString (std::string &t) const
virtual const NLAIC::CIdentType &	getType () const
virtual void	load (NLMISC::IStream &is)
virtual const NLAIC::IBasicType *	newInstance () const
virtual void	save (NLMISC::IStream &os)
Static Public Attributes
const NLAIC::CIdentType *	IdAgent = NULL
TProcessStatement	ProcessBuzzy = processBuzzy
TProcessStatement	ProcessEnd = processEnd
TProcessStatement	ProcessError = processError
TProcessStatement	ProcessIdle = processIdle
TProcessStatement	ProcessLocked = processLocked
CProcessResult	ProcessNotComplit = IObjectIA::CProcessResult(processNotComplete)
CProcessResult	ProcessRun = IObjectIA::CProcessResult()
Protected Member Functions
void	connectLoadStream (NLMISC::IStream &is)
void	refLoadStream (NLMISC::IStream &is)
	the loader of the class.
virtual IObjectIA *	run (const IMessageBase &m)
virtual IMessageBase *	runAchieve (const IMessageBase &m)
virtual IMessageBase *	runAsk (const IMessageBase &m)
virtual IMessageBase *	runBreak (const IMessageBase &m)
virtual IMessageBase *	runError (const IMessageBase &m)
virtual IMessageBase *	runEven (const IMessageBase &m)
virtual IMessageBase *	runExec (const IMessageBase &m)
virtual IMessageBase *	runKill (const IMessageBase &m)
virtual IMessageBase *	runService (const IMessageBase &m)
virtual IMessageBase *	runTell (const IMessageBase &m)
void	setNumRef (const IWordNumRef &ref)
Protected Attributes
TBasicList	_AgentList
TListIBasic	_Connected
TListIBasic	_Connection
IMailBox *	_Mail
	Box letter for communication service.
CProcessResult	_RunState
	Internal state of the agent.
sint	_SizeChild

NLAIAGENT::IAgentManager Class Reference

Detailed Description

Some IObjectIA method.

Some IBasicAgent method.

Some IBasicAgent method.

Public Member Functions

Static Public Attributes

Protected Member Functions

Protected Attributes

Constructor & Destructor Documentation

Member Function Documentation

Field Documentation