Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
57 commits
Select commit Hold shift + click to select a range
8b2979b
provider: adding provide and reprovide queue
guillaumemichel Jul 24, 2025
4049cfd
Merge branch 'provider' into provider-queues
guillaumemichel Jul 24, 2025
fac928e
provider: network operations
guillaumemichel Jul 24, 2025
87c3d14
add some tests
guillaumemichel Jul 24, 2025
7b681e5
schedule prefix len computations
guillaumemichel Jul 24, 2025
a191032
provider schedule
guillaumemichel Jul 24, 2025
41fcb41
provider: handleProvide
guillaumemichel Jul 24, 2025
4081f02
addressed review
guillaumemichel Aug 5, 2025
83e6f59
Merge branch 'provider' into provider-queues
guillaumemichel Aug 5, 2025
db73ea4
use go-test/random
guillaumemichel Aug 5, 2025
e0ece0a
satisfy linter
guillaumemichel Aug 5, 2025
039e0a4
Merge branch 'provider-queues' into provider-network-ops
guillaumemichel Aug 5, 2025
47f82bf
Merge branch 'provider' into provider-network-ops
guillaumemichel Aug 5, 2025
c707b63
Merge branch 'provider-network-ops' into provider-prefixlen
guillaumemichel Aug 5, 2025
fd95218
log errors during initial prefix len measurement
guillaumemichel Aug 5, 2025
b117913
Merge branch 'provider' into provider-prefixlen
guillaumemichel Aug 5, 2025
c8c4bc3
Merge branch 'provider-prefixlen' into provider-schedule
guillaumemichel Aug 5, 2025
fbe5f8a
address review
guillaumemichel Aug 5, 2025
e1ddf61
satisfy linter
guillaumemichel Aug 5, 2025
634601e
Merge branch 'provider-schedule' into provider-handleProvide
guillaumemichel Aug 5, 2025
834802b
address review
guillaumemichel Aug 5, 2025
5fa93f1
provider: explore swarm
guillaumemichel Aug 6, 2025
2889495
provider: batch provide
guillaumemichel Aug 6, 2025
47f65cb
provider: batch reprovide
guillaumemichel Aug 6, 2025
facff54
provider: catchup pending work
guillaumemichel Aug 6, 2025
d1fc1c5
provider: options
guillaumemichel Aug 6, 2025
fc3ea16
provide: handle reprovide
guillaumemichel Aug 6, 2025
2727bba
provider: daemon
guillaumemichel Aug 6, 2025
67f7ffb
provider: integration tests
guillaumemichel Aug 6, 2025
3a97a4f
cancel context of external functions + tests
guillaumemichel Aug 7, 2025
b9f9004
fix panic when adding key to trie if superstring already exists
guillaumemichel Aug 7, 2025
17335b6
address review
guillaumemichel Aug 8, 2025
31a1797
decrease minimal region size from replicationFactor+1 to replicationF…
guillaumemichel Aug 8, 2025
b64abe5
simplify unscheduleSubsumedPrefixesNoClock
guillaumemichel Aug 8, 2025
486a39c
Merge branch 'provider' into provider-prefixlen
guillaumemichel Aug 8, 2025
59c9e9a
Merge branch 'provider-prefixlen' into provider-schedule
guillaumemichel Aug 8, 2025
48a0033
Merge branch 'provider-schedule' into provider-handleProvide
guillaumemichel Aug 8, 2025
425565a
address review
guillaumemichel Aug 8, 2025
6900ec9
Merge branch 'provider-handleProvide' into provider-exploreSwarm
guillaumemichel Aug 8, 2025
1299170
Merge branch 'provider-exploreSwarm' into provider-batchProvide
guillaumemichel Aug 8, 2025
4111c0c
Merge branch 'provider-batchProvide' into provider-batchReprovide
guillaumemichel Aug 8, 2025
d318fae
fix test to match region size (now: replicationFactor, before: replic…
guillaumemichel Aug 8, 2025
79e38d9
Merge branch 'provider-exploreSwarm' into provider-batchProvide
guillaumemichel Aug 8, 2025
bbfba3d
Merge branch 'provider-batchProvide' into provider-batchReprovide
guillaumemichel Aug 8, 2025
ca41e17
dequeue outside of go routine
guillaumemichel Aug 8, 2025
52712c5
Merge branch 'provider-batchReprovide' into provider-catchupPendingWork
guillaumemichel Aug 8, 2025
6df6495
Merge branch 'provider-catchupPendingWork' into provider-options
guillaumemichel Aug 8, 2025
489dee6
Merge branch 'provider-options' into provider-handleReprovide
guillaumemichel Aug 8, 2025
4df4b80
Merge branch 'provider-handleReprovide' into provider-run
guillaumemichel Aug 8, 2025
54802b2
Merge branch 'provider-run' into provider-integrationTests
guillaumemichel Aug 8, 2025
c9c7faa
fix tests
guillaumemichel Aug 8, 2025
8ee0ece
close connectivity
guillaumemichel Aug 13, 2025
8bc762d
fixing conflicts
guillaumemichel Aug 13, 2025
1940029
Merge branch 'provider' into provider-run
guillaumemichel Aug 13, 2025
e1af44b
Merge branch 'provider-run' into provider-integrationTests
guillaumemichel Aug 13, 2025
81bf0c2
Merge branch 'provider' into provider-integrationTests
guillaumemichel Aug 13, 2025
b0e0039
fix waitgroup
guillaumemichel Aug 13, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 1 addition & 2 deletions provider/provider.go
Original file line number Diff line number Diff line change
Expand Up @@ -897,7 +897,7 @@ func (s *SweepingProvider) handleReprovide() {

s.wg.Add(1)
go func() {
if err := s.workerPool.Acquire(periodicWorker); err != nil {
if err := s.workerPool.Acquire(periodicWorker); err == nil {
s.batchReprovide(currentPrefix, true)
s.workerPool.Release(periodicWorker)
}
Expand Down Expand Up @@ -1319,7 +1319,6 @@ func (s *SweepingProvider) provideRegions(regions []keyspace.Region, addrInfo pe
continue
}
s.provideCounter.Add(s.ctx, int64(len(allKeys)))

}
// If at least 1 regions was provided, we don't consider it a failure.
return errCount < len(regions)
Expand Down
Loading
Loading