Skip to content

GitLab

O
openfpm_pdata
Commit 31c4e2ad authored by Pietro Incardona's avatar Pietro Incardona
Browse files
Options

Small fix + example modified

parent 812b8f0b
Hide whitespace changes
Inline Side-by-side
Showing with 146 additions and 12 deletions
example/Grid/0_simple/main.cpp
View file @ 31c4e2ad
#include "Grid/grid_dist_id.hpp"
#include "data_type/scalar.hpp"
#include "data_type/aggregate.hpp"
#include "Decomposition/CartDecomposition.hpp"
/*
......@@ -53,7 +53,7 @@ int main(int argc, char* argv[])
// * domain: where the grid is defined
// * g: ghost extension
//
grid_dist_id<3, float, scalar<float[3]>, CartDecomposition<3,float>> g_dist(sz,domain,g);
grid_dist_id<3, float, aggregate<float[3]>, CartDecomposition<3,float>> g_dist(sz,domain,g);
// ### WIKI 5 ###
//
......
example/Grid/1_stencil/main.cpp
View file @ 31c4e2ad
#include "Grid/grid_dist_id.hpp"
#include "data_type/scalar.hpp"
#include "data_type/aggregate.hpp"
#include "Decomposition/CartDecomposition.hpp"
/*
......@@ -19,13 +19,18 @@
*
* ### WIKI 2 ###
*
* Define some convenient constant
* Define some convenient constant and types
*
*/
constexpr size_t x = 0;
constexpr size_t y = 1;
constexpr size_t z = 2;
constexpr size_t A = 0;
constexpr size_t B = 0;
typedef aggregate<float[3],float[3]> grid_point;
int main(int argc, char* argv[])
{
//
......@@ -65,7 +70,7 @@ int main(int argc, char* argv[])
// * domain: where the grid is defined
// * g: ghost extension
//
grid_dist_id<3, float, scalar<float[3]>, CartDecomposition<3,float>> g_dist(sz,domain,g);
grid_dist_id<3, float, grid_point, CartDecomposition<3,float>> g_dist(sz,domain,g);
// ### WIKI 5 ###
//
......@@ -133,10 +138,10 @@ int main(int argc, char* argv[])
auto key = dom.get();
// Laplace stencil
g_dist.template get<0>(key)[1] = g_dist.template get<0>(key.move(x,1))[0] + g_dist.template get<0>(key.move(x,-1))[0] +
g_dist.template get<0>(key.move(y,1))[0] + g_dist.template get<0>(key.move(y,-1))[0] +
g_dist.template get<0>(key.move(z,1))[0] + g_dist.template get<0>(key.move(z,-1))[0] -
6*g_dist.template get<0>(key)[0];
g_dist.template get<B>(key)[1] = g_dist.template get<A>(key.move(x,1))[0] + g_dist.template get<A>(key.move(x,-1))[0] +
g_dist.template get<A>(key.move(y,1))[0] + g_dist.template get<A>(key.move(y,-1))[0] +
g_dist.template get<A>(key.move(z,1))[0] + g_dist.template get<A>(key.move(z,-1))[0] -
6*g_dist.template get<A>(key)[0];
++dom;
......
example/Vector/0_simple/main.cpp
View file @ 31c4e2ad
#include "Vector/vector_dist.hpp"
#include "Decomposition/CartDecomposition.hpp"
#include "Point_test.hpp"
/*
* ### WIKI 1 ###
......@@ -13,6 +12,32 @@
*
*/
/*
* ### WIKI 2 ###
*
* We define a particle structure it contain 4 scalars one vector with 3 components
* and a tensor of rank 2 3x3
*
* ### WIKI END ###
*
*/
template<typename T> class Particle
{
public:
typedef boost::fusion::vector<T,T,T,T,T[3],T[3][3]> type;
type data;
static const unsigned int x = 0;
static const unsigned int y = 1;
static const unsigned int z = 2;
static const unsigned int s = 3;
static const unsigned int v = 4;
static const unsigned int t = 5;
static const unsigned int max_prop = 6;
};
int main(int argc, char* argv[])
{
......@@ -55,7 +80,7 @@ int main(int argc, char* argv[])
// objects with an undefined position in space. This non-space decomposition is also called data-driven
// decomposition
//
vector_dist<2,float, Point_test<float>, CartDecomposition<2,float> > vd(4096,box);
vector_dist<2,float, Particle<float>, CartDecomposition<2,float> > vd(4096,box);
//
// ### WIKI 5 ###
......
openfpm_data @ 2baeb7be
Subproject commit 080bde845909ab16f01e8425828b91c7e17110ed
Subproject commit 2baeb7bec51322aab29ed97f2b9de6b0b6d347d4
src/Grid/grid_dist_id.hpp
View file @ 31c4e2ad
......@@ -415,6 +415,9 @@ class grid_dist_id
*/
grid_dist_id(const grid_dist_id<dim,St,T,Decomposition,Memory,device_grid> & g)
{
#ifdef SE_CLASS2
check_new(this,8,GRID_DIST_EVENT,4);
#endif
}
/*! \brief Initialize the Cell decomposer of the grid
......@@ -492,6 +495,9 @@ public:
grid_dist_id(Decomposition & dec, const size_t (& g_sz)[dim], const Box<dim,St> & domain, const Ghost<dim,St> & ghost)
:domain(domain),ghost(ghost),dec(dec),v_cl(*global_v_cluster)
{
#ifdef SE_CLASS2
check_new(this,8,GRID_DIST_EVENT,4);
#endif
InitializeCellDecomposer(g_sz);
InitializeStructures(g_sz);
}
......@@ -506,6 +512,9 @@ public:
grid_dist_id(const size_t (& g_sz)[dim],const Box<dim,St> & domain, const Ghost<dim,St> & g)
:domain(domain),ghost(g),dec(* new Decomposition(*global_v_cluster)),v_cl(*global_v_cluster),ginfo(g_sz),ginfo_v(g_sz)
{
#ifdef SE_CLASS2
check_new(this,8,GRID_DIST_EVENT,4);
#endif
InitializeCellDecomposer(g_sz);
InitializeDecomposition(g_sz);
InitializeStructures(g_sz);
......@@ -521,6 +530,9 @@ public:
grid_dist_id(const size_t (& g_sz)[dim],const Box<dim,St> & domain, const Ghost<dim,long int> & g)
:domain(domain),dec(*new Decomposition(*global_v_cluster)),v_cl(*global_v_cluster),ginfo(g_sz),ginfo_v(g_sz)
{
#ifdef SE_CLASS2
check_new(this,8,GRID_DIST_EVENT,4);
#endif
InitializeCellDecomposer(g_sz);
// get the grid spacing
......@@ -551,6 +563,9 @@ public:
grid_dist_id(Decomposition & dec, const size_t (& g_sz)[dim],const Box<dim,St> & domain, const Ghost<dim,long int> & g)
:domain(domain),dec(dec),v_cl(*global_v_cluster),ginfo(g_sz),ginfo_v(g_sz)
{
#ifdef SE_CLASS2
check_new(this,8,GRID_DIST_EVENT,4);
#endif
InitializeCellDecomposer(g_sz);
// get the grid spacing
......@@ -578,6 +593,9 @@ public:
*/
const grid_sm<dim,T> & getGridInfo()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
return ginfo;
}
......@@ -588,6 +606,9 @@ public:
*/
const grid_sm<dim,void> & getGridInfoVoid()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
return ginfo_v;
}
......@@ -598,6 +619,9 @@ public:
*/
Decomposition & getDecomposition()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
return dec;
}
......@@ -608,6 +632,9 @@ public:
*/
const CellDecomposer_sm<dim,St> & getCellDecomposer()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
return cd_sm;
}
......@@ -618,6 +645,9 @@ public:
*/
bool isInside(const grid_key_dx<dim> & gk) const
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
for (size_t i = 0 ; i < dim ; i++)
{
if (gk.get(i) < 0 || gk.get(i) >= (long int)g_sz[i])
......@@ -634,6 +664,9 @@ public:
*/
size_t getLocalDomainSize()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
size_t total = 0;
for (size_t i = 0 ; i < gdb_ext.size() ; i++)
......@@ -651,6 +684,9 @@ public:
*/
const openfpm::vector<GBoxes<device_grid::dims>> & getLocalGridsInfo()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
return gdb_ext;
}
......@@ -661,6 +697,9 @@ public:
*/
grid_dist_iterator<dim,device_grid,FREE> getDomainIterator()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
grid_dist_iterator<dim,device_grid,FREE> it(loc_grid,gdb_ext);
return it;
......@@ -672,6 +711,9 @@ public:
*/
grid_dist_iterator<dim,device_grid,FIXED> getDomainGhostIterator()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
grid_dist_iterator<dim,device_grid,FIXED> it(loc_grid,gdb_ext);
return it;
......@@ -686,6 +728,9 @@ public:
*/
grid_dist_iterator_sub<dim,device_grid> getSubDomainIterator(const grid_key_dx<dim> & start, const grid_key_dx<dim> & stop)
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
grid_dist_iterator_sub<dim,device_grid> it(start,stop,loc_grid,gdb_ext);
return it;
......@@ -694,6 +739,9 @@ public:
//! Destructor
~grid_dist_id()
{
#ifdef SE_CLASS2
check_delete(this);
#endif
dec.decRef();
// if we reach the 0, destroy the object
......@@ -709,6 +757,9 @@ public:
Vcluster & getVC()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
return v_cl;
}
......@@ -720,6 +771,9 @@ public:
*/
template <unsigned int p>inline auto get(const grid_dist_key_dx<dim> & v1) const -> typename std::add_lvalue_reference<decltype(loc_grid.get(v1.getSub()).template get<p>(v1.getKey()))>::type
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
return loc_grid.get(v1.getSub()).template get<p>(v1.getKey());
}
......@@ -731,6 +785,9 @@ public:
*/
template <unsigned int p>inline auto get(const grid_dist_key_dx<dim> & v1) -> typename std::add_lvalue_reference<decltype(loc_grid.get(v1.getSub()).template get<p>(v1.getKey()))>::type
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
return loc_grid.get(v1.getSub()).template get<p>(v1.getKey());
}
......@@ -867,6 +924,10 @@ public:
*/
template<int... prp> void ghost_get()
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
// Sending property object
typedef object<typename object_creator<typename T::type,prp...>::type> prp_object;
......@@ -1036,6 +1097,9 @@ public:
*/
inline grid_key_dx<dim> getGKey(const grid_dist_key_dx<dim> & k)
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
// Get the sub-domain id
size_t sub_id = k.getSub();
......@@ -1057,6 +1121,10 @@ public:
*/
bool write(std::string output)
{
#ifdef SE_CLASS2
check_valid(this,8);
#endif
// Create a writer and write
VTKWriter<boost::mpl::pair<device_grid,float>,VECTOR_GRIDS> vtk_g;
for (size_t i = 0 ; i < loc_grid.size() ; i++)
......@@ -1093,6 +1161,19 @@ public:
return true;
}
/* \brief It return the id of structure in the allocation list
*
* \see print_alloc and SE_CLASS2
*
*/
long int who()
{
#ifdef SE_CLASS2
return check_whoami(this,8);
#endif
}
};
......
src/Vector/vector_dist.hpp
View file @ 31c4e2ad
......@@ -99,6 +99,10 @@ public:
vector_dist(size_t np, Box<dim,St> box, Ghost<dim,St> g = Ghost<dim,St>())
:dec(*global_v_cluster),v_cl(*global_v_cluster)
{
#ifdef SE_CLASS2
check_new(this,8,VECTOR_DIST_EVENT,4);
#endif
// Allocate unassigned particles vectors
v_pos = v_cl.template allocate<openfpm::vector<Point<dim,St>>>(1);
v_prp = v_cl.template allocate<openfpm::vector<prop>>(1);
......@@ -138,6 +142,13 @@ public:
p.zero();
}
~vector_dist()
{
#ifdef SE_CLASS2
check_delete(this);
#endif
}
/*! \brief Get the number of minimum sub-domain
*
* \return minimum number
......@@ -757,6 +768,18 @@ public:
// Write the CSV
return csv_writer.write(output,v_pos.get(INTERNAL),v_prp.get(INTERNAL));
}
/* \brief It return the id of structure in the allocation list
*
* \see print_alloc and SE_CLASS2
*
*/
long int who()
{
#ifdef SE_CLASS2
return check_whoami(this,8);
#endif
}
};
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment