mpimessagebuildermodule Module Reference

Data Types
type	vdcheadertype
type	vdcreceivermapstype
type	mpimessagebuildertype

Functions/Subroutines
subroutine	create (this, map_sizes)
subroutine	destroy (this)
subroutine	init (this)
subroutine	attach_data (this, vdc_models, vdc_exchanges)
subroutine	release_data (this)
subroutine	set_monitor (this, imon)
subroutine	create_header_snd (this, rank, stage, hdrs_snd_type)
	Create the header data type to send to the remote process for this particular stage. From these data, the receiver can construct the. More...
subroutine	create_header_rcv (this, hdr_rcv_type)
subroutine	create_map_snd (this, rank, stage, map_snd_type)
subroutine	create_map_rcv (this, rcv_map, nr_headers, map_rcv_type)
subroutine	create_body_rcv (this, rank, stage, body_rcv_type)
	Create the body to receive based on the headers. More...
subroutine	create_body_snd (this, rank, stage, headers, maps, body_snd_type)
	Create the body to send based on the received headers. More...
integer function	create_vdc_snd_hdr (this, vdc, stage)
	Create send header for virtual data container, relative. More...
integer function	create_vdc_snd_map (this, vdc, stage)
	Create a MPI datatype for sending the maps. More...
integer function	create_vdc_rcv_body (this, vdc, rank, stage)
integer function	create_vdc_snd_body (this, vdc, vdc_maps, rank, stage)
class(virtualdatacontainertype) function, pointer	get_vdc_from_hdr (this, header)
subroutine	get_mpi_datatype (this, virtual_data, el_displ, el_type, el_map_opt)
	Local routine to get elemental mpi data types representing the virtual data items. Types are automatically committed unless. More...
subroutine	free_mpi_datatype (virtual_data, el_type)
	Local routine to free elemental mpi data types representing the virtual data items. This can't be done generally, because some. More...
subroutine	get_mpitype_for_int (mem, el_displ, el_type)
subroutine	get_mpitype_for_int1d (mem, el_displ, el_type, el_map)
subroutine	get_mpitype_for_dbl (mem, el_displ, el_type)
subroutine	get_mpitype_for_dbl1d (mem, el_displ, el_type, el_map)
subroutine	get_mpitype_for_dbl2d (mem, el_displ, el_type, el_map)

Function/Subroutine Documentation

attach_data()

subroutine mpimessagebuildermodule::attach_data ( class(mpimessagebuildertype)  this, type(vdcptrtype), dimension(:), pointer  vdc_models, type(vdcptrtype), dimension(:), pointer  vdc_exchanges  )

private

Definition at line 82 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    type(VdcPtrType), dimension(:), pointer :: vdc_models
    type(VdcPtrType), dimension(:), pointer :: vdc_exchanges
 
    this%vdc_models => vdc_models
    this%vdc_exchanges => vdc_exchanges
 

create()

subroutine mpimessagebuildermodule::create	(	class(vdcreceivermapstype)	this,
		integer(i4b), dimension(nr_vdc_element_maps)	map_sizes
	)

Definition at line 49 of file MpiMessageBuilder.f90.

    class(VdcReceiverMapsType) :: this
    integer(I4B), dimension(NR_VDC_ELEMENT_MAPS) :: map_sizes
    ! local
    integer(I4B) :: i
 
    do i = 1, nr_vdc_element_maps
      this%el_maps(i)%nr_virt_elems = map_sizes(i)
      allocate (this%el_maps(i)%remote_elem_shift(map_sizes(i)))
    end do
 

create_body_rcv()

subroutine mpimessagebuildermodule::create_body_rcv ( class(mpimessagebuildertype)  this, integer(i4b)  rank, integer(i4b)  stage, integer, intent(out)  body_rcv_type  )

private

Definition at line 321 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    integer(I4B) :: rank
    integer(I4B) :: stage
    integer, intent(out) :: body_rcv_type
    ! local
    integer(I4B) :: i, nr_types, offset
    class(VirtualDataContainerType), pointer :: vdc
    type(STLVecInt) :: model_idxs, exg_idxs
    integer :: ierr
    integer, dimension(:), allocatable :: types
    integer(kind=MPI_ADDRESS_KIND), dimension(:), allocatable :: displs
    integer, dimension(:), allocatable :: blk_cnts
 
    call model_idxs%init()
    call exg_idxs%init()
 
    ! gather all containers from this rank
    do i = 1, size(this%vdc_models)
      vdc => this%vdc_models(i)%ptr
      if (vdc%is_active .and. vdc%orig_rank == rank) then
        if (this%imon > 0) then
          write (this%imon, '(6x,a,i0)') "expecting model ", vdc%id
        end if
        call model_idxs%push_back(i)
      end if
    end do
    do i = 1, size(this%vdc_exchanges)
      vdc => this%vdc_exchanges(i)%ptr
      if (vdc%is_active .and. vdc%orig_rank == rank) then
        if (this%imon > 0) then
          write (this%imon, '(6x,a,i0)') "expecting exchange ", vdc%id
        end if
        call exg_idxs%push_back(i)
      end if
    end do
 
    nr_types = model_idxs%size + exg_idxs%size
    allocate (types(nr_types))
    allocate (displs(nr_types))
    allocate (blk_cnts(nr_types))
 
    ! loop over included containers
    do i = 1, model_idxs%size
      vdc => this%vdc_models(model_idxs%at(i))%ptr
      call mpi_get_address(vdc%id, displs(i), ierr)
      types(i) = this%create_vdc_rcv_body(vdc, rank, stage)
      blk_cnts(i) = 1
    end do
    offset = model_idxs%size
    do i = 1, exg_idxs%size
      vdc => this%vdc_exchanges(exg_idxs%at(i))%ptr
      call mpi_get_address(vdc%id, displs(i + offset), ierr)
      blk_cnts(i + offset) = 1
      types(i + offset) = this%create_vdc_rcv_body(vdc, rank, stage)
    end do
 
    ! create a MPI data type for the virtual data containers to receive
    call mpi_type_create_struct(nr_types, blk_cnts, displs, types, &
                                body_rcv_type, ierr)
    call mpi_type_commit(body_rcv_type, ierr)
    do i = 1, nr_types
      call mpi_type_free(types(i), ierr)
    end do
 
    call model_idxs%destroy()
    call exg_idxs%destroy()
    deallocate (types)
    deallocate (displs)
    deallocate (blk_cnts)
 

create_body_snd()

subroutine mpimessagebuildermodule::create_body_snd ( class(mpimessagebuildertype)  this, integer(i4b)  rank, integer(i4b)  stage, type(vdcheadertype), dimension(:)  headers, type(vdcreceivermapstype), dimension(:)  maps, integer, intent(out)  body_snd_type  )

private

Definition at line 396 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    integer(I4B) :: rank
    integer(I4B) :: stage
    type(VdcHeaderType), dimension(:) :: headers
    type(VdcReceiverMapsType), dimension(:) :: maps
    integer, intent(out) :: body_snd_type
    ! local
    integer(I4B) :: i, nr_headers
    class(VirtualDataContainerType), pointer :: vdc
    integer :: ierr
    integer, dimension(:), allocatable :: types
    integer(kind=MPI_ADDRESS_KIND), dimension(:), allocatable :: displs
    integer, dimension(:), allocatable :: blk_cnts
 
    nr_headers = size(headers)
    allocate (types(nr_headers))
    allocate (displs(nr_headers))
    allocate (blk_cnts(nr_headers))
 
    do i = 1, nr_headers
      vdc => this%get_vdc_from_hdr(headers(i))
      call mpi_get_address(vdc%id, displs(i), ierr)
      types(i) = this%create_vdc_snd_body(vdc, maps(i)%el_maps, rank, stage)
      blk_cnts(i) = 1
    end do
 
    ! create the list of virtual data containers to receive
    call mpi_type_create_struct(nr_headers, blk_cnts, displs, &
                                types, body_snd_type, ierr)
    call mpi_type_commit(body_snd_type, ierr)
    do i = 1, nr_headers
      call mpi_type_free(types(i), ierr)
    end do
 
    deallocate (types)
    deallocate (displs)
    deallocate (blk_cnts)
 

create_header_rcv()

subroutine mpimessagebuildermodule::create_header_rcv ( class(mpimessagebuildertype)  this, integer, intent(out)  hdr_rcv_type  )

private

