mirror of
https://github.com/pgsty/minio.git
synced 2026-09-25 20:35:58 +03:00
style: format replication regression fixture
Signed-off-by: Feng Ruohang <rh@vonng.com>
This commit is contained in:
@@ -176,8 +176,13 @@ func testReplicateDeleteMarkerPurge(obj ObjectLayer, instanceType, bucket string
|
|||||||
meta.replicationConfig = &cfg
|
meta.replicationConfig = &cfg
|
||||||
globalBucketMetadataSys.Set(bucket, meta)
|
globalBucketMetadataSys.Set(bucket, meta)
|
||||||
worker := make(chan ReplicationWorkerOperation, 1)
|
worker := make(chan ReplicationWorkerOperation, 1)
|
||||||
p := &ReplicationPool{ctx: ctx, objLayer: obj, workers: []chan ReplicationWorkerOperation{worker},
|
p := &ReplicationPool{
|
||||||
stats: globalReplicationStats.Load(), mrfSaveCh: make(chan MRFReplicateEntry, 1)}
|
ctx: ctx,
|
||||||
|
objLayer: obj,
|
||||||
|
workers: []chan ReplicationWorkerOperation{worker},
|
||||||
|
stats: globalReplicationStats.Load(),
|
||||||
|
mrfSaveCh: make(chan MRFReplicateEntry, 1),
|
||||||
|
}
|
||||||
oldPool := globalReplicationPool
|
oldPool := globalReplicationPool
|
||||||
globalReplicationPool = once.NewSingleton[ReplicationPool]()
|
globalReplicationPool = once.NewSingleton[ReplicationPool]()
|
||||||
globalReplicationPool.Set(p)
|
globalReplicationPool.Set(p)
|
||||||
|
|||||||
Reference in New Issue
Block a user