#include <PaCO++_operation.h>

Collaboration diagram for PaCO_operation:

Classes
struct	_com_info_t

Public Types
typedef map< long, _com_info_t * >	_com_info_map_t

Public Member Functions
void	clearAllScheduleMemory ()

virtual void	clearCommunicationMemoryId (long id) throw (InvalidArgument)

virtual void	clearScheduleMemoryId (long id) throw (InvalidArgument)

virtual void	configureTopo ()

_com_info_t *	getComMemoryId (long id)

virtual void	init (int rank, int total)

virtual void	init_complete_context (PaCO_operation *op)

virtual void	init_context (PaCO_operation *op)

virtual void	init_context_args (PaCO_operation *op)

virtual void	init_context_proxy (PaCO_operation *op)

virtual void	init_return_context (PaCO_operation *op)

virtual void	noCommunicationMemory ()

	PaCO_operation (int _number_arguments)

virtual void	setClientId (CORBA::Short request_uid)

virtual void	setClientTopo (PaCO::PacoTopology_t _client_topo, const string &way) throw (BadWayString)

virtual void	setClientTopo (PaCO::PacoTopology_t _client_topo)

virtual void	setComFab (paco_fabrique_com *fc)

virtual void	setComSchedulingFab (paco_fabrique_comScheduling *ft)

virtual void	setDisLibArg (int arg_number, const string &lib_name, const string &way) throw (BadWayString)

virtual void	setFabManager (paco_fabrique_manager *fm)

virtual void	setLibCom (const string &LibCom, void *_group)

virtual void	setLibComScheduling (const string &LibComScheduling)

virtual void	setLibThread (const string &LibThread)

virtual void	setServerTopo (PaCO::PacoTopology_t _serveur_topo, const string &way) throw (BadWayString)

virtual void	setThreadFab (paco_fabrique_thread *ft)

virtual void	setTypeClient (bool type)

virtual void	useCommunicationMemoryId (long id) throw (InvalidArgument)

virtual	~PaCO_operation ()

Public Attributes
_com_info_map_t	_com_info_map

long	_current_id

bool	_exception

int	_level

PaCO::distLoc_t	_mode

CORBA::Short	client_id

paco_fabrique_com *	FabCom

paco_fabrique_comScheduling *	FabComScheduling

paco_fabrique_manager *	FabManager

paco_fabrique_thread *	FabThread

void *	group

DistributionLibrary **	libraries_in

std::vector< char * >	libraries_in_name

DistributionLibrary **	libraries_out

std::vector< char * >	libraries_out_name

paco_com *	my_com

paco_comScheduling *	my_comScheduling

paco_condition *	my_condition

paco_condition *	my_condition2

paco_mutex *	my_mutex

paco_mutex *	my_mutex2

paco_mutex *	my_mutex3

int	myRank

PaCO::PacoTopology_t	mytopo

int	number_arguments

int	number_stubs

int	return_op

PaCO::PacoTopology_t	serveur_topo_aller

PaCO::PacoTopology_t	serveur_topo_retour

bool	termine

bool	termine2

bool	typeClient

Detailed Description

Definition at line 29 of file PaCO++_operation.h.

Member Typedef Documentation

◆ _com_info_map_t

typedef map<long, _com_info_t*> PaCO_operation::_com_info_map_t

Definition at line 143 of file PaCO++_operation.h.

Constructor & Destructor Documentation

◆ PaCO_operation()

PaCO_operation::PaCO_operation ( int _number_arguments )

Definition at line 13 of file PaCO++_operation.cc.