Definition at line 186 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    integer, intent(out) :: hdr_rcv_type
    ! local
    integer :: ierr
 
    ! this will be for one data container, the mpi recv
    ! call will accept an array of them, no need to create
    ! an overarching contiguous type...
    call mpi_type_contiguous(nr_vdc_element_maps + 2, mpi_integer, &
                             hdr_rcv_type, ierr)
    call mpi_type_commit(hdr_rcv_type, ierr)
 

create_header_snd()

subroutine mpimessagebuildermodule::create_header_snd ( class(mpimessagebuildertype)  this, integer(i4b)  rank, integer(i4b)  stage, integer, intent(out)  hdrs_snd_type  )

private

Definition at line 112 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    integer(I4B) :: rank
    integer(I4B) :: stage
    integer, intent(out) :: hdrs_snd_type
    ! local
    integer(I4B) :: i, offset, nr_types
    class(VirtualDataContainerType), pointer :: vdc
    integer :: ierr
    type(STLVecInt) :: model_idxs, exg_idxs
    integer, dimension(:), allocatable :: blk_cnts, types
    integer(kind=MPI_ADDRESS_KIND), dimension(:), allocatable :: displs
 
    call model_idxs%init()
    call exg_idxs%init()
 
    ! determine which containers to include
    do i = 1, size(this%vdc_models)
      vdc => this%vdc_models(i)%ptr
      if (vdc%is_active .and. vdc%orig_rank == rank) then
        call model_idxs%push_back(i)
      end if
    end do
    do i = 1, size(this%vdc_exchanges)
      vdc => this%vdc_exchanges(i)%ptr
      if (vdc%is_active .and. vdc%orig_rank == rank) then
        call exg_idxs%push_back(i)
      end if
    end do
 
    nr_types = model_idxs%size + exg_idxs%size
    allocate (blk_cnts(nr_types))
    allocate (types(nr_types))
    allocate (displs(nr_types))
 
    if (this%imon > 0) then
      write (this%imon, '(6x,a,*(i3))') "create headers for models: ", &
        model_idxs%get_values()
      write (this%imon, '(6x,a,*(i3))') "create headers for exchange: ", &
        exg_idxs%get_values()
    end if
 
    ! loop over containers
    do i = 1, model_idxs%size
      vdc => this%vdc_models(model_idxs%at(i))%ptr
      call mpi_get_address(vdc%id, displs(i), ierr)
      blk_cnts(i) = 1
      types(i) = this%create_vdc_snd_hdr(vdc, stage)
    end do
    offset = model_idxs%size
    do i = 1, exg_idxs%size
      vdc => this%vdc_exchanges(exg_idxs%at(i))%ptr
      call mpi_get_address(vdc%id, displs(i + offset), ierr)
      blk_cnts(i + offset) = 1
      types(i + offset) = this%create_vdc_snd_hdr(vdc, stage)
    end do
 
    ! create a MPI data type for the headers to send
    call mpi_type_create_struct(nr_types, blk_cnts, displs, types, &
                                hdrs_snd_type, ierr)
    call mpi_type_commit(hdrs_snd_type, ierr)
    do i = 1, nr_types
      call mpi_type_free(types(i), ierr)
    end do
 
    call model_idxs%destroy()
    call exg_idxs%destroy()
 
    deallocate (blk_cnts)
    deallocate (types)
    deallocate (displs)
 

create_map_rcv()

subroutine mpimessagebuildermodule::create_map_rcv ( class(mpimessagebuildertype)  this, type(vdcreceivermapstype), dimension(:)  rcv_map, integer(i4b)  nr_headers, integer, intent(out)  map_rcv_type  )

private

