trabus322/hoymilesClient
1
0
Fork 0
Code Issues 4 Pull requests Projects 3 Releases Packages Wiki Activity

Revert "Trying to make less calls to dtu, making it "multithreaded""

Browse source 
This reverts commit ad4ff13be0.
This commit is contained in:
TraYali 2024-03-18 13:44:25 +01:00
parent ad4ff13be0
commit f22aae499d
7 changed files with 33 additions and 38 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/hoymiles/portParameters/portParameters.cpp
View file

@ -6,11 +6,12 @@
PortParameterMicroinverterSerialNumber::PortParameterMicroinverterSerialNumber() : PortParameterInt("microinverterSerialNumber", 0x0001, 6), PortParameter("microinverterSerialNumber", 0x0001, 6) {}
void PortParameterMicroinverterSerialNumber::setValueFromRegisters(uint16_t *readArray, int readArraySize) {
void PortParameterMicroinverterSerialNumber::setValueFromRegisters(uint16_t *readArray, int registerCount) {
uint16_t readValue;
std::string readValueString = "";
for (int i{0}; i < std::ceil(this->registerSize/2) && (this->parameterAddressOffset + i) < readArraySize; i++) {
readValue = readArray[this->parameterAddressOffset + i];
registerCount = std::ceil(registerCount/2);
for (int i{0}; i < registerCount; i++) {
readValue = readArray[i];
std::stringstream readValueStringStream;
readValueStringStream << std::hex << readValue;
readValueString.append(readValueStringStream.str());
@ -20,9 +21,9 @@ void PortParameterMicroinverterSerialNumber::setValueFromRegisters(uint16_t *rea
PortParameterPortNumber::PortParameterPortNumber() : PortParameterInt("portNumber", 0x0007, 1), PortParameter("portNumber", 0x0007, 1) {}
void PortParameterPortNumber::setValueFromRegisters(uint16_t *readArray, int readArraySize) {
if(readArraySize > this->parameterAddressOffset) {
this->value.i = readArray[this->parameterAddressOffset];
void PortParameterPortNumber::setValueFromRegisters(uint16_t *readArray, int registerCount) {
if (registerCount > 0) {
this->value.i = readArray[0];
}
}

20
src/hoymiles/portParameters/portParametersGeneric.cpp
View file

@ -20,7 +20,7 @@ PortParameter::PortParameter(std::string name, uint16_t parameterAddressOffset,
PortParameter::~PortParameter() {}
void PortParameter::setValueFromRegisters(uint16_t *readArray, int readArraySize) {}
void PortParameter::setValueFromRegisters(uint16_t *readArray, int registerCount) {}
std::pair<PortParameter::PortParameterValue, PortParameter::PortParameterValueType> PortParameter::getValue() {
return std::pair<PortParameter::PortParameterValue, PortParameter::PortParameterValueType>(this->value, this->valueType);
@ -28,7 +28,14 @@ std::pair<PortParameter::PortParameterValue, PortParameter::PortParameterValueTy
std::string PortParameter::getOutputValue() {}
void PortParameter::updateValue(uint16_t *readArray, int readArraySize, int registerCount) {
void PortParameter::updateValue(std::shared_ptr<modbus_t*> modbus_context, std::mutex *modbus_context_mutex, uint16_t portStartAddress) {
uint16_t readArray[this->registerSize];
int registerCount;
modbus_context_mutex->lock();
registerCount = modbus_read_registers(*modbus_context.get(), portStartAddress + this->parameterAddressOffset, this->registerSize, readArray);
modbus_context_mutex->unlock();
if(registerCount == -1){
this->age++;
}
@ -46,7 +53,7 @@ PortParameterFloat::PortParameterFloat(std::string name, int decimalPlaces, uint
this->value.f = 0;
}
void PortParameterFloat::setValueFromRegisters(uint16_t *readArray, int readArraySize) {
void PortParameterFloat::setValueFromRegisters(uint16_t *readArray, int registerCount) {
float temp = readArray[0];
temp = temp / std::pow(10, this->decimalPlaces);
this->value.f = temp;
@ -62,11 +69,12 @@ PortParameterInt::PortParameterInt(std::string name, uint16_t parameterAddressOf
this->value.i = 0;
}
void PortParameterInt::setValueFromRegisters(uint16_t *readArray, int readArraySize) {
void PortParameterInt::setValueFromRegisters(uint16_t *readArray, int registerCount) {
uint16_t readValue;
std::string readValueString = "";
for (int i{0}; i < std::ceil(this->registerSize/2) && (this->parameterAddressOffset + i) < readArraySize; i++) {
readValue = readArray[this->parameterAddressOffset + i];
registerCount = std::ceil(registerCount/2);
for (int i{0}; i < registerCount; i++) {
readValue = readArray[i];
readValueString.append(std::to_string(readValue));
}
this->value.i = std::stol(readValueString);