References _current_id, _exception, _level, _mode, client_id, FabCom, FabComScheduling, FabManager, FabThread, libraries_in, libraries_in_name, libraries_out, libraries_out_name, my_comScheduling, myRank, mytopo, number_arguments, paco_getFabriqueManager(), return_op, PaCO::ServerSide, termine, termine2, PaCO::PacoTopology_s::total, and typeClient.

 {
   // Default case : sequential client
   _current_id = -1;
   myRank = 0;
   mytopo.total = 1;
   _mode = PaCO::ServerSide;
   typeClient = false;
   termine = false;
   termine2 = false;
   client_id = -1;
   number_arguments = _number_arguments;
   libraries_in = new DistributionLibrary*[number_arguments];
   libraries_out = new DistributionLibrary*[number_arguments];
 #ifdef PACO_WARN_DISTLIB
   libraries_in_name.resize(number_arguments);
   libraries_out_name.resize(number_arguments);
 #endif
   for(int i=0; i<number_arguments; i++)
     {
       libraries_in[i] = NULL;
       libraries_out[i] = NULL;
 #ifdef PACO_WARN_DISTLIB
       libraries_in_name[i]=NULL;
       libraries_out_name[i]=NULL;
 #endif
     }
   FabManager=paco_getFabriqueManager();
   FabThread=0;
   FabCom=0;
   FabComScheduling=0;
   my_comScheduling=0;
   return_op = 0;
 
   // Exception handling
   _exception = false;
   _level = 0;
 
   // Timing
 #ifdef PADICO
   _ticks=(padico_timing_t*)malloc(sizeof(padico_timing_t)*10);
 #endif
 
 }

Here is the call graph for this function:

◆ ~PaCO_operation()

PaCO_operation::~PaCO_operation ( )

virtual

Definition at line 58 of file PaCO++_operation.cc.

References libraries_in, libraries_in_name, libraries_out, libraries_out_name, my_condition, my_condition2, my_mutex, my_mutex2, my_mutex3, and number_arguments.

 {
 #ifdef PACO_WARN_DISTLIB
   for(int i=0; i<number_arguments; i++)
     {
       if (libraries_in_name[i])
    free(libraries_in_name[i]);
       if (libraries_out_name[i])
    free(libraries_out_name[i]);
     }
 #endif
   delete libraries_in;
   delete libraries_out;
   delete my_mutex;
   delete my_condition;
   delete my_mutex2;
   delete my_condition2;
   delete my_mutex3;
   // Memories must be deleted
 }

Member Function Documentation

◆ clearAllScheduleMemory()

void PaCO_operation::clearAllScheduleMemory ( )

Definition at line 614 of file PaCO++_operation.cc.

References paco_comScheduling::clearAllSchedules(), and my_comScheduling.

Referenced by configureTopo().

 {
   if (my_comScheduling)
     my_comScheduling->clearAllSchedules();
 }

Here is the call graph for this function:

◆ clearCommunicationMemoryId()

void PaCO_operation::clearCommunicationMemoryId	(	long	id	)
throw	(	InvalidArgument
	)

virtual

Definition at line 586 of file PaCO++_operation.cc.

References _com_info_map, paco_comScheduling::clearScheduleId(), and my_comScheduling.

 {
   if (id<0)
     throw new InvalidArgument("clearCommunicationMemeoryId expects an id >0");
   
 #ifdef DEBUG_INTERNAL
   std::cerr <<"[INFO] clearing communication memory Id "<<id<<endl;
 #endif
   
   _com_info_map_t::iterator it2 = _com_info_map.find(id);
   if (it2 != _com_info_map.end())
     {
       delete _com_info_map[id];
       _com_info_map.erase(it2);
     }
 
   assert(my_comScheduling!=0);
   my_comScheduling->clearScheduleId(id);
 }

Here is the call graph for this function:

◆ clearScheduleMemoryId()

void PaCO_operation::clearScheduleMemoryId	(	long	id	)
throw	(	InvalidArgument
	)

virtual

Definition at line 607 of file PaCO++_operation.cc.

References paco_comScheduling::clearScheduleId(), and my_comScheduling.

 {
   assert(my_comScheduling!=0);
   my_comScheduling->clearScheduleId(id);
 }

Here is the call graph for this function:

◆ configureTopo()

void PaCO_operation::configureTopo ( )

virtual

Definition at line 447 of file PaCO++_operation.cc.

