#include <FilterHistoryPoints.h>

Inheritance diagram for Nektar::SolverUtils::FilterHistoryPoints:

Collaboration diagram for Nektar::SolverUtils::FilterHistoryPoints:

Public Member Functions
SOLVER_UTILS_EXPORT	FilterHistoryPoints (const LibUtilities::SessionReaderSharedPtr &pSession, const ParamMap &pParams)

SOLVER_UTILS_EXPORT	~FilterHistoryPoints ()

Public Member Functions inherited from Nektar::SolverUtils::Filter
SOLVER_UTILS_EXPORT	Filter (const LibUtilities::SessionReaderSharedPtr &pSession)

virtual SOLVER_UTILS_EXPORT	~Filter ()

SOLVER_UTILS_EXPORT void	Initialise (const Array< OneD, const MultiRegions::ExpListSharedPtr > &pFields, const NekDouble &time)

SOLVER_UTILS_EXPORT void	Update (const Array< OneD, const MultiRegions::ExpListSharedPtr > &pFields, const NekDouble &time)

SOLVER_UTILS_EXPORT void	Finalise (const Array< OneD, const MultiRegions::ExpListSharedPtr > &pFields, const NekDouble &time)

SOLVER_UTILS_EXPORT bool	IsTimeDependent ()

Static Public Member Functions
static FilterSharedPtr	create (const LibUtilities::SessionReaderSharedPtr &pSession, const std::map< std::string, std::string > &pParams)
	Creates an instance of this class. More...

Static Public Attributes
static std::string	className = GetFilterFactory().RegisterCreatorFunction("HistoryPoints", FilterHistoryPoints::create)
	Name of the class. More...

Protected Member Functions
virtual SOLVER_UTILS_EXPORT void	v_Initialise (const Array< OneD, const MultiRegions::ExpListSharedPtr > &pFields, const NekDouble &time)

virtual SOLVER_UTILS_EXPORT void	v_Update (const Array< OneD, const MultiRegions::ExpListSharedPtr > &pFields, const NekDouble &time)

virtual SOLVER_UTILS_EXPORT void	v_Finalise (const Array< OneD, const MultiRegions::ExpListSharedPtr > &pFields, const NekDouble &time)

virtual SOLVER_UTILS_EXPORT bool	v_IsTimeDependent ()

Protected Attributes
SpatialDomains::PointGeomVector	m_historyPoints

unsigned int	m_index

unsigned int	m_outputFrequency

unsigned int	m_outputPlane
	plane to take history point from if using a homogeneous1D expansion More...

bool	m_isHomogeneous1D

std::string	m_outputFile

std::ofstream	m_outputStream

std::stringstream	m_historyPointStream

std::list< std::pair < SpatialDomains::PointGeomSharedPtr, Array< OneD, NekDouble > > >	m_historyList

std::map< int, int >	m_historyLocalPointMap

Protected Attributes inherited from Nektar::SolverUtils::Filter
LibUtilities::SessionReaderSharedPtr	m_session

Friends
class	MemoryManager< FilterHistoryPoints >

Additional Inherited Members
Public Types inherited from Nektar::SolverUtils::Filter
typedef std::map< std::string, std::string >	ParamMap

Detailed Description

Definition at line 46 of file FilterHistoryPoints.h.

Constructor & Destructor Documentation

Nektar::SolverUtils::FilterHistoryPoints::FilterHistoryPoints	(	const LibUtilities::SessionReaderSharedPtr &	pSession,
		const ParamMap &	pParams
	)

Definition at line 51 of file FilterHistoryPoints.cpp.