Definition at line 278 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    type(VdcReceiverMapsType), dimension(:) :: rcv_map
    integer(I4B) :: nr_headers
    integer, intent(out) :: map_rcv_type
    ! local
    integer(I4B) :: i, j, nr_elems, type_cnt
    integer :: ierr, max_nr_maps
    integer, dimension(:), allocatable :: types
    integer(kind=MPI_ADDRESS_KIND), dimension(:), allocatable :: displs
    integer, dimension(:), allocatable :: blk_cnts
 
    max_nr_maps = nr_headers * nr_vdc_element_maps
    allocate (types(max_nr_maps))
    allocate (displs(max_nr_maps))
    allocate (blk_cnts(max_nr_maps))
 
    type_cnt = 0
    do i = 1, nr_headers
      do j = 1, nr_vdc_element_maps
        nr_elems = rcv_map(i)%el_maps(j)%nr_virt_elems
        if (nr_elems == 0) cycle
 
        type_cnt = type_cnt + 1
        call mpi_get_address(rcv_map(i)%el_maps(j)%remote_elem_shift, &
                             displs(type_cnt), ierr)
        call mpi_type_contiguous(nr_elems, mpi_integer, types(type_cnt), ierr)
        blk_cnts(type_cnt) = 1
      end do
    end do
 
    call mpi_type_create_struct(type_cnt, blk_cnts, displs, types, &
                                map_rcv_type, ierr)
    call mpi_type_commit(map_rcv_type, ierr)
 
    deallocate (types)
    deallocate (displs)
    deallocate (blk_cnts)
 

create_map_snd()

subroutine mpimessagebuildermodule::create_map_snd ( class(mpimessagebuildertype)  this, integer(i4b)  rank, integer(i4b)  stage, integer, intent(out)  map_snd_type  )

private

Definition at line 201 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    integer(I4B) :: rank
    integer(I4B) :: stage
    integer, intent(out) :: map_snd_type
    ! local
    integer(I4B) :: i, offset, nr_types
    class(VirtualDataContainerType), pointer :: vdc
    integer :: ierr
    type(STLVecInt) :: model_idxs, exg_idxs
    integer, dimension(:), allocatable :: blk_cnts, types
    integer(kind=MPI_ADDRESS_KIND), dimension(:), allocatable :: displs
 
    call model_idxs%init()
    call exg_idxs%init()
 
    ! determine which containers to include,
    ! currently models + exchanges
    do i = 1, size(this%vdc_models)
      vdc => this%vdc_models(i)%ptr
      if (vdc%is_active .and. vdc%orig_rank == rank) then
        call model_idxs%push_back(i)
      end if
    end do
    do i = 1, size(this%vdc_exchanges)
      vdc => this%vdc_exchanges(i)%ptr
      if (vdc%is_active .and. vdc%orig_rank == rank) then
        call exg_idxs%push_back(i)
      end if
    end do
 
    nr_types = model_idxs%size + exg_idxs%size
    allocate (blk_cnts(nr_types))
    allocate (types(nr_types))
    allocate (displs(nr_types))
 
    if (this%imon > 0) then
      write (this%imon, '(6x,a,*(i3))') "create maps for models: ", &
        model_idxs%get_values()
      write (this%imon, '(6x,a,*(i3))') "create maps for exchange: ", &
        exg_idxs%get_values()
    end if
 
    ! loop over containers
    do i = 1, model_idxs%size
      vdc => this%vdc_models(model_idxs%at(i))%ptr
      call mpi_get_address(vdc%id, displs(i), ierr)
      blk_cnts(i) = 1
      types(i) = this%create_vdc_snd_map(vdc, stage)
    end do
    offset = model_idxs%size
    do i = 1, exg_idxs%size
      vdc => this%vdc_exchanges(exg_idxs%at(i))%ptr
      call mpi_get_address(vdc%id, displs(i + offset), ierr)
      blk_cnts(i + offset) = 1
      types(i + offset) = this%create_vdc_snd_map(vdc, stage)
    end do
 
    ! create a compound MPI data type for the maps
    call mpi_type_create_struct(nr_types, blk_cnts, displs, types, &
                                map_snd_type, ierr)
    call mpi_type_commit(map_snd_type, ierr)
 
    ! free the subtypes
    do i = 1, nr_types
      call mpi_type_free(types(i), ierr)
    end do
 
    call model_idxs%destroy()
    call exg_idxs%destroy()
 
    deallocate (blk_cnts)
    deallocate (types)
    deallocate (displs)
 

create_vdc_rcv_body()

integer function mpimessagebuildermodule::create_vdc_rcv_body ( class(mpimessagebuildertype)  this, class(virtualdatacontainertype), pointer  vdc, integer(i4b)  rank, integer(i4b)  stage  )

private

