1
/////////////////////////////////////////////////////////////
3
// Copyright (c) 2003-2014 by The University of Queensland //
4
// Centre for Geoscience Computing //
5
// http://earth.uq.edu.au/centre-geoscience-computing //
7
// Primary Business: Brisbane, Queensland, Australia //
8
// Licensed under the Open Software License version 3.0 //
9
// http://www.apache.org/licenses/LICENSE-2.0 //
11
/////////////////////////////////////////////////////////////
29
\param comm the TML communicator used for sending the data back to the master
30
\param ppa a pointer to the particle array
31
\param rdf the fluid cell member function to access the data
34
ScalarFluidFieldSlave<T>::ScalarFluidFieldSlave(TML_Comm* comm,ParallelParticleArray<T>* ppa,CFluidCell::ScalarFieldFunction rdf):AFieldSlave(comm)
43
send full field data and position of the fluid cells
46
void ScalarFluidFieldSlave<T>::SendDataFull()
48
vector<pair<Vec3,double> > data_vec;
50
data_vec=m_ppa->forAllInnerCellsGet(m_rdf);
52
// send data to master
53
m_comm->send_gather(data_vec,0);
60
void ScalarFluidFieldSlave<T>::SendDataSum()
62
vector<double> data_vec;
64
// get data from particles
65
data_vec=m_ppa->forAllInnerCellsGetSum(m_rdf);
69
for(vector<double>::iterator iter=data_vec.begin();
75
vector<double> sum_vec;
76
sum_vec.push_back(sum);
77
m_comm->send_gather(sum_vec,0);
85
void ScalarFluidFieldSlave<T>::SendDataMax()
87
vector<double> data_vec;
89
// get data from particles
90
data_vec=m_ppa->forAllInnerCellsGetSum(m_rdf);
93
double max=*(data_vec.begin());
94
for(vector<double>::iterator iter=data_vec.begin();
97
max=(*iter > max) ? *iter : max;
100
vector<double> max_vec;
101
max_vec.push_back(max);
102
m_comm->send_gather(max_vec,0);
107
send data back to master
109
template <typename T>
110
void ScalarFluidFieldSlave<T>::sendData()
113
m_comm->recv_broadcast(coll_type,0);
116
case 1: SendDataFull();break;
117
case 2: SendDataSum();break;
118
case 3: SendDataMax();break;
119
default: std::cerr << "unknown collection type" << std::endl;