fluid_scheme_compressible_euler.f90

Go to the documentation of this file.

! Copyright (c) 2025, The Neko Authors
! All rights reserved.
!
! Redistribution and use in source and binary forms, with or without
! modification, are permitted provided that the following conditions
! are met:
!
!   * Redistributions of source code must retain the above copyright
!     notice, this list of conditions and the following disclaimer.
!
!   * Redistributions in binary form must reproduce the above
!     copyright notice, this list of conditions and the following
!     disclaimer in the documentation and/or other materials provided
!     with the distribution.
!
!   * Neither the name of the authors nor the names of its
!     contributors may be used to endorse or promote products derived
!     from this software without specific prior written permission.
!
! THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
! "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
! LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
! FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
! COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
! INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
! BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
! LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
! CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
! LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
! ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
! POSSIBILITY OF SUCH DAMAGE.
!
module fluid_scheme_compressible_euler
  use comm
  use, intrinsic :: iso_fortran_env, only: error_unit
  use advection, only : advection_t, advection_factory
  use device, only : device_memcpy, host_to_device
  use dofmap, only : dofmap_t
  use field_math, only : field_add2, field_cfill, field_cmult, field_cadd, &
       field_copy, field_col2, field_col3, &
       field_addcol3, field_sub2, field_invcol2
  use math, only : col2, copy, col3, addcol3, subcol3
  use device_math, only : device_col2
  use field, only : field_t
  use fluid_scheme_compressible, only: fluid_scheme_compressible_t
  use gs_ops, only : gs_op_add
  use gather_scatter, only : gs_t
  use num_types, only : rp
  use mesh, only : mesh_t
  use operators, only: div, grad
  use json_module, only : json_file, json_core, json_value
  use json_utils, only : json_get, json_get_or_default, json_extract_item
  use profiler, only : profiler_start_region, profiler_end_region
  use user_intf, only : user_t
  use time_scheme_controller, only : time_scheme_controller_t
  use time_step_controller, only : time_step_controller_t
  use ax_product, only : ax_t, ax_helm_factory
  use field_list, only : field_list_t
  use coefs, only: coef_t
  use space, only : space_t
  use euler_residual, only: euler_rhs_t, euler_rhs_factory
  use neko_config, only : neko_bcknd_device
  use runge_kutta_time_scheme, only : runge_kutta_time_scheme_t
  use field_dirichlet, only : field_dirichlet_t
  use field_dirichlet_vector, only : field_dirichlet_vector_t
  use bc_list, only: bc_list_t
  use zero_dirichlet, only : zero_dirichlet_t
  use field_math, only : field_copy
  use bc, only : bc_t
  use utils, only : neko_error, neko_warning
  use logger, only : log_size
  implicit none
  private
 
  type, public, extends(fluid_scheme_compressible_t) &
       :: fluid_scheme_compressible_euler_t
     type(field_t) :: rho_res, m_x_res, m_y_res, m_z_res, m_e_res
     type(field_t) :: drho, dm_x, dm_y, dm_z, de
     type(field_t) :: h
     real(kind=rp) :: c_avisc_low
     class(advection_t), allocatable :: adv
     class(ax_t), allocatable :: ax
     class(euler_rhs_t), allocatable :: euler_rhs
     type(runge_kutta_time_scheme_t) :: rk_scheme
 
     ! List of boundary conditions for velocity
     type(bc_list_t) :: bcs_density
   contains
     procedure, pass(this) :: init => fluid_scheme_compressible_euler_init
     procedure, pass(this) :: free => fluid_scheme_compressible_euler_free
     procedure, pass(this) :: step => fluid_scheme_compressible_euler_step
     procedure, pass(this) :: restart => fluid_scheme_compressible_euler_restart
     procedure, pass(this) :: setup_bcs &
          => fluid_scheme_compressible_euler_setup_bcs
     procedure, pass(this) :: compute_h
  end type fluid_scheme_compressible_euler_t
  type, public, extends(fluid_scheme_compressible_t) & …
 
  interface
 
     module subroutine density_bc_factory(object, scheme, json, coef, user)
       class(bc_t), pointer, intent(inout) :: object
       type(fluid_scheme_compressible_euler_t), intent(in) :: scheme
       type(json_file), intent(inout) :: json
       type(coef_t), intent(in) :: coef
       type(user_t), intent(in) :: user
     end subroutine density_bc_factory
  end interface
 
  interface
 
     module subroutine pressure_bc_factory(object, scheme, json, coef, user)
       class(bc_t), pointer, intent(inout) :: object
       type(fluid_scheme_compressible_euler_t), intent(in) :: scheme
       type(json_file), intent(inout) :: json
       type(coef_t), intent(in) :: coef
       type(user_t), intent(in) :: user
     end subroutine pressure_bc_factory
  end interface
 
  interface
 
     module subroutine velocity_bc_factory(object, scheme, json, coef, user)
       class(bc_t), pointer, intent(inout) :: object
       type(fluid_scheme_compressible_euler_t), intent(in) :: scheme
       type(json_file), intent(inout) :: json
       type(coef_t), intent(in) :: coef
       type(user_t), intent(in) :: user
     end subroutine velocity_bc_factory
  end interface
 
