Router.hpp

/* -----------------------------------------------------------------------------
 *  Diana process modelling, simulation and analysis software
 *  Copyright (c) 2005, Michael Krasnyk
 *  All rights reserved.
 *
 *  This file is a part of Diana process modelling, simulation and analysis software
 *
 *  Diana is free software; you can redistribute it and/or modify it
 *  under the terms of the GNU General Public License as published
 *  by the Free Software Foundation (see accompanying file LICENSE)
 * -----------------------------------------------------------------------------
 *  $Id$
 * -----------------------------------------------------------------------------
 *  Description:
 */


#ifndef __ROUTER_HPP
#define __ROUTER_HPP

#include <mpi.h>
#include "File.hpp"
#include "Parallel_defines.hpp"
#include <CapeOpen.hpp>
#include <Diana.hpp>


typedef struct
{ 
   CapeString szModelName;
   CapeString szESOName;
} ModelInfoType;

class CRouter 
{
private:
   int m_nMyRank; 
   int m_nProcQuantity;  
   CapeArrayLong m_DisplacementArray;
   CapeArrayString m_ProcessorsNames;
   CapeBoolean m_bNeedToUpdateRoutes;
   CapeArrayLong MyModelsIndexes; 
   std::vector<ModelInfoType> ModelsList; 

private: 
   void CollectProcessorsInfo();

   void GenerateRoutes(); 

public:
   CRouter();
      
   void AddModel( CapeLong _lModelIndex ); 
   
   
   void RemoveModel( CapeLong _lModelIndex );


   void ReadConnectionsFile( const CapeString& _szConnectionsFileName )
      throw (Common::Error::ECapeUnknown, Common::Error::ECapeInvalidArgument);


   const CapeArrayLong& GetModelsDisplacement(); 

   const CapeArrayString& GetProcessorsNames();

   CapeLong GetGlobalIndex( const CapeString& _ModelName )
      throw (Common::Error::ECapeInvalidArgument);


   CapeLong GetRank( CapeLong _Index );

   CapeArrayString GetAllModelNames();
   CapeArrayString GetAllESONames();

};


#endif