Fix send on closed channel panic (#5613)

Signed-off-by: Changxin Miao <miaochangxin@step.ai>
juicedata · Jan 26, 2025 · 19fde77 · 19fde77
1 parent 487c5a0
commit 19fde77
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/meta/base.go b/pkg/meta/base.go
@@ -2407,7 +2407,11 @@ func (m *baseMeta) deleteSlice(id uint64, size uint32) {
 		return
 	}
 	if m.dslices != nil {
-		m.dslices <- Slice{Id: id, Size: size}
+		select {
+		case <-m.sessCtx.Done():
+			return
+		case m.dslices <- Slice{Id: id, Size: size}:
+		}
 	} else {
 		m.deleteSlice_(id, size)
 	}