References ASSERTL0, Nektar::LibUtilities::Equation::Evaluate(), m_historyPointStream, m_index, m_isHomogeneous1D, m_outputFile, m_outputFrequency, m_outputPlane, and Nektar::SolverUtils::Filter::m_session.

                              :
     Filter(pSession)
 {
     ParamMap::const_iterator it;
 
     // OutputFile
     it = pParams.find("OutputFile");
     if (it == pParams.end())
     {
         m_outputFile = m_session->GetSessionName();
     }
     else
     {
         ASSERTL0(it->second.length() > 0, "Missing parameter 'OutputFile'.");
         m_outputFile = it->second;
     }
     if (!(m_outputFile.length() >= 4
           && m_outputFile.substr(m_outputFile.length() - 4) == ".his"))
     {
         m_outputFile += ".his";
     }
 
     // OutputFrequency
     it = pParams.find("OutputFrequency");
     if (it == pParams.end())
     {
         m_outputFrequency = 1;
     }
     else
     {
         LibUtilities::Equation equ(m_session, it->second);
         m_outputFrequency = floor(equ.Evaluate());
     }
 
     // OutputPlane
     m_session->MatchSolverInfo("Homogeneous", "1D", m_isHomogeneous1D, false);
     if(m_isHomogeneous1D)
     {
         it = pParams.find("OutputPlane");
         if (it == pParams.end())
         {
             m_outputPlane = 0;
         }
         else
         {
             LibUtilities::Equation equ(m_session, it->second);
             m_outputPlane = floor(equ.Evaluate());
         }
     }
 
     // Points
     it = pParams.find("Points");
     ASSERTL0(it != pParams.end(), "Missing parameter 'Points'.");
     m_historyPointStream.str(it->second);
     m_index = 0;
 }

Nektar::SolverUtils::FilterHistoryPoints::~FilterHistoryPoints ( )

Definition at line 114 of file FilterHistoryPoints.cpp.

 {
 
 }

Member Function Documentation

static FilterSharedPtr Nektar::SolverUtils::FilterHistoryPoints::create	(	const LibUtilities::SessionReaderSharedPtr &	pSession,
		const std::map< std::string, std::string > &	pParams
	)

inlinestatic

Creates an instance of this class.

Definition at line 52 of file FilterHistoryPoints.h.

References Nektar::MemoryManager< DataType >::AllocateSharedPtr().

                                                          {
             FilterSharedPtr p = MemoryManager<FilterHistoryPoints>
                 ::AllocateSharedPtr(pSession, pParams);
             return p;
         }

void Nektar::SolverUtils::FilterHistoryPoints::v_Finalise	(	const Array< OneD, const MultiRegions::ExpListSharedPtr > &	pFields,
		const NekDouble &	time
	)

protectedvirtual

Implements Nektar::SolverUtils::Filter.

Definition at line 460 of file FilterHistoryPoints.cpp.

References m_outputStream.

 {
     if (pFields[0]->GetComm()->GetRank() == 0)
     {
         m_outputStream.close();
     }
 }

void Nektar::SolverUtils::FilterHistoryPoints::v_Initialise	(	const Array< OneD, const MultiRegions::ExpListSharedPtr > &	pFields,
		const NekDouble &	time
	)

protectedvirtual

Implements Nektar::SolverUtils::Filter.

Definition at line 123 of file FilterHistoryPoints.cpp.

