Skip to content

Commit d5c2df1

Browse files
provider: integration tests (#1127)
* provider: adding provide and reprovide queue * provider: network operations * add some tests * schedule prefix len computations * provider schedule * provider: handleProvide * addressed review * use go-test/random * satisfy linter * log errors during initial prefix len measurement * address review * satisfy linter * address review * provider: explore swarm * provider: batch provide * provider: batch reprovide * provider: catchup pending work * provider: options * provide: handle reprovide * provider: daemon * provider: integration tests * cancel context of external functions + tests * fix panic when adding key to trie if superstring already exists * address review * decrease minimal region size from replicationFactor+1 to replicationFactor * simplify unscheduleSubsumedPrefixesNoClock * address review * fix test to match region size (now: replicationFactor, before: replicationFactor+1) * dequeue outside of go routine * fix tests * close connectivity * fix waitgroup
1 parent f0631c4 commit d5c2df1

File tree

2 files changed

+432
-2
lines changed

2 files changed

+432
-2
lines changed

provider/provider.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -897,7 +897,7 @@ func (s *SweepingProvider) handleReprovide() {
897897

898898
s.wg.Add(1)
899899
go func() {
900-
if err := s.workerPool.Acquire(periodicWorker); err != nil {
900+
if err := s.workerPool.Acquire(periodicWorker); err == nil {
901901
s.batchReprovide(currentPrefix, true)
902902
s.workerPool.Release(periodicWorker)
903903
}
@@ -1319,7 +1319,6 @@ func (s *SweepingProvider) provideRegions(regions []keyspace.Region, addrInfo pe
13191319
continue
13201320
}
13211321
s.provideCounter.Add(s.ctx, int64(len(allKeys)))
1322-
13231322
}
13241323
// If at least 1 regions was provided, we don't consider it a failure.
13251324
return errCount < len(regions)

0 commit comments

Comments
 (0)