References clearAllScheduleMemory(), libraries_in, libraries_out, myRank, number_arguments, return_op, serveur_topo_aller, serveur_topo_retour, DistributionLibrary::setDestTopology(), DistributionLibrary::setNodeRank(), and DistributionLibrary::setSourceTopology().

Referenced by init_complete_context().

   {
     // DO NOT FORGET TO CLEAR MEMORIES (WHAT ABOUT COMMUNICATION MATRICES??) !!!!
     clearAllScheduleMemory();
     
     if (return_op == 0)
       {  
    for (int i = 0; i < number_arguments; i++)
      {
        if (libraries_in[i] != NULL)
          {
       libraries_in[i]->setDestTopology(serveur_topo_aller);
       libraries_in[i]->setSourceTopology(serveur_topo_retour);
       libraries_in[i]->setNodeRank(myRank);
          }
        if (libraries_out[i] != NULL)
          {
       libraries_out[i]->setDestTopology(serveur_topo_retour);
       libraries_out[i]->setSourceTopology(serveur_topo_aller);
       libraries_out[i]->setNodeRank(myRank);
          }
      }
       }
   }

Here is the call graph for this function:

◆ getComMemoryId()

PaCO_operation::_com_info_t * PaCO_operation::getComMemoryId ( long id )

Definition at line 527 of file PaCO++_operation.cc.

References _com_info_map.

 {
   // lookup existing communication info
   _com_info_map_t::iterator it2 = _com_info_map.find(id);
   if (it2 != _com_info_map.end()) 
     {
 #ifdef DEBUG_INTERNAL
       std::cerr <<"[INFO] found communication info for Id "<<id<<endl;
 #endif
       return  _com_info_map[id];
     }
   else
     {
       return NULL;
     }
 }

◆ init()

void PaCO_operation::init	(	int	rank,
		int	total
	)

virtual

Definition at line 342 of file PaCO++_operation.cc.

References myRank, mytopo, and PaCO::PacoTopology_s::total.

 {
     myRank = rank;
     mytopo.total = total;
 }

◆ init_complete_context()

virtual void PaCO_operation::init_complete_context ( PaCO_operation * op )

inlinevirtual

Definition at line 87 of file PaCO++_operation.h.

References configureTopo().

87 { cerr << "WARNING : init_complete_context of PaCO_Operation" << endl;}

Here is the call graph for this function:

◆ init_context()

void PaCO_operation::init_context ( PaCO_operation * op )

virtual

Definition at line 86 of file PaCO++_operation.cc.

References FabCom, FabComScheduling, FabManager, FabThread, group, my_com, my_comScheduling, my_condition, my_condition2, my_mutex, my_mutex2, my_mutex3, myRank, mytopo, number_stubs, serveur_topo_aller, serveur_topo_retour, setServerTopo(), PaCO::PacoTopology_s::total, and typeClient.

 {
   myRank = op->myRank ;
   mytopo = op->mytopo ;
   number_stubs = op->number_stubs ;
 
   FabManager = op->FabManager;
  
   group = op->group;
   my_com = op->my_com ;
   FabCom = op->FabCom ;
 
   my_comScheduling = op->my_comScheduling ;
   FabComScheduling = op->FabComScheduling ;
 
   // Client part
   typeClient = op->typeClient ; 
   if (op->serveur_topo_aller.total > 0)
     {
       setServerTopo(op->serveur_topo_aller,"in");
     }
   if (op->serveur_topo_retour.total > 0)
     {
       setServerTopo(op->serveur_topo_retour,"out");
     }
 
   // Server part
   FabThread = op->FabThread ;
   my_mutex = op->my_mutex ;
   my_condition = op->my_condition ;
   my_mutex2 = op->my_mutex2 ;
   my_condition2 = op->my_condition2 ;
   my_mutex3 = op->my_mutex3 ;
 }

Here is the call graph for this function:

◆ init_context_args()

void PaCO_operation::init_context_args ( PaCO_operation * op )

virtual

Definition at line 173 of file PaCO++_operation.cc.

