Neko 1.99.3
A portable framework for high-order spectral element flow simulations
Loading...
Searching...
No Matches
data_streamer Module Reference

Implements type data_streamer_t.

Data Types

type  data_streamer_t
 Provides access to data streaming by interfacing with c++ ADIOS2 subroutines. More...
 

Functions/Subroutines

subroutine data_streamer_init_params (this, nelv, lx, ly, lz, glb_nelv, offset_el, gdim, timeout_seconds)
 Constructor from parameters.
 
subroutine data_streamer_free (this)
 Destructor wraps the adios2 finalize routine. Closes insitu writer.
 
subroutine data_streamer_stream (this, fld)
 streamer
 
subroutine data_streamer_recieve (this, fld)
 reciever
 
subroutine data_streamer_init_coef (this, coef, timeout_seconds)
 Constructor from a coef_t object. Kept for backwards compatibility. Wraps the adios2 set-up.
 
subroutine data_streamer_init_msh_xh (this, msh, xh, timeout_seconds)
 Constructor from a mesh and space.
 

Function/Subroutine Documentation

◆ data_streamer_free()

subroutine data_streamer::data_streamer_free ( class(data_streamer_t), intent(inout this)
private

Definition at line 121 of file data_streamer.F90.

Here is the call graph for this function:

◆ data_streamer_init_coef()

subroutine data_streamer::data_streamer_init_coef ( class(data_streamer_t), intent(inout this,
type(coef_t), intent(inout coef,
integer, intent(in), optional  timeout_seconds 
)
private
Parameters
coefType that contains geometrical information on the case.
timeout_secondsTime in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 176 of file data_streamer.F90.

◆ data_streamer_init_msh_xh()

subroutine data_streamer::data_streamer_init_msh_xh ( class(data_streamer_t), intent(inout this,
type(mesh_t), intent(in msh,
type(space_t), intent(in xh,
integer, intent(in), optional  timeout_seconds 
)
private
Parameters
mshmesh_t object containing global information about number of elements and offsets
xhspace_t object containing ing
timeout_secondsTime in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 191 of file data_streamer.F90.

◆ data_streamer_init_params()

subroutine data_streamer::data_streamer_init_params ( class(data_streamer_t), intent(inout this,
integer, intent(in nelv,
integer, intent(in lx,
integer, intent(in ly,
integer, intent(in lz,
integer, intent(in glb_nelv,
integer, intent(in offset_el,
integer, intent(in gdim,
integer, intent(in), optional  timeout_seconds 
)
Parameters
nelvLocal number of elements
lxNumber of GLL points in x
lyNumber of GLL points in y
lzNumber of GLL points in z
glb_nelvGlobal number of elements
offset_elElement offset for each rank
gdimDimension of the problem
timeout_secondsTime in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 91 of file data_streamer.F90.

Here is the call graph for this function:

◆ data_streamer_recieve()

subroutine data_streamer::data_streamer_recieve ( class(data_streamer_t), intent(inout this,
real(kind=rp), dimension(:,:,:,:), intent(inout fld 
)
private
Parameters
fldarray of shape fieldx

Definition at line 154 of file data_streamer.F90.

Here is the call graph for this function:

◆ data_streamer_stream()

subroutine data_streamer::data_streamer_stream ( class(data_streamer_t), intent(inout this,
real(kind=rp), dimension(:,:,:,:), intent(inout fld 
)
private
Parameters
fldarray of shape fieldx

Definition at line 137 of file data_streamer.F90.

Here is the call graph for this function: