use lock in shredgroup Reset

gordian-engine · Dec 6, 2024 · e2e3e70 · e2e3e70
1 parent 0d28540
commit e2e3e70
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/gturbine/gtshred/shred_group.go b/gturbine/gtshred/shred_group.go
@@ -236,6 +236,9 @@ func (g *ShredGroup) CollectShred(shred *gturbine.Shred) (bool, error) {
 
 // Reset clears the ShredGroup data while maintaining allocated memory
 func (g *ShredGroup) Reset() {
+	g.mu.Lock()
+	defer g.mu.Unlock()
+
 	g.GroupID = uuid.New().String()
 	g.BlockHash = g.BlockHash[:0]
 	g.Height = 0