---

PsPvmCentralNameServer.cxx

Go to the documentation of this file.

#ifdef _PVM
#include "PsPvmCentralNameServer.h"

#include <stdio.h>
#include "pvm3.h"
#include "PsnSvmLink.h"
#include "PsController.h"

#include "PsnPvmMessage.h"
#include "PsnPvmSvm.h"

PsPvmCentralNameServer::PsPvmCentralNameServer ( const PsNameServer & nameServer ) :
  PsClassicalNameServer ( nameServer.getCanonicalRepresentation() )
{

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

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



PsPvmCentralNameServer::~PsPvmCentralNameServer () 
{

} 


void PsPvmCentralNameServer::verifyCompatibilityWithLocalNameServer (int distantTid,
                                                                     PsnPvmIncomingMessage & receivedMessage) 
{
   map<PsName::idType, PsName::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
           PsString receivedPsString (receivedString ) ;
           correspondenceContainerType::iterator foundReceivedString = _stringToIdCorrespondenceContainer.find( receivedPsString );
           if ( foundReceivedString == _stringToIdCorrespondenceContainer.end() )
              {
                 pair<correspondenceContainerType::iterator,bool> res = _stringToIdCorrespondenceContainer.insert(correspondenceContainerType::value_type(PsString (receivedString), receivedId)) ; 
                 _fastStringAccessTable[receivedId] = res.first ;
                 
                 if ( receivedId >= _nextIdentifier ) 
                    {
                       _nextIdentifier = receivedId + 1 ;
                    }
                 cerr<<"Added Id "<<receivedId<<" for "<<receivedString<<endl;
              }
           else
              {
                 PsName::idType correctId = (*foundReceivedString).second ;
                 cerr<<"Correct id for "<<receivedString<<" is "<<correctId<<" and not "<<receivedId<<endl;
                 listOfNeededConversions[receivedId] = correctId ;
                 ++numberOfIncompatibilities ;
              }
        }
      else 
        {
          if ( (*(*foundIterator).second).first  != PsString ( receivedString ) )
            {
               //find the id corresponding to the string
               PsName::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( PsnPvmSvm::pvmDataEncoding ) ; 
  if ( bufid < 0 )
    {
      cerr<<"PsPvmCentralNameServer::PsPvmCentralNameServer: pvm_initsend error "<<bufid<<endl;
      if (PsController::warningLevel == PsController::FatalWarnings ) exit (2) ;
    }

  int info = pvm_pkint ( &numberOfIncompatibilities, 1, 1 ) ;
  
  if (info < 0 )
    {
      cerr<<"PsPvmCentralNameServer::PsPvmCentralNameServer: pvm_pkint error "<<info<<endl;
      if (PsController::warningLevel == PsController::FatalWarnings ) exit (2) ;
    }

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

  info = pvm_send (distantTid, PsnPvmMessage::NameServiceVerifyResult ) ;
  
  if (info < 0 )
    {
      cerr<<"PsPvmCentralNameServer::PsPvmCentralNameServer: pvm_send error "<<info<<endl;
      if (PsController::warningLevel == PsController::FatalWarnings ) exit (2) ;
    }
  
  info = pvm_setsbuf ( oldbufid ) ; //restore the old send buffer

}
#endif

---