#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.

References TIMPI::PostWaitUnpackNestedBuffer< Container >::type.

                                                            :
     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
     }

◆ ~PostWaitUnpackNestedBuffer()

template<typename Container >

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

inline

Definition at line 45 of file post_wait_unpack_nested_buffer.h.

References TIMPI::PostWaitUnpackNestedBuffer< Container >::type.

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

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.

References TIMPI::PostWaitUnpackNestedBuffer< Container >::comm, TIMPI::Communicator::get(), TIMPI::PostWaitUnpackNestedBuffer< Container >::recv, TIMPI::PostWaitUnpackNestedBuffer< Container >::recvbuf, and TIMPI::PostWaitUnpackNestedBuffer< Container >::type.

                               {
 #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
   }