#ifndef FRAMEWORK_DATAPOOLLOCAL_LOCALPOOLVECTOR_TPP_ #define FRAMEWORK_DATAPOOLLOCAL_LOCALPOOLVECTOR_TPP_ #ifndef FRAMEWORK_DATAPOOLLOCAL_LOCALPOOLVECTOR_H_ #error Include LocalPoolVector.h before LocalPoolVector.tpp! #endif template inline LocalPoolVector::LocalPoolVector(lp_id_t poolId, HasHkPoolParametersIF* hkOwner, pool_rwm_t setReadWriteMode, DataSetIF* dataSet) : localPoolId(poolId), valid(false), readWriteMode(setReadWriteMode) { if(poolId == PoolVariableIF::NO_PARAMETER) { sif::warning << "LocalPoolVector: 0 passed as pool ID, which is the " "NO_PARAMETER value!" << std::endl; } memset(this->value, 0, vectorSize * sizeof(T)); if (dataSet != nullptr) { dataSet->registerVariable(this); } } template inline LocalPoolVector::LocalPoolVector(lp_id_t poolId, object_id_t poolOwner, pool_rwm_t setReadWriteMode, DataSetIF *dataSet): readWriteMode(readWriteMode) { if(poolId == PoolVariableIF::NO_PARAMETER) { sif::warning << "LocalPoolVector: 0 passed as pool ID, which is the " "NO_PARAMETER value!" << std::endl; } HasHkPoolParametersIF* hkOwner = objectManager->get(poolOwner); if(hkOwner == nullptr) { sif::error << "LocalPoolVariable: The supplied pool owner did not implement" "the correct interface HasHkPoolParametersIF!" << std::endl; return; } hkManager = hkOwner->getHkManagerHandle(); if(dataSet != nullptr) { dataSet->registerVariable(this); } } template inline ReturnValue_t LocalPoolVector::read(uint32_t lockTimeout) { MutexHelper(hkManager->getMutexHandle(), lockTimeout); return readWithoutLock(); } template inline ReturnValue_t LocalPoolVector::readWithoutLock() { if(readWriteMode == pool_rwm_t::VAR_WRITE) { sif::debug << "LocalPoolVar: Invalid read write " "mode for read() call." << std::endl; return PoolVariableIF::INVALID_READ_WRITE_MODE; } PoolEntry* poolEntry = nullptr; ReturnValue_t result = hkManager->fetchPoolEntry(localPoolId, &poolEntry); memset(this->value, 0, vectorSize * sizeof(T)); if(result != RETURN_OK) { sif::error << "PoolVector: Read of local pool variable of object " "0x" << std::hex << std::setw(8) << std::setfill('0') << hkManager->getOwner() << "and lp ID 0x" << localPoolId << std::dec << " failed." << std::endl; return result; } memcpy(this->value, poolEntry->address, poolEntry->getByteSize()); this->valid = poolEntry->valid; return RETURN_OK; } template inline ReturnValue_t LocalPoolVector::commit( uint32_t lockTimeout) { MutexHelper(hkManager->getMutexHandle(), lockTimeout); return commitWithoutLock(); } template inline ReturnValue_t LocalPoolVector::commitWithoutLock() { if(readWriteMode == pool_rwm_t::VAR_READ) { sif::debug << "LocalPoolVar: Invalid read write " "mode for commit() call." << std::endl; return PoolVariableIF::INVALID_READ_WRITE_MODE; } // Wait maximum of 50 milliseconds. MutexHelper(hkManager->getMutexHandle(), 50); PoolEntry* poolEntry = nullptr; ReturnValue_t result = hkManager->fetchPoolEntry(localPoolId, &poolEntry); if(result != RETURN_OK) { sif::error << "PoolVector: Read of local pool variable of object " "0x" << std::hex << std::setw(8) << std::setfill('0') << hkManager->getOwner() << " and lp ID 0x" << localPoolId << std::dec << " failed.\n" << std::flush; return result; } memcpy(poolEntry->address, this->value, poolEntry->getByteSize()); poolEntry->valid = this->valid; return RETURN_OK; } template inline T& LocalPoolVector::operator [](int i) { if(i <= vectorSize) { return value[i]; } sif::warning << "LocalPoolVector: Invalid index" << std::endl; return 0; } template inline const T& LocalPoolVector::operator [](int i) const { if(i <= vectorSize) { return value[i]; } sif::warning << "LocalPoolVector: Invalid index" << std::endl; return 0; } template inline ReturnValue_t LocalPoolVector::serialize(uint8_t** buffer, size_t* size, const size_t max_size, bool bigEndian) const { ReturnValue_t result = HasReturnvaluesIF::RETURN_FAILED; for (uint16_t i = 0; i < vectorSize; i++) { result = SerializeAdapter::serialize(&(value[i]), buffer, size, max_size, bigEndian); if (result != HasReturnvaluesIF::RETURN_OK) { break; } } return result; } template inline size_t LocalPoolVector::getSerializedSize() const { return vectorSize * SerializeAdapter::getSerializedSize(value); } template inline ReturnValue_t LocalPoolVector::deSerialize( const uint8_t** buffer, size_t* size, bool bigEndian) { ReturnValue_t result = HasReturnvaluesIF::RETURN_FAILED; for (uint16_t i = 0; i < vectorSize; i++) { result = SerializeAdapter::deSerialize(&(value[i]), buffer, size, bigEndian); if (result != HasReturnvaluesIF::RETURN_OK) { break; } } return result; } template inline pool_rwm_t LocalPoolVector::getReadWriteMode() const { return this->readWriteMode; } template inline uint32_t LocalPoolVector::getDataPoolId() const { return localPoolId; } template inline void LocalPoolVector::setDataPoolId(uint32_t poolId) { this->localPoolId = poolId; } template inline void LocalPoolVector::setValid(bool valid) { this->valid = valid; } template inline uint8_t LocalPoolVector::getValid() const { return valid; } template inline bool LocalPoolVector::isValid() const { return valid; } #endif