References _mode, group, libraries_in, libraries_out, number_arguments, return_op, and DistributionLibrary::setCommunicator().

 {
   return_op = 1;
   number_arguments = op->number_arguments;
   _mode = op->_mode;
   libraries_in = op->libraries_out;
   libraries_out = op->libraries_in;
   
   for(int i=0; i<number_arguments; i++)
     {
       if (libraries_in[i])
         {
      libraries_in[i]->setCommunicator(group);
         }
       if (libraries_out[i])
         {
      libraries_out[i]->setCommunicator(group);
         }
     }
 }

Here is the call graph for this function:

◆ init_context_proxy()

void PaCO_operation::init_context_proxy ( PaCO_operation * op )

virtual

Definition at line 153 of file PaCO++_operation.cc.

References group, libraries_in, libraries_out, number_arguments, and DistributionLibrary::setCommunicator().

 {
   number_arguments = op->number_arguments;
   libraries_in = op->libraries_in;
   libraries_out = op->libraries_out;
 
   for(int i=0; i<number_arguments; i++)
     {
       if (libraries_in[i])
         {
      libraries_in[i]->setCommunicator(group);
         }
       if (libraries_out[i])
         {
      libraries_out[i]->setCommunicator(group);
         }
     }
 }

Here is the call graph for this function:

◆ init_return_context()

void PaCO_operation::init_return_context ( PaCO_operation * op )

virtual

Definition at line 122 of file PaCO++_operation.cc.

References FabCom, FabComScheduling, FabManager, FabThread, group, my_com, my_comScheduling, my_condition, my_condition2, my_mutex, my_mutex2, my_mutex3, myRank, mytopo, number_stubs, serveur_topo_aller, setServerTopo(), PaCO::PacoTopology_s::total, and typeClient.

 {
   myRank = op->myRank ;
   mytopo = op->mytopo ;
   number_stubs = op->number_stubs ;
 
   FabManager = op->FabManager;
 
   group = op->group ;
   my_com = op->my_com ;
   FabCom = op->FabCom ;
 
   my_comScheduling = op->my_comScheduling ;
   FabComScheduling = op->FabComScheduling ;
 
   // Client part
   typeClient = op->typeClient ; 
   if (op->serveur_topo_aller.total > 0)
     {
       setServerTopo(op->serveur_topo_aller,"in");
     }
   // Server part
   FabThread = op->FabThread ;
   my_mutex = op->my_mutex ;
   my_condition = op->my_condition ;
   my_mutex2 = op->my_mutex2 ;
   my_condition2 = op->my_condition2 ;
   my_mutex3 = op->my_mutex3 ;
 }

Here is the call graph for this function:

◆ noCommunicationMemory()

void PaCO_operation::noCommunicationMemory ( )

virtual

Definition at line 545 of file PaCO++_operation.cc.

References _current_id.

 {
   _current_id = -1; // _DO_NOT_USE_COMMUNICATION_MEMORY;
 
 #ifdef DEBUG_INTERNAL
   std::cerr <<"[INFO] not using memory"<<endl;
 #endif
 
 }

◆ setClientId()

void PaCO_operation::setClientId ( CORBA::Short request_uid )

virtual

Definition at line 80 of file PaCO++_operation.cc.

References client_id.

 {
   client_id = request_uid;
 }

◆ setClientTopo() [1/2]

void PaCO_operation::setClientTopo	(	PaCO::PacoTopology_t	_client_topo,
		const string &	way
	)
throw	(	BadWayString
	)

virtual

Definition at line 405 of file PaCO++_operation.cc.

References serveur_topo_aller, and serveur_topo_retour.

 {
    if (way == "in")
      {
        serveur_topo_retour = _client_topo;
      }
    else if (way == "out")
      {
        serveur_topo_aller = _client_topo;
      }
    else
      {
        // Bad way string
        throw BadWayString(way);
      }
 }

◆ setClientTopo() [2/2]

void PaCO_operation::setClientTopo ( PaCO::PacoTopology_t _client_topo )

virtual

Definition at line 423 of file PaCO++_operation.cc.

References serveur_topo_retour.

 {
   serveur_topo_retour =  _client_topo;
 }

