32 auto edges = get_edges();
34 auto &thread_counts = edges.sizes.indexes;
36 edges.neigh_cache.check_sizes(thread_counts);
37 edges.positions.check_sizes(thread_counts);
38 edges.old_h.check_sizes(thread_counts);
39 edges.new_h.check_sizes(thread_counts);
40 edges.eps_h.check_sizes(thread_counts);
42 auto &neigh_cache = edges.neigh_cache.neigh_cache;
43 auto &positions = edges.positions.get_spans();
44 auto &old_h = edges.old_h.get_spans();
45 auto &new_h = edges.new_h.get_spans();
46 auto &eps_h = edges.eps_h.get_spans();
48 auto dev_sched = shamsys::instance::get_compute_scheduler_ptr();
50 static constexpr Tscal Rkern = SPHKernel::Rkern;
57 [gpart_mass = this->gpart_mass,
58 h_evol_max = this->h_evol_max,
59 h_evol_iter_max = this->h_evol_iter_max,
60 epsilon_h = this->epsilon_h](
63 const Tvec *__restrict r,
64 const Tscal *__restrict h_old,
65 Tscal *__restrict h_new,
66 Tscal *__restrict eps) {
70 Tscal part_mass = gpart_mass;
71 Tscal h_max_tot_max_evol = h_evol_max;
72 Tscal h_max_evol_p = h_evol_iter_max;
73 Tscal h_max_evol_m = 1 / h_evol_iter_max;
75 if (eps[id_a] > epsilon_h) {
79 Tscal h_a = h_new[id_a];
80 Tscal dint = h_a * h_a * Rkern * Rkern;
85 particle_looper.for_each_object(id_a, [&](
u32 id_b) {
86 Tvec dr = xyz_a - r[id_b];
87 Tscal rab2 = sycl::dot(dr, dr);
93 Tscal rab = sycl::sqrt(rab2);
95 rho_sum += part_mass * SPHKernel::W_3d(rab, h_a);
96 sumdWdh += part_mass * SPHKernel::dhW_3d(rab, h_a);
99 using namespace shamrock::sph;
101 Tscal rho_ha = rho_h(part_mass, h_a, SPHKernel::hfactd);
102 Tscal new_h = newton_iterate_new_h(rho_ha, rho_sum, sumdWdh, h_a);
104 if (new_h < h_a * h_max_evol_m)
105 new_h = h_max_evol_m * h_a;
106 if (new_h > h_a * h_max_evol_p)
107 new_h = h_max_evol_p * h_a;
109 Tscal ha_0 = h_old[id_a];
111 if (new_h < ha_0 * h_max_tot_max_evol) {
113 eps[id_a] = sycl::fabs(new_h - h_a) / ha_0;
115 h_new[id_a] = ha_0 * h_max_tot_max_evol;
void distributed_data_kernel_call(sham::DeviceScheduler_ptr dev_sched, RefIn in, RefOut in_out, const shambase::DistributedData< index_t > &thread_counts, Functor &&func)
A variant of sham::kernel_call for distributed data.