Fix leptond errors with bad pixel

_release/postinstall.sh

@@ -4,5 +4,7 @@ systemctl daemon-reload
 
 systemctl enable thermal-recorder.service
 systemctl enable leptond.service
-systemctl restart leptond.service
+systemctl stop leptond.service
 systemctl restart thermal-recorder.service
+sleep 1
+systemctl start leptond.service

cmd/leptond/main.go

@@ -151,7 +151,7 @@ func runMain() error {
 	}
 
 	for {
-		err = runCamera(conf, camera, conn)
+		err = runCamera(conf, camera, conn, service)
 		if err != nil {
 			if _, isNextFrameErr := err.(*nextFrameErr); !isNextFrameErr {
 				return err
@@ -233,7 +233,7 @@ func sendCameraSpecs(conf *Config, camera *lepton3.Lepton3, conn *net.UnixConn)
 	return nil
 }
 
-func runCamera(conf *Config, camera *lepton3.Lepton3, conn *net.UnixConn) error {
+func runCamera(conf *Config, camera *lepton3.Lepton3, conn *net.UnixConn, service *leptondService) error {
 	conn.SetWriteBuffer(camera.ResX() * camera.ResY() * 2 * 20)
 	log.Print("reading frames")
 	frame := lepton3.NewRawFrame()
@@ -248,6 +248,12 @@ func runCamera(conf *Config, camera *lepton3.Lepton3, conn *net.UnixConn) error
 			notifyCount = 0
 		}
 
+		if service.actions.reset {
+			service.actions.reset = false
+			log.Println("reset triggered through service")
+			return nil
+		}
+
 		if _, err := conn.Write(frame[:]); err != nil {
 			return err
 		}

cmd/leptond/service.go

@@ -33,8 +33,13 @@ const (
 
 var mu sync.Mutex
 
+type actions struct {
+	reset bool
+}
+
 type leptondService struct {
-	camera *lepton3.Lepton3
+	camera  *lepton3.Lepton3
+	actions *actions
 }
 
 func startService() (*leptondService, error) {
@@ -49,7 +54,7 @@ func startService() (*leptondService, error) {
 	if reply != dbus.RequestNameReplyPrimaryOwner {
 		return nil, errors.New("name already taken")
 	}
-	s := &leptondService{}
+	s := &leptondService{actions: &actions{reset: false}}
 	conn.Export(s, dbusPath, dbusName)
 	conn.Export(genIntrospectable(s), dbusPath, "org.freedesktop.DBus.Introspectable")
 	return s, nil
@@ -101,6 +106,13 @@ func (s leptondService) SetAutoFFC(automatic bool) *dbus.Error {
 	return nil
 }
 
+func (s leptondService) RestartCamera() *dbus.Error {
+	mu.Lock()
+	defer mu.Unlock()
+	s.actions.reset = true
+	return nil
+}
+
 func makeDbusError(name string, err error) *dbus.Error {
 	return &dbus.Error{
 		Name: dbusName + "." + name,

cmd/thermal-recorder/main.go

@@ -222,8 +222,8 @@ func handleConn(conn net.Conn, conf *Config) error {
 				Details:   map[string]interface{}{"description": map[string]interface{}{"details": err.Error()}},
 			}
 			eventclient.AddEvent(event)
-			// this will cause camera power to be cycled
-			return err
+			log.Println("bad frame deteccted, requesting camera to restart")
+			leptondController.RestartCamera()
 		}
 	}
 }

leptondController/leptondController.go

@@ -32,3 +32,11 @@ func RunFFC() error {
 	}
 	return obj.Call(methodBase+".RunFFC", 0).Store()
 }
+
+func RestartCamera() error {
+	obj, err := getDbusObj()
+	if err != nil {
+		return err
+	}
+	return obj.Call(methodBase+".RestartCamera", 0).Store()
+}