Definition at line 520 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    class(VirtualDataContainerType), pointer :: vdc
    integer(I4B) :: rank
    integer(I4B) :: stage
    integer :: new_type
    ! local
    type(STLVecInt) :: items
    integer :: ierr
    integer(kind=MPI_ADDRESS_KIND) :: offset
    integer, dimension(:), allocatable :: types
    integer(kind=MPI_ADDRESS_KIND), dimension(:), allocatable :: displs
    integer, dimension(:), allocatable :: blk_cnts
    integer(I4B) :: i
    class(VirtualDataType), pointer :: vd
 
    call items%init()
    call vdc%get_recv_items(stage, rank, items)
    !if (this%imon > 0) call vdc%print_items(this%imon, items)
 
    allocate (types(items%size))
    allocate (displs(items%size))
    allocate (blk_cnts(items%size))
 
    call mpi_get_address(vdc%id, offset, ierr)
 
    do i = 1, items%size
      vd => get_virtual_data_from_list(vdc%virtual_data_list, items%at(i))
      call get_mpi_datatype(this, vd, displs(i), types(i))
      blk_cnts(i) = 1
      ! rebase w.r.t. id field
      displs(i) = displs(i) - offset
    end do
 
    call mpi_type_create_struct(items%size, blk_cnts, displs, &
                                types, new_type, ierr)
    call mpi_type_commit(new_type, ierr)
 
    do i = 1, items%size
      vd => get_virtual_data_from_list(vdc%virtual_data_list, items%at(i))
      call free_mpi_datatype(vd, types(i))
    end do
 
    deallocate (types)
    deallocate (displs)
    deallocate (blk_cnts)
 
    call items%destroy()
 

Here is the call graph for this function:

create_vdc_snd_body()

integer function mpimessagebuildermodule::create_vdc_snd_body ( class(mpimessagebuildertype)  this, class(virtualdatacontainertype), pointer  vdc, type(vdcelementmaptype), dimension(:)  vdc_maps, integer(i4b)  rank, integer(i4b)  stage  )

private

Definition at line 571 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    class(VirtualDataContainerType), pointer :: vdc
    type(VdcElementMapType), dimension(:) :: vdc_maps
    integer(I4B) :: rank
    integer(I4B) :: stage
    integer :: new_type
    ! local
    type(STLVecInt) :: items
    integer :: ierr
    integer(kind=MPI_ADDRESS_KIND) :: offset
    integer, dimension(:), allocatable :: types
    integer(kind=MPI_ADDRESS_KIND), dimension(:), allocatable :: displs
    integer, dimension(:), allocatable :: blk_cnts
    integer(I4B) :: i
    class(VirtualDataType), pointer :: vd
    integer(I4B), dimension(:), pointer, contiguous :: el_map
 
    call items%init()
    call vdc%get_send_items(stage, rank, items)
    !if (this%imon > 0) call vdc%print_items(this%imon, items)
 
    allocate (types(items%size))
    allocate (displs(items%size))
    allocate (blk_cnts(items%size))
 
    call mpi_get_address(vdc%id, offset, ierr)
 
    do i = 1, items%size
      vd => get_virtual_data_from_list(vdc%virtual_data_list, items%at(i))
      if (vd%map_type > 0) then
        el_map => vdc_maps(vd%map_type)%remote_elem_shift
      else
        el_map => null()
      end if
      call get_mpi_datatype(this, vd, displs(i), types(i), el_map)
      blk_cnts(i) = 1
      ! rebase w.r.t. id field
      displs(i) = displs(i) - offset
    end do
 
    call mpi_type_create_struct(items%size, blk_cnts, displs, &
                                types, new_type, ierr)
    call mpi_type_commit(new_type, ierr)
 
    do i = 1, items%size
      vd => get_virtual_data_from_list(vdc%virtual_data_list, items%at(i))
      call free_mpi_datatype(vd, types(i))
    end do
 
    deallocate (types)
    deallocate (displs)
    deallocate (blk_cnts)
 
    call items%destroy()
 

Here is the call graph for this function:

create_vdc_snd_hdr()

integer function mpimessagebuildermodule::create_vdc_snd_hdr ( class(mpimessagebuildertype)  this, class(virtualdatacontainertype)  vdc, integer(i4b)  stage  )

private

