data_streamer::data_streamer_t Type Reference

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

Public Member Functions
generic	init (this, coef, timeout_seconds)
	Generic constructor.
generic	init (this, msh, xh, timeout_seconds)
	Generic constructor.
generic	init (this, nelv, lx, ly, lz, glb_nelv, offset_el, gdim, timeout_seconds)
	Generic constructor.
procedure, pass(this)	init_coef (this, coef, timeout_seconds)
	Constructor from coef.
procedure, pass(this)	init_msh_xh (this, msh, xh, timeout_seconds)
	Constructor from mesh and space.
procedure, pass(this)	init_params (this, nelv, lx, ly, lz, glb_nelv, offset_el, gdim, timeout_seconds)
	Constructor from parameters.
procedure, pass(this)	free (this)
	Destructor.
procedure, pass(this)	stream (this, fld)
	Stream data.
procedure, pass(this)	recieve (this, fld)
	Stream back the data.

Public Attributes
integer	if_asynch
	Define if the execution is asyncrhonous.
integer, dimension(:), allocatable	lglel
	global element numbers

Detailed Description

Adios2 is an API that allows for easy coupling of codes through data streaming and gives the posibility to perform other IO operations such as data compression, etc. This type wraps and interfaces the needed calls to allow the use of the c++ routines that ultimately expose the data from neko to any executable that counts with a proper reader.

Definition at line 56 of file data_streamer.F90.

Member Function/Subroutine Documentation

free()

procedure, pass(this) data_streamer::data_streamer_t::free

(

class(data_streamer_t), intent(inout)

this

)

Definition at line 71 of file data_streamer.F90.

init() [1/3]

generic data_streamer::data_streamer_t::init	(	class(data_streamer_t), intent(inout)	this,
		type(coef_t), intent(inout)	coef,
		integer, intent(in), optional	timeout_seconds
	)

Parameters

coef	Type that contains geometrical information on the case.
timeout_seconds	Time in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 63 of file data_streamer.F90.

init() [2/3]

generic data_streamer::data_streamer_t::init	(	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
	)

Parameters

msh	mesh_t object containing global information about number of elements and offsets
xh	space_t object containing ing
timeout_seconds	Time in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 63 of file data_streamer.F90.

init() [3/3]

generic data_streamer::data_streamer_t::init	(	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

nelv	Local number of elements
lx	Number of GLL points in x
ly	Number of GLL points in y
lz	Number of GLL points in z
glb_nelv	Global number of elements
offset_el	Element offset for each rank
gdim	Dimension of the problem
timeout_seconds	Time in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 63 of file data_streamer.F90.

init_coef()

procedure, pass(this) data_streamer::data_streamer_t::init_coef	(	class(data_streamer_t), intent(inout)	this,
		type(coef_t), intent(inout)	coef,
		integer, intent(in), optional	timeout_seconds
	)

Parameters

coef	Type that contains geometrical information on the case.
timeout_seconds	Time in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 65 of file data_streamer.F90.

init_msh_xh()

procedure, pass(this) data_streamer::data_streamer_t::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
	)

Parameters

msh	mesh_t object containing global information about number of elements and offsets
xh	space_t object containing ing
timeout_seconds	Time in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 67 of file data_streamer.F90.

init_params()

procedure, pass(this) data_streamer::data_streamer_t::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

nelv	Local number of elements
lx	Number of GLL points in x
ly	Number of GLL points in y
lz	Number of GLL points in z
glb_nelv	Global number of elements
offset_el	Element offset for each rank
gdim	Dimension of the problem
timeout_seconds	Time in seconds after which the streaming should time out. Default is 300 seconds.

Definition at line 69 of file data_streamer.F90.

recieve()

procedure, pass(this) data_streamer::data_streamer_t::recieve	(	class(data_streamer_t), intent(inout)	this,
		real(kind=rp), dimension(:,:,:,:), intent(inout)	fld
	)

Parameters

fld	array of shape fieldx

Definition at line 75 of file data_streamer.F90.

stream()

procedure, pass(this) data_streamer::data_streamer_t::stream	(	class(data_streamer_t), intent(inout)	this,
		real(kind=rp), dimension(:,:,:,:), intent(inout)	fld
	)

Parameters

fld	array of shape fieldx

Definition at line 73 of file data_streamer.F90.

Member Data Documentation

if_asynch

integer data_streamer::data_streamer_t::if_asynch

Definition at line 58 of file data_streamer.F90.

lglel

integer, dimension(:), allocatable data_streamer::data_streamer_t::lglel

Definition at line 60 of file data_streamer.F90.

---

The documentation for this type was generated from the following file:

• /home/runner/work/neko/neko/src/io/data_streamer.F90