Changeset 68 for webserver/example/EnergyMeters/Source

Timestamp:

09/12/10 19:33:03 (14 years ago)

Author:

phil

Message:

query time once per minute now works.
more detailled output on FSM stuck error.
FSM needs redesign, search for "duplicate".

Files:

• webserver/example/EnergyMeters/Source/EnergyMeters/SolarCountUART.c (modified) (16 diffs)

webserver/example/EnergyMeters/Source/EnergyMeters/SolarCountUART.c

@@ -23 +23 @@
-#define SOLAR_FSM_STUCK_TIMEOUT  2000
-
+/* how often (in ms) do we query the timer? */
+#define SOLAR_TIME_CHECK_INTERVAL (60 * 1000)
+
+
-/* means "unknown value", converted to "U" on rrdtool script side */
-#define SOLAR_FSM_INVALID_VALUE  0x4000 /* 16384 */
@@ -34 +38 @@
-unsigned long correctVoltWattRx = 0; /* counter of correctly received wattage/voltage packets */
-unsigned long failedVoltWattRx = 0;  /* counter of incorrectly received wattage/voltage packets */
-
+
-
-static unsigned short staticCRC;
@@ -81 +85 @@
-unsigned char currentChannel; /* the SolarCount channel we currently query (here: 0 to 3) */
-
-NO_INIT
+QUERY_TIME
-
-
@@ -140 +144 @@
-portTickType xLastSolarStateChangeTime;
-
+portTickType xLastTimeCheckTime;
+
+
- /* time when the elements of the history array were last moved on one step */
-portTickType xLastSolarHistoryAdvance;
@@ -148 +155 @@
-
-int solarReadCounter = 0;
+
+
+int solarStateWhenFail = 0xFF;
+int currentChannelWhenFail = 0xFF;
-
-/* pototype  section */
@@ -181 +192 @@
-  int i;
-  xLastSolarStateChangeTime = xTaskGetTickCount();
+  xLastTimeCheckTime = xTaskGetTickCount();
-  xLastReadTime = xTaskGetTickCount();
-NO_INIT
+QUERY_TIME
-  uart3TxRunning = 0; /* reset flag to tell if we are currently sending a datagram */
-  rxBuf3NextFreeRxPos = 0;
@@ -374 +386 @@
-
-  /* did the SolarFSM get stuck during reading? */
-xLastSolarStateChangeTime + SOLAR_FSM_STUCK_TIMEOUT
-
-NO_INIT
+(xLastSolarStateChangeTime + SOLAR_FSM_STUCK_TIMEOUT)
+
+QUERY_TIME
-    xLastSolarStateChangeTime = xTaskGetTickCount();
+
+    /* save error info */
+    solarStateWhenFail = solarState;
+    currentChannelWhenFail = currentChannel;
+    
-    initSolarFSM();
-    solarReadErrors++;
+
-  }
-  else if (xTaskGetTickCount() < xLastSolarStateChangeTime)
@@ -429 +447 @@
-      /* now ready to query channel 0 data in next state */
-      xLastSolarStateChangeTime = xTaskGetTickCount();
-QUERY_TIME
+CHAN
-    }
-    else
@@ -441 +459 @@
-
-      resetUart3RxBuf(); /* init */
-      currentChannel = 0; /* the channel we query first */
-
-       /* send query_sc_time */
-      send_uart3((unsigned char *)query_sc_time, sizeof(query_sc_time));
-      xLastSolarStateChangeTime = xTaskGetTickCount();
+      queryTimeCounter++;
-      solarState = SOL_WAIT_FOR_TIME_RSP; /* query sent wait for response */
-    break;
@@ -456 +474 @@
-      if (cmpResult == 0)
-      {
-
+  
-        
-          if (checkRxTwoByteCheckSum(1, 10, 11) == 1) /* checksum in bytes 11 and 12, check bytes 1 to 10 */
@@ -472 +490 @@
-          else
-          {
-
+/* time rx checksum error */ 
-          }
-
@@ -478 +496 @@
-        resetUart3RxBuf();
-
-
-CHAN; /* change state: time response received, now
+
+NO_INIT; /* change state: time response received, now init and
-      }
-      else
@@ -517 +535 @@
-        xLastSolarStateChangeTime = xTaskGetTickCount();
-        solarState = SOL_FINISHED;
+        currentChannel = 0;
+
+        /* new duplicated code: */
+
+        resetUart3RxBuf();
+
+
+        if (xTaskGetTickCount() > (xLastTimeCheckTime + SOLAR_TIME_CHECK_INTERVAL))
+        {
+           /* time to get the time info again! */
+           xLastTimeCheckTime = xTaskGetTickCount();
+           solarState = SOL_QUERY_TIME; /* restart the measurement cycle (with time check at first) */
+        }
+        else if (xTaskGetTickCount() < xLastTimeCheckTime)
+        {
+          /* overflow of timer, just recover. delay will be wrong. */
+          xLastTimeCheckTime = xTaskGetTickCount();
+          solarState = SOL_NO_INIT; /* restart the measurement cycle (without time check at first) */
+        }
+        else
+        {
+          /* not time to get the time info. leave state at SOL_FINISHED. */
+        }
+
+
+
-        break;
-      default:
-
+
+
+
-     } /* switch */
-solarState != SOL_FINISHED
+(solarState != SOL_FINISHED) && (solarState != SOL_QUERY_TIME)
-     {
-
+ 
-      solarState = SOL_CHAN_WAIT_REPLY; /* wait for reply if not finished */
-     } /* if */
@@ -552 +598 @@
-         case 6:
-          /* wait for the response to the finishing init */
-
+// 
-          break;
-        default:
@@ -601 +647 @@
-          /* switch to next channel */
-          currentChannel++;
+
+          /* finally, discard data from buffer */
+          resetUart3RxBuf();
+
-          /* now ready to query channel data for next channel */
-          xLastSolarStateChangeTime = xTaskGetTickCount();
@@ -607 +657 @@
-        else
-        {
+
+          /* I think we never go here ... */
+
-          /* we received the finishing sequence */
-          xLastSolarStateChangeTime = xTaskGetTickCount();
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-      }