primer

Author: skipperoo

tracky/src-redis-primer/firmware.go

@@ -87,8 +87,6 @@ func alteredFoodData(position trackeroo.DrivePosition) FoodSensors {
 	}
 }
 
-var taskManager *trackeroo.TaskManager
-
 func Init() {
 	debugLevel := os.Getenv("DEBUG_LEVEL")
 	level := trackeroo.INFO
@@ -106,13 +104,9 @@ func Init() {
 		level = trackeroo.INFO
 	}
 	trackeroo.InitLogger(level, "")
-	trackeroo.InitQueue("data")
-	taskManager = trackeroo.NewTaskManager()
-	go taskManager.Start()
 }
 
 func Terminate() {
-	taskManager.Shutdown(0)
 }
 
 func Loop() {

tracky/src-redis-primer/tracky.go

@@ -2,50 +2,11 @@ package main
 
 import (
 	"fmt"
-	"os"
-	"os/signal"
-	"runtime/debug"
-	"syscall"
 	"tracky/trackeroo"
 )
 
 func main() {
 	fmt.Println(trackeroo.ART)
-	sigs := make(chan os.Signal, 1)
-	signal.Notify(sigs, os.Interrupt, syscall.SIGTERM)
-
-	round := 1
-	for {
-		done := make(chan struct{})
-
-		go func(r int) {
-			runLoop(r)
-			close(done)
-		}(round)
-
-		select {
-		case <-sigs:
-			Terminate()
-			fmt.Println("Terminated task manager, waiting...")
-			trackeroo.Millisleep(2000)
-			os.Exit(0)
-		case <-done:
-			round++
-		}
-	}
-}
-
-func runLoop(round int) {
-	defer func() {
-		if r := recover(); r != nil {
-			fmt.Printf("Recovered from panic in round %d: %v\n", round, r)
-			fmt.Printf("Stack trace:\n%s\n", string(debug.Stack()))
-
-			Terminate()
-			fmt.Println("Terminated task manager, waiting...")
-			trackeroo.Millisleep(2000)
-		}
-	}()
 	Init()
 	Loop()
 }