close channels

Author: jurkovic-nikola

src/devices/cc/cc.go

@@ -462,6 +462,9 @@ func (d *Device) Stop() {
 					close(d.speedRefreshChan)
 				}
 			}
+			if d.queue != nil {
+				close(d.queue)
+			}
 		})
 	}()
 
@@ -522,6 +525,9 @@ func (d *Device) StopDirty() uint8 {
 					close(d.speedRefreshChan)
 				}
 			}
+			if d.queue != nil {
+				close(d.queue)
+			}
 		})
 	}()
 

src/devices/ccxt/ccxt.go

@@ -316,6 +316,9 @@ func (d *Device) Stop() {
 			if d.autoRefreshChan != nil {
 				close(d.autoRefreshChan)
 			}
+			if d.queue != nil {
+				close(d.queue)
+			}
 		})
 	}()
 
@@ -350,6 +353,9 @@ func (d *Device) StopDirty() uint8 {
 			if d.autoRefreshChan != nil {
 				close(d.autoRefreshChan)
 			}
+			if d.queue != nil {
+				close(d.queue)
+			}
 		})
 	}()
 	logger.Log(logger.Fields{"serial": d.Serial, "product": d.Product}).Info("Device stopped")

src/devices/memory/memory.go

@@ -263,6 +263,9 @@ func (d *Device) Stop() {
 			if d.autoRefreshChan != nil {
 				close(d.autoRefreshChan)
 			}
+			if d.queue != nil {
+				close(d.queue)
+			}
 		})
 	}()