Disable deleted head cleanup

2026-06-03 04:02:34 +00:00 · 2024-02-12 17:39:24 +01:00
parent 6806d1f242
commit 682dd1093f
1 changed files with 4 additions and 0 deletions
@@ -177,6 +177,10 @@ func (t *Tracker) killOrphanedeheads(stream *Stream) {
 	defer stream.lock.Unlock()

 	for encoder_id, head := range stream.heads {
+		if head == DeletedHead {
+			continue
+		}
+
 		distance := int32(99999)
 		for _, info := range t.clients {
 			if info.head == -1 {