feat: Prevent multiple instances of "ipfs routing reprovide" running …

…at the same time
ipfs · Feb 5, 2025 · ca1fabf · ca1fabf
1 parent 7c1f0a3
commit ca1fabf
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -18,6 +18,8 @@ The following emojis are used to highlight certain changes:
 
 ### Changed
 
+- `provider`: Prevent multiple instances of reprovider.Reprovide() from running at the same time.
+
 ### Removed
 
 ### Fixed

diff --git a/provider/reprovider.go b/provider/reprovider.go
@@ -42,6 +42,7 @@ type reprovider struct {
 	ctx     context.Context
 	close   context.CancelFunc
 	closewg sync.WaitGroup
+	mu      sync.Mutex
 
 	reprovideInterval        time.Duration
 	initalReprovideDelay     time.Duration
@@ -470,6 +471,12 @@ func (s *reprovider) reprovide(ctx context.Context, force bool) error {
 		return nil
 	}
 
+	ok := s.mu.TryLock()
+	if !ok {
+		return fmt.Errorf("instance of reprovide already running")
+	}
+	defer s.mu.Unlock()
+
 	kch, err := s.keyProvider(ctx)
 	if err != nil {
 		return err