Definition at line 439 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    class(VirtualDataContainerType) :: vdc
    integer(I4B) :: stage
    integer :: new_type ! the created MPI datatype, uncommitted
    ! local
    integer :: i, ierr
    integer, dimension(NR_VDC_ELEMENT_MAPS + 2) :: blk_cnts
    integer(kind=MPI_ADDRESS_KIND), dimension(NR_VDC_ELEMENT_MAPS + 2) :: displs
    integer, dimension(NR_VDC_ELEMENT_MAPS + 2) :: types
 
    call mpi_get_address(vdc%id, displs(1), ierr)
    types(1) = mpi_integer
    blk_cnts(1) = 1
    call mpi_get_address(vdc%container_type, displs(2), ierr)
    types(2) = mpi_integer
    blk_cnts(2) = 1
    do i = 1, nr_vdc_element_maps
      call mpi_get_address(vdc%element_maps(i)%nr_virt_elems, displs(i + 2), ierr)
      types(i + 2) = mpi_integer
      blk_cnts(i + 2) = 1
    end do
 
    ! rebase to id field
    displs = displs - displs(1)
    call mpi_type_create_struct(nr_vdc_element_maps + 2, blk_cnts, &
                                displs, types, new_type, ierr)
    call mpi_type_commit(new_type, ierr)
 

create_vdc_snd_map()

integer function mpimessagebuildermodule::create_vdc_snd_map ( class(mpimessagebuildertype)  this, class(virtualdatacontainertype), pointer  vdc, integer(i4b)  stage  )

private

Definition at line 472 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    class(VirtualDataContainerType), pointer :: vdc
    integer(I4B) :: stage
    integer :: new_type
    ! local
    integer(I4B) :: i, type_cnt
    integer :: n_elems, ierr
    integer(kind=MPI_ADDRESS_KIND) :: offset
    integer, dimension(:), allocatable :: types
    integer(kind=MPI_ADDRESS_KIND), dimension(:), allocatable :: displs
    integer, dimension(:), allocatable :: blk_cnts
 
    allocate (types(nr_vdc_element_maps))
    allocate (displs(nr_vdc_element_maps))
    allocate (blk_cnts(nr_vdc_element_maps))
 
    ! displ relative to id field
    call mpi_get_address(vdc%id, offset, ierr)
 
    type_cnt = 0
    do i = 1, nr_vdc_element_maps
      n_elems = vdc%element_maps(i)%nr_virt_elems
      if (n_elems == 0) cycle ! only non-empty maps are sent
 
      type_cnt = type_cnt + 1
      call mpi_get_address(vdc%element_maps(i)%remote_elem_shift, &
                           displs(type_cnt), ierr)
      call mpi_type_contiguous(n_elems, mpi_integer, types(type_cnt), ierr)
      call mpi_type_commit(types(type_cnt), ierr)
      blk_cnts(type_cnt) = 1
      displs(type_cnt) = displs(type_cnt) - offset
    end do
 
    call mpi_type_create_struct(type_cnt, blk_cnts, displs, types, &
                                new_type, ierr)
    call mpi_type_commit(new_type, ierr)
 
    do i = 1, type_cnt
      call mpi_type_free(types(i), ierr)
    end do
 
    deallocate (types)
    deallocate (displs)
    deallocate (blk_cnts)
 

destroy()

subroutine mpimessagebuildermodule::destroy ( class(vdcreceivermapstype)  this )

private

Definition at line 62 of file MpiMessageBuilder.f90.

    class(VdcReceiverMapsType) :: this
    ! local
    integer(I4B) :: i
 
    do i = 1, nr_vdc_element_maps
      if (associated(this%el_maps(i)%remote_elem_shift)) then
        deallocate (this%el_maps(i)%remote_elem_shift)
      end if
    end do
 

free_mpi_datatype()

subroutine mpimessagebuildermodule::free_mpi_datatype	(	class(virtualdatatype), pointer	virtual_data,
		integer	el_type
	)

Definition at line 707 of file MpiMessageBuilder.f90.

    class(VirtualDataType), pointer :: virtual_data
    integer :: el_type
    ! local
    type(MemoryType), pointer :: mt
    integer :: ierr
 
    mt => virtual_data%virtual_mt
    if (associated(mt%intsclr)) then
      ! type is MPI_INTEGER, don't free this!
      return
    else if (associated(mt%dblsclr)) then
      ! type is MPI_DOUBLE_PRECISION, don't free this!
      return
    else if (associated(mt%logicalsclr)) then
      ! type is MPI_LOGICAL, don't free this!
      return
    else
      ! all other types are freed here
      call mpi_type_free(el_type, ierr)
      return
    end if
 

