processing.h

Go to the documentation of this file.

 
#ifndef _PROCESSING_H
#define _PROCESSING_H
 
#include "config.h"
 
// analogue input pins
inline constexpr uint8_t sensorV[NO_OF_PHASES]{ 0, 2, 4 }; 
inline constexpr uint8_t sensorI[NO_OF_PHASES]{ 1, 3, 5 }; 
// ------------------------------------------
 
inline uint8_t loadPrioritiesAndState[NO_OF_DUMPLOADS]; 
inline constexpr uint8_t PERSISTENCE_FOR_POLARITY_CHANGE{ 2 }; 
inline constexpr uint16_t initialDelay{ 3000 };  
inline constexpr uint16_t startUpPeriod{ 3000 }; 
// for interaction between the main processor and the ISR
inline volatile uint32_t absenceOfDivertedEnergyCount{ 0 }; 
inline volatile bool b_datalogEventPending{ false };        
inline volatile bool b_newMainsCycle{ false };              
inline volatile bool b_overrideLoadOn[NO_OF_DUMPLOADS];     
inline volatile bool b_reOrderLoads{ false };               
inline volatile bool b_diversionOff{ false };               
// since there's no real locking feature for shared variables, a couple of data
// generated from inside the ISR are copied from time to time to be passed to the
// main processor. When the data are available, the ISR signals it to the main processor.
inline volatile int32_t copyOf_sumP_atSupplyPoint[NO_OF_PHASES];   
inline volatile int32_t copyOf_sum_Vsquared[NO_OF_PHASES];         
inline volatile float copyOf_energyInBucket_main;                  
inline volatile uint8_t copyOf_lowestNoOfSampleSetsPerMainsCycle;  
inline volatile uint16_t copyOf_sampleSetsDuringThisDatalogPeriod; 
inline volatile uint16_t copyOf_countLoadON[NO_OF_DUMPLOADS];      
#ifdef TEMP_ENABLED
inline PayloadTx_struct< NO_OF_PHASES, temperatureSensing.get_size() > tx_data; 
#else
inline PayloadTx_struct< NO_OF_PHASES > tx_data; 
#endif
 
void initializeProcessing();
void initializeOptionalPins();
void updatePhysicalLoadStates();
void updatePortsStates();
void printParamsForSelectedOutputMode();
 
void processCurrentRawSample(uint8_t phase, int16_t rawSample);
void processVoltageRawSample(uint8_t phase, int16_t rawSample);
void processRawSamples(uint8_t phase);
 
void processVoltage(uint8_t phase);
 
#if defined(__DOXYGEN__)
inline void processStartUp(uint8_t phase);
inline void processStartNewCycle();
inline void processPlusHalfCycle(uint8_t phase);
inline void processMinusHalfCycle(uint8_t phase);
inline void processVoltage(uint8_t phase);
inline void processPolarity(uint8_t phase, int16_t rawSample);
inline void confirmPolarity(uint8_t phase);
inline void proceedLowEnergyLevel();
inline void proceedHighEnergyLevel();
inline uint8_t nextLogicalLoadToBeAdded();
inline uint8_t nextLogicalLoadToBeRemoved();
inline void processLatestContribution(uint8_t phase);
#else
inline void processStartUp(uint8_t phase) __attribute__((always_inline));
inline void processStartNewCycle() __attribute__((always_inline));
inline void processPlusHalfCycle(uint8_t phase) __attribute__((always_inline));
inline void processMinusHalfCycle(uint8_t phase) __attribute__((always_inline));
inline void processVoltage(uint8_t phase) __attribute__((always_inline));
inline void processPolarity(uint8_t phase, int16_t rawSample) __attribute__((always_inline));
inline void confirmPolarity(uint8_t phase) __attribute__((always_inline));
inline void proceedLowEnergyLevel() __attribute__((always_inline));
inline void proceedHighEnergyLevel() __attribute__((always_inline));
inline uint8_t nextLogicalLoadToBeAdded() __attribute__((always_inline));
inline uint8_t nextLogicalLoadToBeRemoved() __attribute__((always_inline));
inline void processLatestContribution(uint8_t phase) __attribute__((always_inline));
#endif
 
void processDataLogging();
 
#endif  // _PROCESSING_H