From 622a4ec1a1ace79508b3966d1f988fe807b1c8fc Mon Sep 17 00:00:00 2001 From: Acha Bill Date: Mon, 3 Mar 2025 07:22:43 -0500 Subject: [PATCH 1/3] fix: gsoc listner node selection --- pkg/check/gsoc/gsoc.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pkg/check/gsoc/gsoc.go b/pkg/check/gsoc/gsoc.go index db32b81a0..bde81e660 100644 --- a/pkg/check/gsoc/gsoc.go +++ b/pkg/check/gsoc/gsoc.go @@ -121,7 +121,9 @@ func run(ctx context.Context, uploadClient *bee.Client, listenClient *bee.Client if err != nil { return err } - resourceId, socAddress, err := mineResourceId(ctx, addresses.Overlay, privKey, 1) + depth := 6 + logger.Infof("gsoc: mining resource id for overlay=%s, depth=%d", addresses.Overlay, depth) + resourceId, socAddress, err := mineResourceId(ctx, addresses.Overlay, privKey, depth) if err != nil { return err } @@ -169,7 +171,7 @@ func run(ctx context.Context, uploadClient *bee.Client, listenClient *bee.Client } select { - case <-time.After(1 * time.Minute): + case <-time.After(3 * time.Minute): return fmt.Errorf("timeout: not all messages received") case <-done: } From f9047a30bb0db52c87ee10cc140399aae620cfbf Mon Sep 17 00:00:00 2001 From: Acha Bill Date: Mon, 3 Mar 2025 08:24:37 -0500 Subject: [PATCH 2/3] chore: add pss timeout --- pkg/check/pss/pss.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/check/pss/pss.go b/pkg/check/pss/pss.go index 0b54a65de..2eead6338 100644 --- a/pkg/check/pss/pss.go +++ b/pkg/check/pss/pss.go @@ -139,7 +139,7 @@ func (c *Check) testPss(nodeAName, nodeBName string, clients map[string]*bee.Cli for { select { - case <-time.After(1 * time.Minute): + case <-time.After(3 * time.Minute): return fmt.Errorf("correct message not received after %s", 1*time.Minute) case msg, ok := <-ch: if !ok { From d4802414b3074405957603411c5f7788c73103fa Mon Sep 17 00:00:00 2001 From: Acha Bill Date: Tue, 4 Mar 2025 14:51:45 -0500 Subject: [PATCH 3/3] chore: rename --- pkg/check/gsoc/gsoc.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/check/gsoc/gsoc.go b/pkg/check/gsoc/gsoc.go index bde81e660..2c354ecf2 100644 --- a/pkg/check/gsoc/gsoc.go +++ b/pkg/check/gsoc/gsoc.go @@ -121,9 +121,9 @@ func run(ctx context.Context, uploadClient *bee.Client, listenClient *bee.Client if err != nil { return err } - depth := 6 - logger.Infof("gsoc: mining resource id for overlay=%s, depth=%d", addresses.Overlay, depth) - resourceId, socAddress, err := mineResourceId(ctx, addresses.Overlay, privKey, depth) + prefixMatchDepth := 6 + logger.Infof("gsoc: mining resource id for overlay=%s, prefixMatchDepth=%d", addresses.Overlay, prefixMatchDepth) + resourceId, socAddress, err := mineResourceId(ctx, addresses.Overlay, privKey, prefixMatchDepth) if err != nil { return err }