OMKPvmCentralNameServer.cxx

Go to the documentation of this file.

#include "OMKPvmCentralNameServer.h"

#include <pvm3.h>
#include "OMKSvmLink.h"
#include "OMKController.h"

#include "OMKPvmMessage.h"
#include "OMKPvmSvm.h"
using namespace std ;
using namespace OMK ;

PvmCentralNameServer::PvmCentralNameServer ( const NameServer & nameServer ) :
  NameServer ( nameServer.getCanonicalRepresentation() )
{

   correspondenceContainerType::const_iterator i ;
   for ( i = _stringToIdCorrespondenceContainer.begin() ; 
         i != _stringToIdCorrespondenceContainer.end();
         ++i ) 
      {
         _idToNamesUsingIdContainer.insert(placeOfNamesContainerType::value_type((*i).second,
                                                                                 new list<Name *>(nameServer.getNamesOfId ((*i).second) ) ) ) ;

         OMASSERT( (*_idToNamesUsingIdContainer.find((*i).second)).second->size() == _tableNbInstances[(*i).second] ) ;
      }
}



PvmCentralNameServer::~PvmCentralNameServer () 
{

} 


void PvmCentralNameServer::verifyCompatibilityWithLocalNameServer (int distantTid,
                                                                     PvmIncomingMessage & receivedMessage) 
{
  std::map<Name::idType, Name::idType> listOfNeededConversions ;
  int numberOfIncompatibilities = 0 ;
  long numberOfElements ;
  int stringLength ;
  long receivedId;
  char * receivedString = NULL ;

  receivedMessage >> numberOfElements ;
  for ( long i = 0 ; i < numberOfElements ; ++ i)
  {
    receivedMessage >> stringLength ;
    if ( receivedString != NULL ) delete [] receivedString ;
    receivedString = new char [stringLength] ;
    receivedMessage >> receivedString ;
    receivedMessage >> receivedId ;
    fastStringAccessTableType::iterator foundIterator = _fastStringAccessTable.find(receivedId) ;
    if ( foundIterator == _fastStringAccessTable.end() )
    {
      //the id is unknown to the central name server
      // either the received String is also unknown or a permutation is necessary
      //Therefore, add the sent pair
      correspondenceContainerType::iterator foundReceivedString = _stringToIdCorrespondenceContainer.find( std::string( receivedString ) );
      if ( foundReceivedString == _stringToIdCorrespondenceContainer.end() )
      {
        pair<correspondenceContainerType::iterator,bool> res = _stringToIdCorrespondenceContainer.insert(correspondenceContainerType::value_type( std::string( receivedString ), receivedId ) ) ; 
        _fastStringAccessTable[receivedId] = res.first ;

        if ( receivedId >= _nextIdentifier ) 
        {
          _nextIdentifier = receivedId + 1 ;
        }
        cerr<<"Added Id "<<receivedId<<" for "<<receivedString<<endl;
      }
      else
      {
        Name::idType correctId = (*foundReceivedString).second ;
        cerr<<"Correct id for "<<receivedString<<" is "<<correctId<<" and not "<<receivedId<<endl;
        listOfNeededConversions[receivedId] = correctId ;
        ++numberOfIncompatibilities ;
      }
    }
    else 
    {
      if ( (*(*foundIterator).second).first  != std::string( receivedString ) )
      {
        //find the id corresponding to the string
        Name::idType correctId = getIdentifier (receivedString) ;
        cerr<<"Correct id for "<<receivedString<<" is "<<correctId<<" and not "<<receivedId<<endl;
        listOfNeededConversions[receivedId] = correctId ;
        ++numberOfIncompatibilities ;
      }
    }
  }

  int oldbufid = pvm_setsbuf ( 0 ) ; //save the current send buffer 
  int bufid = pvm_initsend( PvmSvm::pvmDataEncoding ) ; 
  if ( bufid < 0 )
  {
    cerr<<"PvmCentralNameServer::PvmCentralNameServer: pvm_initsend error "<<bufid<<endl;
    OMASSERT( false ) ;
  }

  int info = pvm_pkint ( &numberOfIncompatibilities, 1, 1 ) ;

  if (info < 0 )
  {
    cerr<<"PvmCentralNameServer::PvmCentralNameServer: pvm_pkint error "<<info<<endl;
    OMASSERT( false ) ;
  }

  OMASSERT (listOfNeededConversions.size() == numberOfIncompatibilities ) ;

  for ( std::map<Name::idType, Name::idType>::iterator  j = listOfNeededConversions.begin() ;
    j != listOfNeededConversions.end() ;
    ++j )
  {
    pvm_pklong ( const_cast<Name::idType *>(&((*j).first)) , 1 , 1 ) ;
    pvm_pklong ( &((*j).second) , 1 , 1 ) ;
  }

  info = pvm_send (distantTid, PvmMessage::NameServiceVerifyResult ) ;

  if (info < 0 )
  {
    cerr<<"PvmCentralNameServer::PvmCentralNameServer: pvm_send error "<<info<<endl;
    OMASSERT( false ) ;
  }

  info = pvm_setsbuf ( oldbufid ) ; //restore the old send buffer

}

---