source: XIOS/dev/XIOS_DEV_CMIP6/src/client_server_mapping_distributed.cpp @ 1336

Last change on this file since 1336 was 1336, checked in by oabramkina, 5 years ago

Changes in case of different number of processes per secondary-server pool.

No incorrect behaviour had been found in the previous versions; this commit is just to play safe.

File size: 2.0 KB
Line 
1/*!
2   \file client_server_mapping.hpp
3   \author Ha NGUYEN
4   \since 27 Feb 2015
5   \date 16 Mars 2016
6
7   \brief Mapping between index client and server.
8   Clients pre-calculate all information of server distribution.
9 */
10#include "client_server_mapping_distributed.hpp"
11#include <limits>
12#include <boost/functional/hash.hpp>
13#include "utils.hpp"
14#include "mpi_tag.hpp"
15#include "context.hpp"
16#include "context_client.hpp"
17
18namespace xios
19{
20
21CClientServerMappingDistributed::CClientServerMappingDistributed(const boost::unordered_map<size_t,int>& globalIndexOfServer,
22                                                                 const MPI_Comm& clientIntraComm, bool isDataDistributed)
23  : CClientServerMapping(), ccDHT_(0)
24{
25  ccDHT_ = new CClientClientDHTInt(globalIndexOfServer,
26                                   clientIntraComm);
27}
28
29CClientServerMappingDistributed::~CClientServerMappingDistributed()
30{
31  if (0 != ccDHT_) delete ccDHT_;
32}
33
34/*!
35   Compute mapping global index of server which client sends to.
36   \param [in] globalIndexOnClient global index client has
37   \param [in] nbServer size of server's intracomm
38*/
39void CClientServerMappingDistributed::computeServerIndexMapping(const CArray<size_t,1>& globalIndexOnClient, int nbServer)
40{
41
42  ccDHT_->computeIndexInfoMapping(globalIndexOnClient);
43  const CClientClientDHTInt::Index2VectorInfoTypeMap& infoIndexMap = (ccDHT_->getInfoIndexMap());
44  CClientClientDHTInt::Index2VectorInfoTypeMap::const_iterator itb = infoIndexMap.begin(), ite = infoIndexMap.end(), it;
45  std::vector<size_t> nbInfoIndex(std::max(ccDHT_->getNbClient(),nbServer),0);
46
47  for (it = itb; it != ite; ++it)
48  {
49    ++nbInfoIndex[it->second[0]];
50  }
51
52  for (int idx = 0; idx < nbInfoIndex.size(); ++idx)
53  {
54    if (0 != nbInfoIndex[idx])
55    {
56      indexGlobalOnServer_[idx].resize(nbInfoIndex[idx]);
57      nbInfoIndex[idx] = 0;
58    }
59  }
60
61  for (it = itb; it != ite; ++it)
62  {
63    indexGlobalOnServer_[it->second[0]][nbInfoIndex[it->second[0]]] = (it->first);
64    ++nbInfoIndex[it->second[0]];
65  }
66}
67
68}
Note: See TracBrowser for help on using the repository browser.