From f4eb64d06bee207539a688d73cbefbec3c91b37d Mon Sep 17 00:00:00 2001 From: Acha Bill Date: Wed, 6 Mar 2024 22:57:45 +0100 Subject: [PATCH] fix: seed --- pkg/check/redundancy/redundancy.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/pkg/check/redundancy/redundancy.go b/pkg/check/redundancy/redundancy.go index 1d651585f..8975f3818 100644 --- a/pkg/check/redundancy/redundancy.go +++ b/pkg/check/redundancy/redundancy.go @@ -71,7 +71,7 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, o interf return fmt.Errorf("get clients: %w", err) } - root, data, chunks, err := c.generateChunks(ctx, opts.DataSize, redundancy.Level(i), opts.Seed) + root, data, chunks, err := c.generateChunks(ctx, opts.DataSize, redundancy.Level(i)) if err != nil { return fmt.Errorf("get chunks: %w", err) } @@ -83,7 +83,7 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, o interf } // happy path - err = c.uploadChunks(ctx, uploadClient, chunks, redundancy.Level(i), opts.Seed, batchID, true) + err = c.uploadChunks(ctx, uploadClient, chunks, redundancy.Level(i), batchID, true) if err != nil { return fmt.Errorf("upload chunks: %w", err) } @@ -99,12 +99,12 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, o interf } // non-happy path - root, data, chunks, err = c.generateChunks(ctx, opts.DataSize, redundancy.Level(i), opts.Seed) + root, data, chunks, err = c.generateChunks(ctx, opts.DataSize, redundancy.Level(i)) if err != nil { return fmt.Errorf("get chunks: %w", err) } c.logger.Infof("root hash: %s, chunks: %d", root.String(), len(chunks)) - err = c.uploadChunks(ctx, uploadClient, chunks, redundancy.Level(i), opts.Seed, batchID, false) + err = c.uploadChunks(ctx, uploadClient, chunks, redundancy.Level(i), batchID, false) if err != nil { return fmt.Errorf("upload chunks: %w", err) } @@ -119,13 +119,13 @@ func (c *Check) Run(ctx context.Context, cluster orchestration.Cluster, o interf return nil } -func (c *Check) generateChunks(ctx context.Context, size int64, rLevel redundancy.Level, seed int64) (swarm.Address, []byte, []swarm.Chunk, error) { +func (c *Check) generateChunks(ctx context.Context, size int64, rLevel redundancy.Level) (swarm.Address, []byte, []swarm.Chunk, error) { putter := &splitPutter{ chunks: make([]swarm.Chunk, 0), } buf := make([]byte, size) - rnd := random.PseudoGenerator(seed) + rnd := random.PseudoGenerator(time.Now().UnixNano()) _, err := rnd.Read(buf) if err != nil { return swarm.ZeroAddress, nil, nil, err @@ -140,7 +140,7 @@ func (c *Check) generateChunks(ctx context.Context, size int64, rLevel redundanc return rootAddr, buf, putter.chunks, nil } -func (c *Check) uploadChunks(ctx context.Context, client *bee.Client, chunks []swarm.Chunk, rLevel redundancy.Level, seed int64, batchID string, shouldDownload bool) error { +func (c *Check) uploadChunks(ctx context.Context, client *bee.Client, chunks []swarm.Chunk, rLevel redundancy.Level, batchID string, shouldDownload bool) error { rate := 0.0 if shouldDownload { switch rLevel { @@ -166,7 +166,7 @@ func (c *Check) uploadChunks(ctx context.Context, client *bee.Client, chunks []s } } - rnd := random.PseudoGenerator(seed) + rnd := random.PseudoGenerator(time.Now().UnixNano()) indices := rnd.Perm(len(chunks) - 1) offset := int(rate * float64(len(chunks))) indices = append(indices[offset:], len(chunks)-1)