OMK::PvmCentralNameServer Class Reference

a central name servers for the PVm version of OpenMASK More...

#include <OMKPvmCentralNameServer.h>

Inheritance diagram for OMK::PvmCentralNameServer:

[legend]Collaboration diagram for OMK::PvmCentralNameServer:

[legend]List of all members.

Public Member Functions
virtual	~PvmCentralNameServer ()
	destructor
	PvmCentralNameServer (const NameServer &origServer)
	copy constructor
virtual void	verifyCompatibilityWithLocalNameServer (int distantTid, PvmIncomingMessage &receivedMessage)
	a member function to test and correct Id to Sting known by the local servers

---

Detailed Description

a central name servers for the PVm version of OpenMASK

Author:

David Margery

Version:

1.0

Definition at line 16 of file OMKPvmCentralNameServer.h.

---

Constructor & Destructor Documentation

PvmCentralNameServer::~PvmCentralNameServer

(

)

[virtual]

destructor

Definition at line 30 of file OMKPvmCentralNameServer.cxx.

{

} 

PvmCentralNameServer::PvmCentralNameServer

(

const NameServer &

origServer

)

copy constructor

Definition at line 12 of file OMKPvmCentralNameServer.cxx.

References OMK::NameServer::_idToNamesUsingIdContainer, OMK::NameServer::_stringToIdCorrespondenceContainer, OMK::NameServer::_tableNbInstances, OMK::NameServer::getNamesOfId(), and OMASSERT.

                                                                           :
  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] ) ;
      }
}

---

Member Function Documentation

void PvmCentralNameServer::verifyCompatibilityWithLocalNameServer	(	int	distantTid,
		PvmIncomingMessage &	receivedMessage
	)			[virtual]

a member function to test and correct Id to Sting known by the local servers

Definition at line 36 of file OMKPvmCentralNameServer.cxx.

References OMK::NameServer::_fastStringAccessTable, OMK::NameServer::_nextIdentifier, OMK::NameServer::_stringToIdCorrespondenceContainer, OMK::NameServer::getIdentifier(), OMK::PvmMessage::NameServiceVerifyResult, OMASSERT, and OMK::PvmSvm::pvmDataEncoding.

Referenced by OMK::Svm::serveNameRequestsUntilEnd().

{
  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

}

---