contains
  subroutine fluid_scheme_compressible_euler_init(this, msh, lx, params, user)
    class(fluid_scheme_compressible_euler_t), target, intent(inout) :: this
    type(mesh_t), target, intent(inout) :: msh
    integer, intent(in) :: lx
    type(json_file), target, intent(inout) :: params
    type(user_t), target, intent(in) :: user
    character(len=12), parameter :: scheme = 'compressible'
    integer :: rk_order
 
    call this%free()
 
    ! Initialize base class
    call this%scheme_init(msh, lx, params, scheme, user)
 
    call euler_rhs_factory(this%euler_rhs)
 
    associate(xh_lx => this%Xh%lx, xh_ly => this%Xh%ly, xh_lz => this%Xh%lz, &
         dm_xh => this%dm_Xh, nelv => this%msh%nelv)
 
      call this%drho%init(dm_xh, 'drho')
      call this%dm_x%init(dm_xh, 'dm_x')
      call this%dm_y%init(dm_xh, 'dm_y')
      call this%dm_z%init(dm_xh, 'dm_z')
      call this%dE%init(dm_xh, 'dE')
      call this%h%init(dm_xh, 'h')
 
    end associate
 
    if (neko_bcknd_device .eq. 1) then
       associate(p => this%p, rho_field => this%rho_field, &
            u => this%u, v => this%v, w => this%w, &
            m_x => this%m_x, m_y => this%m_y, m_z => this%m_z)
         call device_memcpy(p%x, p%x_d, p%dof%size(), &
              host_to_device, sync = .false.)
         call device_memcpy(rho_field%x, rho_field%x_d, rho_field%dof%size(), &
              host_to_device, sync = .false.)
         call device_memcpy(u%x, u%x_d, u%dof%size(), &
              host_to_device, sync = .false.)
         call device_memcpy(v%x, v%x_d, v%dof%size(), &
              host_to_device, sync = .false.)
         call device_memcpy(w%x, w%x_d, w%dof%size(), &
              host_to_device, sync = .false.)
         call device_memcpy(m_x%x, m_x%x_d, m_x%dof%size(), &
              host_to_device, sync = .false.)
         call device_memcpy(m_y%x, m_y%x_d, m_y%dof%size(), &
              host_to_device, sync = .false.)
         call device_memcpy(m_z%x, m_z%x_d, m_z%dof%size(), &
              host_to_device, sync = .false.)
       end associate
    end if
 
    ! Initialize the diffusion operator
    call ax_helm_factory(this%Ax, full_formulation = .false.)
 
    ! Compute h
    call this%compute_h()
    call json_get_or_default(params, 'case.numerics.c_avisc_low', &
         this%c_avisc_low, 0.5_rp)
 
    ! Initialize Runge-Kutta scheme
    call json_get_or_default(params, 'case.numerics.time_order', rk_order, 4)
    call this%rk_scheme%init(rk_order)
 
    ! Set up boundary conditions
    call this%setup_bcs(user, params)
 
  subroutine fluid_scheme_compressible_euler_init(this, msh, lx, params, user) …
  end subroutine fluid_scheme_compressible_euler_init
 
  subroutine fluid_scheme_compressible_euler_free(this)
    class(fluid_scheme_compressible_euler_t), intent(inout) :: this
 
    if (allocated(this%Ax)) then
       deallocate(this%Ax)
    end if
 
    call this%drho%free()
    call this%dm_x%free()
    call this%dm_y%free()
    call this%dm_z%free()
    call this%dE%free()
 
    ! call this%scheme_free()
  subroutine fluid_scheme_compressible_euler_free(this) …
  end subroutine fluid_scheme_compressible_euler_free
 
  subroutine fluid_scheme_compressible_euler_step(this, t, tstep, dt, &
       ext_bdf, dt_controller)
    class(fluid_scheme_compressible_euler_t), target, intent(inout) :: this
    real(kind=rp), intent(in) :: t
    integer, intent(in) :: tstep
    real(kind=rp), intent(in) :: dt
    type(time_scheme_controller_t), intent(in) :: ext_bdf
    type(time_step_controller_t), intent(in) :: dt_controller
    type(field_t), pointer :: temp
    integer :: temp_indices(1)
    ! number of degrees of freedom
    integer :: n
 
    n = this%dm_Xh%size()
    call this%scratch%request_field(temp, temp_indices(1))
 
    call profiler_start_region('Fluid compressible', 1)
    associate(u => this%u, v => this%v, w => this%w, p => this%p, &
         m_x=> this%m_x, m_y => this%m_y, m_z => this%m_z, &
         xh => this%Xh, msh => this%msh, ax => this%Ax, &
         c_xh => this%c_Xh, dm_xh => this%dm_Xh, gs_xh => this%gs_Xh, &
         rho => this%rho, mu => this%mu, e => this%E, &
         rho_field => this%rho_field, mu_field => this%mu_field, &
         ulag => this%ulag, vlag => this%vlag, wlag => this%wlag, &
         f_x => this%f_x, f_y => this%f_y, f_z => this%f_z, &
         drho => this%drho, dm_x => this%dm_x, dm_y => this%dm_y, &
         dm_z => this%dm_z, de => this%dE, &
         euler_rhs => this%euler_rhs, h => this%h, &
         c_avisc_low => this%c_avisc_low, rk_scheme => this%rk_scheme)
 
      ! Hack: If m_z is always zero, use it to visualize rho
      ! call field_cfill(m_z, 0.0_rp, n)
 
      call euler_rhs%step(rho_field, m_x, m_y, m_z, e, &
           p, u, v, w, ax, &
           c_xh, gs_xh, h, c_avisc_low, &
           rk_scheme, dt)
 
      call this%bcs_density%apply(rho_field, t, tstep)
 
      ! Update u, v, w
      call field_copy(u, m_x, n)
      call field_invcol2(u, rho_field, n)
      call field_copy(v, m_y, n)
      call field_invcol2(v, rho_field, n)
      call field_copy(w, m_z, n)
      call field_invcol2(w, rho_field, n)
 
      call this%bcs_vel%apply_vector(u%x, v%x, w%x, &
           dm_xh%size(), t, tstep, strong = .true.)
      call field_copy(m_x, u, n)
      call field_col2(m_x, rho_field, n)
      call field_copy(m_y, v, n)
      call field_col2(m_y, rho_field, n)
      call field_copy(m_z, w, n)
      call field_col2(m_z, rho_field, n)
 
      call field_col3(temp, u, u, n)
      call field_addcol3(temp, v, v, n)
      call field_addcol3(temp, w, w, n)
      call field_col2(temp, rho_field, n)
      call field_cmult(temp, 0.5_rp, n)
      call field_copy(p, e, n)
      call field_sub2(p, temp, n)
      call field_cmult(p, this%gamma - 1.0_rp, n)
 
      call this%bcs_prs%apply(p, t, tstep)
      ! TODO: Make sure pressure is positive
      ! E = p / (gamma - 1) + 0.5 * rho * (u^2 + v^2 + w^2)
      call field_copy(e, p, n)
      call field_cmult(e, 1.0_rp / (this%gamma - 1.0_rp), n)
      ! temp = 0.5 * rho * (u^2 + v^2 + w^2)
      call field_add2(e, temp, n)
 
 
      ! Hack: If m_z is always zero, use it to visualize rho
      ! call field_copy(w, rho_field, n)
 
    end associate
    call profiler_end_region('Fluid compressible', 1)
 
    call this%scratch%relinquish_field(temp_indices)
 
  subroutine fluid_scheme_compressible_euler_step(this, t, tstep, dt, & …
  end subroutine fluid_scheme_compressible_euler_step
 
  subroutine fluid_scheme_compressible_euler_setup_bcs(this, user, params)
    class(fluid_scheme_compressible_euler_t), intent(inout) :: this
    type(user_t), target, intent(in) :: user
    type(json_file), intent(inout) :: params
    integer :: i, n_bcs, zone_index, j, zone_size, global_zone_size, ierr
    class(bc_t), pointer :: bc_i
    type(json_core) :: core
    type(json_value), pointer :: bc_object
    type(json_file) :: bc_subdict
    logical :: found
    integer, allocatable :: zone_indices(:)
    character(len=LOG_SIZE) :: log_buf
 
    ! Process boundary conditions
    if (params%valid_path('case.fluid.boundary_conditions')) then
       call params%info('case.fluid.boundary_conditions', n_children = n_bcs)
       call params%get_core(core)
       call params%get('case.fluid.boundary_conditions', bc_object, found)
 
       !
       ! Velocity bcs
       !
       call this%bcs_vel%init(n_bcs)
 
       do i = 1, n_bcs
          ! Extract BC configuration
          call json_extract_item(core, bc_object, i, bc_subdict)
          call json_get(bc_subdict, "zone_indices", zone_indices)
 
          ! Validate zones
          do j = 1, size(zone_indices)
             zone_size = this%msh%labeled_zones(zone_indices(j))%size
             call mpi_allreduce(zone_size, global_zone_size, 1, &
                  mpi_integer, mpi_max, neko_comm, ierr)
 
             if (global_zone_size .eq. 0) then
                write(error_unit,'(A,I0,A)') "Error: Zone ", zone_indices(j), &
                     " has zero size"
                error stop
             end if
          end do
 
          ! Create BC
          bc_i => null()
          call velocity_bc_factory(bc_i, this, bc_subdict, this%c_Xh, user)
 
          ! Add to appropriate lists
          if (associated(bc_i)) then
             call this%bcs_vel%append(bc_i)
          end if
       end do
 
       !
       ! Pressure bcs
       !
       call this%bcs_prs%init(n_bcs)
 
       do i = 1, n_bcs
          ! Create a new json containing just the subdict for this bc
          call json_extract_item(core, bc_object, i, bc_subdict)
          bc_i => null()
          call pressure_bc_factory(bc_i, this, bc_subdict, this%c_Xh, user)
 
          ! Not all bcs require an allocation for pressure in particular,
          ! so we check.
          if (associated(bc_i)) then
             call this%bcs_prs%append(bc_i)
          end if
       end do
 
       !
       ! Density bcs
       !
       call this%bcs_density%init(n_bcs)
 
       do i = 1, n_bcs
          ! Create a new json containing just the subdict for this bc
          call json_extract_item(core, bc_object, i, bc_subdict)
          bc_i => null()
          call density_bc_factory(bc_i, this, bc_subdict, this%c_Xh, user)
 
          ! Not all bcs require an allocation for pressure in particular,
          ! so we check.
          if (associated(bc_i)) then
             call this%bcs_density%append(bc_i)
          end if
       end do
    end if
  subroutine fluid_scheme_compressible_euler_setup_bcs(this, user, params) …
  end subroutine fluid_scheme_compressible_euler_setup_bcs
 
  subroutine compute_h(this)
    class(fluid_scheme_compressible_euler_t), intent(inout) :: this
    integer :: e, i, j, k
    integer :: im, ip, jm, jp, km, kp
    real(kind=rp) :: di, dj, dk, ndim_inv
    integer :: lx_half, ly_half, lz_half
 
    lx_half = this%c_Xh%Xh%lx / 2
    ly_half = this%c_Xh%Xh%ly / 2
    lz_half = this%c_Xh%Xh%lz / 2
 
    do e = 1, this%c_Xh%msh%nelv
       do k = 1, this%c_Xh%Xh%lz
          km = max(1, k-1)
          kp = min(this%c_Xh%Xh%lz, k+1)
 
          do j = 1, this%c_Xh%Xh%ly
             jm = max(1, j-1)
             jp = min(this%c_Xh%Xh%ly, j+1)
 
             do i = 1, this%c_Xh%Xh%lx
                im = max(1, i-1)
                ip = min(this%c_Xh%Xh%lx, i+1)
 
                di = (this%c_Xh%dof%x(ip, j, k, e) - &
                     this%c_Xh%dof%x(im, j, k, e))**2 &
                     + (this%c_Xh%dof%y(ip, j, k, e) - &
                     this%c_Xh%dof%y(im, j, k, e))**2 &
                     + (this%c_Xh%dof%z(ip, j, k, e) - &
                     this%c_Xh%dof%z(im, j, k, e))**2
 
                dj = (this%c_Xh%dof%x(i, jp, k, e) - &
                     this%c_Xh%dof%x(i, jm, k, e))**2 &
                     + (this%c_Xh%dof%y(i, jp, k, e) - &
                     this%c_Xh%dof%y(i, jm, k, e))**2 &
                     + (this%c_Xh%dof%z(i, jp, k, e) - &
                     this%c_Xh%dof%z(i, jm, k, e))**2
 
                dk = (this%c_Xh%dof%x(i, j, kp, e) - &
                     this%c_Xh%dof%x(i, j, km, e))**2 &
                     + (this%c_Xh%dof%y(i, j, kp, e) - &
                     this%c_Xh%dof%y(i, j, km, e))**2 &
                     + (this%c_Xh%dof%z(i, j, kp, e) - &
                     this%c_Xh%dof%z(i, j, km, e))**2
 
                di = sqrt(di) / (ip - im)
                dj = sqrt(dj) / (jp - jm)
                dk = sqrt(dk) / (kp - km)
                this%h%x(i,j,k,e) = (di * dj * dk)**(1.0_rp / 3.0_rp)
 
             end do
          end do
       end do
    end do
 
    if (neko_bcknd_device .eq. 1) then
       call device_memcpy(this%h%x, this%h%x_d, this%h%dof%size(),&
            host_to_device, sync = .false.)
       call this%gs_Xh%op(this%h, gs_op_add)
       call device_col2(this%h%x_d, this%c_Xh%mult_d, this%h%dof%size())
    else
       call this%gs_Xh%op(this%h, gs_op_add)
       call col2(this%h%x, this%c_Xh%mult, this%h%dof%size())
    end if
 
  subroutine compute_h(this) …
  end subroutine compute_h
 
  subroutine fluid_scheme_compressible_euler_restart(this, dtlag, tlag)
    class(fluid_scheme_compressible_euler_t), target, intent(inout) :: this
    real(kind=rp) :: dtlag(10), tlag(10)
  subroutine fluid_scheme_compressible_euler_restart(this, dtlag, tlag) …
  end subroutine fluid_scheme_compressible_euler_restart
 
end module fluid_scheme_compressible_euler