Skip to content

Commit db3d397

Browse files
Fix health report logic in listener (#46)
* Fix listener health report and ticker cleanup * Update listener.go
1 parent 5169fbe commit db3d397

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

chains/heads/listener.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ func (l *listener[HTH, S, ID, BLOCK_HASH]) HealthReport() map[string]error {
138138
err = errors.New("Listener is not receiving heads")
139139
}
140140
if !l.Connected() {
141-
err = errors.New("Listener is not connected")
141+
err = errors.Join(err, errors.New("Listener is not connected"))
142142
}
143143
return map[string]error{l.Name(): err}
144144
}
@@ -150,6 +150,7 @@ func (l *listener[HTH, S, ID, BLOCK_HASH]) receiveHeaders(ctx context.Context, h
150150
if noHeadsAlarmDuration > 0 {
151151
noHeadsAlarmT = time.NewTicker(noHeadsAlarmDuration)
152152
noHeadsAlarmC = noHeadsAlarmT.C
153+
defer noHeadsAlarmT.Stop()
153154
}
154155

155156
for {

0 commit comments

Comments
 (0)