Fixed uint32_t overflow timing bug

Author: wizard97

src/ProcessScheduler.h

@@ -59,8 +59,9 @@
 
     bool Process::needsServicing(uint32_t start)
     {
-        return (isEnabled() && (_force ||
-            ((getPeriod() == SERVICE_CONSTANTLY || start - getScheduledTS() >= getPeriod()) &&
+        return (isEnabled() &&
+            (_force ||
+            ((getPeriod() == SERVICE_CONSTANTLY || timeToNextRun(start) <= 0) &&
             (getIterations() == RUNTIME_FOREVER || getIterations() > 0))));
     }
 

src/ProcessScheduler/Config.h

@@ -84,7 +84,9 @@ class Process
     *
     * @return: int32_t time offset
     */
-    inline int32_t timeToNextRun() { return (_scheduledTS + _period) - _scheduler.getCurrTS(); }
+    inline int32_t timeToNextRun() { return timeToNextRun(_scheduler.getCurrTS()); }
+
+    inline int32_t timeToNextRun(uint32_t curr) { return (int32_t)((_scheduledTS + _period) - curr); }
 
 
     /*

src/ProcessScheduler/Includes.h

@@ -133,6 +133,7 @@ uint8_t Scheduler::countProcesses(int priority, bool enabledOnly)
     return count;
 }
 
+
 int Scheduler::run()
 {
     // Already running in another call frame
@@ -157,7 +158,7 @@ int Scheduler::run()
         while(tmp) {
             if (tmp->needsServicing(start)) {
                 if (torun) { //Compare which one needs to run more
-                    _active = Process::runWhich(torun, tmp);
+                    torun = Process::runWhich(torun, tmp);
                 } else { //torun is NULL so this is the best one to run
                     torun = tmp;
                 }
@@ -213,7 +214,7 @@ int Scheduler::run()
             disable(*_active);
         }
         _active = NULL; //done!
-        
+
         count++; // incr counter
         processQueue();
         delay(0); // For esp8266