ParallelEnv.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 __PARALLELENV_H
#define __PARALLELENV_H


#include "DistributedMatrix.hpp"
#include "ParallelSolver.hpp"
#include "Timer.hpp"
#include <Diana.hpp>



typedef struct
{
   CapeString sComputerName;
   CapeLong lPerformance;
} ProcInfo;



class CParallelEnv : virtual public IParallelEnv
{
private:
   CapeBoolean m_bIsInitialized; 
   ProcInfo m_ProcInfo; 
   int m_nMyRank; 
   int m_nProcQuantity; 

   std::vector<CDistributedMatrix*> m_DistributedMatrixes;
   std::vector<CParallelSolver*> m_ParallelSolvers;

private:
   CapeBoolean CheckInitializedMPD();

public:
   CParallelEnv(); 
   ~CParallelEnv();     

   void Initialize(); 


   void ShowInfo();


   CapeLong ProcessID() throw (Common::Error::ECapeUnknown);


   CapeLong ProcessesNumber()  throw (Common::Error::ECapeUnknown);

   IDistributedMatrix* CreateDistributedMatrix( CapeLong nRows = 0,
      CapeLong nCols = 0 );

   void Barrier();

   IParallelSolver* CreateParallelSolver( const Common::Types::CapeString& 
      _szConnectionsFileName  )
      throw (Common::Error::ECapeUnknown, Common::Error::ECapeInvalidArgument);
};

#endif