#include <MPIInputBuffer.h>
Definition at line 26 of file MPIInputBuffer.h.
MPIInputBuffer::MPIInputBuffer | ( | int | nEngines = 1 |
) |
MPIInputBuffer::~MPIInputBuffer | ( | ) | [virtual] |
Definition at line 22 of file MPIInputBuffer.cpp.
References initialized, mixedMPIDataType, slicer, and MPIBufferSlicer::thereIsMixedDataType.
double* MPIInputBuffer::getAnalogBuffer | ( | ) | [inline] |
Definition at line 32 of file MPIInputBuffer.h.
References analog_buf.
Referenced by DistributedIncomingAnalogMsgDispatcher::initialize().
unsigned& MPIInputBuffer::getAnalogMsgCounter | ( | engineid_t | eng = 0 |
) | [inline] |
Definition at line 37 of file MPIInputBuffer.h.
References analogMsgCounters.
Referenced by DistributedIncomingAnalogMsgDispatcher::addDelayerCycledIncomingAnalogMessage(), and DistributedIncomingAnalogMsgDispatcher::initialize().
void MPIInputBuffer::calculateTotalAnalogMsgCounter | ( | ) | [inline] |
Definition at line 42 of file MPIInputBuffer.h.
References analogMsgCounters, and totalAnalogMsgCounter.
void MPIInputBuffer::startNewMPIExchange | ( | ) |
Definition at line 78 of file MPIInputBuffer.cpp.
References MPIBufferSlicer::reset(), and slicer.
bool MPIInputBuffer::hasNextBufferSlice | ( | ) |
Definition at line 83 of file MPIInputBuffer.cpp.
References MPIBufferSlicer::currentSliceType, MPIInputSpikeBuffer< T >::isLastReceivedBuffer(), mpiInputSpikeBuffer, MPIBufferSlicer::sliceAnalog, slicer, MPIBufferSlicer::sliceUndefined, and totalAnalogMsgCounter.
MPIMessageSpec & MPIInputBuffer::prepareNextBufferSlice | ( | ) |
Definition at line 95 of file MPIInputBuffer.cpp.
References analog_buf, analogMPIDatatype, baseBufferPtr, MPIMessageSpec::buffer, MPIBufferSlicer::calcNextBufferSliceDimensions(), MPIMessageSpec::content_type, MPIMessageSpec::contentAnalog, MPIMessageSpec::contentMixed, MPIMessageSpec::contentSpiking, MPIMessageSpec::count, MPIBufferSlicer::currentAnalogSliceSize, currentMsgInfo, MPIBufferSlicer::currentSlicePos, MPIBufferSlicer::currentSliceType, MPIMessageSpec::datatype, MPIMessageSpec::displacement, mixedMPIDataType, mixedMsgAbsoluteDisplacement, MPIBufferSlicer::sliceAnalog, MPIBufferSlicer::sliceMixed, slicer, MPIBufferSlicer::sliceSpiking, MPIBufferSlicer::sliceUndefined, spike_buf, spike_buffer_size_elements, and spikingMPIDatatype.
void MPIInputBuffer::setHasNewContent | ( | bool | contentIndicator | ) | [inline] |
Definition at line 54 of file MPIInputBuffer.h.
References mpiInputSpikeBuffer, and MPIInputSpikeBuffer< T >::setHasNewContent().
MPIInputSpikeBuffer& MPIInputBuffer::spikeBuf | ( | ) | [inline] |
MPIMessageSpec::ContentType_t& MPIInputBuffer::getContentType | ( | ) | [inline] |
Definition at line 75 of file MPIInputBuffer.h.
References MPIMessageSpec::content_type, and currentMsgInfo.
void MPIInputBuffer::initialize | ( | MPIMessageSpec | msgSpec, | |
size_t | spikeBufferSize, | |||
size_t | maxMPIMsgSize, | |||
void * | baseBufferPtr, | |||
void * | analogBuffer, | |||
void * | spikeBuffer | |||
) | [protected] |
Definition at line 29 of file MPIInputBuffer.cpp.
References analog_buf, analogMPIDatatype, currentMsgInfo, MPIMessageSpec::hasContent, MPIBufferSlicer::initialize(), MPIInputSpikeBuffer< T >::initialize(), initialized, mixedCounts, mixedDisplacements, mixedMPIDataType, mixedMsgAbsoluteDisplacement, mpiInputSpikeBuffer, slicer, spike_buf, spike_buffer_size_elements, spikingMPIDatatype, and MPIBufferSlicer::thereIsMixedDataType.
friend class MPIInputBufferVector [friend] |
Definition at line 118 of file MPIInputBuffer.h.
bool MPIInputBuffer::initialized [protected] |
Definition at line 81 of file MPIInputBuffer.h.
Referenced by initialize(), MPIInputBuffer(), and ~MPIInputBuffer().
void* MPIInputBuffer::spike_buf [protected] |
Definition at line 83 of file MPIInputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
void* MPIInputBuffer::analog_buf [protected] |
Definition at line 85 of file MPIInputBuffer.h.
Referenced by getAnalogBuffer(), initialize(), and prepareNextBufferSlice().
MPI::Datatype MPIInputBuffer::mixedMPIDataType [protected] |
Definition at line 87 of file MPIInputBuffer.h.
Referenced by initialize(), prepareNextBufferSlice(), and ~MPIInputBuffer().
MPI::Datatype MPIInputBuffer::spikingMPIDatatype [protected] |
Definition at line 89 of file MPIInputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
MPI::Datatype MPIInputBuffer::analogMPIDatatype [protected] |
Definition at line 91 of file MPIInputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
MPIMessageSpec MPIInputBuffer::currentMsgInfo [protected] |
Definition at line 93 of file MPIInputBuffer.h.
Referenced by getContentType(), initialize(), and prepareNextBufferSlice().
void* MPIInputBuffer::baseBufferPtr [protected] |
size_t MPIInputBuffer::spike_buffer_size_elements [protected] |
Definition at line 97 of file MPIInputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
vector<unsigned> MPIInputBuffer::analogMsgCounters [protected] |
Definition at line 99 of file MPIInputBuffer.h.
Referenced by calculateTotalAnalogMsgCounter(), getAnalogMsgCounter(), and MPIInputBuffer().
unsigned MPIInputBuffer::totalAnalogMsgCounter [protected] |
Definition at line 101 of file MPIInputBuffer.h.
Referenced by calculateTotalAnalogMsgCounter(), and hasNextBufferSlice().
int MPIInputBuffer::mixedMsgAbsoluteDisplacement [protected] |
Definition at line 103 of file MPIInputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
Definition at line 108 of file MPIInputBuffer.h.
Referenced by hasNextBufferSlice(), initialize(), setHasNewContent(), and spikeBuf().
MPIBufferSlicer MPIInputBuffer::slicer [protected] |
Definition at line 110 of file MPIInputBuffer.h.
Referenced by hasNextBufferSlice(), initialize(), prepareNextBufferSlice(), startNewMPIExchange(), and ~MPIInputBuffer().
int MPIInputBuffer::mixedCounts[2] [protected] |
MPI::Aint MPIInputBuffer::mixedDisplacements[2] [protected] |