Here is the caller graph for this function:

get_mpi_datatype()

subroutine mpimessagebuildermodule::get_mpi_datatype ( class(mpimessagebuildertype)  this, class(virtualdatatype), pointer  virtual_data, integer(kind=mpi_address_kind)  el_displ, integer  el_type, integer(i4b), dimension(:), optional, pointer, contiguous  el_map_opt  )

private

Parameters

el_map_opt

optional, and can be null

Definition at line 660 of file MpiMessageBuilder.f90.

    use simmodule, only: ustop
    class(MpiMessageBuilderType) :: this
    class(VirtualDataType), pointer :: virtual_data
    integer(kind=MPI_ADDRESS_KIND) :: el_displ
    integer :: el_type
    integer(I4B), dimension(:), pointer, contiguous, optional :: el_map_opt !< optional, and can be null
    ! local
    type(MemoryType), pointer :: mt
    integer(I4B), dimension(:), pointer, contiguous :: el_map
 
    el_map => null()
    if (present(el_map_opt)) el_map => el_map_opt
 
    if (this%imon > 0) then
      if (.not. associated(el_map)) then
        write (this%imon, '(8x,2a,i0)') virtual_data%var_name, ' all ', &
          virtual_data%virtual_mt%isize
      else
        write (this%imon, '(8x,2a,i0)') virtual_data%var_name, &
          ' with map size ', size(el_map)
      end if
    end if
 
    mt => virtual_data%virtual_mt
 
    if (associated(mt%intsclr)) then
      call get_mpitype_for_int(mt, el_displ, el_type)
    else if (associated(mt%aint1d)) then
      call get_mpitype_for_int1d(mt, el_displ, el_type, el_map)
    else if (associated(mt%dblsclr)) then
      call get_mpitype_for_dbl(mt, el_displ, el_type)
    else if (associated(mt%adbl1d)) then
      call get_mpitype_for_dbl1d(mt, el_displ, el_type, el_map)
    else if (associated(mt%adbl2d)) then
      call get_mpitype_for_dbl2d(mt, el_displ, el_type, el_map)
    else
      write (*, *) 'unsupported datatype in MPI messaging for ', &
        virtual_data%var_name, virtual_data%mem_path
      call ustop()
    end if
 

Here is the call graph for this function:

Here is the caller graph for this function:

get_mpitype_for_dbl()

subroutine mpimessagebuildermodule::get_mpitype_for_dbl ( type(memorytype), pointer  mem, integer(kind=mpi_address_kind)  el_displ, integer  el_type  )

private

Definition at line 764 of file MpiMessageBuilder.f90.

    type(MemoryType), pointer :: mem
    integer(kind=MPI_ADDRESS_KIND) :: el_displ
    integer :: el_type
    ! local
    integer :: ierr
 
    call mpi_get_address(mem%dblsclr, el_displ, ierr)
    el_type = mpi_double_precision
    ! no need to commit primitive type
 

Here is the caller graph for this function:

get_mpitype_for_dbl1d()

subroutine mpimessagebuildermodule::get_mpitype_for_dbl1d ( type(memorytype), pointer  mem, integer(kind=mpi_address_kind)  el_displ, integer  el_type, integer, dimension(:), pointer  el_map  )

private

Definition at line 777 of file MpiMessageBuilder.f90.

    type(MemoryType), pointer :: mem
    integer(kind=MPI_ADDRESS_KIND) :: el_displ
    integer :: el_type
    integer, dimension(:), pointer :: el_map
    ! local
    integer :: ierr
 
    call mpi_get_address(mem%adbl1d, el_displ, ierr)
    if (associated(el_map)) then
      call mpi_type_create_indexed_block( &
        size(el_map), 1, el_map, mpi_double_precision, el_type, ierr)
    else
      call mpi_type_contiguous(mem%isize, mpi_double_precision, el_type, ierr)
    end if
    call mpi_type_commit(el_type, ierr)
 

Here is the caller graph for this function:

get_mpitype_for_dbl2d()

subroutine mpimessagebuildermodule::get_mpitype_for_dbl2d ( type(memorytype), pointer  mem, integer(kind=mpi_address_kind)  el_displ, integer  el_type, integer, dimension(:), pointer  el_map  )

