#include <post_wait_unpack_nested_buffer.h>

Inheritance diagram for TIMPI::PostWaitUnpackNestedBuffer< Container >:

Public Member Functions
	PostWaitUnpackNestedBuffer (const std::vector< char > &buffer, Container &out, const DataType &timpi_mpi_var(T_type), const Communicator &comm_in)

	~PostWaitUnpackNestedBuffer ()

virtual void	run () override

Private Attributes
const std::vector< char > &	recvbuf

Container &	recv

DataType	type

const Communicator &	comm

Detailed Description

template<typename Container>
struct TIMPI::PostWaitUnpackNestedBuffer< Container >

Definition at line 33 of file post_wait_unpack_nested_buffer.h.

Constructor & Destructor Documentation

◆ PostWaitUnpackNestedBuffer()

template<typename Container >

TIMPI::PostWaitUnpackNestedBuffer< Container >::PostWaitUnpackNestedBuffer	(	const std::vector< char > &	buffer,
		Container &	out,
		const DataType &	timpi_mpi_varT_type,
		const Communicator &	comm_in
	)

inline

Definition at line 34 of file post_wait_unpack_nested_buffer.h.

                                                           :
    recvbuf(buffer), recv(out), comm(comm_in) {
      timpi_call_mpi(MPI_Type_dup(T_type, &(type.operator data_type &())));
#ifndef TIMPI_HAVE_MPI
      timpi_not_implemented(); // This makes no sense without MPI_Unpack
#endif
    }

References TIMPI::cast_int(), and TIMPI::PostWaitUnpackNestedBuffer< Container >::type.

◆ ~PostWaitUnpackNestedBuffer()

template<typename Container >

TIMPI::PostWaitUnpackNestedBuffer< Container >::~PostWaitUnpackNestedBuffer ( )

inline

Definition at line 45 of file post_wait_unpack_nested_buffer.h.

                                {
#ifdef TIMPI_HAVE_MPI
    // Not bothering with return type; we can't throw in a destructor
    MPI_Type_free(&(type.operator data_type &()));
#endif
  }

References TIMPI::cast_int(), and TIMPI::PostWaitUnpackNestedBuffer< Container >::type.

Member Function Documentation

◆ run()

template<typename Container >

virtual void TIMPI::PostWaitUnpackNestedBuffer< Container >::run ( )

inlineoverridevirtual

Implements TIMPI::PostWaitWork.

Definition at line 52 of file post_wait_unpack_nested_buffer.h.

                              {
#ifdef TIMPI_HAVE_MPI
 
#if MPI_VERSION > 3
#  define TIMPI_COUNT_TYPE MPI_COUNT
#  define TIMPI_UNPACK MPI_Unpack_c
#else
#  define TIMPI_COUNT_TYPE MPI_INT
#  define TIMPI_UNPACK MPI_Unpack
#endif
 
  // We should at least have one header datum, for outer vector size
  timpi_assert (!recvbuf.empty());
 
  // Unpack the received buffer
  CountType bufsize = cast_int<CountType>(recvbuf.size());
  CountType recvsize, pos=0;
  timpi_call_mpi
    (TIMPI_UNPACK(recvbuf.data(), bufsize, &pos, &recvsize, 1,
                  TIMPI_COUNT_TYPE, comm.get()));
 
  // ... size the outer buffer
  recv.resize (recvsize);
 
  const std::size_t n_vecs = recvsize;
  for (std::size_t i = 0; i != n_vecs; ++i)
    {
      CountType subvec_size;
 
      timpi_call_mpi
        (TIMPI_UNPACK(recvbuf.data(), bufsize, &pos, &subvec_size, 1,
                      TIMPI_COUNT_TYPE, comm.get()));
 
      // ... size the inner buffer
      recv[i].resize (subvec_size);
 
      // ... unpack the inner buffer if it is not empty
      if (!recv[i].empty())
        timpi_call_mpi
          (TIMPI_UNPACK(recvbuf.data(), bufsize, &pos, recv[i].data(),
                        subvec_size, type, comm.get()));
    }
#endif //TIMPI_HAVE_MPI
  }