MPIBufferSlicer.h

Go to the documentation of this file.

#ifndef MPIBUFFERSLICER_H_
#define MPIBUFFERSLICER_H_

#include <cstddef>
#include <mpi.h>

#include <iostream>

using std::cerr;
using std::endl;


#include "globaldefinitions.h"

#define MIN_MPI_SPIKE_BUFFER_SIZE 20

class MPIBufferSlicer
{
public:

    typedef enum { tpOutputBuffer , tpInputBuffer } MPIBufferType;

    MPIBufferSlicer(MPIBufferType bufferType);

    void initialize(size_t analogBufferSize,
                    size_t maxMPIMsgSize = 0,
                    size_t spikeBufferSize = MPIBUFFER_BLOCK_SIZE);

    virtual ~MPIBufferSlicer()
    {}
    ;

    void reset();

    typedef enum { sliceAnalog, sliceMixed, sliceSpiking, sliceUndefined } SliceType;

    void calcNextBufferSliceDimensions();

    //**************************************************

    // Start position of the current slice of the buffer transferred.
    size_t currentSlicePos;

    // Calculated size of the analog portion of the current slice.

    int currentAnalogSliceSize;


    size_t allowedSpikeSliceSize;

    SliceType currentSliceType;

    bool thereIsMixedDataType;


protected:
    MPIBufferType buffer_type;

    void *analog_buf;

    void *spike_buf;

    size_t spike_buffer_size_elements ;  // number of elements (longs or shorts, depends on the setup)

    size_t spike_buffer_size_bytes;   // bytes in the allocated spike buffer

    size_t analog_buffer_size_elements;  // this is in number of doubles

    size_t analog_buffer_size_bytes; // number of bytes analog buffer contains

    size_t max_mpi_msg_size;

};

#endif /*MPIBUFFERSLICER_H_*/

---