References Nektar::MemoryManager< DataType >::AllocateSharedPtr(), ASSERTL0, Nektar::NekConstants::kGeomFactorsTol, Nektar::NekConstants::kVertexTheSameDouble, m_historyList, m_historyLocalPointMap, m_historyPoints, m_historyPointStream, m_index, m_isHomogeneous1D, m_outputFile, m_outputPlane, m_outputStream, Nektar::SolverUtils::Filter::m_session, Nektar::LibUtilities::ReduceMax, Nektar::LibUtilities::ReduceMin, v_Update(), Vmath::Vcopy(), and Nektar::NekMeshUtils::vert.

 {
     ASSERTL0(!m_historyPointStream.fail(),
              "No history points in stream.");
 
     m_index = 0;
     m_historyList.clear();
 
     // Read history points
     Array<OneD, NekDouble>  gloCoord(3,0.0);
     int dim = pFields[0]->GetGraph()->GetSpaceDimension();
     int i = 0;
     while (!m_historyPointStream.fail())
     {
         m_historyPointStream >> gloCoord[0]
                              >> gloCoord[1]
                              >> gloCoord[2];
         if(m_isHomogeneous1D) // overwrite with plane z
         {
             NekDouble Z = (pFields[0]->GetHomogeneousBasis()
                                         ->GetZ())[m_outputPlane];
             if(fabs(gloCoord[2]-Z) > NekConstants::kVertexTheSameDouble)
             {
                 cout << "Reseting History point from " << gloCoord[2]
                      << " to " << Z << endl;
             }
             gloCoord[2] = Z;
         }
 
         if (!m_historyPointStream.fail())
         {
             SpatialDomains::PointGeomSharedPtr vert
                 = MemoryManager<SpatialDomains::PointGeom>
                 ::AllocateSharedPtr(dim, i, gloCoord[0],
                                     gloCoord[1], gloCoord[2]);
 
             m_historyPoints.push_back(vert);
             ++i;
         }
     }
 
 
     // Determine the unique process responsible for each history point
     // For points on a partition boundary, must select a single process
     LibUtilities::CommSharedPtr vComm = pFields[0]->GetComm();
     int vRank = vComm->GetRank();
     int vHP   = m_historyPoints.size();
     Array<OneD, int>       procList(vHP, -1   );
     Array<OneD, int>       idList  (vHP, -1   );
     Array<OneD, NekDouble> dist    (vHP,  1e16);
     Array<OneD, NekDouble> dist_loc(vHP,  1e16);
     std::vector<Array<OneD, NekDouble> > LocCoords;
 
     // Find the nearest element on this process to which the history
     // point could belong and note down the distance from the element
     // and the process ID.
     for (i = 0; i < vHP; ++i)
     {
         Array<OneD, NekDouble> locCoords(3);
         m_historyPoints[i]->GetCoords(  gloCoord[0],
                                         gloCoord[1],
                                         gloCoord[2]);
 
         // Determine the expansion and local coordinates
         idList[i] = pFields[0]->GetExpIndex(gloCoord,locCoords,
                                         NekConstants::kGeomFactorsTol);
 
         // Save Local coordinates for later
         LocCoords.push_back(locCoords);
 
         // For those points for which a potential nearby element exists
         // compute the perp. distance from the point to the element and
         // store in the distances array.
         if (idList[i] != -1)
         {
             SpatialDomains::GeometrySharedPtr g =
                             pFields[0]->GetExp(idList[i])->GetGeom();
             StdRegions::StdExpansionSharedPtr e = g->GetXmap();
             Array<OneD, NekDouble> coordVals(e->GetTotPoints());
             dist_loc[i] = 0.0;
             for (int j = 0; j < g->GetCoordim(); ++j)
             {
                 e->BwdTrans(g->GetCoeffs(j), coordVals);
                 NekDouble x = e->PhysEvaluate(locCoords, coordVals)
                                                          - gloCoord[j];
                 dist_loc[i] += x*x;
             }
         }
     }
 
     // Reduce distances of points from elements, keeping the smallest
     // distance.
     Vmath::Vcopy(vHP, dist_loc, 1, dist, 1);
     vComm->AllReduce(dist, LibUtilities::ReduceMin);
 
     // If multiple processes find they are the nearest (e.g. point lies
     // on a partition boundary, we will choose the process of highest
     // rank.
     for (i = 0; i < vHP; ++i)
     {
         if (dist_loc[i] == dist[i])
         {
             // Set element id to Vid of m_history point for later use
             m_historyPoints[i]->SetVid(idList[i]);
         }
         else
         {
             // This history point is not handled by this process
             idList[i] = -1;
         }
 
         // If a matching element is found on this process, note the
         // process ID
         if (idList[i] != -1)
         {
             if(m_isHomogeneous1D)
             {
                 int j;
                 Array<OneD, const unsigned int> IDs
                                             = pFields[0]->GetZIDs();
                 for(j = 0; j < IDs.num_elements(); ++j)
                 {
                     if(IDs[j] == m_outputPlane)
                     {
                         break;
                     }
                 }
 
                 if(j != IDs.num_elements())
                 {
                     m_outputPlane = j;
                     procList[i] = vRank;
                 }
             }
             else
             {
                 procList[i] = vRank;
             }
         }
     }
 
     // Reduce process IDs for all history points. The process with
     // largest rank will handle the history point in the case where the
     // distance was the same.
     vComm->AllReduce(procList,  LibUtilities::ReduceMax);
 
     // Determine the element in which each history point resides.
     // If point is not in mesh (on this process), id is -1.
     for (i = 0; i < vHP; ++i)
     {
         // If point lies on partition boundary, only the proc with max
         // rank retains possession.
         if (procList[i] != vRank)
         {
             idList[i] = -1;
         }
 
         // If the current process owns this history point, add it to its
         // local list of history points.
         if (idList[i] != -1)
         {
             m_historyLocalPointMap[m_historyList.size()] = i;
             m_historyList.push_back(
                      std::pair<SpatialDomains::PointGeomSharedPtr,
                                               Array<OneD, NekDouble> >
                               (m_historyPoints[i], LocCoords[i]));
         }
     }
 
     // Collate the element ID list across processes and check each
     // history point is allocated to a process
     vComm->AllReduce(idList, LibUtilities::ReduceMax);
     if (vComm->GetRank() == 0)
     {
         for (i = 0; i < vHP; ++i)
         {
             m_historyPoints[i]->GetCoords(  gloCoord[0],
                                             gloCoord[1],
                                             gloCoord[2]);
 
             // Write an error if no process owns history point
             ASSERTL0(idList[i] != -1,
                      "History point "
                      + boost::lexical_cast<std::string>(gloCoord[0])
                      + ", "
                      + boost::lexical_cast<std::string>(gloCoord[1])
                      + ", "
                      + boost::lexical_cast<std::string>(gloCoord[2])
                      + " cannot be found in the mesh.");
 
             // Print a warning if a process owns it but it is not close
             // enough to the element.
             if (dist[i] > NekConstants::kGeomFactorsTol)
             {
                 cout << "Warning: History point " << i << " at ("
                      << gloCoord[0] << "," << gloCoord[1] << ","
                      << gloCoord[2] << ") lies a distance of "
                      << sqrt(dist[i]) << " from the manifold." << endl;
             }
         }
 
         // Open output stream
         m_outputStream.open(m_outputFile.c_str());
         m_outputStream << "# History data for variables (:";
 
         for (i = 0; i < pFields.num_elements(); ++i)
         {
             m_outputStream << m_session->GetVariable(i) <<",";
         }
 
         if(m_isHomogeneous1D)
         {
             m_outputStream << ") at points:";
         }
         else
         {
             m_outputStream << ") at points:" << endl;
         }
 
         for (i = 0; i < vHP; ++i)
         {
             m_historyPoints[i]->GetCoords(  gloCoord[0],
                                             gloCoord[1],
                                             gloCoord[2]);
 
             m_outputStream << "# " << boost::format("%6.0f") % i;
             m_outputStream << " " << boost::format("%25e") % gloCoord[0];
             m_outputStream << " " << boost::format("%25e") % gloCoord[1];
             m_outputStream << " " << boost::format("%25e") % gloCoord[2];
             m_outputStream << endl;
         }
 
         if(m_isHomogeneous1D)
         {
             m_outputStream << "(in Wavespace)" << endl;
         }
     }
     v_Update(pFields, time);
 }