◆ setComFab()

void PaCO_operation::setComFab ( paco_fabrique_com * fc )

virtual

If not set, use the fabrique manager

Definition at line 201 of file PaCO++_operation.cc.

References FabCom.

 {
     FabCom = fc;
 }

◆ setComSchedulingFab()

void PaCO_operation::setComSchedulingFab ( paco_fabrique_comScheduling * ft )

virtual

If not set, use the fabrique manager If not set, use the fabrique manager

Definition at line 501 of file PaCO++_operation.cc.

References FabComScheduling.

 {
     FabComScheduling = fcs;
 }

◆ setDisLibArg()

void PaCO_operation::setDisLibArg	(	int	arg_number,
		const string &	lib_name,
		const string &	way
	)
throw	(	BadWayString
	)

virtual

If not set, use the fabrique manager Arg part

Definition at line 261 of file PaCO++_operation.cc.

References paco_fabrique_distribution::create(), FabManager, paco_fabrique_manager::get_distribution(), libraries_in, libraries_in_name, libraries_out, and libraries_out_name.

 {
   if (way == "inout")
     {
       libraries_in [arg_number] = FabManager->get_distribution(lib_name)->create();
       libraries_out[arg_number] = FabManager->get_distribution(lib_name)->create();
 #ifdef PACO_WARN_DISTLIB
       if (libraries_in_name[arg_number]) free(libraries_in_name[arg_number]);
       if (libraries_out_name[arg_number]) free(libraries_out_name[arg_number]);
       libraries_in_name [arg_number]  = strdup(lib_name.c_str());
       libraries_out_name [arg_number] = strdup(lib_name.c_str());
 #endif
     }
   else if (way == "in")
     {
       libraries_in[arg_number] = FabManager->get_distribution(lib_name)->create();
 #ifdef PACO_WARN_DISTLIB
       if (libraries_in_name[arg_number]) free(libraries_in_name[arg_number]);
       libraries_in_name [arg_number]  = strdup(lib_name.c_str());
 #endif
     }
   else if (way == "out")
     {
       libraries_out[arg_number] = FabManager->get_distribution(lib_name)->create();
 #ifdef PACO_WARN_DISTLIB
       if (libraries_out_name[arg_number]) free(libraries_out_name[arg_number]);
       libraries_out_name [arg_number] = strdup(lib_name.c_str());
 #endif
     }
   else
     {
       // Bad way string
       throw BadWayString(way);
     }
 }

Here is the call graph for this function:

◆ setFabManager()

void PaCO_operation::setFabManager ( paco_fabrique_manager * fm )

virtual

Associate a pfm to this object. By default, paco_operation is associated to a FabriqueManager (cf paco_getFabriqueManager())

Definition at line 195 of file PaCO++_operation.cc.

References FabManager.

 {
     FabManager = fm;
 }

◆ setLibCom()

void PaCO_operation::setLibCom	(	const string &	LibCom,
		void *	_group
	)

virtual

If not set, use the fabrique manager

Definition at line 207 of file PaCO++_operation.cc.

References FabCom, FabManager, paco_fabrique_manager::get_com(), group, libraries_in, libraries_out, my_com, number_arguments, paco_fabrique_com::paco_create(), and DistributionLibrary::setCommunicator().

 {
   if (FabCom==0)
     {
       if (FabManager)
    FabCom = FabManager->get_com(LibCom);
       else
    {
      cerr << "Error: Unable to instantiate lib com "<<LibCom<<endl;
      abort();
    }      
     }
 
     group = _group;
     my_com = FabCom->paco_create(group);
 
     for(int i=0; i<number_arguments; i++)
       {
         if (libraries_in[i])
         {
             libraries_in[i]->setCommunicator(group);
         }
         if (libraries_out[i])
         {
             libraries_out[i]->setCommunicator(group);
         }
       }
 }

Here is the call graph for this function:

◆ setLibComScheduling()

void PaCO_operation::setLibComScheduling ( const string & LibComScheduling )

virtual

