#include <MPIOutputBuffer.h>
Definition at line 21 of file MPIOutputBuffer.h.
MPIOutputBuffer::MPIOutputBuffer | ( | vector< gl_engineid_t > & | engIDs | ) |
MPIOutputBuffer::~MPIOutputBuffer | ( | ) | [virtual] |
Definition at line 16 of file MPIOutputBuffer.cpp.
References initialized, mixedMPIDataType, slicer, and MPIBufferSlicer::thereIsMixedDataType.
double* MPIOutputBuffer::getAnalogBuffer | ( | ) | [inline] |
Definition at line 28 of file MPIOutputBuffer.h.
References analog_buf.
Referenced by DistributedOutgoingAnalogMsgDispatcher::initialize().
unsigned& MPIOutputBuffer::getAnalogMsgCounter | ( | engineid_t | eng = 0 |
) | [inline] |
Definition at line 33 of file MPIOutputBuffer.h.
References analogMsgCounters.
Referenced by DistributedOutgoingAnalogMsgDispatcher::addOutgoingAnalogMessage(), and DistributedOutgoingAnalogMsgDispatcher::initialize().
void MPIOutputBuffer::calculateTotalAnalogMsgCounter | ( | ) | [inline] |
Definition at line 38 of file MPIOutputBuffer.h.
References analogMsgCounters, and totalAnalogMsgCounter.
void MPIOutputBuffer::startNewMPIExchange | ( | ) |
Definition at line 23 of file MPIOutputBuffer.cpp.
References MPIBufferSlicer::reset(), and slicer.
bool MPIOutputBuffer::hasNextBufferSlice | ( | ) |
Definition at line 77 of file MPIOutputBuffer.cpp.
References MPIBufferSlicer::currentSliceType, MPIOutputSpikeBuffer< T >::hasNextSerializedMPIBuffer(), mpiOutputSpikeBuffer, MPIBufferSlicer::sliceAnalog, slicer, MPIBufferSlicer::sliceUndefined, and totalAnalogMsgCounter.
Referenced by prepareNextBufferSlice().
MPIMessageSpec & MPIOutputBuffer::prepareNextBufferSlice | ( | ) |
Definition at line 90 of file MPIOutputBuffer.cpp.
References MPIBufferSlicer::allowedSpikeSliceSize, 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, MPIMessageSpec::hasContent, hasNextBufferSlice(), mixed_data_types, mixedCounts, mixedDisplacements, mixedMPIDataType, mpiOutputSpikeBuffer, MPIOutputSpikeBuffer< T >::prepareNextSerializedMPIBuffer(), MPIBufferSlicer::sliceAnalog, MPIBufferSlicer::sliceMixed, slicer, MPIBufferSlicer::sliceSpiking, MPIBufferSlicer::sliceUndefined, spike_buf, and spikingMPIDatatype.
void * MPIOutputBuffer::getBuffer | ( | ) |
void MPIOutputBuffer::setFinishedFlag | ( | bool | finished | ) |
Definition at line 140 of file MPIOutputBuffer.cpp.
References mpiOutputSpikeBuffer, and MPIOutputSpikeBuffer< T >::setFinishedFlag().
void MPIOutputBuffer::nextCycle | ( | ) |
Definition at line 145 of file MPIOutputBuffer.cpp.
References mpiOutputSpikeBuffer, and MPIOutputSpikeBuffer< T >::nextCycle().
MPIOutputSpikeBuffer& MPIOutputBuffer::spikeBuf | ( | ) | [inline] |
MPIOutputSpikeBuffer & MPIOutputBuffer::mpiOutputSpikingBuffer | ( | ) |
MPIMessageSpec & MPIOutputBuffer::getCurrentMPIMsgSpecHolder | ( | ) |
void MPIOutputBuffer::getMPIExchangeBlocksInfo | ( | ) |
void MPIOutputBuffer::initialize | ( | MPIMessageSpec | msgSpec, | |
size_t | spikeBufferSize, | |||
size_t | maxMPIMsgSize, | |||
void * | baseBufferPtr, | |||
void * | analogBuffer, | |||
void * | spikeBuffer | |||
) | [protected] |
Definition at line 28 of file MPIOutputBuffer.cpp.
References analog_buf, analogMPIDatatype, currentMsgInfo, MPIOutputSpikeBuffer< T >::initialize(), MPIBufferSlicer::initialize(), initialized, mixed_data_types, mixedCounts, mixedDisplacements, mixedMPIDataType, mpiOutputSpikeBuffer, slicer, spike_buf, spike_buffer_size_elements, spikingMPIDatatype, and MPIBufferSlicer::thereIsMixedDataType.
friend class MPIOutputBufferVector [friend] |
Definition at line 118 of file MPIOutputBuffer.h.
bool MPIOutputBuffer::initialized [protected] |
Definition at line 81 of file MPIOutputBuffer.h.
Referenced by initialize(), and ~MPIOutputBuffer().
void* MPIOutputBuffer::analog_buf [protected] |
Definition at line 83 of file MPIOutputBuffer.h.
Referenced by getAnalogBuffer(), getBuffer(), initialize(), and prepareNextBufferSlice().
void* MPIOutputBuffer::spike_buf [protected] |
Definition at line 85 of file MPIOutputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
void* MPIOutputBuffer::baseBufferPtr [protected] |
MPI::Datatype MPIOutputBuffer::mixedMPIDataType [protected] |
Definition at line 89 of file MPIOutputBuffer.h.
Referenced by initialize(), prepareNextBufferSlice(), and ~MPIOutputBuffer().
MPI::Datatype MPIOutputBuffer::spikingMPIDatatype [protected] |
Definition at line 91 of file MPIOutputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
MPI::Datatype MPIOutputBuffer::analogMPIDatatype [protected] |
Definition at line 93 of file MPIOutputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
MPIMessageSpec MPIOutputBuffer::currentMsgInfo [protected] |
Definition at line 95 of file MPIOutputBuffer.h.
Referenced by getCurrentMPIMsgSpecHolder(), initialize(), and prepareNextBufferSlice().
MPI::Datatype MPIOutputBuffer::mixed_data_types[2] [protected] |
Definition at line 97 of file MPIOutputBuffer.h.
Referenced by initialize(), and prepareNextBufferSlice().
int MPIOutputBuffer::mixedCounts[2] [protected] |
Definition at line 103 of file MPIOutputBuffer.h.
Referenced by getMixedCounts(), initialize(), and prepareNextBufferSlice().
MPI::Aint MPIOutputBuffer::mixedDisplacements[2] [protected] |
Definition at line 106 of file MPIOutputBuffer.h.
Referenced by getMixedDispl(), initialize(), and prepareNextBufferSlice().
size_t MPIOutputBuffer::spike_buffer_size_elements [protected] |
vector<unsigned> MPIOutputBuffer::analogMsgCounters [protected] |
Definition at line 110 of file MPIOutputBuffer.h.
Referenced by calculateTotalAnalogMsgCounter(), getAnalogMsgCounter(), and MPIOutputBuffer().
unsigned MPIOutputBuffer::totalAnalogMsgCounter [protected] |
Definition at line 112 of file MPIOutputBuffer.h.
Referenced by calculateTotalAnalogMsgCounter(), and hasNextBufferSlice().
Definition at line 114 of file MPIOutputBuffer.h.
Referenced by hasNextBufferSlice(), initialize(), mpiOutputSpikingBuffer(), nextCycle(), prepareNextBufferSlice(), setFinishedFlag(), and spikeBuf().
MPIBufferSlicer MPIOutputBuffer::slicer [protected] |
Definition at line 116 of file MPIOutputBuffer.h.
Referenced by hasNextBufferSlice(), initialize(), prepareNextBufferSlice(), startNewMPIExchange(), and ~MPIOutputBuffer().