private

Definition at line 796 of file MpiMessageBuilder.f90.

    type(MemoryType), pointer :: mem
    integer(kind=MPI_ADDRESS_KIND) :: el_displ
    integer :: el_type
    integer, dimension(:), pointer :: el_map
    ! local
    integer :: ierr
    integer :: entry_type
 
    call mpi_get_address(mem%adbl2d, el_displ, ierr)
    if (associated(el_map)) then
      call mpi_type_contiguous( &
        size(mem%adbl2d, dim=1), mpi_double_precision, entry_type, ierr)
      call mpi_type_create_indexed_block( &
        size(el_map), 1, el_map, entry_type, el_type, ierr)
    else
      call mpi_type_contiguous(mem%isize, mpi_double_precision, el_type, ierr)
    end if
    call mpi_type_commit(el_type, ierr)
 

Here is the caller graph for this function:

get_mpitype_for_int()

subroutine mpimessagebuildermodule::get_mpitype_for_int ( type(memorytype), pointer  mem, integer(kind=mpi_address_kind)  el_displ, integer  el_type  )

private

Definition at line 732 of file MpiMessageBuilder.f90.

    type(MemoryType), pointer :: mem
    integer(kind=MPI_ADDRESS_KIND) :: el_displ
    integer :: el_type
    ! local
    integer :: ierr
 
    call mpi_get_address(mem%intsclr, el_displ, ierr)
    el_type = mpi_integer
    ! no need to commit primitive type
 

Here is the caller graph for this function:

get_mpitype_for_int1d()

subroutine mpimessagebuildermodule::get_mpitype_for_int1d ( type(memorytype), pointer  mem, integer(kind=mpi_address_kind)  el_displ, integer  el_type, integer, dimension(:), pointer  el_map  )

private

Definition at line 745 of file MpiMessageBuilder.f90.

    type(MemoryType), pointer :: mem
    integer(kind=MPI_ADDRESS_KIND) :: el_displ
    integer :: el_type
    integer, dimension(:), pointer :: el_map
    ! local
    integer :: ierr
 
    call mpi_get_address(mem%aint1d, el_displ, ierr)
    if (associated(el_map)) then
      call mpi_type_create_indexed_block( &
        size(el_map), 1, el_map, mpi_integer, el_type, ierr)
    else
      call mpi_type_contiguous(mem%isize, mpi_integer, el_type, ierr)
    end if
    call mpi_type_commit(el_type, ierr)
 

Here is the caller graph for this function:

get_vdc_from_hdr()

class(virtualdatacontainertype) function, pointer mpimessagebuildermodule::get_vdc_from_hdr ( class(mpimessagebuildertype)  this, type(vdcheadertype)  header  )

private

Definition at line 629 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    type(VdcHeaderType) :: header
    class(VirtualDataContainerType), pointer :: vdc
    ! local
    integer(I4B) :: i
 
    vdc => null()
    if (header%container_type == vdc_gwfmodel_type .or. &
        header%container_type == vdc_gwtmodel_type .or. &
        header%container_type == vdc_gwemodel_type) then
      do i = 1, size(this%vdc_models)
        vdc => this%vdc_models(i)%ptr
        if (vdc%id == header%id) return
        vdc => null()
      end do
    else if (header%container_type == vdc_gwfexg_type .or. &
             header%container_type == vdc_gwtexg_type .or. &
             header%container_type == vdc_gweexg_type) then
      do i = 1, size(this%vdc_exchanges)
        vdc => this%vdc_exchanges(i)%ptr
        if (vdc%id == header%id) return
        vdc => null()
      end do
    end if
 

init()

subroutine mpimessagebuildermodule::init ( class(mpimessagebuildertype)  this )

private

Definition at line 75 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
 
    this%imon = -1
 

release_data()

subroutine mpimessagebuildermodule::release_data ( class(mpimessagebuildertype)  this )

private

Definition at line 92 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
 
    this%vdc_models => null()
    this%vdc_exchanges => null()
 

set_monitor()

subroutine mpimessagebuildermodule::set_monitor ( class(mpimessagebuildertype)  this, integer(i4b)  imon  )

private

Definition at line 100 of file MpiMessageBuilder.f90.

    class(MpiMessageBuilderType) :: this
    integer(I4B) :: imon
 
    this%imon = imon