If not set, use the fabrique manager

Definition at line 507 of file PaCO++_operation.cc.

References paco_fabrique_comScheduling::create_comScheduling(), FabComScheduling, FabManager, paco_fabrique_manager::get_comScheduling(), and my_comScheduling.

 {
   if (FabComScheduling==0)
     {
       if (FabManager)
    FabComScheduling = FabManager->get_comScheduling(LibComScheduling);
       else
    {
      cerr << "Error: Unable to instantiate lib communication schedule "<<LibComScheduling<<endl;
      abort();
    }
    
     }
     
   if (my_comScheduling)
     delete my_comScheduling;
   my_comScheduling = FabComScheduling->create_comScheduling();
 }

Here is the call graph for this function:

◆ setLibThread()

void PaCO_operation::setLibThread ( const string & LibThread )

virtual

If not set, use the fabrique manager

Definition at line 479 of file PaCO++_operation.cc.

References FabManager, FabThread, paco_fabrique_manager::get_thread(), my_condition, my_condition2, my_mutex, my_mutex2, my_mutex3, paco_fabrique_thread::paco_create_condition(), and paco_fabrique_thread::paco_create_mutex().

 {
   if (FabThread==0)
     {
       if (FabManager)
    FabThread = FabManager->get_thread(LibThread);
       else
    {
      cerr << "Error: Unable to instantiate lib thread "<<LibThread<<endl;
      abort();
    }
    
     }
     
   my_mutex = FabThread->paco_create_mutex();
   my_condition = FabThread->paco_create_condition(my_mutex);
   my_mutex2 = FabThread->paco_create_mutex();
   my_condition2 = FabThread->paco_create_condition(my_mutex2);
   my_mutex3 = FabThread->paco_create_mutex();
 }

Here is the call graph for this function:

◆ setServerTopo()

void PaCO_operation::setServerTopo	(	PaCO::PacoTopology_t	_serveur_topo,
		const string &	way
	)
throw	(	BadWayString
	)

virtual

Definition at line 429 of file PaCO++_operation.cc.

References serveur_topo_aller, and serveur_topo_retour.

Referenced by init_context(), and init_return_context().

 {
    if (way == "in")
      {
        serveur_topo_aller = _serveur_topo;
      }
    else if (way == "out")
      {
        serveur_topo_retour = _serveur_topo;
      }
    else
      {
        // Bad way string
        throw BadWayString(way);
      }
 }

◆ setThreadFab()

void PaCO_operation::setThreadFab ( paco_fabrique_thread * ft )

virtual

If not set, use the fabrique manager

Definition at line 473 of file PaCO++_operation.cc.

References FabThread.

 {
     FabThread = ft;
 }

◆ setTypeClient()

void PaCO_operation::setTypeClient ( bool type )

virtual

Object part

Definition at line 398 of file PaCO++_operation.cc.

References typeClient.

 {
     typeClient = type;
 }

◆ useCommunicationMemoryId()

void PaCO_operation::useCommunicationMemoryId	(	long	id	)
throw	(	InvalidArgument
	)

virtual

Definition at line 556 of file PaCO++_operation.cc.

References _current_id, libraries_in, libraries_in_name, number_arguments, and DistributionLibrary::setComId().

 {
   if (id<0)
     throw new InvalidArgument("useCommunicationMemeoryId expect an id >0");
 
 #ifdef DEBUG_INTERNAL
   std::cerr <<"[INFO] using memory Id "<<id<<endl;
 #endif
 
   // set current id
   _current_id = id;
 
   // Beta patch
   for(int i=0; i<number_arguments; i++)
     {
       if (libraries_in[i])
         {
      bool res=libraries_in[i]->setComId(id);
      if (!res) {
 #ifdef PACO_WARN_DISTLIB
        std::cerr << "warning: argument #"<<i<<" with dist lib "<<libraries_in_name[i]<<" does not support comm cache\n";
 #else
        std::cerr << "warning: argument #"<<i<<" does not support comm cache\n";
 #endif
      }
         }
     }
 }