Skip to content

Commit 2c6e7b5

Browse files
authored
fix: gsoc listner node selection (#467)
* fix: gsoc listner node selection * chore: add pss timeout * chore: rename
1 parent 729dd43 commit 2c6e7b5

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

pkg/check/gsoc/gsoc.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,9 @@ func run(ctx context.Context, uploadClient *bee.Client, listenClient *bee.Client
121121
if err != nil {
122122
return err
123123
}
124-
resourceId, socAddress, err := mineResourceId(ctx, addresses.Overlay, privKey, 1)
124+
prefixMatchDepth := 6
125+
logger.Infof("gsoc: mining resource id for overlay=%s, prefixMatchDepth=%d", addresses.Overlay, prefixMatchDepth)
126+
resourceId, socAddress, err := mineResourceId(ctx, addresses.Overlay, privKey, prefixMatchDepth)
125127
if err != nil {
126128
return err
127129
}
@@ -169,7 +171,7 @@ func run(ctx context.Context, uploadClient *bee.Client, listenClient *bee.Client
169171
}
170172

171173
select {
172-
case <-time.After(1 * time.Minute):
174+
case <-time.After(3 * time.Minute):
173175
return fmt.Errorf("timeout: not all messages received")
174176
case <-done:
175177
}

pkg/check/pss/pss.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ func (c *Check) testPss(nodeAName, nodeBName string, clients map[string]*bee.Cli
139139

140140
for {
141141
select {
142-
case <-time.After(1 * time.Minute):
142+
case <-time.After(3 * time.Minute):
143143
return fmt.Errorf("correct message not received after %s", 1*time.Minute)
144144
case msg, ok := <-ch:
145145
if !ok {

0 commit comments

Comments
 (0)