netgen/libsrc/parallel/paralleltop.cpp

1702 lines
40 KiB
C++
Raw Normal View History

2009-01-25 07:54:27 +05:00
#ifdef PARALLEL
#include <meshing.hpp>
#include "paralleltop.hpp"
namespace netgen
{
void ParallelMeshTopology :: Reset ()
{
*testout << "ParallelMeshTopology::Reset" << endl;
if ( ntasks == 1 ) return;
PrintMessage ( 4, "RESET");
int nvold = nv;
int nedold = ned;
int nfaold = nfa;
ne = mesh.GetNE();
nv = mesh.GetNV();
nseg = mesh.GetNSeg();
nsurfel = mesh.GetNSE();
ned = mesh.GetTopology().GetNEdges();
nfa = mesh.GetTopology().GetNFaces();
loc2distedge.ChangeSize (ned);
for (int i = 0; i < ned; i++)
if (loc2distedge[i].Size() == 0)
loc2distedge.Add (i, -1); // will be the global nr
loc2distface.ChangeSize (nfa);
for (int i = 0; i < nfa; i++)
if (loc2distface[i].Size() == 0)
loc2distface.Add (i, -1); // will be the global nr
if ( !isexchangevert )
{
isexchangevert = new BitArray (nv * ( ntasks+1 ));
isexchangevert->Clear();
}
if ( !isexchangeedge )
{
isexchangeedge = new BitArray (ned*(ntasks+1) );
isexchangeedge->Clear();
}
if ( !isexchangeface )
{
isexchangeface = new BitArray (nfa*(ntasks+1) );
isexchangeface->Clear();
}
if ( !isexchangeel )
{
isexchangeel = new BitArray (ne*(ntasks+1) );
isexchangeel->Clear();
}
// if the number of vertices did not change, return
if ( nvold == nv ) return;
// faces and edges get new numbers -> delete
isexchangeface -> SetSize(nfa*(ntasks+1) );
isexchangeedge -> SetSize(ned*(ntasks+1) );
isexchangeface -> Clear();
isexchangeedge -> Clear();
SetNV(nv);
SetNE(ne);
if ( !isghostedge.Size() )
{
isghostedge.SetSize(ned);
isghostedge.Clear();
}
if ( !isghostface.Size() )
{
isghostface.SetSize(nfa);
isghostface.Clear();
}
}
ParallelMeshTopology :: ~ParallelMeshTopology ()
{
delete isexchangeface;
delete isexchangevert;
delete isexchangeedge;
delete isexchangeel;
}
ParallelMeshTopology :: ParallelMeshTopology ( const netgen::Mesh & amesh )
: mesh(amesh)
{
ned = 0; //mesh.GetTopology().GetNEdges();
nfa = 0; //mesh.GetTopology().GetNFaces();
nv = 0;
ne = 0;
np = 0;
nseg = 0;
nsurfel = 0;
neglob = 0;
nvglob = 0;
nparel = 0;
isexchangeface = 0;
isexchangevert = 0;
isexchangeel = 0;
isexchangeedge = 0;
coarseupdate = 0;
isghostedge.SetSize(0);
isghostface.SetSize(0);
overlap = 0;
}
int ParallelMeshTopology :: Glob2Loc_Vert (int globnum )
{
for (int i = 1; i <= nv; i++)
if ( globnum == loc2distvert[i][0] )
return i;
return -1;
}
int ParallelMeshTopology :: Glob2Loc_VolEl (int globnum )
{
int locnum = -1;
for (int i = 0; i < ne; i++)
{
if ( globnum == loc2distel[i][0] )
{
locnum = i+1;
}
}
return locnum;
}
int ParallelMeshTopology :: Glob2Loc_SurfEl (int globnum )
{
int locnum = -1;
for (int i = 0; i < nsurfel; i++)
{
if ( globnum == loc2distsurfel[i][0] )
{
locnum = i+1;
}
}
return locnum;
}
int ParallelMeshTopology :: Glob2Loc_Segm (int globnum )
{
int locnum = -1;
for (int i = 0; i < nseg; i++)
{
if ( globnum == loc2distsegm[i][0] )
{
locnum = i+1;
}
}
return locnum;
}
void ParallelMeshTopology :: Print() const
{
(*testout) << endl << "TOPOLOGY FOR PARALLEL MESHES" << endl << endl;
for ( int i = 1; i <= nv; i++ )
if ( IsExchangeVert (i) )
{
(*testout) << "exchange point " << i << ": global " << GetLoc2Glob_Vert(i) << endl;
for ( int dest = 0; dest < ntasks; dest ++)
if ( dest != id )
if ( GetDistantPNum( dest, i ) > 0 )
(*testout) << " p" << dest << ": " << GetDistantPNum ( dest, i ) << endl;
}
for ( int i = 1; i <= ned; i++ )
if ( IsExchangeEdge ( i ) )
{
int v1, v2;
mesh . GetTopology().GetEdgeVertices(i, v1, v2);
(*testout) << "exchange edge " << i << ": global vertices " << GetLoc2Glob_Vert(v1) << " "
<< GetLoc2Glob_Vert(v2) << endl;
for ( int dest = 0; dest < ntasks; dest++)
if ( GetDistantEdgeNum ( dest, i ) > 0 )
if ( dest != id )
{
(*testout) << " p" << dest << ": " << GetDistantEdgeNum ( dest, i ) << endl;
}
}
for ( int i = 1; i <= nfa; i++ )
if ( IsExchangeFace(i) )
{
2009-01-25 18:06:46 +05:00
Array<int> facevert;
2009-01-25 07:54:27 +05:00
mesh . GetTopology().GetFaceVertices(i, facevert);
(*testout) << "exchange face " << i << ": global vertices " ;
for ( int fi=0; fi < facevert.Size(); fi++)
(*testout) << GetLoc2Glob_Vert(facevert[fi]) << " ";
(*testout) << endl;
for ( int dest = 0; dest < ntasks; dest++)
if ( dest != id )
{
if ( GetDistantFaceNum ( dest, i ) >= 0 )
(*testout) << " p" << dest << ": " << GetDistantFaceNum ( dest, i ) << endl;
}
}
for ( int i = 1; i < mesh.GetNE(); i++)
{
if ( !IsExchangeElement(i) ) continue;
2009-01-25 18:06:46 +05:00
Array<int> vert;
2009-01-25 07:54:27 +05:00
const Element & el = mesh.VolumeElement(i);
(*testout) << "parallel local element " << i << endl;
(*testout) << "vertices " ;
for ( int j = 0; j < el.GetNV(); j++)
(*testout) << el.PNum(j+1) << " ";
(*testout) << "is ghost " << IsGhostEl(i) << endl;
(*testout) << endl;
}
}
int ParallelMeshTopology :: GetDistantPNum ( int proc, int locpnum ) const
{
if ( proc == 0 )
return loc2distvert[locpnum][0];
for (int i = 1; i < loc2distvert[locpnum].Size(); i += 2)
if ( loc2distvert[locpnum][i] == proc )
return loc2distvert[locpnum][i+1];
return -1;
}
int ParallelMeshTopology :: GetDistantFaceNum ( int proc, int locfacenum ) const
{
if ( proc == 0 )
return loc2distface[locfacenum-1][0];
for ( int i = 1; i < loc2distface[locfacenum-1].Size(); i+=2 )
if ( loc2distface[locfacenum-1][i] == proc )
return loc2distface[locfacenum-1][i+1];
return -1;
}
int ParallelMeshTopology :: GetDistantEdgeNum ( int proc, int locedgenum ) const
{
if ( proc == 0 )
return loc2distedge[locedgenum-1][0];
for ( int i = 1; i < loc2distedge[locedgenum-1].Size(); i+=2 )
if ( loc2distedge[locedgenum-1][i] == proc )
return loc2distedge[locedgenum-1][i+1];
return -1;
}
int ParallelMeshTopology :: GetDistantElNum ( int proc, int locelnum ) const
{
if ( proc == 0 )
return loc2distel[locelnum-1][0];
for ( int i = 1; i < loc2distel[locelnum-1].Size(); i+=2 )
if ( loc2distel[locelnum-1][i] == proc )
return loc2distel[locelnum-1][i+1];
return -1;
}
/*
//
// gibt anzahl an distant pnums zurueck
int ParallelMeshTopology :: GetNDistantPNums ( int locpnum ) const
{
return loc2distvert[locpnum].Size() / 2 + 1;
}
int ParallelMeshTopology :: GetNDistantFaceNums ( int locfacenum ) const
{
int size = loc2distface[locfacenum-1].Size() / 2 + 1;
return size;
}
int ParallelMeshTopology :: GetNDistantEdgeNums ( int locedgenum ) const
{
int size = loc2distedge[locedgenum-1].Size() / 2 + 1;
return size;
}
int ParallelMeshTopology :: GetNDistantElNums ( int locelnum ) const
{
int size = loc2distel[locelnum-1].Size() / 2 + 1;
return size;
}
*/
// gibt anzahl an distant pnums zurueck
2009-01-25 18:06:46 +05:00
// * pnums entspricht Array<int[2] >
2009-01-25 07:54:27 +05:00
int ParallelMeshTopology :: GetDistantPNums ( int locpnum, int * distpnums ) const
{
// distpnums[0] = loc2distvert[locpnum][0];
// for (int i = 1; i < loc2distvert[locpnum].Size(); i += 2)
// distpnums[ loc2distvert[locpnum][i] ] = loc2distvert[locpnum][i+1];
distpnums[0] = 0;
distpnums[1] = loc2distvert[locpnum][0];
for ( int i = 1; i < loc2distvert[locpnum].Size(); i++ )
distpnums[i+1] = loc2distvert[locpnum][i];
int size = loc2distvert[locpnum].Size() / 2 + 1;
return size;
}
int ParallelMeshTopology :: GetDistantFaceNums ( int locfacenum, int * distfacenums ) const
{
// distfacenums[0] = loc2distface[locfacenum-1][0];
// for ( int i = 1; i < loc2distface[locfacenum-1].Size(); i+=2 )
// distfacenums[loc2distface[locfacenum-1][i]] = loc2distface[locfacenum-1][i+1];
distfacenums[0] = 0;
distfacenums[1] = loc2distface[locfacenum-1][0];
for ( int i = 1; i < loc2distface[locfacenum-1].Size(); i++ )
distfacenums[i+1] = loc2distface[locfacenum-1][i];
int size = loc2distface[locfacenum-1].Size() / 2 + 1;
return size;
}
int ParallelMeshTopology :: GetDistantEdgeNums ( int locedgenum, int * distedgenums ) const
{
// distedgenums[0] = loc2distedge[locedgenum-1][0];
// for ( int i = 1; i < loc2distedge[locedgenum-1].Size(); i+=2 )
// distedgenums[loc2distedge[locedgenum-1][i]] = loc2distedge[locedgenum-1][i+1];
distedgenums[0] = 0;
distedgenums[1] = loc2distedge[locedgenum-1][0];
for ( int i = 1; i < loc2distedge[locedgenum-1].Size(); i++ )
distedgenums[i+1] = loc2distedge[locedgenum-1][i];
int size = loc2distedge[locedgenum-1].Size() / 2 + 1;
return size;
}
int ParallelMeshTopology :: GetDistantElNums ( int locelnum, int * distelnums ) const
{
// distelnums[0] = loc2distel[locelnum-1][0];
// for ( int i = 1; i < loc2distel[locelnum-1].Size(); i+=2 )
// distelnums[loc2distel[locelnum-1][i]] = loc2distel[locelnum-1][i+1];
distelnums[0] = 0;
distelnums[1] = loc2distel[locelnum-1][0];
for ( int i = 1; i < loc2distel[locelnum-1].Size(); i++ )
distelnums[i+1] = loc2distel[locelnum-1][i];
int size = loc2distel[locelnum-1].Size() / 2 + 1;
return size;
}
void ParallelMeshTopology :: SetDistantFaceNum ( int dest, int locnum, int distnum )
{
if ( dest == 0 )
{
loc2distface[locnum-1][0] = distnum;
return;
}
for ( int i = 1; i < loc2distface[locnum-1].Size(); i+=2 )
if ( loc2distface[locnum-1][i] == dest )
{
loc2distface[locnum-1][i+1] = distnum;
return;
}
loc2distface.Add(locnum-1, dest);
loc2distface.Add(locnum-1, distnum);
}
void ParallelMeshTopology :: SetDistantPNum ( int dest, int locnum, int distnum )
{
if ( dest == 0 )
{
loc2distvert[locnum][0] = distnum; // HERE
return;
}
for ( int i = 1; i < loc2distvert[locnum].Size(); i+=2 )
if ( loc2distvert[locnum][i] == dest )
{
loc2distvert[locnum][i+1] = distnum;
return;
}
loc2distvert.Add (locnum, dest);
loc2distvert.Add (locnum, distnum);
}
void ParallelMeshTopology :: SetDistantEdgeNum ( int dest, int locnum, int distnum )
{
if ( dest == 0 )
{
loc2distedge[locnum-1][0] = distnum;
return;
}
for ( int i = 1; i < loc2distedge[locnum-1].Size(); i+=2 )
if ( loc2distedge[locnum-1][i] == dest )
{
loc2distedge[locnum-1][i+1] = distnum;
return;
}
loc2distedge.Add (locnum-1, dest);
loc2distedge.Add (locnum-1, distnum);
}
void ParallelMeshTopology :: SetDistantEl ( int dest, int locnum, int distnum )
{
if ( dest == 0 )
{
loc2distel[locnum-1][0] = distnum;
return;
}
for ( int i = 1; i < loc2distel[locnum-1].Size(); i+=2 )
if ( loc2distel[locnum-1][i] == dest )
{
loc2distel[locnum-1][i+1] = distnum;
return;
}
loc2distel.Add (locnum-1, dest);
loc2distel.Add (locnum-1, distnum);
}
void ParallelMeshTopology :: SetDistantSurfEl ( int dest, int locnum, int distnum )
{
if ( dest == 0 )
{
loc2distsurfel[locnum-1][0] = distnum;
return;
}
for ( int i = 1; i < loc2distsurfel[locnum-1].Size(); i+=2 )
if ( loc2distsurfel[locnum-1][i] == dest )
{
loc2distsurfel[locnum-1][i+1] = distnum;
return;
}
loc2distsurfel.Add (locnum-1, dest);
loc2distsurfel.Add (locnum-1, distnum);
}
void ParallelMeshTopology :: SetDistantSegm ( int dest, int locnum, int distnum )
{
if ( dest == 0 )
{
loc2distsegm[locnum-1][0] = distnum;
return;
}
for (int i = 1; i < loc2distsegm[locnum-1].Size(); i+=2 )
if ( loc2distsegm[locnum-1][i] == dest )
{
loc2distsegm[locnum-1][i+1] = distnum;
return;
}
loc2distsegm.Add (locnum-1, dest);
loc2distsegm.Add (locnum-1, distnum);
}
2009-01-25 18:06:46 +05:00
void ParallelMeshTopology :: GetVertNeighbours ( int vnum, Array<int> & dests ) const
2009-01-25 07:54:27 +05:00
{
dests.SetSize(0);
int i = 1;
while ( i < loc2distvert[vnum].Size() )
{
dests.Append ( loc2distvert[vnum][i] );
i+=2;
}
}
void ParallelMeshTopology :: Update ()
{
ne = mesh.GetNE();
nv = mesh.GetNV();
nseg = mesh.GetNSeg();
nsurfel = mesh.GetNSE();
ned = mesh.GetTopology().GetNEdges();
nfa = mesh.GetTopology().GetNFaces();
}
void ParallelMeshTopology :: UpdateRefinement ()
{
;
}
void ParallelMeshTopology :: UpdateCoarseGridGlobal ()
{
PrintMessage ( 1, "UPDATE GLOBAL COARSEGRID STARTS" ); // JS
// MPI_Barrier (MPI_COMM_WORLD);
// PrintMessage ( 1, "all friends are here " ); // JS
// MPI_Barrier (MPI_COMM_WORLD);
int timer = NgProfiler::CreateTimer ("UpdateCoarseGridGlobal");
NgProfiler::RegionTimer reg(timer);
*testout << "ParallelMeshTopology :: UpdateCoarseGridGlobal" << endl;
const MeshTopology & topology = mesh.GetTopology();
2009-01-25 18:06:46 +05:00
Array<int> sendarray, recvarray;
2009-01-25 07:54:27 +05:00
nfa = topology . GetNFaces();
ned = topology . GetNEdges();
np = mesh . GetNP();
nv = mesh . GetNV();
ne = mesh . GetNE();
nseg = mesh.GetNSeg();
nsurfel = mesh.GetNSE();
// low order processor - save mesh partition
if ( id == 0 )
{
if ( !isexchangeel )
{
isexchangeel = new BitArray ( (ntasks+1) * ne );
isexchangeel -> Clear();
}
for ( int eli = 1; eli <= ne; eli++ )
{
loc2distel[eli-1][0] = eli;
SetExchangeElement ( eli );
const Element & el = mesh . VolumeElement ( eli );
int dest = el . GetPartition ( );
SetExchangeElement ( dest, eli );
for ( int i = 0; i < el.GetNP(); i++ )
{
SetExchangeVert ( dest, el.PNum(i+1) );
SetExchangeVert ( el.PNum(i+1) );
}
2009-01-25 18:06:46 +05:00
Array<int> edges;
2009-01-25 07:54:27 +05:00
topology . GetElementEdges ( eli, edges );
for ( int i = 0; i < edges.Size(); i++ )
{
SetExchangeEdge ( dest, edges[i] );
SetExchangeEdge ( edges[i] );
}
topology . GetElementFaces ( eli, edges );
for ( int i = 0; i < edges.Size(); i++ )
{
SetExchangeFace ( dest, edges[i] );
SetExchangeFace ( edges[i] );
}
}
// HERE
for ( int i = 1; i <= mesh .GetNV(); i++)
loc2distvert[i][0] = i;
for ( int i = 0; i < mesh . GetNSeg(); i++)
loc2distsegm[i][0] = i+1;
for ( int i = 0; i < mesh . GetNSE(); i++)
loc2distsurfel[i][0] = i+1;
for ( int i = 0; i < topology .GetNEdges(); i++)
loc2distedge[i][0] = i+1;
for ( int i = 0; i < topology .GetNFaces(); i++)
loc2distface[i][0] = i+1;
}
if ( id == 0 )
sendarray.Append (nfa);
BitArray recvface(nfa);
recvface.Clear();
/*
2009-01-25 18:06:46 +05:00
Array<int> edges, pnums, faces;
2009-01-25 07:54:27 +05:00
for ( int el = 1; el <= ne; el++ )
{
topology.GetElementFaces (el, faces);
int globeli = GetLoc2Glob_VolEl(el);
for ( int fai = 0; fai < faces.Size(); fai++)
{
int fa = faces[fai];
topology.GetElementEdges ( el, edges );
topology.GetFaceVertices ( fa, pnums );
// send :
// localfacenum
// np
// ned
// globalpnums
// localpnums
// localedgenums mit globalv1, globalv2
sendarray. Append ( fa );
sendarray. Append ( globeli );
sendarray. Append ( pnums.Size() );
sendarray. Append ( edges.Size() );
if (id == 0)
for ( int i = 0; i < pnums.Size(); i++ )
sendarray. Append( pnums[i] );
else
for ( int i = 0; i < pnums.Size(); i++ )
sendarray. Append( GetLoc2Glob_Vert(pnums[i]) );
for ( int i = 0; i < pnums.Size(); i++ )
sendarray. Append(pnums[i] );
for ( int i = 0; i < edges.Size(); i++ )
{
sendarray. Append(edges[i] );
int v1, v2;
topology . GetEdgeVertices ( edges[i], v1, v2 );
int dv1 = GetLoc2Glob_Vert ( v1 );
int dv2 = GetLoc2Glob_Vert ( v2 );
if (id > 0) if ( dv1 > dv2 ) swap ( dv1, dv2 );
sendarray . Append ( dv1 );
sendarray . Append ( dv2 );
}
}
}
*/
// new version
2009-01-25 18:06:46 +05:00
Array<int> edges, pnums, faces, elpnums;
2009-01-25 07:54:27 +05:00
sendarray.Append (ne);
for ( int el = 1; el <= ne; el++ )
{
topology.GetElementFaces (el, faces);
topology.GetElementEdges ( el, edges );
const Element & volel = mesh.VolumeElement (el);
int globeli = GetLoc2Glob_VolEl(el);
sendarray. Append ( globeli );
sendarray. Append ( faces.Size() );
sendarray. Append ( edges.Size() );
sendarray. Append ( volel.GetNP() );
for ( int i = 0; i < faces.Size(); i++ )
sendarray. Append(faces[i] );
for ( int i = 0; i < edges.Size(); i++ )
sendarray. Append(edges[i] );
for ( int i = 0; i < volel.GetNP(); i++ )
if (id == 0)
sendarray. Append(volel[i] );
else
sendarray. Append(GetLoc2Glob_Vert (volel[i]));
}
// end new version
BitArray edgeisinit(ned), vertisinit(np);
edgeisinit.Clear();
vertisinit.Clear();
2009-01-25 18:06:46 +05:00
// Array for temporary use, to find local from global element fast
Array<int,1> glob2loc_el;
2009-01-25 07:54:27 +05:00
if ( id != 0 )
{
glob2loc_el.SetSize (neglob);
glob2loc_el = -1;
for ( int locel = 1; locel <= mesh.GetNE(); locel++)
glob2loc_el[GetLoc2Glob_VolEl(locel)] = locel;
}
// MPI_Barrier (MPI_COMM_WORLD);
MPI_Request sendrequest;
if (id == 0)
{
PrintMessage (4, "UpdateCoarseGridGlobal : bcast, size = ", int (sendarray.Size()*sizeof(int)) );
MyMPI_Bcast ( sendarray );
}
else
MyMPI_ISend ( sendarray, 0, sendrequest );
int nloops = (id == 0) ? ntasks-1 : 1;
for (int hi = 0; hi < nloops; hi++)
{
int sender;
if (id == 0)
{
sender = MyMPI_Recv ( recvarray );
PrintMessage (4, "have received from ", sender);
}
else
{
MyMPI_Bcast ( recvarray );
sender = 0;
}
// compare received vertices with own ones
int ii = 0;
int cntel = 0;
int volel = 1;
if ( id != 0 )
nfaglob = recvarray[ii++];
2009-01-25 18:06:46 +05:00
Array<int> faces, edges;
Array<int> pnums, globalpnums;
2009-01-25 07:54:27 +05:00
int recv_ne = recvarray[ii++];
for (int hi = 0; hi < recv_ne; hi++)
{
int globvolel = recvarray[ii++];
int distnfa = recvarray[ii++];
int distned = recvarray[ii++];
int distnp = recvarray[ii++];
if ( id > 0 )
volel = glob2loc_el[globvolel];
else
volel = globvolel;
if (volel != -1)
{
topology.GetElementFaces( volel, faces);
topology.GetElementEdges ( volel, edges);
const Element & volelement = mesh.VolumeElement (volel);
for ( int i = 0; i < faces.Size(); i++)
SetDistantFaceNum ( sender, faces[i], recvarray[ii++]);
for ( int i = 0; i < edges.Size(); i++)
SetDistantEdgeNum ( sender, edges[i], recvarray[ii++]);
for ( int i = 0; i < distnp; i++)
SetDistantPNum ( sender, volelement[i], recvarray[ii++]);
}
else
ii += distnfa + distned + distnp;
}
}
coarseupdate = 1;
if (id != 0)
{
MPI_Status status;
MPI_Wait (&sendrequest, &status);
}
#ifdef SCALASCA
#pragma pomp inst end(updatecoarsegrid)
#endif
}
void ParallelMeshTopology :: UpdateCoarseGrid ()
{
int timer = NgProfiler::CreateTimer ("UpdateCoarseGrid");
NgProfiler::RegionTimer reg(timer);
#ifdef SCALASCA
#pragma pomp inst begin(updatecoarsegrid)
#endif
(*testout) << "UPDATE COARSE GRID PARALLEL TOPOLOGY " << endl;
PrintMessage ( 1, "UPDATE COARSE GRID PARALLEL TOPOLOGY " );
// find exchange edges - first send exchangeedges locnum, v1, v2
// receive distant distnum, v1, v2
// find matching
const MeshTopology & topology = mesh.GetTopology();
UpdateCoarseGridGlobal();
if ( id == 0 ) return;
2009-01-25 18:06:46 +05:00
Array<int> * sendarray, *recvarray;
sendarray = new Array<int> (0);
recvarray = new Array<int>;
2009-01-25 07:54:27 +05:00
nfa = topology . GetNFaces();
ned = topology . GetNEdges();
np = mesh . GetNP();
nv = mesh . GetNV();
ne = mesh . GetNE();
nseg = mesh.GetNSeg();
nsurfel = mesh.GetNSE();
sendarray->SetSize (0);
BitArray recvface(nfa);
recvface.Clear();
for ( int fa = 1; fa <= nfa; fa++ )
{
if ( !IsExchangeFace ( fa ) ) continue;
2009-01-25 18:06:46 +05:00
Array<int> edges, pnums;
2009-01-25 07:54:27 +05:00
int globfa = GetDistantFaceNum ( 0, fa );
topology.GetFaceEdges ( fa, edges );
topology.GetFaceVertices ( fa, pnums );
// send :
// localfacenum
// globalfacenum
// np
// ned
// globalpnums
// localpnums
// localedgenums mit globalv1, globalv2
//
sendarray -> Append ( fa );
sendarray -> Append ( globfa );
sendarray -> Append ( pnums.Size() );
sendarray -> Append ( edges.Size() );
for ( int i = 0; i < pnums.Size(); i++ )
{
sendarray -> Append( GetLoc2Glob_Vert(pnums[i]) );
}
for ( int i = 0; i < pnums.Size(); i++ )
{
sendarray -> Append(pnums[i] );
}
for ( int i = 0; i < edges.Size(); i++ )
{
sendarray -> Append(edges[i] );
int v1, v2;
topology . GetEdgeVertices ( edges[i], v1, v2 );
int dv1 = GetLoc2Glob_Vert ( v1 );
int dv2 = GetLoc2Glob_Vert ( v2 );
sendarray -> Append ( dv1 );
sendarray -> Append ( dv2 );
}
}
BitArray edgeisinit(ned), vertisinit(np);
edgeisinit.Clear();
vertisinit.Clear();
2009-01-25 18:06:46 +05:00
// Array for temporary use, to find local from global element fast
2009-01-25 07:54:27 +05:00
// only for not too big meshes
// seems ok, as low-order space is treated on one proc
2009-01-25 18:06:46 +05:00
Array<int,1> * glob2locfa;
glob2locfa = new Array<int,1> ( nfaglob );
2009-01-25 07:54:27 +05:00
(*glob2locfa) = -1;
for ( int locfa = 1; locfa <= nfa; locfa++)
{
if ( !IsExchangeFace ( locfa ) ) continue;
(*glob2locfa)[GetDistantFaceNum(0, locfa) ] = locfa;
}
for ( int sender = 1; sender < ntasks; sender ++ )
{
if ( id == sender )
MyMPI_Bcast ( *sendarray, sender-1, MPI_HIGHORDER_COMM);
if ( id != sender )
{
MyMPI_Bcast ( *recvarray, sender-1, MPI_HIGHORDER_COMM);
// compare received vertices with own ones
int ii = 0;
int cntel = 0;
int locfa = 1;
while ( ii< recvarray -> Size() )
{
// receive list :
// distant facenum
// global facenum
// np
// ned
// globalpnums
// distant pnums
// distant edgenums mit globalv1, globalv2
int distfa = (*recvarray)[ii++];
int globfa = (*recvarray)[ii++];
int distnp = (*recvarray)[ii++];
int distned =(*recvarray)[ii++];
int locfa = (*glob2locfa) [globfa];
if ( locfa == -1 )
{
ii += 2*distnp + 3*distned;
locfa = 1;
continue;
}
2009-01-25 18:06:46 +05:00
Array<int> edges;
2009-01-25 07:54:27 +05:00
int fa = locfa;
2009-01-25 18:06:46 +05:00
Array<int> pnums, globalpnums;
2009-01-25 07:54:27 +05:00
topology.GetFaceEdges ( fa, edges );
topology.GetFaceVertices ( fa, pnums );
globalpnums.SetSize ( distnp );
for ( int i = 0; i < distnp; i++)
globalpnums[i] = GetLoc2Glob_Vert ( pnums[i] );
SetDistantFaceNum ( sender, fa, distfa );
// find exchange points
for ( int i = 0; i < distnp; i++)
{
int distglobalpnum = (*recvarray)[ii+i];
for ( int j = 0; j < distnp; j++ )
if ( globalpnums[j] == distglobalpnum )
{
// set sender -- distpnum ---- locpnum
int distpnum = (*recvarray)[ii + i +distnp];
SetDistantPNum ( sender, pnums[j], distpnum );
}
}
int * distedgenums = new int [distned];
// find exchange edges
for ( int i = 0; i < edges.Size(); i++)
{
int v1, v2;
topology . GetEdgeVertices ( edges[i], v1, v2 );
int dv1 = GetLoc2Glob_Vert ( v1 );
int dv2 = GetLoc2Glob_Vert ( v2 );
if ( dv1 > dv2 ) swap ( dv1, dv2 );
for ( int ed = 0; ed < distned; ed++)
{
distedgenums[ed] = (*recvarray)[ii + 2*distnp + 3*ed];
int ddv1 = (*recvarray)[ii + 2*distnp + 3*ed + 1];
int ddv2 = (*recvarray)[ii + 2*distnp + 3*ed + 2];
if ( ddv1 > ddv2 ) swap ( ddv1, ddv2 );
if ( dv1 == ddv1 && dv2 == ddv2 )
{
// set sender -- distednum -- locednum
SetDistantEdgeNum ( sender, edges[i], distedgenums[ed] );
}
}
}
delete [] distedgenums;
ii += 2*distnp + 3*distned;
}
}
}
// set which elements are where for the master processor
delete sendarray; delete recvarray;
if ( id > 0 )
delete glob2locfa;
coarseupdate = 1;
#ifdef SCALASCA
#pragma pomp inst end(updatecoarsegrid)
#endif
}
void ParallelMeshTopology :: UpdateCoarseGridOverlap ()
{
UpdateCoarseGridGlobal();
#ifdef SCALASCA
#pragma pomp inst begin(updatecoarsegrid)
#endif
(*testout) << "UPDATE COARSE GRID PARALLEL TOPOLOGY, OVERLAP " << endl;
PrintMessage ( 1, "UPDATE COARSE GRID PARALLEL TOPOLOGY, OVERLAP " );
const MeshTopology & topology = mesh.GetTopology();
nfa = topology . GetNFaces();
ned = topology . GetNEdges();
np = mesh . GetNP();
nv = mesh . GetNV();
ne = mesh . GetNE();
nseg = mesh.GetNSeg();
nsurfel = mesh.GetNSE();
if ( id != 0 )
{
// find exchange edges - first send exchangeedges locnum, v1, v2
// receive distant distnum, v1, v2
// find matching
2009-01-25 18:06:46 +05:00
Array<int> * sendarray, *recvarray;
sendarray = new Array<int> (0);
recvarray = new Array<int>;
2009-01-25 07:54:27 +05:00
sendarray->SetSize (0);
BitArray recvface(nfa);
recvface.Clear();
for ( int el = 1; el <= ne; el++ )
{
2009-01-25 18:06:46 +05:00
Array<int> edges, pnums, faces;
2009-01-25 07:54:27 +05:00
topology.GetElementFaces (el, faces);
int globeli = GetLoc2Glob_VolEl(el);
for ( int fai = 0; fai < faces.Size(); fai++)
{
int fa = faces[fai];
topology.GetFaceEdges ( fa, edges );
topology.GetFaceVertices ( fa, pnums );
if ( !IsExchangeElement ( el ) ) continue;
int globfa = GetDistantFaceNum(0, fa) ;
// send :
// localfacenum
// globalfacenum
// globalelnum
// np
// ned
// globalpnums
// localpnums
// localedgenums mit globalelnums mit globalv1, globalv2
//
sendarray -> Append ( fa );
sendarray -> Append ( globfa );
sendarray -> Append ( globeli );
sendarray -> Append ( pnums.Size() );
sendarray -> Append ( edges.Size() );
for ( int i = 0; i < pnums.Size(); i++ )
{
sendarray -> Append( GetLoc2Glob_Vert(pnums[i]) );
}
for ( int i = 0; i < pnums.Size(); i++ )
{
sendarray -> Append(pnums[i] );
}
for ( int i = 0; i < edges.Size(); i++ )
{
int globedge = GetDistantEdgeNum(0, edges[i] );
int v1, v2;
topology . GetEdgeVertices ( edges[i], v1, v2 );
int dv1 = GetLoc2Glob_Vert ( v1 );
int dv2 = GetLoc2Glob_Vert ( v2 );
sendarray -> Append(edges[i] );
sendarray -> Append (globedge);
sendarray -> Append ( dv1 );
sendarray -> Append ( dv2 );
}
}
}
BitArray edgeisinit(ned), vertisinit(np);
edgeisinit.Clear();
vertisinit.Clear();
2009-01-25 18:06:46 +05:00
// Array for temporary use, to find local from global element fast
2009-01-25 07:54:27 +05:00
// only for not too big meshes
// seems ok, as low-order space is treated on one proc
2009-01-25 18:06:46 +05:00
Array<int,1> * glob2loc_el;
2009-01-25 07:54:27 +05:00
2009-01-25 18:06:46 +05:00
glob2loc_el = new Array<int,1> ( neglob );
2009-01-25 07:54:27 +05:00
(*glob2loc_el) = -1;
for ( int locel = 1; locel <= mesh.GetNE(); locel++)
(*glob2loc_el)[GetLoc2Glob_VolEl(locel)] = locel;
for ( int sender = 1; sender < ntasks; sender ++ )
{
if ( id == sender )
MyMPI_Bcast (*sendarray, sender-1, MPI_HIGHORDER_COMM);
// {
// for ( int dest = 1; dest < ntasks; dest ++ )
// if ( dest != id)
// {
// MyMPI_Send (*sendarray, dest);
// }
// }
if ( id != sender )
{
// MyMPI_Recv ( *recvarray, sender);
MyMPI_Bcast (*recvarray, sender-1, MPI_HIGHORDER_COMM);
// compare received vertices with own ones
int ii = 0;
int cntel = 0;
int volel = 1;
while ( ii< recvarray -> Size() )
{
// receive list :
// distant facenum
// np
// ned
// globalpnums
// distant pnums
// distant edgenums mit globalv1, globalv2
int distfa = (*recvarray)[ii++];
int globfa = (*recvarray)[ii++];
int globvolel = (*recvarray)[ii++];
int distnp = (*recvarray)[ii++];
int distned =(*recvarray)[ii++];
if ( id > 0 ) // GetLoc2Glob_VolEl ( volel ) != globvolel )
volel = (*glob2loc_el)[globvolel]; //Glob2Loc_VolEl ( globvolel );
else
volel = globvolel;
if ( volel == -1 )
{
ii += 2*distnp + 4*distned;
volel = 1;
continue;
}
2009-01-25 18:06:46 +05:00
Array<int> faces, edges;
2009-01-25 07:54:27 +05:00
topology.GetElementFaces( volel, faces);
topology.GetElementEdges ( volel, edges);
for ( int fai= 0; fai < faces.Size(); fai++ )
{
int fa = faces[fai];
if ( !IsExchangeFace ( fa ) && sender != 0 ) continue;
// if ( recvface.Test ( fa-1 ) ) continue;
2009-01-25 18:06:46 +05:00
Array<int> pnums, globalpnums;
2009-01-25 07:54:27 +05:00
//topology.GetFaceEdges ( fa, edges );
topology.GetFaceVertices ( fa, pnums );
// find exchange faces ...
// have to be of same type
if ( pnums.Size () != distnp ) continue;
globalpnums.SetSize ( distnp );
for ( int i = 0; i < distnp; i++)
globalpnums[i] = GetLoc2Glob_Vert ( pnums[i] );
// test if 3 vertices match
bool match = 1;
for ( int i = 0; i < distnp; i++)
if ( !globalpnums.Contains ( (*recvarray)[ii+i] ) )
match = 0;
if ( !match ) continue;
// recvface.Set(fa-1);
SetDistantFaceNum ( sender, fa, distfa );
SetDistantFaceNum ( 0, fa, globfa );
// find exchange points
for ( int i = 0; i < distnp; i++)
{
int distglobalpnum = (*recvarray)[ii+i];
for ( int j = 0; j < distnp; j++ )
if ( globalpnums[j] == distglobalpnum )
{
// set sender -- distpnum ---- locpnum
int distpnum = (*recvarray)[ii + i +distnp];
SetDistantPNum ( sender, pnums[j], distpnum );
}
}
int * distedgenums = new int [distned];
// find exchange edges
for ( int i = 0; i < edges.Size(); i++)
{
int v1, v2;
topology . GetEdgeVertices ( edges[i], v1, v2 );
int dv1 = GetLoc2Glob_Vert ( v1 );
int dv2 = GetLoc2Glob_Vert ( v2 );
if ( dv1 > dv2 ) swap ( dv1, dv2 );
for ( int ed = 0; ed < distned; ed++)
{
distedgenums[ed] = (*recvarray)[ii + 2*distnp + 4*ed];
int globedgenum = (*recvarray)[ii + 2*distnp + 4*ed + 1];
int ddv1 = (*recvarray)[ii + 2*distnp + 4*ed + 2];
int ddv2 = (*recvarray)[ii + 2*distnp + 4*ed + 3];
if ( ddv1 > ddv2 ) swap ( ddv1, ddv2 );
if ( dv1 == ddv1 && dv2 == ddv2 )
{
// set sender -- distednum -- locednum
SetDistantEdgeNum ( sender, edges[i], distedgenums[ed] );
SetDistantEdgeNum ( 0, edges[i], globedgenum );
}
}
}
delete [] distedgenums;
}
ii += 2*distnp + 4*distned;
}
}
}
// set which elements are where for the master processor
delete sendarray; delete recvarray;
if ( id > 0 )
delete glob2loc_el;
coarseupdate = 1;
}
// send global-local el/face/edge/vert-info to id 0
// nfa = topology . GetNFaces();
// ned = topology . GetNEdges();
// np = mesh . GetNP();
// nv = mesh . GetNV();
// ne = mesh . GetNE();
// nseg = mesh.GetNSeg();
// nsurfel = mesh.GetNSE();
if ( id != 0 )
{
2009-01-25 18:06:46 +05:00
Array<int> * sendarray;
sendarray = new Array<int> (4);
2009-01-25 07:54:27 +05:00
int sendnfa = 0, sendned = 0;
(*sendarray)[0] = ne;
(*sendarray)[1] = nfa;
(*sendarray)[2] = ned;
(*sendarray)[3] = np;
int ii = 4;
for ( int el = 1; el <= ne; el++ )
(*sendarray).Append ( GetLoc2Glob_VolEl (el ) );
for ( int fa = 1; fa <= nfa; fa++ )
{
if ( !IsExchangeFace (fa) ) continue;
sendnfa++;
(*sendarray).Append ( fa );
(*sendarray).Append ( GetDistantFaceNum (0, fa) );
}
for ( int ed = 1; ed <= ned; ed++ )
{
if ( !IsExchangeEdge (ed) ) continue;
sendned++;
sendarray->Append ( ed );
sendarray->Append ( GetDistantEdgeNum(0, ed) );
}
for ( int vnum = 1; vnum <= np; vnum++ )
sendarray->Append ( GetLoc2Glob_Vert(vnum) );
(*sendarray)[1] = sendnfa;
(*sendarray)[2] = sendned;
MyMPI_Send (*sendarray, 0);
delete sendarray;
}
else
{
2009-01-25 18:06:46 +05:00
Array<int> * recvarray = new Array<int>;
2009-01-25 07:54:27 +05:00
for ( int sender = 1; sender < ntasks; sender++ )
{
MyMPI_Recv ( *recvarray, sender);
int distnel = (*recvarray)[0];
int distnfa = (*recvarray)[1];
int distned = (*recvarray)[2];
int distnp = (*recvarray)[3];
int ii = 4;
for ( int el = 1; el <= distnel; el++ )
SetDistantEl ( sender, (*recvarray)[ii++], el );
for ( int fa = 1; fa <= distnfa; fa++ )
{
int distfa = (*recvarray)[ii++];
SetDistantFaceNum ( sender, (*recvarray)[ii++], distfa );
}
for ( int ed = 1; ed <= distned; ed++ )
{
int disted = (*recvarray)[ii++];
SetDistantEdgeNum ( sender, (*recvarray)[ii++], disted );
}
for ( int vnum = 1; vnum <= distnp; vnum++ )
SetDistantPNum ( sender, (*recvarray)[ii++], vnum );
}
delete recvarray;
}
#ifdef SCALASCA
#pragma pomp inst end(updatecoarsegrid)
#endif
}
void ParallelMeshTopology :: UpdateTopology ()
{
// loop over parallel faces and edges, find new local face/edge number,
const MeshTopology & topology = mesh.GetTopology();
int nfa = topology.GetNFaces();
int ned = topology.GetNEdges();
isghostedge.SetSize(ned);
isghostface.SetSize(nfa);
isghostedge.Clear();
isghostface.Clear();
for ( int ed = 1; ed <= ned; ed++)
{
int v1, v2;
topology.GetEdgeVertices ( ed, v1, v2 );
if ( IsGhostVert(v1) || IsGhostVert(v2) )
SetGhostEdge ( ed );
}
2009-01-25 18:06:46 +05:00
Array<int> pnums;
2009-01-25 07:54:27 +05:00
for ( int fa = 1; fa <= nfa; fa++)
{
topology.GetFaceVertices ( fa, pnums );
for ( int i = 0; i < pnums.Size(); i++)
if ( IsGhostVert( pnums[i] ) )
{
SetGhostFace ( fa );
break;
}
}
}
void ParallelMeshTopology :: UpdateExchangeElements()
{
(*testout) << "UPDATE EXCHANGE ELEMENTS " << endl;
const MeshTopology & topology = mesh.GetTopology();
isexchangeedge->SetSize ( (ntasks+1) * topology.GetNEdges() );
isexchangeface->SetSize ( (ntasks+1) * topology.GetNFaces() );
isexchangeedge->Clear();
isexchangeface->Clear();
for ( int eli = 1; eli <= mesh.GetNE(); eli++)
{
if ( ! IsExchangeElement ( eli ) ) continue;
const Element & el = mesh.VolumeElement(eli);
2009-01-25 18:06:46 +05:00
Array<int> faces, edges;
2009-01-25 07:54:27 +05:00
int np = el.NP();
topology.GetElementEdges ( eli, edges );
topology.GetElementFaces ( eli, faces );
for ( int i = 0; i < edges.Size(); i++)
{
SetExchangeEdge ( edges[i] );
}
for ( int i = 0; i < faces.Size(); i++)
{
SetExchangeFace ( faces[i] );
}
for ( int i = 0; i < np; i++)
{
SetExchangeVert ( el[i] );
}
}
if ( id == 0 ) return;
2009-01-25 18:06:46 +05:00
Array<int> ** elementonproc, ** recvelonproc;
elementonproc = new Array<int>*[ntasks];
recvelonproc = new Array<int>*[ntasks];
2009-01-25 07:54:27 +05:00
for ( int i = 1; i < ntasks; i++ )
{
2009-01-25 18:06:46 +05:00
elementonproc[i] = new Array<int>(0);
recvelonproc[i] = new Array<int>(0);
2009-01-25 07:54:27 +05:00
}
for ( int eli = 1; eli <= mesh.GetNE(); eli++ )
{
if ( !IsExchangeElement(eli) ) continue;
for ( int i = 1; i < ntasks; i++ )
if ( GetDistantElNum(i, eli) != -1 && i != id )
{
elementonproc[i] -> Append(eli);
elementonproc[i] -> Append(GetDistantElNum(i, eli));
}
}
for ( int sender = 1; sender < ntasks; sender ++ )
{
if ( id == sender )
for ( int dest = 1; dest < ntasks; dest ++ )
if ( dest != id)
{
MyMPI_Send ( *(elementonproc[dest]), dest);
elementonproc[dest] -> SetSize(0);
}
if ( id != sender )
{
MyMPI_Recv (*( recvelonproc[sender]), sender);
}
}
int ii = 0;
for ( int sender = 1; sender < ntasks; sender++ )
{
if ( sender == id ) continue;
ii = 0;
while ( recvelonproc[sender]->Size() > ii )
{
int distelnum = (*recvelonproc[sender])[ii++];
int locelnum = (*recvelonproc[sender])[ii++];
SetDistantEl ( sender, locelnum, distelnum);
}
recvelonproc[sender]->SetSize(0);
}
BitArray procs(ntasks);
procs.Clear();
for ( int eli = 1; eli <= mesh.GetNE(); eli++)
{
if ( IsGhostEl(eli) ) continue;
if ( !IsExchangeElement(eli) ) continue;
procs.Clear();
int sumprocs = 0;
for ( int i = 1; i < ntasks; i++ )
if ( GetDistantElNum(i, eli) != -1 && i != id )
{
procs.Set(i);
sumprocs++;
}
for ( int dest = 1; dest < ntasks; dest++)
{
if ( !procs.Test(dest) ) continue;
elementonproc[dest]->Append(GetDistantElNum(dest, eli));
elementonproc[dest]->Append(sumprocs);
for ( int i = 1; i < ntasks; i++ )
if ( procs.Test(i) )
{
elementonproc[dest]->Append(i);
elementonproc[dest]->Append(GetDistantElNum(i, eli));
}
}
}
for ( int sender = 1; sender < ntasks; sender ++ )
{
if ( id == sender )
for ( int dest = 1; dest < ntasks; dest ++ )
if ( dest != id)
{
MyMPI_Send ( *(elementonproc[dest]), dest);
delete elementonproc[dest];
}
if ( id != sender )
{
MyMPI_Recv (*( recvelonproc[sender]), sender);
}
}
for ( int sender = 1; sender < ntasks; sender++ )
{
if ( sender == id ) continue;
ii = 0;
while ( recvelonproc[sender]->Size() > ii )
{
int locelnum = (*recvelonproc[sender])[ii++];
int nprocs = (*recvelonproc[sender])[ii++];
for ( int iproc = 0; iproc < nprocs; iproc++)
{
int proc = (*recvelonproc[sender])[ii++];
int distelnum = (*recvelonproc[sender])[ii++];
if ( id == proc ) continue;
SetExchangeElement (locelnum, proc);
SetDistantEl( proc, locelnum, distelnum );
}
}
delete recvelonproc[sender];
}
delete [] elementonproc;
delete [] recvelonproc;
}
void ParallelMeshTopology :: SetNV ( const int anv )
{
*testout << "called setnv" << endl
<< "old size: " << loc2distvert.Size() << endl
<< "new size: " << anv << endl;
loc2distvert.ChangeSize (anv);
for (int i = 1; i <= anv; i++)
if (loc2distvert.EntrySize(i) == 0)
loc2distvert.Add (i, -1); // will be the global nr
BitArray * isexchangevert2 = new BitArray( (ntasks+1) * anv );
isexchangevert2->Clear();
if ( isexchangevert )
{
for ( int i = 0; i < min2( isexchangevert->Size(), isexchangevert2->Size() ); i++ )
if ( isexchangevert->Test(i) ) isexchangevert2->Set(i);
delete isexchangevert;
}
isexchangevert = isexchangevert2;
nv = anv;
}
void ParallelMeshTopology :: SetNE ( const int ane )
{
loc2distel.ChangeSize (ane);
for (int i = 0; i < ane; i++)
{
if (loc2distel[i].Size() == 0)
loc2distel.Add (i, -1); // will be the global nr
}
BitArray * isexchangeel2 = new BitArray ( (ntasks+1) * ane );
isexchangeel2->Clear();
if ( isexchangeel )
{
for ( int i = 0; i < min2(isexchangeel->Size(), isexchangeel2->Size() ) ; i++ )
if ( isexchangeel->Test(i) ) isexchangeel2->Set(i);
delete isexchangeel;
}
ne = ane;
isexchangeel = isexchangeel2;
}
void ParallelMeshTopology :: SetNSE ( int anse )
{
loc2distsurfel.ChangeSize (anse);
for (int i = 0; i < anse; i++)
if (loc2distsurfel[i].Size() == 0)
loc2distsurfel.Add (i, -1); // will be the global nr
nsurfel = anse;
}
void ParallelMeshTopology :: SetNSegm ( int anseg )
{
loc2distsegm.ChangeSize (anseg);
for (int i = 0; i < anseg; i++)
if (loc2distsegm[i].Size() == 0)
loc2distsegm.Add (i, -1); // will be the global nr
nseg = anseg;
}
}
#endif