From 9ba39d7fad14e7f25258cdafab2403638d3b0868 Mon Sep 17 00:00:00 2001 From: Sveinn Date: Wed, 19 Jun 2024 01:59:39 -0700 Subject: [PATCH] Removing a channel that was not being used (#19948) --- cmd/erasure-sets.go | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/cmd/erasure-sets.go b/cmd/erasure-sets.go index 021e29c28..bb2b7cedc 100644 --- a/cmd/erasure-sets.go +++ b/cmd/erasure-sets.go @@ -36,7 +36,6 @@ import ( "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio-go/v7/pkg/tags" "github.com/minio/minio/internal/dsync" - xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/console" "github.com/minio/pkg/v3/sync/errgroup" @@ -80,10 +79,6 @@ type erasureSets struct { poolIndex int - // A channel to send the set index to the MRF when - // any disk belonging to that set is connected - setReconnectEvent chan int - // Distribution algorithm of choice. distributionAlgo string deploymentID [16]byte @@ -380,7 +375,6 @@ func newErasureSets(ctx context.Context, endpoints PoolEndpoints, storageDisks [ setDriveCount: setDriveCount, defaultParityCount: defaultParityCount, format: format, - setReconnectEvent: make(chan int), distributionAlgo: format.Erasure.DistributionAlgo, deploymentID: uuid.MustParse(format.ID), poolIndex: poolIdx, @@ -662,14 +656,6 @@ func (s *erasureSets) Shutdown(ctx context.Context) error { return err } } - select { - case _, ok := <-s.setReconnectEvent: - if ok { - xioutil.SafeClose(s.setReconnectEvent) - } - default: - xioutil.SafeClose(s.setReconnectEvent) - } return nil }