bool Nektar::SolverUtils::FilterHistoryPoints::v_IsTimeDependent ( )

protectedvirtual

Implements Nektar::SolverUtils::Filter.

Definition at line 472 of file FilterHistoryPoints.cpp.

 {
     return true;
 }

void Nektar::SolverUtils::FilterHistoryPoints::v_Update	(	const Array< OneD, const MultiRegions::ExpListSharedPtr > &	pFields,
		const NekDouble &	time
	)

protectedvirtual

Implements Nektar::SolverUtils::Filter.

Reimplemented in Nektar::FilterCellHistoryPoints.

Definition at line 369 of file FilterHistoryPoints.cpp.

References Nektar::iterator, m_historyList, m_historyLocalPointMap, m_historyPoints, m_index, m_isHomogeneous1D, m_outputFrequency, m_outputPlane, m_outputStream, and Nektar::LibUtilities::ReduceSum.

Referenced by v_Initialise().

 {
     // Only output every m_outputFrequency.
     if ((m_index++) % m_outputFrequency)
     {
         return;
     }
 
     int j         = 0;
     int k         = 0;
     int numPoints = m_historyPoints.size();
     int numFields = pFields.num_elements();
     LibUtilities::CommSharedPtr vComm = pFields[0]->GetComm();
     Array<OneD, NekDouble> data(numPoints*numFields, 0.0);
     Array<OneD, NekDouble> gloCoord(3, 0.0);
     std::list<std::pair<SpatialDomains::PointGeomSharedPtr, Array<OneD, NekDouble> > >::iterator x;
 
     Array<OneD, NekDouble> physvals;
     Array<OneD, NekDouble> locCoord;
     int expId;
 
     // Pull out data values field by field
     for (j = 0; j < numFields; ++j)
     {
         if(m_isHomogeneous1D)
         {
             for (k = 0, x = m_historyList.begin(); x != m_historyList.end();
                  ++x, ++k)
             {
                 locCoord = (*x).second;
                 expId    = (*x).first->GetVid();
 
                 physvals = pFields[j]->GetPlane(m_outputPlane)->UpdatePhys() + pFields[j]->GetPhys_Offset(expId);
 
                 // transform elemental data if required.
                 if(pFields[j]->GetPhysState() == false)
                 {
                     pFields[j]->GetPlane(m_outputPlane)->GetExp(expId)->BwdTrans(pFields[j]->GetPlane(m_outputPlane)->GetCoeffs() + pFields[j]->GetCoeff_Offset(expId),physvals);
                 }
 
                 // interpolate point can do with zero plane methods
                 data[m_historyLocalPointMap[k]*numFields+j] = pFields[j]->GetExp(expId)->StdPhysEvaluate(locCoord,physvals);
 
             }
         }
         else
         {
             for (k = 0, x = m_historyList.begin(); x != m_historyList.end(); ++x, ++k)
             {
                 locCoord = (*x).second;
                 expId    = (*x).first->GetVid();
 
                 physvals = pFields[j]->UpdatePhys() + pFields[j]->GetPhys_Offset(expId);
 
                 // transform elemental data if required.
                 if(pFields[j]->GetPhysState() == false)
                 {
                     pFields[j]->GetExp(expId)->BwdTrans(pFields[j]->GetCoeffs() + pFields[j]->GetCoeff_Offset(expId),physvals);
                 }
 
                 // interpolate point
                 data[m_historyLocalPointMap[k]*numFields+j] = pFields[j]->GetExp(expId)->StdPhysEvaluate(locCoord,physvals);
             }
         }
     }
 
     // Exchange history data
     // This could be improved to reduce communication but works for now
     vComm->AllReduce(data, LibUtilities::ReduceSum);
 
     // Only the root process writes out history data
     if (vComm->GetRank() == 0)
     {
 
         // Write data values point by point
         for (k = 0; k < m_historyPoints.size(); ++k)
         {
             m_outputStream << boost::format("%25e") % time;
             for (int j = 0; j < numFields; ++j)
             {
                 m_outputStream << " " << boost::format("%25e") % data[k*numFields+j];
             }
             m_outputStream << endl;
         }
     }
 }

Friends And Related Function Documentation

friend class MemoryManager< FilterHistoryPoints >

friend

Definition at line 49 of file FilterHistoryPoints.h.

Member Data Documentation

std::string Nektar::SolverUtils::FilterHistoryPoints::className = GetFilterFactory().RegisterCreatorFunction("HistoryPoints", FilterHistoryPoints::create)

static

Name of the class.

Definition at line 61 of file FilterHistoryPoints.h.